Changeset 6725 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.3/TaskDownloader.cs

Timestamp:

09/08/11 16:38:28 (13 years ago)

Author:

ascheibe

Message:

#1233 more renaming for more consistency

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.3/TaskDownloader.cs (moved) (moved from branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.3/HiveJobDownloader.cs) (5 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.3/TaskDownloader.cs

@@ -27 +27 @@
 
 namespace HeuristicLab.Clients.Hive {
-  public class HiveJobDownloader {
-    private IEnumerable<Guid> jobIds;
-    private ConcurrentJobDownloader<ItemJob> jobDownloader;
-    private IDictionary<Guid, HiveJob> results;
+  public class TaskDownloader {
+    private IEnumerable<Guid> taskIds;
+    private ConcurrentTaskDownloader<ItemTask> taskDownloader;
+    private IDictionary<Guid, HiveTask> results;
     private bool exceptionOccured = false;
     private Exception currentException;
@@ -36 +36 @@
     public bool IsFinished {
       get {
-        return results.Count == jobIds.Count();
+        return results.Count == taskIds.Count();
       }
     }
@@ -58 +58 @@
     }
 
-    public IDictionary<Guid, HiveJob> Results {
+    public IDictionary<Guid, HiveTask> Results {
       get {
         return results;
@@ -64 +64 @@
     }
 
-    public HiveJobDownloader(IEnumerable<Guid> jobIds) {
-      this.jobIds = jobIds;
-      this.jobDownloader = new ConcurrentJobDownloader<ItemJob>(2, 2);
-      this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured);
-      this.results = new Dictionary<Guid, HiveJob>();
+    public TaskDownloader(IEnumerable<Guid> jobIds) {
+      this.taskIds = jobIds;
+      this.taskDownloader = new ConcurrentTaskDownloader<ItemTask>(2, 2);
+      this.taskDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(taskDownloader_ExceptionOccured);
+      this.results = new Dictionary<Guid, HiveTask>();
     }
     
     public void StartAsync() {
-      foreach (Guid jobId in jobIds) {
+      foreach (Guid jobId in taskIds) {
         Task job = ServiceLocator.Instance.CallHiveService(s => s.GetJob(jobId));
 
-        jobDownloader.DownloadJob(job,
+        taskDownloader.DownloadJob(job,
           (localJob, itemJob) => {
             if (localJob != null && itemJob != null) {
-              HiveJob hiveJob;
-              if (itemJob is OptimizerJob) {
-                hiveJob = new OptimizerHiveJob((OptimizerJob)itemJob);
+              HiveTask hiveJob;
+              if (itemJob is OptimizerTask) {
+                hiveJob = new OptimizerHiveTask((OptimizerTask)itemJob);
               } else {
-                hiveJob = new HiveJob(itemJob, true);
+                hiveJob = new HiveTask(itemJob, true);
               }
-              hiveJob.Job = localJob;
+              hiveJob.Task = localJob;
               this.results.Add(localJob.Id, hiveJob);
             }
@@ -91 +91 @@
     }
 
-    private void jobDownloader_ExceptionOccured(object sender, EventArgs<Exception> e) {
+    private void taskDownloader_ExceptionOccured(object sender, EventArgs<Exception> e) {
       OnExceptionOccured(e.Value);
     }