Initial import

mdl/m_pipe_windows.pas

@@ -0,0 +1,170 @@
+Unit m_Pipe_Windows;
+
+{$I M_OPS.PAS}
+
+Interface
+
+Uses
+  Windows,
+  m_DateTime,
+  m_FileIO,
+  m_Strings;
+
+Const
+  TPipeBufSize = 8 * 1024;
+
+Type
+  TPipeWindows = Class
+    PipeID     : Word;
+    Connected  : Boolean;
+    IsClient   : Boolean;
+    PipeHandle : THandle;
+
+    Constructor Create       (Dir: String; Client: Boolean; ID: Word);
+    Destructor  Destroy;     Override;
+    // Server functions
+    Function    CreatePipe   : Boolean;
+    Function    WaitForPipe  (Secs: LongInt) : Boolean;
+    // Client functions
+    Function    ConnectPipe  (Secs: LongInt) : Boolean;
+    // General functions
+    Procedure   SendToPipe   (Var Buf; Len: Longint);
+    Procedure   ReadFromPipe (Var Buf; Len: LongInt; Var bRead: LongWord);
+    Procedure   Disconnect;
+  End;
+
+Implementation
+
+Constructor TPipeWindows.Create (Dir: String; Client: Boolean; ID: Word);
+Begin
+  Connected  := False;
+  IsClient   := Client;
+  PipeID     := ID;
+  PipeHandle := -1;
+End;
+
+Destructor TPipeWindows.Destroy;
+Begin
+  If Connected Then Disconnect;
+
+  Inherited Destroy;
+End;
+
+Function TPipeWindows.CreatePipe : Boolean;
+Var
+  SecAttr  : TSecurityAttributes;
+  PipeName : String;
+Begin
+  IsClient := False;
+
+  FillChar (SecAttr, SizeOf(SecAttr), 0);
+
+  SecAttr.nLength              := SizeOf(SecAttr);
+  SecAttr.lpSecurityDescriptor := NIL;
+  SecAttr.bInheritHandle       := True;
+
+  PipeName   := '\\.\PIPE\MYSTIC_' + strI2S(PipeID) + #0;
+  PipeHandle := CreateNamedPipe (@PipeName[1],
+                                  PIPE_ACCESS_DUPLEX OR FILE_FLAG_WRITE_THROUGH,
+                                  PIPE_TYPE_BYTE OR PIPE_READMODE_BYTE OR PIPE_NOWAIT,
+                                  2,         //MaxPipes
+                                  TPipeBufSize,  //Buffer size
+                                  TPipeBufSize,
+                                  1000,       //Pipe wait
+                                  @SecAttr
+                                );
+
+  Result := PipeHandle <> INVALID_HANDLE_VALUE;
+End;
+
+Procedure TPipeWindows.SendToPipe (Var Buf; Len: LongInt);
+Var
+  Written : LongWord;
+Begin
+  If Not Connected Then Exit;
+
+  WriteFile (PipeHandle, Buf, Len, Written, NIL);
+
+//  Connected := GetLastError = ERROR_SUCCESS;
+  Connected := Written > 0;
+End;
+
+Procedure TPipeWindows.ReadFromPipe (Var Buf; Len: LongInt; Var bRead: LongWord);
+Begin
+  bRead := 0;
+
+  If Not Connected Then Exit;
+
+  ReadFile (PipeHandle, Buf, Len, bRead, NIL);
+
+  Connected := GetLastError = ERROR_SUCCESS;
+End;
+
+Function TPipeWindows.WaitForPipe (Secs: LongInt) : Boolean;
+Var
+  Res     : LongBool;
+  LE      : LongInt;
+  TimeOut : LongInt;
+Begin
+  Result := Connected;
+
+  If Connected Then Exit;
+
+  TimeOut := TimerSet(Secs);
+
+  Repeat
+    Res := ConnectNamedPipe (PipeHandle, NIL);
+    LE  := GetLastError;
+
+    Connected := (LE = ERROR_PIPE_CONNECTED) or (Res);
+  Until Connected or TimerUp(TimeOut);
+
+  Result := Connected;
+End;
+
+Function TPipeWindows.ConnectPipe (Secs: LongInt) : Boolean;
+Var
+  SecAttr  : TSecurityAttributes;
+  PipeName : String;
+  TimeOut  : LongInt;
+Begin
+  IsClient := True;
+
+  Disconnect;
+
+  FillChar (SecAttr, SizeOf(SecAttr), 0);
+
+  SecAttr.nLength              := SizeOf(SecAttr);
+  SecAttr.lpSecurityDescriptor := NIL;
+  SecAttr.bInheritHandle       := True;
+
+  PipeName := '\\.\PIPE\MYSTIC_' + strI2S(PipeID) + #0;
+  TimeOut  := TimerSet(Secs);
+
+  Repeat
+    PipeHandle := CreateFile (@PipeName[1],
+                              GENERIC_READ OR GENERIC_WRITE,
+                              0,
+                              @SecAttr,
+                              OPEN_EXISTING,
+                              FILE_ATTRIBUTE_NORMAL OR FILE_FLAG_WRITE_THROUGH,
+                              0);
+
+    Connected := GetLastError = ERROR_SUCCESS;
+  Until Connected or TimerUp(TimeOut);
+
+  Result := Connected;
+End;
+
+Procedure TPipeWindows.Disconnect;
+Begin
+  If Not Connected Then Exit;
+
+  DisconnectNamedPipe (PipeHandle);
+  CloseHandle         (PipeHandle);
+
+  PipeHandle := -1;
+  Connected  := False;
+End;
+
+End.