welcome simgrid::smpi::Request

[simgrid.git] / 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 cfb643f..7ae8569 100644 (file)
--- 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);