Class astutedds::dcps::Replier

ClassList > astutedds > dcps > Replier

Service-side RPC endpoint (reads requests, writes replies).

  • #include <dcps.hpp>

Public Functions

Type Name
Replier (DomainParticipant * participant, const std::string & service_name, const std::string & request_type_name, const std::string & reply_type_name, const ReplierQos & qos)
Replier (const Replier &) = delete
Replier & operator= (const Replier &) = delete
DataWriter * reply_writer () const
DataReader * request_reader () const
bool send_reply (const std::array< uint8_t, 16 > & client_gid, int64_t sequence_number, const std::vector< uint8_t > & payload)
const std::string & service_name () const
std::optional< TakenRequest > take_request ()
~Replier ()

Public Functions Documentation

function Replier [1/2]

astutedds::dcps::Replier::Replier (
    DomainParticipant * participant,
    const std::string & service_name,
    const std::string & request_type_name,
    const std::string & reply_type_name,
    const ReplierQos & qos
) 

function Replier [2/2]

astutedds::dcps::Replier::Replier (
    const Replier &
) = delete

function operator=

Replier & astutedds::dcps::Replier::operator= (
    const Replier &
) = delete

function reply_writer

inline DataWriter * astutedds::dcps::Replier::reply_writer () const

function request_reader

inline DataReader * astutedds::dcps::Replier::request_reader () const

function send_reply

bool astutedds::dcps::Replier::send_reply (
    const std::array< uint8_t, 16 > & client_gid,
    int64_t sequence_number,
    const std::vector< uint8_t > & payload
) 

Send a reply. Prepends the 24-byte header using the caller- supplied GID + sequence number (typically echoed from a previously-taken TakenRequest).


function service_name

inline const std::string & astutedds::dcps::Replier::service_name () const

function take_request

std::optional< TakenRequest > astutedds::dcps::Replier::take_request () 

Take the next request. Header is stripped and its GID + sequence number are returned in the TakenRequest struct.


function ~Replier

astutedds::dcps::Replier::~Replier () 


The documentation for this class was generated from the following file include/astutedds/dcps/dcps.hpp