Changeset 6398 for branches/MPI/HeuristicLab.MPIAlgorithmRunner

Timestamp:

06/08/11 15:52:16 (14 years ago)

Author:

svonolfe

Message:

Added MPIEngine view (#1542)

Location:

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3

Files:

• AlgorithmBroker.cs (modified) (3 diffs)
• IAlgorithmBroker.cs (modified) (1 diff)
• Program.cs (modified) (2 diffs)

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

@@ -58 +58 @@
       quotas.MaxArrayLength = int.MaxValue;
       netTCPBinding.ReaderQuotas = quotas;
+      netTCPBinding.SendTimeout = new TimeSpan(100000000);
+      netTCPBinding.ReceiveTimeout = new TimeSpan(100000000);
       endpoint.Binding = netTCPBinding;
       int port = FindFreeTcpPort();
@@ -90 +92 @@
     #region IAlgorithmBroker Members
 
-    public void TransmitAlgorithm(MPITransportWrapper<IAlgorithm> algorithm) {
+    public void TransmitAlgorithm(MPITransportWrapper<IAlgorithm> algorithm, int updateInterval) {
       Console.WriteLine("Transmitting Algorithm...");
       int clients = MPI.Communicator.world.Group.Size - 1;
@@ -97 +99 @@
         int client = i + 1;
         communicator.Send<MPITransportWrapper<IAlgorithm>>(algorithm, client, 0);
+        communicator.Send<int>(updateInterval, client, 1);
       }
     }

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

@@ -33 +33 @@
   public interface IAlgorithmBroker {
     [OperationContract]
-    void TransmitAlgorithm(MPITransportWrapper<IAlgorithm> algorithm);
+    void TransmitAlgorithm(MPITransportWrapper<IAlgorithm> algorithm, int updateInterval);
 
     [OperationContract]

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

@@ -68 +68 @@
         Console.WriteLine("Clients: " + clients);
 
-        int updateInterval = 5000;
-
         MPI.Communicator communicator = MPI.Communicator.world.Clone() as MPI.Communicator;
 
@@ -119 +117 @@
         } else {
           Program p = new Program();
-          p.StartAlgorithm(updateInterval, communicator);
+          p.StartAlgorithm(communicator);
         }
       }
     }
 
-    public void StartAlgorithm(int updateInterval, MPI.Communicator communicator) {
+    public void StartAlgorithm(MPI.Communicator communicator) {
       IAlgorithm alg = communicator.Receive<MPITransportWrapper<IAlgorithm>>(0, 0).InnerItem;
+      int updateInterval = communicator.Receive<int>(0, 1);
 
       Console.WriteLine("Starting algorithm...");