X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/727c068cd59669e79c6779f9ff93ec4ac91f7522..a2f1b23687f04169144f4ffb4f20dc4fc5c28395:/src/smpi/colls/alltoall-ring.c diff --git a/src/smpi/colls/alltoall-ring.c b/src/smpi/colls/alltoall-ring.c index e5e4e2b84b..91976090bb 100644 --- a/src/smpi/colls/alltoall-ring.c +++ b/src/smpi/colls/alltoall-ring.c @@ -20,34 +20,34 @@ ****************************************************************************/ int -smpi_coll_tuned_alltoall_ring(void * send_buff, int send_count, MPI_Datatype send_type, - void * recv_buff, int recv_count, MPI_Datatype recv_type, - MPI_Comm comm) +smpi_coll_tuned_alltoall_ring(void *send_buff, int send_count, + MPI_Datatype send_type, void *recv_buff, + int recv_count, MPI_Datatype recv_type, + MPI_Comm comm) { MPI_Status s; MPI_Aint send_chunk, recv_chunk; int i, src, dst, rank, num_procs; - int tag = 1, success = 1; /*, failure = 0, pof2 = 1*/; + int tag = 1, success = 1; /*, failure = 0, pof2 = 1 */ ; + + char *send_ptr = (char *) send_buff; + char *recv_ptr = (char *) recv_buff; - char * send_ptr = (char *) send_buff; - char * recv_ptr = (char *) recv_buff; - MPI_Comm_rank(comm, &rank); MPI_Comm_size(comm, &num_procs); MPI_Type_extent(send_type, &send_chunk); MPI_Type_extent(recv_type, &recv_chunk); send_chunk *= send_count; - recv_chunk *= recv_count; - - for (i = 0; i < num_procs; i++) - { - src = (rank - i + num_procs) % num_procs; - dst = (rank + i) % num_procs; - - MPI_Sendrecv(send_ptr + dst * send_chunk, send_count, send_type, dst, - tag, recv_ptr + src * recv_chunk, recv_count, recv_type, - src, tag, comm, &s); - } + recv_chunk *= recv_count; + + for (i = 0; i < num_procs; i++) { + src = (rank - i + num_procs) % num_procs; + dst = (rank + i) % num_procs; + + MPI_Sendrecv(send_ptr + dst * send_chunk, send_count, send_type, dst, + tag, recv_ptr + src * recv_chunk, recv_count, recv_type, + src, tag, comm, &s); + } return success; }