Struct AstuteDDSSubscription

ClassList > AstuteDDSSubscription

More...

  • #include <types.hpp>

Public Attributes

Type Name
uint8_t gid = {}
16-byte subscription GID.
std::mutex listener_mtx
rmw_event_callback_t on_liveliness_changed_cb = { nullptr }
const void * on_liveliness_changed_ud = { nullptr }
rmw_event_callback_t on_message_lost_cb = { nullptr }
const void * on_message_lost_ud = { nullptr }
rmw_event_callback_t on_new_message_cb = { nullptr }
const void * on_new_message_user_data = { nullptr }
Opaque pointer passed back verbatim to on_new_message_cb .
rmw_event_callback_t on_requested_deadline_missed_cb = { nullptr }
const void * on_requested_deadline_missed_ud = { nullptr }
rmw_event_callback_t on_requested_incompatible_qos_cb = { nullptr }
const void * on_requested_incompatible_qos_ud = { nullptr }
rmw_event_callback_t on_subscription_matched_cb = { nullptr }
const void * on_subscription_matched_ud = { nullptr }
rmw_qos_profile_t qos = {}
QoS requested at create.
AstuteDDS_DataReader reader = { nullptr }
Owning DataReader.
AstuteDDS_Topic topic = { nullptr }
Owning Topic.
std::string topic_name
DDS topic name.
std::string type_name
DDS type name.
TypeSupportHandle type_support = {}
Cached at create time.

Detailed Description

State pointed to by rmw_subscription_t::data. Reader-side mirror of AstuteDDSPublisher.

Public Attributes Documentation

variable gid

16-byte subscription GID.

uint8_t AstuteDDSSubscription::gid[16];


variable listener_mtx

std::mutex AstuteDDSSubscription::listener_mtx;

Protects every on_*_cb / on_*_ud pair below (including the "new message" pair); see AstuteDDSPublisher::listener_mtx for why a single mutex + full-struct rebuild is required.


variable on_liveliness_changed_cb

rmw_event_callback_t AstuteDDSSubscription::on_liveliness_changed_cb;

variable on_liveliness_changed_ud

const void* AstuteDDSSubscription::on_liveliness_changed_ud;

variable on_message_lost_cb

rmw_event_callback_t AstuteDDSSubscription::on_message_lost_cb;

variable on_message_lost_ud

const void* AstuteDDSSubscription::on_message_lost_ud;

variable on_new_message_cb

rmw_event_callback_t AstuteDDSSubscription::on_new_message_cb;

User callback registered via rmw_subscription_set_on_new_message_callback; null when no callback is registered.


variable on_new_message_user_data

Opaque pointer passed back verbatim to on_new_message_cb .

const void* AstuteDDSSubscription::on_new_message_user_data;


variable on_requested_deadline_missed_cb

rmw_event_callback_t AstuteDDSSubscription::on_requested_deadline_missed_cb;

variable on_requested_deadline_missed_ud

const void* AstuteDDSSubscription::on_requested_deadline_missed_ud;

variable on_requested_incompatible_qos_cb

rmw_event_callback_t AstuteDDSSubscription::on_requested_incompatible_qos_cb;

variable on_requested_incompatible_qos_ud

const void* AstuteDDSSubscription::on_requested_incompatible_qos_ud;

variable on_subscription_matched_cb

rmw_event_callback_t AstuteDDSSubscription::on_subscription_matched_cb;

variable on_subscription_matched_ud

const void* AstuteDDSSubscription::on_subscription_matched_ud;

variable qos

QoS requested at create.

rmw_qos_profile_t AstuteDDSSubscription::qos;


variable reader

Owning DataReader.

AstuteDDS_DataReader AstuteDDSSubscription::reader;


variable topic

Owning Topic.

AstuteDDS_Topic AstuteDDSSubscription::topic;


variable topic_name

DDS topic name.

std::string AstuteDDSSubscription::topic_name;


variable type_name

DDS type name.

std::string AstuteDDSSubscription::type_name;


variable type_support

Cached at create time.

TypeSupportHandle AstuteDDSSubscription::type_support;



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