Changeset 9169 for branches/UnloadJobs/HeuristicLab.Clients.Hive/3.3/HiveClient.cs

Timestamp:

01/16/13 11:13:18 (11 years ago)

Author:

ascheibe

Message:

#2005

• renamed some events and methods
• fixed some memory leaks

File:

• branches/UnloadJobs/HeuristicLab.Clients.Hive/3.3/HiveClient.cs (modified) (7 diffs)

branches/UnloadJobs/HeuristicLab.Clients.Hive/3.3/HiveClient.cs

@@ -52 +52 @@
         if (value != jobs) {
           jobs = value;
-          OnHiveExperimentsChanged();
+          OnHiveJobsChanged();
         }
       }
@@ -77 +77 @@
 
     private HiveClient() { }
+
+    public void ClearHiveClient() {
+      foreach (var j in Jobs) {
+        if (j.RefreshAutomatically) {
+          j.RefreshAutomatically = false; // stop result polling
+          j.Dispose();
+        }
+      }
+      Jobs = null;
+      if (onlinePlugins != null)
+        onlinePlugins.Clear();
+      if (alreadyUploadedPlugins != null)
+        alreadyUploadedPlugins.Clear();
+    }
 
     #region Refresh
@@ -205 +219 @@
       if (handler != null) handler(this, EventArgs.Empty);
     }
-    public event EventHandler HiveExperimentsChanged;
-    private void OnHiveExperimentsChanged() {
-      var handler = HiveExperimentsChanged;
+    public event EventHandler HiveJobsChanged;
+    private void OnHiveJobsChanged() {
+      var handler = HiveJobsChanged;
       if (handler != null) handler(this, EventArgs.Empty);
     }
@@ -308 +322 @@
       }
       finally {
-        refreshableJob.RefreshAutomatically = true;
-        refreshableJob.StartResultPolling();
+        //refreshableJob.RefreshAutomatically = true;        
         refreshableJob.Job.Modified = false;
         refreshableJob.IsProgressing = false;
@@ -421 +434 @@
       refreshableJob.IsProgressing = true;
       refreshableJob.Progress = new Progress();
+      TaskDownloader downloader = null;
 
       try {
@@ -433 +447 @@
 
         refreshableJob.Progress.Status = "Downloading tasks...";
-        TaskDownloader downloader = new TaskDownloader(allTasks.Select(x => x.Id));
+        downloader = new TaskDownloader(allTasks.Select(x => x.Id));
         downloader.StartAsync();
 
@@ -465 +479 @@
         refreshableJob.IsProgressing = false;
         refreshableJob.Progress.Finish();
+        if (downloader != null) {
+          downloader.Dispose();
+        }
       }
     }