Searched refs:waitQueue (Results 1 – 3 of 3) sorted by relevance
59 std::deque<std::unique_ptr<DispatchEntry>> waitQueue; variable
550 for (const auto& dispatchEntry : connection.waitQueue) { in isConnectionResponsive()3890 if (connection->waitQueue.empty()) { in startDispatchCycleLocked()3919 connection->waitQueue.emplace_back(std::move(dispatchEntry)); in startDispatchCycleLocked()3998 drainDispatchQueue(connection->waitQueue); in abortBrokenDispatchCycleLocked()6033 if (!connection->waitQueue.empty()) { in dumpDispatchStateLocked()6035 connection->waitQueue.size()); in dumpDispatchStateLocked()6036 dump += dumpQueue(connection->waitQueue, currentTime); in dumpDispatchStateLocked()6383 std::find_if(connection->waitQueue.begin(), connection->waitQueue.end(), in doDispatchCycleFinishedCommand()6385 if (dispatchEntryIt == connection->waitQueue.end()) { in doDispatchCycleFinishedCommand()6411 auto entryIt = std::find_if(connection->waitQueue.begin(), connection->waitQueue.end(), in doDispatchCycleFinishedCommand()[all …]
16 …ication, the normal flow is: `mPendingEvent` → `connection.outboundQueue` → `connection.waitQueue`.18 … not responding, we look at the oldest entry in the `waitQueue`. If the entry sits in the `waitQue…31 Looping through `waitQueue`s of all connections on every dispatch cycle could be costly. To improve…37 …particular dispatch entry, that entry is removed from the connection's `waitQueue`, and it is also…