Changeset 420 for trunk/sources/HeuristicLab.CEDMA.Core

Timestamp:

08/01/08 21:35:35 (16 years ago)

Author:

gkronber

Message:

worked on #211.

• Implemented downloading of linked operators from the database in AgentList (to allow view/edit of the whole operator graph)
• Implemented downloading and patching of linked operators in RunScheduler to prepare the operator-graph for execution (OperatorLink operator can't be executed)

(there is some code duplication because the patching is very similar in AgentList DatabaseOperatorLibrary and RunScheduler. This needs some more work)

File:

• trunk/sources/HeuristicLab.CEDMA.Core/AgentList.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.CEDMA.Core/AgentList.cs

@@ -30 +30 @@
 using System.Runtime.Serialization;
 using System.IO;
+using HeuristicLab.Operators;
 
 namespace HeuristicLab.CEDMA.Core {
@@ -50 +51 @@
         newAgent.Status = a.Status;
         IOperatorGraph opGraph = (IOperatorGraph)PersistenceManager.RestoreFromGZip(a.RawData);
-        foreach(IOperator op in opGraph.Operators) newAgent.OperatorGraph.AddOperator(op);
+
+        DownloadOperators(opGraph, new Dictionary<long, IOperator>());
+
+        foreach(IOperator op in opGraph.Operators) {
+          newAgent.OperatorGraph.AddOperator(op);
+        }
         newAgent.OperatorGraph.InitialOperator = opGraph.InitialOperator;
         agentList.Add(newAgent);
@@ -80 +86 @@
     }
 
+    private void DownloadOperators(IOperatorGraph opGraph, Dictionary<long, IOperator> downloaded) {
+      foreach(IOperator op in opGraph.Operators) {
+        DownloadOperators(op, downloaded);
+      }
+    }
+
+    private void DownloadOperators(IOperator op, Dictionary<long, IOperator> downloaded) {
+      if(op is OperatorLink) {
+        OperatorLink link = op as OperatorLink;
+        if(downloaded.ContainsKey(link.Id)) {
+          link.Operator = downloaded[link.Id];
+        } else {
+          OperatorEntry targetEntry = database.GetOperator(link.Id);
+          IOperator target = (IOperator)PersistenceManager.RestoreFromGZip(targetEntry.RawData);
+          downloaded.Add(link.Id, target);
+          DownloadOperators(target, downloaded);
+          link.Operator = target;
+        }
+      } else if(op is CombinedOperator) {
+        DownloadOperators(((CombinedOperator)op).OperatorGraph, downloaded);
+      }
+    }
+
     public override IView CreateView() {
       return new AgentListView(this);