Changeset 1272 for trunk/sources/HeuristicLab.Hive.Server.Core

Timestamp:

03/06/09 14:21:11 (15 years ago)

Author:

msteinbi

Message:

Main structure of Sheduler (including Interface and first minimalistic implementation) (#507)

Location:

trunk/sources/HeuristicLab.Hive.Server.Core

Files:

• ClientCommunicator.cs (modified) (4 diffs)
• HeuristicLab.Hive.Server.Core.csproj (modified) (1 diff)
• ServiceLocator.cs (modified) (3 diffs)

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

@@ -54 +54 @@
     ILifecycleManager lifecycleManager;
     IInternalJobManager jobManager;
+    IScheduler scheduler;
 
     /// <summary>
@@ -67 +68 @@
       jobManager = ServiceLocator.GetJobManager() as 
         IInternalJobManager;
+      scheduler = ServiceLocator.GetScheduler();
 
       lifecycleManager.RegisterHeartbeat( 
@@ -187 +189 @@
 
       response.Success = true;
-      response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_HARDBEAT_RECEIVED;
-      List<Job> allOfflineJobs = new List<Job>(jobAdapter.GetJobsByState(State.offline));
-      if (allOfflineJobs.Count > 0 && hbData.freeCores > 0) 
+      response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_HEARTBEAT_RECEIVED;
+      if (hbData.freeCores > 0 && scheduler.ExistsJobForClient(hbData))
         response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.FetchJob));
       else
@@ -225 +226 @@
     public ResponseJob PullJob(Guid clientId) {
       ResponseJob response = new ResponseJob();
-      
-      /// Critical section ///
-      jobLock.WaitOne();
-
-      LinkedList<Job> allOfflineJobs = new LinkedList<Job>(jobAdapter.GetJobsByState(State.offline));
-      if (allOfflineJobs != null && allOfflineJobs.Count > 0) {
-        Job job2Calculate = allOfflineJobs.First.Value;
-        job2Calculate.State = State.calculating;
-        job2Calculate.Client = clientAdapter.GetById(clientId);
-        job2Calculate.Client.State = State.calculating;
-
-        job2Calculate.DateCalculated = DateTime.Now;
+
+      Job job2Calculate = scheduler.GetNextJobForClient(clientId);
+      if (job2Calculate != null) {
         response.Job = job2Calculate;
-        jobAdapter.Update(job2Calculate);
         response.Success = true;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_PULLED;
       } else {
-        response.Success = true;
+        response.Success = false;
+        response.Job = null;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_NO_JOBS_LEFT;
       }
-
-      jobLock.ReleaseMutex();
-      /// End Critical section ///
-
       return response;
     }

trunk/sources/HeuristicLab.Hive.Server.Core/HeuristicLab.Hive.Server.Core.csproj

@@ -83 +83 @@
     <Compile Include="InternalInterfaces\DataAccess\IUserGroupAdapter.cs" />
     <Compile Include="InternalInterfaces\IInternalJobManager.cs" />
+    <Compile Include="InternalInterfaces\IScheduler.cs" />
     <Compile Include="JobManager.cs" />
     <Compile Include="LifecycleManager.cs" />

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

@@ -25 +25 @@
 using HeuristicLab.Hive.Contracts.Interfaces;
 using HeuristicLab.Hive.Server.Core;
+using HeuristicLab.Hive.Server.Core.InternalInterfaces;
 
 /// <summary>
@@ -61 +62 @@
   private static IJobResultsAdapter jobResultsAdapter = null;
 
+  private static IScheduler scheduler = null;
+
 
   /// <summary>
@@ -239 +242 @@
     return jobResultsAdapter;
   }
+
+  /// <summary>
+  /// Gets the scheduler
+  /// </summary>
+  /// <returns></returns>
+  [MethodImpl(MethodImplOptions.Synchronized)]
+  public static IScheduler GetScheduler() {
+    if (scheduler == null) {
+      scheduler = discoveryService.GetInstances<IScheduler>()[0];
+    }
+
+    return scheduler;
+  }
 }