Class SubscriptionData

• Defined in File rmw_subscription_data.hpp

Nested Relationships

Nested Types

• Struct SubscriptionData::Message

Inheritance Relationships

Base Type

• public std::enable_shared_from_this< SubscriptionData >

Class Documentation

class SubscriptionData : public std::enable_shared_from_this<SubscriptionData>

=============================================================================

Public Functions

std::size_t gid_hash() const

liveliness::TopicInfo topic_info() const

bool liveliness_is_valid() const

std::shared_ptr<EventsManager> events_mgr() const

rmw_ret_t shutdown()

bool is_shutdown() const

void add_new_message(std::unique_ptr<Message> msg, const std::string &topic_name)

bool queue_has_data_and_attach_condition_if_not(rmw_wait_set_data_t *wait_set_data)

bool detach_condition_and_queue_is_empty()

rmw_ret_t take_one_message(void *ros_message, rmw_message_info_t *message_info, bool *taken)

rmw_ret_t take_serialized_message(rmw_serialized_message_t *serialized_message, bool *taken, rmw_message_info_t *message_info)

void set_on_new_message_callback(rmw_event_callback_t callback, const void *user_data)

std::shared_ptr<GraphCache> graph_cache() const

~SubscriptionData()

Public Static Functions

static std::shared_ptr<SubscriptionData> make(std::shared_ptr<zenoh::Session> session, std::shared_ptr<GraphCache> graph_cache, const rmw_node_t *const node, liveliness::NodeInfo node_info, std::size_t node_id, std::size_t Subscription_id, const std::string &topic_name, const rosidl_message_type_support_t *type_support, const rmw_qos_profile_t *qos_profile, const rmw_subscription_options_t &sub_options)

struct Message

Public Functions

explicit Message(const zenoh::Bytes &bytes, uint64_t recv_ts, AttachmentData &&attachment)

~Message() = default

Public Members

Payload payload

uint64_t recv_timestamp

AttachmentData attachment