Searched refs:mPendingWriteEventsQueue (Results 1 – 2 of 2) sorted by relevance
152 mPendingWriteEventsQueue = std::queue<std::pair<std::vector<Event>, size_t>>(); in initialize()295 if (!mPendingWriteEventsQueue.empty()) { in debug()297 << mPendingWriteEventsQueue.front().first.size() << std::endl; in debug()487 lock, [&] { return !mPendingWriteEventsQueue.empty() || !mThreadsRun.load(); }); in handlePendingWrites()489 std::vector<Event>& pendingWriteEvents = mPendingWriteEventsQueue.front().first; in handlePendingWrites()490 size_t numWakeupEvents = mPendingWriteEventsQueue.front().second; in handlePendingWrites()517 mPendingWriteEventsQueue.pop(); in handlePendingWrites()577 if (mPendingWriteEventsQueue.empty()) { in postEventsToMessageQueue()593 mPendingWriteEventsQueue.push({eventsLeft, numWakeupEvents}); in postEventsToMessageQueue()
201 std::queue<std::pair<std::vector<Event>, size_t>> mPendingWriteEventsQueue; variable