update for HEAD-2003091401

[reactos.git] / ntoskrnl / ke / queue.c

diff --git a/ntoskrnl/ke/queue.c b/ntoskrnl/ke/queue.c
index dbc5aa5..6a19619 100644 (file)
--- a/ntoskrnl/ke/queue.c
+++ b/ntoskrnl/ke/queue.c
@@ -29,6 +29,7 @@
 /* INCLUDES *****************************************************************/
 
 #include <ddk/ntddk.h>
+#include <ntos.h>
 #include <internal/ke.h>
 #include <internal/id.h>
 #include <internal/ps.h>
@@ -38,6 +39,9 @@
 
 /* FUNCTIONS *****************************************************************/
 
+/*
+ * @implemented
+ */
 VOID STDCALL
 KeInitializeQueue(IN PKQUEUE Queue,
                  IN ULONG Count OPTIONAL)
@@ -48,11 +52,14 @@ KeInitializeQueue(IN PKQUEUE Queue,
                               0);
   InitializeListHead(&Queue->EntryListHead);
   InitializeListHead(&Queue->ThreadListHead);
-  Queue->RunningThreads = 0;
-  Queue->MaximumThreads = (Count == 0) ? (ULONG) KeNumberProcessors : Count;
+  Queue->CurrentCount = 0;
+  Queue->MaximumCount = (Count == 0) ? (ULONG) KeNumberProcessors : Count;
 }
 
 
+/*
+ * @implemented
+ */
 LONG STDCALL
 KeReadStateQueue(IN PKQUEUE Queue)
 {
@@ -85,7 +92,7 @@ KiInsertQueue(
       InsertTailList(&Queue->EntryListHead, Entry);
    }
 
-   if (Queue->RunningThreads < Queue->MaximumThreads && InitialState == 0)
+   if (Queue->CurrentCount < Queue->MaximumCount && InitialState == 0)
    {
       KeDispatcherObjectWake(&Queue->Header);
    }
@@ -96,6 +103,9 @@ KiInsertQueue(
 
 
 
+/*
+ * @implemented
+ */
 LONG STDCALL
 KeInsertHeadQueue(IN PKQUEUE Queue,
                  IN PLIST_ENTRY Entry)
@@ -104,6 +114,9 @@ KeInsertHeadQueue(IN PKQUEUE Queue,
 }
 
 
+/*
+ * @implemented
+ */
 LONG STDCALL
 KeInsertQueue(IN PKQUEUE Queue,
              IN PLIST_ENTRY Entry)
@@ -112,6 +125,9 @@ KeInsertQueue(IN PKQUEUE Queue,
 }
 
 
+/*
+ * @implemented
+ */
 PLIST_ENTRY STDCALL
 KeRemoveQueue(IN PKQUEUE Queue,
              IN KPROCESSOR_MODE WaitMode,
@@ -134,11 +150,11 @@ KeRemoveQueue(IN PKQUEUE Queue,
 
       //associate with this queue
       InsertHeadList(&Queue->ThreadListHead, &Thread->QueueListEntry);
-      Queue->RunningThreads++;
+      Queue->CurrentCount++;
       Thread->Queue = Queue;
    }
    
-   if (Queue->RunningThreads <= Queue->MaximumThreads && !IsListEmpty(&Queue->EntryListHead))
+   if (Queue->CurrentCount <= Queue->MaximumCount && !IsListEmpty(&Queue->EntryListHead))
    {
       ListEntry = RemoveHeadList(&Queue->EntryListHead);
       Queue->Header.SignalState--;
@@ -170,6 +186,9 @@ KeRemoveQueue(IN PKQUEUE Queue,
 }
 
 
+/*
+ * @implemented
+ */
 PLIST_ENTRY STDCALL
 KeRundownQueue(IN PKQUEUE Queue)
 {