| /external/chromium_org/net/http/ |
| D | http_stream_parser.cc | 186 read_buf_(read_buffer), in HttpStreamParser()
317 if (read_buf_->offset() > 0) { in ReadResponseHeaders()
319 result = read_buf_->offset(); in ReadResponseHeaders()
320 read_buf_->set_offset(0); in ReadResponseHeaders()
551 if (read_buf_->RemainingCapacity() == 0) in DoReadHeaders()
552 read_buf_->SetCapacity(read_buf_->capacity() + kHeaderBufInitialSize); in DoReadHeaders()
556 CHECK(read_buf_->data()); in DoReadHeaders()
559 ->Read(read_buf_.get(), read_buf_->RemainingCapacity(), io_callback_); in DoReadHeaders()
613 if (read_buf_->offset()) { in DoReadBody()
614 int available = read_buf_->offset() - read_buf_unused_offset_; in DoReadBody()
[all …]
|
| D | http_basic_state.cc | 20 : read_buf_(new GrowableIOBuffer()), in HttpBasicState()
34 connection_.get(), request_info, read_buf_.get(), net_log)); in Initialize()
43 return read_buf_; in read_buf()
|
| D | http_response_body_drainer.cc | 25 read_buf_ = new IOBuffer(kDrainBodyBufferSize); in Start()
71 read_buf_.get(), in DoDrainResponseBody()
|
| D | http_response_body_drainer.h | 54 scoped_refptr<IOBuffer> read_buf_; variable
|
| D | http_basic_state.h | 57 scoped_refptr<GrowableIOBuffer> read_buf_;
|
| D | http_transaction_test_util.cc | 189 content_.append(read_buf_->data(), result); in DidRead()
203 read_buf_ = new net::IOBuffer(1024); in Read()
204 int result = trans_->Read(read_buf_.get(), in Read()
|
| /external/chromium_org/net/tools/quic/ |
| D | quic_spdy_client_stream.cc | 22 read_buf_(new GrowableIOBuffer()), in QuicSpdyClientStream()
53 if (read_buf_->RemainingCapacity() < (int)data_len) { in ProcessData()
54 read_buf_->SetCapacity(read_buf_->capacity() + kHeaderBufInitialSize); in ProcessData()
56 memcpy(read_buf_->data(), data, data_len); in ProcessData()
57 read_buf_->set_offset(read_buf_->offset() + data_len); in ProcessData()
97 size_t read_buf_len = static_cast<size_t>(read_buf_->offset()); in ParseResponseHeaders()
100 char* data = read_buf_->StartOfBuffer(); in ParseResponseHeaders()
101 size_t len = framer.ParseHeaderBlockInBuffer(data, read_buf_->offset(), in ParseResponseHeaders()
|
| D | quic_spdy_server_stream.cc | 24 read_buf_(new GrowableIOBuffer()), in QuicSpdyServerStream()
37 if (read_buf_->RemainingCapacity() < (int)data_len) { in ProcessData()
38 read_buf_->SetCapacity(read_buf_->capacity() + kHeaderBufInitialSize); in ProcessData()
40 memcpy(read_buf_->data(), data, data_len); in ProcessData()
41 read_buf_->set_offset(read_buf_->offset() + data_len); in ProcessData()
68 size_t read_buf_len = static_cast<size_t>(read_buf_->offset()); in ParseRequestHeaders()
71 char* data = read_buf_->StartOfBuffer(); in ParseRequestHeaders()
72 size_t len = framer.ParseHeaderBlockInBuffer(data, read_buf_->offset(), in ParseRequestHeaders()
|
| D | quic_spdy_server_stream.h | 58 scoped_refptr<GrowableIOBuffer> read_buf_; variable
|
| D | quic_spdy_client_stream.h | 75 scoped_refptr<GrowableIOBuffer> read_buf_; variable
|
| /external/chromium_org/net/quic/ |
| D | quic_spdy_server_stream.cc | 26 read_buf_(new GrowableIOBuffer()), in QuicSpdyServerStream()
28 read_buf_->SetCapacity(kHeaderBufInitialSize); in QuicSpdyServerStream()
42 while (read_buf_->RemainingCapacity() < static_cast<int>(data_len)) { in ProcessData()
43 read_buf_->SetCapacity(read_buf_->capacity() * 2); in ProcessData()
45 memcpy(read_buf_->data(), data, data_len); in ProcessData()
46 read_buf_->set_offset(read_buf_->offset() + data_len); in ProcessData()
84 const char* data = read_buf_->StartOfBuffer(); in ParseRequestHeaders()
85 size_t read_buf_len = static_cast<size_t>(read_buf_->offset()); in ParseRequestHeaders()
|
| D | quic_http_stream.cc | 40 read_buf_(new GrowableIOBuffer()), in QuicHttpStream()
295 if (read_buf_->RemainingCapacity() < length) { in OnDataReceived()
296 size_t additional_capacity = length - read_buf_->RemainingCapacity(); in OnDataReceived()
299 read_buf_->SetCapacity(read_buf_->capacity() + additional_capacity); in OnDataReceived()
301 memcpy(read_buf_->data(), data, length); in OnDataReceived()
302 read_buf_->set_offset(read_buf_->offset() + length); in OnDataReceived()
514 size_t read_buf_len = static_cast<size_t>(read_buf_->offset()); in ParseResponseHeaders()
517 char* data = read_buf_->StartOfBuffer(); in ParseResponseHeaders()
518 size_t len = framer.ParseHeaderBlockInBuffer(data, read_buf_->offset(), in ParseResponseHeaders()
|
| D | quic_spdy_server_stream.h | 58 scoped_refptr<GrowableIOBuffer> read_buf_; variable
|
| /external/chromium_org/jingle/glue/ |
| D | fake_ssl_client_socket.cc | 85 read_buf_(NewDrainableIOBufferWithSize(arraysize(kSslServerHello))) { in FakeSSLClientSocket()
122 DCHECK_EQ(read_buf_->BytesConsumed(), 0); in Connect()
197 DCHECK_EQ(read_buf_->BytesConsumed(), 0); in ProcessConnectDone()
227 DCHECK_EQ(read_buf_->BytesConsumed(), 0); in ProcessSendClientHelloDone()
238 read_buf_.get(), in DoVerifyServerHello()
239 read_buf_->BytesRemaining(), in DoVerifyServerHello()
270 DCHECK_LE(read, static_cast<size_t>(read_buf_->BytesRemaining())); in ProcessVerifyServerHelloDone()
276 read_buf_->BytesRemaining()]; in ProcessVerifyServerHelloDone()
277 if (std::memcmp(expected_data_start, read_buf_->data(), read) != 0) { in ProcessVerifyServerHelloDone()
280 if (read < static_cast<size_t>(read_buf_->BytesRemaining())) { in ProcessVerifyServerHelloDone()
[all …]
|
| D | chrome_async_socket.cc | 38 read_buf_(new net::IOBufferWithSize(read_buf_size)), in ChromeAsyncSocket()
179 read_buf_.get(), read_buf_->size(), in DoRead()
241 std::memcpy(data, read_buf_->data() + read_start_, *len_read); in Read()
|
| D | chrome_async_socket.h | 197 scoped_refptr<net::IOBufferWithSize> read_buf_; variable
|
| /external/chromium_org/storage/browser/blob/ |
| D | blob_url_request_job.cc | 112 DCHECK(!read_buf_.get()); in ReadRawData()
113 read_buf_ = new net::DrainableIOBuffer(dest, dest_size); in ReadRawData()
363 read_buf_->DidConsume(result); in AdvanceBytesRead()
364 DCHECK_GE(read_buf_->BytesRemaining(), 0); in AdvanceBytesRead()
369 DCHECK_GE(read_buf_->BytesRemaining(), bytes_to_read); in ReadBytesItem()
371 memcpy(read_buf_->data(), in ReadBytesItem()
381 DCHECK_GE(read_buf_->BytesRemaining(), bytes_to_read); in ReadFileItem()
384 read_buf_.get(), in ReadFileItem()
412 if (!read_buf_->BytesRemaining()) { in DidReadFile()
433 int bytes_read = read_buf_->BytesConsumed(); in BytesReadCompleted()
[all …]
|
| /external/chromium_org/ppapi/examples/crxfs/ |
| D | crxfs.cc | 55 char read_buf_[kBufSize]; member in MyInstance
102 int32_t rv = file_io_.Read(0, read_buf_, sizeof(read_buf_), in FileIOOpenCallback()
117 content.append(read_buf_, pp_error); in FileIOReadCallback()
|
| /external/chromium_org/net/server/ |
| D | http_connection.h | 118 ReadIOBuffer* read_buf() const { return read_buf_.get(); } in read_buf()
127 const scoped_refptr<ReadIOBuffer> read_buf_; variable
|
| D | http_server_unittest.cc | 472 read_buf_(NULL), in MockStreamSocket()
482 read_buf_ = NULL; in Disconnect()
513 read_buf_ = buf; in Read()
537 if (!read_buf_.get()) { in DidRead()
542 memcpy(read_buf_->data(), data, read_len); in DidRead()
544 read_buf_ = NULL; in DidRead()
553 scoped_refptr<IOBuffer> read_buf_; member in net::__anon8e6254270211::MockStreamSocket
|
| /external/chromium_org/net/socket/ |
| D | socket_libevent.cc | 249 read_buf_ = buf; in Read()
425 int rv = DoRead(read_buf_.get(), read_buf_len_); in ReadCompleted()
431 read_buf_ = NULL; in ReadCompleted()
467 read_buf_ = NULL; in StopWatchingAndCleanUp()
|
| D | ssl_server_socket_unittest.cc | 66 DCHECK(!read_buf_.get()); in Read()
71 read_buf_ = buf; in Read()
113 int copied = PropogateData(read_buf_, read_buf_len_); in DoReadCallback()
116 read_buf_ = NULL; in DoReadCallback()
142 scoped_refptr<IOBuffer> read_buf_; member in net::__anone1fe2eb30111::FakeDataChannel
|
| D | deterministic_socket_data_unittest.cc | 56 scoped_refptr<IOBuffer> read_buf_; member in net::DeterministicSocketDataTest
71 read_buf_(NULL), in DeterministicSocketDataTest()
132 read_buf_ = new IOBuffer(len); in AssertReadReturns()
133 ASSERT_EQ(rv, sock_->Read(read_buf_.get(), len, read_callback_.callback())); in AssertReadReturns()
138 ASSERT_EQ(std::string(data, len), std::string(read_buf_->data(), len)); in AssertReadBufferEquals()
|
| /external/chromium_org/net/socket_stream/ |
| D | socket_stream.cc | 109 read_buf_(NULL), in SocketStream()
403 DCHECK(read_buf_.get()); in DidReceiveData()
410 delegate_->OnReceivedData(this, read_buf_->data(), len); in DidReceiveData()
412 read_buf_ = NULL; in DidReceiveData()
450 } else if (result > 0 && read_buf_.get()) { in OnReadCompleted()
1149 if (!read_buf_.get()) { in DoReadWrite()
1151 read_buf_ = new IOBuffer(kReadBufferSize); in DoReadWrite()
1153 read_buf_.get(), in DoReadWrite()
1174 DCHECK(read_buf_.get()); in DoReadWrite()
|
| /external/chromium_org/net/udp/ |
| D | udp_socket_libevent.cc | 98 read_buf_ = NULL; in Close()
191 read_buf_ = buf; in RecvFrom()
382 InternalRecvFrom(read_buf_.get(), read_buf_len_, recv_from_address_); in DidCompleteRead()
384 read_buf_ = NULL; in DidCompleteRead()
|