Lines Matching refs:waitQueue
1726 targetType, connection->outboundQueue.count(), connection->waitQueue.count()); in checkWindowReadyForMoreInputLocked()
1742 if (!connection->outboundQueue.isEmpty() || !connection->waitQueue.isEmpty()) { in checkWindowReadyForMoreInputLocked()
1746 targetType, connection->outboundQueue.count(), connection->waitQueue.count()); in checkWindowReadyForMoreInputLocked()
1764 if (!connection->waitQueue.isEmpty() in checkWindowReadyForMoreInputLocked()
1765 && currentTime >= connection->waitQueue.head->deliveryTime in checkWindowReadyForMoreInputLocked()
1771 connection->waitQueue.count(), in checkWindowReadyForMoreInputLocked()
1772 (currentTime - connection->waitQueue.head->deliveryTime) * 0.000001f); in checkWindowReadyForMoreInputLocked()
2082 if (connection->waitQueue.isEmpty()) { in startDispatchCycleLocked()
2110 connection->waitQueue.enqueueAtTail(dispatchEntry); in startDispatchCycleLocked()
2143 drainDispatchQueueLocked(&connection->waitQueue); in abortBrokenDispatchCycleLocked()
3365 if (!connection->waitQueue.isEmpty()) { in dumpDispatchStateLocked()
3367 connection->waitQueue.count()); in dumpDispatchStateLocked()
3368 for (DispatchEntry* entry = connection->waitQueue.head; entry; in dumpDispatchStateLocked()
3657 connection->waitQueue.dequeue(dispatchEntry); in doDispatchCycleFinishedLockedInterruptible()
3886 ATRACE_INT(counterName, connection->waitQueue.count()); in traceWaitQueueLengthLocked()
4490 for (DispatchEntry* entry = waitQueue.head; entry != NULL; entry = entry->next) { in findWaitQueueEntry()