| /external/chromium_org/extensions/browser/api/cast_channel/ |
| H A D | cast_transport.cc | 121 for (; !write_queue_.empty(); write_queue_.pop()) {
122 net::CompletionCallback& callback = write_queue_.front().callback;
143 write_queue_.push(write_request);
148 base::StringPrintf("Queue size: %" PRIuS, write_queue_.size()));
194 << write_queue_.size();
196 if (write_queue_.empty()) {
226 } while (!write_queue_.empty() && rv != net::ERR_IO_PENDING &&
238 if (write_queue_.empty()) {
251 DCHECK(!write_queue_
[all...] |
| H A D | cast_socket.cc | 370 DCHECK_EQ(write_queue_.size(), 1UL);
456 for (; !write_queue_.empty(); write_queue_.pop()) {
457 net::CompletionCallback& callback = write_queue_.front().callback;
499 write_queue_.push(write_request);
504 base::StringPrintf("Queue size: %" PRIuS, write_queue_.size()));
513 VLOG_WITH_CONNECTION(1) << "DoWriteLoop queue size: " << write_queue_.size();
515 if (write_queue_.empty()) {
545 } while (!write_queue_.empty() && rv != net::ERR_IO_PENDING &&
556 if (write_queue_
[all...] |
| H A D | cast_transport.h | 173 std::queue<WriteRequest> write_queue_; member in class:extensions::core_api::cast_channel::CastTransport
|
| H A D | cast_socket.h | 332 std::queue<WriteRequest> write_queue_; member in class:extensions::core_api::cast_channel::CastSocket
|
| /external/chromium_org/extensions/browser/api/socket/ |
| H A D | socket.cc | 43 write_queue_.push(WriteRequest(io_buffer, byte_count, callback));
52 WriteRequest& request = write_queue_.front();
69 WriteRequest& request = write_queue_.front();
82 write_queue_.pop();
84 if (!write_queue_.empty())
|
| H A D | socket.h | 135 std::queue<WriteRequest> write_queue_; member in class:extensions::Socket
|
| /external/chromium_org/device/bluetooth/ |
| H A D | bluetooth_socket_net.cc | 150 std::swap(write_queue_, empty);
238 write_queue_.push(request);
239 if (write_queue_.size() == 1) {
251 if (write_queue_.size() == 0)
254 linked_ptr<WriteRequest> request = write_queue_.front();
274 write_queue_.pop();
|
| H A D | bluetooth_socket_net.h | 116 std::queue<linked_ptr<WriteRequest> > write_queue_; member in class:device::BluetoothSocketNet
|
| /external/chromium_org/mojo/services/html_viewer/ |
| H A D | websockethandle_impl.h | 53 scoped_ptr<WebSocketWriteQueue> write_queue_; member in class:mojo::WebSocketHandleImpl
|
| H A D | websockethandle_impl.cc | 170 write_queue_.reset(new WebSocketWriteQueue(send_stream_.get()));
186 write_queue_->Write(
|
| /external/chromium_org/chrome/browser/extensions/api/messaging/ |
| H A D | native_message_process_host.cc | 223 write_queue_.push(buffer);
346 if (write_queue_.empty())
349 write_queue_.front().get(), write_queue_.front()->size());
350 write_queue_.pop();
|
| H A D | native_message_process_host.h | 172 std::queue<scoped_refptr<net::IOBufferWithSize> > write_queue_; member in class:extensions::NativeMessageProcessHost
|
| /external/chromium_org/mojo/services/network/ |
| H A D | web_socket_impl.cc | 102 scoped_ptr<WebSocketWriteQueue> write_queue_; member in struct:mojo::__anon8817::WebSocketEventHandler
113 write_queue_.reset(new WebSocketWriteQueue(receive_stream_.get()));
126 write_queue_->Write(
|
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| H A D | socket_host_tcp.cc | 366 write_queue_.push(buffer);
401 if (write_queue_.empty()) {
404 write_buffer_ = write_queue_.front();
405 write_queue_.pop();
|
| H A D | socket_host_tcp.h | 89 std::queue<scoped_refptr<net::DrainableIOBuffer> > write_queue_; member in class:content::P2PSocketHostTcpBase
|
| /external/chromium_org/net/spdy/ |
| H A D | spdy_session.cc | 1457 write_queue_.IsEmpty()) {
1512 if (!write_queue_.Dequeue(&frame_type, &producer, &stream)) {
1671 write_queue_.RemovePendingWritesForStreamsAfter(last_good_stream_id);
1882 write_queue_.Enqueue(priority, frame_type, producer.Pass(), stream);
1931 write_queue_.RemovePendingWritesForStream(stream->GetWeakPtr());
|
| H A D | spdy_session.h | 1028 SpdyWriteQueue write_queue_; member in class:net::SpdySession
|