Changeset 4263 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs
- Timestamp:
- 08/19/10 12:41:05 (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs
r4173 r4263 42 42 using System.Collections; 43 43 using System.ServiceModel; 44 using HeuristicLab.Hive.Contracts.ResponseObjects; 44 45 45 46 namespace HeuristicLab.Hive.Experiment { … … 561 562 LogMessage("Polling results for " + jobIdsToQuery.Count() + " jobs"); 562 563 try { 563 ResponseObject<JobResultList> response = executionEngineFacade.Get AllJobResults(jobIdsToQuery);564 if (response.S uccess) {564 ResponseObject<JobResultList> response = executionEngineFacade.GetJobResults(jobIdsToQuery); 565 if (response.StatusMessage == ResponseStatus.Ok) { 565 566 JobResultList jobItemList = response.Obj; 566 567 UpdateJobItems(jobItemList); 567 568 568 569 LogMessage("Polling successfully finished"); 570 } else { 571 throw new Exception(response.StatusMessage.ToString()); 569 572 } 570 573 } catch (Exception e) { … … 603 606 604 607 Response snapShotResponse = executionEngineFacade.RequestSnapshot(jobId); 605 if (snapShotResponse.StatusMessage == ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED) {608 if (snapShotResponse.StatusMessage == ResponseStatus.RequestSnapshot_JobIsNotBeeingCalculated) { 606 609 // job already finished 607 610 Logger.Debug("HiveExperiment: Abort - GetLastResult(false)"); 608 611 response = executionEngineFacade.GetLastSerializedResult(jobId, false, false); 609 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage + " success: " + response.Success);612 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage); 610 613 } else { 611 614 // server sent snapshot request to client … … 615 618 Logger.Debug("HiveExperiment: Abort - GetLastResult(true)"); 616 619 response = executionEngineFacade.GetLastSerializedResult(jobId, false, true); 617 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage + " success: " + response.Success);620 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage); 618 621 retryCount++; 619 622 // loop while … … 622 625 } while ( 623 626 (retryCount < maxSnapshotRetries) && ( 624 !response.Success || 625 response.StatusMessage == ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE) 627 response.StatusMessage == ResponseStatus.GetLastSerializedResult_JobResultNotYetThere) 626 628 ); 627 629 } 628 if (response.S uccess) {630 if (response.StatusMessage == ResponseStatus.Ok) { 629 631 LogMessage(jobId, "Snapshot polling successfull for job " + jobId); 630 632 UpdateSnapshot(response);
Note: See TracChangeset
for help on using the changeset viewer.