Changeset 163 for PinConnection/UPacketBurst.pas

Timestamp:

Feb 8, 2011, 11:02:02 AM (13 years ago)

Author:

george

Message:

• Modified: Units are dependent on MicroThreading system now.

Location:

PinConnection

Files:

• . (modified) (1 prop)
• UPacketBurst.pas (modified) (7 diffs)

PinConnection

@@ -1 +1 @@
 lib
+backup

@@ -1 +1 @@
 lib
+backup

PinConnection/UPacketBurst.pas

@@ -6 +6 @@
 
 uses
-  Classes, UCommPin, SyncObjs, UStreamHelper, UCommon, SysUtils;
+  Classes, UCommPin, SyncObjs, UStreamHelper, UCommon, SysUtils,
+  UMicroThreading, DateUtils;
 
 type
   TPacketBurst = class;
 
-  TPacketBurstSendThread = class(TThread)
+  TPacketBurstSendThread = class(TMicroThread)
     PacketBurst: TPacketBurst;
     procedure Execute; override;
   end;
 
+  { TPacketBurst }
+
   TPacketBurst = class
   private
-    SendThreadEvent: TEvent;
+    FActive: Boolean;
+    SendThreadEvent: TMicroThreadEvent;
     SendThread: TPacketBurstSendThread;
     SendStreamLock: TCriticalSection;
@@ -25 +29 @@
     procedure PacketSingleReceive(Sender: TCommPin; Stream: TStream);
     procedure PacketBurstReceive(Sender: TCommPin; Stream: TStream);
+    procedure SetActive(const AValue: Boolean);
   public
-    SendPeriod: Integer; // ms
+    SendPeriod: TDateTime;
     SendBurstSize: Integer;
     PacketSinglePin: TCommPin;
@@ -32 +37 @@
     destructor Destroy; override;
     constructor Create;
+    property Active: Boolean read FActive write SetActive;
   end;
 
@@ -44 +50 @@
   PacketBurstPin := TCommPin.Create;
   PacketBurstPin.OnReceive := PacketBurstReceive;
-  SendThread := TPacketBurstSendThread.Create(True);
-  SendThread.PacketBurst := Self;
-  SendThread.Start;
+  SendThread := TMicroThreadEvent.Create;
+  SendPeriod := OneMillisecond;
 end;
 
 destructor TPacketBurst.Destroy;
 begin
-  SendThread.Free;
+  Active := False;
+  SendThreadEvent.Free;
   PacketSinglePin.Free;
   PacketBurstPin.Free;
@@ -79 +85 @@
 end;
 
+procedure TPacketBurst.SetActive(const AValue: Boolean);
+begin
+  if FActive = AValue then Exit;
+  FActive := AValue;
+  if AValue then begin
+    SendThread := TPacketBurstSendThread.Create(True);
+    SendThread.FreeOnTerminate := False;
+    SendThread.PacketBurst := Self;
+    SendThread.Name := 'PacketBurst';
+    SendThread.Start;
+  end else begin
+    FreeAndNil(SendThread);
+  end;
+end;
+
 procedure TPacketBurst.PacketSingleReceive(Sender: TCommPin; Stream: TStream);
 var
@@ -101 +122 @@
   Stream: TStreamHelper;
 begin
-  inherited;
-  try
   try
     Stream := TStreamHelper.Create;
@@ -127 +146 @@
     Stream.Free;
   end;
-  except
-    on E: Exception do
-      if Assigned(ExceptionHandler) then ExceptionHandler(Self, E);
-  end;
 end;
 

@@ -1 +1 @@
 lib
+backup