Class RMW_Connext_Subscriber

• Defined in File rmw_impl.hpp

Class Documentation

class RMW_Connext_Subscriber

Public Functions

rmw_ret_t finalize()

inline DDS_DataReader *reader() const

inline RMW_Connext_UntypedSampleSeq *data_seq()

inline DDS_SampleInfoSeq *info_seq()

inline RMW_Connext_MessageTypeSupport *message_type_support() const

inline DDS_InstanceHandle_t instance_handle()

inline DDS_InstanceHandle_t participant_instance_handle()

inline rmw_ret_t enable() const

inline RMW_Connext_SubscriberStatusCondition *condition()

inline const rmw_gid_t *gid() const

size_t publications_count()

rmw_ret_t qos(rmw_qos_profile_t *const qos)

rmw_ret_t loan_messages(const bool update_condition = true)

rmw_ret_t return_messages()

inline rmw_ret_t loan_messages_if_needed(const bool update_condition = true)

void requestreply_header_from_dds(RMW_Connext_RequestReplyMessage *const rr_msg, const DDS_SampleIdentity_t *const sample_identity, const DDS_SampleIdentity_t *const related_sample_identity)

rmw_ret_t take_next(void **const ros_messages, rmw_message_info_t *const message_infos, const size_t max_samples, size_t *const taken, const bool serialized, const DDS_InstanceHandle_t *const request_writer_handle = nullptr)

rmw_ret_t take_message(void *const ros_message, rmw_message_info_t *const message_info, bool *const taken, const DDS_InstanceHandle_t *const request_writer_handle = nullptr)

rmw_ret_t take(rmw_message_sequence_t *const message_sequence, rmw_message_info_sequence_t *const message_info_sequence, const size_t max_samples, size_t *const taken)

rmw_ret_t take_serialized(rmw_serialized_message_t *const serialized_message, rmw_message_info_t *const message_info, bool *const taken)

rmw_ret_t set_content_filter(const rmw_subscription_content_filter_options_t *const options)

rmw_ret_t get_content_filter(rcutils_allocator_t *allocator, rmw_subscription_content_filter_options_t *const options)

inline bool has_data()

inline rmw_ret_t count_unread_samples(size_t &unread_count)

inline DDS_Subscriber *dds_subscriber() const

inline DDS_DomainParticipant *dds_participant() const

inline DDS_Topic *topic() const

inline bool is_cft_enabled()

Public Members

const bool internal

const bool ignore_local

Public Static Functions

static RMW_Connext_Subscriber *create(rmw_context_impl_t *const ctx, DDS_DomainParticipant *const dp, DDS_Subscriber *const sub, const rosidl_message_type_support_t *const type_supports, const char *const topic_name, const rmw_qos_profile_t *const qos_policies, const rmw_subscription_options_t *const subscriber_options, const bool internal = false, const RMW_Connext_MessageType msg_type = RMW_CONNEXT_MESSAGE_USERDATA, const void *const intro_members = nullptr, const bool intro_members_cpp = false, std::string *const type_name = nullptr, const char *const cft_name = nullptr, const char *const cft_filter = nullptr)

static inline std::string get_atomic_id()