X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/84637d5a56f373e75eb6619d1afb54b7da3f5e36..5089a0a98b27f5eeee62321dff4f025f1648f025:/src/smpi/colls/reduce_scatter/reduce_scatter-ompi.cpp diff --git a/src/smpi/colls/reduce_scatter/reduce_scatter-ompi.cpp b/src/smpi/colls/reduce_scatter/reduce_scatter-ompi.cpp index 905d637ccc..79f77d73b1 100644 --- a/src/smpi/colls/reduce_scatter/reduce_scatter-ompi.cpp +++ b/src/smpi/colls/reduce_scatter/reduce_scatter-ompi.cpp @@ -41,16 +41,15 @@ * Returns: - MPI_SUCCESS or error code * Limitation: - Works only for commutative operations. */ -namespace simgrid{ -namespace smpi{ -int -Coll_reduce_scatter_ompi_basic_recursivehalving::reduce_scatter(const void *sbuf, - void *rbuf, - const int *rcounts, - MPI_Datatype dtype, - MPI_Op op, - MPI_Comm comm - ) +namespace simgrid { +namespace smpi { +int reduce_scatter__ompi_basic_recursivehalving(const void *sbuf, + void *rbuf, + const int *rcounts, + MPI_Datatype dtype, + MPI_Op op, + MPI_Comm comm + ) { int i, rank, size, count, err = MPI_SUCCESS; int tmp_size = 1, remain = 0, tmp_rank; @@ -348,12 +347,11 @@ Coll_reduce_scatter_ompi_basic_recursivehalving::reduce_scatter(const void *sbuf * DONE :) * */ -int -Coll_reduce_scatter_ompi_ring::reduce_scatter(const void *sbuf, void *rbuf, const int *rcounts, - MPI_Datatype dtype, - MPI_Op op, - MPI_Comm comm - ) +int reduce_scatter__ompi_ring(const void *sbuf, void *rbuf, const int *rcounts, + MPI_Datatype dtype, + MPI_Op op, + MPI_Comm comm + ) { int ret, line, rank, size, i, k, recv_from, send_to, total_count, max_block_count; int inbi; @@ -441,7 +439,7 @@ Coll_reduce_scatter_ompi_ring::reduce_scatter(const void *sbuf, void *rbuf, cons - wait on block (r) - compute on block (r) - copy block (r) to rbuf - Note that we must be careful when computing the begining of buffers and + Note that we must be careful when computing the beginning of buffers and for send operations and computation we must compute the exact block size. */ send_to = (rank + 1) % size;