rmw_fastrtps_shared_cpp  master
Code shared on static and dynamic type support of rmw_fastrtps_cpp.
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
Classes | Functions
rmw_fastrtps_shared_cpp Namespace Reference

Classes

struct  hash_fastrtps_guid
 
struct  SerializedData
 
struct  TopicHolder
 
class  TypeSupport
 

Functions

rmw_gid_t create_rmw_gid (const char *identifier, const eprosima::fastrtps::rtps::GUID_t &guid)
 
template<typename ByteT >
void copy_from_byte_array_to_fastrtps_guid (const ByteT *guid_byte_array, eprosima::fastrtps::rtps::GUID_t *guid)
 
template<typename ByteT >
void copy_from_fastrtps_guid_to_byte_array (const eprosima::fastrtps::rtps::GUID_t &guid, ByteT *guid_byte_array)
 
rmw_ret_t decrement_context_impl_ref_count (rmw_context_t *context)
 Increment rmw_context_impl_t reference count, destroying it if the count reaches zero. More...
 
rmw_ret_t run_listener_thread (rmw_context_t *context)
 
rmw_ret_t join_listener_thread (rmw_context_t *context)
 
CustomParticipantInfocreate_participant (const char *identifier, size_t domain_id, const rmw_security_options_t *security_options, bool localhost_only, const char *enclave, rmw_dds_common::Context *common_context)
 
rmw_ret_t destroy_participant (CustomParticipantInfo *info)
 
rmw_ret_t destroy_publisher (const char *identifier, CustomParticipantInfo *participant_info, rmw_publisher_t *publisher)
 
rmw_ret_t __rmw_destroy_client (const char *identifier, rmw_node_t *node, rmw_client_t *client)
 
rmw_ret_t __rmw_compare_gids_equal (const char *identifier, const rmw_gid_t *gid1, const rmw_gid_t *gid2, bool *result)
 
rmw_ret_t __rmw_count_publishers (const char *identifier, const rmw_node_t *node, const char *topic_name, size_t *count)
 
rmw_ret_t __rmw_count_subscribers (const char *identifier, const rmw_node_t *node, const char *topic_name, size_t *count)
 
rmw_ret_t __rmw_get_gid_for_publisher (const char *identifier, const rmw_publisher_t *publisher, rmw_gid_t *gid)
 
rmw_guard_condition_t__rmw_create_guard_condition (const char *identifier)
 
rmw_ret_t __rmw_destroy_guard_condition (rmw_guard_condition_t *guard_condition)
 
rmw_ret_t __rmw_trigger_guard_condition (const char *identifier, const rmw_guard_condition_t *guard_condition_handle)
 
rmw_ret_t __rmw_set_log_severity (rmw_log_severity_t severity)
 
rmw_node_t__rmw_create_node (rmw_context_t *context, const char *identifier, const char *name, const char *namespace_)
 
rmw_ret_t __rmw_destroy_node (const char *identifier, rmw_node_t *node)
 
const rmw_guard_condition_t__rmw_node_get_graph_guard_condition (const rmw_node_t *node)
 
rmw_ret_t __rmw_get_node_names (const char *identifier, const rmw_node_t *node, rcutils_string_array_t *node_names, rcutils_string_array_t *node_namespaces)
 
rmw_ret_t __rmw_init_event (const char *identifier, rmw_event_t *rmw_event, const char *topic_endpoint_impl_identifier, void *data, rmw_event_type_t event_type)
 
rmw_ret_t __rmw_get_node_names_with_enclaves (const char *identifier, const rmw_node_t *node, rcutils_string_array_t *node_names, rcutils_string_array_t *node_namespaces, rcutils_string_array_t *enclaves)
 
rmw_ret_t __rmw_publish (const char *identifier, const rmw_publisher_t *publisher, const void *ros_message, rmw_publisher_allocation_t *allocation)
 
rmw_ret_t __rmw_publish_serialized_message (const char *identifier, const rmw_publisher_t *publisher, const rmw_serialized_message_t *serialized_message, rmw_publisher_allocation_t *allocation)
 
rmw_ret_t __rmw_publisher_assert_liveliness (const char *identifier, const rmw_publisher_t *publisher)
 
rmw_ret_t __rmw_destroy_publisher (const char *identifier, const rmw_node_t *node, rmw_publisher_t *publisher)
 
rmw_ret_t __rmw_publisher_count_matched_subscriptions (const rmw_publisher_t *publisher, size_t *subscription_count)
 
