3 * Copyright (C) 1998, 1999, 2000, 2001 ReactOS Team
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 * PROJECT: ReactOS kernel
22 * FILE: ntoskrnl/ke/sem.c
23 * PURPOSE: Implements kernel semaphores
24 * PROGRAMMER: David Welch (welch@mcmail.com)
29 /* INCLUDES *****************************************************************/
33 #include <internal/debug.h>
35 /* FUNCTIONS *****************************************************************/
41 KeInitializeSemaphore (PKSEMAPHORE Semaphore
,
45 KeInitializeDispatcherHeader(&Semaphore
->Header
,
46 InternalSemaphoreType
,
47 sizeof(KSEMAPHORE
)/sizeof(ULONG
),
49 Semaphore
->Limit
=Limit
;
56 KeReadStateSemaphore (PKSEMAPHORE Semaphore
)
58 return(Semaphore
->Header
.SignalState
);
65 KeReleaseSemaphore (PKSEMAPHORE Semaphore
,
70 * FUNCTION: KeReleaseSemaphore releases a given semaphore object. This
71 * routine supplies a runtime priority boost for waiting threads. If this
72 * call sets the semaphore to the Signaled state, the semaphore count is
73 * augmented by the given value. The caller can also specify whether it
74 * will call one of the KeWaitXXX routines as soon as KeReleaseSemaphore
77 * Semaphore = Points to an initialized semaphore object for which the
78 * caller provides the storage.
79 * Increment = Specifies the priority increment to be applied if
80 * releasing the semaphore causes a wait to be
82 * Adjustment = Specifies a value to be added to the current semaphore
83 * count. This value must be positive
84 * Wait = Specifies whether the call to KeReleaseSemaphore is to be
85 * followed immediately by a call to one of the KeWaitXXX.
86 * RETURNS: If the return value is zero, the previous state of the semaphore
87 * object is Not-Signaled.
93 DPRINT("KeReleaseSemaphore(Semaphore %x, Increment %d, Adjustment %d, "
94 "Wait %d)\n", Semaphore
, Increment
, Adjustment
, Wait
);
96 OldIrql
= KeAcquireDispatcherDatabaseLock();
98 InitialState
= Semaphore
->Header
.SignalState
;
99 if (Semaphore
->Limit
< (LONG
) InitialState
+ Adjustment
||
100 InitialState
> InitialState
+ Adjustment
)
102 ExRaiseStatus(STATUS_SEMAPHORE_LIMIT_EXCEEDED
);
105 Semaphore
->Header
.SignalState
+= Adjustment
;
106 if (InitialState
== 0)
108 KiDispatcherObjectWake(&Semaphore
->Header
);
113 KeReleaseDispatcherDatabaseLock(OldIrql
);
117 KTHREAD
*Thread
= KeGetCurrentThread();
118 Thread
->WaitNext
= TRUE
;
119 Thread
->WaitIrql
= OldIrql
;
122 return(InitialState
);