#include <assert.h>
#include "private.h"
-#include "smpi_coll_private.h"
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_coll, smpi,
"Logging specific to SMPI (coll)");
rank = smpi_comm_rank(comm);
/* wait for data from my parent in the tree */
if (!tree->isRoot) {
- DEBUG3("<%d> tree_bcast(): i am not root: recv from %d, tag=%d)",
+ XBT_DEBUG("<%d> tree_bcast(): i am not root: recv from %d, tag=%d)",
rank, tree->parent, system_tag + rank);
smpi_mpi_recv(buf, count, datatype, tree->parent, system_tag + rank,
comm, MPI_STATUS_IGNORE);
}
requests = xbt_new(MPI_Request, tree->numChildren);
- DEBUG2("<%d> creates %d requests (1 per child)", rank,
+ XBT_DEBUG("<%d> creates %d requests (1 per child)", rank,
tree->numChildren);
/* iniates sends to ranks lower in the tree */
for (i = 0; i < tree->numChildren; i++) {
if (tree->child[i] == -1) {
requests[i] = MPI_REQUEST_NULL;
} else {
- DEBUG3("<%d> send to <%d>, tag=%d", rank, tree->child[i],
+ XBT_DEBUG("<%d> send to <%d>, tag=%d", rank, tree->child[i],
system_tag + tree->child[i]);
requests[i] =
smpi_isend_init(buf, count, datatype, tree->child[i],
rank = smpi_comm_rank(comm);
// everyone sends to its parent, except root.
if (!tree->isRoot) {
- DEBUG3("<%d> tree_antibcast(): i am not root: send to %d, tag=%d)",
+ XBT_DEBUG("<%d> tree_antibcast(): i am not root: send to %d, tag=%d)",
rank, tree->parent, system_tag + rank);
smpi_mpi_send(buf, count, datatype, tree->parent, system_tag + rank,
comm);
}
//every one receives as many messages as it has children
requests = xbt_new(MPI_Request, tree->numChildren);
- DEBUG2("<%d> creates %d requests (1 per child)", rank,
+ XBT_DEBUG("<%d> creates %d requests (1 per child)", rank,
tree->numChildren);
for (i = 0; i < tree->numChildren; i++) {
if (tree->child[i] == -1) {
requests[i] = MPI_REQUEST_NULL;
} else {
- DEBUG3("<%d> recv from <%d>, tag=%d", rank, tree->child[i],
+ XBT_DEBUG("<%d> recv from <%d>, tag=%d", rank, tree->child[i],
system_tag + tree->child[i]);
requests[i] =
smpi_irecv_init(buf, count, datatype, tree->child[i],
// FIXME: check implementation
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
- DEBUG1("<%d> algorithm alltoall_bruck() called.", rank);
+ XBT_DEBUG("<%d> algorithm alltoall_bruck() called.", rank);
err = smpi_datatype_extent(sendtype, &lb, &sendextent);
err = smpi_datatype_extent(recvtype, &lb, &recvextent);
/* Local copy from self */
/* Create all receives that will be posted first */
for (i = 0; i < size; ++i) {
if (i == rank) {
- DEBUG3("<%d> skip request creation [src = %d, recvcount = %d]",
+ XBT_DEBUG("<%d> skip request creation [src = %d, recvcount = %d]",
rank, i, recvcount);
continue;
}
/* Now create all sends */
for (i = 0; i < size; ++i) {
if (i == rank) {
- DEBUG3("<%d> skip request creation [dst = %d, sendcount = %d]",
+ XBT_DEBUG("<%d> skip request creation [dst = %d, sendcount = %d]",
rank, i, sendcount);
continue;
}
}
/* Wait for them all. */
smpi_mpi_startall(count, requests);
- DEBUG2("<%d> wait for %d requests", rank, count);
+ XBT_DEBUG("<%d> wait for %d requests", rank, count);
smpi_mpi_waitall(count, requests, MPI_STATUS_IGNORE);
xbt_free(requests);
}
/* Initialize. */
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
- DEBUG1("<%d> algorithm alltoall_basic_linear() called.", rank);
+ XBT_DEBUG("<%d> algorithm alltoall_basic_linear() called.", rank);
err = smpi_datatype_extent(sendtype, &lb, &sendinc);
err = smpi_datatype_extent(recvtype, &lb, &recvinc);
sendinc *= sendcount;
}
/* Wait for them all. */
smpi_mpi_startall(count, requests);
- DEBUG2("<%d> wait for %d requests", rank, count);
+ XBT_DEBUG("<%d> wait for %d requests", rank, count);
smpi_mpi_waitall(count, requests, MPI_STATUS_IGNORE);
xbt_free(requests);
}
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
- DEBUG1("<%d> algorithm alltoall_pairwise() called.", rank);
+ XBT_DEBUG("<%d> algorithm alltoall_pairwise() called.", rank);
sendsize = smpi_datatype_size(sendtype);
recvsize = smpi_datatype_size(recvtype);
/* Perform pairwise exchange - starting from 1 so the local copy is last */
/* Initialize. */
rank = smpi_comm_rank(comm);
size = smpi_comm_size(comm);
- DEBUG1("<%d> algorithm basic_alltoallv() called.", rank);
+ XBT_DEBUG("<%d> algorithm basic_alltoallv() called.", rank);
err = smpi_datatype_extent(sendtype, &lb, &sendextent);
err = smpi_datatype_extent(recvtype, &lb, &recvextent);
/* Local copy from self */
/* Create all receives that will be posted first */
for (i = 0; i < size; ++i) {
if (i == rank || recvcounts[i] == 0) {
- DEBUG3
+ XBT_DEBUG
("<%d> skip request creation [src = %d, recvcounts[src] = %d]",
rank, i, recvcounts[i]);
continue;
/* Now create all sends */
for (i = 0; i < size; ++i) {
if (i == rank || sendcounts[i] == 0) {
- DEBUG3
+ XBT_DEBUG
("<%d> skip request creation [dst = %d, sendcounts[dst] = %d]",
rank, i, sendcounts[i]);
continue;
}
/* Wait for them all. */
smpi_mpi_startall(count, requests);
- DEBUG2("<%d> wait for %d requests", rank, count);
+ XBT_DEBUG("<%d> wait for %d requests", rank, count);
smpi_mpi_waitall(count, requests, MPI_STATUS_IGNORE);
xbt_free(requests);
}