Changeset 7132

Timestamp:

12/06/11 12:49:34 (13 years ago)

Author:

ascheibe

Message:

#1672

• fixed name of slave windows service

reviewing comments:

• reduced MaxParallelDownloads to 2 to not completely overload cpus
• renamed ServiceLocator to HiveServiceLocator

Location:

trunk/sources

Files:

• HeuristicLab.Clients.Hive.Slave.Views/3.3/Properties/Settings.Designer.cs (modified) (2 diffs)
• HeuristicLab.Clients.Hive.Slave.Views/3.3/Properties/Settings.settings (modified) (1 diff)
• HeuristicLab.Clients.Hive.Slave.Views/3.3/app.config (modified) (1 diff)
• HeuristicLab.Clients.Hive.Slave/3.3/WcfService.cs (modified) (3 diffs)
• HeuristicLab.Clients.Hive/3.3/ConcurrentTaskDownloader.cs (modified) (2 diffs)
• HeuristicLab.Clients.Hive/3.3/HeuristicLab.Clients.Hive-3.3.csproj (modified) (2 diffs)
• HeuristicLab.Clients.Hive/3.3/HiveAdminClient.cs (modified) (4 diffs)
• HeuristicLab.Clients.Hive/3.3/HiveClient.cs (modified) (13 diffs)
• HeuristicLab.Clients.Hive/3.3/HiveJobs/HiveTask.cs (modified) (2 diffs)
• HeuristicLab.Clients.Hive/3.3/HiveServiceLocator.cs (moved) (moved from trunk/sources/HeuristicLab.Clients.Hive/3.3/ServiceLocator.cs) (1 diff)
• HeuristicLab.Clients.Hive/3.3/IHiveServiceLocator.cs (moved) (moved from trunk/sources/HeuristicLab.Clients.Hive/3.3/IServiceLocator.cs) (1 diff)
• HeuristicLab.Clients.Hive/3.3/JobResultPoller.cs (modified) (1 diff)
• HeuristicLab.Clients.Hive/3.3/Settings.Designer.cs (modified) (1 diff)
• HeuristicLab.Clients.Hive/3.3/Settings.settings (modified) (1 diff)
• HeuristicLab.Clients.Hive/3.3/app.config (modified) (1 diff)

trunk/sources/HeuristicLab.Clients.Hive.Slave.Views/3.3/Properties/Settings.Designer.cs

@@ -2 +2 @@
 // <auto-generated>
 //     This code was generated by a tool.
-//     Runtime Version:4.0.30319.235
+//     Runtime Version:4.0.30319.239
 //
 //     Changes to this file may cause incorrect behavior and will be lost if
@@ -62 +62 @@
         [global::System.Configuration.UserScopedSettingAttribute()]
         [global::System.Diagnostics.DebuggerNonUserCodeAttribute()]
