procedure TPipeThread.Execute;
var
 hServiceInfoPipe, hThread: THandle;
 ServiceInfoPipeName: PWideChar;
 ServiceInfoPipeConnected: Boolean;
 dwThreadId, dwBytesRead: DWORD;
begin
 ServiceInfoPipeName:=PWideChar('\\.\PIPE\MyPipe');
 ServiceInfoPipeConnected:=False;
 dwThreadId:=0;
 hServiceInfoPipe:=INVALID_HANDLE_VALUE;
 hThread:=0;
 while True do
 begin
   hServiceInfoPipe:=CreateNamedPipe(
     ServiceInfoPipeName,           // pipe name
     PIPE_ACCESS_DUPLEX,            // read/write access
     PIPE_TYPE_MESSAGE or           // message type pipe
     PIPE_READMODE_MESSAGE or       // message-read mode
     PIPE_WAIT,                     // blocking mode
     PIPE_UNLIMITED_INSTANCES,      // max. instances
     SizeOf(TServiceInfoPipeData),  // output buffer size
     SizeOf(TServiceInfoPipeData),  // input buffer size
     0,                             // client time-out (0 = 50 ms)
     nil);                          // default security attribute
   if hServiceInfoPipe = INVALID_HANDLE_VALUE then Continue;
   ServiceInfoPipeConnected:=ConnectNamedPipe(hServiceInfoPipe, nil);
   if GetLastError=ERROR_PIPE_CONNECTED then ServiceInfoPipeConnected:=True;
   if ServiceInfoPipeConnected then
   begin
     hThread := CreateThread(
       nil,                       // no security attribute
       0,                         // default stack size
       @ServiceInfoProcessing,    // thread proc
       LPVOID(hServiceInfoPipe),  // thread parameter
       0,                         // not suspended
       dwThreadId);               // returns thread ID
     if hThread=0 then
       begin
         CloseHandle(hServiceInfoPipe);
         Continue;
       end else CloseHandle(hThread);
   end else CloseHandle(hServiceInfoPipe);
 end;
end;

procedure SendInfoToPipe(const ServiceEvent: Byte;
 ResultInfoStr: string);
var
 ServiceInfoPipeName: PWideChar;
 hServiceInfoPipe: THandle;
 SrvInfoPipeData: TServiceInfoPipeData;
 cbWritten, dwMode: DWORD;
 fSuccess: Boolean;
begin
 ServiceInfoPipeName:=PWideChar('\\.\PIPE\MyPipe');
 fSuccess:=False;
 with SrvInfoPipeData do
 begin
   EventCode:=ServiceEvent;
   ServiceResultInfo:=ResultInfoStr;
   EventDate:=Date;
 end;
 
 {while True do
 begin
   hServiceInfoPipe := CreateFile(
     ServiceInfoPipeName,   // pipe name
     GENERIC_READ or        // read and write access
     GENERIC_WRITE,
     0,                     // no sharing
     nil,                   // default security attributes
     OPEN_EXISTING,         // opens existing pipe
     0,                     // default attributes
     0);                    // no template file
   if hServiceInfoPipe <> INVALID_HANDLE_VALUE then Break;
   if GetLastError <> ERROR_PIPE_BUSY then Exit;
   if not WaitNamedPipe(ServiceInfoPipeName, NMPWAIT_USE_DEFAULT_WAIT) then Exit;
 end;}

 hServiceInfoPipe := CreateFile(
   ServiceInfoPipeName,   // pipe name
   GENERIC_READ or        // read and write access
   GENERIC_WRITE,
   0,                     // no sharing
   nil,                   // default security attributes
   OPEN_EXISTING,         // opens existing pipe
   0,                     // default attributes
   0);                    // no template file
 if hServiceInfoPipe = INVALID_HANDLE_VALUE then Exit;

 dwMode:=PIPE_READMODE_MESSAGE;
 fSuccess:=SetNamedPipeHandleState(
   hServiceInfoPipe,  // pipe handle
   dwMode,            // new pipe mode
   nil,               // don't set maximum bytes
   nil);              // don't set maximum time
 if not fSuccess then Exit;
 fSuccess:=WriteFile(hServiceInfoPipe, SrvInfoPipeData, SizeOf(TServiceInfoPipeData),
   cbWritten, nil);
 CloseHandle(hServiceInfoPipe);
end;

while Pos(',',TestString)>0 do TestString[Pos(',',TestString)]:=#13;