Searched refs:read_buffer_ (Results 1 - 25 of 90) sorted by relevance

1234

/external/chromium_org/content/browser/loader/
H A Dstream_resource_handler.cc22 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 Dcertificate_resource_handler.cc25 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 Dsync_resource_handler.cc26 read_buffer_(new net::IOBuffer(kReadBufSize)),
110 *buf = read_buffer_.get();
118 result_.data.append(read_buffer_->data(), bytes_read);
H A Dbuffered_resource_handler.cc159 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 Ddetachable_resource_handler.cc60 // 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 Dandroid_usb_socket.cc68 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 Dsocket_reader.cc41 read_buffer_ = new net::IOBuffer(kReadBufferSize);
43 read_buffer_.get(),
61 read_buffer_ = NULL;
65 read_buffer_, result));
H A Dsocket_reader.h46 scoped_refptr<net::IOBuffer> read_buffer_; member in class:remoting::SocketReader
/external/chromium_org/chromeos/process_proxy/
H A Dprocess_output_watcher.cc70 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 Dprocess_output_watcher.h56 // 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 Dsave_file_resource_handler.cc81 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 Ddata_sink_unittest.cc51 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 Draw_channel.cc160 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 Dmessage_pipe_perftest.cc45 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 Durl_request_adapter.cc28 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 Dsocket_stream.cc25 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 Dmessage_reader.cc49 read_buffer_ = new net::IOBuffer(kReadBufferSize);
51 read_buffer_.get(),
75 OnDataReceived(read_buffer_.get(), result);
H A Dfake_datagram_socket.cc36 int result = CopyReadData(read_buffer_.get(), read_buffer_size_);
37 read_buffer_ = NULL;
61 read_buffer_ = buf;
/external/chromium_org/net/quic/
H A Dquic_server.cc46 read_buffer_(new IOBufferWithSize(kReadBufferSize)),
135 read_buffer_.get(),
136 read_buffer_->size(),
170 QuicEncryptedPacket packet(read_buffer_->data(), result, false);
H A Dquic_server.h104 scoped_refptr<IOBufferWithSize> read_buffer_; member in class:net::QuicServer
/external/chromium_org/content/browser/renderer_host/p2p/
H A Dsocket_host_tcp.cc280 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 Durl_request_file_dir_job.cc81 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 Dsm_connection.cc50 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 Dwebsocket.cc64 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 Dchannel_socket_adapter.cc58 read_buffer_ = buf;
129 read_buffer_ = NULL;
150 DCHECK(read_buffer_.get());
159 memcpy(read_buffer_->data(), data, data_size);
163 read_buffer_ = NULL;

Completed in 1941 milliseconds

1234