Class astutedds::dcps::Requester

ClassList > astutedds > dcps > Requester

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

• #include <dcps.hpp>

Public Functions

Type	Name
	Requester (DomainParticipant * participant, const std::string & service_name, const std::string & request_type_name, const std::string & reply_type_name, const RequesterQos & qos)
	Requester (const Requester &) = delete
const std::array< uint8_t, 16 > &	gid () const Stable 16-byte GID for this requester (used in header + filter).
Requester &	operator= (const Requester &) = delete
DataReader *	reply_reader () const Underlying reply DataReader — useful for listener attachment.
DataWriter *	request_writer () const Underlying request DataWriter — useful for listener attachment.
int64_t	send_request (const std::vector< uint8_t > & payload)
const std::string &	service_name () const The service name (unqualified — without the rq/…Request suffix).
std::optional< TakenReply >	take_reply ()
	~Requester ()

Detailed Description

Owned by DomainParticipant; do not construct directly — use DomainParticipant::create_requester(). Internally owns one DataWriter on rq/<service>Request and one DataReader on rr/<service>Reply, plus their Topic + Publisher/Subscriber.

Public Functions Documentation

function Requester [1/2]

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

---

function Requester [2/2]

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

---

function gid

Stable 16-byte GID for this requester (used in header + filter).

inline const std::array< uint8_t, 16 > & astutedds::dcps::Requester::gid () const

---

function operator=

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

---

function reply_reader

Underlying reply DataReader — useful for listener attachment.

inline DataReader * astutedds::dcps::Requester::reply_reader () const

---

function request_writer

Underlying request DataWriter — useful for listener attachment.

inline DataWriter * astutedds::dcps::Requester::request_writer () const

---

function send_request

int64_t astutedds::dcps::Requester::send_request (
    const std::vector< uint8_t > & payload
) 

Send a request. Prepends the 24-byte header (my GID + auto-seq). Returns the sequence number assigned, or 0 on failure.

---

function service_name

The service name (unqualified — without the rq/…Request suffix).

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

---

function take_reply

std::optional< TakenReply > astutedds::dcps::Requester::take_reply () 

Take the next reply addressed to this requester. Skips replies belonging to other requesters on the same service.

---

function ~Requester

astutedds::dcps::Requester::~Requester () 

---

---

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