- Timestamp:
- 08/17/15 15:14:04 (9 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/HiveStatistics/sources/HeuristicLab.Services.Hive/3.3/Manager/EventManager.cs
r12861 r12866 34 34 public void Cleanup() { 35 35 var pm = PersistenceManager; 36 // same transactions as the old EventManager37 36 pm.UseTransaction(() => { 38 37 SetTimeoutSlavesOffline(pm); … … 57 56 if (!slave.LastHeartbeat.HasValue || 58 57 (DateTime.Now - slave.LastHeartbeat.Value) > 59 HeuristicLab.Services.Hive.Properties.Settings.Default.SlaveHeartbeatTimeout) {58 Properties.Settings.Default.SlaveHeartbeatTimeout) { 60 59 slave.SlaveState = SlaveState.Offline; 61 60 } … … 88 87 private void SetTimeoutTasksWaiting(IPersistenceManager pm) { 89 88 var taskDao = pm.TaskDao; 90 var tasks = taskDao.GetAll().Where(x => (x.State == TaskState.Calculating && (DateTime.Now - x.LastHeartbeat) > HeuristicLab.Services.Hive.Properties.Settings.Default.CalculatingJobHeartbeatTimeout)91 || (x.State == TaskState.Transferring && (DateTime.Now - x.LastHeartbeat) > HeuristicLab.Services.Hive.Properties.Settings.Default.TransferringJobHeartbeatTimeout));89 var tasks = taskDao.GetAll().Where(x => (x.State == TaskState.Calculating && (DateTime.Now - x.LastHeartbeat) > Properties.Settings.Default.CalculatingJobHeartbeatTimeout) 90 || (x.State == TaskState.Transferring && (DateTime.Now - x.LastHeartbeat) > Properties.Settings.Default.TransferringJobHeartbeatTimeout)); 92 91 foreach (var task in tasks) { 93 92 task.State = TaskState.Waiting; … … 112 111 .Where(x => x.IsDisposable.GetValueOrDefault() 113 112 && x.SlaveState == SlaveState.Offline 114 && (DateTime.Now - x.LastHeartbeat) > Hive.Properties.Settings.Default.SweepInterval)113 && (DateTime.Now - x.LastHeartbeat) > Properties.Settings.Default.SweepInterval) 115 114 .Select(x => x.ResourceId) 116 115 .ToList();
Note: See TracChangeset
for help on using the changeset viewer.