Changeset 6394 for branches/MPI/HeuristicLab.MPIAlgorithmRunner

Timestamp:

06/08/11 14:26:36 (13 years ago)

Author:

svonolfe

Message:

Added first working version of the MPI engine (#1542)

Location:

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3

Files:

• AlgorithmBroker.cs (modified) (3 diffs)
• HeuristicLab.MPIAlgorithmRunner-3.3.csproj (modified) (2 diffs)
• Program.cs (modified) (2 diffs)

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/AlgorithmBroker.cs

@@ -32 +32 @@
 using HeuristicLab.Core;
 using System.Threading;
+using System.Xml;
                      
 namespace HeuristicLab.MPIAlgorithmRunner {
@@ -53 +54 @@
       endpoint.Name = "AlgorithmBrokerEndpoint";
       NetTcpBinding netTCPBinding = new NetTcpBinding(SecurityMode.None);
+      netTCPBinding.MaxReceivedMessageSize = int.MaxValue;
+      XmlDictionaryReaderQuotas quotas = new XmlDictionaryReaderQuotas();
+      quotas.MaxArrayLength = int.MaxValue;
+      netTCPBinding.ReaderQuotas = quotas;
       endpoint.Binding = netTCPBinding;
       int port = FindFreeTcpPort();
       endpoint.Address = new EndpointAddress("net.tcp://localhost:" + port + "/AlgorithmBroker");
       service.AddServiceEndpoint(endpoint);
+      ServiceDebugBehavior debug = service.Description.Behaviors.Find<ServiceDebugBehavior>();
+      debug.IncludeExceptionDetailInFaults = true;
 
       return service;
@@ -85 +92 @@
     public void TransmitAlgorithm(MPITransportWrapper<IAlgorithm> algorithm) {
       Console.WriteLine("Transmitting Algorithm...");
-      int clients = MPI.Communicator.world.Group.Size;
+      int clients = MPI.Communicator.world.Group.Size - 1;
 
       for(int i = 0; i < clients; i++) {

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/HeuristicLab.MPIAlgorithmRunner-3.3.csproj

@@ -129 +129 @@
     <Reference Include="System" />
     <Reference Include="System.Core" />
+    <Reference Include="System.Runtime.Serialization" />
     <Reference Include="System.ServiceModel" />
     <Reference Include="System.Xml.Linq" />
@@ -168 +169 @@
 SubWCRev "%25ProjectDir%25\" "%25ProjectDir%25\HeuristicLabMPIAlgorithmRunnerPlugin.cs.frame" "%25ProjectDir%25\HeuristicLabMPIAlgorithmRunnerPlugin.cs"</PreBuildEvent>
   </PropertyGroup>
+  <PropertyGroup>
+    <PostBuildEvent>set ProjectName=$(ProjectName)
+set Source=$(TargetPath)
+set Configuration=$(ConfigurationName)
+set Platform=$(PlatformName)
+set SolutionDir=$(SolutionDir)
+
+if exist "$(SolutionDir)CustomPostBuild.cmd" call "$(SolutionDir)CustomPostBuild.cmd"</PostBuildEvent>
+  </PropertyGroup>
   <!-- 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/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/Program.cs

@@ -41 +41 @@
 
       // Discover the job's context from the environment
-      String headNodeName = System.Environment.GetEnvironmentVariable("CCP_CLUSTER_NAME");
+      String headNodeName = System.Environment.GetEnvironmentVariable("CCP_SCHEDULER");
       int jobId = System.Convert.ToInt32(System.Environment.GetEnvironmentVariable("CCP_JOBID"));
+
+      Console.WriteLine(jobId + "@" + headNodeName); 
 
       // Connect to the head node and get the job
@@ -63 +65 @@
     static void Main(string[] args) {
       using (new MPI.Environment(ref args)) {
-        int clients = MPI.Communicator.world.Group.Size;
+        int clients = MPI.Communicator.world.Group.Size - 1;
+        Console.WriteLine("Clients: " + clients);
+
         int updateInterval = 5000;