/external/chromium_org/content/browser/loader/ |
H A D | stream_resource_handler.cc | 23 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 D | certificate_resource_handler.cc | 24 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 D | sync_resource_handler.cc | 26 read_buffer_(new net::IOBuffer(kReadBufSize)), 109 *buf = read_buffer_.get(); 118 result_.data.append(read_buffer_->data(), bytes_read);
|
H A D | buffered_resource_handler.cc | 158 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 D | detachable_resource_handler.cc | 60 // 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 D | android_usb_socket.cc | 65 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 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/chrome/browser/renderer_host/ |
H A D | save_file_resource_handler.cc | 72 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 D | download_resource_handler.cc | 134 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 D | save_file_resource_handler.cc | 82 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 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(); 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 D | socket_host_tcp.cc | 242 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 D | process_output_watcher.cc | 48 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 D | process_output_watcher.h | 58 char read_buffer_[kReadBufferSize]; member in class:chromeos::ProcessOutputWatcher
|
/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);
|
/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/net/url_request/ |
H A D | url_request_file_dir_job.h | 69 scoped_refptr<IOBuffer> read_buffer_; member in class:net::URLRequestFileDirJob
|
H A D | url_request_file_dir_job.cc | 91 read_buffer_ = buf; 188 if (FillReadBuffer(read_buffer_->data(), read_buffer_length_, 192 read_buffer_ = NULL;
|
/external/chromium_org/mojo/system/ |
H A D | raw_channel_posix.cc | 81 // 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 D | udp_socket_resource_base.cc | 38 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 D | sm_connection.cc | 43 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 D | sm_connection.cc | 50 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 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; 127 read_buffer_ = NULL; 148 DCHECK(read_buffer_.get()); 157 memcpy(read_buffer_->data(), data, data_size); 161 read_buffer_ = NULL;
|