/external/chromium_org/content/browser/loader/ |
H A D | stream_resource_handler.cc | 22 read_buffer_(NULL) { 65 if (!read_buffer_.get()) 66 read_buffer_ = new net::IOBuffer(kReadBufSize); 67 *buf = read_buffer_.get(); 78 DCHECK(read_buffer_.get()); 83 read_buffer_.swap(buffer);
|
H A D | certificate_resource_handler.cc | 25 read_buffer_(NULL), 67 if (!read_buffer_.get()) { 68 read_buffer_ = new net::IOBuffer(kReadBufSize); 70 *buf = read_buffer_.get(); 81 DCHECK(read_buffer_.get()); 87 read_buffer_.swap(buffer);
|
H A D | sync_resource_handler.cc | 26 read_buffer_(new net::IOBuffer(kReadBufSize)), 110 *buf = read_buffer_.get(); 118 result_.data.append(read_buffer_->data(), bytes_read);
|
H A D | buffered_resource_handler.cc | 159 if (read_buffer_.get()) { 161 *buf = new DependentIOBuffer(read_buffer_.get(), bytes_read_); 167 read_buffer_ = *buf; 247 if (!read_buffer_.get()) { 290 net::SniffMimeType(read_buffer_->data(), bytes_read_, request()->url(), 416 DCHECK(read_buffer_.get()); 420 read_buffer_ = NULL; 479 if (!read_buffer_.get()) 488 memcpy(buf->data(), read_buffer_->data(), bytes_read_);
|
H A D | detachable_resource_handler.cc | 60 // drain into |read_buffer_|. (If |next_handler_| is an AsyncResourceHandler, 154 if (!read_buffer_.get()) 155 read_buffer_ = new net::IOBuffer(kReadBufSize); 156 *buf = read_buffer_;
|
/external/chromium_org/chrome/browser/devtools/device/usb/ |
H A D | android_usb_socket.cc | 68 read_buffer_ += message->body; 121 if (read_buffer_.empty()) { 126 size_t bytes_to_copy = static_cast<size_t>(length) > read_buffer_.length() ? 127 read_buffer_.length() : static_cast<size_t>(length); 128 memcpy(buffer->data(), read_buffer_.data(), bytes_to_copy); 129 if (read_buffer_.length() > bytes_to_copy) 130 read_buffer_ = read_buffer_.substr(bytes_to_copy); 132 read_buffer_ = ""; 236 while (!read_requests.empty() && (!read_buffer_ [all...] |
/external/chromium_org/remoting/base/ |
H A D | socket_reader.cc | 41 read_buffer_ = new net::IOBuffer(kReadBufferSize); 43 read_buffer_.get(), 61 read_buffer_ = NULL; 65 read_buffer_, result));
|
H A D | socket_reader.h | 46 scoped_refptr<net::IOBuffer> read_buffer_; member in class:remoting::SocketReader
|
/external/chromium_org/chromeos/process_proxy/ |
H A D | process_output_watcher.cc | 70 read_buffer_capacity_ = arraysize(read_buffer_) - 1; 122 &read_buffer_[read_buffer_size_], 159 if (!CBU8_IS_TRAIL(read_buffer_[last_lead_byte])) 165 size_t last_length = UTF8SizeFromLeadingByte(read_buffer_[last_lead_byte]); 182 on_read_callback_.Run(type, std::string(read_buffer_, output_to_report)); 188 read_buffer_[i - output_to_report] = read_buffer_[i];
|
H A D | process_output_watcher.h | 56 // Processes new |read_buffer_| state and notifies observer about new process 63 char read_buffer_[256]; member in class:chromeos::ProcessOutputWatcher
|
/external/chromium_org/content/browser/download/ |
H A D | save_file_resource_handler.cc | 81 if (!read_buffer_.get()) { 83 read_buffer_ = new net::IOBuffer(*buf_size); 85 *buf = read_buffer_.get(); 90 DCHECK(read_buffer_.get()); 93 read_buffer_.swap(buffer); 109 read_buffer_ = NULL;
|
/external/chromium_org/device/serial/ |
H A D | data_sink_unittest.cc | 51 read_buffer_.reset(); 84 if (!read_buffer_) 86 ASSERT_TRUE(read_buffer_); 87 data.append(read_buffer_->GetData(), read_buffer_->GetSize()); 88 if (bytes_to_read <= read_buffer_->GetSize()) { 90 read_buffer_->DoneWithError(bytes_to_read, error); 92 read_buffer_->Done(bytes_to_read); 93 read_buffer_.reset(); 96 bytes_to_read -= read_buffer_ 189 scoped_ptr<ReadOnlyBuffer> read_buffer_; member in class:device::DataSinkTest [all...] |
/external/chromium_org/mojo/system/ |
H A D | raw_channel.cc | 160 DCHECK(!read_buffer_); 181 DCHECK(!read_buffer_); 182 read_buffer_.reset(new ReadBuffer); 189 read_buffer_.reset(); 224 OnShutdownNoLock(read_buffer_.Pass(), write_buffer_.Pass()); 297 read_buffer_->num_valid_bytes_ += bytes_read; 301 // Tracks the offset of the first undispatched message in |read_buffer_|. 304 size_t remaining_bytes = read_buffer_->num_valid_bytes_; 308 // |read_buffer_->buffer_| if |remaining_bytes| is zero. 314 &read_buffer_ [all...] |
H A D | message_pipe_perftest.cc | 45 read_buffer_.resize(message_size * 2); 59 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer_.size()); 61 UserPointer<void>(&read_buffer_[0]), 99 std::string read_buffer_; member in class:mojo::system::__anon8854::MultiprocessMessagePipePerfTest
|
/external/chromium_org/components/cronet/android/ |
H A D | url_request_adapter.cc | 28 read_buffer_(new net::GrowableIOBuffer()), 207 if (read_buffer_->RemainingCapacity() == 0) { 208 int new_capacity = read_buffer_->capacity() + kBufferSizeIncrement; 209 read_buffer_->SetCapacity(new_capacity); 214 read_buffer_, read_buffer_->RemainingCapacity(), &bytes_read)) { 228 read_buffer_->set_offset(0); 256 read_buffer_->set_offset(read_buffer_->offset() + bytes_read); 296 return reinterpret_cast<unsigned char*>(read_buffer_ [all...] |
/external/chromium_org/google_apis/gcm/base/ |
H A D | socket_stream.cc | 25 read_buffer_(new net::DrainableIOBuffer(io_buffer_.get(), 49 DCHECK_LT(next_pos_, read_buffer_->BytesConsumed()); 52 next_pos_ = read_buffer_->BytesConsumed(); 66 << " of " << read_buffer_->BytesConsumed(); 83 return read_buffer_->BytesConsumed() - next_pos_; 92 if (byte_limit > read_buffer_->BytesRemaining()) { 106 socket_->Read(read_buffer_.get(), 140 read_buffer_->DidConsume(unread_data_size); 157 if (read_buffer_->BytesConsumed() == next_pos_) 184 read_buffer_ [all...] |
/external/chromium_org/remoting/protocol/ |
H A D | message_reader.cc | 49 read_buffer_ = new net::IOBuffer(kReadBufferSize); 51 read_buffer_.get(), 75 OnDataReceived(read_buffer_.get(), result);
|
H A D | fake_datagram_socket.cc | 36 int result = CopyReadData(read_buffer_.get(), read_buffer_size_); 37 read_buffer_ = NULL; 61 read_buffer_ = buf;
|
/external/chromium_org/net/quic/ |
H A D | quic_server.cc | 46 read_buffer_(new IOBufferWithSize(kReadBufferSize)), 135 read_buffer_.get(), 136 read_buffer_->size(), 170 QuicEncryptedPacket packet(read_buffer_->data(), result, false);
|
H A D | quic_server.h | 104 scoped_refptr<IOBufferWithSize> read_buffer_; member in class:net::QuicServer
|
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_host_tcp.cc | 280 if (!read_buffer_.get()) { 281 read_buffer_ = new net::GrowableIOBuffer(); 282 read_buffer_->SetCapacity(kReadBufferSize); 283 } else if (read_buffer_->RemainingCapacity() < kReadBufferSize) { 288 read_buffer_->SetCapacity(read_buffer_->capacity() + kReadBufferSize - 289 read_buffer_->RemainingCapacity()); 292 read_buffer_.get(), 293 read_buffer_->RemainingCapacity(), 436 read_buffer_ [all...] |
/external/chromium_org/net/url_request/ |
H A D | url_request_file_dir_job.cc | 81 read_buffer_ = buf; 152 if (FillReadBuffer(read_buffer_->data(), read_buffer_length_, 156 read_buffer_ = NULL;
|
/external/chromium_org/net/tools/flip_server/ |
H A D | sm_connection.cc | 50 read_buffer_(kSpdySegmentSize * 40), 151 read_buffer_.Clear(); 413 while (!read_buffer_.Full()) { 421 read_buffer_.GetWritablePtr(&bytes, &size); 474 read_buffer_.AdvanceWritablePtr(bytes_read); 499 read_buffer_.GetReadablePtr(&bytes, &size); 507 read_buffer_.AdvanceReadablePtr(bytes_consumed); 521 read_buffer_.GetReadablePtr(&bytes, &size); 644 read_buffer_.Clear();
|
/external/chromium_org/chrome/test/chromedriver/net/ |
H A D | websocket.cc | 64 read_buffer_(new net::IOBufferWithSize(4096)) {} 182 socket_->Read(read_buffer_.get(), 183 read_buffer_->size(), 196 OnReadDuringHandshake(read_buffer_->data(), code); 198 OnReadDuringOpen(read_buffer_->data(), code);
|
/external/chromium_org/jingle/glue/ |
H A D | channel_socket_adapter.cc | 58 read_buffer_ = buf; 129 read_buffer_ = NULL; 150 DCHECK(read_buffer_.get()); 159 memcpy(read_buffer_->data(), data, data_size); 163 read_buffer_ = NULL;
|