Searched refs:mQueue (Results 1 – 3 of 3) sorted by relevance
33 while (mQueue.empty() && mIsActive) { in waitForItems()42 if (mQueue.empty() || !mIsActive) { in flush()45 while (!mQueue.empty()) { in flush()46 items.push_back(std::move(mQueue.front())); in flush()47 mQueue.pop(); in flush()58 mQueue.push(std::move(item)); in push()84 std::queue<T> mQueue; variable108 mQueue = queue; in run()129 mQueue->waitForItems(); in runInternal()135 std::vector<T> items = mQueue->flush(); in runInternal()[all …]
96 if (mQueue && (mDataMaxSize <= mQueue->getQuantumCount())) { in writeQueue()97 if (!mQueue->write(mData.get(), mDataWritten)) { in writeQueue()111 mQueue = std::move(newQueue); in writeQueue()125 return (mQueue) ? mQueue->getDesc() : nullptr; in getMQDescriptor()632 std::unique_ptr<CommandQueueType> mQueue; variable646 mQueue = std::make_unique<CommandQueueType>(descriptor, false); in setMQDescriptor()647 if (mQueue->isValid()) { in setMQDescriptor()650 mQueue = nullptr; in setMQDescriptor()658 if (!mQueue) { in readQueue()662 auto quantumCount = mQueue->getQuantumCount(); in readQueue()[all …]
413 while (!mQueue.empty()) { in ~RequestQueue()414 request = mQueue.front(); in ~RequestQueue()415 mQueue.pop(); in ~RequestQueue()420 mQueue.push(request); in push()424 if (!mQueue.empty()) { in pop()425 request = mQueue.front(); in pop()426 mQueue.pop(); in pop()433 std::queue<LocationAPIRequest*> mQueue; variable