Searched refs:outboundQueue (Results 1 – 3 of 3) sorted by relevance
55 std::deque<std::unique_ptr<DispatchEntry>> outboundQueue; variable
3426 const bool wasEmpty = connection->outboundQueue.empty(); in enqueueDispatchEntryAndStartDispatchCycleLocked()3431 if (wasEmpty && !connection->outboundQueue.empty()) { in enqueueDispatchEntryAndStartDispatchCycleLocked()3591 connection->outboundQueue.emplace_back(std::move(cancelDispatchEntry)); in enqueueDispatchEntryLocked()3635 connection->outboundQueue.emplace_back(std::move(dispatchEntry)); in enqueueDispatchEntryLocked()3793 while (connection->status == Connection::Status::NORMAL && !connection->outboundQueue.empty()) { in startDispatchCycleLocked()3794 std::unique_ptr<DispatchEntry>& dispatchEntry = connection->outboundQueue.front(); in startDispatchCycleLocked()3920 connection->outboundQueue.erase(connection->outboundQueue.begin()); in startDispatchCycleLocked()3996 drainDispatchQueue(connection->outboundQueue); in abortBrokenDispatchCycleLocked()4205 const bool wasEmpty = connection->outboundQueue.empty(); in synthesizeCancelationEventsForConnectionLocked()4291 if (wasEmpty && !connection->outboundQueue.empty()) { in synthesizeCancelationEventsForConnectionLocked()[all …]
16 … to an application, the normal flow is: `mPendingEvent` → `connection.outboundQueue` → `connection…