Class faabric::transport::PointToPointBroker

class PointToPointBroker

Public Functions

PointToPointBroker()

std::string getHostForReceiver(int groupId, int recvIdx)

int getMpiPortForReceiver(int groupId, int recvIdx)

std::set<std::string> setUpLocalMappingsFromSchedulingDecision(const faabric::batch_scheduler::SchedulingDecision &decision)

void setAndSendMappingsFromSchedulingDecision(const faabric::batch_scheduler::SchedulingDecision &decision)

void sendMappingsFromSchedulingDecision(const faabric::batch_scheduler::SchedulingDecision &decision, const std::set<std::string> &hostList)

void waitForMappingsOnThisHost(int groupId)

std::set<int> getIdxsRegisteredForGroup(int groupId)

std::set<std::string> getHostsRegisteredForGroup(int groupId)

void updateHostForIdx(int groupId, int groupIdx, std::string newHost)

void sendMessage(int groupId, int sendIdx, int recvIdx, const uint8_t *buffer, size_t bufferSize, std::string hostHint, bool mustOrderMsg = false)

void sendMessage(int groupId, int sendIdx, int recvIdx, const uint8_t *buffer, size_t bufferSize, bool mustOrderMsg = false, int sequenceNum = NO_SEQUENCE_NUM, std::string hostHint = "")

std::vector<uint8_t> recvMessage(int groupId, int sendIdx, int recvIdx, bool mustOrderMsg = false)

void clearGroup(int groupId)

void clear()

void resetThreadLocalCache()

void postMigrationHook(faabric::Message &msg)