Changeset 1097 for trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs

Timestamp:

01/08/09 17:00:09 (15 years ago)

Author:

kgrading

Message:

various changes (#457)

File:

• trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs (modified) (5 diffs)

trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs

@@ -58 +58 @@
 
     private WcfService wcfService;
+    private Heartbeat beat;
 
     public void Start() {
@@ -82 +83 @@
       }
    
-      Heartbeat beat = new Heartbeat { Interval = 10000 };
+      beat = new Heartbeat { Interval = 10000 };
       beat.StartHeartbeat();     
 
@@ -120 +121 @@
         case MessageContainer.MessageType.Shutdown:
           ShutdownFlag = true;
+          beat.StopHeartBeat();
           break;
       }
@@ -192 +194 @@
 
     void wcfService_ServerChanged(object sender, EventArgs e) {
+      Logging.GetInstance().Info(this.ToString(), "ServerChanged has been called");
       lock (Locker) {
         foreach (KeyValuePair<long, AppDomain> entries in appDomains)
@@ -201 +204 @@
 
     void wcfService_Connected(object sender, EventArgs e) {
-      wcfService.LoginAsync(ConfigManager.Instance.GetClientInfo());
-    }
-
+      wcfService.LoginSync(ConfigManager.Instance.GetClientInfo());
+    }
+
+    //this is a little bit tricky - 
     void wcfService_ConnectionRestored(object sender, EventArgs e) {
-      //Do some fancy new things here... e.g: check all appdomains if there are still active Jobs that need to be transmitted
+      Logging.GetInstance().Info(this.ToString(), "Reconnected to old server - checking currently running appdomains");                 
+
+      foreach (KeyValuePair<long, Executor> execKVP in engines) {
+        if (!execKVP.Value.Running && execKVP.Value.CurrentMessage == MessageContainer.MessageType.NoMessage) {
+          Logging.GetInstance().Info(this.ToString(), "Checking for JobId: " + execKVP.Value.JobId);
+          Thread finThread = new Thread(new ParameterizedThreadStart(GetFinishedJob));
+          finThread.Start(execKVP.Value.JobId);
+        }
+      }
     }