Changeset 4285 for branches/3.3-HiveMigration/sources

Timestamp:

08/23/10 13:07:11 (14 years ago)

Author:

cneumuel

Message:

• changed Hive.Server WCF services to be configurable in app.config
• changed endpoints to wsHttpBinding
• changed project type of Hive.Server.Core to WCF Service Library, so that it can be started directly to be able to test the service (and update references) (#1159)

Location:

branches/3.3-HiveMigration/sources/HeuristicLab.Hive

Files:

• HeuristicLab.Hive 3.3.sln (modified) (2 diffs)
• HeuristicLab.Hive.Contracts/3.3/Interfaces/IServerConsoleFacade.cs (modified) (1 diff)
• HeuristicLab.Hive.Contracts/3.3/WcfSettings.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/3.3/DefaultScheduler.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/3.3/HeuristicLab.Hive.Server.Core-3.3.csproj (modified) (4 diffs)
• HeuristicLab.Hive.Server.Core/3.3/SlaveCommunicator.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/3.3/app.config (added)
• HeuristicLab.Hive.Server/3.3/HeuristicLab.Hive.Server-3.3.csproj (modified) (3 diffs)
• HeuristicLab.Hive.Server/3.3/HeuristicLabHiveServerApplication.cs (modified) (2 diffs)
• HeuristicLab.Hive.Slave.ExecutionEngine/3.3/Executor.cs (modified) (1 diff)
• HeuristicLab.Hive/3.3/Files.txt (modified) (2 diffs)
• HeuristicLab.Hive/3.3/HeuristicLab 3.3.exe.config (modified) (1 diff)
• HeuristicLab.Hive/3.3/MergeConfigs.cmd (modified) (1 diff)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive 3.3.sln

@@ -492 +492 @@
   EndGlobalSection
   GlobalSection(NestedProjects) = preSolution
-    {89F4BC52-C174-481E-9BD2-3814171020E8} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
-    {AEB51212-CDBA-4FC6-A2EE-02359AA53ECE} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
-    {8B14A35E-DBDF-43EB-B019-23E9FBC5A35E} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
-    {5010BD86-23B7-4F8C-888A-76D21AD5266A} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
-    {1605256A-1CB3-44AB-AAFF-577093EE5789} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
     {A04AE929-D0E1-466D-A9D3-BF3C4B2C209F} = {E7D8EFDA-B0CB-4B62-8EAE-2CF473F14D74}
     {42A1D075-6C12-4DD9-B0C2-C6F5210A8119} = {E7D8EFDA-B0CB-4B62-8EAE-2CF473F14D74}
@@ -516 +511 @@
     {5CDACE54-5FB2-4344-A21C-963F63CB7C2B} = {BD1DE6F6-A188-4D1F-9681-BA7104818370}
     {D17A4D6A-4CAA-4470-8A19-F42463C021FD} = {BD1DE6F6-A188-4D1F-9681-BA7104818370}
+    {89F4BC52-C174-481E-9BD2-3814171020E8} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
+    {AEB51212-CDBA-4FC6-A2EE-02359AA53ECE} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
+    {8B14A35E-DBDF-43EB-B019-23E9FBC5A35E} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
+    {5010BD86-23B7-4F8C-888A-76D21AD5266A} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
+    {1605256A-1CB3-44AB-AAFF-577093EE5789} = {DC8C63A5-7B57-4B3A-A74A-6F42C7DD1668}
     {55B89815-F3E7-4D09-9442-273F849141DD} = {4F2D8149-D608-42B3-BB1C-6909BDA2B350}
   EndGlobalSection

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/IServerConsoleFacade.cs

@@ -32 +32 @@
   /// Facade for the server management console
   /// </summary>
-  [ServiceContract(SessionMode=SessionMode.Required)]
+  [ServiceContract()]
   public interface IServerConsoleFacade : ISlaveManager, 
     IJobManager {

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/WcfSettings.cs

@@ -73 +73 @@
     /// </summary>
     /// <returns></returns>
-    public static string GetActiveIP() {
-      return System.Net.NetworkInformation.IPGlobalProperties.GetIPGlobalProperties().GetActiveTcpConnections()[0].LocalEndPoint.Address.ToString();
+    public static IPAddress GetActiveIP() {
+      //return System.Net.NetworkInformation.IPGlobalProperties.GetIPGlobalProperties().GetActiveTcpConnections()[0].LocalEndPoint.Address.ToString();
+      IPAddress[] addresses;
+      addresses = Dns.GetHostAddresses(Dns.GetHostName());
+      int index = 0;
+      if (System.Environment.OSVersion.Version.Major >= 6) {
+        for (index = addresses.Length - 1; index >= 0; index--)
+          if (addresses[index].AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
+            break;
+      }
+      return addresses[index];
     }
 

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/DefaultScheduler.cs

@@ -31 +31 @@
         using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = ApplicationConstants.ISOLATION_LEVEL_SCOPE })) {
           SlaveDto slave = DaoLocator.SlaveDao.FindById(slaveId);
-          LinkedList<JobDto> allOfflineJobsForSlave = new LinkedList<JobDto>(DaoLocator.JobDao.FindFittingJobsForSlave(JobState.Offline, slave.NrOfFreeCores, slave.FreeMemory, slave.Id));
-          if (allOfflineJobsForSlave != null && allOfflineJobsForSlave.Count > 0) {
-            jobToCalculate = allOfflineJobsForSlave.First.Value;
-            jobToCalculate.State = JobState.Calculating;
-            jobToCalculate.Slave = slave;
-            jobToCalculate.Slave.State = SlaveState.Calculating;
-            jobToCalculate.DateCalculated = DateTime.Now;
-            DaoLocator.JobDao.AssignSlaveToJob(slave.Id, jobToCalculate.Id);
-            DaoLocator.JobDao.Update(jobToCalculate);
-            DaoLocator.SlaveDao.Update(jobToCalculate.Slave);
+          if (slave != null) {
+            LinkedList<JobDto> allOfflineJobsForSlave = new LinkedList<JobDto>(DaoLocator.JobDao.FindFittingJobsForSlave(JobState.Offline, slave.NrOfFreeCores, slave.FreeMemory, slave.Id));
+            if (allOfflineJobsForSlave != null && allOfflineJobsForSlave.Count > 0) {
+              jobToCalculate = allOfflineJobsForSlave.First.Value;
+              jobToCalculate.State = JobState.Calculating;
+              jobToCalculate.Slave = slave;
+              jobToCalculate.Slave.State = SlaveState.Calculating;
+              jobToCalculate.DateCalculated = DateTime.Now;
+              DaoLocator.JobDao.AssignSlaveToJob(slave.Id, jobToCalculate.Id);
+              DaoLocator.JobDao.Update(jobToCalculate);
+              DaoLocator.SlaveDao.Update(jobToCalculate.Slave);
+            }
           }
           scope.Complete();

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/HeuristicLab.Hive.Server.Core-3.3.csproj

@@ -11 +11 @@
     <RootNamespace>HeuristicLab.Hive.Server.Core</RootNamespace>
     <AssemblyName>HeuristicLab.Hive.Server.Core-3.3</AssemblyName>
+    <ProjectTypeGuids>{3D9AD99F-2412-4246-B90B-4EAA41C64699};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</ProjectTypeGuids>
     <TargetFrameworkVersion>v3.5</TargetFrameworkVersion>
     <FileAlignment>512</FileAlignment>
@@ -96 +97 @@
     </Reference>
     <Reference Include="System.Drawing" />
+    <Reference Include="System.Runtime.Serialization" />
     <Reference Include="System.ServiceModel">
       <RequiredTargetFramework>3.0</RequiredTargetFramework>
@@ -143 +145 @@
   </ItemGroup>
   <ItemGroup>
+    <None Include="app.config" />
     <None Include="HeuristicLab.snk" />
     <EmbeddedResource Include="Authorization\HivePermissionSet.xsd">
@@ -185 +188 @@
     </ProjectReference>
   </ItemGroup>
-  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
+  <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
+  <ProjectExtensions>
+    <VisualStudio>
+      <FlavorProperties GUID="{3D9AD99F-2412-4246-B90B-4EAA41C64699}">
+        <WcfProjectProperties>
+          <AutoStart>False</AutoStart>
+        </WcfProjectProperties>
+      </FlavorProperties>
+    </VisualStudio>
+  </ProjectExtensions>
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/SlaveCommunicator.cs

@@ -34 +34 @@
 using HeuristicLab.Tracing;
 using HeuristicLab.Hive.Contracts.ResponseObjects;
+using System.Security.Permissions;
 
 namespace HeuristicLab.Hive.Server.Core {

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server/3.3/HeuristicLab.Hive.Server-3.3.csproj

@@ -109 +109 @@
       <RequiredTargetFramework>3.0</RequiredTargetFramework>
     </Reference>
+    <Reference Include="System.ServiceProcess" />
     <Reference Include="System.Transactions" />
     <Reference Include="System.Xml.Linq">
@@ -149 +150 @@
     </ProjectReference>
   </ItemGroup>
-  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
+  <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -165 +166 @@
 call PreBuildEvent.cmd</PreBuildEvent>
   </PropertyGroup>
+  <PropertyGroup>
+    <PostBuildEvent>
+    </PostBuildEvent>
+  </PropertyGroup>
 </Project>

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server/3.3/HeuristicLabHiveServerApplication.cs

@@ -35 +35 @@
   [Application("Hive Server", "Server application for the distributed hive engine.", true)]
   public class HeuristicLabHiveServerApplication : ApplicationBase {
-    public const string STR_SlaveCommunicator = "SlaveCommunicator";
+    public const string STR_SlaveCommunicator = "HiveServer";
     public const string STR_ServerConsoleFacade = "ServerConsoleFacade";
     public const string STR_ExecutionEngineFacade = "ExecutionEngineFacade";
-
-    private Dictionary<string, ServiceHost> runningServices = new Dictionary<string, ServiceHost>();
-    private NetTcpBinding binding = (NetTcpBinding)WcfSettings.GetBinding();
-    private NetTcpBinding streamedBinding = (NetTcpBinding)WcfSettings.GetStreamedBinding();
-
-    private enum Services {
-      SlaveCommunicator,
-      ServerConsoleFacade,
-      ExecutionEngineFacade,
-      All
-    }
-
-    private bool AddMexEndpoint(ServiceHost serviceHost) {
-      if (serviceHost != null) {
-        ServiceMetadataBehavior behavior = new ServiceMetadataBehavior();
-        serviceHost.Description.Behaviors.Add(behavior);
-
-        return serviceHost.AddServiceEndpoint(
-          typeof(IMetadataExchange),
-          MetadataExchangeBindings.CreateMexTcpBinding(),
-          "mex") != null;
-      } else
-        return false;
-    }
-
-    private Uri StartService(Services svc, IPAddress ipAddress, int port) {
-      string curServiceHost = "";
-      Uri uriTcp;
-      ISlaveFacade clientCommunicatorInstance = ApplicationManager.Manager.GetInstances<ISlaveFacade>().First();
-      IServerConsoleFacade serverConsoleInstance = ApplicationManager.Manager.GetInstances<IServerConsoleFacade>().First();
-      IExecutionEngineFacade executionEngineInstance = ApplicationManager.Manager.GetInstances<IExecutionEngineFacade>().First();
-      //SpringServiceHost serviceHost = null;
-      ServiceHost serviceHost = null;
-
-      switch (svc) {
-        case Services.SlaveCommunicator:
-          //  if (clientCommunicatorInstances.Count() > 0) {
-          uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/HiveServer/");
-          serviceHost = new ServiceHost(clientCommunicatorInstance.GetType(), uriTcp);
-          //serviceHost = new ServiceHost(typeof(SlaveFacade), uriTcp);
-          //serviceHost = new SpringServiceHost("clientFacade", uriTcp);
-          serviceHost.AddServiceEndpoint(typeof(ISlaveFacade), streamedBinding, STR_SlaveCommunicator);
-
-          ServiceDebugBehavior sdb = serviceHost.Description.Behaviors.Find<ServiceDebugBehavior>();
-          if (sdb == null) {
-            sdb = new ServiceDebugBehavior();
-            serviceHost.Description.Behaviors.Add(sdb);
-          }
-          sdb.IncludeExceptionDetailInFaults = true;
-
-
-
-          curServiceHost = STR_SlaveCommunicator;
-          //  }
-          break;
-        case Services.ServerConsoleFacade:
-          //  if (serverConsoleInstances.Count() > 0) {
-          uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/HiveServerConsole/");
-          serviceHost = new ServiceHost(serverConsoleInstance.GetType(), uriTcp);
-          //serviceHost = new SpringServiceHost("serverConsoleFacade", uriTcp);
-          serviceHost.AddServiceEndpoint(typeof(IServerConsoleFacade), binding, STR_ServerConsoleFacade);
-          curServiceHost = STR_ServerConsoleFacade;
-          //  }
-          break;
-        case Services.ExecutionEngineFacade:
-          //  if (executionEngineInstances.Count() > 0) {
-          uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/ExecutionEngine/");
-          serviceHost = new ServiceHost(executionEngineInstance.GetType(), uriTcp);
-          //serviceHost = new SpringServiceHost("executionEngineFacade", uriTcp);
-          serviceHost.AddServiceEndpoint(typeof(IExecutionEngineFacade), streamedBinding, STR_ExecutionEngineFacade);
-          curServiceHost = STR_ExecutionEngineFacade;
-          //  }
-          break;
-        case Services.All:
-          throw new InvalidOperationException("Not supported!");
-        default:
-          return null;
-      }
-      if (!String.IsNullOrEmpty(curServiceHost)) {
-        AddMexEndpoint(serviceHost);
-        //WcfSettings.SetServiceCertificate(serviceHost);
-        serviceHost.Open();
-        runningServices.Add(curServiceHost, serviceHost);
-        return serviceHost.BaseAddresses[0];
-      } else
-        return null;
-    }
-
-    private void StopService(Services svc) {
-      ServiceHost svcHost = null;
-      switch (svc) {
-        case Services.SlaveCommunicator:
-          runningServices.TryGetValue(STR_SlaveCommunicator, out svcHost);
-          break;
-        case Services.ServerConsoleFacade:
-          runningServices.TryGetValue(STR_ServerConsoleFacade, out svcHost);
-          break;
-        case Services.ExecutionEngineFacade:
-          runningServices.TryGetValue(STR_ExecutionEngineFacade, out svcHost);
-          break;
-        case Services.All:
-          foreach (KeyValuePair<string, ServiceHost> item in runningServices)
-            item.Value.Close();
-          return;
-        default:
-          throw new InvalidOperationException("Not supported!");
-      }
-      svcHost.Close();
-    }
+    Dictionary<string, Uri> baseAddrDict = new Dictionary<string, Uri>();
 
     public override void Run() {
-      IPAddress[] addresses = Dns.GetHostAddresses(Dns.GetHostName());
-      int index = 0;
-      if (System.Environment.OSVersion.Version.Major >= 6) {
-        for (index = addresses.Length - 1; index >= 0; index--)
-          if (addresses[index].AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
-            break;
-      }
+      ServiceHost slaveHost = new ServiceHost(ApplicationManager.Manager.GetTypes(typeof(ISlaveFacade)).First(), GetUri(STR_SlaveCommunicator));
+      slaveHost.Open();
 
-      //Start services and record their base address
-      Dictionary<string, Uri> baseAddrDict = new Dictionary<string, Uri>();
-      baseAddrDict.Add(STR_SlaveCommunicator, StartService(Services.SlaveCommunicator, addresses[index], WcfSettings.DEFAULTPORT));
-      baseAddrDict.Add(STR_ServerConsoleFacade, StartService(Services.ServerConsoleFacade, addresses[index], WcfSettings.DEFAULTPORT));
-      baseAddrDict.Add(STR_ExecutionEngineFacade, StartService(Services.ExecutionEngineFacade, addresses[index], WcfSettings.DEFAULTPORT));
+      ServiceHost serverConsoleHost = new ServiceHost(ApplicationManager.Manager.GetTypes(typeof(IServerConsoleFacade)).First(), GetUri(STR_ServerConsoleFacade));
+      serverConsoleHost.Open();
+
+      ServiceHost executionEngineHost = new ServiceHost(ApplicationManager.Manager.GetTypes(typeof(IExecutionEngineFacade)).First(), GetUri(STR_ExecutionEngineFacade));
+      executionEngineHost.Open();
 
       ILifecycleManager lifecycleManager = ServiceLocator.GetLifecycleManager();
-
       lifecycleManager.Init();
 
@@ -170 +56 @@
       Application.Run();
 
+      slaveHost.Close();
+      serverConsoleHost.Close();
+      executionEngineHost.Close();
+
       lifecycleManager.Shutdown();
-      
-      StopService(Services.All);
     }
+
+    private Uri GetUri(string serviceName) {
+      string ipAddress = WcfSettings.GetActiveIP().ToString();
+      string port = WcfSettings.DEFAULTPORT.ToString();
+      Uri uriHttp = new Uri("http://" + ipAddress + ":" + port + "/" + serviceName + "/");
+      baseAddrDict.Add(serviceName, uriHttp);
+      return uriHttp;
+    }
+
   }
 }

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.ExecutionEngine/3.3/Executor.cs

@@ -77 +77 @@
     public void Abort() {
       CurrentMessage = MessageContainer.MessageType.AbortJob;
-      Job.Stop();
+      if (Job.ExecutionState != Core.ExecutionState.Stopped) {
+        Job.Stop();
+      }
     }
 

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive/3.3/Files.txt

@@ -14 +14 @@
 HeuristicLab.Hive.Slave.ExecutionEngine\3.3:HeuristicLab.Hive.Slave.ExecutionEngine-3.3.dll
 
-HeuristicLab.Hive.Engine\3.3:HeuristicLab.Hive.Engine-3.3.dll
 HeuristicLab.Hive.Experiment\3.3:HeuristicLab.Hive.Experiment-3.3.dll
 HeuristicLab.Hive.Experiment.Views\3.3:HeuristicLab.Hive.Experiment.Views-3.3.dll
@@ -38 +37 @@
 ;HeuristicLab.Security.Server\3.3:HeuristicLab.Security.Server-3.3.dll
 
-;External Libraries
-;HeuristicLab.ExtLibs\HeuristicLab.SpringNET\1.3.0:HeuristicLab.SpringNET-1.3.0.dll
-;HeuristicLab.ExtLibs\HeuristicLab.SpringNET\1.3.0:Common.Logging.dll
-;HeuristicLab.ExtLibs\HeuristicLab.SpringNET\1.3.0:Spring.Aop.dll
-;HeuristicLab.ExtLibs\HeuristicLab.SpringNET\1.3.0:Spring.Core.dll
-;HeuristicLab.ExtLibs\HeuristicLab.SpringNET\1.3.0:Spring.Services.dll

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive/3.3/HeuristicLab 3.3.exe.config

@@ -10 +10 @@
   <connectionStrings>
   </connectionStrings>
+  
+  <!-- [chn] TODO: system.web should be located in HeuristicLab.Hive.Server.Core/app.config, but the ConfigMerger does not merge system.web (yet) -->
+  <system.web>
+    <membership>
+      <providers>
+        <clear/>
+        <add name="AspNetSqlMembershipProvider" type="System.Web.Security.SqlMembershipProvider" connectionStringName="HeuristicLab.Authentication"
+             enablePasswordRetrieval="false" enablePasswordReset="true" requiresQuestionAndAnswer="false" requiresUniqueEmail="false"
+             maxInvalidPasswordAttempts="5" minRequiredPasswordLength="6" minRequiredNonalphanumericCharacters="0" passwordAttemptWindow="10"
+             applicationName="HeuristicLab.Authentication" />
+      </providers>
+    </membership>
+
+    <roleManager enabled="true">
+      <providers>
+        <clear/>
+        <add name="AspNetSqlRoleProvider" type="System.Web.Security.SqlRoleProvider" connectionStringName="HeuristicLab.Authentication" applicationName="HeuristicLab.Authentication" />
+      </providers>
+    </roleManager>
+  </system.web>
+  
   <system.serviceModel>
     <behaviors>

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive/3.3/MergeConfigs.cmd

@@ +1 @@
+
+
+ConfigMerger "%SolutionDir%HeuristicLab.Hive.Experiment\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"
+ConfigMerger "%SolutionDir%HeuristicLab.Hive.Server.Core\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"
 ConfigMerger "%SolutionDir%HeuristicLab.Hive.Server.LINQDataAccess\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"
 ConfigMerger "%SolutionDir%HeuristicLab.Hive.Slave.Core\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"
-ConfigMerger "%SolutionDir%HeuristicLab.Hive.Experiment\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"
 ConfigMerger "%SolutionDir%HeuristicLab.Hive.Tracing\3.3\app.config" "HeuristicLab.Hive-3.3.dll.config"