Changeset 5721 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4/HeartbeatManager.cs

Timestamp:

03/16/11 18:05:56 (13 years ago)

Author:

ascheibe

Message:

#1233 worked on slave and slave service installer

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4/HeartbeatManager.cs (modified) (6 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4/HeartbeatManager.cs

@@ -34 +34 @@
     private Thread heartBeatThread;
     private AutoResetEvent waitHandle;
+    private WcfService wcfService;
+    private bool threadStopped;
+    ReaderWriterLockSlim heartBeatThreadIsSleepingLock = new ReaderWriterLockSlim();
 
     public HeartbeatManager() {
@@ -42 +45 @@
       Interval = interval;
     }
-
-    private WcfService wcfService;
-
-    private bool threadStopped;
-
-    ReaderWriterLockSlim heartBeatThreadIsSleepingLock = new ReaderWriterLockSlim();
 
     /// <summary>
@@ -78 +75 @@
 
     private void RunHeartBeatThread() {
+      bool sleepForever;
       while (!threadStopped) {
+        sleepForever = false;
         try {
           lock (locker) {
@@ -88 +87 @@
 
               Heartbeat heartBeatData = new Heartbeat {
-                SlaveId = info.Id, /*Settings.Default.Guid*/
+                SlaveId = info.Id,
                 FreeCores = info.Cores.HasValue ? info.Cores.Value - ConfigManager.Instance.GetUsedCores() : 0,
                 FreeMemory = ConfigManager.GetFreeMemory(),
@@ -102 +101 @@
                 OnExceptionOccured(new Exception("Error getting response from Heartbeat"));
               } else {
-                SlaveClientCom.Instance.ClientCom.LogMessage("Heartbeat Response received: ");
+                SlaveClientCom.Instance.ClientCom.LogMessage("Heartbeat Response received (" + msgs.Count + "): ");
                 msgs.ForEach(mc => SlaveClientCom.Instance.ClientCom.LogMessage(mc.Message.ToString()));
                 msgs.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));
+                //after fetching a job, we sleep until the core wakes us up!!
+                msgs.ForEach(s => { if (s.Message == MessageContainer.MessageType.CalculateJob) sleepForever = true; });
               }
             }
@@ -113 +114 @@
           OnExceptionOccured(e);
         }
-        waitHandle.WaitOne(this.Interval);
+        if (sleepForever)
+          waitHandle.WaitOne();
+        else
+          waitHandle.WaitOne(this.Interval);
       }
       waitHandle.Close();