Changeset 2025 for trunk/sources/HeuristicLab.Hive.Client.Core/3.2/Heartbeat.cs

Timestamp:

06/05/09 14:40:53 (15 years ago)

Author:

kgrading

Message:

added calendar behavior in the whole application (#669)

File:

• trunk/sources/HeuristicLab.Hive.Client.Core/3.2/Heartbeat.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.Hive.Client.Core/3.2/Heartbeat.cs

@@ -39 +39 @@
   /// </summary>
   public class Heartbeat {
+
+    private bool offline;
+
     public double Interval { get; set; }    
     private Timer heartbeatTimer = null;
@@ -72 +75 @@
     void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {
       Console.WriteLine("tick");  
-      ClientInfo info = ConfigManager.Instance.GetClientInfo();
-      // Todo: remove tempfix for free cores.
+      ClientInfo info = ConfigManager.Instance.GetClientInfo();      
 
       PerformanceCounter counter = new PerformanceCounter("Memory", "Available Bytes", true);
       int mb = (int)(counter.NextValue() / 1024 / 1024);
-
-      
 
       HeartBeatData heartBeatData = new HeartBeatData {
@@ -84 +84 @@
         FreeCores = info.NrOfCores - ConfigManager.Instance.GetUsedCores(),
         FreeMemory = mb,
-        JobProgress = ConfigManager.Instance.GetProgressOfAllJobs()
+        JobProgress = ConfigManager.Instance.GetProgressOfAllJobs()      
       };
+      
+      DateTime lastFullHour = DateTime.Parse(DateTime.Now.Hour.ToString() + ":00");
+      TimeSpan span = DateTime.Now - lastFullHour;
+      if (span.TotalSeconds < (Interval/1000)) {
+        if (UptimeManager.Instance.isOnline()) {
+          //That's quiet simple: Just reconnect and you're good for new jobs
+          if (wcfService.ConnState != NetworkEnum.WcfConnState.Connected) {
+            Logging.Instance.Info(this.ToString(), "Client goes online according to timetable");
+            wcfService.Connect();
+          }
+        } else {
+          //We have quit a lot of work to do here: snapshot all jobs, submit them back, then disconnect and then pray to god that nothing goes wrong
+          MessageQueue.GetInstance().AddMessage(MessageContainer.MessageType.UptimeLimitDisconnect);                  
+        }        
+      }
       if (wcfService.ConnState == NetworkEnum.WcfConnState.Failed) {
         wcfService.Connect();