File ExecGraph.cpp

Defines

EXEC_GRAPH_TIMEOUT_MS

namespace faabric

namespace util

Functions

ExecGraphNode getFunctionExecGraphNode(int appId, int msgId)

ExecGraph getFunctionExecGraph(const faabric::Message &msg)

void logChainedFunction(faabric::Message &parentMessage, const faabric::Message &chainedMessage)

std::set<unsigned int> getChainedFunctions(const faabric::Message &msg)

int countExecGraphNodes(const ExecGraph &graph)

std::set<std::string> getExecGraphHosts(const ExecGraph &graph)

std::vector<std::string> getMpiRankHostsFromExecGraph(const ExecGraph &graph)

std::pair<std::vector<std::string>, std::vector<std::string>> getMigratedMpiRankHostsFromExecGraph(const ExecGraph &graph)

std::string execNodeToJson(const ExecGraphNode &node)

std::string execGraphToJson(const ExecGraph &graph)

void addDetail(faabric::Message &msg, const std::string &key, const std::string &value)

void incrementCounter(faabric::Message &msg, const std::string &key, const int valueToIncrement = 1)

int countExecGraphNode(const ExecGraphNode &node)

std::set<std::string> getExecGraphHostsForNode(const ExecGraphNode &node)

std::vector<std::string> getMpiRankHostsFromExecGraphNode(const ExecGraphNode &node)