Changeset 4264 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/JobManager.cs
- Timestamp:
- 08/19/10 13:30:56 (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/JobManager.cs
r4263 r4264 58 58 List<JobDto> allJobs = new List<JobDto>(DaoLocator.JobDao.FindAll()); 59 59 foreach (JobDto curJob in allJobs) { 60 if (curJob.State != State.Calculating && curJob.State !=State.Finished) {60 if (curJob.State != JobState.Calculating && curJob.State != JobState.Finished) { 61 61 DaoLocator.JobDao.SetJobOffline(curJob); 62 62 } … … 86 86 } 87 87 88 public ResponseList<JobDto> GetAllJobsWithFilter( State jobState, int offset, int count) {88 public ResponseList<JobDto> GetAllJobsWithFilter(JobState jobState, int offset, int count) { 89 89 ResponseList<JobDto> response = new ResponseList<JobDto>(); 90 90 response.List = new List<JobDto>(DaoLocator.JobDao.FindWithLimitations(jobState, offset, count)); … … 153 153 154 154 if (job != null && job.JobInfo != null) { 155 if (job.JobInfo.State != State.Offline) {155 if (job.JobInfo.State != JobState.Offline) { 156 156 response.StatusMessage = ResponseStatus.AddNewJob_JobStateMustBeOffline; 157 157 return response; … … 222 222 223 223 //if it's a snapshot but the result hasn't reached the server yet... 224 if (snapshot && (job.State == State.RequestSnapshot || job.State == State.RequestSnapshotSent)) {224 if (snapshot && (job.State == JobState.SnapshotRequested || job.State == JobState.SnapshotSent)) { 225 225 response.StatusMessage = ResponseStatus.GetLastSerializedResult_JobResultNotYetThere; 226 226 … … 229 229 230 230 //if it's NOT a snapshot, NEITHER request NOR is it finished 231 if (!requested && !snapshot && job.State != State.Finished) {231 if (!requested && !snapshot && job.State != JobState.Finished) { 232 232 response.StatusMessage = ResponseStatus.GetLastSerializedResult_JobResultNotYetThere; 233 233 … … 248 248 249 249 JobDto job = DaoLocator.JobDao.FindById(jobId); 250 if (job.State == State.RequestSnapshot || job.State == State.RequestSnapshotSent) {250 if (job.State == JobState.SnapshotRequested || job.State == JobState.SnapshotSent) { 251 251 response.StatusMessage = ResponseStatus.RequestSnapshot_SnapshotAlreadyRequested; 252 252 return response; 253 253 } 254 if (job.State != State.Calculating) {254 if (job.State != JobState.Calculating) { 255 255 response.StatusMessage = ResponseStatus.RequestSnapshot_JobIsNotBeeingCalculated; 256 256 return response; 257 257 } 258 258 // job is in correct state 259 job.State = State.RequestSnapshot;259 job.State = JobState.SnapshotRequested; 260 260 DaoLocator.JobDao.Update(job); 261 261 … … 275 275 return response; // no commit needed 276 276 } 277 if (job.State == State.Abort) {277 if (job.State == JobState.Aborted) { 278 278 //response.Success = true; 279 279 response.StatusMessage = ResponseStatus.AbortJob_AbortAlreadyRequested; 280 280 return response; // no commit needed 281 281 } 282 if (job.State != State.Calculating && job.State != State.RequestSnapshot && job.State != State.RequestSnapshotSent) {282 if (job.State != JobState.Calculating && job.State != JobState.SnapshotRequested && job.State != JobState.SnapshotSent) { 283 283 //response.Success = false; 284 284 response.StatusMessage = ResponseStatus.AbortJob_JobIsNotBeeingCalculated; … … 286 286 } 287 287 // job is in correct state 288 job.State = State.Abort;288 job.State = JobState.Aborted; 289 289 DaoLocator.JobDao.Update(job); 290 290
Note: See TracChangeset
for help on using the changeset viewer.