Changeset 4119 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Core/3.3/Heartbeat.cs

Timestamp:

07/28/10 17:48:10 (14 years ago)

Author:

cneumuel

Message:

HiveExperiment is now able to send IOptimizers of an Experiment and receive the calculated result (#1115)

File:

• branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Core/3.3/Heartbeat.cs (modified) (4 diffs)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Core/3.3/Heartbeat.cs

@@ -43 +43 @@
     private bool offline;
 
-    public double Interval { get; set; }    
+    public double Interval { get; set; }
     private Timer heartbeatTimer = null;
-        
+
+    private static object locker = new object();
+
     public Heartbeat() {
       Interval = 100;
@@ -51 +53 @@
 
     public Heartbeat(double interval) {
-      Interval = interval;      
+      Interval = interval;
     }
 
@@ -74 +76 @@
     /// <param name="sender"></param>
     /// <param name="e"></param>
-    void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {      
-      ClientDto info = ConfigManager.Instance.GetClientInfo();      
+    void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {
+      lock (locker) {
+        // check if cwfService is disconnected for any reason (should happen at first heartbeat)
+        // [chn] TODO: Client should always send heartbeats. when calendar disallows he should tell the server he does not want to compute anything
+        if (wcfService.ConnState == NetworkEnum.WcfConnState.Disconnected &&
+          (!UptimeManager.Instance.CalendarAvailable || UptimeManager.Instance.IsOnline())) {
+          wcfService.Connect();
+        }
 
-      PerformanceCounter counter = new PerformanceCounter("Memory", "Available Bytes", true);
-      int mb = (int)(counter.NextValue() / 1024 / 1024);
+        ClientDto info = ConfigManager.Instance.GetClientInfo();
 
-      HeartBeatData heartBeatData = new HeartBeatData {
-        ClientId = info.Id,
-        FreeCores = info.NrOfCores - ConfigManager.Instance.GetUsedCores(),
-        FreeMemory = mb,
-        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() && UptimeManager.Instance.CalendarAvailable) {
-          //That's quiet simple: Just reconnect and you're good for new jobs
-          if (wcfService.ConnState != NetworkEnum.WcfConnState.Loggedin) {
-            Logger.Info("Client goes online according to timetable");
-            wcfService.Connect();
+        PerformanceCounter counter = new PerformanceCounter("Memory", "Available Bytes", true);
+        int mb = (int)(counter.NextValue() / 1024 / 1024);
+
+        HeartBeatData heartBeatData = new HeartBeatData {
+          ClientId = info.Id,
+          FreeCores = info.NrOfCores - ConfigManager.Instance.GetUsedCores(),
+          FreeMemory = mb,
+          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() && UptimeManager.Instance.CalendarAvailable) {
+            //That's quiet simple: Just reconnect and you're good for new jobs
+            if (wcfService.ConnState != NetworkEnum.WcfConnState.Loggedin) {
+              Logger.Info("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);
           }
-        } 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();
-      } else if (wcfService.ConnState == NetworkEnum.WcfConnState.Loggedin) {
-        Logger.Debug("Sending Heartbeat: " + heartBeatData);        
-        wcfService.ProcessHeartBeatAsync(heartBeatData);
+        }
+        if (wcfService.ConnState == NetworkEnum.WcfConnState.Failed) {
+          wcfService.Connect();
+        } else if (wcfService.ConnState == NetworkEnum.WcfConnState.Loggedin) {
+          Logger.Debug("Sending Heartbeat: " + heartBeatData);
+          wcfService.ProcessHeartBeatAsync(heartBeatData);
+        }
       }
     }
@@ -111 +122 @@
     void wcfService_ProcessHeartBeatCompleted(object sender, ProcessHeartBeatCompletedEventArgs e) {
       Logger.Debug("Heartbeat received");
-      e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));      
+      e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));
     }