Commit in reactos/ntoskrnl/ex on MAIN
work.c+16-181.20 -> 1.21
fix broken work item impl.

reactos/ntoskrnl/ex
work.c 1.20 -> 1.21
diff -u -r1.20 -r1.21
--- work.c	22 Oct 2004 20:18:37 -0000	1.20
+++ work.c	15 Nov 2004 23:14:36 -0000	1.21
@@ -1,4 +1,4 @@
-/* $Id: work.c,v 1.20 2004/10/22 20:18:37 ekohl Exp $
+/* $Id: work.c,v 1.21 2004/11/15 23:14:36 gdalsnes Exp $
  *
  * COPYRIGHT:          See COPYING in the top level directory
  * PROJECT:            ReactOS kernel
@@ -36,7 +36,7 @@
    /*
     * PURPOSE: Worker threads with nothing to do wait on this event
     */
-   KSEMAPHORE Sem;
+   KEVENT Event;
    
    /*
     * PURPOSE: Thread associated with work queue
@@ -84,7 +84,7 @@
 	  }
 	else
 	  {
-	     KeWaitForSingleObject((PVOID)&queue->Sem,
+	     KeWaitForSingleObject((PVOID)&queue->Event,
 				   Executive,
 				   KernelMode,
 				   FALSE,
@@ -102,9 +102,10 @@
    
    InitializeListHead(&WorkQueue->Head);
    KeInitializeSpinLock(&WorkQueue->Lock);
-   KeInitializeSemaphore(&WorkQueue->Sem,
-			 0,
-			 256);
+   KeInitializeEvent(&WorkQueue->Event,
+                     SynchronizationEvent,
+                     FALSE);   
+
    for (i=0; i<NUMBER_OF_WORKER_THREADS; i++)
      {
 	PsCreateSystemThread(&WorkQueue->Thread[i],
@@ -164,30 +165,27 @@
 	    ExInterlockedInsertTailList(&EiNormalWorkQueue.Head,
 				    &WorkItem->List,
 				    &EiNormalWorkQueue.Lock);
-	    KeReleaseSemaphore(&EiNormalWorkQueue.Sem,
-			   IO_NO_INCREMENT,
-			   1,
-			   FALSE);
+       KeSetEvent(&EiNormalWorkQueue.Event,
+                  IO_NO_INCREMENT,
+                  FALSE);
 	break;
 	
     case CriticalWorkQueue:
         ExInterlockedInsertTailList(&EiCriticalWorkQueue.Head,
 				    &WorkItem->List,
 				    &EiCriticalWorkQueue.Lock);
-        KeReleaseSemaphore(&EiCriticalWorkQueue.Sem,
-	       	  	   IO_NO_INCREMENT,
-	       		   1,
-	       		   FALSE);
+        KeSetEvent(&EiCriticalWorkQueue.Event,
+                   IO_NO_INCREMENT,
+                   FALSE);
 	    break;
 
     case HyperCriticalWorkQueue:
 	    ExInterlockedInsertTailList(&EiHyperCriticalWorkQueue.Head,
 				    &WorkItem->List,
 				    &EiHyperCriticalWorkQueue.Lock);
-	    KeReleaseSemaphore(&EiHyperCriticalWorkQueue.Sem,
-			   IO_NO_INCREMENT,
-			   1,
-			   FALSE);
+       KeSetEvent(&EiHyperCriticalWorkQueue.Event,
+                  IO_NO_INCREMENT,
+                  FALSE);
     	break;
 
 #ifdef __USE_W32API
CVSspam 0.2.8