Searched refs:socket_write_queue_ (Results 1 – 1 of 1) sorted by relevance
177 std::deque<ByteBufferPtr> socket_write_queue_; variable289 if (!socket_write_queue_.empty()) { in Deactivate()293 socket_write_queue_.size(), in Deactivate()295 socket_write_queue_.clear(); in Deactivate()337 if (socket_write_queue_.empty()) { in OnSocketWritable()387 PW_CHECK(socket_write_queue_.size() <= socket_write_queue_max_frames_); in OnChannelDataReceived()392 if (socket_write_queue_.size() == socket_write_queue_max_frames_) { in OnChannelDataReceived()394 socket_write_queue_.pop_front(); in OnChannelDataReceived()410 socket_write_queue_.push_back(std::move(rx_data)); in OnChannelDataReceived()429 if (!socket_write_queue_.empty()) { in OnChannelClosed()[all …]