/* Asynchronous parts of the basic collective algorithms, meant to be used both for the naive default implementation, but also for non blocking collectives */
-/* Copyright (c) 2009-2019. The SimGrid Team. All rights reserved. */
+/* Copyright (c) 2009-2021. The SimGrid Team. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
namespace simgrid{
namespace smpi{
-
-int Colls::ibarrier(MPI_Comm comm, MPI_Request* request, int external)
+int colls::ibarrier(MPI_Comm comm, MPI_Request* request, int external)
{
int size = comm->size();
int rank = comm->rank();
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if (rank > 0) {
- MPI_Request* requests = new MPI_Request[2];
+ auto* requests = new MPI_Request[2];
requests[0] = Request::isend (nullptr, 0, MPI_BYTE, 0,
system_tag,
comm);
(*request)->set_nbc_requests(requests, 2);
}
else {
- MPI_Request* requests = new MPI_Request[(size - 1) * 2];
+ auto* 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, system_tag, comm);
requests[i] = Request::isend(nullptr, 0, MPI_BYTE, (i + 1) / 2, system_tag, comm);
return MPI_SUCCESS;
}
-int Colls::ibcast(void *buf, int count, MPI_Datatype datatype, int root, MPI_Comm comm, MPI_Request* request, int external)
+int colls::ibcast(void* buf, int count, MPI_Datatype datatype, int root, MPI_Comm comm, MPI_Request* request,
+ int external)
{
int size = comm->size();
int rank = comm->rank();
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if (rank != root) {
- MPI_Request* requests = new MPI_Request[1];
+ auto* requests = new MPI_Request[1];
requests[0] = Request::irecv (buf, count, datatype, root,
system_tag,
comm);
(*request)->set_nbc_requests(requests, 1);
}
else {
- MPI_Request* requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int n = 0;
for (int i = 0; i < size; i++) {
if(i!=root){
return MPI_SUCCESS;
}
-int Colls::iallgather(const void *sendbuf, int sendcount, MPI_Datatype sendtype,
- void *recvbuf,int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iallgather(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount,
+ MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_ALLGATHER-external;
Datatype::copy(sendbuf, sendcount, sendtype, static_cast<char *>(recvbuf) + rank * recvcount * recvext, recvcount,
recvtype);
// Send/Recv buffers to/from others;
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
for (int other = 0; other < size; other++) {
if(other != rank) {
return MPI_SUCCESS;
}
-int Colls::iscatter(const void *sendbuf, int sendcount, MPI_Datatype sendtype,
- void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iscatter(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount,
+ MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_SCATTER-external;
MPI_Aint lb = 0;
(*request) = new Request( nullptr, 0, MPI_BYTE,
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
- MPI_Request* requests = new MPI_Request[1];
+ auto* 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
- MPI_Request* requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for(int dst = 0; dst < size; dst++) {
if(dst != root) {
return MPI_SUCCESS;
}
-int Colls::iallgatherv(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf,
- const int *recvcounts, const int *displs, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iallgatherv(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, const int* recvcounts,
+ const int* displs, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_ALLGATHERV-external;
MPI_Aint lb = 0;
Datatype::copy(sendbuf, sendcount, sendtype,
static_cast<char *>(recvbuf) + displs[rank] * recvext,recvcounts[rank], recvtype);
// Send buffers to others;
- MPI_Request *requests = new MPI_Request[2 * (size - 1)];
+ auto* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
for (int other = 0; other < size; other++) {
if(other != rank) {
return MPI_SUCCESS;
}
-int Colls::ialltoall( const void *sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external){
+int colls::ialltoall(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount,
+ MPI_Datatype recvtype, MPI_Comm comm, MPI_Request* request, int external)
+{
int system_tag = COLL_TAG_ALLTOALL-external;
MPI_Aint lb = 0;
MPI_Aint sendext = 0;
static_cast<char *>(recvbuf) + rank * recvcount * recvext, recvcount, recvtype);
if (err == MPI_SUCCESS && size > 1) {
/* Initiate all send/recv to/from others. */
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* requests = new MPI_Request[2 * (size - 1)];
/* Post all receives first -- a simple optimization */
int count = 0;
for (int i = (rank + 1) % size; i != rank; i = (i + 1) % size) {
return MPI_SUCCESS;
}
-int Colls::ialltoallv(const void *sendbuf, const int *sendcounts, const int *senddisps, MPI_Datatype sendtype,
- void *recvbuf, const int *recvcounts, const int *recvdisps, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request, int external){
+int colls::ialltoallv(const void* sendbuf, const int* sendcounts, const int* senddisps, MPI_Datatype sendtype,
+ void* recvbuf, const int* recvcounts, const int* recvdisps, MPI_Datatype recvtype, MPI_Comm comm,
+ MPI_Request* request, int external)
+{
const int system_tag = COLL_TAG_ALLTOALLV-external;
MPI_Aint lb = 0;
MPI_Aint sendext = 0;
static_cast<char *>(recvbuf) + recvdisps[rank] * recvext, recvcounts[rank], recvtype);
if (err == MPI_SUCCESS && size > 1) {
/* Initiate all send/recv to/from others. */
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* 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) {
return err;
}
-int Colls::ialltoallw(const void *sendbuf, const int *sendcounts, const int *senddisps, const MPI_Datatype* sendtypes,
- void *recvbuf, const int *recvcounts, const int *recvdisps, const MPI_Datatype* recvtypes, MPI_Comm comm, MPI_Request *request, int external){
+int colls::ialltoallw(const void* sendbuf, const int* sendcounts, const int* senddisps, const MPI_Datatype* sendtypes,
+ void* recvbuf, const int* recvcounts, const int* recvdisps, const MPI_Datatype* recvtypes,
+ MPI_Comm comm, MPI_Request* request, int external)
+{
const int system_tag = COLL_TAG_ALLTOALLW-external;
/* Initialize. */
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. */
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* 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) {
return err;
}
-int Colls::igather(const void *sendbuf, int sendcount, MPI_Datatype sendtype,
- void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external)
+int colls::igather(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount,
+ MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_GATHER-external;
MPI_Aint lb = 0;
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
// Send buffer to root
- MPI_Request* requests = new MPI_Request[1];
+ auto* 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
- MPI_Request* requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int src = 0; src < size; src++) {
if(src != root) {
return MPI_SUCCESS;
}
-int Colls::igatherv(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, const int *recvcounts, const int *displs,
- MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external)
+int colls::igatherv(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, const int* recvcounts,
+ const int* displs, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request* request,
+ int external)
{
int system_tag = COLL_TAG_GATHERV-external;
MPI_Aint lb = 0;
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if (rank != root) {
// Send buffer to root
- MPI_Request* requests = new MPI_Request[1];
+ auto* 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
- MPI_Request* requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int src = 0; src < size; src++) {
if(src != root) {
}
return MPI_SUCCESS;
}
-int Colls::iscatterv(const void *sendbuf, const int *sendcounts, const int *displs, MPI_Datatype sendtype, void *recvbuf, int recvcount,
- MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external)
+int colls::iscatterv(const void* sendbuf, const int* sendcounts, const int* displs, MPI_Datatype sendtype,
+ void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request* request,
+ int external)
{
int system_tag = COLL_TAG_SCATTERV-external;
MPI_Aint lb = 0;
rank,rank, system_tag, comm, MPI_REQ_PERSISTENT);
if(rank != root) {
// Recv buffer from root
- MPI_Request* requests = new MPI_Request[1];
+ auto* requests = new MPI_Request[1];
requests[0]=Request::irecv(recvbuf, recvcount, recvtype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
sendtype, recvbuf, recvcount, recvtype);
}
// Send buffers to receivers
- MPI_Request *requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int dst = 0; dst < size; dst++) {
if (dst != root) {
return MPI_SUCCESS;
}
-int Colls::ireduce(const void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root,
- MPI_Comm comm, MPI_Request* request, int external)
+int colls::ireduce(const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root,
+ MPI_Comm comm, MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_REDUCE-external;
MPI_Aint lb = 0;
if(rank != root) {
// Send buffer to root
- MPI_Request* requests = new MPI_Request[1];
+ auto* requests = new MPI_Request[1];
requests[0] = Request::isend(real_sendbuf, count, datatype, root, system_tag, comm);
(*request)->set_nbc_requests(requests, 1);
} else {
if (real_sendbuf != nullptr && recvbuf != nullptr)
Datatype::copy(real_sendbuf, count, datatype, recvbuf, count, datatype);
// Receive buffers from senders
- MPI_Request *requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int src = 0; src < size; src++) {
if (src != root) {
return MPI_SUCCESS;
}
-int Colls::iallreduce(const void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype,
- MPI_Op op, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iallreduce(const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm,
+ MPI_Request* request, int external)
{
const int system_tag = COLL_TAG_ALLREDUCE-external;
// Local copy from self
Datatype::copy(sendbuf, count, datatype, recvbuf, count, datatype);
// Send/Recv buffers to/from others;
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
for (int other = 0; other < size; other++) {
if(other != rank) {
return MPI_SUCCESS;
}
-int Colls::iscan(const void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iscan(const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm,
+ MPI_Request* request, int external)
{
int system_tag = -888-external;
MPI_Aint lb = 0;
Datatype::copy(sendbuf, count, datatype, recvbuf, count, datatype);
// Send/Recv buffers to/from others
- MPI_Request *requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int other = 0; other < rank; other++) {
requests[index] = Request::irecv_init(smpi_get_tmp_sendbuffer(count * dataext), count, datatype, other, system_tag, comm);
return MPI_SUCCESS;
}
-int Colls::iexscan(const void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request* request, int external)
+int colls::iexscan(const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm,
+ MPI_Request* request, int external)
{
int system_tag = -888-external;
MPI_Aint lb = 0;
memset(recvbuf, 0, count*dataext);
// Send/Recv buffers to/from others
- MPI_Request *requests = new MPI_Request[size - 1];
+ auto* requests = new MPI_Request[size - 1];
int index = 0;
for (int other = 0; other < rank; other++) {
requests[index] = Request::irecv_init(smpi_get_tmp_sendbuffer(count * dataext), count, datatype, other, system_tag, comm);
return MPI_SUCCESS;
}
-int Colls::ireduce_scatter(const void *sendbuf, void *recvbuf, const int *recvcounts, MPI_Datatype datatype, MPI_Op op,
- MPI_Comm comm, MPI_Request* request, int external){
-//Version where each process performs the reduce for its own part. Alltoall pattern for comms.
+int colls::ireduce_scatter(const void* sendbuf, void* recvbuf, const int* recvcounts, MPI_Datatype datatype, MPI_Op op,
+ MPI_Comm comm, MPI_Request* request, int external)
+{
+ // Version where each process performs the reduce for its own part. Alltoall pattern for comms.
const int system_tag = COLL_TAG_REDUCE_SCATTER-external;
MPI_Aint lb = 0;
MPI_Aint dataext = 0;
datatype->extent(&lb, &dataext);
// Send/Recv buffers to/from others;
- MPI_Request* requests = new MPI_Request[2 * (size - 1)];
+ auto* requests = new MPI_Request[2 * (size - 1)];
int index = 0;
int recvdisp=0;
for (int other = 0; other < size; other++) {
