Changeset 289 for PinConnection/UCommHub.pas

Timestamp:

Nov 1, 2011, 10:32:54 AM (13 years ago)

Author:

george

Message:

• Added: New class TPinConcentrator as special case of TCommHub. Concentrator send data received from Main pin to all registred pins and send all data received from registred pins to main pin.
• Modified: Pins of TCommHub are now implemented as descendand of TObjectList rather then methods of TCommHub.

File:

• PinConnection/UCommHub.pas (modified) (5 diffs)

PinConnection/UCommHub.pas

@@ -9 +9 @@
 
 type
+  TCommHub = class;
+
+  { TPinList }
+
+  TPinList = class(TObjectList)
+    Hub: TCommHub;
+    function Add(AObject: TObject): Integer;
+    function AddNew: TCommPin;
+    function Extract(Item: TObject): TObject;
+    procedure Insert(Index: Integer; AObject: TObject);
+  end;
 
   { TCommHub }
@@ -15 +26 @@
   private
     FActive: Boolean;
-    FPins: TObjectList;
-    function GetPin(Index: Integer): TCommPin;
+    FPins: TPinList;
     procedure Receive(Sender: TCommPin; Stream: TStream);
     procedure SetStatus(Sender: TCommPin; Status: Integer);
@@ -22 +32 @@
     constructor Create;
     destructor Destroy; override;
-    function Add(Pin: TCommPin): Integer;
-    function Extract(Pin: TCommPin): TCommPin;
-    function Remove(Pin: TCommPin): Integer;
-    function IndexOf(Pin: TCommPin): Integer;
-    Procedure Insert(Index: Integer; Pin: TCommPin);
-    function First: TCommPin;
-    Function Last: TCommPin;
-    function AddNew: TCommPin;
-    property Pins[Index: Integer]: TCommPin read GetPin;
+    property Pins: TPinList read FPins write FPins;
     property Active: Boolean read FActive write FActive;
   end;
@@ -36 +38 @@
 implementation
 
+{ TPinList }
+
+function TPinList.Add(AObject: TObject): Integer;
+begin
+  Result := inherited Add(AObject);
+  TCommPin(AObject).OnReceive := Hub.Receive;
+  TCommPin(AObject).OnSetSatus := Hub.SetStatus;
+end;
+
+function TPinList.AddNew: TCommPin;
+begin
+  Result := TCommPin(Items[Add(TCommPin.Create)]);
+end;
+
+function TPinList.Extract(Item: TObject): TObject;
+begin
+  TCommPin(Item).OnReceive := nil;
+  TCommPin(Item).OnSetSatus := nil;
+  Result := inherited Extract(Item);
+end;
+
+procedure TPinList.Insert(Index: Integer; AObject: TObject);
+begin
+  inherited Insert(Index, AObject);
+  TCommPin(AObject).OnReceive := Hub.Receive;
+  TCommPin(AObject).OnSetSatus := Hub.SetStatus;
+end;
+
 { TCommHub }
-
-function TCommHub.GetPin(Index: Integer): TCommPin;
-begin
-  Result := TCommPin(FPins[Index]);
-end;
 
 procedure TCommHub.Receive(Sender: TCommPin; Stream: TStream);
@@ -69 +94 @@
 constructor TCommHub.Create;
 begin
-  FPins := TObjectList.Create;
+  FPins := TPinList.Create;
+  FPins.Hub := Self;
 end;
 
 destructor TCommHub.Destroy;
 begin
+  Active := False;
   FPins.Free;
   inherited Destroy;
 end;
 
-function TCommHub.Add(Pin: TCommPin): Integer;
-begin
-  Pin.OnReceive := Receive;
-  Pin.OnSetSatus := SetStatus;
-  Result := FPins.Add(Pin);
-end;
-
-function TCommHub.Extract(Pin: TCommPin): TCommPin;
-begin
-  Pin.OnReceive := nil;
-  Pin.OnSetSatus := nil;
-  Result := TCommPin(FPins.Extract(Pin));
-end;
-
-function TCommHub.Remove(Pin: TCommPin): Integer;
-begin
-  Result := FPins.Remove(Pin);
-end;
-
-function TCommHub.IndexOf(Pin: TCommPin): Integer;
-begin
-  Result := FPins.IndexOf(Pin);
-end;
-
-procedure TCommHub.Insert(Index: Integer; Pin: TCommPin);
-begin
-  Pin.OnReceive := Receive;
-  Pin.OnSetSatus := SetStatus;
-  FPins.Insert(Index, Pin);
-end;
-
-function TCommHub.First: TCommPin;
-begin
-  Result := TCommPin(FPins.First);
-end;
-
-function TCommHub.Last: TCommPin;
-begin
-  Result := TCommPin(FPins.Last);
-end;
-
-function TCommHub.AddNew: TCommPin;
-begin
-  Result := TCommPin.Create;
-  Result.OnReceive := Receive;
-  Result.OnSetSatus := SetStatus;
-  FPins.Add(Result);
-end;
-
 end.