X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bb1ec3ebdc8aad0b788cfded0ca9bf7b071a6721..004b932fe967a47a2ded3795af9dc069c3de9671:/src/smpi/colls/allgather-NTSLR-NB.cpp diff --git a/src/smpi/colls/allgather-NTSLR-NB.cpp b/src/smpi/colls/allgather-NTSLR-NB.cpp index cfb643f35b..7ae8569207 100644 --- a/src/smpi/colls/allgather-NTSLR-NB.cpp +++ b/src/smpi/colls/allgather-NTSLR-NB.cpp @@ -41,7 +41,7 @@ smpi_coll_tuned_allgather_NTSLR_NB(void *sbuf, int scount, MPI_Datatype stype, //copy a single segment from sbuf to rbuf send_offset = rank * scount * sextent; - smpi_mpi_sendrecv(sbuf, scount, stype, rank, tag, + Request::sendrecv(sbuf, scount, stype, rank, tag, (char *)rbuf + send_offset, rcount, rtype, rank, tag, comm, &status); @@ -51,15 +51,15 @@ smpi_coll_tuned_allgather_NTSLR_NB(void *sbuf, int scount, MPI_Datatype stype, //post all irecv first for (i = 0; i < size - 1; i++) { recv_offset = ((rank - i - 1 + size) % size) * increment; - rrequest_array[i] = smpi_mpi_irecv((char *)rbuf + recv_offset, rcount, rtype, from, tag + i, comm); + rrequest_array[i] = Request::irecv((char *)rbuf + recv_offset, rcount, rtype, from, tag + i, comm); } for (i = 0; i < size - 1; i++) { send_offset = ((rank - i + size) % size) * increment; - srequest_array[i] = smpi_mpi_isend((char *)rbuf + send_offset, scount, stype, to, tag + i, comm); - smpi_mpi_wait(&rrequest_array[i], &status); - smpi_mpi_wait(&srequest_array[i], &status2); + srequest_array[i] = Request::isend((char *)rbuf + send_offset, scount, stype, to, tag + i, comm); + Request::wait(&rrequest_array[i], &status); + Request::wait(&srequest_array[i], &status2); } free(rrequest_array);