Struct AstuteDDSSubscription
ClassList > AstuteDDSSubscription
#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