Struct CustomSubscriberInfo

• Defined in File custom_subscriber_info.hpp

Inheritance Relationships

Base Type

• public CustomEventInfo (Struct CustomEventInfo)

Struct Documentation

struct CustomSubscriberInfo : public CustomEventInfo

Public Functions

virtual ~CustomSubscriberInfo() = default

virtual EventListenerInterface *get_listener() const final

Public Members

eprosima::fastdds::dds::DataReader *data_reader_ = {nullptr}

RMWSubscriptionEvent *subscription_event_ = {nullptr}

CustomDataReaderListener *data_reader_listener_ = {nullptr}

eprosima::fastdds::dds::TypeSupport type_support_

const void *type_support_impl_ = {nullptr}

rmw_gid_t subscription_gid_ = {}

const char *typesupport_identifier_ = {nullptr}

std::shared_ptr<rmw_fastrtps_shared_cpp::LoanManager> loan_manager_

const rmw_node_t *node_ = {nullptr}

rmw_dds_common::Context *common_context_ = {nullptr}

eprosima::fastdds::dds::DomainParticipant *dds_participant_ = {nullptr}

eprosima::fastdds::dds::Subscriber *subscriber_ = {nullptr}

std::string topic_name_mangled_

eprosima::fastdds::dds::Topic *topic_ = {nullptr}

eprosima::fastdds::dds::ContentFilteredTopic *filtered_topic_ = {nullptr}

eprosima::fastdds::dds::DataReaderQos datareader_qos_

bool is_buffer_aware_ = {false}

bool is_cpu_only_ = {false}

std::vector<std::string> my_backend_types_

rmw_topic_endpoint_info_t local_endpoint_info_ = {}

const void *serialization_context_ = {nullptr}

std::shared_ptr<BufferSubscriptionState> buffer_state_{std::make_shared<BufferSubscriptionState>()}

std::unique_ptr<eprosima::fastdds::dds::GuardCondition> buffer_data_guard_

Guard condition triggered when buffer channel DataReaders receive data. Used by rmw_wait to detect data on buffer-aware subscriptions.

eprosima::fastdds::dds::DataReader *cpu_data_reader_ = {nullptr}

eprosima::fastdds::dds::Topic *cpu_topic_ = {nullptr}

std::shared_ptr<eprosima::fastdds::dds::DataReaderListener> cpu_data_reader_listener_

eprosima::fastdds::dds::DataReader *accel_data_reader_ = {nullptr}

eprosima::fastdds::dds::Topic *accel_topic_ = {nullptr}

std::shared_ptr<eprosima::fastdds::dds::DataReaderListener> accel_data_reader_listener_