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

1234

/external/chromium_org/content/browser/loader/
H A Dstream_resource_handler.cc23 read_buffer_(NULL) {
67 if (!read_buffer_.get())
68 read_buffer_ = new net::IOBuffer(kReadBufSize);
69 *buf = read_buffer_.get();
82 DCHECK(read_buffer_.get());
87 read_buffer_.swap(&buffer);
H A Dcertificate_resource_handler.cc24 read_buffer_(NULL),
67 if (!read_buffer_.get()) {
68 read_buffer_ = new net::IOBuffer(kReadBufSize);
70 *buf = read_buffer_.get();
83 DCHECK(read_buffer_.get());
89 read_buffer_.swap(&buffer);
H A Dsync_resource_handler.cc26 read_buffer_(new net::IOBuffer(kReadBufSize)),
109 *buf = read_buffer_.get();
118 result_.data.append(read_buffer_->data(), bytes_read);
H A Dbuffered_resource_handler.cc158 if (read_buffer_.get()) {
160 *buf = new DependentIOBuffer(read_buffer_.get(), bytes_read_);
166 read_buffer_ = *buf;
248 if (!read_buffer_.get()) {
291 net::SniffMimeType(read_buffer_->data(), bytes_read_, request()->url(),
394 DCHECK(read_buffer_.get());
399 read_buffer_ = NULL;
467 memcpy(buf->data(), read_buffer_->data(), bytes_read_);
H A Ddetachable_resource_handler.cc60 // drain into |read_buffer_|. (If |next_handler_| is an AsyncResourceHandler,
142 if (!read_buffer_)
143 read_buffer_ = new net::IOBuffer(kReadBufSize);
144 *buf = read_buffer_;
/external/chromium_org/chrome/browser/devtools/adb/
H A Dandroid_usb_socket.cc65 read_buffer_ += message->body;
111 if (read_buffer_.empty()) {
116 size_t bytes_to_copy = static_cast<size_t>(length) > read_buffer_.length() ?
117 read_buffer_.length() : static_cast<size_t>(length);
118 memcpy(buffer->data(), read_buffer_.data(), bytes_to_copy);
119 if (read_buffer_.length() > bytes_to_copy)
120 read_buffer_ = read_buffer_.substr(bytes_to_copy);
122 read_buffer_ = "";
225 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/chrome/browser/renderer_host/
H A Dsave_file_resource_handler.cc72 if (!read_buffer_) {
74 read_buffer_ = new net::IOBuffer(*buf_size);
76 *buf = read_buffer_.get();
81 DCHECK(read_buffer_);
84 read_buffer_.swap(buffer);
107 read_buffer_ = NULL;
H A Ddownload_resource_handler.cc134 if (!read_buffer_) {
136 read_buffer_ = new net::IOBuffer(*buf_size);
138 *buf = read_buffer_.get();
146 DCHECK(read_buffer_);
152 read_buffer_.swap(&buffer);
192 read_buffer_ = NULL;
/external/chromium_org/content/browser/download/
H A Dsave_file_resource_handler.cc82 if (!read_buffer_.get()) {
84 read_buffer_ = new net::IOBuffer(*buf_size);
86 *buf = read_buffer_.get();
92 DCHECK(read_buffer_.get());
95 read_buffer_.swap(buffer);
112 read_buffer_ = NULL;
/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();
65 << " of " << read_buffer_->BytesConsumed();
82 return read_buffer_->BytesConsumed() - next_pos_;
91 if (byte_limit > read_buffer_->BytesRemaining()) {
105 read_buffer_,
139 read_buffer_->DidConsume(unread_data_size);
154 if (read_buffer_->BytesConsumed() == next_pos_)
181 read_buffer_
[all...]
/external/chromium_org/content/browser/renderer_host/p2p/
H A Dsocket_host_tcp.cc242 if (!read_buffer_.get()) {
243 read_buffer_ = new net::GrowableIOBuffer();
244 read_buffer_->SetCapacity(kReadBufferSize);
245 } else if (read_buffer_->RemainingCapacity() < kReadBufferSize) {
250 read_buffer_->SetCapacity(read_buffer_->capacity() + kReadBufferSize -
251 read_buffer_->RemainingCapacity());
254 read_buffer_.get(),
255 read_buffer_->RemainingCapacity(),
390 read_buffer_
[all...]
/external/chromium_org/chromeos/process_proxy/
H A Dprocess_output_watcher.cc48 read_buffer_size_ = arraysize(read_buffer_) - 1;
97 ssize_t bytes_read = HANDLE_EINTR(read(*fd, read_buffer_, read_buffer_size_));
102 on_read_callback_.Run(type, std::string(read_buffer_, bytes_read));
H A Dprocess_output_watcher.h58 char read_buffer_[kReadBufferSize]; member in class:chromeos::ProcessOutputWatcher
/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);
/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/net/url_request/
H A Durl_request_file_dir_job.h69 scoped_refptr<IOBuffer> read_buffer_; member in class:net::URLRequestFileDirJob
H A Durl_request_file_dir_job.cc91 read_buffer_ = buf;
188 if (FillReadBuffer(read_buffer_->data(), read_buffer_length_,
192 read_buffer_ = NULL;
/external/chromium_org/mojo/system/
H A Draw_channel_posix.cc81 // We store data from |read()|s in |read_buffer_|. The start of |read_buffer_|
83 // this), but |read_buffer_| may be larger than the actual number of bytes we
85 std::vector<char> read_buffer_; member in class:mojo::system::__anon9069::RawChannelPosix
215 // Tracks the offset of the first undispatched message in |read_buffer_|.
219 if (read_buffer_.size() - (read_buffer_start + read_buffer_num_valid_bytes_)
226 size_t new_size = std::max(read_buffer_.size(), kReadSize);
232 read_buffer_.resize(new_size, 0);
237 &read_buffer_[read_buffer_start + read_buffer_num_valid_bytes_],
259 &read_buffer_[read_buffer_star
[all...]
/external/chromium_org/ppapi/proxy/
H A Dudp_socket_resource_base.cc38 read_buffer_(NULL),
142 read_buffer_ = buffer;
204 read_buffer_ = NULL;
242 // It is possible that |recvfrom_callback_| is pending while |read_buffer_| is
246 if (!TrackedCallback::IsPending(recvfrom_callback_) || !read_buffer_)
263 memcpy(read_buffer_, data.c_str(), data.size());
266 read_buffer_ = NULL;
/external/chromium/net/tools/flip_server/
H A Dsm_connection.cc43 read_buffer_(kSpdySegmentSize * 40),
150 read_buffer_.Clear();
405 while (!read_buffer_.Full()) {
413 read_buffer_.GetWritablePtr(&bytes, &size);
466 read_buffer_.AdvanceWritablePtr(bytes_read);
491 read_buffer_.GetReadablePtr(&bytes, &size);
499 read_buffer_.AdvanceReadablePtr(bytes_consumed);
513 read_buffer_.GetReadablePtr(&bytes, &size);
638 read_buffer_.Clear();
/external/chromium_org/net/tools/flip_server/
H A Dsm_connection.cc50 read_buffer_(kSpdySegmentSize * 40),
151 read_buffer_.Clear();
411 while (!read_buffer_.Full()) {
419 read_buffer_.GetWritablePtr(&bytes, &size);
472 read_buffer_.AdvanceWritablePtr(bytes_read);
497 read_buffer_.GetReadablePtr(&bytes, &size);
505 read_buffer_.AdvanceReadablePtr(bytes_consumed);
519 read_buffer_.GetReadablePtr(&bytes, &size);
642 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;
127 read_buffer_ = NULL;
148 DCHECK(read_buffer_.get());
157 memcpy(read_buffer_->data(), data, data_size);
161 read_buffer_ = NULL;

Completed in 870 milliseconds

1234