Changeset 2025 for trunk/sources/HeuristicLab.Hive.Client.Core/3.2/JobStorage

Timestamp:

06/05/09 14:40:53 (16 years ago)

Author:

kgrading

Message:

added calendar behavior in the whole application (#669)

File:

• trunk/sources/HeuristicLab.Hive.Client.Core/3.2/JobStorage/JobStorageManager.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Hive.Client.Core/3.2/JobStorage/JobStorageManager.cs

@@ -47 +47 @@
           String filename = storedJobsList[index-1].ServerIP + "." + storedJobsList[index-1].ServerPort + "." + storedJobsList[index-1].JobID.ToString();          
           Logging.Instance.Info("JobStorrageManager", "Sending stored job " + storedJobsList[index - 1].JobID + " to the server");
-          byte[] job = File.ReadAllBytes(path + filename + ".dat");
-
-          if (WcfService.Instance.IsJobStillNeeded(storedJobsList[index - 1].JobID).StatusMessage == ApplicationConstants.RESPONSE_COMMUNICATOR_SEND_JOBRESULT) {
-            ResponseResultReceived res = WcfService.Instance.SendStoredJobResultsSync(ConfigManager.Instance.GetClientInfo().Id, storedJobsList[index - 1].JobID, job, 1.00, null, true);
-            if (!res.Success)
-              Logging.Instance.Error("JobStorageManager", "sending of job failed: " + res.StatusMessage);
-            else
-              Logging.Instance.Info("JobStorrageManager", "Sending of job " + storedJobsList[index - 1].JobID + " done");      
+          try {
+            byte[] job = File.ReadAllBytes(path + filename + ".dat");
+            if (WcfService.Instance.IsJobStillNeeded(storedJobsList[index - 1].JobID).StatusMessage == ApplicationConstants.RESPONSE_COMMUNICATOR_SEND_JOBRESULT) {
+              ResponseResultReceived res = WcfService.Instance.SendStoredJobResultsSync(ConfigManager.Instance.GetClientInfo().Id, storedJobsList[index - 1].JobID, job, 1.00, null, true);
+              if (!res.Success)
+                Logging.Instance.Error("JobStorageManager", "sending of job failed: " + res.StatusMessage);
+              else
+                Logging.Instance.Info("JobStorrageManager", "Sending of job " + storedJobsList[index - 1].JobID + " done");
+            }
+            ClientStatusInfo.JobsProcessed++;
+            storedJobsList.Remove(storedJobsList[index - 1]);
+            File.Delete(path + filename + ".dat"); 
           }
-          ClientStatusInfo.JobsProcessed++;
-                  
-          
-
-          storedJobsList.Remove(storedJobsList[index - 1]);
-          File.Delete(path + filename + ".dat");       
+          catch (Exception e) {
+            Logging.Instance.Error("JobStorrageManager", "Job not on hdd but on list - deleting job from list", e);
+            storedJobsList.Remove(storedJobsList[index - 1]);
           }
+      
+         }
         }
     }