X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/40616078da72e823931c1fb884949054699ec39d..2807fde4fd1f59c230d69a934634c5dfb77905f2:/src/smpi/colls/alltoall/alltoall-rdb.cpp diff --git a/src/smpi/colls/alltoall/alltoall-rdb.cpp b/src/smpi/colls/alltoall/alltoall-rdb.cpp index 92a0722e7d..31e521f727 100644 --- a/src/smpi/colls/alltoall/alltoall-rdb.cpp +++ b/src/smpi/colls/alltoall/alltoall-rdb.cpp @@ -1,10 +1,11 @@ -/* Copyright (c) 2013-2014. The SimGrid Team. +/* Copyright (c) 2013-2017. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "../colls_private.h" +#include "../colls_private.hpp" +#include "smpi_status.hpp" /***************************************************************************** @@ -12,7 +13,7 @@ * Return: int - * inputs: + * inputs: send_buff: send input buffer send_count: number of elements to send send_type: data type of elements being sent @@ -24,10 +25,12 @@ * Descrp: Function realizes the allgather operation using the recursive doubling algorithm. - * Auther: MPICH / slightly modified by Ahmad Faraj. + * Auther: MPICH / slightly modified by Ahmad Faraj. ****************************************************************************/ -int smpi_coll_tuned_alltoall_rdb(void *send_buff, int send_count, +namespace simgrid{ +namespace smpi{ +int Coll_alltoall_rdb::alltoall(void *send_buff, int send_count, MPI_Datatype send_type, void *recv_buff, int recv_count, MPI_Datatype recv_type, MPI_Comm comm) @@ -78,7 +81,7 @@ int smpi_coll_tuned_alltoall_rdb(void *send_buff, int send_count, tmp_buff + recv_offset, mask * recv_count * num_procs, recv_type, dst, tag, comm, &status); - last_recv_count = smpi_mpi_get_count(&status, recv_type); + last_recv_count = Status::get_count(&status, recv_type); curr_size += last_recv_count; } @@ -131,7 +134,7 @@ int smpi_coll_tuned_alltoall_rdb(void *send_buff, int send_count, mask * num_procs * send_count, send_type, dst, tag, comm, &status); - last_recv_count = smpi_mpi_get_count(&status, send_type); + last_recv_count = Status::get_count(&status, send_type); curr_size += last_recv_count; } @@ -152,3 +155,5 @@ int smpi_coll_tuned_alltoall_rdb(void *send_buff, int send_count, smpi_free_tmp_buffer(tmp_buff); return MPI_SUCCESS; } +} +}