mcx::comm::RequestReply

mcx::comm::RequestReply

Inherits from mcx::comm::BaseRequestReply

Public Functions

Name
RequestReply(ProtocolType protocol_type =ProtocolType::SINGLE_TIMESTAMP)
RequestReply(const RequestReply & orig) =delete
~RequestReply() override
bool addRPCProcessor(const char * name, RPCProcessor * rpc_processor, bool force =false)
bool configure(parameter_server::Parameter * root, const std::string & path)
bool start(const ConnectionData & conn_data)
void iterate(unsigned int timeout_micro_s =50)
void stop()

Public Attributes

Name
nng_listener listener
nng_dialer dialer

Additional inherited members

Public Functions inherited from mcx::comm::BaseRequestReply

Name
BaseRequestReply(ProtocolType protocol_type)
ProtocolType getProtocolType() const
const GroupManager & getGroupManager() const
virtual ~BaseRequestReply() =default

Protected Attributes inherited from mcx::comm::BaseRequestReply

Name
ProtocolType protocol_type_
GroupManager group_manager_

Public Functions Documentation

function RequestReply

explicit RequestReply(
    ProtocolType protocol_type =ProtocolType::SINGLE_TIMESTAMP
)

function RequestReply

RequestReply(
    const RequestReply & orig
) =delete

function ~RequestReply

~RequestReply() override

function addRPCProcessor

bool addRPCProcessor(
    const char * name,
    RPCProcessor * rpc_processor,
    bool force =false
)

function configure

bool configure(
    parameter_server::Parameter * root,
    const std::string & path
)

function start

bool start(
    const ConnectionData & conn_data
)

function iterate

void iterate(
    unsigned int timeout_micro_s =50
)

function stop

void stop()

Public Attributes Documentation

variable listener

nng_listener listener;

variable dialer

nng_dialer dialer;

Updated on 2022-04-05 at 16:21:26 +0200