reactos/services/eventlog/logport.c

   1 /*
   2  *  ReactOS kernel
   3  *  Copyright (C) 2002 ReactOS Team
   4  *
   5  *  This program is free software; you can redistribute it and/or modify
   6  *  it under the terms of the GNU General Public License as published by
   7  *  the Free Software Foundation; either version 2 of the License, or
   8  *  (at your option) any later version.
   9  *
  10  *  This program is distributed in the hope that it will be useful,
  11  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  *  GNU General Public License for more details.
  14  *
  15  *  You should have received a copy of the GNU General Public License
  16  *  along with this program; if not, write to the Free Software
  17  *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  18  */
  19 /*
  20  * COPYRIGHT:        See COPYING in the top level directory
  21  * PROJECT:          ReactOS kernel
  22  * FILE:             services/eventlog/logport.c
  23  * PURPOSE:          Event logger service
  24  * PROGRAMMER:       Eric Kohl
  25  */
  26
  27 /* INCLUDES *****************************************************************/
  28
  29 #include <windows.h>
  30 #define NTOS_MODE_USER
  31 #include <ndk/ntndk.h>
  32
  33 #include "eventlog.h"
  34
  35 #define NDEBUG
  36 #include <debug.h>
  37
  38
  39 /* GLOBALS ******************************************************************/
  40
  41 HANDLE PortThreadHandle = NULL;
  42 HANDLE ConnectPortHandle = NULL;
  43 HANDLE MessagePortHandle = NULL;
  44
  45
  46 /* FUNCTIONS ****************************************************************/
  47
  48 static NTSTATUS
  49 InitLogPort(VOID)
  50 {
  51   OBJECT_ATTRIBUTES ObjectAttributes;
  52   UNICODE_STRING PortName;
  53   PORT_MESSAGE Request;
  54   NTSTATUS Status;
  55
  56   ConnectPortHandle = NULL;
  57   MessagePortHandle = NULL;
  58
  59   RtlInitUnicodeString(&PortName,
  60                        L"\\ErrorLogPort");
  61   InitializeObjectAttributes(&ObjectAttributes,
  62                              &PortName,
  63                              0,
  64                              NULL,
  65                              NULL);
  66
  67   Status = NtCreatePort(&ConnectPortHandle,
  68                         &ObjectAttributes,
  69                         0,
  70                         0x100,
  71                         0x2000);
  72   if (!NT_SUCCESS(Status))
  73     {
  74       DPRINT1("NtCreatePort() failed (Status %lx)\n", Status);
  75       goto ByeBye;
  76     }
  77
  78   Status = NtListenPort(ConnectPortHandle,
  79                         &Request);
  80   if (!NT_SUCCESS(Status))
  81     {
  82       DPRINT1("NtListenPort() failed (Status %lx)\n", Status);
  83       goto ByeBye;
  84     }
  85
  86   Status = NtAcceptConnectPort(&MessagePortHandle,
  87                                ConnectPortHandle,
  88                                NULL,
  89                                TRUE,
  90                                NULL,
  91                                NULL);
  92   if (!NT_SUCCESS(Status))
  93     {
  94       DPRINT1("NtAcceptConnectPort() failed (Status %lx)\n", Status);
  95       goto ByeBye;
  96     }
  97
  98   Status = NtCompleteConnectPort(MessagePortHandle);
  99   if (!NT_SUCCESS(Status))
 100     {
 101       DPRINT1("NtCompleteConnectPort() failed (Status %lx)\n", Status);
 102       goto ByeBye;
 103     }
 104
 105 ByeBye:
 106   if (!NT_SUCCESS(Status))
 107     {
 108       if (ConnectPortHandle != NULL)
 109         NtClose(ConnectPortHandle);
 110
 111       if (MessagePortHandle != NULL)
 112         NtClose(MessagePortHandle);
 113     }
 114
 115   return Status;
 116 }
 117
 118 static NTSTATUS
 119 ProcessPortMessage(VOID)
 120 {
 121   IO_ERROR_LPC Request;
 122   PIO_ERROR_LOG_MESSAGE Message;
 123 //#ifndef NDEBUG
 124   ULONG i;
 125   PWSTR p;
 126 //#endif
 127   NTSTATUS Status;
 128
 129
 130   DPRINT1("ProcessPortMessage() called\n");
 131
 132   Status = STATUS_SUCCESS;
 133
 134   while (TRUE)
 135     {
 136       Status = NtReplyWaitReceivePort(MessagePortHandle,
 137                                       0,
 138                                       NULL,
 139                                       &Request.Header);
 140       if (!NT_SUCCESS(Status))
 141         {
 142           DPRINT1("NtReplyWaitReceivePort() failed (Status %lx)\n", Status);
 143           break;
 144         }
 145
 146       DPRINT("Received message\n");
 147
 148       if (Request.Header.u2.s2.Type == LPC_PORT_CLOSED)
 149         {
 150           DPRINT("Port closed\n");
 151
 152           return STATUS_SUCCESS;
 153         }
 154       if (Request.Header.u2.s2.Type == LPC_REQUEST)
 155         {
 156           DPRINT("Received request\n");
 157
 158         }
 159       else if (Request.Header.u2.s2.Type == LPC_DATAGRAM)
 160         {
 161           DPRINT("Received datagram\n");
 162
 163
 164           Message = (PIO_ERROR_LOG_MESSAGE)&Request.Message;
 165
 166           DPRINT("Message->Type %hx\n", Message->Type);
 167           DPRINT("Message->Size %hu\n", Message->Size);
 168
 169 //#ifndef NDEBUG
 170           DbgPrint("\n Error mesage:\n");
 171           DbgPrint("Error code: %lx\n", Message->EntryData.ErrorCode);
 172           DbgPrint("Retry count: %u\n", Message->EntryData.RetryCount);
 173           DbgPrint("Sequence number: %lu\n", Message->EntryData.SequenceNumber);
 174
 175           if (Message->DriverNameLength != 0)
 176             {
 177               DbgPrint("Driver name: %.*S\n",
 178                        Message->DriverNameLength / sizeof(WCHAR),
 179                        (PWCHAR)((ULONG_PTR)Message + Message->DriverNameOffset));
 180             }
 181
 182           if (Message->EntryData.NumberOfStrings != 0)
 183             {
 184               p = (PWSTR)((ULONG_PTR)&Message->EntryData + Message->EntryData.StringOffset);
 185               for (i = 0; i < Message->EntryData.NumberOfStrings; i++)
 186                 {
 187                   DbgPrint("String %lu: %S\n", i, p);
 188                   p += wcslen(p) + 1;
 189                 }
 190               DbgPrint("\n");
 191             }
 192
 193 //#endif
 194
 195           /* FIXME: Enqueue message */
 196
 197         }
 198     }
 199
 200   return Status;
 201 }
 202
 203
 204 static NTSTATUS STDCALL
 205 PortThreadRoutine(PVOID Param)
 206 {
 207   NTSTATUS Status = STATUS_SUCCESS;
 208
 209   Status = InitLogPort();
 210   if (!NT_SUCCESS(Status))
 211     return Status;
 212
 213   while (NT_SUCCESS(Status))
 214     {
 215       Status = ProcessPortMessage();
 216     }
 217
 218   if (ConnectPortHandle != NULL)
 219     NtClose(ConnectPortHandle);
 220
 221   if (MessagePortHandle != NULL)
 222     NtClose(MessagePortHandle);
 223
 224   return Status;
 225 }
 226
 227
 228 BOOL
 229 StartPortThread(VOID)
 230 {
 231   DWORD ThreadId;
 232
 233   PortThreadHandle = CreateThread(NULL,
 234                                   0x1000,
 235                                   (LPTHREAD_START_ROUTINE)PortThreadRoutine,
 236                                   NULL,
 237                                   0,
 238                                   &ThreadId);
 239
 240   return (PortThreadHandle != NULL);
 241 }
 242
 243 /* EOF */