Searched refs:consumer_queues_ (Results 1 – 2 of 2) sorted by relevance
196 auto search = consumer_queues_.find(queue_id); in GetQueue()197 if (search != consumer_queues_.end()) in GetQueue()206 for (const auto& entry : consumer_queues_) in GetQueueIds()239 consumer_queues_[consumer->id()] = std::move(consumer); in OnCreateQueue()260 auto search = consumer_queues_.find(consumer_queue->id()); in OnQueueEvent()261 if (search != consumer_queues_.end()) { in OnQueueEvent()262 consumer_queues_.erase(search); in OnQueueEvent()
135 std::unordered_map<int32_t, std::shared_ptr<ConsumerQueue>> consumer_queues_; variable