- Timestamp:
- 09/25/15 14:39:59 (9 years ago)
- Location:
- branches/gteufl
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/gteufl
- Property svn:ignore
-
old new 8 8 FxCopResults.txt 9 9 Google.ProtocolBuffers-0.9.1.dll 10 Google.ProtocolBuffers-2.4.1.473.dll 10 11 HeuristicLab 3.3.5.1.ReSharper.user 11 12 HeuristicLab 3.3.6.0.ReSharper.user 12 13 HeuristicLab.4.5.resharper.user 13 14 HeuristicLab.ExtLibs.6.0.ReSharper.user 15 HeuristicLab.Scripting.Development 14 16 HeuristicLab.resharper.user 15 17 ProtoGen.exe … … 17 19 _ReSharper.HeuristicLab 18 20 _ReSharper.HeuristicLab 3.3 21 _ReSharper.HeuristicLab 3.3 Tests 19 22 _ReSharper.HeuristicLab.ExtLibs 20 23 bin 21 24 protoc.exe 22 _ReSharper.HeuristicLab 3.3 Tests 23 Google.ProtocolBuffers-2.4.1.473.dll 25 obj
-
- Property svn:mergeinfo changed
-
Property
svn:global-ignores
set to
*.nuget
packages
- Property svn:ignore
-
branches/gteufl/HeuristicLab.Clients.Hive.Slave/3.3/Core.cs
r9456 r12969 1 1 #region License Information 2 2 /* HeuristicLab 3 * Copyright (C) 2002-201 3Heuristic and Evolutionary Algorithms Laboratory (HEAL)3 * Copyright (C) 2002-2015 Heuristic and Evolutionary Algorithms Laboratory (HEAL) 4 4 * 5 5 * This file is part of HeuristicLab. … … 204 204 TS.Task.Factory.StartNew(HandleCalculateTask, jobId) 205 205 .ContinueWith((t) => { 206 SlaveStatusInfo.Increment ExceptionOccured();206 SlaveStatusInfo.IncrementTasksFailed(); 207 207 SlaveClientCom.Instance.LogMessage(t.Exception.ToString()); 208 208 }, TaskContinuationOptions.OnlyOnFaulted); … … 212 212 TS.Task.Factory.StartNew(HandleStopTask, jobId) 213 213 .ContinueWith((t) => { 214 SlaveStatusInfo.Increment ExceptionOccured();214 SlaveStatusInfo.IncrementTasksFailed(); 215 215 SlaveClientCom.Instance.LogMessage(t.Exception.ToString()); 216 216 }, TaskContinuationOptions.OnlyOnFaulted); … … 220 220 TS.Task.Factory.StartNew(HandlePauseTask, jobId) 221 221 .ContinueWith((t) => { 222 SlaveStatusInfo.Increment ExceptionOccured();222 SlaveStatusInfo.IncrementTasksFailed(); 223 223 SlaveClientCom.Instance.LogMessage(t.Exception.ToString()); 224 224 }, TaskContinuationOptions.OnlyOnFaulted); … … 228 228 TS.Task.Factory.StartNew(HandleAbortTask, jobId) 229 229 .ContinueWith((t) => { 230 SlaveStatusInfo.Increment ExceptionOccured();230 SlaveStatusInfo.IncrementTasksFailed(); 231 231 SlaveClientCom.Instance.LogMessage(t.Exception.ToString()); 232 232 }, TaskContinuationOptions.OnlyOnFaulted); … … 271 271 catch (Exception e) { 272 272 SlaveStatusInfo.DecrementUsedCores(usedCores); 273 wcfService.UpdateJobState(taskId, TaskState. Waiting, e.ToString()); // unknown internal error - report and set waiting again273 wcfService.UpdateJobState(taskId, TaskState.Failed, e.ToString()); 274 274 throw; 275 275 } … … 328 328 this.taskManager.TaskStopped += new EventHandler<EventArgs<SlaveTask, TaskData>>(taskManager_TaskStopped); 329 329 this.taskManager.TaskFailed += new EventHandler<EventArgs<Tuple<SlaveTask, TaskData, Exception>>>(taskManager_TaskFailed); 330 this.taskManager.ExceptionOccured += new EventHandler<EventArgs<SlaveTask, Exception>>(taskManager_ExceptionOccured);331 330 this.taskManager.TaskAborted += new EventHandler<EventArgs<SlaveTask>>(taskManager_TaskAborted); 332 331 } … … 391 390 } 392 391 catch (TaskNotFoundException ex) { 393 SlaveStatusInfo.Increment ExceptionOccured();392 SlaveStatusInfo.IncrementTasksFailed(); 394 393 SlaveClientCom.Instance.LogMessage(ex.ToString()); 395 394 } 396 395 catch (Exception ex) { 397 SlaveStatusInfo.Increment ExceptionOccured();396 SlaveStatusInfo.IncrementTasksFailed(); 398 397 SlaveClientCom.Instance.LogMessage(ex.ToString()); 399 398 } 400 }401 402 private void taskManager_ExceptionOccured(object sender, EventArgs<SlaveTask, Exception> e) {403 SlaveStatusInfo.DecrementUsedCores(e.Value.CoresNeeded);404 SlaveStatusInfo.IncrementExceptionOccured();405 heartbeatManager.AwakeHeartBeatThread();406 SlaveClientCom.Instance.LogMessage(string.Format("Exception occured for task {0}: {1}", e.Value.TaskId, e.Value2.ToString()));407 wcfService.UpdateJobState(e.Value.TaskId, TaskState.Waiting, e.Value2.ToString());408 399 } 409 400 … … 490 481 SlaveClientCom.Instance.LogMessage("Stopping heartbeat"); 491 482 heartbeatManager.StopHeartBeat(); 483 SlaveClientCom.Instance.LogMessage("Stopping checkpointing"); 484 taskManager.StopCheckpointing(); 485 492 486 abortRequested = true; 493 487
Note: See TracChangeset
for help on using the changeset viewer.