Changeset 512 for trunk

Timestamp:

08/13/08 16:33:03 (16 years ago)

Author:

gkronber

Message:

worked on #211

Location:

trunk/sources/HeuristicLab.CEDMA.Core

Files:

• Agent.cs (modified) (2 diffs)
• AgentView.cs (modified) (2 diffs)
• DatabaseOperatorLibrary.cs (modified) (2 diffs)
• OperatorLink.cs (modified) (4 diffs)

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

@@ -88 +88 @@
         return results;
       }
-    } 
+    }
 
     public IView CreateView() {
@@ -94 +94 @@
         byte[] rawData = Database.GetAgentRawData(Id);
         IOperatorGraph opGraph = (IOperatorGraph)PersistenceManager.RestoreFromGZip(rawData);
-        DownloadOperators(opGraph, new Dictionary<long, IOperator>());
         foreach(IOperator op in opGraph.Operators) OperatorGraph.AddOperator(op);
         OperatorGraph.InitialOperator = opGraph.InitialOperator;
+        PatchOperatorLinks(OperatorGraph);
       }
       return new AgentView(this);
     }
 
-    private void DownloadOperators(IOperatorGraph opGraph, Dictionary<long, IOperator> downloaded) {
+    private void PatchOperatorLinks(IOperatorGraph opGraph) {
       foreach(IOperator op in opGraph.Operators) {
-        DownloadOperators(op, downloaded);
+        PatchOperatorLinks(op);
       }
     }
 
-    private void DownloadOperators(IOperator op, Dictionary<long, IOperator> downloaded) {
+    private void PatchOperatorLinks(IOperator op) {
       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;
+        link.Database = Database;
+        //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);
+        //  PatchOperatorLinks(target, downloaded);
+        //  link.Operator = target;
+        //}
+      } else if(op is CombinedOperator) {
+        PatchOperatorLinks(((CombinedOperator)op).OperatorGraph);
+      }
+      // also patch operator links contained (indirectly) in variables
+      foreach(VariableInfo varInfo in op.VariableInfos) {
+        IVariable var = op.GetVariable(varInfo.ActualName);
+        if(var != null && var.Value is IOperatorGraph) {
+          PatchOperatorLinks((IOperatorGraph)var.Value);
+        } else if(var != null && var.Value is IOperator) {
+          PatchOperatorLinks((IOperator)var.Value);
         }
-      } else if(op is CombinedOperator) {
-        DownloadOperators(((CombinedOperator)op).OperatorGraph, downloaded);
       }
     }

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

@@ -32 +32 @@
 namespace HeuristicLab.CEDMA.Core {
   public partial class AgentView : ViewBase {
-    private IAgent agent;
-    public IAgent Agent {
+    private Agent agent;
+    public Agent Agent {
       get { return agent; }
       set { agent = value; }
@@ -42 +42 @@
       Caption = "Agent";
     }
-    public AgentView(IAgent agent)
+    public AgentView(Agent agent)
       : this() {
       Agent = agent;

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

@@ -91 +91 @@
     }
 
+    private void PatchLinks(IOperatorGraph opGraph) {
+      foreach(IOperator op in opGraph.Operators) {
+        PatchLinks(op);
+      }
+    }
+
     private void PatchLinks(IOperator op) {
       if(op is OperatorLink) {
         OperatorLink link = op as OperatorLink;
-        link.Operator = FindOperator(link.Id);
+        link.Database = Database;
       }
       else if(op is CombinedOperator) {
@@ -100 +106 @@
         foreach(IOperator internalOp in combinedOp.OperatorGraph.Operators) {
           PatchLinks(internalOp);
+        }
+      }
+      // also patch operator links contained (indirectly) in variables
+      foreach(VariableInfo varInfo in op.VariableInfos) {
+        IVariable var = op.GetVariable(varInfo.ActualName);
+        if(var != null && var.Value is IOperatorGraph) {
+          PatchLinks((IOperatorGraph)var.Value);
+        } else if(var != null && var.Value is IOperator) {
+          PatchLinks((IOperator)var.Value);
         }
       }

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

@@ -26 +26 @@
 using HeuristicLab.Core;
 using System.Xml;
+using HeuristicLab.CEDMA.DB.Interfaces;
+using HeuristicLab.Operators;
 
 namespace HeuristicLab.CEDMA.Core {
@@ -33 +35 @@
       get { return id; }
     }
+
+    public IDatabase Database { get; set; }
 
     private IOperator myOperator;
@@ -65 +69 @@
 
     public override IView CreateView() {
+      if(Operator == null) {
+        if(Database == null) return null;
+        OperatorEntry targetEntry = Database.GetOperator(Id);
+        IOperator target = (IOperator)PersistenceManager.RestoreFromGZip(targetEntry.RawData);
+        PatchOperatorLinks(target);
+        Operator = target;
+      }
       return myOperator.CreateView();
     }
@@ -84 +95 @@
       base.Populate(node, restoredObjects);
     }
+
+    private void PatchOperatorLinks(IOperatorGraph opGraph) {
+      foreach(IOperator op in opGraph.Operators) {
+        PatchOperatorLinks(op);
+      }
+    }
+
+    private void PatchOperatorLinks(IOperator op) {
+      if(op is OperatorLink) {
+        OperatorLink link = op as OperatorLink;
+        link.Database = Database;
+        //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);
+        //  PatchOperatorLinks(target, downloaded);
+        //  link.Operator = target;
+        //}
+      } else if(op is CombinedOperator) {
+        PatchOperatorLinks(((CombinedOperator)op).OperatorGraph);
+      }
+      // also patch operator links contained (indirectily) in variables
+      foreach(VariableInfo varInfo in op.VariableInfos) {
+        IVariable var = op.GetVariable(varInfo.ActualName);
+        if(var != null && var.Value is IOperatorGraph) {
+          PatchOperatorLinks((IOperatorGraph)var.Value);
+        } else if(var != null && var.Value is IOperator) {
+          PatchOperatorLinks((IOperator)var.Value);
+        }
+      }
+    }
   }
 }