Changeset 9202 for branches/UnloadJobs/HeuristicLab.Clients.Hive/3.3/ConcurrentTaskDownloader.cs

Timestamp:

02/03/13 16:17:44 (11 years ago)

Author:

ascheibe

Message:

#2005

• add repeating of failed tasks and task datas
• added an additional ws method that loads lightweight tasks without the statelogs

File:

• branches/UnloadJobs/HeuristicLab.Clients.Hive/3.3/ConcurrentTaskDownloader.cs (modified) (2 diffs)

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

@@ -68 +68 @@
 
     private Task DownloadTask(object taskId) {
-      return HiveServiceLocator.Instance.CallHiveService(s => s.GetTask((Guid)taskId));
+      Task t = null;
+      HiveClient.TryAndRepeat(() => {
+        t = HiveServiceLocator.Instance.CallHiveService(s => s.GetTask((Guid)taskId));
+      }, Settings.Default.MaxRepeatServiceCalls, "Failed to download task.");
+      return t;
     }
 
@@ -77 +81 @@
     protected Tuple<Task, TaskData> DownloadTaskData(Task task) {
       downloadSemaphore.WaitOne();
-      TaskData result;
+      TaskData result = null;
       try {
         if (abort) return null;
-        result = HiveServiceLocator.Instance.CallHiveService(s => s.GetTaskData(task.Id));
+        HiveClient.TryAndRepeat(() => {
+          result = HiveServiceLocator.Instance.CallHiveService(s => s.GetTaskData(task.Id));
+        }, Settings.Default.MaxRepeatServiceCalls, "Failed to download task data.");
       }
       finally {