X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/70a1c67dc21179a44b0b317a1ea4823b63b7c666..50048ea494302c3030b44964627044c74a85a66c:/src/smpi/colls/allreduce-smp-rsag-lr.c diff --git a/src/smpi/colls/allreduce-smp-rsag-lr.c b/src/smpi/colls/allreduce-smp-rsag-lr.c index 6a928bc946..fa9296f2c8 100644 --- a/src/smpi/colls/allreduce-smp-rsag-lr.c +++ b/src/smpi/colls/allreduce-smp-rsag-lr.c @@ -164,10 +164,10 @@ int smpi_coll_tuned_allreduce_smp_rsag_lr(void *send_buf, void *recv_buf, - /* // INTER_binomial_reduce // only root node for each SMP + /* if (intra_rank == 0) { mask = 1; @@ -191,38 +191,35 @@ int smpi_coll_tuned_allreduce_smp_rsag_lr(void *send_buf, void *recv_buf, } */ - /* // INTER_binomial_bcast - if (intra_rank == 0) { - mask = 1; - while (mask < inter_comm_size) { - if (inter_rank & mask) { - src = (inter_rank - mask) * num_core; +// if (intra_rank == 0) { +// mask = 1; +// while (mask < inter_comm_size) { +// if (inter_rank & mask) { +// src = (inter_rank - mask) * num_core; //printf("Node %d recv from node %d when mask is %d\n", rank, src, mask); - smpi_mpi_recv(recv_buf, count, dtype, src, tag, comm, &status); - break; - } - mask <<= 1; - } - - mask >>= 1; +// smpi_mpi_recv(recv_buf, count, dtype, src, tag, comm, &status); +// break; +// } +// mask <<= 1; +// } +// +// mask >>= 1; //printf("My rank = %d my mask = %d\n", rank,mask); - while (mask > 0) { - if (inter_rank < inter_comm_size) { - dst = (inter_rank + mask) * num_core; - if (dst < comm_size) { - //printf("Node %d send to node %d when mask is %d\n", rank, dst, mask); - smpi_mpi_send(recv_buf, count, dtype, dst, tag, comm); - } - } - mask >>= 1; - } - } - */ - +// while (mask > 0) { +// if (inter_rank < inter_comm_size) { +// dst = (inter_rank + mask) * num_core; +// if (dst < comm_size) { +// //printf("Node %d send to node %d when mask is %d\n", rank, dst, mask); +// smpi_mpi_send(recv_buf, count, dtype, dst, tag, comm); +// } +// } +// mask >>= 1; +// } +// } // INTRA_binomial_bcast