Skip to content

examples/looks_like_mpi: Fix build errors #468

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Oct 21, 2025
Merged

examples/looks_like_mpi: Fix build errors #468

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1357a89
examples/looks_like_mpi: fix functions without return statements
jackbondpreston-arm May 9, 2025
d72f3a6
examples/looks_like_mpi: use updated shared_ptr Store API
jackbondpreston-arm Oct 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 12 additions & 2 deletions gloo/examples/looks_like_mpi.cc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@ std::shared_ptr<gloo::Context> kContext;
using MPI_Comm = int;
const MPI_Comm MPI_COMM_WORLD = 0;

static constexpr int MPI_SUCCESS = 0;

enum MPI_Datatype {
MPI_INT,
};
Expand All @@ -44,6 +46,7 @@ int MPI_Comm_rank(MPI_Comm comm, int* rank) {
if (rank) {
*rank = kContext->rank;
}
return MPI_SUCCESS;
}

// Same prototype as MPI API.
Expand All @@ -52,13 +55,15 @@ int MPI_Comm_size(MPI_Comm comm, int* size) {
if (size) {
*size = kContext->size;
}
return MPI_SUCCESS;
}

// Same prototype as MPI API.
int MPI_Barrier(MPI_Comm comm) {
ASSERT(comm == MPI_COMM_WORLD);
gloo::BarrierOptions opts(kContext);
gloo::barrier(opts);
return MPI_SUCCESS;
}

// Same prototype
Expand All @@ -79,6 +84,7 @@ int MPI_Allreduce(
static_cast<void (*)(void*, const void*, const void*, size_t)>(
&gloo::sum<int>));
gloo::allreduce(opts);
return MPI_SUCCESS;
}

// Actual prototype:
Expand All @@ -101,6 +107,7 @@ int MPI_Recv(void* buf, ssize_t bytes, int source, int tag, MPI_Comm comm) {
auto ubuf = kContext->createUnboundBuffer(buf, bytes);
ubuf->recv(source, tag);
ubuf->waitRecv();
return MPI_SUCCESS;
}

// Actual prototype:
Expand All @@ -126,6 +133,7 @@ int MPI_Send(
auto ubuf = kContext->createUnboundBuffer(const_cast<void*>(cbuf), bytes);
ubuf->send(dest, tag);
ubuf->waitSend();
return MPI_SUCCESS;
}

// Entrypoint of this example.
Expand Down Expand Up @@ -165,6 +173,7 @@ int run() {

// Barrier before exit
MPI_Barrier(MPI_COMM_WORLD);
return MPI_SUCCESS;
}

// See example1.cc in this directory for a walkthrough of initialization.
Expand All @@ -181,8 +190,9 @@ void init(const std::string& path) {
const int size = atoi(getenv("SIZE"));

// Initialize store
auto fileStore = gloo::rendezvous::FileStore(path);
auto prefixStore = gloo::rendezvous::PrefixStore(prefix, fileStore);
auto fileStore = std::make_shared<gloo::rendezvous::FileStore>(path);
auto prefixStore =
std::make_shared<gloo::rendezvous::PrefixStore>(prefix, fileStore);

// Initialize device
gloo::transport::tcp::attr attr;
Expand Down
Loading