Changeset 6354 for branches/MPI/HeuristicLab.Operators.MPISupport/3.3

Timestamp:

06/01/11 17:37:05 (13 years ago)

Author:

svonolfe

Message:

Added first version of the MPIEngine (#1542)

Location:

branches/MPI/HeuristicLab.Operators.MPISupport/3.3

Files:

• MPITransportWrapper.cs (modified) (1 diff)
• MPIUnidirectionalRingMigrator.cs (modified) (2 diffs)

branches/MPI/HeuristicLab.Operators.MPISupport/3.3/MPITransportWrapper.cs

@@ -34 +34 @@
   /// </summary>
   [Serializable]
-  class MPITransportWrapper<T>: ISerializable where T: class, IItem {
+  public class MPITransportWrapper<T>: ISerializable where T: class, IItem {
     [NonSerialized]
     private T innerItem;

branches/MPI/HeuristicLab.Operators.MPISupport/3.3/MPIUnidirectionalRingMigrator.cs

@@ -43 +43 @@
     }
 
+    public static int Channel = 100;
+
     public override IOperation Apply() {
       if (MPI.Communicator.world != null) {
-        int size = MPI.Communicator.world.Group.Size;
-        if (size > 1) {
+        int size = MPI.Communicator.world.Size;
+        if (size > 2) {
           int i = MPI.Communicator.world.Rank;
           IScope scope = ExecutionContext.Scope;
@@ -52 +54 @@
           IScope emigrants = scope.SubScopes[1];
           scope.SubScopes.Remove(emigrants);
-          int recipent = (i + 1) % size;
+          int recipent = i + 1;
+          if (recipent == size)
+            recipent = 1;
 
           Console.WriteLine("MIGRATE " + i + " TO " + recipent);
           MPI.Communicator.world.Send<MPITransportWrapper<IScope>>(
-            new MPITransportWrapper<IScope>(emigrants), recipent, 0);
+            new MPITransportWrapper<IScope>(emigrants), recipent, Channel);
 
           IScope immigrants = null;
           int sender = i - 1;
-          if (sender < 0)
+          if (sender < 1)
             sender = size - 1;
 
           Console.WriteLine("MIGRATE " + i + " FROM " + sender);
-          immigrants = MPI.Communicator.world.Receive<MPITransportWrapper<IScope>>(sender, 0).InnerItem;
+          immigrants = MPI.Communicator.world.Receive<MPITransportWrapper<IScope>>(sender, Channel).InnerItem;
 
           scope.SubScopes.Add(immigrants);