#include "colls_private.h"
#include "coll_tuned_topo.h"
-#define MCA_COLL_BASE_TAG_REDUCE 555
reqs[inbi]=smpi_mpi_irecv(local_recvbuf, recvcount, datatype,
tree->tree_next[i],
- MCA_COLL_BASE_TAG_REDUCE, comm
+ COLL_TAG_REDUCE, comm
);
}
/* wait for previous req to complete, if any.
/* send combined/accumulated data to parent */
smpi_mpi_send( accumulator, prevcount,
datatype, tree->tree_prev,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm);
}
segindex * segment_increment,
count_by_segment, datatype,
tree->tree_prev,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm) ;
segindex++;
original_count -= count_by_segment;
segindex * segment_increment,
count_by_segment, datatype,
tree->tree_prev,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm);
original_count -= count_by_segment;
}
segindex * segment_increment,
count_by_segment, datatype,
tree->tree_prev,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm );
creq = (creq + 1) % max_outstanding_reqs;
segindex++;
if (root == rank) {
/* Receive result from rank io_root to recvbuf */
smpi_mpi_recv(recvbuf, count, datatype, io_root,
- MCA_COLL_BASE_TAG_REDUCE, comm,
+ COLL_TAG_REDUCE, comm,
MPI_STATUS_IGNORE);
if (MPI_IN_PLACE == sendbuf) {
free(use_this_sendbuf);
} else if (io_root == rank) {
/* Send result from use_this_recvbuf to root */
smpi_mpi_send(use_this_recvbuf, count, datatype, root,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm);
free(use_this_recvbuf);
}
if (rank != root) {
smpi_mpi_send(sbuf, count, dtype, root,
- MCA_COLL_BASE_TAG_REDUCE,
+ COLL_TAG_REDUCE,
comm);
return -1;
}
smpi_datatype_copy((char*)sbuf, count, dtype,(char*)rbuf, count, dtype);
} else {
smpi_mpi_recv(rbuf, count, dtype, size - 1,
- MCA_COLL_BASE_TAG_REDUCE, comm,
+ COLL_TAG_REDUCE, comm,
MPI_STATUS_IGNORE);
}
inbuf = (char*)sbuf;
} else {
smpi_mpi_recv(pml_buffer, count, dtype, i,
- MCA_COLL_BASE_TAG_REDUCE, comm,
+ COLL_TAG_REDUCE, comm,
MPI_STATUS_IGNORE);
inbuf = pml_buffer;
}