rmw_ret_t __rmw_publisher_get_actual_qos (const rmw_publisher_t *publisher, rmw_qos_profile_t *qos)
 
rmw_ret_t __rmw_send_request (const char *identifier, const rmw_client_t *client, const void *ros_request, int64_t *sequence_id)
 
rmw_ret_t __rmw_take_request (const char *identifier, const rmw_service_t *service, rmw_service_info_t *request_header, void *ros_request, bool *taken)
 
rmw_ret_t __rmw_take_response (const char *identifier, const rmw_client_t *client, rmw_service_info_t *request_header, void *ros_response, bool *taken)
 
rmw_ret_t __rmw_send_response (const char *identifier, const rmw_service_t *service, rmw_request_id_t *request_header, void *ros_response)
 
rmw_ret_t __rmw_destroy_service (const char *identifier, rmw_node_t *node, rmw_service_t *service)
 
rmw_ret_t __rmw_get_service_names_and_types (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, rmw_names_and_types_t *service_names_and_types)
 
rmw_ret_t __rmw_get_publisher_names_and_types_by_node (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *node_name, const char *node_namespace, bool no_demangle, rmw_names_and_types_t *topic_names_and_types)
 
rmw_ret_t __rmw_get_service_names_and_types_by_node (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *node_name, const char *node_namespace, rmw_names_and_types_t *service_names_and_types)
 
rmw_ret_t __rmw_get_client_names_and_types_by_node (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *node_name, const char *node_namespace, rmw_names_and_types_t *service_names_and_types)
 
rmw_ret_t __rmw_get_subscriber_names_and_types_by_node (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *node_name, const char *node_namespace, bool no_demangle, rmw_names_and_types_t *topic_names_and_types)
 
rmw_ret_t __rmw_service_server_is_available (const char *identifier, const rmw_node_t *node, const rmw_client_t *client, bool *is_available)
 
rmw_ret_t __rmw_destroy_subscription (const char *identifier, const rmw_node_t *node, rmw_subscription_t *subscription)
 
rmw_ret_t __rmw_subscription_count_matched_publishers (const rmw_subscription_t *subscription, size_t *publisher_count)
 
rmw_ret_t __rmw_subscription_get_actual_qos (const rmw_subscription_t *subscription, rmw_qos_profile_t *qos)
 
rmw_ret_t __rmw_take (const char *identifier, const rmw_subscription_t *subscription, void *ros_message, bool *taken, rmw_subscription_allocation_t *allocation)
 
rmw_ret_t __rmw_take_sequence (const char *identifier, const rmw_subscription_t *subscription, size_t count, rmw_message_sequence_t *message_sequencxe, rmw_message_info_sequence_t *message_info_sequence, size_t *taken, rmw_subscription_allocation_t *allocation)
 
rmw_ret_t __rmw_take_event (const char *identifier, const rmw_event_t *event_handle, void *event_info, bool *taken)
 
rmw_ret_t __rmw_take_with_info (const char *identifier, const rmw_subscription_t *subscription, void *ros_message, bool *taken, rmw_message_info_t *message_info, rmw_subscription_allocation_t *allocation)
 
rmw_ret_t __rmw_take_serialized_message (const char *identifier, const rmw_subscription_t *subscription, rmw_serialized_message_t *serialized_message, bool *taken, rmw_subscription_allocation_t *allocation)
 
rmw_ret_t __rmw_take_serialized_message_with_info (const char *identifier, const rmw_subscription_t *subscription, rmw_serialized_message_t *serialized_message, bool *taken, rmw_message_info_t *message_info, rmw_subscription_allocation_t *allocation)
 
rmw_ret_t __rmw_get_topic_names_and_types (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, bool no_demangle, rmw_names_and_types_t *topic_names_and_types)
 
rmw_ret_t __rmw_wait (const char *identifier, rmw_subscriptions_t *subscriptions, rmw_guard_conditions_t *guard_conditions, rmw_services_t *services, rmw_clients_t *clients, rmw_events_t *events, rmw_wait_set_t *wait_set, const rmw_time_t *wait_timeout)
 
rmw_wait_set_t__rmw_create_wait_set (const char *identifier, rmw_context_t *context, size_t max_conditions)
 
rmw_ret_t __rmw_destroy_wait_set (const char *identifier, rmw_wait_set_t *wait_set)
 
rmw_ret_t __rmw_get_publishers_info_by_topic (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *topic_name, bool no_mangle, rmw_topic_endpoint_info_array_t *publishers_info)
 
