Changeset 11409 for branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/AlgorithmNode.cs

Timestamp:

10/02/14 03:30:30 (9 years ago)

Author:

swagner

Message:

#2205: Worked on optimization networks

File:

• branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/AlgorithmNode.cs (modified) (11 diffs)

branches/OptimizationNetworks/HeuristicLab.Optimization.Networks/3.3/AlgorithmNode.cs

@@ -20 +20 @@
 #endregion
 
-using System;
-using System.Collections.Generic;
-using System.Drawing;
 using HeuristicLab.Common;
 using HeuristicLab.Core;
 using HeuristicLab.Persistence.Default.CompositeSerializers.Storable;
+using System;
 
 namespace HeuristicLab.Optimization.Networks {
   [Item("AlgorithmNode", "A node of an optimization network which contains a HeuristicLab algorithm.")]
   [StorableClass]
-  public class AlgorithmNode : Node {
+  public class AlgorithmNode : Node, IAlgorithmNode {
+    new public PortCollection Ports {
+      get { return base.Ports; }
+    }
+
     [Storable]
     private IAlgorithm algorithm;
@@ -54 +56 @@
     }
     public AlgorithmNode()
-      : base("Node") {
+      : base("AlgorithmNode") {
       RegisterPortsEvents();
     }
@@ -69 +71 @@
     private void AfterDeserialization() {
       RegisterPortsEvents();
+      RegisterAlgorithmEvents();
     }
 
@@ -77 +80 @@
     private void UpdateParameter(IInputPort port) {
       if (algorithm != null) {
-        foreach (var param in algorithm.Parameters) {
+        IParameter param = null;
+        if (algorithm.Parameters.TryGetValue(port.Name, out param)) {
           IValueParameter p = param as IValueParameter;
-          if ((p != null) && (p.Name == port.Name)) {
+          if (p != null) {
             p.Value = (IItem)port.Value;
           }
@@ -86 +90 @@
     }
     private void UpdateOutputPort(IResult result) {
-      foreach (var port in Ports) {
+      IPort port = null;
+      if (Ports.TryGetValue(result.Name, out port)) {
         IOutputPort p = port as IOutputPort;
-        if ((p != null) && (p.Name == result.Name)) {
+        if (p != null) {
           p.Value = result.Value;
+        }
+      }
+    }
+    private void UpdateOutputPort(IOutputPort port) {
+      if ((algorithm != null) && (algorithm.Results != null)) {
+        IResult result = null;
+        if (algorithm.Results.TryGetValue(port.Name, out result)) {
+          port.Value = result != null ? result.Value : null;
+        } else {
+          port.Value = null;
         }
       }
@@ -106 +121 @@
       Ports.ItemsReplaced += Ports_ItemsReplaced;
       Ports.CollectionReset += Ports_CollectionReset;
+      foreach (var p in Ports)
+        RegisterPortEvents(p);
     }
     void Ports_ItemsAdded(object sender, Collections.CollectionItemsChangedEventArgs<IPort> e) {
@@ -131 +148 @@
     #region Port Events
     private void RegisterPortEvents(IPort port) {
-      IInputPort p = port as IInputPort;
-      if (p != null) {
-        p.ValueChanged += InputPort_ValueChanged;
+      IInputPort i = port as IInputPort;
+      if (i != null) {
+        i.NameChanged += InputPort_NameChanged;
+        i.ValueChanged += InputPort_ValueChanged;
+        UpdateParameter(i);
+      }
+      IOutputPort o = port as IOutputPort;
+      if (o != null) {
+        o.NameChanged += OutputPort_NameChanged;
+        UpdateOutputPort(o);
       }
     }
     private void DeregisterPortEvents(IPort port) {
-      IInputPort p = port as IInputPort;
-      if (p != null) {
-        p.ValueChanged -= InputPort_ValueChanged;
-      }
+      IInputPort i = port as IInputPort;
+      if (i != null) {
+        i.NameChanged -= InputPort_NameChanged;
+        i.ValueChanged -= InputPort_ValueChanged;
+      }
+      IOutputPort o = port as IOutputPort;
+      if (o != null) {
+        o.NameChanged -= OutputPort_NameChanged;
+      }
+    }
+    private void InputPort_NameChanged(object sender, EventArgs e) {
+      UpdateParameter((IInputPort)sender);
     }
     private void InputPort_ValueChanged(object sender, EventArgs e) {
       UpdateParameter((IInputPort)sender);
+    }
+    private void OutputPort_NameChanged(object sender, EventArgs e) {
+      UpdateOutputPort((IOutputPort)sender);
     }
     #endregion
@@ -150 +185 @@
     private void RegisterAlgorithmEvents() {
       if (algorithm != null) {
+        algorithm.Prepared += Algorithm_Prepared;
+        RegisterResultsEvents();
+      }
+    }
+
+    private void DeregisterAlgorithmEvents() {
+      if (algorithm != null) {
+        algorithm.Prepared -= Algorithm_Prepared;
+        DeregisterResultsEvents();
+      }
+    }
+    private void Algorithm_Prepared(object sender, EventArgs e) {
+      RegisterResultsEvents();
+    }
+    #endregion
+
+    #region Results Events
+    private void RegisterResultsEvents() {
+      if ((algorithm != null) && (algorithm.Results != null)) {
         algorithm.Results.ItemsAdded += Results_ItemsAdded;
         algorithm.Results.ItemsRemoved += Results_ItemsRemoved;
         algorithm.Results.ItemsReplaced += Results_ItemsReplaced;
         algorithm.Results.CollectionReset += Results_CollectionReset;
-      }
-    }
-    private void DeregisterAlgorithmEvents() {
-      if (algorithm != null) {
+        foreach (var r in algorithm.Results)
+          RegisterResultEvents(r);
+      }
+    }
+    private void DeregisterResultsEvents() {
+      if ((algorithm != null) && (algorithm.Results != null)) {
         algorithm.Results.ItemsAdded -= Results_ItemsAdded;
         algorithm.Results.ItemsRemoved -= Results_ItemsRemoved;
         algorithm.Results.ItemsReplaced -= Results_ItemsReplaced;
         algorithm.Results.CollectionReset -= Results_CollectionReset;
+        foreach (var r in algorithm.Results)
+          DeregisterResultEvents(r);
       }
     }
@@ -190 +248 @@
       if (result != null) {
         result.ValueChanged += Result_ValueChanged;
+        result.ToStringChanged += Result_ToStringChanged;
+        UpdateOutputPort(result);
       }
     }
@@ -195 +255 @@
       if (result != null) {
         result.ValueChanged -= Result_ValueChanged;
+        result.ToStringChanged += Result_ToStringChanged;
       }
     }
@@ -200 +261 @@
       UpdateOutputPort((IResult)sender);
     }
+    private void Result_ToStringChanged(object sender, EventArgs e) {
+      UpdateOutputPort((IResult)sender);
+    }
     #endregion
   }