int?pthread_cond_signal(pthread_cond_t *cond)

{

????if?(cond?==?NULL)

????????return?pth_error(EINVAL,?EINVAL);

????if?(*cond?== PTHREAD_COND_INITIALIZER)

????????if?(pthread_cond_init(cond,?NULL) != OK)

????????????return?errno;

????if?(!pth_cond_notify((pth_cond_t *)(*cond),?FALSE))

????????return?errno;

????return?OK;

}

int?pth_cond_notify(pth_cond_t *cond,?int?broadcast)

{??????

????/* consistency checks */

????if?(cond?==?NULL)

????????return?pth_error(FALSE,?EINVAL);

????if?(!(cond->cn_state & PTH_COND_INITIALIZED))

????????return?pth_error(FALSE,?EDEADLK);

???

????/* do something only if there is at least one waiters (POSIX semantics) */

????if (cond->cn_waiters > 0) {

????????/* signal the condition */

????????cond->cn_state |= PTH_COND_SIGNALED;

????????if?(broadcast)

????????????cond->cn_state |= PTH_COND_BROADCAST;

????????else

????????????cond->cn_state &= ~(PTH_COND_BROADCAST);

????????cond->cn_state &= ~(PTH_COND_HANDLED);

???

????????/* and give other threads a chance to awake */

????????pth_yield(NULL);

????}

?

????/* return to caller */

????return?TRUE;

}

LONG

STDCALL

KeSetEvent(PKEVENT?Event,

???????????KPRIORITY?Increment,

???????????BOOLEAN?Wait)

{

????KIRQL?OldIrql;

????LONG?PreviousState;

????PKWAIT_BLOCK?WaitBlock;

?

????DPRINT("KeSetEvent(Event %x, Wait %x)/n",Event,Wait);

?

????/* Lock the Dispathcer Database */

????OldIrql?= KeAcquireDispatcherDatabaseLock();

?

????/* Save the Previous State */

????PreviousState?=?Event->Header.SignalState;

?

????/* Check if we have stuff in the Wait Queue */

????if (IsListEmpty(&Event->Header.WaitListHead)) {

?

????????/* Set the Event to Signaled */

????????DPRINT("Empty Wait Queue, Signal the Event/n");

????????Event->Header.SignalState = 1;

????} else {

?

????????/* Get the Wait Block */

????????WaitBlock?=?CONTAINING_RECORD(Event->Header.WaitListHead.Flink,

??????????????????????????????????????KWAIT_BLOCK,

??????????????????????????????????????WaitListEntry);

?

?

????????/* Check the type of event */

????????if?(Event->Header.Type?== NotificationEvent ||?WaitBlock->WaitType == WaitAll) {

?

????????????if?(PreviousState?== 0) {

?

????????????????/* We must do a full wait satisfaction */

????????????????DPRINT("Notification Event or WaitAll, Wait on the Event and Signal/n");

????????????????Event->Header.SignalState = 1;

????????????????KiWaitTest(&Event->Header,?Increment);

????????????}

?

????????}?else?{

?

????????????/* We can satisfy wait simply by waking the thread, since our signal state is 0 now */

????????????DPRINT("WaitAny or Sync Event, just unwait the thread/n");

????????????KiAbortWaitThread(WaitBlock->Thread,?WaitBlock->WaitKey,?Increment);

????????}

????}

?

????/* Check what wait state was requested */

????if?(Wait?==?FALSE) {

?

????????/* Wait not requested, release Dispatcher Database and return */

????????KeReleaseDispatcherDatabaseLock(OldIrql);

?

????}?else?{

?

????????/* Return Locked and with a Wait */

????????KTHREAD *Thread?= KeGetCurrentThread();

????????Thread->WaitNext =?TRUE;

????????Thread->WaitIrql =?OldIrql;

????}

?

????/* Return the previous State */

????DPRINT("Done: %d/n",?PreviousState);

????return?PreviousState;

}

?

NTSTATUS

STDCALL

KeWaitForSingleObject(PVOID?Object,

??????????????????????KWAIT_REASON?WaitReason,

??????????????????????KPROCESSOR_MODE?WaitMode,

??????????????????????BOOLEAN?Alertable,

??????????????????????PLARGE_INTEGER?Timeout)

{

?????????...

if (CurrentObject->Header.SignalState > 0)

????????{

????????????/* Another satisfied object */

????????????KiSatisfyNonMutantWait(CurrentObject, CurrentThread);

????????????WaitStatus = STATUS_WAIT_0;

????????????goto DontWait;

????????}

...

}