Searched refs:m_outgoing_messages (Results 1 – 3 of 3) sorted by relevance
264 std::list<Message> m_outgoing_messages; member in ClientNetworking::Impl524 if (!m_outgoing_messages.empty()) in NetworkingThread()531 m_outgoing_messages.clear(); in NetworkingThread()598 m_outgoing_messages.pop_front(); in HandleMessageWrite()599 if (!m_outgoing_messages.empty()) in HandleMessageWrite()621 HeaderToBuffer(m_outgoing_messages.front(), m_outgoing_header); in AsyncWriteMessage()624 buffers.push_back(boost::asio::buffer(m_outgoing_messages.front().Data(), in AsyncWriteMessage()633 bool start_write = m_outgoing_messages.empty(); in SendMessageImpl()634 m_outgoing_messages.push_back(Message()); in SendMessageImpl()635 swap(m_outgoing_messages.back(), message); in SendMessageImpl()[all …]
489 bool start_write = self->m_outgoing_messages.empty(); in SendMessageImpl()490 self->m_outgoing_messages.push_back(Message()); in SendMessageImpl()491 swap(self->m_outgoing_messages.back(), message); in SendMessageImpl()503 HeaderToBuffer(m_outgoing_messages.front(), m_outgoing_header); in AsyncWriteMessage()506 buffers.push_back(boost::asio::buffer(m_outgoing_messages.front().Data(), in AsyncWriteMessage()507 m_outgoing_messages.front().Size())); in AsyncWriteMessage()530 self->m_outgoing_messages.pop_front(); in HandleMessageWrite()531 if (!self->m_outgoing_messages.empty()) in HandleMessageWrite()
329 std::list<Message> m_outgoing_messages; variable