rmw_ret_t __rmw_get_subscriptions_info_by_topic (const char *identifier, const rmw_node_t *node, rcutils_allocator_t *allocator, const char *topic_name, bool no_mangle, rmw_topic_endpoint_info_array_t *subscriptions_info)
 
rmw_ret_t __rmw_qos_profile_check_compatible (const rmw_qos_profile_t publisher_profile, const rmw_qos_profile_t subscription_profile, rmw_qos_compatibility_type_t *compatibility, char *reason, size_t reason_size)
 
rmw_ret_t __rmw_publisher_get_network_flow_endpoints (const rmw_publisher_t *publisher, rcutils_allocator_t *allocator, rmw_network_flow_endpoint_array_t *network_flow_endpoint_array)
 
rmw_ret_t __rmw_subscription_get_network_flow_endpoints (const rmw_subscription_t *subscription, rcutils_allocator_t *allocator, rmw_network_flow_endpoint_array_t *network_flow_endpoint_array)
 
rmw_ret_t rmw_init_options_init (const char *identifier, rmw_init_options_t *init_options, rcutils_allocator_t allocator)
 
rmw_ret_t rmw_init_options_copy (const char *identifier, const rmw_init_options_t *src, rmw_init_options_t *dst)
 
rmw_ret_t rmw_init_options_fini (const char *identifier, rmw_init_options_t *init_options)
 
rmw_ret_t destroy_subscription (const char *identifier, CustomParticipantInfo *participant_info, rmw_subscription_t *subscription)
 
rmw_ret_t cast_error_dds_to_rmw (eprosima::fastrtps::types::ReturnCode_t code)
 
bool cast_or_create_topic (eprosima::fastdds::dds::DomainParticipant *participant, eprosima::fastdds::dds::TopicDescription *desc, const std::string &topic_name, const std::string &type_name, const eprosima::fastdds::dds::TopicQos &topic_qos, bool is_writer_topic, TopicHolder *topic_holder)
 
bool find_and_check_topic_and_type (const CustomParticipantInfo *participant_info, const std::string &topic_name, const std::string &type_name, eprosima::fastdds::dds::TopicDescription **returned_topic, eprosima::fastdds::dds::TypeSupport *returned_type)
 
void remove_topic_and_type (const CustomParticipantInfo *participant_info, const eprosima::fastdds::dds::TopicDescription *topic, const eprosima::fastdds::dds::TypeSupport &type)
 

Function Documentation

◆ create_rmw_gid()

rmw_gid_t rmw_fastrtps_shared_cpp::create_rmw_gid ( const char *  identifier,
const eprosima::fastrtps::rtps::GUID_t &  guid 
)

◆ copy_from_byte_array_to_fastrtps_guid()

template<typename ByteT >
void rmw_fastrtps_shared_cpp::copy_from_byte_array_to_fastrtps_guid ( const ByteT *  guid_byte_array,
eprosima::fastrtps::rtps::GUID_t *  guid 
)

◆ copy_from_fastrtps_guid_to_byte_array()

template<typename ByteT >
void rmw_fastrtps_shared_cpp::copy_from_fastrtps_guid_to_byte_array ( const eprosima::fastrtps::rtps::GUID_t &  guid,
ByteT *  guid_byte_array 
)

◆ decrement_context_impl_ref_count()

rmw_ret_t rmw_fastrtps_shared_cpp::decrement_context_impl_ref_count ( rmw_context_t context)

Increment rmw_context_impl_t reference count, destroying it if the count reaches zero.

Function that should be called when destroying a node.

◆ run_listener_thread()

rmw_ret_t rmw_fastrtps_shared_cpp::run_listener_thread ( rmw_context_t context)

◆ join_listener_thread()

rmw_ret_t rmw_fastrtps_shared_cpp::join_listener_thread ( rmw_context_t context)

◆ create_participant()

CustomParticipantInfo* rmw_fastrtps_shared_cpp::create_participant ( const char *  identifier,
size_t  domain_id,
const rmw_security_options_t security_options,
bool  localhost_only,
const char *  enclave,
rmw_dds_common::Context *  common_context 
)

◆ destroy_participant()

rmw_ret_t rmw_fastrtps_shared_cpp::destroy_participant ( CustomParticipantInfo info)

◆ destroy_publisher()

rmw_ret_t rmw_fastrtps_shared_cpp::destroy_publisher ( const char *  identifier,
CustomParticipantInfo participant_info,
rmw_publisher_t publisher 
)

