Searched refs:outboundQueue (Results 1 – 2 of 2) sorted by relevance
56 std::deque<DispatchEntry*> outboundQueue; variable
2276 bool wasEmpty = connection->outboundQueue.empty(); in enqueueDispatchEntriesLocked()2293 if (wasEmpty && !connection->outboundQueue.empty()) { in enqueueDispatchEntriesLocked()2424 connection->outboundQueue.push_back(dispatchEntry.release()); in enqueueDispatchEntryLocked()2467 while (connection->status == Connection::STATUS_NORMAL && !connection->outboundQueue.empty()) { in startDispatchCycleLocked()2468 DispatchEntry* dispatchEntry = connection->outboundQueue.front(); in startDispatchCycleLocked()2603 connection->outboundQueue.erase(std::remove(connection->outboundQueue.begin(), in startDispatchCycleLocked()2604 connection->outboundQueue.end(), in startDispatchCycleLocked()2664 drainDispatchQueue(connection->outboundQueue); in abortBrokenDispatchCycleLocked()4241 if (!connection->outboundQueue.empty()) { in dumpDispatchStateLocked()4243 connection->outboundQueue.size()); in dumpDispatchStateLocked()[all …]