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

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

Implementing Lifecycle Management (#453)

File size: 5.3 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    public void ResetJobsDependingOnResults(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      if (lastJobResult != null) {
61        job.Percentage = lastJobResult.Percentage;
62        job.SerializedJob = lastJobResult.Result;
63      } else {
64        job.Percentage = 0;
65      }
66
67      job.Client = null;
68      job.State = State.offline;
69
70      jobAdapter.Update(job);
71    }
72
73    void checkForDeadJobs() {
74      List<Job> allJobs = new List<Job>(jobAdapter.GetAll());
75      foreach (Job curJob in allJobs) {
76        if (curJob.State == State.calculating) {
77          ResetJobsDependingOnResults(curJob);
78        }
79      }
80    }
81
82    void lifecycleManager_OnStartup(object sender, EventArgs e) {
83      checkForDeadJobs();
84    }
85
86    void lifecycleManager_OnShutdown(object sender, EventArgs e) {
87      checkForDeadJobs();
88    }
89
90    /// <summary>
91    /// returns all jobs stored in the database
92    /// </summary>
93    /// <returns></returns>
94    public ResponseList<Job> GetAllJobs() {
95      ResponseList<Job> response = new ResponseList<Job>();
96
97      response.List = new List<Job>(jobAdapter.GetAll());
98      response.Success = true;
99      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ALL_JOBS;
100     
101      return response;
102    }
103
104    /// <summary>
105    /// Adds a new job into the database
106    /// </summary>
107    /// <param name="job"></param>
108    /// <returns></returns>
109    public ResponseObject<Job> AddNewJob(Job job) {
110      ResponseObject<Job> response = new ResponseObject<Job>();
111
112      if (job != null) {
113        if (job.State != State.offline) {
114          response.Success = false;
115          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE;
116          return response;
117        }
118        if (job.Id != 0) {
119          response.Success = false;
120          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ID_MUST_NOT_BE_SET;
121          return response;
122        }
123        if (job.SerializedJob == null) {
124          response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL;
125          response.Success = false;
126          return response;
127        }
128
129        jobAdapter.Update(job);
130        response.Success = true;
131        response.Obj = job;
132        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_ADDED;
133      } else {
134        response.Success = false;
135        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL;
136      }
137
138      return response;
139    }
140
141    /// <summary>
142    /// Removes a job from the database
143    /// </summary>
144    /// <param name="jobId"></param>
145    /// <returns></returns>
146    public Response RemoveJob(long jobId) {
147      Response response = new Response();
148
149      Job job = jobAdapter.GetById(jobId);
150      if (job == null) {
151        response.Success = false;
152        response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST;
153        return response;
154      }
155      jobAdapter.Delete(job);
156      response.Success = false;
157      response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_REMOVED;
158
159      return response;
160    }
161
162    #endregion
163  }
164}
Note: See TracBrowser for help on using the repository browser.