Changeset 407 for PinConnection/UCommTCPServer.pas

Timestamp:

Aug 14, 2012, 10:31:30 AM (12 years ago)

Author:

chronos

Message:

• Modified: PinConnection package now use for data parameters TListByte instead of TStream class contained in TemplateGenerics package. TStream have Position property which has no meaning for forwarding plain byte memory block. There is TBinarySerializer class used for serializing data instead of TStreamHelper class.

File:

• PinConnection/UCommTCPServer.pas (modified) (6 diffs)

PinConnection/UCommTCPServer.pas

@@ -7 +7 @@
 uses
   Classes, SysUtils, blcksock, synsock, UCommPin, UCommon, UThreading,
-  DateUtils, SpecializedList;
+  DateUtils, SpecializedList, tlntsend;
 
 type
@@ -19 +19 @@
   public
     Parent: TCommTCPServer;
-    Stream: TMemoryStream;
+    Stream: TListByte;
     procedure Execute; override;
     constructor Create(CreateSuspended: Boolean;
@@ -32 +32 @@
   TCommTCPServerSession = class
   private
-    procedure ReceiveData(Sender: TCommPin; Stream: TStream);
+    procedure ReceiveData(Sender: TCommPin; Stream: TListByte);
   public
     Server: TCommTCPServer;
@@ -67 +67 @@
 { TCommTCPServerSession }
 
-procedure TCommTCPServerSession.ReceiveData(Sender: TCommPin; Stream: TStream);
-begin
-  Socket.SendStreamRaw(Stream);
+procedure TCommTCPServerSession.ReceiveData(Sender: TCommPin; Stream: TListByte);
+var
+  Mem: TMemoryStream;
+begin
+  try
+    Mem := TMemoryStream.Create;
+    Stream.WriteToStream(Mem);
+    Socket.SendStreamRaw(Mem);
+  finally
+    Mem.Free;
+  end;
 end;
 
@@ -130 +138 @@
           //if Socket.Socket = INVALID_SOCKET then Break;
 
-          Stream.Size := Length(Buffer);
-          Stream.Position := 0;
-          Stream.Write(Buffer[0], Length(Buffer));
+          Stream.Count := Length(Buffer);
+          Stream.ReplaceBuffer(0, PByte(Buffer)^, Length(Buffer));
           Pin.Send(Stream);
           DoSleep := False;
@@ -146 +153 @@
 begin
   inherited;
-  Stream := TMemoryStream.Create;
+  Stream := TListByte.Create;
 end;