-        [global::System.Configuration.DefaultSettingValueAttribute("HeuristicLab.Clients.Hive.SlaveCore.WindowsService")]
+        [global::System.Configuration.DefaultSettingValueAttribute("HeuristicLab.Clients.Hive.Slave")]
         public string ServiceName {
             get {

trunk/sources/HeuristicLab.Clients.Hive.Slave.Views/3.3/Properties/Settings.settings

@@ -13 +13 @@
     </Setting>
     <Setting Name="ServiceName" Type="System.String" Scope="User">
-      <Value Profile="(Default)">HeuristicLab.Clients.Hive.SlaveCore.WindowsService</Value>
+      <Value Profile="(Default)">HeuristicLab.Clients.Hive.Slave</Value>
     </Setting>
   </Settings>

trunk/sources/HeuristicLab.Clients.Hive.Slave.Views/3.3/app.config

@@ -17 +17 @@
                 <value>SlaveCommunicationServiceEndpoint</value>
             </setting>
+            <setting name="ServiceName" serializeAs="String">
+                <value>HeuristicLab.Clients.Hive.Slave</value>
+            </setting>
         </HeuristicLab.Clients.Hive.SlaveCore.Views.Properties.Settings>
     </userSettings>

trunk/sources/HeuristicLab.Clients.Hive.Slave/3.3/WcfService.cs

@@ -42 +42 @@
         if (instance == null) {
           instance = new WcfService();
-          ServiceLocator.Instance.Username = HeuristicLab.Clients.Hive.SlaveCore.Properties.Settings.Default.SlaveUser;
-          ServiceLocator.Instance.Password = HeuristicLab.Clients.Hive.SlaveCore.Properties.Settings.Default.SlavePwd;
+          HiveServiceLocator.Instance.Username = HeuristicLab.Clients.Hive.SlaveCore.Properties.Settings.Default.SlaveUser;
+          HiveServiceLocator.Instance.Password = HeuristicLab.Clients.Hive.SlaveCore.Properties.Settings.Default.SlavePwd;
         }
         return instance;
@@ -161 +161 @@
     public void CallHiveService(Action<IHiveService> call) {
       try {
-        ServiceLocator.Instance.CallHiveService(call);
+        HiveServiceLocator.Instance.CallHiveService(call);
       }
       catch (Exception ex) {
@@ -170 +170 @@
     private T CallHiveService<T>(Func<IHiveService, T> call) {
       try {
-        return ServiceLocator.Instance.CallHiveService(call);
+        return HiveServiceLocator.Instance.CallHiveService(call);
       }
       catch (Exception ex) {

trunk/sources/HeuristicLab.Clients.Hive/3.3/ConcurrentTaskDownloader.cs

@@ -69 +69 @@
 
     private Task DownloadTask(object taskId) {
-      return ServiceLocator.Instance.CallHiveService(s => s.GetTask((Guid)taskId));
+      return HiveServiceLocator.Instance.CallHiveService(s => s.GetTask((Guid)taskId));
     }
 
@@ -81 +81 @@
       try {
         if (abort) return null;
-        result = ServiceLocator.Instance.CallHiveService(s => s.GetTaskData(task.Id));
+        result = HiveServiceLocator.Instance.CallHiveService(s => s.GetTaskData(task.Id));
       } finally {
         downloadSemaphore.Release();

trunk/sources/HeuristicLab.Clients.Hive/3.3/HeuristicLab.Clients.Hive-3.3.csproj

@@ -116 +116 @@
     </Compile>
     <Compile Include="Exceptions\ResourceNotFoundException.cs" />
-    <Compile Include="IServiceLocator.cs" />
+    <Compile Include="IHiveServiceLocator.cs" />
     <Compile Include="Tasks\EngineTask.cs" />
     <Compile Include="Tasks\OptimizerTask.cs" />
@@ -149 +149 @@
     <Compile Include="ServiceClients\HiveServiceClient.cs" />
     <Compile Include="ServiceClients\Task.cs" />
-    <Compile Include="ServiceLocator.cs" />
+    <Compile Include="HiveServiceLocator.cs" />
     <None Include="HeuristicLab.snk" />
     <None Include="ServiceClients\GenerateServiceClients.cmd" />

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveAdminClient.cs

@@ -79 +79 @@
         resources = new ItemList<Resource>();
 
-        ServiceLocator.Instance.CallHiveService(service => {
+        HiveServiceLocator.Instance.CallHiveService(service => {
           service.GetSlaveGroups().ForEach(g => resources.Add(g));
           service.GetSlaves().ForEach(s => resources.Add(s));
@@ -101 +101 @@
           downtimes = new ItemList<Downtime>();
 
-          ServiceLocator.Instance.CallHiveService(service => {
+          HiveServiceLocator.Instance.CallHiveService(service => {
             service.GetDowntimesForResource(downtimeForResourceId).ForEach(d => downtimes.Add(d));
           });
@@ -119 +119 @@
       if (item.Id == Guid.Empty) {
         if (item is SlaveGroup) {
-          item.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddSlaveGroup((SlaveGroup)item));
+          item.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddSlaveGroup((SlaveGroup)item));
         }
         if (item is Slave) {
-          item.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddSlave((Slave)item));
+          item.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddSlave((Slave)item));
         }
         if (item is Downtime) {
-          item.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddDowntime((Downtime)item));
+          item.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddDowntime((Downtime)item));
         }
       } else {
         if (item is SlaveGroup) {
-          ServiceLocator.Instance.CallHiveService((s) => s.UpdateSlaveGroup((SlaveGroup)item));
+          HiveServiceLocator.Instance.CallHiveService((s) => s.UpdateSlaveGroup((SlaveGroup)item));
         }
         if (item is Slave) {
-          ServiceLocator.Instance.CallHiveService((s) => s.UpdateSlave((Slave)item));
+          HiveServiceLocator.Instance.CallHiveService((s) => s.UpdateSlave((Slave)item));
         }
         if (item is Downtime) {
-          ServiceLocator.Instance.CallHiveService((s) => s.UpdateDowntime((Downtime)item));
+          HiveServiceLocator.Instance.CallHiveService((s) => s.UpdateDowntime((Downtime)item));
         }
       }
@@ -144 +144 @@
     public static void Delete(IHiveItem item) {
       if (item is SlaveGroup) {
-        ServiceLocator.Instance.CallHiveService((s) => s.DeleteSlaveGroup(item.Id));
+        HiveServiceLocator.Instance.CallHiveService((s) => s.DeleteSlaveGroup(item.Id));
       } else if (item is Slave) {
-        ServiceLocator.Instance.CallHiveService((s) => s.DeleteSlave(item.Id));
+        HiveServiceLocator.Instance.CallHiveService((s) => s.DeleteSlave(item.Id));
       } else if (item is Downtime) {
-        ServiceLocator.Instance.CallHiveService((s) => s.DeleteDowntime(item.Id));
+        HiveServiceLocator.Instance.CallHiveService((s) => s.DeleteDowntime(item.Id));
       }
     }

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveClient.cs

@@ -82 +82 @@
 
       try {
-        this.IsAllowedPrivileged = ServiceLocator.Instance.CallHiveService((s) => s.IsAllowedPrivileged());
+        this.IsAllowedPrivileged = HiveServiceLocator.Instance.CallHiveService((s) => s.IsAllowedPrivileged());
 
         var oldJobs = jobs ?? new ItemCollection<RefreshableJob>();
         jobs = new HiveItemCollection<RefreshableJob>();
-        var jobsLoaded = ServiceLocator.Instance.CallHiveService<IEnumerable<Job>>(s => s.GetJobs());
+        var jobsLoaded = HiveServiceLocator.Instance.CallHiveService<IEnumerable<Job>>(s => s.GetJobs());
 
         foreach (var j in jobsLoaded) {
@@ -142 +142 @@
         if (item is JobPermission) {
           var hep = (JobPermission)item;
-          hep.GrantedUserId = ServiceLocator.Instance.CallHiveService((s) => s.GetUserIdByUsername(hep.GrantedUserName));
+          hep.GrantedUserId = HiveServiceLocator.Instance.CallHiveService((s) => s.GetUserIdByUsername(hep.GrantedUserName));
           if (hep.GrantedUserId == Guid.Empty) {
             throw new ArgumentException(string.Format("The user {0} was not found.", hep.GrantedUserName));
           }
-          ServiceLocator.Instance.CallHiveService((s) => s.GrantPermission(hep.JobId, hep.GrantedUserId, hep.Permission));
+          HiveServiceLocator.Instance.CallHiveService((s) => s.GrantPermission(hep.JobId, hep.GrantedUserId, hep.Permission));
         }
       } else {
         if (item is Job)
-          ServiceLocator.Instance.CallHiveService(s => s.UpdateJob((Job)item));
+          HiveServiceLocator.Instance.CallHiveService(s => s.UpdateJob((Job)item));
       }
     }
@@ -176 +176 @@
 
       if (item is Job)
-        ServiceLocator.Instance.CallHiveService(s => s.DeleteJob(item.Id));
+        HiveServiceLocator.Instance.CallHiveService(s => s.DeleteJob(item.Id));
       if (item is RefreshableJob)
-        ServiceLocator.Instance.CallHiveService(s => s.DeleteJob(item.Id));
+        HiveServiceLocator.Instance.CallHiveService(s => s.DeleteJob(item.Id));
       if (item is JobPermission) {
         var hep = (JobPermission)item;
-        ServiceLocator.Instance.CallHiveService(s => s.RevokePermission(hep.JobId, hep.GrantedUserId));
+        HiveServiceLocator.Instance.CallHiveService(s => s.RevokePermission(hep.JobId, hep.GrantedUserId));
       }
       item.Id = Guid.Empty;
@@ -215 +215 @@
 
     public static void PauseJob(RefreshableJob refreshableJob) {
-      ServiceLocator.Instance.CallHiveService(service => {
+      HiveServiceLocator.Instance.CallHiveService(service => {
         foreach (HiveTask task in refreshableJob.GetAllHiveTasks()) {
           if (task.Task.State != TaskState.Finished && task.Task.State != TaskState.Aborted && task.Task.State != TaskState.Failed)
@@ -225 +225 @@
 
     public static void StopJob(RefreshableJob refreshableJob) {
-      ServiceLocator.Instance.CallHiveService(service => {
+      HiveServiceLocator.Instance.CallHiveService(service => {
         foreach (HiveTask task in refreshableJob.GetAllHiveTasks()) {
           if (task.Task.State != TaskState.Finished && task.Task.State != TaskState.Aborted && task.Task.State != TaskState.Failed)
@@ -246 +246 @@
         var resourceIds = new List<Guid>();
         foreach (var resourceName in resourceNames) {
-          Guid resourceId = ServiceLocator.Instance.CallHiveService((s) => s.GetResourceId(resourceName));
+          Guid resourceId = HiveServiceLocator.Instance.CallHiveService((s) => s.GetResourceId(resourceName));
           if (resourceId == Guid.Empty) {
             throw new ResourceNotFoundException(string.Format("Could not find the resource '{0}'", resourceName));
@@ -259 +259 @@
         // upload Job
         refreshableJob.Progress.Status = "Uploading Job...";
-        refreshableJob.Job.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddJob(refreshableJob.Job));
+        refreshableJob.Job.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddJob(refreshableJob.Job));
         bool isPrivileged = refreshableJob.Job.IsPrivileged;
-        refreshableJob.Job = ServiceLocator.Instance.CallHiveService((s) => s.GetJob(refreshableJob.Job.Id)); // update owner and permissions
+        refreshableJob.Job = HiveServiceLocator.Instance.CallHiveService((s) => s.GetJob(refreshableJob.Job.Id)); // update owner and permissions
         refreshableJob.Job.IsPrivileged = isPrivileged;
         cancellationToken.ThrowIfCancellationRequested();
@@ -271 +271 @@
         // upload plugins
         refreshableJob.Progress.Status = "Uploading plugins...";
-        this.OnlinePlugins = ServiceLocator.Instance.CallHiveService((s) => s.GetPlugins());
+        this.OnlinePlugins = HiveServiceLocator.Instance.CallHiveService((s) => s.GetPlugins());
         this.AlreadyUploadedPlugins = new List<Plugin>();
-        Plugin configFilePlugin = ServiceLocator.Instance.CallHiveService((s) => UploadConfigurationFile(s, onlinePlugins));
+        Plugin configFilePlugin = HiveServiceLocator.Instance.CallHiveService((s) => UploadConfigurationFile(s, onlinePlugins));
         this.alreadyUploadedPlugins.Add(configFilePlugin);
         cancellationToken.ThrowIfCancellationRequested();
@@ -357 +357 @@
           if (!cancellationToken.IsCancellationRequested) {
             lock (pluginLocker) {
-              ServiceLocator.Instance.CallHiveService((s) => hiveTask.Task.PluginsNeededIds = PluginUtil.GetPluginDependencies(s, this.onlinePlugins, this.alreadyUploadedPlugins, plugins));
+              HiveServiceLocator.Instance.CallHiveService((s) => hiveTask.Task.PluginsNeededIds = PluginUtil.GetPluginDependencies(s, this.onlinePlugins, this.alreadyUploadedPlugins, plugins));
             }
           }
@@ -370 +370 @@
           if (!cancellationToken.IsCancellationRequested) {
             if (parentHiveTask != null) {
-              hiveTask.Task.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddChildTask(parentHiveTask.Task.Id, hiveTask.Task, taskData));
+              hiveTask.Task.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddChildTask(parentHiveTask.Task.Id, hiveTask.Task, taskData));
             } else {
-              hiveTask.Task.Id = ServiceLocator.Instance.CallHiveService((s) => s.AddTask(hiveTask.Task, taskData, groups.ToList()));
+              hiveTask.Task.Id = HiveServiceLocator.Instance.CallHiveService((s) => s.AddTask(hiveTask.Task, taskData, groups.ToList()));
             }
           }
@@ -417 +417 @@
         // fetch all task objects to create the full tree of tree of HiveTask objects
         refreshableJob.Progress.Status = "Downloading list of tasks...";
-        allTasks = ServiceLocator.Instance.CallHiveService(s => s.GetLightweightJobTasks(hiveExperiment.Id));
+        allTasks = HiveServiceLocator.Instance.CallHiveService(s => s.GetLightweightJobTasks(hiveExperiment.Id));
         totalJobCount = allTasks.Count();
 
@@ -480 +480 @@
 
     public static ItemTask LoadItemJob(Guid jobId) {
-      TaskData taskData = ServiceLocator.Instance.CallHiveService(s => s.GetTaskData(jobId));
+      TaskData taskData = HiveServiceLocator.Instance.CallHiveService(s => s.GetTaskData(jobId));
       try {
         return PersistenceUtil.Deserialize<ItemTask>(taskData.Data);
@@ -505 +505 @@
 
     public static HiveItemCollection<JobPermission> GetJobPermissions(Guid jobId) {
-      return ServiceLocator.Instance.CallHiveService((service) => {
+      return HiveServiceLocator.Instance.CallHiveService((service) => {
         IEnumerable<JobPermission> jps = service.GetJobPermissions(jobId);
         foreach (var hep in jps) {

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveJobs/HiveTask.cs

@@ -456 +456 @@
         try {
           foreach (var child in childHiveTasks) {
-            ServiceLocator.Instance.CallHiveService(s => s.PauseTask(child.task.Id));
+            HiveServiceLocator.Instance.CallHiveService(s => s.PauseTask(child.task.Id));
           }
         }
         finally { childHiveTasksLock.ExitReadLock(); }
       } else {
-        ServiceLocator.Instance.CallHiveService(s => s.PauseTask(this.task.Id));
+        HiveServiceLocator.Instance.CallHiveService(s => s.PauseTask(this.task.Id));
       }
     }
@@ -470 +470 @@
         try {
           foreach (var child in childHiveTasks) {
-            ServiceLocator.Instance.CallHiveService(s => s.StopTask(child.task.Id));
+            HiveServiceLocator.Instance.CallHiveService(s => s.StopTask(child.task.Id));
           }
         }
         finally { childHiveTasksLock.ExitReadLock(); }
       } else {
-        ServiceLocator.Instance.CallHiveService(s => s.StopTask(this.task.Id));
+        HiveServiceLocator.Instance.CallHiveService(s => s.StopTask(this.task.Id));
       }
     }
 
     public void Restart() {
-      ServiceLocator.Instance.CallHiveService(service => {
+      HiveServiceLocator.Instance.CallHiveService(service => {
         TaskData taskData = new TaskData();
         taskData.TaskId = this.task.Id;

trunk/sources/HeuristicLab.Clients.Hive/3.3/HiveServiceLocator.cs

@@ -24 +24 @@
 
 namespace HeuristicLab.Clients.Hive {
-  public class ServiceLocator : IServiceLocator {
-    private static IServiceLocator instance = null;
-    public static IServiceLocator Instance {
+  public class HiveServiceLocator : IHiveServiceLocator {
+    private static IHiveServiceLocator instance = null;
+    public static IHiveServiceLocator Instance {
       get {
         if (instance == null) {
-          instance = new ServiceLocator();
+          instance = new HiveServiceLocator();
         }
         return instance;

trunk/sources/HeuristicLab.Clients.Hive/3.3/IHiveServiceLocator.cs

@@ -23 +23 @@
 
 namespace HeuristicLab.Clients.Hive {
-  public interface IServiceLocator {
+  public interface IHiveServiceLocator {
     string Username { get; set; }
     string Password { get; set; }

trunk/sources/HeuristicLab.Clients.Hive/3.3/JobResultPoller.cs

@@ -106 +106 @@
 
     public IEnumerable<LightweightTask> FetchJobResults() {
-      return ServiceLocator.Instance.CallHiveService(service => {
+      return HiveServiceLocator.Instance.CallHiveService(service => {
         var responses = new List<LightweightTask>();
         responses.AddRange(service.GetLightweightJobTasks(jobId));

trunk/sources/HeuristicLab.Clients.Hive/3.3/Settings.Designer.cs

@@ -53 +53 @@
         [global::System.Configuration.ApplicationScopedSettingAttribute()]
         [global::System.Diagnostics.DebuggerNonUserCodeAttribute()]
-        [global::System.Configuration.DefaultSettingValueAttribute("5")]
+        [global::System.Configuration.DefaultSettingValueAttribute("2")]
         public int MaxParallelDownloads {
             get {

trunk/sources/HeuristicLab.Clients.Hive/3.3/Settings.settings

@@ -13 +13 @@
     </Setting>
     <Setting Name="MaxParallelDownloads" Type="System.Int32" Scope="Application">
-      <Value Profile="(Default)">5</Value>
+      <Value Profile="(Default)">2</Value>
     </Setting>
     <Setting Name="MaxRepeatServiceCalls" Type="System.Int32" Scope="Application">

trunk/sources/HeuristicLab.Clients.Hive/3.3/app.config

@@ -18 +18 @@
       </setting>
       <setting name="MaxParallelDownloads" serializeAs="String">
-        <value>5</value>
+        <value>2</value>
       </setting>
       <setting name="MaxRepeatServiceCalls" serializeAs="String">