Searched refs:mQueue (Results 1 – 6 of 6) 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 …]
102 size_t staleDataSize = mQueue ? mQueue->availableToRead() : 0; in writeQueue()106 if (mQueue->beginRead(staleDataSize, &tx)) { in writeQueue()107 mQueue->commitRead(staleDataSize); in writeQueue()112 if (mQueue && (mDataMaxSize <= mQueue->getQuantumCount())) { in writeQueue()113 if (!mQueue->write(mData.get(), mDataWritten)) { in writeQueue()126 mQueue = std::move(newQueue); in writeQueue()138 return (mQueue) ? mQueue->getDesc() : nullptr; in getMQDescriptor()570 std::unique_ptr<CommandQueueType> mQueue; variable580 mQueue = std::make_unique<CommandQueueType>(descriptor, false); in setMQDescriptor()581 if (mQueue->isValid()) { in setMQDescriptor()[all …]
426 while (!mQueue.empty()) { in ~RequestQueue()427 request = mQueue.front(); in ~RequestQueue()428 mQueue.pop(); in ~RequestQueue()433 mQueue.push(request); in push()437 if (!mQueue.empty()) { in pop()438 request = mQueue.front(); in pop()439 mQueue.pop(); in pop()446 std::queue<LocationAPIRequest*> mQueue; variable
33 std::unique_ptr<C2Work> work = std::move(mQueue.front().work); in pop_front()34 mQueue.pop_front(); in pop_front()39 mQueue.push_back({ std::move(work), NO_DRAIN }); in push_back()43 return mQueue.empty(); in empty()47 mQueue.clear(); in clear()51 return mQueue.front().drainMode; in drainMode()55 mQueue.push_back({ nullptr, drainMode }); in markDrain()
83 while (!mQueue.empty()) { in reset()84 request = mQueue.front(); in reset()85 mQueue.pop(); in reset()91 mQueue.push(request); in push()95 if (!mQueue.empty()) { in pop()96 request = mQueue.front(); in pop()97 mQueue.pop(); in pop()104 std::queue<LocationAPIRequest*> mQueue; variable
190 std::list<Entry> mQueue; variable