◆ __rmw_destroy_client()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_client ( const char *  identifier,
rmw_node_t node,
rmw_client_t client 
)

◆ __rmw_compare_gids_equal()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_compare_gids_equal ( const char *  identifier,
const rmw_gid_t gid1,
const rmw_gid_t gid2,
bool *  result 
)

◆ __rmw_count_publishers()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_count_publishers ( const char *  identifier,
const rmw_node_t node,
const char *  topic_name,
size_t *  count 
)

◆ __rmw_count_subscribers()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_count_subscribers ( const char *  identifier,
const rmw_node_t node,
const char *  topic_name,
size_t *  count 
)

◆ __rmw_get_gid_for_publisher()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_gid_for_publisher ( const char *  identifier,
const rmw_publisher_t publisher,
rmw_gid_t gid 
)

◆ __rmw_create_guard_condition()

rmw_guard_condition_t* rmw_fastrtps_shared_cpp::__rmw_create_guard_condition ( const char *  identifier)

◆ __rmw_destroy_guard_condition()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_guard_condition ( rmw_guard_condition_t guard_condition)

◆ __rmw_trigger_guard_condition()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_trigger_guard_condition ( const char *  identifier,
const rmw_guard_condition_t guard_condition_handle 
)

◆ __rmw_set_log_severity()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_set_log_severity ( rmw_log_severity_t  severity)

◆ __rmw_create_node()

rmw_node_t* rmw_fastrtps_shared_cpp::__rmw_create_node ( rmw_context_t context,
const char *  identifier,
const char *  name,
const char *  namespace_ 
)

◆ __rmw_destroy_node()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_node ( const char *  identifier,
rmw_node_t node 
)

◆ __rmw_node_get_graph_guard_condition()

const rmw_guard_condition_t* rmw_fastrtps_shared_cpp::__rmw_node_get_graph_guard_condition ( const rmw_node_t node)

◆ __rmw_get_node_names()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_node_names ( const char *  identifier,
const rmw_node_t node,
rcutils_string_array_t node_names,
rcutils_string_array_t node_namespaces 
)

◆ __rmw_init_event()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_init_event ( const char *  identifier,
rmw_event_t rmw_event,
const char *  topic_endpoint_impl_identifier,
void *  data,
rmw_event_type_t  event_type 
)

◆ __rmw_get_node_names_with_enclaves()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_node_names_with_enclaves ( const char *  identifier,
const rmw_node_t node,
rcutils_string_array_t node_names,
rcutils_string_array_t node_namespaces,
rcutils_string_array_t enclaves 
)

◆ __rmw_publish()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publish ( const char *  identifier,
const rmw_publisher_t publisher,
const void *  ros_message,
rmw_publisher_allocation_t allocation 
)

◆ __rmw_publish_serialized_message()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publish_serialized_message ( const char *  identifier,
const rmw_publisher_t publisher,
const rmw_serialized_message_t serialized_message,
rmw_publisher_allocation_t allocation 
)

◆ __rmw_publisher_assert_liveliness()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publisher_assert_liveliness ( const char *  identifier,
const rmw_publisher_t publisher 
)

◆ __rmw_destroy_publisher()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_publisher ( const char *  identifier,
const rmw_node_t node,
rmw_publisher_t publisher 
)

◆ __rmw_publisher_count_matched_subscriptions()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publisher_count_matched_subscriptions ( const rmw_publisher_t publisher,
size_t *  subscription_count 
)

◆ __rmw_publisher_get_actual_qos()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publisher_get_actual_qos ( const rmw_publisher_t publisher,
rmw_qos_profile_t qos 
)

◆ __rmw_send_request()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_send_request ( const char *  identifier,
const rmw_client_t client,
const void *  ros_request,
int64_t *  sequence_id 
)

◆ __rmw_take_request()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_request ( const char *  identifier,
const rmw_service_t service,
rmw_service_info_t request_header,
void *  ros_request,
bool *  taken 
)

◆ __rmw_take_response()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_response ( const char *  identifier,
const rmw_client_t client,
rmw_service_info_t request_header,
void *  ros_response,
bool *  taken 
)

◆ __rmw_send_response()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_send_response ( const char *  identifier,
const rmw_service_t service,
rmw_request_id_t request_header,
void *  ros_response 
)

◆ __rmw_destroy_service()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_service ( const char *  identifier,
rmw_node_t node,
rmw_service_t service 
)

◆ __rmw_get_service_names_and_types()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_service_names_and_types ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
rmw_names_and_types_t service_names_and_types 
)

