Changeset 6200 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/ExperimentManagerClient.cs

Timestamp:

05/16/11 00:18:48 (13 years ago)

Author:

cneumuel

Message:

#1233

• stability improvements for HiveEngine

File:

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

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

@@ -239 +239 @@
       }
     }
-
+    
     /// <summary>
     /// Uploads the local configuration file as plugin
@@ -286 +286 @@
       }
 
-      hiveJob.Job.PluginsNeededIds = PluginUtil.GetPluginDependencies(service, this.onlinePlugins, this.alreadyUploadedPlugins, plugins, useLocalPlugins);
+      TryAndRepeat(() => {
+        hiveJob.Job.PluginsNeededIds = PluginUtil.GetPluginDependencies(service, this.onlinePlugins, this.alreadyUploadedPlugins, plugins, useLocalPlugins);
+      }, -1, "Failed to upload plugins");
       hiveJob.Job.PluginsNeededIds.Add(configPluginId);
       hiveJob.Job.HiveExperimentId = hiveExperimentId;
@@ -293 +295 @@
       progress.ProgressValue = (double)jobCount / totalJobCount;
 
-      if (parentHiveJob != null) {
-        hiveJob.Job.Id = service.AddChildJob(parentHiveJob.Job.Id, hiveJob.Job, jobData);
-      } else {
-        hiveJob.Job.Id = service.AddJob(hiveJob.Job, jobData, groups.ToList());
-      }
+
+      TryAndRepeat(() => {
+        if (parentHiveJob != null) {
+          hiveJob.Job.Id = service.AddChildJob(parentHiveJob.Job.Id, hiveJob.Job, jobData);
+        } else {
+          hiveJob.Job.Id = service.AddJob(hiveJob.Job, jobData, groups.ToList());
+        }
+      }, -1, "Failed to add job");
 
       foreach (HiveJob child in hiveJob.ChildHiveJobs) {
@@ -382 +387 @@
       }
     }
+
+    /// <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>
+    public static void TryAndRepeat(Action action, int repetitions, string errorMessage) {
+      try { action(); }
+      catch (Exception e) {
+        repetitions--;
+        if (repetitions == 0)
+          throw new HiveException(errorMessage, e);
+        TryAndRepeat(action, repetitions, errorMessage);
+      }
+    }
   }
 }