Searched refs:output_queue_ (Results 1 – 6 of 6) sorted by relevance
189 output_queue_.push_back(msg + "\n"); in deliver()227 if (output_queue_.empty()) in read_line()229 output_queue_.push_back("\n"); in read_line()258 if (output_queue_.empty()) in await_output()282 boost::asio::buffer(output_queue_.front()), in write_line()291 output_queue_.pop_front(); in write_line()333 std::deque<std::string> output_queue_; member in tcp_session
196 output_queue_.push_back(msg + "\n"); in deliver()234 if (output_queue_.empty()) in handle_read()236 output_queue_.push_back("\n"); in handle_read()257 if (output_queue_.empty()) in await_output()279 boost::asio::buffer(output_queue_.front()), in start_write()291 output_queue_.pop_front(); in handle_write()328 std::deque<std::string> output_queue_; member in tcp_session
202 output_queue_.clear(); in Close()217 output_queue_.push_back(std::move(message_ptr)); in Send()274 if (output_queue_.empty()) in ProcessOutgoingMessages()282 while (!output_queue_.empty()) { in ProcessOutgoingMessages()283 std::unique_ptr<Message> msg = std::move(output_queue_.front()); in ProcessOutgoingMessages()284 output_queue_.pop_front(); in ProcessOutgoingMessages()
110 base::circular_deque<std::unique_ptr<Message>> output_queue_; variable