- Timestamp:
- 03/16/11 17:02:15 (13 years ago)
- Location:
- branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/HeartbeatManager.cs
r5636 r5718 4 4 using HeuristicLab.Services.Hive.Common; 5 5 using HeuristicLab.Services.Hive.Common.DataTransfer; 6 using HeuristicLab.Tracing;7 6 8 7 namespace HeuristicLab.Services.Hive { … … 73 72 // job does not exist in db 74 73 actions.Add(new MessageContainer(MessageContainer.MessageType.AbortJob, jobProgress.Key)); 75 Log ger.Error("Job does not exist in DB: " + jobProgress.Key);74 LogFactory.GetLogger(this.GetType().Namespace).Log("Job does not exist in DB: " + jobProgress.Key); 76 75 } else { 77 76 if (curJob.CurrentStateLog.SlaveId == Guid.Empty || curJob.CurrentStateLog.SlaveId != heartbeat.SlaveId) { 78 77 // assigned slave does not match heartbeat 79 78 actions.Add(new MessageContainer(MessageContainer.MessageType.AbortJob, curJob.Id)); 80 Log ger.Error("The slave " + heartbeat.SlaveId + " is not supposed to calculate Job: " + curJob);79 LogFactory.GetLogger(this.GetType().Namespace).Log("The slave " + heartbeat.SlaveId + " is not supposed to calculate Job: " + curJob); 81 80 } else { 82 81 // save job execution time -
branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/HeuristicLab.Services.Hive-3.4.csproj
r5711 r5718 91 91 <HintPath>..\..\..\..\..\..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.PluginInfrastructure-3.3.dll</HintPath> 92 92 </Reference> 93 <Reference Include="HeuristicLab.Tracing-3.3, Version=3.3.0.0, Culture=neutral, PublicKeyToken=ba48961d6f65dcec, processorArchitecture=MSIL">94 <SpecificVersion>False</SpecificVersion>95 <HintPath>..\..\..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Tracing-3.3.dll</HintPath>96 </Reference>97 93 <Reference Include="System" /> 98 94 <Reference Include="System.Core" /> -
branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/LifecycleManager.cs
r5636 r5718 55 55 var jobs = dao.GetJobs(x => x.State == JobState.Calculating).Where(x => x.StateLog.Last().SlaveId == slaveId); 56 56 foreach (var j in jobs) { 57 j.StateLog.Add(new StateLog() { 58 State = JobState.Waiting, 59 JobId = j.Id, 60 DateTime = DateTime.Now, 61 Exception = "Slave timed out" 62 }); 63 dao.UpdateJob(j); 57 dao.UpdateJobState(j.Id, JobState.Waiting, slaveId, null, "Slave timed out"); 64 58 } 65 59 }
Note: See TracChangeset
for help on using the changeset viewer.