File MpiWorldRegistry.h

namespace faabric

namespace mpi

class MpiWorldRegistry

Public Functions

MpiWorldRegistry() = default

MpiWorld &createWorld(faabric::Message &msg, int worldId, std::string hostOverride = "")

MpiWorld &getOrInitialiseWorld(faabric::Message &msg)

MpiWorld &getWorld(int worldId)

bool worldExists(int worldId)

void clearWorld(int worldId)

void clear()

Private Members

faabric::util::ConcurrentMap<int, std::shared_ptr<MpiWorld>> worldMap