| /external/chromium_org/chrome/browser/extensions/api/socket/ |
| D | udp_socket.cc | 93 scoped_refptr<net::IOBuffer> io_buffer; in Read() local
105 io_buffer = new net::IOBuffer(count); in Read()
106 result = socket_.Read(io_buffer.get(), count, in Read()
108 io_buffer)); in Read()
112 OnReadComplete(io_buffer, result); in Read()
115 int UDPSocket::WriteImpl(net::IOBuffer* io_buffer, in WriteImpl() argument
121 return socket_.Write(io_buffer, io_buffer_size, callback); in WriteImpl()
136 scoped_refptr<net::IOBuffer> io_buffer; in RecvFrom() local
149 io_buffer = new net::IOBuffer(count); in RecvFrom()
152 io_buffer.get(), in RecvFrom()
[all …]
|
| D | socket.h | 30 typedef base::Callback<void(int, scoped_refptr<net::IOBuffer> io_buffer)>
33 void(int, scoped_refptr<net::IOBuffer> io_buffer, const std::string&, int)>
61 void Write(scoped_refptr<net::IOBuffer> io_buffer,
67 virtual void SendTo(scoped_refptr<net::IOBuffer> io_buffer,
100 virtual int WriteImpl(net::IOBuffer* io_buffer,
115 WriteRequest(scoped_refptr<net::IOBuffer> io_buffer,
119 scoped_refptr<net::IOBuffer> io_buffer; member
|
| D | socket.cc | 39 void Socket::Write(scoped_refptr<net::IOBuffer> io_buffer, in Write() argument
43 write_queue_.push(WriteRequest(io_buffer, byte_count, callback)); in Write()
56 request.io_buffer->data() + request.bytes_written); in WriteData()
144 Socket::WriteRequest::WriteRequest(scoped_refptr<net::IOBuffer> io_buffer, in WriteRequest() argument
147 : io_buffer(io_buffer), in WriteRequest()
|
| D | tcp_socket.cc | 158 scoped_refptr<net::IOBuffer> io_buffer = new net::IOBuffer(count); in Read() local
159 int result = socket_->Read(io_buffer.get(), count, in Read()
161 io_buffer)); in Read()
164 OnReadComplete(io_buffer, result); in Read()
172 void TCPSocket::SendTo(scoped_refptr<net::IOBuffer> io_buffer, in SendTo() argument
264 int TCPSocket::WriteImpl(net::IOBuffer* io_buffer, in WriteImpl() argument
272 return socket_->Write(io_buffer, io_buffer_size, callback); in WriteImpl()
291 void TCPSocket::OnReadComplete(scoped_refptr<net::IOBuffer> io_buffer, in OnReadComplete() argument
294 read_callback_.Run(result, io_buffer); in OnReadComplete()
|
| D | udp_socket.h | 30 virtual void SendTo(scoped_refptr<net::IOBuffer> io_buffer,
53 virtual int WriteImpl(net::IOBuffer* io_buffer,
61 void OnReadComplete(scoped_refptr<net::IOBuffer> io_buffer,
63 void OnRecvFromComplete(scoped_refptr<net::IOBuffer> io_buffer,
|
| D | tcp_socket_unittest.cc | 62 scoped_refptr<net::IOBuffer> io_buffer));
104 scoped_refptr<net::IOBufferWithSize> io_buffer( in TEST() local
106 socket->Write(io_buffer.get(), io_buffer->size(), in TEST()
123 scoped_refptr<net::IOBufferWithSize> io_buffer(new net::IOBufferWithSize(42)); in TEST() local
124 socket->Write(io_buffer.get(), io_buffer->size(), in TEST()
|
| D | udp_socket_unittest.cc | 28 scoped_refptr<net::IOBuffer> io_buffer, in OnCompleted() argument
104 scoped_refptr<net::IOBuffer> io_buffer) { in OnMulticastReadCompleted() argument
106 EXPECT_EQ(0, strncmp(io_buffer->data(), test_message, test_message_length)); in OnMulticastReadCompleted()
|
| D | tcp_socket.h | 41 virtual void SendTo(scoped_refptr<net::IOBuffer> io_buffer,
67 virtual int WriteImpl(net::IOBuffer* io_buffer,
74 void OnReadComplete(scoped_refptr<net::IOBuffer> io_buffer,
|
| /external/chromium_org/chrome/browser/extensions/api/cast_channel/ |
| D | cast_socket.cc | 390 VLOG(1) << "WriteData byte_count = " << request.io_buffer->size() in WriteData()
391 << " bytes_written " << request.io_buffer->BytesConsumed(); in WriteData()
395 request.io_buffer.get(), in WriteData()
396 request.io_buffer->BytesRemaining(), in WriteData()
412 scoped_refptr<net::DrainableIOBuffer> io_buffer = request.io_buffer; in OnWriteData() local
415 io_buffer->DidConsume(result); in OnWriteData()
416 if (io_buffer->BytesRemaining() > 0) { in OnWriteData()
417 VLOG(1) << "OnWriteComplete size = " << io_buffer->size() in OnWriteData()
418 << " consumed " << io_buffer->BytesConsumed() in OnWriteData()
419 << " remaining " << io_buffer->BytesRemaining() in OnWriteData()
[all …]
|
| /external/chromium_org/net/dns/ |
| D | dns_query_unittest.cc | 44 ASSERT_EQ(static_cast<int>(sizeof(query_data)), q1.io_buffer()->size()); in TEST()
45 EXPECT_EQ(0, memcmp(q1.io_buffer()->data(), query_data, sizeof(query_data))); in TEST()
62 EXPECT_EQ(q1.io_buffer()->size(), q2->io_buffer()->size()); in TEST()
|
| D | dns_response_unittest.cc | 208 memcpy(resp.io_buffer()->data(), response_data, sizeof(response_data)); in TEST()
211 EXPECT_FALSE(resp.InitParse(query->io_buffer()->size() - 1, *query)); in TEST()
250 memcpy(resp.io_buffer()->data(), kT0ResponseDatagram, in TEST()
301 memcpy(resp.io_buffer()->data(), response_data, sizeof(response_data)); in TEST()
359 memcpy(resp.io_buffer()->data(), response_data, sizeof(response_data)); in TEST()
390 memcpy(resp.io_buffer()->data(), response_data, sizeof(response_data)); in TEST()
|
| D | dns_transaction.cc | 221 return socket()->Write(query_->io_buffer(), in DoSendQuery()
222 query_->io_buffer()->size(), in DoSendQuery()
233 if (rv != query_->io_buffer()->size()) in DoSendQueryComplete()
243 return socket()->Read(response_->io_buffer(), in DoReadResponse()
244 response_->io_buffer()->size(), in DoReadResponse()
391 WriteBigEndian<uint16>(length_buffer_->data(), query_->io_buffer()->size()); in DoConnectComplete()
411 buffer_ = new DrainableIOBuffer(query_->io_buffer(), in DoSendLength()
412 query_->io_buffer()->size()); in DoSendLength()
451 if (response_length_ < query_->io_buffer()->size()) in DoReadLength()
455 buffer_ = new DrainableIOBuffer(response_->io_buffer(), response_length_); in DoReadLength()
|
| D | dns_test_util.cc | 99 char* buffer = response.io_buffer()->data(); in Finish()
100 int nbytes = query.io_buffer()->size(); in Finish()
101 memcpy(buffer, query.io_buffer()->data(), nbytes); in Finish()
|
| D | dns_query.cc | 75 io_buffer_ = new IOBufferWithSize(orig.io_buffer()->size()); in DnsQuery()
76 memcpy(io_buffer_.get()->data(), orig.io_buffer()->data(), in DnsQuery()
|
| D | dns_transaction_unittest.cc | 47 *length = base::HostToNet16(query_->io_buffer()->size()); in DnsSocketData()
54 query_->io_buffer()->data(), in DnsSocketData()
55 query_->io_buffer()->size())); in DnsSocketData()
74 response->io_buffer()->data(), in AddResponseWithLength()
75 response->io_buffer()->size())); in AddResponseWithLength()
81 uint16 tcp_length = response->io_buffer()->size(); in AddResponse()
95 new DnsResponse(query_->io_buffer()->data(), in AddRcode()
96 query_->io_buffer()->size(), in AddRcode()
99 reinterpret_cast<dns_protocol::Header*>(response->io_buffer()->data()); in AddRcode()
|
| D | dns_query.h | 39 IOBufferWithSize* io_buffer() const { return io_buffer_.get(); } in io_buffer() function
|
| /external/chromium_org/net/spdy/ |
| D | spdy_buffer_unittest.cc | 113 scoped_refptr<IOBuffer> io_buffer = buffer.GetIOBufferForRemainingData(); in TEST_F() local
116 EXPECT_EQ(expectedData, std::string(io_buffer->data(), io_buffer_size)); in TEST_F()
119 EXPECT_EQ(expectedData, std::string(io_buffer->data(), io_buffer_size)); in TEST_F()
127 scoped_refptr<IOBuffer> io_buffer = buffer->GetIOBufferForRemainingData(); in TEST_F() local
132 std::memcpy(io_buffer->data(), kData, kDataSize); in TEST_F()
|
| /external/chromium_org/content/browser/streams/ |
| D | stream.cc | 104 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(size)); in AddData() local
105 memcpy(io_buffer->data(), data, size); in AddData()
106 AddData(io_buffer, size); in AddData()
|
| /external/chromium/net/udp/ |
| D | udp_socket_unittest.cc | 58 scoped_refptr<StringIOBuffer> io_buffer(new StringIOBuffer(msg)); in SendToSocket() local
60 new DrainableIOBuffer(io_buffer, length)); in SendToSocket()
93 scoped_refptr<StringIOBuffer> io_buffer(new StringIOBuffer(msg)); in WriteSocket() local
95 new DrainableIOBuffer(io_buffer, length)); in WriteSocket()
|
| /external/chromium_org/webkit/browser/appcache/ |
| D | appcache_response_unittest.cc | 185 void WriteResponseBody(scoped_refptr<IOBuffer> io_buffer, int buf_len) { in WriteResponseBody() argument
187 write_buffer_ = io_buffer; in WriteResponseBody()
195 void ReadResponseBody(scoped_refptr<IOBuffer> io_buffer, int buf_len) { in ReadResponseBody() argument
197 read_buffer_ = io_buffer; in ReadResponseBody()
453 scoped_refptr<IOBuffer> io_buffer( in WriteOneBlock() local
455 FillData(block_number, io_buffer->data(), kBlockSize); in WriteOneBlock()
456 WriteResponseBody(io_buffer, kBlockSize); in WriteOneBlock()
|
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp/ |
| D | tcp_socket_event_dispatcher.cc | 116 scoped_refptr<net::IOBuffer> io_buffer) { in ReadCallback() argument
131 receive_info.data = std::string(io_buffer->data(), bytes_read); in ReadCallback()
|
| /external/chromium_org/chrome/browser/extensions/api/sockets_udp/ |
| D | udp_socket_event_dispatcher.cc | 101 scoped_refptr<net::IOBuffer> io_buffer, in ReceiveCallback() argument
114 receive_info.data = std::string(io_buffer->data(), bytes_read); in ReceiveCallback()
|
| /external/chromium/net/spdy/ |
| D | spdy_http_stream.cc | 359 IOBufferWithSize* io_buffer = new IOBufferWithSize(length); in OnDataReceived() local
360 memcpy(io_buffer->data(), data, length); in OnDataReceived()
361 response_body_.push_back(make_scoped_refptr(io_buffer)); in OnDataReceived()
|
| D | spdy_proxy_client_socket.cc | 453 scoped_refptr<IOBuffer> io_buffer(new IOBuffer(length)); in OnDataReceived() local
454 memcpy(io_buffer->data(), data, length); in OnDataReceived()
456 make_scoped_refptr(new DrainableIOBuffer(io_buffer, length))); in OnDataReceived()
|
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| D | webkit_file_stream_reader_impl_unittest.cc | 143 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(kBufferSize)); in TEST_F() local
145 int result = reader->Read(io_buffer.get(), kBufferSize, callback.callback()); in TEST_F()
|