diff --git a/src/mca/coll/basic/coll_basic_reduce_scatter.c b/src/mca/coll/basic/coll_basic_reduce_scatter.c index a85971c9be..bae7b2e6be 100644 --- a/src/mca/coll/basic/coll_basic_reduce_scatter.c +++ b/src/mca/coll/basic/coll_basic_reduce_scatter.c @@ -253,7 +253,8 @@ int mca_coll_basic_reduce_scatter_inter(void *sbuf, void *rbuf, int *rcounts, tcount += rcounts[i]; } - err = ompi_request_wait_all (rsize, reqs, MPI_STATUSES_IGNORE); + err = ompi_request_wait_all (rsize, comm->c_coll_basic_data->mccb_reqs, + MPI_STATUSES_IGNORE); if ( OMPI_SUCCESS != err ) { goto exit; } diff --git a/src/mca/coll/basic/coll_basic_scatter.c b/src/mca/coll/basic/coll_basic_scatter.c index 019acb9600..28308fb514 100644 --- a/src/mca/coll/basic/coll_basic_scatter.c +++ b/src/mca/coll/basic/coll_basic_scatter.c @@ -135,7 +135,8 @@ int mca_coll_basic_scatter_inter(void *sbuf, int scount, } } - err = ompi_request_wait_all (size, reqs, MPI_STATUSES_IGNORE); + err = ompi_request_wait_all (size, comm->c_coll_basic_data->mccb_reqs, + MPI_STATUSES_IGNORE); } return err;