Lines Matching refs:Queue
102 PKQUEUE Queue = ObjectBody; in IopDeleteIoCompletion() local
109 FirstEntry = KeRundownQueue(Queue); in IopDeleteIoCompletion()
154 PKQUEUE Queue = (PKQUEUE)IoCompletion; in IoSetIoCompletion() local
203 KeInsertQueue(Queue, &Packet->ListEntry); in IoSetIoCompletion()
258 PKQUEUE Queue; in NtCreateIoCompletion() local
290 (PVOID*)&Queue); in NtCreateIoCompletion()
294 KeInitializeQueue(Queue, NumberOfConcurrentThreads); in NtCreateIoCompletion()
297 Status = ObInsertObject(Queue, in NtCreateIoCompletion()
388 PKQUEUE Queue; in NtQueryIoCompletion() local
411 (PVOID*)&Queue, in NtQueryIoCompletion()
420 Depth = KeReadStateQueue(Queue); in NtQueryIoCompletion()
436 ObDereferenceObject(Queue); in NtQueryIoCompletion()
452 PKQUEUE Queue; in NtRemoveIoCompletion() local
494 (PVOID*)&Queue, in NtRemoveIoCompletion()
499 ListEntry = KeRemoveQueue(Queue, PreviousMode, Timeout); in NtRemoveIoCompletion()
560 ObDereferenceObject(Queue); in NtRemoveIoCompletion()
576 PKQUEUE Queue; in NtSetIoCompletion() local
584 (PVOID*)&Queue, in NtSetIoCompletion()
589 Status = IoSetIoCompletion(Queue, in NtSetIoCompletion()
597 ObDereferenceObject(Queue); in NtSetIoCompletion()