Searched refs:mPendingWriteEventsQueue (Results 1 – 2 of 2) sorted by relevance
227 mPendingWriteEventsQueue = std::queue<std::pair<std::vector<V2_1::Event>, size_t>>(); in initializeCommon()377 if (!mPendingWriteEventsQueue.empty()) { in debug()379 << mPendingWriteEventsQueue.front().first.size() << std::endl; in debug()578 lock, [&] { return !mPendingWriteEventsQueue.empty() || !mThreadsRun.load(); }); in handlePendingWrites()580 std::vector<Event>& pendingWriteEvents = mPendingWriteEventsQueue.front().first; in handlePendingWrites()581 size_t numWakeupEvents = mPendingWriteEventsQueue.front().second; in handlePendingWrites()609 mPendingWriteEventsQueue.pop(); in handlePendingWrites()669 if (mPendingWriteEventsQueue.empty()) { in postEventsToMessageQueue()685 mPendingWriteEventsQueue.push({eventsLeft, numWakeupEvents}); in postEventsToMessageQueue()
208 std::queue<std::pair<std::vector<Event>, size_t>> mPendingWriteEventsQueue; variable