Changeset 5778 for branches/HeuristicLab.Hive-3.4/sources

Timestamp:

03/21/11 14:16:01 (14 years ago)

Author:

ascheibe

Message:

#1233

• log uncaught exceptions to an eventlog if available
• fixed job pause bug

Location:

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4

Files:

• Core.cs (modified) (5 diffs)
• Executor.cs (modified) (1 diff)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4/Core.cs

@@ -22 +22 @@
 using System;
 using System.Collections.Generic;
+using System.Diagnostics;
 using System.IO;
 using System.Runtime.CompilerServices;
@@ -42 +43 @@
     public static Core TheCore;
 
+    public EventLog ServiceEventLog { get; set; }
+
     public static bool abortRequested { get; set; }
     private Semaphore waitShutdownSem = new Semaphore(0, 1);
@@ -76 +79 @@
       abortRequested = false;
 
-      //start the client communication service (pipe between slave and slave gui)
-      slaveComm = new ServiceHost(typeof(SlaveCommunicationService));
-      slaveComm.Open();
-
-      ClientCom = SlaveClientCom.Instance.ClientCom;
-      ClientCom.LogMessage("Hive Slave started");
-
-      ConfigManager manager = ConfigManager.Instance;
-      manager.Core = this;
-
-      wcfService = WcfService.Instance;
-      RegisterServiceEvents();
-
-      StartHeartbeats(); // Start heartbeats thread
-      DispatchMessageQueue(); // dispatch messages until abortRequested
-
-      DeRegisterServiceEvents();
-      waitShutdownSem.Release();
+      try {
+        //start the client communication service (pipe between slave and slave gui)
+        slaveComm = new ServiceHost(typeof(SlaveCommunicationService));
+        slaveComm.Open();
+
+        ClientCom = SlaveClientCom.Instance.ClientCom;
+        ClientCom.LogMessage("Hive Slave started");
+
+        ConfigManager manager = ConfigManager.Instance;
+        manager.Core = this;
+
+        wcfService = WcfService.Instance;
+        RegisterServiceEvents();
+
+        StartHeartbeats(); // Start heartbeats thread
+        DispatchMessageQueue(); // dispatch messages until abortRequested
+      }
+      catch (Exception ex) {
+        if (ServiceEventLog != null) {
+          try {
+            ServiceEventLog.WriteEntry("Hive Slave threw exception: " + ex.ToString() + " with stack trace: " + ex.StackTrace);
+          }
+          catch (Exception) { }
+        } else {
+          throw ex;
+        }
+      }
+      finally {
+        DeRegisterServiceEvents();
+        waitShutdownSem.Release();
+      }
     }
 
     private void StartHeartbeats() {
-      //Initialize the heartbeat      
-      heartbeatManager = new HeartbeatManager { Interval = new TimeSpan(0, 0, 10) };
-      heartbeatManager.StartHeartbeat();
+      //Initialize the heartbeat     
+      if (heartbeatManager != null) {
+        heartbeatManager = new HeartbeatManager { Interval = new TimeSpan(0, 0, 10) };
+        heartbeatManager.StartHeartbeat();
+      }
     }
 
@@ -194 +212 @@
       if (job != null) {
         engines[job.Id].Pause();
-        JobData sJob = engines[job.Id].GetFinishedJob();
+        JobData sJob = engines[job.Id].GetPausedJob();
         // job.Exception = engines[job.Id].CurrentException; // can there be an exception if a job is paused
         job.ExecutionTime = engines[job.Id].ExecutionTime;
@@ -339 +357 @@
       ClientCom.LogMessage("Sleep received");
       heartbeatManager.StopHeartBeat();
+      heartbeatManager = null;
       DoStopAll();
       WcfService.Instance.Disconnect();

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.4/Executor.cs

@@ -175 +175 @@
       }
 
+      return GetJob();
+    }
+
+    public JobData GetPausedJob() {
+      if (Job == null) {
+        throw new InvalidStateException("Job is null");
+      }
+
+      if (Job.ExecutionState == HeuristicLab.Core.ExecutionState.Started) {
+        try { Job.Pause(); }
+        catch { }
+      }
+
+      return GetJob();
+    }
+
+    private JobData GetJob() {
       if (Job.ExecutionState == HeuristicLab.Core.ExecutionState.Started) {
         throw new InvalidStateException("Job is still running");