CoreDX Data Distribution Service
The High Performance, Small Footprint DDS from Twin Oaks Computing, Inc
|
Public Member Functions | |
Replier (ReplierParams r_params) | |
void | close () |
bool | is_null () |
void | send_reply (TRep reply, SampleIdentity_t related_request_id) |
bool | receive_request (Sample< TReq > request, Duration_t max_wait) |
LoanedSamples< TReq > | receive_requests (Duration_t max_wait) |
LoanedSamples< TReq > | receive_requests (int min_request_count, int max_request_count, Duration_t max_wait) |
bool | wait_for_requests (Duration_t max_wait) |
bool | wait_for_requests (int min_count, Duration_t max_wait) |
bool | take_request (Sample< TReq > request) |
LoanedSamples< TReq > | take_requests (int max_samples) |
bool | read_request (Sample< TReq > request) |
LoanedSamples< TReq > | read_requests (int max_samples) |
ReplierParams | get_replier_params () |
bool | receive_nondata_samples (bool enable) |
DataReaderI< TReq > | get_request_datareader () |
DataWriterI< TRep > | get_reply_datawriter () |
A replier receives requests and send replies.
An instance of Replier is configured at the time of construction using ReplierParams, which is a container of configuration parameters such as domain participant, QoS, listeners and more.
Replier allows listener-based and polling-based reception of requests.
SimpleReplierListener and ReplierListener interfaces enable call-back based notification when a request is available. On the other hand, Replier provides functions to allow polling reception of requests.
TReq | : | RequestType | |
TReq | : | new() | |
TRep | : | ReplyType | |
TRep | : | new() |
|
inline |
Constructor that accepts ReplierParams configuration.
|
inline |
|
inline |
Access the ReplierParams values that define the configuration of the Replier.
|
inline |
Access the underlying DataWriter used to send Replies.
|
inline |
Access the underlying DataReader used to receive Requests.
|
inline |
|
inline |
Attempt to access the next request.
This may will block until a request is available.
true | if able to access a request. |
false | otherwise |
|
inline |
Attempt to access up to 'max_samples' requests.
This call may block if no requests are available.
collection | of requests |
|
inline |
Toggle the underlying entities to deliver non-data samples to the application
|
inline |
Attempt to access the next request.
This may block for up to 'max_wait' if no request is immediately available.
|
inline |
Attempt to access any available requests.
This may block for up to 'max_wait' if no requests are immediately available.
|
inline |
Attempt to access up to 'max_request_count' requests.
This may block for up to 'max_wait' if there are not at least 'min_request_count' requests immediately available.
|
inline |
Sends the provided 'reply' associated with 'related_request_id'.
|
inline |
Attempt to access the next request.
This call will not block.
true | if able to access a request. |
false | otherwise |
|
inline |
Attempt to access up to 'max_samples' requests.
This call will not block.
collection | of requests (possibly empty) |
|
inline |
Block until at least one request is available.
This may block for up to 'max_wait'.
|
inline |
Block until at least 'min_count requests available.
This may block for up to 'max_wait'.