Changeset 2099 for trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs

Timestamp:

06/25/09 13:54:15 (15 years ago)

Author:

svonolfe

Message:

Further avoided out of memory exceptions by updating the JobResult DAO (#372)

File:

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

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

@@ -100 +100 @@
       Thread t = new Thread(() => {
         IExecutionEngineFacade executionEngineFacade = ServiceLocator.CreateExecutionEngineFacade(HiveServerUrl);
-        ResponseObject<JobResult> response = null;
+        ResponseObject<SerializedJobResult> response = null;
         Job restoredJob = null;
         do {
@@ -106 +106 @@
           lock (locker) {
             HiveLogger.Debug("HiveEngine: Results-polling - GetLastResult");
-            response = executionEngineFacade.GetLastResult(jobId, false);
+            response = executionEngineFacade.GetLastSerializedResult(jobId, false);
             HiveLogger.Debug("HiveEngine: Results-polling - Server: " + response.StatusMessage + " success: " + response.Success);
             // loop while 
@@ -116 +116 @@
             if (response.Success && response.Obj != null) {
               HiveLogger.Debug("HiveEngine: Results-polling - Got result!");
-              restoredJob = (Job)PersistenceManager.RestoreFromGZip(response.Obj.Result);
+              restoredJob = (Job)PersistenceManager.RestoreFromGZip(response.Obj.SerializedJobResultData);
               HiveLogger.Debug("HiveEngine: Results-polling - IsSnapshotResult: " + restoredJob.Engine.Canceled);
             }
@@ -133 +133 @@
       IExecutionEngineFacade executionEngineFacade = ServiceLocator.CreateExecutionEngineFacade(HiveServerUrl);
 
-      ResponseObject<JobResult> response;
+      ResponseObject<SerializedJobResult> response;
       lock (locker) {
         HiveLogger.Debug("HiveEngine: Abort - RequestSnapshot");
@@ -140 +140 @@
           // job is finished already
           HiveLogger.Debug("HiveEngine: Abort - GetLastResult(false)");
-          response = executionEngineFacade.GetLastResult(jobId, false);
+          response = executionEngineFacade.GetLastSerializedResult(jobId, false);
           HiveLogger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);
         } else {
@@ -148 +148 @@
             Thread.Sleep(SNAPSHOT_POLLING_INTERVAL_MS);
             HiveLogger.Debug("HiveEngine: Abort - GetLastResult(true)");
-            response = executionEngineFacade.GetLastResult(jobId, true);
+            response = executionEngineFacade.GetLastSerializedResult(jobId, true);
             HiveLogger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);
             // loop while
@@ -158 +158 @@
         }
       }
-      JobResult jobResult = response.Obj;
+      SerializedJobResult jobResult = response.Obj;
       if (jobResult != null) {
         HiveLogger.Debug("HiveEngine: Results-polling - Got result!");
-        job = (Job)PersistenceManager.RestoreFromGZip(jobResult.Result);
+        job = (Job)PersistenceManager.RestoreFromGZip(jobResult.SerializedJobResultData);
         //PluginManager.ControlManager.ShowControl(job.Engine.CreateView());
       }