reactos/ntoskrnl/lpc/queue.c

   1 /* $Id$
   2  *
   3  * COPYRIGHT:       See COPYING in the top level directory
   4  * PROJECT:         ReactOS kernel
   5  * FILE:            ntoskrnl/lpc/queue.c
   6  * PURPOSE:         Communication mechanism
   7  *
   8  * PROGRAMMERS:     David Welch (welch@cwcom.net)
   9  */
  10
  11 /* INCLUDES *****************************************************************/
  12
  13 #include <ntoskrnl.h>
  14 #define NDEBUG
  15 #include <internal/debug.h>
  16
  17 /* FUNCTIONS *****************************************************************/
  18
  19 VOID STDCALL
  20 EiEnqueueMessagePort (IN OUT    PEPORT          Port,
  21                       IN        PQUEUEDMESSAGE  Message)
  22 {
  23   InsertTailList (&Port->QueueListHead,
  24                   &Message->QueueListEntry);
  25   Port->QueueLength++;
  26 }
  27
  28 VOID STDCALL
  29 EiEnqueueMessageAtHeadPort (IN OUT      PEPORT          Port,
  30                             IN  PQUEUEDMESSAGE  Message)
  31 {
  32   InsertTailList (&Port->QueueListHead,
  33                   &Message->QueueListEntry);
  34   Port->QueueLength++;
  35 }
  36
  37 PQUEUEDMESSAGE STDCALL
  38 EiDequeueMessagePort (IN OUT    PEPORT  Port)
  39 {
  40   PQUEUEDMESSAGE        Message;
  41   PLIST_ENTRY   entry;
  42
  43   if (IsListEmpty(&Port->QueueListHead))
  44     {
  45       return(NULL);
  46     }
  47   entry = RemoveHeadList (&Port->QueueListHead);
  48   Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
  49   Port->QueueLength--;
  50
  51   return (Message);
  52 }
  53
  54
  55 VOID STDCALL
  56 EiEnqueueConnectMessagePort (IN OUT     PEPORT          Port,
  57                              IN PQUEUEDMESSAGE  Message)
  58 {
  59   InsertTailList (&Port->ConnectQueueListHead,
  60                   &Message->QueueListEntry);
  61   Port->ConnectQueueLength++;
  62 }
  63
  64
  65 PQUEUEDMESSAGE STDCALL
  66 EiDequeueConnectMessagePort (IN OUT     PEPORT  Port)
  67 {
  68   PQUEUEDMESSAGE        Message;
  69   PLIST_ENTRY   entry;
  70
  71   if (IsListEmpty(&Port->ConnectQueueListHead))
  72     {
  73       return(NULL);
  74     }
  75   entry = RemoveHeadList (&Port->ConnectQueueListHead);
  76   Message = CONTAINING_RECORD (entry, QUEUEDMESSAGE, QueueListEntry);
  77   Port->ConnectQueueLength--;
  78
  79   return (Message);
  80 }
  81
  82
  83 /* EOF */