Changeset 6178 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/RefreshableHiveExperiment.cs

Timestamp:

05/10/11 17:58:59 (13 years ago)

Author:

cneumuel

Message:

#1233

• added semaphores to ensure an appdomain is never unloaded when the start method has not finished
• HiveEngine uploading and downloading of jobs works and is displayed in the view

File:

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

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

@@ -34 +34 @@
   public class RefreshableHiveExperiment : IHiveItem, IDeepCloneable, IContent, IProgressReporter {
     private JobResultPoller jobResultPoller;
-    private JobDownloader<ItemJob> jobDownloader = new JobDownloader<ItemJob>(2, 2);
+    private ConcurrentJobDownloader<ItemJob> jobDownloader = new ConcurrentJobDownloader<ItemJob>(2, 2);
     private static object locker = new object();
 
@@ -83 +83 @@
     }
 
+    [Storable]
+    private bool isControllable = true;
+    public bool IsControllable {
+      get { return isControllable; }
+      set {
+        if (value != isControllable) {
+          isControllable = value;
+          OnIsControllableChanged();
+        }
+      }
+    }
+
     #region Constructors and Cloning
     public RefreshableHiveExperiment() {
@@ -99 +111 @@
       this.RefreshAutomatically = original.RefreshAutomatically;
       this.IncludeJobs = original.IncludeJobs;
+      this.IsControllable = original.IsControllable;
     }
     public IDeepCloneable Clone(Cloner cloner) {
@@ -163 +176 @@
             jobDownloader.DownloadJob(hj.Job.Id, (id, itemJob, exception) => {
               if (exception != null) {
-                throw new JobDownloaderException("Downloading job failed.", exception);
+                throw new ConcurrentJobDownloaderException("Downloading job failed.", exception);
               }
 
@@ -171 +184 @@
                 // if the job is paused, download but don't integrate into parent optimizer (to avoid Prepare)
                 if (hj.Job.State == JobState.Paused) {
-                  hj.JobItem = itemJob;
+                  hj.ItemJob = itemJob;
                 } else {
                   if (lightweightJob.ParentJobId.HasValue) {
@@ -177 +190 @@
                     parentHiveJob.IntegrateChild(itemJob, hj.Job.Id);
                   } else {
-                    hj.JobItem = itemJob;
+                    hj.ItemJob = itemJob;
                   }
                 }
@@ -211 +224 @@
 
     public bool AllJobsFinished() {
-      return hiveExperiment.GetAllHiveJobs().All(j => j.Job.State == JobState.Finished
-                                            || j.Job.State == JobState.Aborted
-                                            || j.Job.State == JobState.Failed);
+      return hiveExperiment.GetAllHiveJobs().All(j => (j.Job.State == JobState.Finished
+                                                   || j.Job.State == JobState.Aborted
+                                                   || j.Job.State == JobState.Failed)
+                                                   && j.ItemJobDownloaded);
     }
 
@@ -299 +313 @@
       if (handler != null) handler(sender, e);
     }
+
+    public event EventHandler IsControllableChanged;
+    private void OnIsControllableChanged() {
+      var handler = IsControllableChanged;
+      if (handler != null) handler(this, EventArgs.Empty);
+    }
     #endregion