mcx::comm::RequestReply
less than a minute
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