Searched refs:mQueue (Results 1 – 7 of 7) sorted by relevance
94 if (mQueue.isEmpty()) {113 private final ArrayDeque<Pair<Packet, CompletableFuture<Transport.Result>>> mQueue = field in TransportManager145 for (Pair<Packet, CompletableFuture<Transport.Result>> item : mQueue) { in shutdownImpl()149 mQueue.clear(); in shutdownImpl()174 if (mQueue.isEmpty()) { in processQueueImpl()213 Pair<Packet, CompletableFuture<Transport.Result>> pending = mQueue.pop(); in processQueueImpl()339 mQueue.push(new Pair<>(packet, ret)); in handlePacket()
41 std::unique_ptr<C2Work> work = std::move(mQueue.front().work); in pop_front()42 mQueue.pop_front(); in pop_front()47 mQueue.push_back({std::move(work), NO_DRAIN}); in push_back()50 bool SimpleC2Component::WorkQueue::empty() const { return mQueue.empty(); } in empty()52 void SimpleC2Component::WorkQueue::clear() { mQueue.clear(); } in clear()55 return mQueue.front().drainMode; in drainMode()59 mQueue.push_back({nullptr, drainMode}); in markDrain()
59 std::shared_ptr<Mutexed<ConversionQueue>> mQueue;97 std::shared_ptr<Mutexed<ConversionQueue>> mQueue; member
479 : Thread(false), mQueue(queue) {} in ConverterThread()482 Mutexed<ConversionQueue>::Locked queue(*mQueue); in threadLoop()509 mIntf(intfImpl), mCtx(nullptr), mQueue(new Mutexed<ConversionQueue>) {} in C2GoldfishVpxDec()
436 port->mQueue.push_back(buffer); in onMessageReceived()569 port->mQueue.clear(); in onPortEnable()626 port->mQueue.clear(); in onPortFlush()741 return mPorts.editItemAt(portIndex).mQueue; in getPortQueue()
60 List<BufferInfo *> mQueue; member
241 std::list<Entry> mQueue; variable