#include "../colls_private.h"
+namespace simgrid{
+namespace smpi{
static int scatter_for_bcast(
int root,
recv_size, MPI_BYTE, src,
COLL_TAG_BCAST, comm, &status);
/* query actual size of data received */
- curr_size=smpi_mpi_get_count(&status, MPI_BYTE);
+ curr_size=Status::get_count(&status, MPI_BYTE);
}
break;
}
return mpi_errno;
}
+
int
Coll_bcast_scatter_rdb_allgather::bcast (
void *buffer,
((char *)tmp_buf + recv_offset),
(nbytes-recv_offset < 0 ? 0 : nbytes-recv_offset),
MPI_BYTE, dst, COLL_TAG_BCAST, comm, &status);
- recv_size=smpi_mpi_get_count(&status, MPI_BYTE);
+ recv_size=Status::get_count(&status, MPI_BYTE);
curr_size += recv_size;
}
comm, &status);
/* nprocs_completed is also equal to the no. of processes
whose data we don't have */
- recv_size=smpi_mpi_get_count(&status, MPI_BYTE);
+ recv_size=Status::get_count(&status, MPI_BYTE);
curr_size += recv_size;
/* printf("Rank %d, recv from %d, offset %d, size %d\n", rank, dst, offset, recv_size);
fflush(stdout);*/
/* xbt_free(tmp_buf);*/
return mpi_errno;
}
+
+}
+}