/external/chromium_org/device/hid/ |
H A D | hid_connection_linux.cc | 161 ssize_t bytes_read = HANDLE_EINTR( local 163 if (bytes_read < 0) { 173 bytes_read++; 176 ProcessInputReport(buffer, bytes_read);
|
/external/chromium_org/device/serial/ |
H A D | serial_io_handler.cc | 113 void SerialIoHandler::ReadCompleted(int bytes_read, argument 119 pending_read_buffer->Done(bytes_read); 121 pending_read_buffer->DoneWithError(bytes_read, error); 168 void SerialIoHandler::QueueReadCompleted(int bytes_read, argument 172 base::Bind(&SerialIoHandler::ReadCompleted, this, bytes_read, error));
|
/external/chromium_org/extensions/browser/api/sockets_tcp/ |
H A D | tcp_socket_event_dispatcher.cc | 115 int bytes_read, 119 // If |bytes_read| == 0, the connection has been closed by the peer. 120 // If |bytes_read| < 0, there was a network error, and |bytes_read| is a value 123 if (bytes_read == 0) { 124 bytes_read = net::ERR_CONNECTION_CLOSED; 127 if (bytes_read > 0) { 131 receive_info.data = std::string(io_buffer->data(), bytes_read); 144 } else if (bytes_read == net::ERR_IO_PENDING) { 152 receive_error_info.result_code = bytes_read; 113 ReadCallback( const ReadParams& params, int bytes_read, scoped_refptr<net::IOBuffer> io_buffer) argument [all...] |
/external/chromium_org/extensions/browser/api/sockets_udp/ |
H A D | udp_socket_event_dispatcher.cc | 100 int bytes_read, 106 // If |bytes_read| == 0, the message contained no data. 107 // If |bytes_read| < 0, there was a network error, and |bytes_read| is a value 110 if (bytes_read >= 0) { 114 receive_info.data = std::string(io_buffer->data(), bytes_read); 129 } else if (bytes_read == net::ERR_IO_PENDING) { 137 receive_error_info.result_code = bytes_read; 98 ReceiveCallback( const ReceiveParams& params, int bytes_read, scoped_refptr<net::IOBuffer> io_buffer, const std::string& address, int port) argument
|
/external/chromium_org/media/audio/ |
H A D | audio_device_thread.cc | 168 size_t bytes_read = socket_.Receive(&pending_data, sizeof(pending_data)); local 169 if (bytes_read != sizeof(pending_data))
|
/external/chromium_org/mojo/system/ |
H A D | 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/ |
H A D | 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/base/ |
H A D | file_stream_context_win.cc | 67 DWORD bytes_read; local 69 &bytes_read, &io_context_.overlapped)) { 133 DWORD bytes_read, 154 result = bytes_read; 155 IncrementOffset(&io_context_.overlapped, bytes_read); 131 OnIOCompleted( base::MessageLoopForIO::IOContext* context, DWORD bytes_read, DWORD error) argument
|
/external/chromium_org/net/quic/ |
H A D | 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) << [all...] |
/external/chromium_org/net/socket/ |
H A D | 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;
|
H A D | 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;
|
/external/chromium_org/net/spdy/ |
H A D | 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/ |
H A D | 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/ |
H A D | quic_server.cc | 220 int bytes_read = local 225 if (bytes_read < 0) { 229 QuicEncryptedPacket packet(buf, bytes_read, false);
|
H A D | 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/tests/ |
H A D | test_host_resolver.cc | 60 int32_t* bytes_read) { 66 *bytes_read = callback.result(); 57 SyncRead(pp::TCPSocket* socket, char* buffer, int32_t num_bytes, int32_t* bytes_read) argument
|
H A D | test_host_resolver_private.cc | 74 int32_t* bytes_read) { 80 *bytes_read = callback.result(); 71 SyncRead(pp::TCPSocketPrivate* socket, char* buffer, int32_t num_bytes, int32_t* bytes_read) argument
|
/external/chromium_org/remoting/host/ |
H A D | token_validator_base.cc | 85 int bytes_read = 0; local 86 request_->Read(buffer_.get(), kBufferSize, &bytes_read); 87 OnReadCompleted(request_.get(), bytes_read); 91 int bytes_read) { 95 if (!request_->status().is_success() || bytes_read <= 0) 98 data_.append(buffer_->data(), bytes_read); 99 } while (request_->Read(buffer_.get(), kBufferSize, &bytes_read)); 90 OnReadCompleted(net::URLRequest* source, int bytes_read) argument
|
/external/chromium_org/storage/browser/fileapi/ |
H A D | file_system_dir_url_request_job.cc | 49 int *bytes_read) { 55 *bytes_read = count; 48 ReadRawData(net::IOBuffer* dest, int dest_size, int *bytes_read) argument
|
/external/chromium_org/third_party/sfntly/cpp/src/sample/chromium/ |
H A D | chrome_subsetter.cc | 57 size_t bytes_read = fread(&((*input_buffer)[0]), 1, file_size, input_file); local 59 return bytes_read == file_size;
|
/external/chromium_org/third_party/sfntly/cpp/src/sfntly/data/ |
H A D | byte_array.cc | 111 int32_t bytes_read = 0; local 115 while ((bytes_read = 117 int bytes_written = array->Put(index + dst_offset, &(b[0]), 0, bytes_read); 119 index += bytes_read; 120 remaining_length -= bytes_read; 132 int32_t bytes_read = 0; local 135 while ((bytes_read = Get(index + offset, &(b[0]), 0, buffer_length)) > 0) { 136 os->Write(&b, 0, bytes_read); 137 index += bytes_read; 145 int32_t bytes_read local 165 int32_t bytes_read = 0; local [all...] |
H A D | font_input_stream.cc | 86 int32_t bytes_read = stream_->Read(b, offset, bytes_to_read); local 87 position_ += bytes_read; 88 return bytes_read;
|
/external/chromium_org/third_party/webrtc/system_wrappers/source/ |
H A D | file_impl.cc | 198 int bytes_read = static_cast<int>(fread(buf, 1, length, id_)); local 199 if (bytes_read != length && !looping_) { 202 return bytes_read;
|
/external/chromium_org/third_party/webrtc/test/ |
H A D | fake_audio_device.cc | 100 int bytes_read = file_utility_->ReadPCMData( local 102 if (bytes_read <= 0) 104 int num_samples = bytes_read / 2; // 2 bytes per sample.
|
/external/lldb/source/API/ |
H A D | SBCommunication.cpp | 147 size_t bytes_read = 0; local 149 bytes_read = m_opaque->Read (dst, dst_len, timeout_usec, status, NULL); 160 (uint64_t)bytes_read); 161 return bytes_read;
|