Changeset 393 for trunk/sources/HeuristicLab.CEDMA.Server/RunScheduler.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.Server/RunScheduler.cs (modified) (4 diffs)

trunk/sources/HeuristicLab.CEDMA.Server/RunScheduler.cs

@@ -31 +31 @@
 using HeuristicLab.Grid;
 using System.Diagnostics;
+using HeuristicLab.Data;
 
 namespace HeuristicLab.CEDMA.Server {
@@ -39 +40 @@
       public AtomicOperation Operation;
     }
+    private string serverUri;
     private Database database;
     private JobManager jobManager;
@@ -47 +49 @@
     private AutoResetEvent runningJobs = new AutoResetEvent(false);
 
-    public RunScheduler(Database database, JobManager jobManager) {
+    public RunScheduler(Database database, JobManager jobManager, string serverUri) {
       this.database = database;
       this.jobManager = jobManager;
+      this.serverUri = serverUri;
       jobQueue = new Queue<Job>();
       Thread resultsGatheringThread = new Thread(GatherResults);
@@ -66 +69 @@
       }
       foreach(AgentEntry entry in agents) {
-        IOperatorGraph opGraph = (IOperatorGraph)DbPersistenceManager.Restore(entry.RawData);
-        AtomicOperation op = new AtomicOperation(opGraph.InitialOperator, new Scope());
+        Agent agent = (Agent)DbPersistenceManager.Restore(entry.RawData);
+        IOperatorGraph opGraph = agent.OperatorGraph;
+        Scope scope = new Scope();
+        // initialize CEDMA variables for the execution of the agent
+        scope.AddVariable(new Variable("AgentId", new IntData((int)entry.Id)));
+        scope.AddVariable(new Variable("CedmaServerUri", new StringData(serverUri)));
+        AtomicOperation op = new AtomicOperation(opGraph.InitialOperator, scope);
         WaitHandle wHandle;
         lock(remoteCommLock) {