◆ __rmw_get_publisher_names_and_types_by_node()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_publisher_names_and_types_by_node ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  node_name,
const char *  node_namespace,
bool  no_demangle,
rmw_names_and_types_t topic_names_and_types 
)

◆ __rmw_get_service_names_and_types_by_node()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_service_names_and_types_by_node ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  node_name,
const char *  node_namespace,
rmw_names_and_types_t service_names_and_types 
)

◆ __rmw_get_client_names_and_types_by_node()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_client_names_and_types_by_node ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  node_name,
const char *  node_namespace,
rmw_names_and_types_t service_names_and_types 
)

◆ __rmw_get_subscriber_names_and_types_by_node()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_subscriber_names_and_types_by_node ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  node_name,
const char *  node_namespace,
bool  no_demangle,
rmw_names_and_types_t topic_names_and_types 
)

◆ __rmw_service_server_is_available()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_service_server_is_available ( const char *  identifier,
const rmw_node_t node,
const rmw_client_t client,
bool *  is_available 
)

◆ __rmw_destroy_subscription()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_subscription ( const char *  identifier,
const rmw_node_t node,
rmw_subscription_t subscription 
)

◆ __rmw_subscription_count_matched_publishers()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_subscription_count_matched_publishers ( const rmw_subscription_t subscription,
size_t *  publisher_count 
)

◆ __rmw_subscription_get_actual_qos()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_subscription_get_actual_qos ( const rmw_subscription_t subscription,
rmw_qos_profile_t qos 
)

◆ __rmw_take()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take ( const char *  identifier,
const rmw_subscription_t subscription,
void *  ros_message,
bool *  taken,
rmw_subscription_allocation_t allocation 
)

◆ __rmw_take_sequence()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_sequence ( const char *  identifier,
const rmw_subscription_t subscription,
size_t  count,
rmw_message_sequence_t message_sequencxe,
rmw_message_info_sequence_t message_info_sequence,
size_t *  taken,
rmw_subscription_allocation_t allocation 
)

◆ __rmw_take_event()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_event ( const char *  identifier,
const rmw_event_t event_handle,
void *  event_info,
bool *  taken 
)

◆ __rmw_take_with_info()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_with_info ( const char *  identifier,
const rmw_subscription_t subscription,
void *  ros_message,
bool *  taken,
rmw_message_info_t message_info,
rmw_subscription_allocation_t allocation 
)

◆ __rmw_take_serialized_message()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_serialized_message ( const char *  identifier,
const rmw_subscription_t subscription,
rmw_serialized_message_t serialized_message,
bool *  taken,
rmw_subscription_allocation_t allocation 
)

◆ __rmw_take_serialized_message_with_info()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_take_serialized_message_with_info ( const char *  identifier,
const rmw_subscription_t subscription,
rmw_serialized_message_t serialized_message,
bool *  taken,
rmw_message_info_t message_info,
rmw_subscription_allocation_t allocation 
)

◆ __rmw_get_topic_names_and_types()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_topic_names_and_types ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
bool  no_demangle,
rmw_names_and_types_t topic_names_and_types 
)

◆ __rmw_wait()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_wait ( const char *  identifier,
rmw_subscriptions_t subscriptions,
rmw_guard_conditions_t guard_conditions,
rmw_services_t services,
rmw_clients_t clients,
rmw_events_t events,
rmw_wait_set_t wait_set,
const rmw_time_t wait_timeout 
)

◆ __rmw_create_wait_set()

rmw_wait_set_t* rmw_fastrtps_shared_cpp::__rmw_create_wait_set ( const char *  identifier,
rmw_context_t context,
size_t  max_conditions 
)

◆ __rmw_destroy_wait_set()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_destroy_wait_set ( const char *  identifier,
rmw_wait_set_t wait_set 
)

◆ __rmw_get_publishers_info_by_topic()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_publishers_info_by_topic ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  topic_name,
bool  no_mangle,
rmw_topic_endpoint_info_array_t publishers_info 
)

◆ __rmw_get_subscriptions_info_by_topic()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_get_subscriptions_info_by_topic ( const char *  identifier,
const rmw_node_t node,
rcutils_allocator_t allocator,
const char *  topic_name,
bool  no_mangle,
rmw_topic_endpoint_info_array_t subscriptions_info 
)

◆ __rmw_qos_profile_check_compatible()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_qos_profile_check_compatible ( const rmw_qos_profile_t  publisher_profile,
const rmw_qos_profile_t  subscription_profile,
rmw_qos_compatibility_type_t compatibility,
char *  reason,
size_t  reason_size 
)

