Home
last modified time | relevance | path

Searched refs:queues_ (Results 1 – 1 of 1) sorted by relevance

/device/google/cuttlefish/common/libs/concurrency/
Dmultiplexer.h43 const int id_to_return = queues_.size(); in RegisterQueue()
44 queues_.push_back(std::move(queue)); in RegisterQueue()
50 queues_[idx]->Push(std::move(t)); in Push()
58 QueuePtr& queue = queues_[q_id]; in Pop()
65 for (int i = 0; i < queues_.size(); i++) { in Pop()
66 if (!queues_[i]->IsEmpty()) { in Pop()
75 bool IsEmpty(const int idx) { return queues_[idx]->IsEmpty(); } in IsEmpty()
81 CHECK(idx >= 0 && idx < queues_.size()) << "queues_ array out of bound"; in CheckIdx()
85 std::vector<QueuePtr> queues_; variable