Changeset 11501 for branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/Ports/GenericPort.cs

Timestamp:

10/25/14 02:54:42 (10 years ago)

Author:

swagner

Message:

#2205: Worked on optimization networks

File:

• branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/Ports/GenericPort.cs (modified) (4 diffs)

branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/Ports/GenericPort.cs

@@ -65 +65 @@
       }
     }
+    [Storable]
+    protected MessageCollection messages;
+    public MessageCollection Messages {
+      get { return messages; }
+    }
 
     [StorableConstructor]
     protected GenericPort(bool deserializing) : base(deserializing) { }
-    protected GenericPort(GenericPort original, Cloner cloner) : base(original, cloner) {
+    protected GenericPort(GenericPort original, Cloner cloner)
+      : base(original, cloner) {
       connectedPort = cloner.Clone(original.connectedPort);
       portConnectionValid = original.portConnectionValid;
+      messages = cloner.Clone(original.messages);
       RegisterConnectedPortEvents();
     }
-    public GenericPort() : base("GenericPort") { }
-    public GenericPort(string name) : base(name) { }
-    public GenericPort(string name, string description) : base(name, description) { }
+    public GenericPort()
+      : base("GenericPort") {
+      portConnectionValid = true;
+      messages = new MessageCollection();
+    }
+    public GenericPort(string name)
+      : base(name) {
+      portConnectionValid = true;
+      messages = new MessageCollection();
+    }
+    public GenericPort(string name, string description)
+      : base(name, description) {
+      portConnectionValid = true;
+      messages = new MessageCollection();
+    }
 
     [StorableHook(HookType.AfterDeserialization)]
@@ -164 +183 @@
     public void SendMessage(IMessage message, CancellationToken token) {
       if (!PortConnectionValid) throw new InvalidOperationException("Port connection is not valid");
+      Messages.Add(message);
       if (ConnectedPort != null) ConnectedPort.ReceiveMessage(message, token);
       OnMessageSent(message, token);
@@ -180 +200 @@
 
     public void ReceiveMessage(IMessage message, CancellationToken token) {
+      if (!PortConnectionValid) throw new InvalidOperationException("Port connection is not valid");
+      Messages.Add(message);
       OnMessageReceived(message, token);
     }
@@ -195 +217 @@
 
     protected override void OnInterfaceChanged() {
-      PortConnectionValid = (connectedPort != null) && CanConnectToPort(connectedPort);
+      PortConnectionValid = CanConnectToPort(connectedPort);
       base.OnInterfaceChanged();
     }