reactos/ntoskrnl/lpc/close.c

   1 /* $Id$
   2  *
   3  * COPYRIGHT:       See COPYING in the top level directory
   4  * PROJECT:         ReactOS kernel
   5  * FILE:            ntoskrnl/lpc/close.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 /**********************************************************************
  20  * NAME
  21  *
  22  * DESCRIPTION
  23  *
  24  * ARGUMENTS
  25  *
  26  * RETURN VALUE
  27  *
  28  * REVISIONS
  29  */
  30 VOID STDCALL
  31 NiClosePort (PVOID      ObjectBody, ULONG       HandleCount)
  32 {
  33   PEPORT Port = (PEPORT)ObjectBody;
  34   LPC_MESSAGE Message;
  35
  36   /* FIXME Race conditions here! */
  37
  38   DPRINT("NiClosePort 0x%p OtherPort 0x%p State %d\n", Port, Port->OtherPort, Port->State);
  39
  40   /*
  41    * If the client has just closed its handle then tell the server what
  42    * happened and disconnect this port.
  43    */
  44   if (HandleCount == 1 && Port->State == EPORT_CONNECTED_CLIENT)
  45     {
  46       DPRINT("Informing server\n");
  47       Message.MessageSize = sizeof(LPC_MESSAGE);
  48       Message.DataSize = 0;
  49       EiReplyOrRequestPort (Port->OtherPort,
  50                             &Message,
  51                             LPC_PORT_CLOSED,
  52                             Port);
  53       Port->OtherPort->OtherPort = NULL;
  54       Port->OtherPort->State = EPORT_DISCONNECTED;
  55       KeReleaseSemaphore( &Port->OtherPort->Semaphore,
  56                           IO_NO_INCREMENT,
  57                           1,
  58                           FALSE );
  59       ObDereferenceObject (Port);
  60     }
  61
  62   /*
  63    * If the server has closed all of its handles then disconnect the port,
  64    * don't actually notify the client until it attempts an operation.
  65    */
  66   if (HandleCount == 1 && Port->State == EPORT_CONNECTED_SERVER)
  67     {
  68         DPRINT("Cleaning up server\n");
  69         Port->OtherPort->OtherPort = NULL;
  70         Port->OtherPort->State = EPORT_DISCONNECTED;
  71         ObDereferenceObject(Port->OtherPort);
  72      }
  73 }
  74
  75
  76 /**********************************************************************
  77  * NAME
  78  *
  79  * DESCRIPTION
  80  *
  81  * ARGUMENTS
  82  *
  83  * RETURN VALUE
  84  *
  85  * REVISIONS
  86  */
  87 VOID STDCALL
  88 NiDeletePort (PVOID     ObjectBody)
  89 {
  90    //   PEPORT Port = (PEPORT)ObjectBody;
  91
  92    //   DPRINT1("Deleting port %x\n", Port);
  93 }
  94
  95
  96 /* EOF */