Home
last modified time | relevance | path

Searched refs:Queue (Results 1 – 25 of 102) sorted by relevance

12345

/reactos/ntoskrnl/ke/
H A Dqueue.c30 ASSERT_QUEUE(Queue); in KiActivateWaiterQueue()
33 Queue->CurrentCount--; in KiActivateWaiterQueue()
36 if (Queue->CurrentCount < Queue->MaximumCount) in KiActivateWaiterQueue()
79 ASSERT_QUEUE(Queue); in KiInsertQueue()
92 if ((Queue->CurrentCount < Queue->MaximumCount) && in KiInsertQueue()
94 ((Thread->Queue != Queue) || in KiInsertQueue()
177 ASSERT_QUEUE(Queue); in KeInsertHeadQueue()
203 ASSERT_QUEUE(Queue); in KeInsertQueue()
229 ASSERT_QUEUE(Queue); in KeReadStateQueue()
276 Thread->Queue = Queue; in KeRemoveQueue()
[all …]
H A Dgate.c39 PKQUEUE Queue; in KeWaitForGate() local
60 Queue = Thread->Queue; in KeWaitForGate()
61 if (Queue) KiAcquireDispatcherLockAtSynchLevel(); in KeWaitForGate()
80 if (Queue) KiReleaseDispatcherLockFromSynchLevel(); in KeWaitForGate()
113 if (Queue) in KeWaitForGate()
116 KiActivateWaiterQueue(Queue); in KeWaitForGate()
203 if (WaitThread->Queue) in KeSignalGateBoostPriority()
209 if (WaitThread->Queue) in KeSignalGateBoostPriority()
212 WaitThread->Queue->CurrentCount++; in KeSignalGateBoostPriority()
H A Dwait.c83 if (Thread->Queue) Thread->Queue->CurrentCount++; in KiUnlinkThread()
355 if (Thread->Queue) KiActivateWaiterQueue(Thread->Queue); in KeDelayExecutionThread()
522 if (Thread->Queue) KiActivateWaiterQueue(Thread->Queue); in KeWaitForSingleObject()
814 if (Thread->Queue) KiActivateWaiterQueue(Thread->Queue); in KeWaitForMultipleObjects()
/reactos/sdk/include/wdf/kmdf/1.17/
H A Dwdfio.h234 WDFQUEUE Queue,
250 WDFQUEUE Queue,
267 WDFQUEUE Queue,
282 WDFQUEUE Queue,
299 WDFQUEUE Queue,
316 WDFQUEUE Queue,
337 WDFQUEUE Queue,
359 WDFQUEUE Queue,
375 WDFQUEUE Queue,
684 WDFQUEUE Queue
[all …]
/reactos/sdk/lib/drivers/wdf/shared/inc/private/common/
H A Dfxioqueuecallbacks.hpp84 __in WDFQUEUE Queue, in Invoke() argument
117 __in WDFQUEUE Queue, in Invoke() argument
149 __in WDFQUEUE Queue, in Invoke() argument
182 __in WDFQUEUE Queue, in Invoke() argument
215 __in WDFQUEUE Queue, in Invoke() argument
227 Queue, in Invoke()
256 __in WDFQUEUE Queue, in Invoke() argument
268 Queue, in Invoke()
297 __in WDFQUEUE Queue, in Invoke() argument
326 __in WDFQUEUE Queue, in Invoke() argument
[all …]
H A Dfxpkgio.hpp159 __in_opt FxIoQueue* Queue
185 __inout FxIoQueue * Queue
374 __in FxIoQueue* Queue in IsTopLevelQueue() argument
380 if (m_DispatchTable[index] == Queue) { in IsTopLevelQueue()
H A Dfxrequest.hpp91 __in FxIoQueue* Queue,
626 __in FxIoQueue *Queue in SetForwardProgressQueue() argument
629 m_ForwardProgressQueue = Queue; in SetForwardProgressQueue()
650 __in FxIoQueue *Queue in SetCurrentQueue() argument
653 m_IoQueue = Queue; in SetCurrentQueue()
1344 __in FxIoQueue* Queue
1350 __in FxIoQueue* Queue
1356 __in FxIoQueue* Queue
1362 __in FxIoQueue* Queue
/reactos/sdk/lib/drivers/wdf/shared/irphandlers/io/
H A Dfxioqueueapi.cpp63 WDFQUEUE* Queue in __drv_maxIRQL()
258 WDFQUEUE Queue, in __drv_maxIRQL()
307 WDFQUEUE Queue in __drv_maxIRQL()
344 WDFQUEUE Queue in __drv_maxIRQL()
391 WDFQUEUE Queue, in __drv_maxIRQL()
448 WDFQUEUE Queue in __drv_maxIRQL()
500 WDFQUEUE Queue, in __drv_maxIRQL()
563 WDFQUEUE Queue in __drv_maxIRQL()
621 WDFQUEUE Queue, in __drv_maxIRQL()
1136 WDFQUEUE Queue in __drv_maxIRQL()
[all …]
H A Dfxpkgio.cpp345 __in_opt FxIoQueue* Queue in DispatchStep2() argument
357 isForwardProgressQueue = Queue != NULL && Queue->IsForwardProgressQueue(); in DispatchStep2()
361 Queue != NULL); in DispatchStep2()
376 if (Queue != NULL && Queue->GetCxDeviceInfo() != NULL) { in DispatchStep2()
400 if (m_Filter && Queue == NULL) { in DispatchStep2()
456 request->SetInternalContext(Queue); in DispatchStep2()
466 ASSERT(Queue != NULL); in DispatchStep2()
467 status = Queue->QueueRequest(request); in DispatchStep2()
491 __inout FxIoQueue * Queue in InitializeDefaultQueue() argument
531 m_DefaultQueue = Queue; in InitializeDefaultQueue()
[all …]
/reactos/ntoskrnl/io/iomgr/
H A Diocomp.c102 PKQUEUE Queue = ObjectBody; in IopDeleteIoCompletion() local
109 FirstEntry = KeRundownQueue(Queue); in IopDeleteIoCompletion()
154 PKQUEUE Queue = (PKQUEUE)IoCompletion; in IoSetIoCompletion() local
258 PKQUEUE Queue; in NtCreateIoCompletion() local
297 Status = ObInsertObject(Queue, in NtCreateIoCompletion()
388 PKQUEUE Queue; in NtQueryIoCompletion() local
436 ObDereferenceObject(Queue); in NtQueryIoCompletion()
452 PKQUEUE Queue; in NtRemoveIoCompletion() local
560 ObDereferenceObject(Queue); in NtRemoveIoCompletion()
576 PKQUEUE Queue; in NtSetIoCompletion() local
[all …]
H A Dcontroller.c34 DeviceObject->Queue.Wcb.DeviceContext = Context; in IoAllocateController()
35 DeviceObject->Queue.Wcb.DeviceRoutine = ExecutionRoutine; in IoAllocateController()
39 &DeviceObject->Queue.Wcb.WaitQueueEntry)) in IoAllocateController()
138 Queue.Wcb.WaitQueueEntry); in IoFreeController()
141 Result = DeviceObject->Queue.Wcb.DeviceRoutine(DeviceObject, in IoFreeController()
145 Queue.Wcb.DeviceContext); in IoFreeController()
H A Dvolume.c313 IopInterlockedIncrementUlong(IN KSPIN_LOCK_QUEUE_NUMBER Queue, in IopInterlockedIncrementUlong() argument
319 Irql = KeAcquireQueuedSpinLock(Queue); in IopInterlockedIncrementUlong()
321 KeReleaseQueuedSpinLock(Queue, Irql); in IopInterlockedIncrementUlong()
331 IopInterlockedDecrementUlong(IN KSPIN_LOCK_QUEUE_NUMBER Queue, in IopInterlockedDecrementUlong() argument
337 Irql = KeAcquireQueuedSpinLock(Queue); in IopInterlockedDecrementUlong()
339 KeReleaseQueuedSpinLock(Queue, Irql); in IopInterlockedDecrementUlong()
367 Queue.ListEntry); in IopShutdownBaseFileSystems()
805 Queue.ListEntry); in IopNotifyAlreadyRegisteredFileSystems()
1030 InsertHeadList(FsList, &DeviceObject->Queue.ListEntry); in IoRegisterFileSystem()
1065 if (DeviceObject->Queue.ListEntry.Flink) in IoUnregisterFileSystem()
[all …]
/reactos/ntoskrnl/ex/
H A Dwork.c340 PEX_WORK_QUEUE Queue; in ExpDetectWorkerThreadDeadlock() local
346 Queue = &ExWorkerQueue[i]; in ExpDetectWorkerThreadDeadlock()
350 if ((Queue->QueueDepthLastPass) && in ExpDetectWorkerThreadDeadlock()
351 (Queue->WorkItemsProcessed == Queue->WorkItemsProcessedLastPass) && in ExpDetectWorkerThreadDeadlock()
352 (Queue->DynamicThreadCount < 16)) in ExpDetectWorkerThreadDeadlock()
361 Queue->WorkItemsProcessedLastPass = Queue->WorkItemsProcessed; in ExpDetectWorkerThreadDeadlock()
362 Queue->QueueDepthLastPass = KeReadStateQueue(&Queue->WorkerQueue); in ExpDetectWorkerThreadDeadlock()
385 PEX_WORK_QUEUE Queue; in ExpCheckDynamicThreadCount() local
391 Queue = &ExWorkerQueue[i]; in ExpCheckDynamicThreadCount()
396 (Queue->WorkerQueue.CurrentCount < in ExpCheckDynamicThreadCount()
[all …]
/reactos/sdk/lib/drivers/wdf/shared/enhancedverif/
H A Dvfeventhooks.cpp679 WDFQUEUE Queue, in VfEvtIoDefault() argument
695 Queue, in VfEvtIoDefault()
720 WDFQUEUE Queue, in VfEvtIoStop() argument
767 WDFQUEUE Queue, in VfEvtIoResume() argument
788 Queue, in VfEvtIoResume()
801 WDFQUEUE Queue, in VfEvtIoRead() argument
845 WDFQUEUE Queue, in VfEvtIoWrite() argument
889 WDFQUEUE Queue, in VfEvtIoDeviceControl() argument
939 WDFQUEUE Queue, in VfEvtIoInternalDeviceControl() argument
989 WDFQUEUE Queue, in VfEvtIoCanceledOnQueue() argument
[all …]
/reactos/modules/rosapps/drivers/green/
H A Dkeyboard.c149 ULONG Queue; in KeyboardDpcSendData() local
154 Queue = DeviceExtension->ActiveQueue % 2; in KeyboardDpcSendData()
158 DeviceExtension->KeyboardInputData[Queue], in KeyboardDpcSendData()
159 DeviceExtension->KeyboardInputData[Queue] + DeviceExtension->InputDataCount[Queue], in KeyboardDpcSendData()
162 DeviceExtension->InputDataCount[Queue] = 0; in KeyboardDpcSendData()
180 ULONG i, Queue; in KeyboardDeviceWorker() local
233 Queue = DeviceExtension->ActiveQueue % 2; in KeyboardDeviceWorker()
235 Input = &DeviceExtension->KeyboardInputData[Queue][DeviceExtension->InputDataCount[Queue]]; in KeyboardDeviceWorker()
238 SpaceInQueue = KEYBOARD_BUFFER_SIZE - DeviceExtension->InputDataCount[Queue]; in KeyboardDeviceWorker()
247 DeviceExtension->InputDataCount[Queue] += BytesConsumed; in KeyboardDeviceWorker()
/reactos/drivers/input/sermouse/
H A Dreadmouse.c75 ULONG Queue; in SermouseDeviceWorker() local
186 Queue = DeviceExtension->ActiveQueue % 2; in SermouseDeviceWorker()
189 if (DeviceExtension->InputDataCount[Queue] == 1) in SermouseDeviceWorker()
192 Input = &DeviceExtension->MouseInputData[Queue]; in SermouseDeviceWorker()
257 DeviceExtension->InputDataCount[Queue]++; in SermouseDeviceWorker()
263 &DeviceExtension->MouseInputData[Queue], in SermouseDeviceWorker()
264 &DeviceExtension->MouseInputData[Queue] + 1, in SermouseDeviceWorker()
265 &DeviceExtension->InputDataCount[Queue]); in SermouseDeviceWorker()
267 DeviceExtension->InputDataCount[Queue] = 0; in SermouseDeviceWorker()
/reactos/drivers/filesystems/npfs/
H A Ddatasup.c43 InitializeListHead(&DataQueue->Queue); in NpInitializeDataQueue()
60 NextEntry = DataQueue->Queue.Flink; in NpCompleteStalledWrites()
61 while (NextEntry != &DataQueue->Queue) in NpCompleteStalledWrites()
116 ASSERT(IsListEmpty(&DataQueue->Queue)); in NpRemoveDataQueueEntry()
140 if (IsListEmpty(&DataQueue->Queue)) in NpRemoveDataQueueEntry()
183 for (NextEntry = DataQueue->Queue.Flink; in NpGetNextRealDataQueueEntry()
184 NextEntry != &DataQueue->Queue; in NpGetNextRealDataQueueEntry()
185 NextEntry = DataQueue->Queue.Flink) in NpGetNextRealDataQueueEntry()
232 if (DataEntry->QueueEntry.Blink == &DataQueue->Queue) in NpCancelDataQueueIrp()
258 if (IsListEmpty(&DataQueue->Queue)) in NpCancelDataQueueIrp()
[all …]
H A Dreadsup.c45 DataEntry = CONTAINING_RECORD(DataQueue->Queue.Flink, in NpReadDataQueue()
56 while ((&DataEntry->QueueEntry != &DataQueue->Queue) && (RemainingSize)) in NpReadDataQueue()
74 if (&DataEntry->QueueEntry == DataQueue->Queue.Flink) in NpReadDataQueue()
/reactos/sdk/lib/drivers/wdf/shared/enhancedverif/um/
H A Dvfprivum.hpp242 __in WDFQUEUE Queue, in PerfEvtIoStopStart() argument
250 FxObject *pObject = FxObject::_GetObjectFromHandle(Queue, &offset); in PerfEvtIoStopStart()
254 Queue, in PerfEvtIoStopStart()
267 __in WDFQUEUE Queue, in PerfEvtIoStopStop() argument
275 FxObject *pObject = FxObject::_GetObjectFromHandle(Queue, &offset); in PerfEvtIoStopStop()
279 Queue, in PerfEvtIoStopStop()
H A Dvfwdfdynamics.cpp549 WDFQUEUE Queue, in _IRQL_requires_max_()
1105 WDFQUEUE Queue, in _IRQL_requires_max_()
2039 WDFQUEUE* Queue in _IRQL_requires_max_()
2054 Queue); in _IRQL_requires_max_()
2090 WDFQUEUE Queue in _IRQL_requires_max_()
2124 WDFQUEUE Queue in _IRQL_requires_max_()
2138 WDFQUEUE Queue in _IRQL_requires_max_()
2242 WDFQUEUE Queue in _IRQL_requires_max_()
2276 WDFQUEUE Queue in _IRQL_requires_max_()
2349 WDFQUEUE Queue in _IRQL_requires_max_()
[all …]
/reactos/sdk/lib/drivers/wdf/shared/enhancedverif/km/
H A Dvfprivkm.hpp308 __in WDFQUEUE Queue, in PerfEvtIoStopStart() argument
317 FxObject *pObject = FxObject::_GetObjectFromHandle(Queue, &offset); in PerfEvtIoStopStart()
323 Queue, in PerfEvtIoStopStart()
338 __in WDFQUEUE Queue, in PerfEvtIoStopStop() argument
347 FxObject *pObject = FxObject::_GetObjectFromHandle(Queue, &offset); in PerfEvtIoStopStop()
350 Queue, in PerfEvtIoStopStop()
/reactos/subsystems/mvdm/ntvdm/hardware/
H A Dps2.c38 BYTE Queue[BUFFER_SIZE]; member
434 OutputBuffer = Port->Queue[(Port->QueueStart - 1) % BUFFER_SIZE]; in PS2PortQueueRead()
450 OutputBuffer = Port->Queue[Port->QueueStart]; in PS2PortQueueRead()
503 Port->Queue[Port->QueueEnd] = Data; in PS2QueuePush()
/reactos/media/doc/
H A Dirp cancel boilerplate.c62 InsertTailList(Queue);
73 Irp = RemoveHeadList(Queue);
/reactos/drivers/storage/port/storahci/
H A Dstorahci.c2502 __inout PAHCI_QUEUE Queue, in AddQueue() argument
2506 NT_ASSERT(Queue->Head < MAXIMUM_QUEUE_BUFFER_SIZE); in AddQueue()
2507 NT_ASSERT(Queue->Tail < MAXIMUM_QUEUE_BUFFER_SIZE); in AddQueue()
2509 if (Queue->Tail == ((Queue->Head + 1) % MAXIMUM_QUEUE_BUFFER_SIZE)) in AddQueue()
2512 Queue->Buffer[Queue->Head++] = Srb; in AddQueue()
2513 Queue->Head %= MAXIMUM_QUEUE_BUFFER_SIZE; in AddQueue()
2533 __inout PAHCI_QUEUE Queue in RemoveQueue() argument
2538 NT_ASSERT(Queue->Head < MAXIMUM_QUEUE_BUFFER_SIZE); in RemoveQueue()
2541 if (Queue->Head == Queue->Tail) in RemoveQueue()
2544 Srb = Queue->Buffer[Queue->Tail++]; in RemoveQueue()
[all …]
/reactos/sdk/lib/drivers/wdf/shared/core/
H A Dfxrequest.cpp876 __in FxIoQueue* Queue in PostProcessCompletion() argument
893 ASSERT(Queue != NULL); in PostProcessCompletion()
894 Queue->RequestCompletedCallback(this); in PostProcessCompletion()
918 __in FxIoQueue* Queue in PostProcessCompletionForReserved() argument
935 ASSERT(m_IoQueue == Queue); in PostProcessCompletionForReserved()
936 Queue->RequestCompletedCallback(this); in PostProcessCompletionForReserved()
957 __in FxIoQueue* Queue in PreProcessCompletionForDriverRequest() argument
972 Queue->PreRequestCompletedCallback(this); in PreProcessCompletionForDriverRequest()
974 else if (Queue != NULL){ in PreProcessCompletionForDriverRequest()
998 __in FxIoQueue* Queue in PostProcessCompletionForDriverRequest() argument
[all …]

12345