| /external/chromium/net/http/ |
| D | http_stream_parser.cc | 32 read_buf_(read_buffer), in HttpStreamParser()
114 if (read_buf_->offset() > 0) { in ReadResponseHeaders()
116 result = read_buf_->offset() - read_buf_unused_offset_; in ReadResponseHeaders()
117 read_buf_->set_offset(read_buf_unused_offset_); in ReadResponseHeaders()
347 if (read_buf_->RemainingCapacity() == 0) in DoReadHeaders()
348 read_buf_->SetCapacity(read_buf_->capacity() + kHeaderBufInitialSize); in DoReadHeaders()
352 CHECK(read_buf_->data()); in DoReadHeaders()
354 return connection_->socket()->Read(read_buf_, in DoReadHeaders()
355 read_buf_->RemainingCapacity(), in DoReadHeaders()
369 if (result == ERR_CONNECTION_CLOSED && read_buf_->offset() == 0 && in DoReadHeadersComplete()
[all …]
|
| D | http_response_body_drainer.cc | 28 read_buf_ = new IOBuffer(kDrainBodyBufferSize); in Start()
73 read_buf_, kDrainBodyBufferSize - total_read_, in DoDrainResponseBody()
|
| D | http_basic_stream.cc | 21 : read_buf_(new GrowableIOBuffer()), in HttpBasicStream()
36 read_buf_, net_log)); in InitializeStream()
|
| D | http_transaction_unittest.cc | 180 content_.append(read_buf_->data(), result); in DidRead()
194 read_buf_ = new net::IOBuffer(1024); in Read()
195 int result = trans_->Read(read_buf_, 1024, this); in Read()
|
| D | http_response_body_drainer.h | 54 scoped_refptr<IOBuffer> read_buf_; variable
|
| D | http_cache_transaction.cc | 715 return network_trans_->Read(read_buf_, io_buf_len_, &io_callback_); in DoNetworkRead()
1153 read_buf_ = new IOBuffer(io_buf_len_); in DoCacheReadResponse()
1157 return entry_->disk_entry->ReadData(kResponseInfoIndex, 0, read_buf_, in DoCacheReadResponse()
1166 !HttpCache::ParseResponseInfo(read_buf_->data(), io_buf_len_, in DoCacheReadResponseComplete()
1259 return partial_->CacheRead(entry_->disk_entry, read_buf_, io_buf_len_, in DoCacheReadData()
1264 read_buf_, io_buf_len_, cache_callback_); in DoCacheReadData()
1296 return AppendResponseDataToEntry(read_buf_, num_bytes, cache_callback_); in DoCacheWriteData()
1846 read_buf_ = data; in ReadFromNetwork()
1853 read_buf_ = data; in ReadFromEntry()
|
| D | http_network_transaction.cc | 259 read_buf_ = new IOBuffer(kDrainBodyBufferSize); // A bit bucket. in PrepareForAuthRestart()
333 read_buf_ = buf; in Read()
907 DCHECK(read_buf_); in DoReadBody()
912 return stream_->ReadResponseBody(read_buf_, read_buf_len_, &io_callback_); in DoReadBody()
950 read_buf_ = NULL; in DoReadBodyComplete()
1223 read_buf_ = NULL; in ResetStateForAuthRestart()
|
| D | http_basic_stream.h | 85 scoped_refptr<GrowableIOBuffer> read_buf_;
|
| D | http_stream_parser.h | 148 scoped_refptr<GrowableIOBuffer> read_buf_; variable
|
| D | http_transaction_unittest.h | 141 scoped_refptr<net::IOBuffer> read_buf_; variable
|
| D | http_network_transaction.h | 261 scoped_refptr<IOBuffer> read_buf_; variable
|
| D | http_cache_transaction.h | 354 scoped_refptr<IOBuffer> read_buf_; variable
|
| D | http_network_transaction_unittest.cc | 4294 trans->read_buf_ = new IOBuffer(15); in TEST_F()
4319 EXPECT_TRUE(trans->read_buf_.get() == NULL); in TEST_F()
|
| /external/chromium/net/socket_stream/ |
| D | socket_stream.cc | 67 read_buf_(NULL), in SocketStream()
316 DCHECK(read_buf_); in DidReceiveData()
323 delegate_->OnReceivedData(this, read_buf_->data(), len); in DidReceiveData()
325 read_buf_ = NULL; in DidReceiveData()
364 } else if (result > 0 && read_buf_) { in OnReadCompleted()
886 if (!read_buf_) { in DoReadWrite()
888 read_buf_ = new IOBuffer(kReadBufferSize); in DoReadWrite()
889 result = socket_->Read(read_buf_, kReadBufferSize, &read_callback_); in DoReadWrite()
908 DCHECK(read_buf_); in DoReadWrite()
|
| D | socket_stream.h | 311 scoped_refptr<IOBuffer> read_buf_; variable
|
| /external/chromium/net/udp/ |
| D | udp_socket_libevent.cc | 61 read_buf_ = NULL; in Close()
153 read_buf_ = buf; in RecvFrom()
272 int result = InternalRecvFrom(read_buf_, read_buf_len_, recv_from_address_); in DidCompleteRead()
274 read_buf_ = NULL; in DidCompleteRead()
|
| D | udp_socket_libevent.h | 172 scoped_refptr<IOBuffer> read_buf_; variable
|
| /external/chromium/net/socket/ |
| D | ssl_server_socket_unittest.cc | 55 read_buf_ = buf; in Read()
74 int copied = PropogateData(read_buf_, read_buf_len_); in DoReadCallback()
77 read_buf_ = NULL; in DoReadCallback()
94 scoped_refptr<net::IOBuffer> read_buf_; member in net::__anon3f5d413b0111::FakeDataChannel
|
| D | deterministic_socket_data_unittest.cc | 50 scoped_refptr<IOBuffer> read_buf_; member in net::DeterministicSocketDataTest
69 read_buf_(NULL), in DeterministicSocketDataTest()
130 read_buf_ = new IOBuffer(len); in AssertReadReturns()
131 ASSERT_EQ(rv, sock_->Read(read_buf_, len, &read_callback_)); in AssertReadReturns()
136 ASSERT_EQ(std::string(data, len), std::string(read_buf_->data(), len)); in AssertReadBufferEquals()
|
| D | tcp_client_socket_libevent.cc | 413 read_buf_ = buf; in Read()
621 bytes_transferred = HANDLE_EINTR(read(socket_, read_buf_->data(), in DidCompleteRead()
632 read_buf_->data()); in DidCompleteRead()
638 read_buf_ = NULL; in DidCompleteRead()
|
| D | tcp_client_socket_libevent.h | 168 scoped_refptr<IOBuffer> read_buf_; variable
|
| D | socket_test_util.cc | 869 read_buf_(NULL), in DeterministicMockTCPClientSocket()
887 DCHECK(read_buf_); in CompleteRead()
901 memcpy(read_buf_->data(), read_data_.data, result); in CompleteRead()
946 read_buf_ = buf; in Read()
|
| D | socket_test_util.h | 691 net::IOBuffer* read_buf_; variable
|
| /external/chromium/net/spdy/ |
| D | spdy_proxy_client_socket_unittest.cc | 109 scoped_refptr<IOBuffer> read_buf_; member in net::SpdyProxyClientSocketTest
133 read_buf_(NULL), in SpdyProxyClientSocketTest()
260 read_buf_ = new IOBuffer(len); in AssertReadStarts()
261 ASSERT_EQ(ERR_IO_PENDING, sock_->Read(read_buf_, len, &read_callback_)); in AssertReadStarts()
270 ASSERT_EQ(std::string(data, len), std::string(read_buf_->data(), len)); in AssertReadReturns()
|