Searched refs:outgoing_messages_ (Results 1 – 3 of 3) sorted by relevance
82 bool write_now = !delay_writes_ && outgoing_messages_.empty(); in Write()83 outgoing_messages_.emplace_back(std::move(message)); in Write()84 if (write_now && !WriteNoLock(outgoing_messages_.front())) in Write()263 DCHECK(!outgoing_messages_.empty()); in OnWriteDone()265 Channel::MessagePtr message = std::move(outgoing_messages_.front()); in OnWriteDone()266 outgoing_messages_.pop_front(); in OnWriteDone()317 if (outgoing_messages_.empty()) in WriteNextNoLock()319 return WriteNoLock(outgoing_messages_.front()); in WriteNextNoLock()356 base::circular_deque<Channel::MessagePtr> outgoing_messages_; member in mojo::core::__anon2256fa540111::ChannelWin
167 if (outgoing_messages_.empty()) { in Write()171 outgoing_messages_.emplace_back(std::move(message), 0); in Write()503 outgoing_messages_.emplace_front(std::move(message_view)); in WriteNoLock()535 outgoing_messages_.emplace_back(std::move(fds_message), 0); in WriteNoLock()578 outgoing_messages_.emplace_front(std::move(message_view)); in WriteNoLock()591 std::swap(outgoing_messages_, messages); in FlushOutgoingMessagesNoLock()598 if (!outgoing_messages_.empty()) { in FlushOutgoingMessagesNoLock()604 std::swap(messages, outgoing_messages_); in FlushOutgoingMessagesNoLock()606 outgoing_messages_.push_front(std::move(messages.back())); in FlushOutgoingMessagesNoLock()724 base::circular_deque<MessageView> outgoing_messages_; member in mojo::core::__anon7bef9a390111::ChannelPosix
120 return outgoing_messages_.size(); in GetQueuedMessageCount()152 std::swap(outgoing_messages, outgoing_messages_); in FlushOutgoingMessages()196 outgoing_messages_.clear(); in ShutDown()658 outgoing_messages_.emplace_back(std::move(*message)); in SendMessage()945 std::vector<mojo::Message> outgoing_messages_; member in IPC::__anonefff342a0111::ChannelAssociatedGroupController