Home
last modified time | relevance | path

Searched refs:Semaphore (Results 1 – 25 of 26) sorted by relevance

12

/reactos/ntoskrnl/ke/
H A Dsemphobj.c22 KeInitializeSemaphore(IN PKSEMAPHORE Semaphore, in KeInitializeSemaphore() argument
27 Semaphore->Header.Type = SemaphoreObject; in KeInitializeSemaphore()
29 Semaphore->Header.SignalState = Count; in KeInitializeSemaphore()
33 Semaphore->Limit = Limit; in KeInitializeSemaphore()
41 KeReadStateSemaphore(IN PKSEMAPHORE Semaphore) in KeReadStateSemaphore() argument
43 ASSERT_SEMAPHORE(Semaphore); in KeReadStateSemaphore()
46 return Semaphore->Header.SignalState; in KeReadStateSemaphore()
54 KeReleaseSemaphore(IN PKSEMAPHORE Semaphore, in KeReleaseSemaphore() argument
62 ASSERT_SEMAPHORE(Semaphore); in KeReleaseSemaphore()
69 InitialState = Semaphore->Header.SignalState; in KeReleaseSemaphore()
[all …]
/reactos/ntoskrnl/ex/
H A Dsem.c75 PKSEMAPHORE Semaphore; in NtCreateSemaphore() local
116 (PVOID*)&Semaphore); in NtCreateSemaphore()
122 KeInitializeSemaphore(Semaphore, in NtCreateSemaphore()
127 Status = ObInsertObject((PVOID)Semaphore, in NtCreateSemaphore()
228 PKSEMAPHORE Semaphore; in NtQuerySemaphore() local
256 (PVOID*)&Semaphore, in NtQuerySemaphore()
270 BasicInfo->MaximumCount = Semaphore->Limit; in NtQuerySemaphore()
283 ObDereferenceObject(Semaphore); in NtQuerySemaphore()
300 PKSEMAPHORE Semaphore; in NtReleaseSemaphore() local
333 (PVOID*)&Semaphore, in NtReleaseSemaphore()
[all …]
H A Dresource.c263 PKSEMAPHORE Semaphore; in ExpAllocateSharedWaiterSemaphore() local
272 Semaphore = ExAllocatePoolWithTag(NonPagedPool, in ExpAllocateSharedWaiterSemaphore()
275 if (Semaphore) in ExpAllocateSharedWaiterSemaphore()
278 KeInitializeSemaphore(Semaphore, 0, MAXLONG); in ExpAllocateSharedWaiterSemaphore()
282 Semaphore, in ExpAllocateSharedWaiterSemaphore()
287 ExFreePoolWithTag(Semaphore, TAG_RESOURCE_SEMAPHORE); in ExpAllocateSharedWaiterSemaphore()
1764 PKSEMAPHORE Semaphore; in ExReinitializeResourceLite() local
1788 Semaphore = Resource->SharedWaiters; in ExReinitializeResourceLite()
1789 if (Semaphore) KeInitializeSemaphore(Semaphore, 0, MAXLONG); in ExReinitializeResourceLite()
/reactos/win32ss/gdi/eng/
H A Dsemaphor.c148 _Out_ ENGSAFESEMAPHORE *Semaphore) in EngInitializeSafeSemaphore() argument
152 if (InterlockedIncrement(&Semaphore->lCount) == 1) in EngInitializeSafeSemaphore()
158 InterlockedDecrement(&Semaphore->lCount); in EngInitializeSafeSemaphore()
163 (void)InterlockedExchangePointer((volatile PVOID *)&Semaphore->hsem, hSem); in EngInitializeSafeSemaphore()
168 ASSERT(Semaphore->lCount > 1); in EngInitializeSafeSemaphore()
170 while (Semaphore->hsem == NULL); in EngInitializeSafeSemaphore()
/reactos/ntoskrnl/lpc/
H A Dsend.c150 LpcpCompleteWait(QueuePort->MsgQueue.Semaphore); in LpcRequestPort()
190 PKSEMAPHORE Semaphore; in LpcRequestWaitReplyPort() local
254 Semaphore = NULL; // we'd use the Thread Semaphore here in LpcRequestWaitReplyPort()
344 Semaphore = QueuePort->MsgQueue.Semaphore; in LpcRequestWaitReplyPort()
355 LpcpCompleteWait(Semaphore); in LpcRequestWaitReplyPort()
615 LpcpCompleteWait(QueuePort->MsgQueue.Semaphore); in NtRequestPort()
708 PKSEMAPHORE Semaphore; in NtRequestWaitReplyPort() local
837 Semaphore = NULL; // we'd use the Thread Semaphore here in NtRequestWaitReplyPort()
952 Semaphore = QueuePort->MsgQueue.Semaphore; in NtRequestWaitReplyPort()
963 LpcpCompleteWait(Semaphore); in NtRequestWaitReplyPort()
H A Dcreate.c32 KeInitializeSemaphore(&MessageQueue->Semaphore, 0, MAXLONG); in LpcpInitializePortQueue()
36 Port->MsgQueue.Semaphore = &MessageQueue->Semaphore; in LpcpInitializePortQueue()
H A Dclose.c231 if (Port->MsgQueue.Semaphore) in LpcpDestroyPortQueue()
234 MessageQueue = CONTAINING_RECORD(Port->MsgQueue.Semaphore, in LpcpDestroyPortQueue()
236 Semaphore); in LpcpDestroyPortQueue()
H A Dconnect.c598 LpcpCompleteWait(Port->MsgQueue.Semaphore); in NtSecureConnectPort()
H A Dreply.c598 LpcpReceiveWait(ReceivePort->MsgQueue.Semaphore, WaitMode); in NtReplyWaitReceivePortEx()
/reactos/drivers/bus/acpi/acpica/executer/
H A Dexsystem.c69 ACPI_SEMAPHORE Semaphore, in AcpiExSystemWaitSemaphore() argument
78 Status = AcpiOsWaitSemaphore (Semaphore, 1, ACPI_DO_NOT_WAIT); in AcpiExSystemWaitSemaphore()
89 Status = AcpiOsWaitSemaphore (Semaphore, 1, Timeout); in AcpiExSystemWaitSemaphore()
/reactos/dll/win32/kernel32/client/
H A Dsynch.c435 …ConvertWin32AnsiObjectApiToUnicodeApi(Semaphore, lpName, lpSemaphoreAttributes, lInitialCount, lMa… in CreateSemaphoreA()
449 CreateNtObjectFromWin32Api(Semaphore, Semaphore, SEMAPHORE_ALL_ACCESS, in CreateSemaphoreW()
466 CreateNtObjectFromWin32Api(Semaphore, Semaphore, dwDesiredAccess, in CreateSemaphoreExW()
520 ConvertOpenWin32AnsiObjectApiToUnicodeApi(Semaphore, dwDesiredAccess, bInheritHandle, lpName); in OpenSemaphoreA()
533 OpenNtObjectFromWin32Api(Semaphore, dwDesiredAccess, bInheritHandle, lpName); in OpenSemaphoreW()
/reactos/sdk/include/ndk/
H A Dlpctypes.h195 KSEMAPHORE Semaphore; member
202 PKSEMAPHORE Semaphore; member
/reactos/subsystems/mvdm/pifmgr/res_alt/
H A DREADME.txt36 Semaphore, based on
/reactos/drivers/ksfilter/ks/
H A Devent.c237 …Status = ObReferenceObjectByHandle(EventData->SemaphoreHandle.Semaphore, SEMAPHORE_MODIFY_STATE, *… in KspEnableEvent()
333 EventEntry->Object = EventData->SemaphoreObject.Semaphore; in KspEnableEvent()
/reactos/sdk/include/xdk/
H A Dkefuncs.h302 _Out_ PRKSEMAPHORE Semaphore,
390 _In_ PRKSEMAPHORE Semaphore);
425 _Inout_ PRKSEMAPHORE Semaphore,
/reactos/modules/rostests/kmtests/ntos_ob/
H A DObTypes.c207 …CheckObjectType(Semaphore, *ExSemaphoreObjectType, OBT_NO_DEFAULT, … in TestObjectTypes()
/reactos/drivers/filters/fltmgr/
H A Dfltmgrint.h208 KSEMAPHORE Semaphore; member
H A DMessaging.c809 KeInitializeSemaphore(&MsgWaiterQueue->Semaphore, 0, MAXLONG); in InitializeMessageWaiterQueue()
/reactos/drivers/bus/acpi/acpica/include/
H A Dacinterp.h451 ACPI_SEMAPHORE Semaphore,
/reactos/sdk/include/psdk/
H A Dd3dukmdt.h1697 } Semaphore; member
1788 } Semaphore; member
H A Dks.h1740 HANDLE Semaphore; member
1751 PVOID Semaphore; member
/reactos/media/drivers/etc/
H A Dprotocol108 scc-sp 96 SCC-SP # Semaphore Communications Sec. Pro.
H A Dservices721 sfs-smp-net 451/tcp #Cray Network Semaphore server
722 sfs-smp-net 451/udp #Cray Network Semaphore server
5294 semaphore 3255/tcp #Semaphore Connection Port
5295 semaphore 3255/udp #Semaphore Connection Port
/reactos/dll/directx/ksproxy/
H A Dproxy.cpp759 Event->EventData.SemaphoreHandle.Semaphore = (HANDLE)hSemaphore; in AdvisePeriodic()
/reactos/dll/win32/kernel32/winnls/lang/
H A Dde-DE.mc592 ERROR_TOO_MANY_SEMAPHORES - Es kann keine weitere System-Semaphore erstellt werden.
600 ERROR_EXCL_SEM_ALREADY_OWNED - Die exklusive Semaphore geh�rt einem anderen Prozess.
608 ERROR_SEM_IS_SET - Die Semaphore ist gesetzt und kann nicht geschlossen werden.
616 ERROR_TOO_MANY_SEM_REQUESTS - Die Semaphore kann nicht erneut gesetzt werden.
632 ERROR_SEM_OWNER_DIED - Der vorherige Eigent�mer dieser Semaphore wurde beendet.
744 ERROR_SEM_TIMEOUT - Der Timeout f�r die Semaphore ist abgelaufen.
1528 ERROR_TOO_MANY_POSTS - Es wurden zu viele Aufrufe zu einer Semaphore gemacht.

12