Searched refs:incoming_messages_ (Results 1 – 2 of 2) sorted by relevance
530 tracker->TrackField("incoming_messages", incoming_messages_); in MemoryInfo()536 incoming_messages_.emplace_back(std::move(message)); in AddToIncomingQueue()697 if (data_->incoming_messages_.empty() || in ReceiveMessage()699 !data_->incoming_messages_.front().IsCloseMessage())) { in ReceiveMessage()703 received = std::move(data_->incoming_messages_.front()); in ReceiveMessage()704 data_->incoming_messages_.pop_front(); in ReceiveMessage()725 processing_limit = std::max(data_->incoming_messages_.size(), in OnMessage()982 if (!data_->incoming_messages_.empty()) in Start()
147 std::list<Message> incoming_messages_; variable