X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/92b5807a50d37d792c86af8b7309b73056586c41..29aa074252888a50d97e3069f51ffb8e6cf99101:/src/smpi/colls/allreduce-smp-rdb.cpp diff --git a/src/smpi/colls/allreduce-smp-rdb.cpp b/src/smpi/colls/allreduce-smp-rdb.cpp index 94490b6bec..b3036422b9 100644 --- a/src/smpi/colls/allreduce-smp-rdb.cpp +++ b/src/smpi/colls/allreduce-smp-rdb.cpp @@ -78,7 +78,7 @@ int smpi_coll_tuned_allreduce_smp_rdb(void *send_buf, void *recv_buf, int count, src = (inter_rank * num_core) + (intra_rank | mask); if (src < comm_size) { Request::recv(tmp_buf, count, dtype, src, tag, comm, &status); - if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, &dtype); + if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, dtype); } } else { dst = (inter_rank * num_core) + (intra_rank & (~mask)); @@ -115,7 +115,7 @@ int smpi_coll_tuned_allreduce_smp_rdb(void *send_buf, void *recv_buf, int count, } else { src = rank - num_core; Request::recv(tmp_buf, count, dtype, src, tag, comm, &status); - if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, &dtype); + if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, dtype); newrank = inter_rank / 2; } } else { @@ -141,7 +141,7 @@ int smpi_coll_tuned_allreduce_smp_rdb(void *send_buf, void *recv_buf, int count, /* exchange data in rdb manner */ Request::sendrecv(recv_buf, count, dtype, dst, tag, tmp_buf, count, dtype, dst, tag, comm, &status); - if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, &dtype); + if(op!=MPI_OP_NULL) op->apply( tmp_buf, recv_buf, &count, dtype); mask <<= 1; } }