Struct astutedds::rtps::ReaderProxy

ClassList > astutedds > rtps > ReaderProxy

Model for a DDS DataReader endpoint to be announced via SEDP. More...

  • #include <endpoint_proxy.hpp>

Public Attributes

Type Name
dcps::DeadlineQosPolicy deadline
dcps::DestinationOrderQosPolicy destination_order
dcps::DurabilityQosPolicy durability
bool expectsInlineQos = {false}
Count_t heartbeatCount = {0}
dcps::HistoryQosPolicy history
SequenceNumber_t lastAcknowledgedSN = {0, 0}
std::chrono::steady_clock::time_point lastHeartbeatTime
dcps::LivelinessQosPolicy liveliness
LocatorList_t multicastLocatorList
dcps::OwnershipQosPolicy ownership
std::vector< std::string > partitions
dcps::PresentationQosPolicy presentation
GUID_t readerGuid = {}
dcps::ReliabilityQosPolicy reliability
dcps::DataRepresentationQosPolicy representation
std::set< uint32_t > requestedChanges
dcps::ResourceLimitsQosPolicy resource_limits
std::string topicName
std::string typeName
LocatorList_t unicastLocatorList

Public Functions

Type Name
std::vector< uint8_t > serialize_to_parameter_list () const
Serialize to SEDP parameter list payload.
void set_default_qos ()
Initialize with default interop-friendly QoS.

Detailed Description

Tracks state for a remote reader.

Contains all the information needed to generate a complete SEDP subscription announcement that will be accepted by other DDS implementations (RTI, OpenDDS, Cyclone, FastDDS).

Used by writers to track acknowledgments from each reader.

Public Attributes Documentation

variable deadline

dcps::DeadlineQosPolicy astutedds::rtps::ReaderProxy::deadline;

variable destination_order

dcps::DestinationOrderQosPolicy astutedds::rtps::ReaderProxy::destination_order;

variable durability

dcps::DurabilityQosPolicy astutedds::rtps::ReaderProxy::durability;

variable expectsInlineQos

bool astutedds::rtps::ReaderProxy::expectsInlineQos;

variable heartbeatCount

Count_t astutedds::rtps::ReaderProxy::heartbeatCount;

variable history

dcps::HistoryQosPolicy astutedds::rtps::ReaderProxy::history;

variable lastAcknowledgedSN

SequenceNumber_t astutedds::rtps::ReaderProxy::lastAcknowledgedSN;

variable lastHeartbeatTime

std::chrono::steady_clock::time_point astutedds::rtps::ReaderProxy::lastHeartbeatTime;

variable liveliness

dcps::LivelinessQosPolicy astutedds::rtps::ReaderProxy::liveliness;

variable multicastLocatorList

LocatorList_t astutedds::rtps::ReaderProxy::multicastLocatorList;

variable ownership

dcps::OwnershipQosPolicy astutedds::rtps::ReaderProxy::ownership;

variable partitions

std::vector<std::string> astutedds::rtps::ReaderProxy::partitions;

variable presentation

dcps::PresentationQosPolicy astutedds::rtps::ReaderProxy::presentation;

variable readerGuid

GUID_t astutedds::rtps::ReaderProxy::readerGuid;

variable reliability

dcps::ReliabilityQosPolicy astutedds::rtps::ReaderProxy::reliability;

variable representation

dcps::DataRepresentationQosPolicy astutedds::rtps::ReaderProxy::representation;

variable requestedChanges

std::set<uint32_t> astutedds::rtps::ReaderProxy::requestedChanges;

variable resource_limits

dcps::ResourceLimitsQosPolicy astutedds::rtps::ReaderProxy::resource_limits;

variable topicName

std::string astutedds::rtps::ReaderProxy::topicName;

variable typeName

std::string astutedds::rtps::ReaderProxy::typeName;

variable unicastLocatorList

LocatorList_t astutedds::rtps::ReaderProxy::unicastLocatorList;

Public Functions Documentation

function serialize_to_parameter_list

Serialize to SEDP parameter list payload.

inline std::vector< uint8_t > astutedds::rtps::ReaderProxy::serialize_to_parameter_list () const

Creates a complete parameter list suitable for SEDP subscription announcements. Includes all required PIDs for RTI interop.

Returns:

CDR-encoded parameter list (with encapsulation header)


function set_default_qos

Initialize with default interop-friendly QoS.

inline void astutedds::rtps::ReaderProxy::set_default_qos () 

Sets QoS values that are compatible with most DDS implementations: * BEST_EFFORT reliability

VOLATILE durability * KEEP_LAST history with depth 1



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