X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/77bbf3027c4240a2e833209a3a3f186589da8577..72d32c4e88a57f4786f62fec48a1bfa454adbff9:/src/smpi/colls/alltoallv/alltoallv-pair-mpi-barrier.cpp diff --git a/src/smpi/colls/alltoallv/alltoallv-pair-mpi-barrier.cpp b/src/smpi/colls/alltoallv/alltoallv-pair-mpi-barrier.cpp index 98dac23fae..c901225e5c 100644 --- a/src/smpi/colls/alltoallv/alltoallv-pair-mpi-barrier.cpp +++ b/src/smpi/colls/alltoallv/alltoallv-pair-mpi-barrier.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2013-2017. The SimGrid Team. +/* Copyright (c) 2013-2022. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -24,16 +24,14 @@ phases, nodes in pair communicate their data. MPI barriers are inserted between each two phases. - * Auther: Ahmad Faraj + * Author: Ahmad Faraj ****************************************************************************/ -namespace simgrid{ -namespace smpi{ -int -Coll_alltoallv_pair_mpi_barrier::alltoallv(void *send_buff, int *send_counts, int *send_disps, - MPI_Datatype send_type, - void *recv_buff, int *recv_counts, int *recv_disps, - MPI_Datatype recv_type, MPI_Comm comm) +namespace simgrid::smpi { +int alltoallv__pair_mpi_barrier(const void *send_buff, const int *send_counts, const int *send_disps, + MPI_Datatype send_type, + void *recv_buff, const int *recv_counts, const int *recv_disps, + MPI_Datatype recv_type, MPI_Comm comm) { MPI_Status s; MPI_Aint send_chunk, recv_chunk; @@ -46,19 +44,18 @@ Coll_alltoallv_pair_mpi_barrier::alltoallv(void *send_buff, int *send_counts, in num_procs = comm->size(); if((num_procs&(num_procs-1))) - THROWF(arg_error,0, "alltoallv pair algorithm can't be used with non power of two number of processes ! "); + throw std::invalid_argument("alltoallv pair algorithm can't be used with non power of two number of processes!"); send_chunk = send_type->get_extent(); recv_chunk = recv_type->get_extent(); for (i = 0; i < num_procs; i++) { src = dst = rank ^ i; - Colls::barrier(comm); + colls::barrier(comm); Request::sendrecv(send_ptr + send_disps[dst] * send_chunk, send_counts[dst], send_type, dst, tag, recv_ptr + recv_disps[src] * recv_chunk, recv_counts[src], recv_type, src, tag, comm, &s); } return MPI_SUCCESS; } -} -} +} // namespace simgrid::smpi