Searched refs:mPendingWriteEventsQueue (Results 1 – 2 of 2) sorted by relevance
212 mPendingWriteEventsQueue = std::queue<std::pair<std::vector<V2_1::Event>, size_t>>(); in initializeCommon()363 if (!mPendingWriteEventsQueue.empty()) { in debug()365 << mPendingWriteEventsQueue.front().first.size() << std::endl; in debug()564 lock, [&] { return !mPendingWriteEventsQueue.empty() || !mThreadsRun.load(); }); in handlePendingWrites()566 std::vector<Event>& pendingWriteEvents = mPendingWriteEventsQueue.front().first; in handlePendingWrites()567 size_t numWakeupEvents = mPendingWriteEventsQueue.front().second; in handlePendingWrites()594 mPendingWriteEventsQueue.pop(); in handlePendingWrites()654 if (mPendingWriteEventsQueue.empty()) { in postEventsToMessageQueue()670 mPendingWriteEventsQueue.push({eventsLeft, numWakeupEvents}); in postEventsToMessageQueue()
206 std::queue<std::pair<std::vector<Event>, size_t>> mPendingWriteEventsQueue; variable