Changeset 119 for Comm/UCommPin.pas

Timestamp:

Jan 5, 2011, 1:16:30 PM (13 years ago)

Author:

george

Message:

• Created: New Lazarus package as container for few classes with bidirectional pin interconnection system .

Location:

Comm

Files:

• . (modified) (1 prop)
• UCommPin.pas (modified) (4 diffs)

Comm/UCommPin.pas

@@ -9 +9 @@
 
 type
+  TCommPin = class;
+
   TDataDiretion = (ddReceive, ddSend);
   TOnLogDataEvent = procedure (Stream: TStream; Direction: TDataDiretion) of object;
-  TOnStreamEvent = procedure (Stream: TStream) of object;
+  TOnStreamEvent = procedure (Sender: TCommPin; Stream: TStream) of object;
 
   { TCommPin }
@@ -19 +21 @@
     FOnLogData: TOnLogDataEvent;
     FOnReceive: TOnStreamEvent;
+    FDataTxCount: Integer;
+    FDataRxCount: Integer;
+    FFrameTxCount: Integer;
+    FFrameRxCount: Integer;
     function GetConnected: Boolean;
   public
     RemotePin: TCommPin;
+    constructor Create;
     destructor Destroy; override;
     procedure Connect(Pin: TCommPin);
@@ -27 +34 @@
     procedure Send(Stream: TStream);
     procedure Receive(Stream: TStream);
+    procedure ResetCounters;
     property OnReceive: TOnStreamEvent read FOnReceive write FOnReceive;
     property Connected: Boolean read GetConnected;
     property OnLogData: TOnLogDataEvent read FOnLogData write FOnLogData;
+    property DataTxCount: Integer read FDataTxCount;
+    property DataRxCount: Integer read FDataRxCount;
+    property FrameTxCount: Integer read FFrameTxCount;
+    property FrameRxCount: Integer read FFrameRxCount;
   end;
 
@@ -63 +75 @@
 end;
 
+constructor TCommPin.Create;
+begin
+  RemotePin := nil;
+end;
+
 procedure TCommPin.Receive(Stream: TStream);
 begin
+  Inc(FDataRxCount, Stream.Size);
+  Inc(FFrameRxCount);
   if Assigned(FOnLogData) then FOnLogData(Stream, ddReceive);
   Stream.Position := 0;
-  if Assigned(FOnReceive) then FOnReceive(Stream);
+  if Assigned(FOnReceive) then FOnReceive(Self, Stream);
+end;
+
+procedure TCommPin.ResetCounters;
+begin
+  FDataTxCount := 0;
+  FDataRxCount := 0;
+  FFrameTxCount := 0;
+  FFrameRxCount := 0;
 end;
 
 procedure TCommPin.Send(Stream: TStream);
 begin
+  Inc(FDataTxCount, Stream.Size);
+  Inc(FFrameTxCount);
   if Assigned(FOnLogData) then FOnLogData(Stream, ddSend);
   if Assigned(RemotePin) then RemotePin.Receive(Stream);