Changeset 5399 for branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.HiveEngine/3.3/HiveEngine.cs

Timestamp:

01/31/11 10:35:57 (14 years ago)

Author:

cneumuel

Message:

#1260

• fixed wiring of textboxes in HiveExperimentManager
• robustified results polling in HiveExperimentManager
• robustified HiveEngine

File:

• branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.HiveEngine/3.3/HiveEngine.cs (modified) (5 diffs)

branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.HiveEngine/3.3/HiveEngine.cs

@@ -51 +51 @@
       }
     }
-    
+
     #region constructors and cloning
     public HiveEngine() {
@@ -310 +310 @@
     private void DeleteJobs(IDictionary<Guid, int> jobIndices) {
       if (jobIndices.Count > 0) {
-        using (Disposable<IClientFacade> service = ServiceLocator.Instance.ClientFacadePool.GetService()) {
-          foreach (Guid jobId in jobIndices.Keys) {
-            service.Obj.DeleteJob(jobId);
-          }
-          LogMessage(string.Format("Deleted {0} jobs on hive.", jobIndices.Count));
-          jobIndices.Clear();
-        }
+        TryAndRepeat(() => {
+          LogMessage(string.Format("Deleting {0} jobs on hive.", jobIndices.Count));
+          using (Disposable<IClientFacade> service = ServiceLocator.Instance.ClientFacadePool.GetService()) {
+            foreach (Guid jobId in jobIndices.Keys) {
+              service.Obj.DeleteJob(jobId);
+            }
+            jobIndices.Clear();
+          }
+        }, 5, string.Format("Could not delete {0} jobs", jobIndices.Count));
       }
     }
@@ -364 +366 @@
             catch (Exception e) {
               LogException(e);
+              LogMessage("Repeating upload");
             }
           }
@@ -393 +396 @@
           catch (Exception e) {
             LogException(e);
+            LogMessage("Repeating download");
           }
         }
@@ -423 +427 @@
       }
     }
+
+    /// <summary>
+    /// Executes the action. If it throws an exception it is repeated until repetition-count is reached.
+    /// If repetitions is -1, it is repeated infinitely.
+    /// </summary>
+    private static void TryAndRepeat(Action action, int repetitions, string errorMessage) {
+      while (repetitions > 0) {
+        try { action(); }
+        catch (Exception e) {
+          repetitions--;
+          if (repetitions == 0) {
+            throw new HiveEngineException(errorMessage, e);
+          }
+        }
+      }
+    }
+
+    private static void TryAndRepeat(Action action) {
+      TryAndRepeat(action, -1, string.Empty);
+    }
   }