Changeset 3578 for trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs
- Timestamp:
- 05/01/10 13:58:24 (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs
r3220 r3578 135 135 Thread.Sleep(RESULT_POLLING_INTERVAL_MS); 136 136 lock (locker) { 137 HiveLogger.Debug("HiveEngine: Results-polling - GetLastResult");137 Logger.Debug("HiveEngine: Results-polling - GetLastResult"); 138 138 response = executionEngineFacade.GetLastSerializedResult(jobId, false); 139 HiveLogger.Debug("HiveEngine: Results-polling - Server: " + response.StatusMessage + " success: " + response.Success);139 Logger.Debug("HiveEngine: Results-polling - Server: " + response.StatusMessage + " success: " + response.Success); 140 140 // loop while 141 141 // 1. the user doesn't request an abort … … 145 145 if (abortRequested) return; 146 146 if (response.Success && response.Obj != null) { 147 HiveLogger.Debug("HiveEngine: Results-polling - Got result!");147 Logger.Debug("HiveEngine: Results-polling - Got result!"); 148 148 restoredJob = (Job)PersistenceManager.RestoreFromGZip(response.Obj.SerializedJobData); 149 HiveLogger.Debug("HiveEngine: Results-polling - IsSnapshotResult: " + (restoredJob.Progress<1.0));149 Logger.Debug("HiveEngine: Results-polling - IsSnapshotResult: " + (restoredJob.Progress < 1.0)); 150 150 } 151 151 } … … 157 157 OnFinished(); 158 158 }); 159 HiveLogger.Debug("HiveEngine: Starting results-polling thread");159 Logger.Debug("HiveEngine: Starting results-polling thread"); 160 160 t.Start(); 161 161 } … … 166 166 ResponseObject<SerializedJob> response; 167 167 lock (locker) { 168 HiveLogger.Debug("HiveEngine: Abort - RequestSnapshot");168 Logger.Debug("HiveEngine: Abort - RequestSnapshot"); 169 169 Response snapShotResponse = executionEngineFacade.RequestSnapshot(jobId); 170 170 if (snapShotResponse.StatusMessage == ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED) { 171 171 // job is finished already 172 HiveLogger.Debug("HiveEngine: Abort - GetLastResult(false)");172 Logger.Debug("HiveEngine: Abort - GetLastResult(false)"); 173 173 response = executionEngineFacade.GetLastSerializedResult(jobId, false); 174 HiveLogger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);174 Logger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success); 175 175 } else { 176 176 // server sent snapshot request to client … … 178 178 do { 179 179 Thread.Sleep(SNAPSHOT_POLLING_INTERVAL_MS); 180 HiveLogger.Debug("HiveEngine: Abort - GetLastResult(true)");180 Logger.Debug("HiveEngine: Abort - GetLastResult(true)"); 181 181 response = executionEngineFacade.GetLastSerializedResult(jobId, true); 182 HiveLogger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);182 Logger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success); 183 183 retryCount++; 184 184 // loop while … … 194 194 SerializedJob jobResult = response.Obj; 195 195 if (jobResult != null) { 196 HiveLogger.Debug("HiveEngine: Results-polling - Got result!");196 Logger.Debug("HiveEngine: Results-polling - Got result!"); 197 197 job = (Job)PersistenceManager.RestoreFromGZip(jobResult.SerializedJobData); 198 198 ControlManager.Manager.ShowControl(job.Engine.CreateView());
Note: See TracChangeset
for help on using the changeset viewer.