Changeset 1118 for trunk/sources

Timestamp:

01/14/09 15:32:14 (16 years ago)

Author:

msteinbi

Message:

Implementing Lifecycle Management (#453)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Contracts/ApplicationConstants.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Hive.Contracts/ApplicationConstants.cs

@@ -6 +6 @@
 namespace HeuristicLab.Hive.Contracts {
   public class ApplicationConstants {
+
+    public static int HEARTBEAT_MAX_DIF = 30; // value in seconds
 
     public static string RESPONSE_SERVERCONSOLE_LOGIN_SUCCESS = "Logged in";

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

@@ -59 +59 @@
             DateTime lastHbOfClient = lastHeartbeats[client.ClientId];
             TimeSpan dif = DateTime.Now.Subtract(lastHbOfClient);
-            Console.WriteLine(dif);
+            // check if time between last hearbeat and now is greather than HEARTBEAT_MAX_DIF
+            if (dif.Seconds > ApplicationConstants.HEARTBEAT_MAX_DIF) {
+              // if client calculated jobs, the job must be reset
+              if (client.State == State.calculating) {
+                // check wich job the client was calculating and reset it
+                foreach (Job job in allJobs) {
+                  if (job.Client.ClientId == client.ClientId) {
+                    // TODO check for job results
+                    job.Client = null;
+                    job.Percentage = 0;
+                    job.State = State.idle;
+                  }
+                }
+              }
+              
+              // client must be set offline
+              client.State = State.offline;
+              clientAdapter.Update(client);
+              lastHeartbeats.Remove(client.ClientId);
+            }
           }
         } else {