- Timestamp:
- 01/02/12 11:40:31 (13 years ago)
- Location:
- branches/RegressionBenchmarks
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/RegressionBenchmarks
-
branches/RegressionBenchmarks/HeuristicLab.Services.Hive/3.3/Manager/EventManager.cs
r6983 r7255 41 41 get { return LogFactory.GetLogger(this.GetType().Namespace); } 42 42 } 43 private DataAccess.ITransactionManager trans { 44 get { return ServiceLocator.Instance.TransactionManager; } 45 } 43 46 44 public void Cleanup() { 45 log.Log("EventManager.Cleanup()"); 46 SetTimeoutSlavesOffline(); 47 SetTimeoutTasksWaiting(); 48 FinishParentTasks(); 49 UpdateStatistics(); 47 public void Cleanup() { 48 trans.UseTransaction(() => { 49 SetTimeoutSlavesOffline(); 50 SetTimeoutTasksWaiting(); 51 }, true); 52 53 trans.UseTransaction(() => { 54 FinishParentTasks(); 55 UpdateStatistics(); 56 }, false); 50 57 } 51 58 -
branches/RegressionBenchmarks/HeuristicLab.Services.Hive/3.3/Manager/HeartbeatManager.cs
r6983 r7255 44 44 if (slave == null) { 45 45 actions.Add(new MessageContainer(MessageContainer.MessageType.SayHello)); 46 } else { 47 Slave s = dao.GetSlave(heartbeat.SlaveId); 48 if (s != null) { 49 if (heartbeat.HbInterval != s.HbInterval) { 50 actions.Add(new MessageContainer(MessageContainer.MessageType.NewHBInterval)); 51 } 46 } else { 47 if (heartbeat.HbInterval != slave.HbInterval) { 48 actions.Add(new MessageContainer(MessageContainer.MessageType.NewHBInterval)); 52 49 } 53 50 54 51 // update slave data 55 52 slave.FreeCores = heartbeat.FreeCores;
Note: See TracChangeset
for help on using the changeset viewer.