File PointToPointBroker.cpp

Defines

NO_LOCK_OWNER_IDX

MAPPING_TIMEOUT_MS

NO_CURRENT_GROUP_ID

namespace faabric

namespace transport

Functions

PointToPointBroker &getPointToPointBroker()

static std::shared_ptr<PointToPointClient> getClient(const std::string &host)

std::string getPointToPointKey(int groupId, int sendIdx, int recvIdx)

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

auto getEndpointPtrs(const std::string &label)

Variables

static faabric::util::ConcurrentMap<int, std::shared_ptr<PointToPointGroup>> groups

static faabric::util::ConcurrentMap<std::string, std::shared_ptr<std::tuple<std::unique_ptr<AsyncInternalRecvMessageEndpoint>, std::unique_ptr<AsyncInternalSendMessageEndpoint>, std::atomic_int32_t>>> endpoints

thread_local absl::flat_hash_set<std::string> threadEndpoints

static faabric::util::ConcurrentMap<std::string, std::shared_ptr<PointToPointClient>> clients

thread_local int currentGroupId = NO_CURRENT_GROUP_ID

thread_local std::vector<int> sentMsgCount

thread_local std::vector<int> recvMsgCount

thread_local std::vector<std::list<Message>> outOfOrderMsgs