Changeset 7187 for trunk/sources/HeuristicLab.Services.Hive/3.3/Manager

Timestamp:

12/14/11 01:09:54 (13 years ago)

Author:

ascheibe

Message:

#1672

• increased times between life cycles on the server
• some smaller performance improvements on the server

Location:

trunk/sources/HeuristicLab.Services.Hive/3.3/Manager

Files:

• EventManager.cs (modified) (1 diff)
• HeartbeatManager.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Services.Hive/3.3/Manager/EventManager.cs

@@ -41 +41 @@
       get { return LogFactory.GetLogger(this.GetType().Namespace); }
     }
+    private DataAccess.ITransactionManager trans {
+      get { return ServiceLocator.Instance.TransactionManager; }
+    }
 
-    public void Cleanup() {
-      SetTimeoutSlavesOffline();
-      SetTimeoutTasksWaiting();
-      FinishParentTasks();
-      UpdateStatistics();
+    public void Cleanup() { 
+      trans.UseTransaction(() => {
+        SetTimeoutSlavesOffline();
+        SetTimeoutTasksWaiting();
+      }, true);
+
+      trans.UseTransaction(() => {
+        FinishParentTasks();
+        UpdateStatistics();
+      }, false);
     }
 

trunk/sources/HeuristicLab.Services.Hive/3.3/Manager/HeartbeatManager.cs

@@ -44 +44 @@
       if (slave == null) {
         actions.Add(new MessageContainer(MessageContainer.MessageType.SayHello));
-      } else {
-        Slave s = dao.GetSlave(heartbeat.SlaveId);
-        if (s != null) {
-          if (heartbeat.HbInterval != s.HbInterval) {
-            actions.Add(new MessageContainer(MessageContainer.MessageType.NewHBInterval));
-          }
+      } else {        
+        if (heartbeat.HbInterval != slave.HbInterval) {
+          actions.Add(new MessageContainer(MessageContainer.MessageType.NewHBInterval));
         }
-
+        
         // update slave data
         slave.FreeCores = heartbeat.FreeCores;