Changeset 1334 for trunk

Timestamp:

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

Author:

msteinbi

Message:

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

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/InternalInterfaces/IScheduler.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Scheduler/DefaultScheduler.cs (modified) (1 diff)

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

@@ -46 +46 @@
       new ReaderWriterLockSlim(LockRecursionPolicy.SupportsRecursion);
 
-    private static Mutex jobLock =
-      new Mutex();
-
     IClientAdapter clientAdapter;
     IJobAdapter jobAdapter;

trunk/sources/HeuristicLab.Hive.Server.Core/InternalInterfaces/IScheduler.cs

@@ -1 @@
-using System;
+#region License Information
+/* HeuristicLab
+ * Copyright (C) 2002-2008 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
+ *
+ * This file is part of HeuristicLab.
+ *
+ * HeuristicLab is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * HeuristicLab is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
+ */
+#endregion
+
+using System;
 using System.Collections.Generic;
 using System.Linq;

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;
     }