Changeset 7218 for trunk/sources/HeuristicLab.Clients.Hive

Timestamp:

12/21/11 10:34:36 (12 years ago)

Author:

ascheibe

Message:

#1672 renamed some jobs to tasks

Location:

trunk/sources/HeuristicLab.Clients.Hive/3.3

Files:

• HiveJobs/HiveTask.cs (modified) (2 diffs)
• HiveJobs/OptimizerHiveTask.cs (modified) (3 diffs)
• RefreshableJob.cs (modified) (4 diffs)

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveJobs/HiveTask.cs

@@ -360 +360 @@
       childHiveTasksLock.EnterReadLock();
       try {
-        var jobs = new List<HiveTask>();
-        jobs.Add(this);
+        var tasks = new List<HiveTask>();
+        tasks.Add(this);
         foreach (HiveTask child in this.childHiveTasks) {
-          jobs.AddRange(child.GetAllHiveTasks());
-        }
-        return jobs;
+          tasks.AddRange(child.GetAllHiveTasks());
+        }
+        return tasks;
       }
       finally { childHiveTasksLock.ExitReadLock(); }
@@ -405 +405 @@
     }
 
-    public void RemoveByTaskId(Guid jobId) {
+    public void RemoveByTaskId(Guid taskId) {
       childHiveTasksLock.EnterWriteLock();
       try {
-        IEnumerable<HiveTask> jobs = childHiveTasks.Where(j => j.Task.Id == jobId).ToList();
-        foreach (HiveTask j in jobs) {
-          this.childHiveTasks.Remove(j);
+        IEnumerable<HiveTask> tasks = childHiveTasks.Where(j => j.Task.Id == taskId).ToList();
+        foreach (HiveTask t in tasks) {
+          this.childHiveTasks.Remove(t);
         }
         foreach (HiveTask child in childHiveTasks) {
-          child.RemoveByTaskId(jobId);
+          child.RemoveByTaskId(taskId);
         }
       }

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveJobs/OptimizerHiveTask.cs

@@ -185 +185 @@
     ///   add the runs from the optimizerTask to the batchrun and replace the Optimizer
     /// </summary>
-    public override void IntegrateChild(ItemTask task, Guid childJobId) {
+    public override void IntegrateChild(ItemTask task, Guid childTaskId) {
       var optimizerTask = (OptimizerTask)task;
       syncTasksWithOptimizers = false; // don't sync with optimizers during this method
@@ -198 +198 @@
 
       childHiveTasksLock.EnterReadLock();
-      OptimizerHiveTask child = (OptimizerHiveTask)this.ChildHiveTasks.Single(j => j.Task.Id == childJobId);
+      OptimizerHiveTask child = (OptimizerHiveTask)this.ChildHiveTasks.Single(j => j.Task.Id == childTaskId);
       try {
         if (!optimizerTask.ComputeInParallel) {
@@ -329 +329 @@
     }
 
-    public OptimizerHiveTask GetChildByOptimizerJob(OptimizerTask optimizerJob) {
+    public OptimizerHiveTask GetChildByOptimizerTask(OptimizerTask optimizerTask) {
       childHiveTasksLock.EnterReadLock();
       try {
         foreach (OptimizerHiveTask child in childHiveTasks) {
-          if (child.ItemTask == optimizerJob)
+          if (child.ItemTask == optimizerTask)
             return child;
         }

trunk/sources/HeuristicLab.Clients.Hive/3.3/RefreshableJob.cs

@@ -265 +265 @@
     private void jobResultPoller_JobResultReceived(object sender, EventArgs<IEnumerable<LightweightTask>> e) {
       foreach (LightweightTask lightweightTask in e.Value) {
-        HiveTask hiveTask = GetHiveJobById(lightweightTask.Id);
+        HiveTask hiveTask = GetHiveTaskById(lightweightTask.Id);
         if (hiveTask != null) {
           // lastJobDataUpdate equals DateTime.MinValue right after it was uploaded. When the first results are polled, this value is updated
@@ -279 +279 @@
             jobDownloader.DownloadTaskData(hiveTask.Task, (localJob, itemJob) => {
               log.LogMessage(string.Format("Finished downloading task {0}", localJob.Id));
-              HiveTask localHiveTask = GetHiveJobById(localJob.Id);
+              HiveTask localHiveTask = GetHiveTaskById(localJob.Id);
 
               if (itemJob == null) {
@@ -294 +294 @@
                 } else {
                   if (localJob.ParentTaskId.HasValue) {
-                    HiveTask parentHiveTask = GetHiveJobById(localJob.ParentTaskId.Value);
+                    HiveTask parentHiveTask = GetHiveTaskById(localJob.ParentTaskId.Value);
                     parentHiveTask.IntegrateChild(itemJob, localJob.Id);
                   } else {
@@ -317 +317 @@
     }
 
-    public HiveTask GetHiveJobById(Guid jobId) {
-      foreach (HiveTask job in this.HiveTasks) {
-        var hj = job.GetHiveTaskByTaskId(jobId);
+    public HiveTask GetHiveTaskById(Guid jobId) {
+      foreach (HiveTask t in this.HiveTasks) {
+        var hj = t.GetHiveTaskByTaskId(jobId);
         if (hj != null)
           return hj;