Changeset 1334 for trunk/sources/HeuristicLab.Hive.Server.Scheduler

Timestamp:

03/12/09 14:39:22 (16 years ago)

Author:

msteinbi

Message:

Merging defaultscheduler and ischeduler (dummy check in) with correct version (#507)

File:

• trunk/sources/HeuristicLab.Hive.Server.Scheduler/DefaultScheduler.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Hive.Server.Scheduler/DefaultScheduler.cs

@@ -4 +4 @@
 using System.Text;
 using HeuristicLab.Hive.Server.Core.InternalInterfaces;
+using HeuristicLab.Hive.Contracts.BusinessObjects;
+using HeuristicLab.Hive.Server.Core.InternalInterfaces.DataAccess;
+using System.Threading;
 
 namespace HeuristicLab.Hive.Server.Scheduler {
-  class DefaultScheduler : IScheduler {
+  class DefaultScheduler: IScheduler {
+
+    IJobAdapter jobAdapter;
+    IClientAdapter clientAdapter;
+
+    private static Mutex jobLock =
+      new Mutex();
+
     #region IScheduler Members
 
+    public DefaultScheduler() {
+      jobAdapter = ServiceLocator.GetJobAdapter();
+      clientAdapter = ServiceLocator.GetClientAdapter();
+    }
+
     public bool ExistsJobForClient(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData) {
-      throw new NotImplementedException();
+      List<Job> allOfflineJobs = new List<Job>(jobAdapter.GetJobsByState(State.offline));
+      return (allOfflineJobs.Count > 0);
     }
 
     public HeuristicLab.Hive.Contracts.BusinessObjects.Job GetNextJobForClient(Guid clientId) {
-      throw new NotImplementedException();
+
+      /// Critical section ///
+      jobLock.WaitOne();
+
+      LinkedList<Job> allOfflineJobs = new LinkedList<Job>(jobAdapter.GetJobsByState(State.offline));
+
+      Job job2Calculate = null;
+      if (allOfflineJobs != null && allOfflineJobs.Count > 0) {
+        job2Calculate = allOfflineJobs.First.Value;
+        job2Calculate.State = State.calculating;
+        job2Calculate.Client = clientAdapter.GetById(clientId);
+        job2Calculate.Client.State = State.calculating;
+
+        job2Calculate.DateCalculated = DateTime.Now;
+        jobAdapter.Update(job2Calculate);
+      }
+      jobLock.ReleaseMutex();
+      /// End Critical section ///
+
+      return job2Calculate;
     }