Changeset 393 for trunk/sources/HeuristicLab.CEDMA.Operators/OnGridProcessor.cs

Timestamp:

07/22/08 23:29:18 (16 years ago)

Author:

gkronber

Message:

worked on very basic control to view the tree of agents/runs (ticket #188)

File:

• trunk/sources/HeuristicLab.CEDMA.Operators/OnGridProcessor.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.CEDMA.Operators/OnGridProcessor.cs

@@ -40 +40 @@
       AddVariableInfo(new VariableInfo("AgentId", "Id of the agent that the run should be associated to.", typeof(IntData), VariableKind.In));
       AddVariableInfo(new VariableInfo("OperatorGraph", "The operator graph that should be executed on the grid", typeof(IOperatorGraph), VariableKind.In));
-      AddVariableInfo(new VariableInfo("ServerUrl", "Url of the CEDMA server", typeof(StringData), VariableKind.In));
+      AddVariableInfo(new VariableInfo("CedmaServerUri", "Uri of the CEDMA server", typeof(StringData), VariableKind.In));
     }
 
@@ -46 +46 @@
       
       IOperatorGraph operatorGraph = scope.GetVariableValue<IOperatorGraph>("OperatorGraph", false);
-      string serverUrl = scope.GetVariableValue<StringData>("ServerUrl", true).Data;
+      string serverUrl = scope.GetVariableValue<StringData>("CedmaServerUri", true).Data;
       long agentId = scope.GetVariableValue<IntData>("AgentId", true).Data;
+
+      Agent agent = new Agent();
+      foreach(IOperator op in operatorGraph.Operators) {
+        agent.OperatorGraph.AddOperator(op);
+      }
+      agent.OperatorGraph.InitialOperator = operatorGraph.InitialOperator;
 
       NetTcpBinding binding = new NetTcpBinding();
@@ -56 +62 @@
       using(ChannelFactory<IDatabase> factory = new ChannelFactory<IDatabase>(binding)) {
         IDatabase database = factory.CreateChannel(new EndpointAddress(serverUrl));
-        long id = database.InsertAgent(agentId, null, false, DbPersistenceManager.Save(operatorGraph));
+        long id = database.InsertAgent(agentId, null, false, DbPersistenceManager.Save(agent));
         database.UpdateAgent(id, ProcessStatus.Waiting);
       }