Changeset 1088 for trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs

Timestamp:

01/07/09 17:04:39 (15 years ago)

Author:

msteinbi

Message:

Started implementation of Lifecycle Management for CLient Communicator (#453)

File:

• trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (4 diffs)

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

@@ -18 +18 @@
   public class ClientCommunicator: IClientCommunicator {
     int nrOfJobs = 0;
+    Dictionary<Guid, DateTime> lastHeartbeats;
 
     IClientAdapter clientAdapter;
     IJobAdapter jobAdapter;
     IJobResultsAdapter jobResultAdapter;
+    ILifecycleManager lifecycleManager;
 
     public ClientCommunicator() {
@@ -27 +29 @@
       jobAdapter = ServiceLocator.GetJobAdapter();
       jobResultAdapter = ServiceLocator.GetJobResultsAdapter();
+      lifecycleManager = ServiceLocator.GetLifecycleManager();
+
+      lifecycleManager.OnServerHeartbeat += 
+        new EventHandler(lifecycleManager_OnServerHeartbeat);
 
       for (int i = 0; i < nrOfJobs; i++) {
@@ -34 +40 @@
         jobAdapter.Update(job);
       }
+      lastHeartbeats = new Dictionary<Guid, DateTime>();
 
+    }
+
+    void lifecycleManager_OnServerHeartbeat(object sender, EventArgs e) {
+      List<ClientInfo> allClients = new List<ClientInfo>(clientAdapter.GetAll());
+
+      foreach (ClientInfo client in allClients) {
+        
+      }
     }
 
@@ -58 +73 @@
     public ResponseHB SendHeartBeat(HeartBeatData hbData) {
       ResponseHB response = new ResponseHB();
+
+      if (lastHeartbeats.ContainsKey(hbData.ClientId)) {
+        lastHeartbeats[hbData.ClientId] = DateTime.Now;
+      } else {
+        lastHeartbeats.Add(hbData.ClientId, DateTime.Now);
+      }
 
       response.Success = true;