| /reactos/subsystems/csr/csrsrv/ |
| H A D | wait.c | 57 PCSR_WAIT_BLOCK WaitBlock; in CsrInitializeWait() local
66 if (!WaitBlock) in CsrInitializeWait()
74 WaitBlock->Size = Size; in CsrInitializeWait()
78 WaitBlock->WaitList.Flink = NULL; in CsrInitializeWait()
87 *NewWaitBlock = WaitBlock; in CsrInitializeWait()
137 WaitBlock->WaitThread->WaitBlock = NULL; in CsrNotifyWaitBlock()
215 PCSR_WAIT_BLOCK WaitBlock; in CsrCreateWait() local
240 CsrWaitThread->WaitBlock = WaitBlock; in CsrCreateWait()
269 PCSR_WAIT_BLOCK WaitBlock; in CsrDereferenceWait() local
334 PCSR_WAIT_BLOCK WaitBlock; in CsrMoveSatisfiedWait() local
[all …]
|
| H A D | thredsup.c | 842 if (CsrThread->WaitBlock) in CsrDestroyThread()
845 CsrNotifyWaitBlock(CsrThread->WaitBlock, in CsrDestroyThread()
|
| H A D | api.h | 190 CsrNotifyWaitBlock(IN PCSR_WAIT_BLOCK WaitBlock,
|
| H A D | procsup.c | 784 if (CsrThread->WaitBlock) in CsrDestroyProcess()
787 CsrNotifyWaitBlock(CsrThread->WaitBlock, in CsrDestroyProcess()
|
| /reactos/ntoskrnl/ex/ |
| H A D | pushlock.c | 113 WaitBlock = FirstWaitBlock; in ExfWakePushLock()
133 WaitBlock = WaitBlock->Next; in ExfWakePushLock()
177 if (WaitBlock->Previous) in ExfWakePushLock()
206 if (!WaitBlock) break; in ExfWakePushLock()
270 WaitBlock = WaitBlock->Next; in ExpOptimizePushLockList()
535 WaitBlock->Last = WaitBlock; in ExfAcquirePushLockExclusive()
719 WaitBlock->Last = WaitBlock; in ExfAcquirePushLockShared()
870 WaitBlock = WaitBlock->Next; in ExfReleasePushLock()
1009 WaitBlock = WaitBlock->Next; in ExfReleasePushLockShared()
1213 if (WaitBlock) in ExfUnblockPushLock()
[all …]
|
| H A D | rundown.c | 200 PEX_RUNDOWN_WAIT_BLOCK WaitBlock; in ExfReleaseRundownProtection() local
264 PEX_RUNDOWN_WAIT_BLOCK WaitBlock; in ExfReleaseRundownProtectionEx() local
327 EX_RUNDOWN_WAIT_BLOCK WaitBlock; in ExfWaitForRundownProtectionRelease() local
351 KeInitializeEvent(&WaitBlock.WakeEvent, in ExfWaitForRundownProtectionRelease()
356 Event = &WaitBlock.WakeEvent; in ExfWaitForRundownProtectionRelease()
360 WaitBlock.Count = Count; in ExfWaitForRundownProtectionRelease()
376 ASSERT(WaitBlock.Count == 0); in ExfWaitForRundownProtectionRelease()
441 EX_RUNDOWN_WAIT_BLOCK WaitBlock; in ExfWaitForRundownProtectionReleaseCacheAware() local
453 WaitBlock.Count = 0; in ExfWaitForRundownProtectionReleaseCacheAware()
487 KeInitializeEvent(&WaitBlock.WakeEvent, in ExfWaitForRundownProtectionReleaseCacheAware()
[all …]
|
| H A D | handle.c | 862 EX_PUSH_LOCK_WAIT_BLOCK WaitBlock; in ExpBlockOnLockedHandleEntry() local
865 ExBlockPushLock(&HandleTable->HandleContentionEvent, &WaitBlock); in ExpBlockOnLockedHandleEntry()
872 ExfUnblockPushLock(&HandleTable->HandleContentionEvent, &WaitBlock); in ExpBlockOnLockedHandleEntry()
878 &WaitBlock); in ExpBlockOnLockedHandleEntry()
|
| /reactos/ntoskrnl/ke/ |
| H A D | wait.c | 24 PKWAIT_BLOCK WaitBlock; in KiWaitTest() local
36 WaitThread = WaitBlock->Thread; in KiWaitTest()
40 if (WaitBlock->WaitType == WaitAny) in KiWaitTest()
58 PKWAIT_BLOCK WaitBlock; in KiUnlinkThread() local
65 WaitBlock = Thread->WaitBlockList; in KiUnlinkThread()
72 WaitBlock = WaitBlock->NextWaitBlock; in KiUnlinkThread()
424 PKWAIT_BLOCK WaitBlock = &Thread->WaitBlock[0]; in KeWaitForSingleObject() local
596 PKWAIT_BLOCK WaitBlock; in KeWaitForMultipleObjects() local
765 WaitBlock = WaitBlock->NextWaitBlock; in KeWaitForMultipleObjects()
799 WaitBlock = WaitBlockArray; in KeWaitForMultipleObjects()
[all …]
|
| H A D | queue.c | 28 PKWAIT_BLOCK WaitBlock; in KiActivateWaiterQueue() local
56 WaitBlock = CONTAINING_RECORD(WaitEntry, in KiActivateWaiterQueue()
59 Thread = WaitBlock->Thread; in KiActivateWaiterQueue()
76 PKWAIT_BLOCK WaitBlock; in KiInsertQueue() local
101 WaitBlock = CONTAINING_RECORD(WaitEntry, KWAIT_BLOCK, WaitListEntry); in KiInsertQueue()
102 Thread = WaitBlock->Thread; in KiInsertQueue()
246 PKWAIT_BLOCK WaitBlock = &Thread->WaitBlock[0]; in KeRemoveQueue() local
247 PKWAIT_BLOCK TimerBlock = &Thread->WaitBlock[TIMER_WAIT_BLOCK]; in KeRemoveQueue()
376 &WaitBlock->WaitListEntry); in KeRemoveQueue()
|
| H A D | gate.c | 88 GateWaitBlock = &Thread->WaitBlock[0]; in KeWaitForGate()
139 PKWAIT_BLOCK WaitBlock; in KeSignalGateBoostPriority() local
166 WaitBlock = CONTAINING_RECORD(Gate->Header.WaitListHead.Flink, in KeSignalGateBoostPriority()
171 WaitThread = WaitBlock->Thread; in KeSignalGateBoostPriority()
185 RemoveEntryList(&WaitBlock->WaitListEntry); in KeSignalGateBoostPriority()
|
| H A D | eventobj.c | 233 PKWAIT_BLOCK WaitBlock; in KeSetEventBoostPriority() local
253 WaitBlock = CONTAINING_RECORD(Event->Header.WaitListHead.Flink, in KeSetEventBoostPriority()
258 if (WaitBlock->WaitType == WaitAll) in KeSetEventBoostPriority()
269 WaitThread = WaitBlock->Thread; in KeSetEventBoostPriority()
|
| /reactos/sdk/lib/drivers/wdf/shared/inc/primitives/um/ |
| H A D | mxworkitemum.h | 66 PTP_WAIT WaitBlock; member
126 m_WorkItem->WaitBlock = CreateThreadpoolWait( in Allocate()
132 if (m_WorkItem->WaitBlock == NULL) { in Allocate()
190 SetThreadpoolWait(m_WorkItem->WaitBlock, in Enqueue()
225 if (NULL != Item->WaitBlock) { in _Free()
230 SetThreadpoolWait(Item->WaitBlock, NULL, NULL); in _Free()
240 WaitForThreadpoolWaitCallbacks(Item->WaitBlock, in _Free()
248 CloseThreadpoolWait(Item->WaitBlock); in _Free()
|
| /reactos/ntoskrnl/include/internal/ |
| H A D | ke_x.h | 1118 WaitBlock = &WaitBlockArray[Index]; \
1193 WaitBlock->NextWaitBlock = WaitBlock; \
1239 WaitBlock->NextWaitBlock = WaitBlock; \
1263 PKWAIT_BLOCK WaitBlock; in KxUnwaitThread() local
1277 WaitThread = WaitBlock->Thread; in KxUnwaitThread()
1280 if (WaitBlock->WaitType == WaitAny) in KxUnwaitThread()
1283 WaitKey = WaitBlock->WaitKey; in KxUnwaitThread()
1308 PKWAIT_BLOCK WaitBlock; in KxUnwaitThreadForEvent() local
1321 WaitThread = WaitBlock->Thread; in KxUnwaitThreadForEvent()
1324 if (WaitBlock->WaitType == WaitAny) in KxUnwaitThreadForEvent()
[all …]
|
| H A D | ntoskrnl.h | 108 C_ASSERT(FIELD_OFFSET(KTHREAD, SystemAffinityActive) == FIELD_OFFSET(KTHREAD, WaitBlock) + FIELD_OF…
121 C_ASSERT(FIELD_OFFSET(KTHREAD, WaitBlock) == 0x0A8);
125 C_ASSERT(FIELD_OFFSET(KTHREAD, PreviousMode) == FIELD_OFFSET(KTHREAD, WaitBlock) + sizeof(KWAIT_BLO…
126 C_ASSERT(FIELD_OFFSET(KTHREAD, ResourceIndex) == FIELD_OFFSET(KTHREAD, WaitBlock) + 2*sizeof(KWAIT_…
127 C_ASSERT(FIELD_OFFSET(KTHREAD, LargeStack) == FIELD_OFFSET(KTHREAD, WaitBlock) + 3*sizeof(KWAIT_BLO…
|
| /reactos/sdk/lib/rtl/ |
| H A D | srw.c | 202 PRTLP_SRWLOCK_WAITBLOCK WaitBlock; in RtlpAcquireWaitBlockLock() local
226 return WaitBlock; in RtlpAcquireWaitBlockLock()
244 if (WaitBlock->Wake != 0) in RtlpAcquireSRWLockExclusiveWait()
529 PRTLP_SRWLOCK_WAITBLOCK WaitBlock; in RtlReleaseSRWLockShared() local
542 WaitBlock = RtlpAcquireWaitBlockLock(SRWLock); in RtlReleaseSRWLockShared()
543 if (WaitBlock != NULL) in RtlReleaseSRWLockShared()
545 LastShared = (--WaitBlock->SharedCount == 0); in RtlReleaseSRWLockShared()
713 PRTLP_SRWLOCK_WAITBLOCK WaitBlock; in RtlReleaseSRWLockExclusive() local
730 WaitBlock = RtlpAcquireWaitBlockLock(SRWLock); in RtlReleaseSRWLockExclusive()
731 if (WaitBlock != NULL) in RtlReleaseSRWLockExclusive()
[all …]
|
| /reactos/sdk/lib/drivers/wdf/shared/primitives/um/ |
| H A D | mxworkitemum.cpp | 56 Mx::MxAssert(NULL != m_WorkItem->WaitBlock); in WaitForCallbacksToComplete()
61 WaitForThreadpoolWaitCallbacks(m_WorkItem->WaitBlock, in WaitForCallbacksToComplete()
|
| /reactos/modules/rostests/kmtests/ntos_ke/ |
| H A D | KeEvent.c | 24 WaitBlock[0].WaitListEntry); \
154 KWAIT_BLOCK WaitBlock[RTL_NUMBER_OF(Threads)]; in TestEventConcurrent() local
203 …dObjects, SatisfiesAll ? WaitAll : WaitAny, Executive, KernelMode, FALSE, &LongTimeout, WaitBlock); in TestEventConcurrent()
219 …jects(ThreadCount, ThreadObjects, WaitAny, Executive, KernelMode, FALSE, &ShortTimeout, WaitBlock); in TestEventConcurrent()
|
| H A D | KeTimer.c | 24 WaitBlock[0].WaitListEntry); \
|
| /reactos/sdk/include/ndk/tests/ |
| H A D | win8_x86.c | 55 C_ASSERT_FIELD(KTHREAD, 0x0E0, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | win7_x86.c | 51 C_ASSERT_FIELD(KTHREAD, 0x0C0, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | win8_x64.c | 49 C_ASSERT_FIELD(KTHREAD, 0x140, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | winvista_x86.c | 52 C_ASSERT_FIELD(KTHREAD, 0x0B8, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | winvista_x64.c | 42 C_ASSERT_FIELD(KTHREAD, 0x0F8, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | win81_x86.c | 71 C_ASSERT_FIELD(KTHREAD, 0x0E0, KWAIT_BLOCK[4], WaitBlock)
|
| H A D | win81_x64.c | 49 C_ASSERT_FIELD(KTHREAD, 0x140, KWAIT_BLOCK[4], WaitBlock)
|