Changeset 1642 for XIOS/dev/branch_openmp/extern/src_ep_dev/ep_scatter.cpp
- Timestamp:
- 01/23/19 10:31:44 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_openmp/extern/src_ep_dev/ep_scatter.cpp
r1539 r1642 73 73 std::vector<int>ranks(ep_size); 74 74 75 if(mpi_rank == root_mpi_rank) MPI_Gather_local(&ep_rank, 1, MPI_INT, local_ranks.data(), root_ep_loc, comm);76 else MPI_Gather_local(&ep_rank, 1, MPI_INT, local_ranks.data(), 0, comm);75 if(mpi_rank == root_mpi_rank) MPI_Gather_local(&ep_rank, 1, EP_INT, local_ranks.data(), root_ep_loc, comm); 76 else MPI_Gather_local(&ep_rank, 1, EP_INT, local_ranks.data(), 0, comm); 77 77 78 78 … … 91 91 displs[i] = displs[i-1] + recvcounts[i-1]; 92 92 93 ::MPI_Gatherv(local_ranks.data(), num_ep, to_mpi_type( MPI_INT), ranks.data(), recvcounts.data(), displs.data(), to_mpi_type(MPI_INT), root_mpi_rank, to_mpi_comm(comm->mpi_comm));93 ::MPI_Gatherv(local_ranks.data(), num_ep, to_mpi_type(EP_INT), ranks.data(), recvcounts.data(), displs.data(), to_mpi_type(EP_INT), root_mpi_rank, to_mpi_comm(comm->mpi_comm)); 94 94 } 95 95 … … 109 109 { 110 110 int local_sendcount = num_ep * count; 111 ::MPI_Gather(&local_sendcount, 1, to_mpi_type( MPI_INT), recvcounts.data(), 1, to_mpi_type(MPI_INT), root_mpi_rank, to_mpi_comm(comm->mpi_comm));111 ::MPI_Gather(&local_sendcount, 1, to_mpi_type(EP_INT), recvcounts.data(), 1, to_mpi_type(EP_INT), root_mpi_rank, to_mpi_comm(comm->mpi_comm)); 112 112 113 113 if(is_root) for(int i=1; i<mpi_size; i++) displs[i] = displs[i-1] + recvcounts[i-1];
Note: See TracChangeset
for help on using the changeset viewer.