Changeset 1577 for trunk/sources/HeuristicLab.Hive.Server.Core/3.2/JobManager.cs

Timestamp:

04/16/09 17:33:09 (15 years ago)

Author:

msteinbi

Message:

added request and abort snapshot (#572)

File:

• trunk/sources/HeuristicLab.Hive.Server.Core/3.2/JobManager.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Server.Core/3.2/JobManager.cs

@@ -254 +254 @@
       
       try {
-        
+        IJobAdapter jobAdapter = session.GetDataAdapter<Job, IJobAdapter>();
+
+        Job job = jobAdapter.GetById(jobId);
+        if (job.State == State.requestSnapshot) {
+          response.Success = true;
+          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_REQUEST_ALLREADY_SET;
+          return response; // no commit needed
+        }
+        if (job.State != State.calculating) {
+          response.Success = false;
+          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED;
+          return response; // no commit needed
+        }
+        // job is in correct state
+        job.State = State.requestSnapshot;
+        jobAdapter.Update(job);
+
+        response.Success = true;
+        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_REQUEST_SET;
 
         return response;
@@ -265 +283 @@
 
     public Response AbortJob(Guid jobId) {
-      throw new NotImplementedException();
+      ISession session = factory.GetSessionForCurrentThread();
+      Response response = new Response();
+
+      try {
+        IJobAdapter jobAdapter = session.GetDataAdapter<Job, IJobAdapter>();
+
+        Job job = jobAdapter.GetById(jobId);
+        if (job.State == State.abort) {
+          response.Success = true;
+          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ABORT_REQUEST_ALLREADY_SET;
+          return response; // no commit needed
+        }
+        if (job.State != State.calculating) {
+          response.Success = false;
+          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED;
+          return response; // no commit needed
+        }
+        // job is in correct state
+        job.State = State.abort;
+        jobAdapter.Update(job);
+
+        response.Success = true;
+        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ABORT_REQUEST_SET;
+
+        return response;
+      }
+      finally {
+        if (session != null)
+          session.EndSession();
+      }
     }