int Colls::ibarrier(MPI_Comm comm, MPI_Request* request)
{
- int i;
int size = comm->size();
int rank = comm->rank();
- MPI_Request* requests;
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, COLL_TAG_BARRIER, comm, MPI_REQ_PERSISTENT);
if (rank > 0) {
- requests = new MPI_Request[2];
+ MPI_Request* requests = new MPI_Request[2];
requests[0] = Request::isend (nullptr, 0, MPI_BYTE, 0,
COLL_TAG_BARRIER,
comm);
(*request)->set_nbc_requests(requests, 2);
}
else {
- requests = new MPI_Request[(size-1)*2];
- for (i = 1; i < 2*size-1; i+=2) {
- requests[i-1] = Request::irecv(nullptr, 0, MPI_BYTE, MPI_ANY_SOURCE,
- COLL_TAG_BARRIER, comm
- );
- requests[i] = Request::isend(nullptr, 0, MPI_BYTE, (i+1)/2,
- COLL_TAG_BARRIER,
- comm
- );
+ MPI_Request* requests = new MPI_Request[(size - 1) * 2];
+ for (int i = 1; i < 2 * size - 1; i += 2) {
+ requests[i - 1] = Request::irecv(nullptr, 0, MPI_BYTE, MPI_ANY_SOURCE, COLL_TAG_BARRIER, comm);
+ requests[i] = Request::isend(nullptr, 0, MPI_BYTE, (i + 1) / 2, COLL_TAG_BARRIER, comm);
}
(*request)->set_nbc_requests(requests, 2*(size-1));
}
int Colls::ibcast(void *buf, int count, MPI_Datatype datatype, int root, MPI_Comm comm, MPI_Request* request)
{
- int i;
int size = comm->size();
int rank = comm->rank();
- MPI_Request* requests;
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, COLL_TAG_BCAST, comm, MPI_REQ_PERSISTENT);
if (rank != root) {
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
requests[0] = Request::irecv (buf, count, datatype, root,
COLL_TAG_BCAST,
comm);
(*request)->set_nbc_requests(requests, 1);
}
else {
- requests = new MPI_Request[size-1];
+ MPI_Request* requests = new MPI_Request[size - 1];
int n = 0;
- for (i = 0; i < size; i++) {
+ for (int i = 0; i < size; i++) {
if(i!=root){
requests[n] = Request::isend(buf, count, datatype, i,
COLL_TAG_BCAST,
const int system_tag = COLL_TAG_ALLGATHER;
MPI_Aint lb = 0;
MPI_Aint recvext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
Datatype::copy(sendbuf, sendcount, sendtype, static_cast<char *>(recvbuf) + rank * recvcount * recvext, recvcount,
recvtype);
// Send/Recv buffers to/from others;
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
for (int other = 0; other < size; other++) {
if(other != rank) {
const int system_tag = COLL_TAG_SCATTER;
MPI_Aint lb = 0;
MPI_Aint sendext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
// Recv buffer from root
requests[0] = Request::irecv(recvbuf, recvcount, recvtype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
sendcount, sendtype, recvbuf, recvcount, recvtype);
}
// Send buffers to receivers
- requests = new MPI_Request[size - 1];
+ MPI_Request* requests = new MPI_Request[size - 1];
int index = 0;
for(int dst = 0; dst < size; dst++) {
if(dst != root) {
int Colls::ialltoall( void *sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request){
int system_tag = COLL_TAG_ALLTOALL;
- int i;
- int count;
MPI_Aint lb = 0, sendext = 0, recvext = 0;
- MPI_Request *requests;
/* Initialize. */
int rank = comm->rank();
static_cast<char *>(recvbuf) + rank * recvcount * recvext, recvcount, recvtype);
if (err == MPI_SUCCESS && size > 1) {
/* Initiate all send/recv to/from others. */
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
/* Post all receives first -- a simple optimization */
- count = 0;
- for (i = (rank + 1) % size; i != rank; i = (i + 1) % size) {
+ int count = 0;
+ for (int i = (rank + 1) % size; i != rank; i = (i + 1) % size) {
requests[count] = Request::irecv_init(static_cast<char *>(recvbuf) + i * recvcount * recvext, recvcount,
recvtype, i, system_tag, comm);
count++;
* when messages actually arrive in the order in which they were posted.
* TODO: check the previous assertion
*/
- for (i = (rank + size - 1) % size; i != rank; i = (i + size - 1) % size) {
+ for (int i = (rank + size - 1) % size; i != rank; i = (i + size - 1) % size) {
requests[count] = Request::isend_init(static_cast<char *>(sendbuf) + i * sendcount * sendext, sendcount,
sendtype, i, system_tag, comm);
count++;
MPI_Aint lb = 0;
MPI_Aint sendext = 0;
MPI_Aint recvext = 0;
- MPI_Request *requests;
/* Initialize. */
int rank = comm->rank();
static_cast<char *>(recvbuf) + recvdisps[rank] * recvext, recvcounts[rank], recvtype);
if (err == MPI_SUCCESS && size > 1) {
/* Initiate all send/recv to/from others. */
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
int count = 0;
/* Create all receives that will be posted first */
for (int i = 0; i < size; ++i) {
int Colls::ialltoallw(void *sendbuf, int *sendcounts, int *senddisps, MPI_Datatype* sendtypes,
void *recvbuf, int *recvcounts, int *recvdisps, MPI_Datatype* recvtypes, MPI_Comm comm, MPI_Request *request){
const int system_tag = COLL_TAG_ALLTOALLV;
- MPI_Request *requests;
/* Initialize. */
int rank = comm->rank();
static_cast<char *>(recvbuf) + recvdisps[rank], recvcounts[rank], recvtypes[rank]): MPI_SUCCESS;
if (err == MPI_SUCCESS && size > 1) {
/* Initiate all send/recv to/from others. */
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
int count = 0;
/* Create all receives that will be posted first */
for (int i = 0; i < size; ++i) {
const int system_tag = COLL_TAG_GATHER;
MPI_Aint lb = 0;
MPI_Aint recvext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
// Send buffer to root
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
requests[0]=Request::isend(sendbuf, sendcount, sendtype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
Datatype::copy(sendbuf, sendcount, sendtype, static_cast<char*>(recvbuf) + root * recvcount * recvext,
recvcount, recvtype);
// Receive buffers from senders
- requests = new MPI_Request[size - 1];
+ MPI_Request* requests = new MPI_Request[size - 1];
int index = 0;
for (int src = 0; src < size; src++) {
if(src != root) {
int system_tag = COLL_TAG_GATHERV;
MPI_Aint lb = 0;
MPI_Aint recvext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if (rank != root) {
// Send buffer to root
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
requests[0]=Request::isend(sendbuf, sendcount, sendtype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
Datatype::copy(sendbuf, sendcount, sendtype, static_cast<char*>(recvbuf) + displs[root] * recvext,
recvcounts[root], recvtype);
// Receive buffers from senders
- requests = new MPI_Request[size - 1];
+ MPI_Request* requests = new MPI_Request[size - 1];
int index = 0;
for (int src = 0; src < size; src++) {
if(src != root) {
int system_tag = COLL_TAG_SCATTERV;
MPI_Aint lb = 0;
MPI_Aint sendext = 0;
- MPI_Request* requests;
int rank = comm->rank();
int size = comm->size();
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
// Recv buffer from root
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
requests[0]=Request::irecv(recvbuf, recvcount, recvtype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
const int system_tag = COLL_TAG_REDUCE;
MPI_Aint lb = 0;
MPI_Aint dataext = 0;
- MPI_Request* requests;
char* sendtmpbuf = static_cast<char *>(sendbuf);
if(rank != root) {
// Send buffer to root
- requests = new MPI_Request[1];
+ MPI_Request* requests = new MPI_Request[1];
requests[0]=Request::isend(sendtmpbuf, count, datatype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
const int system_tag = COLL_TAG_ALLREDUCE;
MPI_Aint lb = 0;
MPI_Aint dataext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
// Local copy from self
Datatype::copy(sendbuf, count, datatype, recvbuf, count, datatype);
// Send/Recv buffers to/from others;
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
for (int other = 0; other < size; other++) {
if(other != rank) {
const int system_tag = COLL_TAG_REDUCE_SCATTER;
MPI_Aint lb = 0;
MPI_Aint dataext = 0;
- MPI_Request *requests;
int rank = comm->rank();
int size = comm->size();
datatype->extent(&lb, &dataext);
// Send/Recv buffers to/from others;
- requests = new MPI_Request[2 * (size - 1)];
+ MPI_Request* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
int recvdisp=0;
for (int other = 0; other < size; other++) {