Class RPCData

Defined in File rpc_data.hpp

Class Documentation

class RPCData

Public Functions

RPCData(RPCData const&) = delete

void operator=(RPCData const&) = delete

margo_instance *server_rpc_mid()

void server_rpc_mid(margo_instance *server_rpc_mid)

margo_instance *proxy_server_rpc_mid()

void proxy_server_rpc_mid(margo_instance *client_rpc_mid)

margo_instance *client_rpc_mid()

void client_rpc_mid(margo_instance *client_rpc_mid)

margo_client_ids &rpc_client_ids()

std::map<uint64_t, hg_addr_t> &rpc_endpoints()

void rpc_endpoints(const std::map<uint64_t, hg_addr_t> &rpc_endpoints)

uint64_t hosts_size() const

void hosts_size(uint64_t hosts_size)

uint64_t local_host_id() const

void local_host_id(uint64_t local_host_id)

ABT_pool io_pool() const

void io_pool(ABT_pool io_pool)

std::vector<ABT_xstream> &io_streams()

void io_streams(const std::vector<ABT_xstream> &io_streams)

const std::string &self_addr_str() const

void self_addr_str(const std::string &addr_str)

const std::string &self_proxy_addr_str() const

void self_proxy_addr_str(const std::string &proxy_addr_str)

const std::shared_ptr<gkfs::rpc::Distributor> &distributor() const

void distributor(const std::shared_ptr<gkfs::rpc::Distributor> &distributor)

Public Static Functions

static inline RPCData *getInstance()

Private Functions

inline RPCData()

Private Members

margo_instance_id server_rpc_mid_

margo_instance_id proxy_server_rpc_mid_

margo_instance_id client_rpc_mid_

margo_client_ids rpc_client_ids_ = {}

std::map<uint64_t, hg_addr_t> rpc_endpoints_

uint64_t hosts_size_

uint64_t local_host_id_

ABT_pool io_pool_

std::vector<ABT_xstream> io_streams_

std::string self_addr_str_

std::string self_proxy_addr_str_

std::shared_ptr<gkfs::rpc::Distributor> distributor_