Changeset 1515 for XIOS/dev/branch_openmp/extern/ep_dev/ep_intercomm.cpp

Timestamp:

05/31/18 16:32:39 (6 years ago)

Author:

yushan

Message:

save dev

File:

• XIOS/dev/branch_openmp/extern/ep_dev/ep_intercomm.cpp (modified) (2 diffs)

XIOS/dev/branch_openmp/extern/ep_dev/ep_intercomm.cpp

@@ -24 +24 @@
 
     MPI_Barrier(local_comm);
+
+    int leader_ranks_in_peer[3];  // local_leader_rank_in_peer
+                                  // remote_leader_rank_in_peer
+                                  // size of peer
+
+    if(ep_rank == local_leader)
+    {
+      MPI_Comm_rank(peer_comm, &leader_ranks_in_peer[0]);
+      leader_ranks_in_peer[1] = remote_leader;
+      MPI_Comm_size(peer_comm, &leader_ranks_in_peer[2]);
+    }
+
+    MPI_Bcast(leader_ranks_in_peer, 3, MPI_INT, local_leader, local_comm);
+
+    if(leader_ranks_in_peer[0] != leader_ranks_in_peer[2])
+    {
+      Debug("calling MPI_Intercomm_create_kernel\n");
+      return MPI_Intercomm_create_kernel(local_comm, local_leader, peer_comm, remote_leader, tag, newintercomm);
+    }
+
+    else
+    {
+      if(leader_ranks_in_peer[2] == 1)
+      {
+        Debug("calling MPI_Intercomm_create_unique\n");
+        return MPI_Intercomm_create_unique_leader(local_comm, local_leader, peer_comm, remote_leader, tag, newintercomm); 
+        
+      }
+      else
+      {
+        Debug("calling MPI_Intercomm_create_world\n");
+        return MPI_Intercomm_create_from_world(local_comm, local_leader, peer_comm, remote_leader, tag, newintercomm);   
+      }
+      
+    }
+
+
 
 
@@ -174 +211 @@
     }
 
-    if(ep_rank == local_leader) printf("calling MPI_Intercomm_create_kernel\n");
-
-    return MPI_Intercomm_create_kernel(local_comm, local_leader, peer_comm, remote_leader, tag, newintercomm);
+    
 
   }