X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/08e7455d67920bbd7a87f440d00f2c1e071314a0..49b53eb334bc6f19b530603201d00bcc312bfd29:/src/smpi/colls/bcast/bcast-scatter-rdb-allgather.cpp?ds=sidebyside diff --git a/src/smpi/colls/bcast/bcast-scatter-rdb-allgather.cpp b/src/smpi/colls/bcast/bcast-scatter-rdb-allgather.cpp index 8f2d24d9f5..70c043a52a 100644 --- a/src/smpi/colls/bcast/bcast-scatter-rdb-allgather.cpp +++ b/src/smpi/colls/bcast/bcast-scatter-rdb-allgather.cpp @@ -164,8 +164,7 @@ int bcast__scatter_rdb_allgather( position = 0; if (rank == root) { mpi_errno = datatype->pack(buffer, count, tmp_buf, nbytes, &position, comm); - if (mpi_errno) - xbt_die("crash while packing %d", mpi_errno); + xbt_assert(mpi_errno == 0, "crash while packing %d", mpi_errno); } } @@ -174,9 +173,7 @@ int bcast__scatter_rdb_allgather( mpi_errno = scatter_for_bcast(root, comm, nbytes, tmp_buf); - if (mpi_errno) { - xbt_die("crash while scattering %d", mpi_errno); - } + xbt_assert(mpi_errno == 0, "crash while scattering %d", mpi_errno); /* curr_size is the amount of data that this process now has stored in * buffer at byte offset (relative_rank*scatter_size) */ @@ -316,16 +313,13 @@ int bcast__scatter_rdb_allgather( /* check that we received as much as we expected */ /* recvd_size may not be accurate for packed heterogeneous data */ - if (is_homogeneous && curr_size != nbytes) { - xbt_die("we didn't receive enough !"); - } + xbt_assert(not is_homogeneous || curr_size == nbytes, "we didn't receive enough !"); if (not is_contig || not is_homogeneous) { if (rank != root) { position = 0; mpi_errno = MPI_Unpack(tmp_buf, nbytes, &position, buffer, count, datatype, comm); - if (mpi_errno) - xbt_die("error when unpacking %d", mpi_errno); + xbt_assert(mpi_errno == 0, "error when unpacking %d", mpi_errno); } }