replace star_reduction by our own reduction

[simgrid.git] / src / smpi / colls / allreduce-rab1.c

diff --git a/src/smpi/colls/allreduce-rab1.c b/src/smpi/colls/allreduce-rab1.c
index e57ac2f..ae72f74 100644 (file)
--- a/src/smpi/colls/allreduce-rab1.c
+++ b/src/smpi/colls/allreduce-rab1.c
@@ -50,7 +50,7 @@ int smpi_coll_tuned_allreduce_rab1(void *sbuff, void *rbuff,
       smpi_mpi_sendrecv((char *) recv + send_idx * extent, send_cnt, dtype, dst, tag,
                    tmp_buf, recv_cnt, dtype, dst, tag, comm, &status);
 
-      star_reduction(op, tmp_buf, (char *) recv + recv_idx * extent, &recv_cnt,
+      smpi_op_apply(op, tmp_buf, (char *) recv + recv_idx * extent, &recv_cnt,
                      &dtype);
 
       // update send_idx for next iteration 
@@ -84,7 +84,7 @@ int smpi_coll_tuned_allreduce_rab1(void *sbuff, void *rbuff,
       smpi_mpi_sendrecv((char *) rbuff + send_idx * extent, send_cnt, dtype, dst,
                    tag, tmp_buf, recv_cnt, dtype, dst, tag, comm, &status);
 
-      star_reduction(op, tmp_buf, (char *) rbuff + recv_idx * extent, &recv_cnt,
+      smpi_op_apply(op, tmp_buf, (char *) rbuff + recv_idx * extent, &recv_cnt,
                      &dtype);
 
       // update send_idx for next iteration