Changeset 6945 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave

Timestamp:

11/02/11 18:42:44 (13 years ago)

Author:

ascheibe

Message:

#1233 slave: catch more errors and log them to the windows event log

Location:

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

Files:

• Core.cs (modified) (2 diffs)
• HeuristicLab.Clients.Hive.Slave-3.3.csproj (modified) (1 diff)
• Manager/EventLogManager.cs (added)
• SlaveClientCom.cs (modified) (2 diffs)
• SlaveCommunicationService.cs (modified) (2 diffs)
• SlaveTask.cs (modified) (3 diffs)

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

@@ -71 +71 @@
     public void Start() {
       abortRequested = false;
+      EventLogManager.ServiceEventLog = ServiceEventLog;
 
       try {
@@ -90 +91 @@
       catch (Exception ex) {
         if (ServiceEventLog != null) {
-          try {
-            ServiceEventLog.WriteEntry(string.Format("Hive Slave threw exception: {0} with stack trace: {1}", ex.ToString(), ex.StackTrace), EventLogEntryType.Error);
-          }
-          catch (Exception) { }
+          EventLogManager.LogException(ex);
         } else {
           //try to log with clientCom. if this works the user sees at least a message, 

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

@@ -118 +118 @@
     <Compile Include="ExecutorQueue.cs" />
     <Compile Include="IPluginProvider.cs" />
+    <Compile Include="Manager\EventLogManager.cs" />
     <Compile Include="Manager\TaskManager.cs" />
     <Compile Include="Exceptions\OutOfCoresException.cs" />

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.3/SlaveClientCom.cs

@@ -57 +57 @@
       }
       catch {
-        pipeFactory = new DuplexChannelFactory<ISlaveCommunication>(dummy, new NetNamedPipeBinding(), new EndpointAddress("net.pipe://localhost/HeuristicLabSlaveCom"));
+        EventLogManager.LogMessage("Couldn't create pipe for SlaveClientCom with config!");
+
+        try {
+          pipeFactory = new DuplexChannelFactory<ISlaveCommunication>(dummy, new NetNamedPipeBinding(), new EndpointAddress("net.pipe://localhost/HeuristicLabSlaveCom"));
+        }
+        catch {
+          EventLogManager.LogMessage("Couldn't create pipe for SlaveClientCom with fixed addresse!");
+          return;
+        }
       }
+      pipeFactory.Faulted += new System.EventHandler(pipeFactory_Faulted);
 
       ISlaveCommunication pipeProxy = pipeFactory.CreateChannel();
@@ -64 +73 @@
     }
 
+    void pipeFactory_Faulted(object sender, System.EventArgs e) {
+      EventLogManager.LogMessage("SlaveClientCom just faulted. Trying to repair it...");
+
+      try {
+        pipeFactory.Faulted -= new System.EventHandler(pipeFactory_Faulted);
+        SetupClientCom();
+      }
+      catch { }
+    }
+
     public static void Close() {
-      if (pipeFactory.State != CommunicationState.Closed)
+      if (pipeFactory.State != CommunicationState.Closed && pipeFactory.State != CommunicationState.Faulted)
         pipeFactory.Close();
     }

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.3/SlaveCommunicationService.cs

@@ -20 +20 @@
 #endregion
 
+using System;
 using System.Collections.Generic;
 using System.ServiceModel;
@@ -54 +55 @@
 
     public void LogMessage(string message) {
-      subscribers.ForEach(delegate(ISlaveCommunicationCallbacks callback) {
-        if (((ICommunicationObject)callback).State == CommunicationState.Opened) {
-          callback.OnMessageLogged(message);
-        } else {
-          subscribers.Remove(callback);
-        }
-      });
+      try {
+        subscribers.ForEach(delegate(ISlaveCommunicationCallbacks callback) {
+          if (((ICommunicationObject)callback).State == CommunicationState.Opened) {
+            callback.OnMessageLogged(message);
+          } else {
+            subscribers.Remove(callback);
+          }
+        });
+      }
+      catch (Exception ex) {
+        EventLogManager.LogException(ex);
+      }
     }
 
     public void StatusChanged(StatusCommons status) {
-      subscribers.ForEach(delegate(ISlaveCommunicationCallbacks callback) {
-        if (((ICommunicationObject)callback).State == CommunicationState.Opened) {
-          callback.OnStatusChanged(status);
-        } else {
-          subscribers.Remove(callback);
-        }
-      });
+      try {
+        subscribers.ForEach(delegate(ISlaveCommunicationCallbacks callback) {
+          if (((ICommunicationObject)callback).State == CommunicationState.Opened) {
+            callback.OnStatusChanged(status);
+          } else {
+            subscribers.Remove(callback);
+          }
+        });
+      }
+      catch (Exception ex) {
+        EventLogManager.LogException(ex);
+      }
     }
 

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive.Slave/3.3/SlaveTask.cs

@@ -51 +51 @@
 
     public TimeSpan ExecutionTime {
-      get { return executor != null ? executor.ExecutionTime : TimeSpan.Zero; }
+      get {
+        try {
+          return executor != null ? executor.ExecutionTime : TimeSpan.Zero;
+        }
+        catch (Exception ex) {
+          EventLogManager.LogException(ex);
+          return TimeSpan.Zero;
+        }
+      }
     }
 
@@ -122 +130 @@
 
       if (executor != null) {
-        executor.Dispose();
+        try {
+          executor.Dispose();
+        }
+        catch (Exception ex) {
+          EventLogManager.LogException(ex);
+        }
       }
 
@@ -155 +168 @@
 
     public TaskData GetTaskData() {
-      return executor.GetTaskData();
+      TaskData data = null;
+      try {
+        data = executor.GetTaskData();
+      }
+      catch (Exception ex) {
+        EventLogManager.LogException(ex);
+      }
+      return data;
     }