Changeset 14635 for branches/OptimizationNetworks/HeuristicLab.Networks.IntegratedOptimization

Timestamp:

02/01/17 18:25:28 (8 years ago)

Author:

jkarder

Message:

#2205: worked on optimization networks

• created default parameters for orchestration and evaluation ports
• adapted FeatureSelectionNetwork

File:

• branches/OptimizationNetworks/HeuristicLab.Networks.IntegratedOptimization/3.3/OrchestratedAlgorithmNode.cs (modified) (6 diffs)

branches/OptimizationNetworks/HeuristicLab.Networks.IntegratedOptimization/3.3/OrchestratedAlgorithmNode.cs

@@ -73 +73 @@
     public OrchestratedAlgorithmNode(string name)
       : base(name) {
-      var orchestrationPort = new MessagePort(OrchestrationPortName);
-      Ports.Add(orchestrationPort);
-
-      var evaluationPort = new MessagePort(EvaluationPortName);
-      Ports.Add(evaluationPort);
+      Ports.Add(CreateOrchestrationPort<IProblem>(OrchestrationPortName));
+      Ports.Add(CreateEvaluationPort<IItem>(EvaluationPortName, "Solution", "Quality"));
 
       RegisterEvents();
@@ -93 +90 @@
     private void RegisterEvents() {
       OrchestrationPort.MessageReceived += OrchestrationPort_MessageReceived;
+    }
+
+    protected IMessagePort CreateOrchestrationPort<T>(string portName) where T : class, IProblem {
+      var orchestrationPort = new MessagePort(portName);
+      orchestrationPort.Parameters.Add(new PortParameter<EnumValue<OrchestrationMessage>>("OrchestrationMessage") {
+        Type = PortParameterType.Input
+      });
+      orchestrationPort.Parameters.Add(new PortParameter<T>("Problem") {
+        Type = PortParameterType.Input
+      });
+      orchestrationPort.Parameters.Add(new PortParameter<ResultCollection>("Results") {
+        Type = PortParameterType.Output
+      });
+      return orchestrationPort;
+    }
+
+    protected IMessagePort CreateEvaluationPort<T>(string portName, string solutionName, string qualityName) where T : class, IItem {
+      var evaluationPort = new MessagePort(portName);
+      evaluationPort.Parameters.Add(new PortParameter<T>(solutionName) {
+        Type = PortParameterType.Output
+      });
+      evaluationPort.Parameters.Add(new PortParameter<DoubleValue>(qualityName) {
+        Type = PortParameterType.Input | PortParameterType.Output
+      });
+      return evaluationPort;
     }
 
@@ -106 +128 @@
           case ExecutionState.Paused:
           case ExecutionState.Stopped:
-            IMessageValue problemMsgVal;
-            if (e.Value.Values.TryGetValue("Problem", out problemMsgVal)) {
-              var problem = (IProblem)problemMsgVal.Value.Clone();
+            var problem = (IProblem)requestMessage["Problem"];
+            if (problem != null) {
+              problem = (IProblem)problem.Clone();
 
               var heuristicOptimizationProblem = problem as IHeuristicOptimizationProblem;
@@ -140 +162 @@
                 }
               }
-
-              Algorithm.Prepare(messageFlags.HasFlag(OrchestrationMessage.ClearRuns));
             }
+
+
+            Algorithm.Prepare(messageFlags.HasFlag(OrchestrationMessage.ClearRuns));
             break;
         }
@@ -192 +215 @@
           try {
             Algorithm.Pause();
-          }
-          catch (InvalidOperationException) {
+          } catch (InvalidOperationException) {
             // ExecutionState might have changed since we accepted the message
           }
@@ -207 +229 @@
             try {
               Algorithm.Stop();
-            }
-            catch (InvalidOperationException) {
+            } catch (InvalidOperationException) {
               // ExecutionState might have changed since we accepted the message
-            }
-            catch (NullReferenceException) {
+            } catch (NullReferenceException) {
               // BasicAlgorithm might have stopped since we accepted the message
               // CancellationTokenSource is null in this case