source: trunk/sources/HeuristicLab.Hive.Server.Core/JobManager.cs @ 1170

Last change on this file since 1170 was 1170, checked in by msteinbi, 12 years ago

Implementing Lifecycle Management (#453)

File size: 5.8 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2008 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using System;
23using System.Collections.Generic;
24using System.Linq;
25using System.Text;
26using HeuristicLab.Hive.Contracts.Interfaces;
27using HeuristicLab.Hive.Contracts.BusinessObjects;
28using HeuristicLab.Hive.Contracts;
29using HeuristicLab.Hive.Server.Core.InternalInterfaces.DataAccess;
30using HeuristicLab.Hive.Server.Core.InternalInterfaces;
31
32namespace HeuristicLab.Hive.Server.Core {
33  class JobManager: IJobManager, IInternalJobManager {
34
35    IJobAdapter jobAdapter;
36    IJobResultsAdapter jobResultAdapter;
37    ILifecycleManager lifecycleManager;
38
39    #region IJobManager Members
40
41    public JobManager() {
42      jobAdapter = ServiceLocator.GetJobAdapter();
43      jobResultAdapter = ServiceLocator.GetJobResultsAdapter();
44
45      lifecycleManager = ServiceLocator.GetLifecycleManager();
46
47      lifecycleManager.RegisterStartup(new EventHandler(lifecycleManager_OnStartup));
48      lifecycleManager.RegisterStartup(new EventHandler(lifecycleManager_OnShutdown));
49    }
50
51    private JobResult GetLastJobResult(Job job) {
52      List<JobResult> allJobResults = new List<JobResult>(jobResultAdapter.GetResultsOf(job));
53      JobResult lastJobResult = null;
54      foreach (JobResult jR in allJobResults) {
55        // if lastJobResult was before the current jobResult the lastJobResult must be updated
56        if (lastJobResult == null ||
57            (jR.timestamp > lastJobResult.timestamp))
58          lastJobResult = jR;
59      }
60      return lastJobResult;
61    }
62
63    public void ResetJobsDependingOnResults(Job job) {
64      JobResult lastJobResult = GetLastJobResult(job);
65      if (lastJobResult != null) {
66        job.Percentage = lastJobResult.Percentage;
67        job.SerializedJob = lastJobResult.Result;
68      } else {
69        job.Percentage = 0;
70      }
71
72      job.Client = null;
73      job.State = State.offline;
74
75      jobAdapter.Update(job);
76    }
77
78    void checkForDeadJobs() {
79      List<Job> allJobs = new List<Job>(jobAdapter.GetAll());
80      foreach (Job curJob in allJobs) {
81        if (curJob.State == State.calculating) {
82          ResetJobsDependingOnResults(curJob);
83        }
84      }
85    }
86
87    void lifecycleManager_OnStartup(object sender, EventArgs e) {
88      checkForDeadJobs();
89    }
90
91    void lifecycleManager_OnShutdown(object sender, EventArgs e) {
92      checkForDeadJobs();
93    }
94
95    /// <summary>
96    /// returns all jobs stored in the database
97    /// </summary>
98    /// <returns></returns>
99    public ResponseList<Job> GetAllJobs() {
100      ResponseList<Job> response = new ResponseList<Job>();
101
102      response.List = new List<Job>(jobAdapter.GetAll());
103      response.Success = true;
104      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ALL_JOBS;
105     
106      return response;
107    }
108
109    /// <summary>
110    /// Adds a new job into the database
111    /// </summary>
112    /// <param name="job"></param>
113    /// <returns></returns>
114    public ResponseObject<Job> AddNewJob(Job job) {
115      ResponseObject<Job> response = new ResponseObject<Job>();
116
117      if (job != null) {
118        if (job.State != State.offline) {
119          response.Success = false;
120          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE;
121          return response;
122        }
123        if (job.Id != 0) {
124          response.Success = false;
125          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ID_MUST_NOT_BE_SET;
126          return response;
127        }
128        if (job.SerializedJob == null) {
129          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL;
130          response.Success = false;
131          return response;
132        }
133
134        job.DateCreated = DateTime.Now;
135        jobAdapter.Update(job);
136        response.Success = true;
137        response.Obj = job;
138        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_ADDED;
139      } else {
140        response.Success = false;
141        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL;
142      }
143
144      return response;
145    }
146
147    /// <summary>
148    /// Removes a job from the database
149    /// </summary>
150    /// <param name="jobId"></param>
151    /// <returns></returns>
152    public Response RemoveJob(long jobId) {
153      Response response = new Response();
154
155      Job job = jobAdapter.GetById(jobId);
156      if (job == null) {
157        response.Success = false;
158        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST;
159        return response;
160      }
161      jobAdapter.Delete(job);
162      response.Success = false;
163      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_REMOVED;
164
165      return response;
166    }
167
168    public ResponseObject<JobResult> GetLasJobResultOf(long jobId) {
169      ResponseObject<JobResult> response = new ResponseObject<JobResult>();
170      response.Success = true;
171      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_RESULT_SENT;
172      response.Obj = GetLastJobResult(jobAdapter.GetById(jobId));
173
174      return response;
175    }
176
177    #endregion
178  }
179}
Note: See TracBrowser for help on using the repository browser.