Changeset 2063 for trunk

Timestamp:

06/18/09 17:19:32 (15 years ago)

Author:

kgrading

Message:

added "time for shutdown" behavior: Snapshots of jobs get sent back to the server and then killed. When all jobs are killed, the client switches to disconnect state (#669)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Client.Communication/3.2/WcfService.cs (modified) (1 diff)
• HeuristicLab.Hive.Client.Core/3.2/Core.cs (modified) (3 diffs)

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

@@ -267 +267 @@
       if (e.Error == null && e.Result.Success == true)
         SendHeartBeatCompleted(sender, e);
-      else
+      else {
+        Logging.Instance.Error(this.ToString(), "Error: " + e.Result.StatusMessage);
         HandleNetworkError(e.Error);
+      }
     }
 

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

@@ -176 +176 @@
         case MessageContainer.MessageType.UptimeLimitDisconnect:
           Logging.Instance.Info(this.ToString(), "Uptime Limit reached, storing jobs and sending them back");
-          WcfService.Instance.Disconnect();
+
+          //check if there are running jobs
+          if (engines.Count > 0) {
+            //make sure there is no more fetching of jobs while the snapshots get processed
+            currentlyFetching = true;
+            //request a snapshot of each running job
+            foreach (KeyValuePair<Guid, Executor> kvp in engines) {
+              kvp.Value.RequestSnapshot();
+            }
+            
+          } else {
+            //Disconnect afterwards
+            WcfService.Instance.Disconnect();
+          }
           break;
         
@@ -239 +252 @@
         engines[jId].Progress,
         null);
-      engines[jId].StartOnlyJob();
+
+      //Uptime Limit reached, now is a good time to destroy this jobs.
+      if (!UptimeManager.Instance.isOnline()) {
+        lock (engines) {
+          appDomains[jId].UnhandledException -= new UnhandledExceptionEventHandler(appDomain_UnhandledException);
+          AppDomain.Unload(appDomains[jId]);
+          appDomains.Remove(jId);
+          engines.Remove(jId);
+          jobs.Remove(jId);
+        }
+        GC.Collect();
+
+        //Still anything running?
+        if (engines.Count == 0)
+          WcfService.Instance.Disconnect();
+      
+      } else {
+        engines[jId].StartOnlyJob();
+      }
     }
 
@@ -249 +280 @@
     void wcfService_LoginCompleted(object sender, LoginCompletedEventArgs e) {
       if (e.Result.Success) {
+        currentlyFetching = false;
         Logging.Instance.Info(this.ToString(), "Login completed to Hive Server @ " + DateTime.Now);        
       } else