Lines Matching defs:queue
697 // If we don't know who the peer is, queue the message for delivery. If this
704 auto& queue = pending_peer_messages_[name];
705 needs_introduction = queue.empty();
706 queue.emplace(std::move(channel_message));
739 std::queue<ports::ScopedMessage> messages;
837 // AcceptMessage, we flush the queue after calling any of those methods.
851 // Normally, the queue is processed after the action that added the local
854 // and OnChannelMessage() doesn't process this queue (although
857 // this message queue.
860 // code path, post a task to the IO thread to process the queue. If the
861 // current call stack processes the queue, this may end up doing nothing.
1056 std::queue<ports::NodeName> pending_broker_clients;
