Searched refs:write_queue_ (Results 1 – 12 of 12) sorted by relevance
363 write_queue_.push(write_request); in SendCastMessageInternal()372 VLOG_WITH_CONNECTION(1) << "DoWriteLoop queue size: " << write_queue_.size(); in DoWriteLoop()374 if (write_queue_.empty()) { in DoWriteLoop()404 } while (!write_queue_.empty() && in DoWriteLoop()410 if (write_queue_.empty()) in DoWriteLoop()419 DCHECK(!write_queue_.empty()); in DoWrite()420 WriteRequest& request = write_queue_.front(); in DoWrite()435 DCHECK(!write_queue_.empty()); in DoWriteComplete()443 WriteRequest& request = write_queue_.front(); in DoWriteComplete()455 DCHECK(!write_queue_.empty()); in DoWriteCallback()[all …]
342 std::queue<WriteRequest> write_queue_; variable
43 write_queue_.push(WriteRequest(io_buffer, byte_count, callback)); in Write()52 WriteRequest& request = write_queue_.front(); in WriteData()69 WriteRequest& request = write_queue_.front(); in OnWriteComplete()82 write_queue_.pop(); in OnWriteComplete()84 if (!write_queue_.empty()) in OnWriteComplete()
120 std::queue<WriteRequest> write_queue_; variable
152 std::swap(write_queue_, empty); in DoClose()240 write_queue_.push(request); in DoSend()241 if (write_queue_.size() == 1) { in DoSend()253 if (write_queue_.size() == 0) in SendFrontWriteRequest()256 linked_ptr<WriteRequest> request = write_queue_.front(); in SendFrontWriteRequest()276 write_queue_.pop(); in OnSocketWriteComplete()
124 std::queue<linked_ptr<WriteRequest> > write_queue_; variable
224 write_queue_.push(buffer); in Send()347 if (write_queue_.empty()) in DoWrite()350 write_queue_.front().get(), write_queue_.front()->size()); in DoWrite()351 write_queue_.pop(); in DoWrite()
173 std::queue<scoped_refptr<net::IOBufferWithSize> > write_queue_; variable
333 write_queue_.push(buffer); in WriteOrQueue()366 if (write_queue_.empty()) { in HandleWriteResult()369 write_buffer_ = write_queue_.front(); in HandleWriteResult()370 write_queue_.pop(); in HandleWriteResult()
89 std::queue<scoped_refptr<net::DrainableIOBuffer> > write_queue_; variable
1381 write_queue_.IsEmpty()) { in PumpWriteLoop()1436 if (!write_queue_.Dequeue(&frame_type, &producer, &stream)) { in DoWrite()1595 write_queue_.RemovePendingWritesForStreamsAfter(last_good_stream_id); in StartGoingAway()1806 write_queue_.Enqueue(priority, frame_type, producer.Pass(), stream); in EnqueueWrite()1855 write_queue_.RemovePendingWritesForStream(stream->GetWeakPtr()); in DeleteStream()
988 SpdyWriteQueue write_queue_; variable