Searched refs:incoming_messages_ (Results 1 – 2 of 2) sorted by relevance
580 tracker->TrackField("incoming_messages", incoming_messages_); in MemoryInfo()586 incoming_messages_.emplace_back(std::move(message)); in AddToIncomingQueue()735 if (data_->incoming_messages_.empty() || in ReceiveMessage()737 !data_->incoming_messages_.front()->IsCloseMessage())) { in ReceiveMessage()741 received = data_->incoming_messages_.front(); in ReceiveMessage()742 data_->incoming_messages_.pop_front(); in ReceiveMessage()764 processing_limit = std::max(data_->incoming_messages_.size(), in OnMessage()1026 if (!data_->incoming_messages_.empty()) in Start()
211 std::deque<std::shared_ptr<Message>> incoming_messages_; variable