◆ __rmw_publisher_get_network_flow_endpoints()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_publisher_get_network_flow_endpoints ( const rmw_publisher_t publisher,
rcutils_allocator_t allocator,
rmw_network_flow_endpoint_array_t network_flow_endpoint_array 
)

◆ __rmw_subscription_get_network_flow_endpoints()

rmw_ret_t rmw_fastrtps_shared_cpp::__rmw_subscription_get_network_flow_endpoints ( const rmw_subscription_t subscription,
rcutils_allocator_t allocator,
rmw_network_flow_endpoint_array_t network_flow_endpoint_array 
)

◆ rmw_init_options_init()

rmw_ret_t rmw_fastrtps_shared_cpp::rmw_init_options_init ( const char *  identifier,
rmw_init_options_t init_options,
rcutils_allocator_t  allocator 
)

◆ rmw_init_options_copy()

rmw_ret_t rmw_fastrtps_shared_cpp::rmw_init_options_copy ( const char *  identifier,
const rmw_init_options_t src,
rmw_init_options_t dst 
)

◆ rmw_init_options_fini()

rmw_ret_t rmw_fastrtps_shared_cpp::rmw_init_options_fini ( const char *  identifier,
rmw_init_options_t init_options 
)

◆ destroy_subscription()

rmw_ret_t rmw_fastrtps_shared_cpp::destroy_subscription ( const char *  identifier,
CustomParticipantInfo participant_info,
rmw_subscription_t subscription 
)

◆ cast_error_dds_to_rmw()

rmw_ret_t rmw_fastrtps_shared_cpp::cast_error_dds_to_rmw ( eprosima::fastrtps::types::ReturnCode_t  code)

Convert a Fast DDS return code into the corresponding rmw_ret_t

Parameters
[in]codeThe Fast DDS return code to be translated
Returns
the corresponding rmw_ret_t value

◆ cast_or_create_topic()

bool rmw_fastrtps_shared_cpp::cast_or_create_topic ( eprosima::fastdds::dds::DomainParticipant *  participant,
eprosima::fastdds::dds::TopicDescription *  desc,
const std::string topic_name,
const std::string type_name,
const eprosima::fastdds::dds::TopicQos &  topic_qos,
bool  is_writer_topic,
TopicHolder topic_holder 
)

Auxiliary method to reuse or create a topic during the creation of an entity.

Parameters
[in]participantDomainParticipant where the topic will be created.
[in]descTopicDescription returned by find_and_check_topic_and_type.
[in]topic_nameName of the topic.
[in]type_nameName of the type.
[in]topic_qosQoS with which to create the topic.
[in]is_writer_topicWhether the resulting topic will be used on a DataWriter.
[out]topic_holderWill hold the pointer to the topic along with the necessary information for its deletion. When is_writer_topic is true, topic_holder->topic can be directly used on a create_datawriter call. When is_writer_topic is false, topic_holder->desc can be directly used on a create_datareader call.
Returns
true when the topic was reused (topic_holder->should_be_deleted will be false)
true when the topic was created (topic_holder->should_be_deleted will be true)
false when the topic could not be created

◆ find_and_check_topic_and_type()

bool rmw_fastrtps_shared_cpp::find_and_check_topic_and_type ( const CustomParticipantInfo participant_info,
const std::string topic_name,
const std::string type_name,
eprosima::fastdds::dds::TopicDescription **  returned_topic,
eprosima::fastdds::dds::TypeSupport *  returned_type 
)

Tries to find already registered topic and type.

Parameters
[in]participant_infoCustomParticipantInfo associated to the context.
[in]topic_nameName of the topic for the entity being created.
[in]type_nameName of the type for the entity being created.
[out]returned_topicTopicDescription for topic_name
[out]returned_typeTypeSupport for type_name
Returns
false if topic_name was previously created with a different type name.
true when there is no such conflict. Returned topic and type may be null if they were not previously registered on the participant.

◆ remove_topic_and_type()

void rmw_fastrtps_shared_cpp::remove_topic_and_type ( const CustomParticipantInfo participant_info,
const eprosima::fastdds::dds::TopicDescription *  topic,
const eprosima::fastdds::dds::TypeSupport &  type 
)

Performs removal of associated topic and type.

Parameters
[in]participant_infoCustomParticipantInfo associated to the context.
[in]topicTopic of the entity being deleted.
[in]typeTypeSupport of the entity being deleted.