Changeset 1773

Timestamp:

05/08/09 14:29:06 (16 years ago)

Author:

gkronber

Message:

worked on snapshotting functionality of HiveEngine. #545 (Engine which can be executed in the Hive)

File:

• trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs

@@ -125 +125 @@
       IExecutionEngineFacade executionEngineFacade = ServiceLocator.CreateExecutionEngineFacade(HiveServerUrl);
 
-      //Requests the last result.
-      //false: There will always be a result that is been sent back
-      //true: if you hit "requestsnapshot" before - it won't send you the job back if
-      //      the snapshot hasn't been submitted to the server (because the client needs
-      //      more time).
-      var result = executionEngineFacade.GetLastResult(jobId, false);
-      if (result.Success) {
-        JobResult jobResult = result.Obj;
+      // request snapshot
+      executionEngineFacade.RequestSnapshot(jobId);
+
+      // poll until snapshot is ready
+      ResponseObject<JobResult> response;
+      do {
+        response = executionEngineFacade.GetLastResult(jobId, true);
+        if (response.Success && response.StatusMessage == ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE) {
+          Thread.Sleep(1000);
+        }
+      } while (response.Success && response.StatusMessage == ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE);
+
+      if (response.Success) {
+        JobResult jobResult = response.Obj;
         if (jobResult != null) {
           job = (Job)PersistenceManager.RestoreFromGZip(jobResult.Result);
@@ -138 +144 @@
         }
       } else {
-        Exception ex = new Exception(result.Obj.Exception.Message);
+        Exception ex = new Exception(response.Obj.Exception.Message);
         ThreadPool.QueueUserWorkItem(delegate(object state) { OnExceptionOccurred(ex); });
       }