Changeset 5106 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager

Timestamp:

12/14/10 16:52:55 (14 years ago)

Author:

cneumuel

Message:

#1233

• made MockJob to execute asynchronously with the option to spinWait
• added methods to IHiveService
• implemented methods for Slave handling in HiveService
• added more tests for server
• changed db-schema of slaves and slavegroups

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/HiveExperimentClient.cs (modified) (3 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/HiveExperimentClient.cs

@@ -46 +46 @@
     private System.Timers.Timer timer;
     private DateTime lastUpdateTime;
-    private Guid? rootJobId;
+    private Guid rootJobId;
     private JobResultPoller jobResultPoller;
 
@@ -535 +535 @@
           // fetch all Job objects to create the full tree of tree of HiveJob objects
           progress.Status = "Downloading list of jobs...";
-          IEnumerable<LightweightJob> allResults = service.Obj.GetLightweightChildJobs(rootJobId.Value, true, true);
+          IEnumerable<LightweightJob> allResults = service.Obj.GetLightweightChildJobs(rootJobId, true, true);
           totalJobCount = allResults.Count();
 
@@ -550 +550 @@
 
           jobCount = 1;
-          progress.Status = string.Format("Deserializing {0} of {1} jobs... ({2} kb)", jobCount, totalJobCount, allJobDatas[this.rootJobId.Value].Data.Count() / 1024);
-          this.HiveJob = new HiveJob(allJobs[this.rootJobId.Value], allJobDatas[this.rootJobId.Value], false);
-          allJobDatas.Remove(this.rootJobId.Value); // reduce memory footprint
-          allJobs.Remove(this.rootJobId.Value);
+          progress.Status = string.Format("Deserializing {0} of {1} jobs... ({2} kb)", jobCount, totalJobCount, allJobDatas[this.rootJobId].Data.Count() / 1024);
+          this.HiveJob = new HiveJob(allJobs[this.rootJobId], allJobDatas[this.rootJobId], false);
+          allJobDatas.Remove(this.rootJobId); // reduce memory footprint
+          allJobs.Remove(this.rootJobId);
           progress.ProgressValue = (double)jobCount / totalJobCount;
 
           if (this.HiveJob.Job.DateFinished.HasValue) {
-            this.ExecutionTime = this.HiveJob.Job.DateFinished.Value - this.HiveJob.Job.DateCreated.Value;
+            this.ExecutionTime = this.HiveJob.Job.DateFinished.Value - this.HiveJob.Job.DateCreated;
             this.lastUpdateTime = this.HiveJob.Job.DateFinished.Value;
             this.ExecutionState = Core.ExecutionState.Stopped;
             OnStopped();
           } else {
-            this.ExecutionTime = DateTime.Now - this.HiveJob.Job.DateCreated.Value;
+            this.ExecutionTime = DateTime.Now - this.HiveJob.Job.DateCreated;
             this.lastUpdateTime = DateTime.Now;
             this.ExecutionState = Core.ExecutionState.Started;