Struct PublisherInfo

Inheritance Relationships

Base Type

Struct Documentation

struct PublisherInfo : 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_offered_deadline_missed(const dds_OfferedDeadlineMissedStatus &status)
void on_offered_incompatible_qos(const dds_OfferedIncompatibleQosStatus &status)
void on_liveliness_lost(const dds_LivelinessLostStatus &status)
void on_publication_matched(const dds_PublicationMatchedStatus &status)

Public Members

const rosidl_message_type_support_t *rosidl_message_typesupport
const char *implementation_identifier
rmw_context_impl_t *ctx
int64_t sequence_number
rmw_gid_t publisher_gid
dds_DataWriter *topic_writer
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 inconsistent_topic_changed = false
dds_InconsistentTopicStatus inconsistent_topic_status = {}
bool offered_deadline_missed_changed = false
dds_OfferedDeadlineMissedStatus offered_deadline_missed_status = {}
bool offered_incompatible_qos_changed = false
dds_OfferedIncompatibleQosStatus offered_incompatible_qos_status = {}
bool liveliness_lost_changed = false
dds_LivelinessLostStatus liveliness_lost_status = {}
bool publication_matched_changed = false
dds_PublicationMatchedStatus publication_matched_status = {}
dds_DataWriterListener topic_listener = {}