Changeset 1097

Timestamp:

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

Author:

kgrading

Message:

various changes (#457)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Client.Communication/WcfService.cs (modified) (3 diffs)
• HeuristicLab.Hive.Client.Core/Core.cs (modified) (5 diffs)
• HeuristicLab.Hive.Client.Core/Heartbeat.cs (modified) (1 diff)
• HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Hive.Client.Communication/WcfService.cs

@@ -48 +48 @@
         proxy.SendHeartBeatCompleted += new EventHandler<SendHeartBeatCompletedEventArgs>(proxy_SendHeartBeatCompleted);
         proxy.Open();
-        if (ConnState == NetworkEnum.WcfConnState.Failed)
-          ConnectionRestored(this, new EventArgs());
 
         ConnState = NetworkEnum.WcfConnState.Connected;
-        ConnectedSince = DateTime.Now;        
+        ConnectedSince = DateTime.Now;
+        
         if (Connected != null)
           Connected(this, new EventArgs());                               
+        
+        if (ConnState == NetworkEnum.WcfConnState.Failed)
+          ConnectionRestored(this, new EventArgs());        
       }
       catch (Exception ex) {
@@ -93 +95 @@
         NetworkErrorHandling(e.Error.InnerException);
     }
+
+    public void LoginSync(ClientInfo clientInfo) {
+      try {
+        if (ConnState == NetworkEnum.WcfConnState.Connected) {
+          Response res = proxy.Login(clientInfo);
+          Logging.GetInstance().Info(this.ToString(), res.StatusMessage);
+        }
+      }
+      catch (Exception e) {
+        NetworkErrorHandling(e);
+      }
+    }
+
     #endregion
 
@@ -139 +154 @@
     }
 
-    #endregion
-
+    #endregion  
   }
 }

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);
+        }
+      }
     }
 

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

@@ -90 +90 @@
       e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));
     }
+
+    public void StopHeartBeat() {
+      heartbeatTimer.Dispose();
+    }
   }
 }

trunk/sources/HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs

@@ -38 +38 @@
     public MessageContainer.MessageType CurrentMessage { get; set; }
     public MessageQueue Queue { get; set; }
+    public bool Running {
+      get {
+        return Job.Running;
+      }
+    }
     public double Progress {
       get {