semphobj.c File Reference

#include <ntoskrnl.h>
#include <debug.h>

Include dependency graph for semphobj.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
VOID NTAPI	KeInitializeSemaphore (IN PKSEMAPHORE Semaphore, IN LONG Count, IN LONG Limit)
LONG NTAPI	KeReadStateSemaphore (IN PKSEMAPHORE Semaphore)
LONG NTAPI	KeReleaseSemaphore (IN PKSEMAPHORE Semaphore, IN KPRIORITY Increment, IN LONG Adjustment, IN BOOLEAN Wait)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 12 of file semphobj.c.

Function Documentation

KeInitializeSemaphore()

VOID NTAPI KeInitializeSemaphore	(	IN PKSEMAPHORE	Semaphore,
		IN LONG	Count,
		IN LONG	Limit
	)

Definition at line 22 of file semphobj.c.

{
    /* Simply Initialize the Header */
    Semaphore->Header.Type = SemaphoreObject;
    Semaphore->Header.Size = sizeof(KSEMAPHORE) / sizeof(ULONG);
    Semaphore->Header.SignalState = Count;
    InitializeListHead(&(Semaphore->Header.WaitListHead));
 
    /* Set the Limit */
    Semaphore->Limit = Limit;
}

Referenced by DLDAcquireShared(), DriverEntry(), ExpAllocateSharedWaiterSemaphore(), ExReinitializeResourceLite(), FsRtlInitSystem(), HDA_InitCodec(), InitializeMessageWaiterQueue(), KeInitThread(), LpcpInitializePortQueue(), NtCreateSemaphore(), PspCreateThread(), SacInitializeLock(), USBH_AddDevice(), USBH_StartHubFdoDevice(), and USBPORT_AddDevice().

KeReadStateSemaphore()

LONG NTAPI KeReadStateSemaphore

(

IN PKSEMAPHORE

Semaphore

)

Definition at line 41 of file semphobj.c.

{
    ASSERT_SEMAPHORE(Semaphore);
 
    /* Just return the Signal State */
    return Semaphore->Header.SignalState;
}

Referenced by LpcpDestroyPortQueue(), NtQuerySemaphore(), and NtSecureConnectPort().

KeReleaseSemaphore()

LONG NTAPI KeReleaseSemaphore	(	IN PKSEMAPHORE	Semaphore,
		IN KPRIORITY	Increment,
		IN LONG	Adjustment,
		IN BOOLEAN	Wait
	)

Definition at line 54 of file semphobj.c.

{
    LONG InitialState, State;
    KIRQL OldIrql;
    PKTHREAD CurrentThread;
    ASSERT_SEMAPHORE(Semaphore);
    ASSERT_IRQL_LESS_OR_EQUAL(DISPATCH_LEVEL);
 
    /* Lock the Dispatcher Database */
    OldIrql = KiAcquireDispatcherLock();
 
    /* Save the Old State and get new one */
    InitialState = Semaphore->Header.SignalState;
    State = InitialState + Adjustment;
 
    /* Check if the Limit was exceeded */
    if ((Semaphore->Limit < State) || (InitialState > State))
    {
        /* Raise an error if it was exceeded */
        KiReleaseDispatcherLock(OldIrql);
        ExRaiseStatus(STATUS_SEMAPHORE_LIMIT_EXCEEDED);
    }
 
    /* Now set the new state */
    Semaphore->Header.SignalState = State;
 
    /* Check if we should wake it */
    if (!(InitialState) && !(IsListEmpty(&Semaphore->Header.WaitListHead)))
    {
        /* Wake the Semaphore */
        KiWaitTest(&Semaphore->Header, Increment);
    }
 
    /* Check if the caller wants to wait after this release */
    if (Wait == FALSE)
    {
        /* Release the Lock */
        KiReleaseDispatcherLock(OldIrql);
    }
    else
    {
        /* Set a wait */
        CurrentThread = KeGetCurrentThread();
        CurrentThread->WaitNext = TRUE;
        CurrentThread->WaitIrql = OldIrql;
    }
 
    /* Return the previous state */
    return InitialState;
}

Referenced by CsqInsertIrp(), ExConvertExclusiveToSharedLite(), ExReleaseResourceForThreadLite(), FsRtlDeregisterUncProvider(), FsRtlRegisterUncProvider(), HDA_DpcForIsr(), IssueUniqueIdChangeNotify(), KsGenerateEvent(), LpcpDestroyPortQueue(), MountMgrCheckUnprocessedVolumes(), MountMgrDeviceControl(), MountMgrMountedDeviceArrival(), MountMgrMountedDeviceRemoval(), MountMgrQueryDosVolumePaths(), MountMgrShutdown(), MountMgrUniqueIdChangeRoutine(), MountMgrUnload(), NtReleaseSemaphore(), NtSignalAndWaitForSingleObject(), QueueWorkItem(), ReconcileThisDatabaseWithMasterWorker(), ReleaseRemoteDatabaseSemaphore(), RemoveWorkItem(), SacReleaseLock(), USBH_ChangeIndicationWorker(), USBH_CheckHubIdle(), USBH_CheckIdleAbort(), USBH_FdoIdleNotificationCallback(), USBH_FdoPnP(), USBH_FdoPower(), USBH_FdoQueryBusRelations(), USBH_FlushPortPwrList(), USBH_PdoIoctlGetPortStatus(), USBH_ResetDevice(), USBH_ResetPortWorker(), USBH_SyncResetPort(), USBPORT_CreateDevice(), USBPORT_HandleSelectConfiguration(), USBPORT_HandleSelectInterface(), USBPORT_InitializeDevice(), USBPORT_RemoveDevice(), USBPORT_RestoreDevice(), and USBPORT_SynchronizeRootHubCallback().