Class faabric::transport::PointToPointGroup

class PointToPointGroup

Public Functions

PointToPointGroup(int appId, int groupIdIn, int groupSizeIn, bool isSingleHostIn)

void lock(int groupIdx, bool recursive)

void unlock(int groupIdx, bool recursive)

int getLockOwner(bool recursive)

void localLock()

void localUnlock()

bool localTryLock()

void barrier(int groupIdx)

void notify(int groupIdx)

int getNotifyCount()

Public Static Functions

static std::shared_ptr<PointToPointGroup> getGroup(int groupId)

static std::shared_ptr<PointToPointGroup> getOrAwaitGroup(int groupId)

static bool groupExists(int groupId)

static void addGroup(int appId, int groupId, int groupSize, bool isSingleHost)

static void addGroupIfNotExists(int appId, int groupId, int groupSize)

static void clearGroup(int groupId)

static void clear()