- Silence TCPIP.

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

diff --git a/reactos/ntoskrnl/lpc/queue.c b/reactos/ntoskrnl/lpc/queue.c
index bb40869..971e108 100644 (file)
--- a/reactos/ntoskrnl/lpc/queue.c
+++ b/reactos/ntoskrnl/lpc/queue.c
@@ -1,86 +1,82 @@
-/* $Id: queue.c,v 1.2 2000/10/22 16:36:51 ekohl Exp $
- * 
+/* $Id$
+ *
  * COPYRIGHT:       See COPYING in the top level directory
  * PROJECT:         ReactOS kernel
  * FILE:            ntoskrnl/lpc/queue.c
  * PURPOSE:         Communication mechanism
- * PROGRAMMER:      David Welch (welch@cwcom.net)
- * UPDATE HISTORY:
- *                  Created 22/05/98
+ *
+ * PROGRAMMERS:     David Welch (welch@cwcom.net)
  */
 
 /* INCLUDES *****************************************************************/
 
-#include <ddk/ntddk.h>
-#include <internal/ob.h>
-#include <internal/port.h>
-#include <internal/dbg.h>
-
+#include <ntoskrnl.h>
 #define NDEBUG
 #include <internal/debug.h>
 
+/* FUNCTIONS *****************************************************************/
 
-VOID
-STDCALL
-EiEnqueueMessagePort (
-       IN OUT  PEPORT          Port,
-       IN      PQUEUEDMESSAGE  Message
-       )
+VOID STDCALL
+EiEnqueueMessagePort (IN OUT   PEPORT          Port,
+                     IN        PQUEUEDMESSAGE  Message)
 {
-       InsertTailList (
-               & Port->QueueListHead,
-               & Message->QueueListEntry
-               );
-       Port->QueueLength++;
+  InsertTailList (&Port->QueueListHead,
+                 &Message->QueueListEntry);
+  Port->QueueLength++;
 }
 
+VOID STDCALL
+EiEnqueueMessageAtHeadPort (IN OUT     PEPORT          Port,
+                           IN  PQUEUEDMESSAGE  Message)
+{
+  InsertTailList (&Port->QueueListHead,
+                 &Message->QueueListEntry);
+  Port->QueueLength++;
+}
 
-PQUEUEDMESSAGE
-STDCALL
-EiDequeueMessagePort (
-       IN OUT  PEPORT  Port
-       )
+PQUEUEDMESSAGE STDCALL
+EiDequeueMessagePort (IN OUT   PEPORT  Port)
 {
-       PQUEUEDMESSAGE  Message;
-       PLIST_ENTRY     entry;
-   
-       entry = RemoveHeadList (& Port->QueueListHead);
-       Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
-       Port->QueueLength--;
-   
-       return (Message);
+  PQUEUEDMESSAGE       Message;
+  PLIST_ENTRY  entry;
+
+  if (IsListEmpty(&Port->QueueListHead))
+    {
+      return(NULL);
+    }
+  entry = RemoveHeadList (&Port->QueueListHead);
+  Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
+  Port->QueueLength--;
+
+  return (Message);
 }
 
 
-VOID
-STDCALL
-EiEnqueueConnectMessagePort (
-       IN OUT  PEPORT          Port,
-       IN      PQUEUEDMESSAGE  Message
-       )
+VOID STDCALL
+EiEnqueueConnectMessagePort (IN OUT    PEPORT          Port,
+                            IN PQUEUEDMESSAGE  Message)
 {
-       InsertTailList (
-               & Port->ConnectQueueListHead,
-               & Message->QueueListEntry
-               );
-       Port->ConnectQueueLength++;
+  InsertTailList (&Port->ConnectQueueListHead,
+                 &Message->QueueListEntry);
+  Port->ConnectQueueLength++;
 }
 
 
-PQUEUEDMESSAGE
-STDCALL
-EiDequeueConnectMessagePort (
-       IN OUT  PEPORT  Port
-       )
+PQUEUEDMESSAGE STDCALL
+EiDequeueConnectMessagePort (IN OUT    PEPORT  Port)
 {
-       PQUEUEDMESSAGE  Message;
-       PLIST_ENTRY     entry;
-   
-       entry = RemoveHeadList (& Port->ConnectQueueListHead);
-       Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
-       Port->ConnectQueueLength--;
-
-       return (Message);
+  PQUEUEDMESSAGE       Message;
+  PLIST_ENTRY  entry;
+
+  if (IsListEmpty(&Port->ConnectQueueListHead))
+    {
+      return(NULL);
+    }
+  entry = RemoveHeadList (&Port->ConnectQueueListHead);
+  Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
+  Port->ConnectQueueLength--;
+
+  return (Message);
 }