Changeset 1083

Timestamp:

01/07/09 16:15:51 (15 years ago)

Author:

kgrading

Message:

added shutdownflag (#401)

Location:

trunk/sources/HeuristicLab.Hive.Client.Core

Files:

• ClientConsoleService/ClientConsoleCommunicator.cs (modified) (1 diff)
• ClientConsoleService/Interfaces/IClientConsoleCommunicator.cs (modified) (1 diff)
• Core.cs (modified) (5 diffs)

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

@@ -34 +34 @@
     }
 
+    public void ShutdownClient() {
+      Core.ShutdownFlag = true;
+    }
+
     #endregion
   }

trunk/sources/HeuristicLab.Hive.Client.Core/ClientConsoleService/Interfaces/IClientConsoleCommunicator.cs

@@ -18 +18 @@
     [OperationContract]
     ConnectionContainer GetCurrentConnection();
+    [OperationContract]
+    void ShutdownClient();
   }
 }

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

@@ -51 +51 @@
     public static Object Locker { get; set; }
 
+    public static bool ShutdownFlag { get; set; }
+
     Dictionary<long, Executor> engines = new Dictionary<long, Executor>();
     Dictionary<long, AppDomain> appDomains = new Dictionary<long, AppDomain>();
@@ -59 +61 @@
     public void Start() {
       Core.Locker = new Object();
+      ShutdownFlag = false;
+
       Logging.GetInstance().Info(this.ToString(), "Hive Client started");
       ClientConsoleServer server = new ClientConsoleServer();
@@ -82 +86 @@
 
       MessageQueue queue = MessageQueue.GetInstance();
-      while (true) {
+      while (!ShutdownFlag) {
         MessageContainer container = queue.GetMessage();
         Debug.WriteLine("Main loop received this message: " + container.Message.ToString());
@@ -135 +139 @@
 
     #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) {
@@ -201 +201 @@
     }
 
+    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
+    }
 
     #endregion