Changeset 1170 for trunk

Timestamp:

01/22/09 15:21:02 (16 years ago)

Author:

msteinbi

Message:

Implementing Lifecycle Management (#453)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Contracts/ApplicationConstants.cs (modified) (1 diff)
• HeuristicLab.Hive.Contracts/HiveServerMessages.resx (modified) (1 diff)
• HeuristicLab.Hive.Contracts/Interfaces/IJobManager.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (2 diffs)
• HeuristicLab.Hive.Server.Core/JobManager.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.Hive.Contracts/ApplicationConstants.cs

@@ -81 +81 @@
     public static string RESPONSE_JOB_JOB_REMOVED = "Job.JobRemoved";
     public static string RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE = "Job.JobStateMustBeOffline";
+    public static string RESPONSE_JOB_JOB_RESULT_SENT = "Job.JobResultSent";
   }
 }

trunk/sources/HeuristicLab.Hive.Contracts/HiveServerMessages.resx

@@ -235 +235 @@
     <value>This client is not registered to calculate this job</value>
   </data>
+  <data name="Job.JobResultSent" xml:space="preserve">
+    <value>Job Result sent successfully</value>
+  </data>
 </root>

trunk/sources/HeuristicLab.Hive.Contracts/Interfaces/IJobManager.cs

@@ -39 +39 @@
     [OperationContract]
     Response RemoveJob(long jobId);
+    [OperationContract]
+    ResponseObject<JobResult> GetLasJobResultOf(long jobId);
   }
 }

trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs

@@ -236 +236 @@
         job2Calculate.Client.State = State.calculating;
 
+        job2Calculate.DateCalculated = DateTime.Now;
         response.Job = job2Calculate;
         jobAdapter.Update(job2Calculate);
@@ -317 +318 @@
       jobResult.Percentage = percentage;
       jobResult.Exception = exception;
+      jobResult.DateFinished = DateTime.Now;
 
       jobResultAdapter.Update(jobResult);

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

@@ -49 +49 @@
     }
 
-    public void ResetJobsDependingOnResults(Job job) {
+    private JobResult GetLastJobResult(Job job) {
       List<JobResult> allJobResults = new List<JobResult>(jobResultAdapter.GetResultsOf(job));
       JobResult lastJobResult = null;
       foreach (JobResult jR in allJobResults) {
         // if lastJobResult was before the current jobResult the lastJobResult must be updated
-        if (lastJobResult == null ||          
+        if (lastJobResult == null ||
             (jR.timestamp > lastJobResult.timestamp))
           lastJobResult = jR;
       }
+      return lastJobResult;
+    }
+
+    public void ResetJobsDependingOnResults(Job job) {
+      JobResult lastJobResult = GetLastJobResult(job);
       if (lastJobResult != null) {
         job.Percentage = lastJobResult.Percentage;
@@ -127 +132 @@
         }
 
+        job.DateCreated = DateTime.Now;
         jobAdapter.Update(job);
         response.Success = true;
@@ -160 +166 @@
     }
 
+    public ResponseObject<JobResult> GetLasJobResultOf(long jobId) {
+      ResponseObject<JobResult> response = new ResponseObject<JobResult>();
+      response.Success = true;
+      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_RESULT_SENT;
+      response.Obj = GetLastJobResult(jobAdapter.GetById(jobId));
+
+      return response;
+    }
+
     #endregion
   }