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