Changeset 924

Timestamp:

12/07/08 16:52:28 (16 years ago)

Author:

kgrading

Message:

added a connectionRestored Event (#418)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Client.Communication/WcfService.cs (modified) (2 diffs)
• HeuristicLab.Hive.Client.Core/Core.cs (modified) (2 diffs)

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

@@ -22 +22 @@
     }
 
-    public enum ConnectionState { connected, disconnected, failed };
+    public enum ConnectionState { connected, disconnected, failed }  
+    public ConnectionState ConnState { get; set; }
+
+    public event EventHandler ConnectionRestored;    
 
     private ClientCommunicatorClient proxy = null;
-
-    public ConnectionState ConnState { get; set; }
-
     private string serverIP;
     private string serverPort;
@@ -46 +46 @@
         proxy.SendJobResultCompleted += new EventHandler<SendJobResultCompletedEventArgs>(proxy_SendJobResultCompleted);
         proxy.SendHeartBeatCompleted += new EventHandler<SendHeartBeatCompletedEventArgs>(proxy_SendHeartBeatCompleted);
+
+        if (ConnState == ConnectionState.failed)
+          ConnectionRestored(this, new EventArgs());
+        ConnState = ConnectionState.connected;
+
       }
       catch (Exception ex) {

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

@@ -66 +66 @@
       wcfService.PullJobCompleted += new EventHandler<PullJobCompletedEventArgs>(wcfService_PullJobCompleted);
       wcfService.SendJobResultCompleted += new EventHandler<SendJobResultCompletedEventArgs>(wcfService_SendJobResultCompleted);
+      wcfService.ConnectionRestored += new EventHandler(wcfService_ConnectionRestored);
 
       wcfService.LoginAsync(ConfigurationManager.GetInstance().GetClientInfo());
@@ -127 +128 @@
     #region wcfService Events
 
+    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
+    }
+
     void wcfService_LoginCompleted(object sender, LoginCompletedEventArgs e) {
       if (e.Result.Success) {