Changeset 14624 for branches/OptimizationNetworks/HeuristicLab.Networks.IntegratedOptimization/3.3/OrchestratedAlgorithmNode.cs

Timestamp:

01/31/17 13:58:50 (7 years ago)

Author:

mkommend

Message:

#2205: Refactored messages in orchestrated algorithm node.

File:

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

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

@@ -65 +65 @@
     [StorableConstructor]
     protected OrchestratedAlgorithmNode(bool deserializing) : base(deserializing) { }
-    protected OrchestratedAlgorithmNode(OrchestratedAlgorithmNode original, Cloner cloner) : base(original, cloner) {
+    protected OrchestratedAlgorithmNode(OrchestratedAlgorithmNode original, Cloner cloner)
+      : base(original, cloner) {
       EvalHook = cloner.Clone(original.EvalHook);
       RegisterEvents();
     }
     public OrchestratedAlgorithmNode() : this("OrchestratedAlgorithmNode") { }
-    public OrchestratedAlgorithmNode(string name) : base(name) {
+    public OrchestratedAlgorithmNode(string name)
+      : base(name) {
       var orchestrationPort = new MessagePort(OrchestrationPortName);
       Ports.Add(orchestrationPort);
@@ -95 +97 @@
     #region Port Events
     private void OrchestrationPort_MessageReceived(object sender, EventArgs<IMessage, CancellationToken> e) {
-      var message = ((EnumValue<OrchestrationMessage>)e.Value["OrchestrationMessage"]).Value;
+      var message = e.Value;
+      var orchestrationMessage = ((EnumValue<OrchestrationMessage>)message["OrchestrationMessage"]).Value;
 
       #region Prepare
-      if (message.HasFlag(OrchestrationMessage.Prepare)) {
+      if (orchestrationMessage.HasFlag(OrchestrationMessage.Prepare)) {
         switch (Algorithm.ExecutionState) {
           case ExecutionState.Prepared:
@@ -107 +110 @@
               var prob = (IHeuristicOptimizationProblem)problemMsgVal.Value.Clone();
 
-              if (message.HasFlag(OrchestrationMessage.SetEvalHook)) {
+              if (orchestrationMessage.HasFlag(OrchestrationMessage.SetEvalHook)) {
                 var instEval = prob.Evaluator as InstrumentedOperator;
                 if (instEval != null && EvalHook != null) instEval.AfterExecutionOperators.Add(EvalHook);
@@ -137 +140 @@
               }
 
-              Algorithm.Prepare(message.HasFlag(OrchestrationMessage.ClearRuns));
+              Algorithm.Prepare(orchestrationMessage.HasFlag(OrchestrationMessage.ClearRuns));
             }
             break;
@@ -145 +148 @@
 
       #region Start
-      if (message.HasFlag(OrchestrationMessage.Start)) {
+      if (orchestrationMessage.HasFlag(OrchestrationMessage.Start)) {
         switch (Algorithm.ExecutionState) {
           case ExecutionState.Prepared:
@@ -172 +175 @@
 
             if (sendResultMessage) {
+              message["Results"] = (ResultCollection)Algorithm.Results.Clone();
               var msg = OrchestrationPort.PrepareMessage();
               msg["Results"] = (ResultCollection)Algorithm.Results.Clone();
@@ -182 +186 @@
 
       #region Pause
-      if (message.HasFlag(OrchestrationMessage.Pause)) {
+      if (orchestrationMessage.HasFlag(OrchestrationMessage.Pause)) {
         if (Algorithm.ExecutionState == ExecutionState.Started) {
           sendResultMessage = false;
           try {
             Algorithm.Pause();
-          } catch (InvalidOperationException) {
+          }
+          catch (InvalidOperationException) {
             // ExecutionState might have changed since we accepted the message
           }
@@ -195 +200 @@
 
       #region Stop
-      if (message.HasFlag(OrchestrationMessage.Stop)) {
+      if (orchestrationMessage.HasFlag(OrchestrationMessage.Stop)) {
         switch (Algorithm.ExecutionState) {
           case ExecutionState.Started:
@@ -201 +206 @@
             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