| /external/chromium_org/components/nacl/loader/ |
| nacl_ipc_adapter_unittest.cc | 89 int bytes_read = BlockingReceive(buf, kBufSize); local
91 static_cast<size_t>(bytes_read));
195 int bytes_read = BlockingReceive(buf, bytes_requested); local
196 ASSERT_EQ(bytes_requested, bytes_read);
199 bytes_read += BlockingReceive(&buf[bytes_requested],
202 static_cast<size_t>(bytes_read));
212 bytes_read = BlockingReceive(buf, kBufSize);
214 static_cast<size_t>(bytes_read));
|
| /external/chromium_org/content/browser/streams/ |
| stream_unittest.cc | 52 int bytes_read = 0; local
55 stream->ReadRawData(buffer.get(), kBufferSize, &bytes_read);
73 buffer_->SetCapacity(old_capacity + bytes_read);
75 buffer->data(), bytes_read);
|
| /external/chromium_org/device/serial/ |
| serial_io_handler_posix.cc | 175 int bytes_read = HANDLE_EINTR(read(file().GetPlatformFile(), local
178 if (bytes_read < 0) {
184 } else if (bytes_read == 0) {
187 ReadCompleted(bytes_read, serial::RECEIVE_ERROR_NONE);
|
| /external/chromium_org/google_apis/gcm/engine/ |
| connection_handler_impl.cc | 346 int bytes_read = prev_byte_count - input_stream_->UnreadByteCount(); local
347 DCHECK_EQ(bytes_read, 1);
348 input_stream_->BackUp(bytes_read);
|
| /external/chromium_org/ipc/ |
| ipc_channel_nacl.cc | 47 int bytes_read = imc_recvmsg(pipe, &msg, 0); local
49 if (bytes_read <= 0) {
56 DCHECK(bytes_read);
58 contents->data.resize(bytes_read);
318 int* bytes_read) {
319 *bytes_read = 0;
324 while (!read_queue_.empty() && *bytes_read < buffer_len) {
326 size_t bytes_to_read = buffer_len - *bytes_read;
329 std::copy(vec->begin(), vec->end(), buffer + *bytes_read);
330 *bytes_read += vec->size()
[all...] |
| /external/chromium_org/media/cdm/ppapi/ |
| cdm_file_io_impl.cc | 331 void CdmFileIOImpl::OnFileRead(int32_t bytes_read) {
332 CDM_DLOG() << __FUNCTION__ << ": " << bytes_read; local
336 // 0 |bytes_read| indicates end-of-file reached.
337 if (bytes_read < PP_OK) {
344 PP_DCHECK(static_cast<size_t>(bytes_read) <= io_buffer_.size());
345 // Append |bytes_read| in |io_buffer_| to |cumulative_read_buffer_|.
348 io_buffer_.begin() + bytes_read);
349 io_offset_ += bytes_read;
352 if (bytes_read > 0) {
|
| /external/chromium_org/mojo/system/ |
| multiprocess_message_pipe_unittest.cc | 455 size_t bytes_read = fread(&fread_buffer[0], 1, fread_buffer.size(), fp.get()); local
456 fread_buffer.resize(bytes_read);
|
| /external/chromium_org/native_client_sdk/src/tests/nacl_io_test/ |
| filesystem_test.cc | 387 int bytes_read = 0; local
389 0, dev_urandom->Read(attrs, &buffer[0], kSampleBatchSize, &bytes_read));
390 EXPECT_EQ(kSampleBatchSize, bytes_read);
392 for (int i = 0; i < bytes_read; ++i) {
|
| /external/chromium_org/net/quic/ |
| quic_data_stream_test.cc | 221 size_t bytes_read = stream_->Readv(&vec, 1); local
222 EXPECT_EQ(headers.length(), bytes_read);
223 EXPECT_EQ(headers, string(buffer, bytes_read));
225 bytes_read = stream_->Readv(&vec, 1);
226 EXPECT_EQ(body.length(), bytes_read);
227 EXPECT_EQ(body, string(buffer, bytes_read));
248 size_t bytes_read = stream_->Readv(&vec, 1); local
249 ASSERT_EQ(1u, bytes_read);
274 size_t bytes_read = stream_->Readv(vec, 2); local
275 ASSERT_EQ(2u, bytes_read) << i
[all...] |
| /external/chromium_org/net/socket/ |
| tcp_server_socket_unittest.cc | 231 size_t bytes_read = 0; local
232 while (bytes_read < message.size()) {
234 new IOBufferWithSize(message.size() - bytes_read));
240 ASSERT_TRUE(bytes_read + read_result <= message.size());
241 memmove(&buffer[bytes_read], read_buffer->data(), read_result);
242 bytes_read += read_result;
|
| tcp_socket_unittest.cc | 267 size_t bytes_read = 0; local
268 while (bytes_read < message.size()) {
270 new IOBufferWithSize(message.size() - bytes_read));
276 ASSERT_TRUE(bytes_read + read_result <= message.size());
277 memmove(&buffer[bytes_read], read_buffer->data(), read_result);
278 bytes_read += read_result;
|
| transport_client_socket_unittest.cc | 144 uint32 bytes_read = 0; local
146 while (bytes_read < bytes_to_read) {
154 bytes_read += rv;
157 return static_cast<int>(bytes_read);
212 uint32 bytes_read; local
229 bytes_read = DrainClientSocket(buf.get(), 1, 1, &callback);
230 ASSERT_EQ(bytes_read, 1u);
237 bytes_read = DrainClientSocket(
239 ASSERT_EQ(bytes_read, arraysize(kServerReply) - 2);
250 bytes_read = DrainClientSocket(buf.get(), 1, 1, &callback)
285 uint32 bytes_read = DrainClientSocket( local
310 uint32 bytes_read = 0; local
[all...] |
| /external/chromium_org/net/spdy/ |
| buffered_spdy_framer_unittest.cc | 145 size_t bytes_read = local
148 buffered_spdy_framer_.ProcessInput(input_ptr, bytes_read);
|
| /external/chromium_org/net/tools/flip_server/ |
| ring_buffer.cc | 110 int bytes_read = 0; local
116 memcpy(bytes + bytes_read, rptr, rsize);
117 bytes_read += rsize;
122 return bytes_read;
|
| /external/chromium_org/net/tools/quic/ |
| quic_server.cc | 220 int bytes_read = local
225 if (bytes_read < 0) {
229 QuicEncryptedPacket packet(buf, bytes_read, false);
|
| quic_socket_utils.cc | 126 int bytes_read = recvmsg(fd, &hdr, 0); local
130 if (bytes_read < 0 && errno != 0) {
154 return bytes_read;
|
| /external/chromium_org/ppapi/proxy/ |
| audio_input_resource.cc | 256 size_t bytes_read = socket_->Receive(&pending_data, sizeof(pending_data)); local
257 if (bytes_read != sizeof(pending_data)) {
258 DCHECK_EQ(bytes_read, 0U);
|
| /external/chromium_org/ppapi/tests/ |
| test_flash_file.cc | 59 DWORD bytes_read = 0; local
61 result = !!::ReadFile(file_handle, buffer, kBufferSize, &bytes_read, NULL);
62 if (result && bytes_read > 0)
63 contents->append(buffer, bytes_read);
64 } while (result && bytes_read > 0);
67 ssize_t bytes_read = 0; local
70 bytes_read = read(file_handle, buffer, kBufferSize);
71 } while (bytes_read == -1 && errno == EINTR);
72 result = bytes_read != -1;
73 if (bytes_read > 0
[all...] |
| /external/chromium_org/storage/browser/fileapi/ |
| native_file_util.cc | 55 int bytes_read = infile.ReadAtCurrentPos(&buffer[0], kBufferSize); local
56 if (bytes_read < 0)
58 if (bytes_read == 0)
60 for (int bytes_written = 0; bytes_written < bytes_read; ) {
62 &buffer[bytes_written], bytes_read - bytes_written);
|
| /external/chromium_org/third_party/libjingle/source/talk/media/devices/ |
| filevideocapturer.cc | 285 size_t bytes_read; local
289 &bytes_read,
292 << ", bytes read = " << bytes_read << ", error = " << error;
294 if (CapturedFrame::kFrameHeaderSize != bytes_read) {
|
| /external/chromium_org/tools/android/heap_profiler/ |
| heap_dump.c | 236 size_t bytes_read = 0; local
241 res = read(fd, buf + bytes_read, count - bytes_read);
245 bytes_read += res;
246 } while (bytes_read < count);
247 return bytes_read ? bytes_read : res;
|
| /external/chromium_org/tools/gn/ |
| function_exec_script.cc | 125 DWORD bytes_read = 0; local
126 BOOL success = ReadFile(out_read, buffer, kBufferSize, &bytes_read, NULL);
127 if (!success || bytes_read == 0)
129 std_out->append(buffer, bytes_read);
215 ssize_t bytes_read = 0; local
218 bytes_read = HANDLE_EINTR(read(pipe_fd[0], buffer, sizeof(buffer)));
219 if (bytes_read <= 0)
221 std_out->append(buffer, bytes_read);
|
| /external/chromium_org/tools/win/split_link/ |
| split_link.cc | 192 DWORD bytes_read = 0; local
193 if (!ReadFile(file, buffer, *length, &bytes_read, NULL))
|
| /external/e2fsprogs/lib/quota/ |
| quotaio.c | 178 unsigned int bytes_read = 0; local
187 err = ext2fs_file_read(e2_file, buf, size, &bytes_read);
193 return bytes_read;
|
| /external/lldb/source/Core/ |
| Communication.cpp | 353 size_t bytes_read = comm->ReadFromConnection (buf, sizeof(buf), 5 * TimeValue::MicroSecPerSec, status, &error); local
354 if (bytes_read > 0)
355 comm->AppendBytesToCache (buf, bytes_read, true, status);
356 else if ((bytes_read == 0)
361 comm->AppendBytesToCache (buf, bytes_read, true, status);
|
