Changeset 1133 for trunk/sources/HeuristicLab.Hive.Server.Core/JobManager.cs

Timestamp:

01/15/09 14:53:13 (16 years ago)

Author:

msteinbi

Message:

Implementing Lifecycle Management (#453)

File:

• trunk/sources/HeuristicLab.Hive.Server.Core/JobManager.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Server.Core/JobManager.cs

@@ -33 +33 @@
 
     IJobAdapter jobAdapter;
+    ILifecycleManager lifecycleManager;
 
     #region IJobManager Members
@@ -38 +39 @@
     public JobManager() {
       jobAdapter = ServiceLocator.GetJobAdapter();
+
+      lifecycleManager = ServiceLocator.GetLifecycleManager();
+
+      lifecycleManager.RegisterStartup(new EventHandler(lifecycleManager_OnStartup));
+      lifecycleManager.RegisterStartup(new EventHandler(lifecycleManager_OnShutdown));
+    }
+
+    void checkForDeadJobs() {
+      List<Job> allJobs = new List<Job>(jobAdapter.GetAll());
+      foreach (Job curJob in allJobs) {
+        if (curJob.State == State.calculating) {
+          // TODO check for job results
+          curJob.State = State.idle;
+          curJob.Percentage = 0;
+          curJob.Client = null;
+        }
+      }
+    }
+
+    void lifecycleManager_OnStartup(object sender, EventArgs e) {
+      checkForDeadJobs();
+    }
+
+    void lifecycleManager_OnShutdown(object sender, EventArgs e) {
+      checkForDeadJobs();
     }