X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2bf42881ff8e158f7d9e7683d52725e42668dd24..bad5891a4d5a2d97e1dea926cb640f516c1fae0c:/src/smpi/colls/reduce_scatter/reduce_scatter-mpich.cpp diff --git a/src/smpi/colls/reduce_scatter/reduce_scatter-mpich.cpp b/src/smpi/colls/reduce_scatter/reduce_scatter-mpich.cpp index 2f75f1f9b0..98eb126d91 100644 --- a/src/smpi/colls/reduce_scatter/reduce_scatter-mpich.cpp +++ b/src/smpi/colls/reduce_scatter/reduce_scatter-mpich.cpp @@ -32,16 +32,13 @@ int reduce_scatter__mpich_pair(const void *sendbuf, void *recvbuf, const int rec unsigned char* tmp_recvbuf; int mpi_errno = MPI_SUCCESS; int total_count, dst, src; - int is_commutative; comm_size = comm->size(); rank = comm->rank(); extent =datatype->get_extent(); datatype->extent(&true_lb, &true_extent); - if (op->is_commutative()) { - is_commutative = 1; - } + bool is_commutative = (op == MPI_OP_NULL || op->is_commutative()); int* disps = new int[comm_size]; @@ -274,16 +271,14 @@ int reduce_scatter__mpich_rdb(const void *sendbuf, void *recvbuf, const int recv int mask, dst_tree_root, my_tree_root, j, k; int received; MPI_Datatype sendtype, recvtype; - int nprocs_completed, tmp_mask, tree_root, is_commutative=0; + int nprocs_completed, tmp_mask, tree_root; comm_size = comm->size(); rank = comm->rank(); extent =datatype->get_extent(); datatype->extent(&true_lb, &true_extent); - if ((op==MPI_OP_NULL) || op->is_commutative()) { - is_commutative = 1; - } + bool is_commutative = (op == MPI_OP_NULL || op->is_commutative()); int* disps = new int[comm_size];