Class RMW_Connext_SubscriberStatusCondition

• Defined in File rmw_waitset_std.hpp

Inheritance Relationships

Base Type

• public RMW_Connext_StatusCondition (Class RMW_Connext_StatusCondition)

Class Documentation

class RMW_Connext_SubscriberStatusCondition : public RMW_Connext_StatusCondition

Public Functions

RMW_Connext_SubscriberStatusCondition(DDS_DataReader *const reader, const bool ignore_local, const bool internal)

virtual ~RMW_Connext_SubscriberStatusCondition()

virtual bool has_status(const rmw_event_type_t event_type)

virtual rmw_ret_t get_status(const rmw_event_type_t event_type, void *const event_info)

rmw_ret_t install(RMW_Connext_Subscriber *const sub)

void on_requested_deadline_missed(const DDS_RequestedDeadlineMissedStatus *const status)

void on_requested_incompatible_qos(const DDS_RequestedIncompatibleQosStatus *const status)

void on_liveliness_changed(const DDS_LivelinessChangedStatus *const status)

void on_sample_lost(const DDS_SampleLostStatus *const status)

void on_matched(const DDS_SubscriptionMatchedStatus *const status)

inline rmw_ret_t set_data_available(const bool available)

inline virtual bool owns(DDS_Condition *const cond)

inline virtual rmw_ret_t _attach(DDS_WaitSet *const waitset)

inline virtual rmw_ret_t _detach(DDS_WaitSet *const waitset)

inline rmw_ret_t get_liveliness_changed_status(rmw_liveliness_changed_status_t *const status)

inline rmw_ret_t get_requested_deadline_missed_status(rmw_requested_deadline_missed_status_t *const status)

inline rmw_ret_t get_requested_qos_incompatible_status(rmw_requested_qos_incompatible_event_status_t *const status)

inline rmw_ret_t get_message_lost_status(rmw_message_lost_status_t *const status)

inline rmw_ret_t get_matched_status(rmw_matched_status_t *const status)

Public Members

const bool ignore_local

const DDS_InstanceHandle_t participant_handle

Protected Functions

void update_status_deadline(const DDS_RequestedDeadlineMissedStatus *const status)

void update_status_liveliness(const DDS_LivelinessChangedStatus *const status)

void update_status_qos(const DDS_RequestedIncompatibleQosStatus *const status)

void update_status_sample_lost(const DDS_SampleLostStatus *const status)

void update_status_matched(const DDS_SubscriptionMatchedStatus *const status)

Protected Attributes

DDS_GuardCondition *const loan_guard_condition

bool triggered_deadline = {false}

bool triggered_liveliness = {false}

bool triggered_qos = {false}

bool triggered_sample_lost = {false}

bool triggered_matched = {false}

bool triggered_data = {false}

DDS_RequestedDeadlineMissedStatus status_deadline

DDS_RequestedIncompatibleQosStatus status_qos

DDS_LivelinessChangedStatus status_liveliness

DDS_SampleLostStatus status_sample_lost

DDS_SubscriptionMatchedStatus status_matched

DDS_RequestedDeadlineMissedStatus status_deadline_last

DDS_RequestedIncompatibleQosStatus status_qos_last

DDS_LivelinessChangedStatus status_liveliness_last

DDS_SampleLostStatus status_sample_lost_last

DDS_SubscriptionMatchedStatus status_matched_last

RMW_Connext_Subscriber *sub

Friends

friend class RMW_Connext_WaitSet

friend void RMW_Connext_DataReaderListener_requested_deadline_missed(void *listener_data, DDS_DataReader *reader, const struct DDS_RequestedDeadlineMissedStatus *status)

friend void RMW_Connext_DataReaderListener_requested_incompatible_qos(void *listener_data, DDS_DataReader *reader, const struct DDS_RequestedIncompatibleQosStatus *status)

friend void RMW_Connext_DataReaderListener_liveliness_changed(void *listener_data, DDS_DataReader *reader, const struct DDS_LivelinessChangedStatus *status)

friend void RMW_Connext_DataReaderListener_sample_lost(void *listener_data, DDS_DataReader *reader, const struct DDS_SampleLostStatus *status)

friend void RMW_Connext_DataReaderListener_on_data_available(void *listener_data, DDS_DataReader *reader)