Struct SubscriberInfo

Defined in File event_info_common.hpp

Inheritance Relationships

Base Type

public rmw_gurumdds_cpp::EventInfo (Struct EventInfo)

Struct Documentation

struct SubscriberInfo : public rmw_gurumdds_cpp::EventInfo 

Public Functions

virtual rmw_ret_t get_status(rmw_event_type_t event_type, void *event) override

virtual dds_StatusCondition *get_status_condition() override

virtual dds_GuardCondition *get_guard_condition(rmw_event_type_t event_type) override

virtual bool is_status_changed(rmw_event_type_t event_type) override

virtual bool has_callback(rmw_event_type_t event_type) override

bool has_callback_unsafe(rmw_event_type_t event_type) const

virtual rmw_ret_t set_on_new_event_callback(rmw_event_type_t event_type, const void *user_data, rmw_event_callback_t callback) override

virtual void update_inconsistent_topic(int32_t total_count, int32_t total_count_change) override

void on_requested_deadline_missed(const dds_RequestedDeadlineMissedStatus &status)

void on_requested_incompatible_qos(const dds_RequestedIncompatibleQosStatus &status)

void on_data_available()

void on_liveliness_changed(const dds_LivelinessChangedStatus &status)

void on_subscription_matched(const dds_SubscriptionMatchedStatus &status)

void on_sample_lost(const dds_SampleLostStatus &status)

size_t count_unread()

Public Members

const rosidl_message_type_support_t *rosidl_message_typesupport

const char *implementation_identifier

rmw_context_impl_t *ctx

std::mutex mutex_event

rmw_event_callback_t on_new_event_cb[RMW_EVENT_INVALID] = {}

const void *user_data_cb[RMW_EVENT_INVALID] = {}

dds_GuardCondition *event_guard_cond[RMW_EVENT_INVALID] = {}

dds_StatusMask mask = 0

bool requested_deadline_missed_changed = false

dds_RequestedDeadlineMissedStatus requested_deadline_missed_status = {}

bool requested_incompatible_qos_changed = false

dds_RequestedIncompatibleQosStatus requested_incompatible_qos_status = {}

bool inconsistent_topic_changed = false

dds_InconsistentTopicStatus inconsistent_topic_status = {}

bool liveliness_changed = false

dds_LivelinessChangedStatus liveliness_changed_status = {}

bool subscription_matched_changed = false

dds_SubscriptionMatchedStatus subscription_matched_status = {}

bool sample_lost_changed = false

dds_SampleLostStatus sample_lost_status = {}

rmw_gid_t subscriber_gid

dds_DataReader *topic_reader

dds_ReadCondition *read_condition

dds_DataReaderListener topic_listener

dds_DataSeq *data_seq

dds_SampleInfoSeq *info_seq

dds_UnsignedLongSeq *raw_data_sizes

event_callback_data_t event_callback_data