Changeset 4368 for branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/Core.cs

Timestamp:

09/07/10 10:22:27 (14 years ago)

Author:

cneumuel

Message:

• created HiveClient which shows an overview over all submitted HiveExperiments
• its possible to download all submitted HiveExperiments including results
• Experiments are now sent as a whole to the Hive and the Hive-Slaves take care of creating child-jobs (if necessary). The parent job is then paused and will be reactivated when all child-jobs are finished
• WcfService-Clients are now consistently managed by WcfServicePool which allows to use IDisposable-Pattern and always keeps exactly one proxy-object until all callers disposed them.
• created ProgressView which is able to lock a View and display progress of an action. It also allows to simulate progress if no progress-information is available so that users don't get too nervous while waiting.

File:

• branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/Core.cs (modified) (3 diffs)

branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/Core.cs

@@ -30 +30 @@
 using HeuristicLab.Hive.Slave.Common;
 using HeuristicLab.Hive.Slave.Communication;
-using HeuristicLab.Hive.Slave.Core.SlaveConsoleService;
+using HeuristicLab.Hive.Slave.Communication.SlaveFacade;
 using HeuristicLab.Hive.Slave.Core.ConfigurationManager;
 using HeuristicLab.Hive.Slave.Core.JobStorage;
+using HeuristicLab.Hive.Slave.Core.SlaveConsoleService;
 using HeuristicLab.Hive.Slave.ExecutionEngine;
 using HeuristicLab.Tracing;
-using HeuristicLab.Hive.Slave.Communication.SlaveService;
 
 namespace HeuristicLab.Hive.Slave.Core {
@@ -205 +205 @@
           WcfService.Instance.Logout(ConfigManager.Instance.GetClientInfo().Id);
           break;
-      }
+
+        case MessageContainer.MessageType.AddChildJob:
+          AddChildJob((MessageContainerWithJob)container);
+          break;
+
+        case MessageContainer.MessageType.PauseJob:
+          // send the job back to hive
+          PauseJob((MessageContainerWithJob)container);
+          break;
+
+        case MessageContainer.MessageType.GetChildJobs:
+          // send the job back to hive
+          GetChildJobs((MessageContainerWithCallback<SerializedJobList>)container);
+          break;
+      }
+    }
+
+    private void GetChildJobs(MessageContainerWithCallback<SerializedJobList> mc) {
+      ResponseObject<SerializedJobList> response = wcfService.GetChildJobs(mc.JobId);
+      if (response.StatusMessage != ResponseStatus.Ok) {
+        Logger.Error("GetChildJobs failed: " + response.StatusMessage);
+      } else {
+        mc.Callback(response.Obj);
+      }
+    }
+
+    private void PauseJob(MessageContainerWithJob mc) {
+      ResponseObject<JobDto> response = wcfService.PauseJob(mc.SerializedJob);
+      KillAppDomain(mc.JobId);
+      if (response.StatusMessage != ResponseStatus.Ok) {
+        Logger.Error("PauseJob failed: " + response.StatusMessage);
+      }
+    }
+
+    private ResponseObject<JobDto> AddChildJob(MessageContainerWithJob mc) {
+      ResponseObject<JobDto> response = wcfService.AddChildJob(mc.JobId, mc.SerializedJob);
+      if (response.StatusMessage != ResponseStatus.Ok) {
+        Logger.Error("AddChildJob failed: " + response.StatusMessage);
+      }
+      return response;
     }
 
@@ -462 +501 @@
             appDomains.Remove(id);
           }
+
           engines.Remove(id);
           jobs.Remove(id);