Changeset 1527 for XIOS/dev/branch_openmp/extern/ep_dev/ep_allgather.cpp

Timestamp:

06/08/18 15:59:53 (6 years ago)

Author:

yushan

Message:

save dev

File:

• XIOS/dev/branch_openmp/extern/ep_dev/ep_allgather.cpp (modified) (3 diffs)

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

@@ -43 +43 @@
   {
 
-    if(!comm->is_ep && comm->mpi_comm)
-    {
-      return ::MPI_Allgather(const_cast<void*>(sendbuf), sendcount, to_mpi_type(sendtype), recvbuf, recvcount, to_mpi_type(recvtype), to_mpi_comm(comm->mpi_comm));
-    }
+    if(!comm->is_ep) return ::MPI_Allgather(const_cast<void*>(sendbuf), sendcount, to_mpi_type(sendtype), recvbuf, recvcount, to_mpi_type(recvtype), to_mpi_comm(comm->mpi_comm));
+    if(comm->is_intercomm) return MPI_Allgather_intercomm(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm);
+
 
     assert(sendcount == recvcount);
@@ -119 +118 @@
     MPI_Bcast_local(recvbuf, count*ep_size, datatype, 0, comm);
 
-    MPI_Barrier(comm);
-
-
     if(is_master)
     {
@@ -131 +127 @@
   }
 
+  int MPI_Allgather_intercomm(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm)
+  {
+    printf("MPI_Allgather_intercomm not yet implemented\n");
+    MPI_Abort(comm, 0);
+  }