Changeset 288 for PinConnection/UCommThread.pas

Timestamp:

Oct 24, 2011, 9:01:08 AM (13 years ago)

Author:

george

Message:

• Added: TCommPin now support state number forwarding. State value is designed mainly for simulating parity bit and possibly other state bits.

File:

• PinConnection/UCommThread.pas (modified) (7 diffs)

PinConnection/UCommThread.pas

@@ -36 +36 @@
     FInputBufferLock: TCriticalSection;
     FDataAvailable: TEvent;
-    procedure ReceiveData(Sender: TCommPin; Stream: TStream);
+    FStatusEvent: TEvent;
+    FStatusValue: Integer;
+    procedure PinReceiveData(Sender: TCommPin; Stream: TStream);
+    procedure PinSetStatus(Sender: TCommPin; Status: Integer);
     procedure ExtReceiveData(Sender: TCommPin; Stream: TStream);
+    procedure ExtSetStatus(Sender: TCommPin; AStatus: Integer);
     procedure SetActive(const AValue: Boolean);
   public
@@ -51 +55 @@
 { TCommThread }
 
-procedure TCommThread.ReceiveData(Sender: TCommPin; Stream:TStream);
+procedure TCommThread.PinReceiveData(Sender: TCommPin; Stream:TStream);
 begin
   if FActive then Ext.Send(Stream);
+end;
+
+procedure TCommThread.PinSetStatus(Sender: TCommPin; Status: Integer);
+begin
+  if FActive then Ext.Status := Status;
 end;
 
@@ -68 +77 @@
     FInputBufferLock.Release;
     StreamHelper.Free;
+  end;
+end;
+
+procedure TCommThread.ExtSetStatus(Sender: TCommPin; AStatus: Integer);
+begin
+  try
+    FInputBufferLock.Acquire;
+    FStatusValue := AStatus;
+    FStatusEvent.SetEvent;
+  finally
+    FInputBufferLock.Release;
   end;
 end;
@@ -96 +116 @@
   Ext := TCommPin.Create;
   Ext.OnReceive := ExtReceiveData;
+  Ext.OnSetSatus := ExtSetStatus;
   Pin := TCommPin.Create;
-  Pin.OnReceive := ReceiveData;
+  Pin.OnReceive := PinReceiveData;
+  Pin.OnSetSatus := PinSetStatus;
   FDataAvailable := TSimpleEvent.Create;
+  FStatusEvent := TSimpleEvent.Create;
 end;
 
@@ -108 +131 @@
   Ext.Free;
   Pin.Free;
+  FStatusEvent.Free;
   FDataAvailable.Free;
   inherited Destroy;
@@ -119 +143 @@
     with Parent do
     repeat
+      // Check if new data arrived
       if FDataAvailable.WaitFor(1) = wrSignaled then
       try
@@ -130 +155 @@
         FInputBufferLock.Release;
       end; // else Yield;
+
+      // Check if state changed
+      if FStatusEvent.WaitFor(1) = wrSignaled then
+      try
+        FInputBufferLock.Acquire;
+        Pin.Status := FStatusValue;
+      finally
+        FStatusEvent.ResetEvent;
+        FInputBufferLock.Release;
+      end;
     until Terminated;
   finally