Struct faabric::mpi::MpiRankState

struct MpiRankState

Public Functions

inline void reset()

Public Members

int msgCount = 1

faabric::Message *msg = nullptr

std::vector<std::unique_ptr<std::list<MpiMessage>>> unackedMessageBuffers

std::unique_ptr<faabric::util::FaabricCpuSet> pinnedCpu

std::vector<std::unique_ptr<faabric::transport::tcp::SendSocket>> sendSockets

std::unique_ptr<faabric::transport::tcp::RecvSocket> recvSocket

std::vector<int> recvConnPool