Struct rmw_context_impl_s

Struct Documentation

struct rmw_context_impl_s

Public Types

enum class participant_qos_override_policy_t

Values:

enumerator All
enumerator Basic
enumerator Never
enum class endpoint_qos_override_policy_t

Values:

enumerator Always
enumerator DDSTopics
enumerator Never

Public Functions

inline explicit rmw_context_impl_s(rmw_context_t *const base)
inline ~rmw_context_impl_s()
rmw_ret_t initialize_node(const rmw_discovery_options_t *const discovery_options)
rmw_ret_t finalize_node()
rmw_ret_t initialize_participant()
rmw_ret_t enable_participant()
rmw_ret_t finalize_participant()
uint32_t next_client_id()
rmw_ret_t assert_topic(DDS_DomainParticipant *const participant, const char *const topic_name, const char *const type_name, const bool internal, DDS_Topic **const topic, bool &created)
rmw_ret_t finalize()

Public Members

rmw_dds_common::Context common
rmw_context_t *base
DDS_DomainParticipantFactory *factory
DDS_DomainId_t domain_id
DDS_DomainParticipant *participant
DDS_Publisher *dds_pub
DDS_Subscriber *dds_sub
DDS_DataReader *dr_participants
DDS_DataReader *dr_publications
DDS_DataReader *dr_subscriptions
rmw_discovery_options_t *discovery_options
char *domain_tag
std::string qos_ctx_name
std::string qos_ctx_namespace
bool use_default_publish_mode
RMW_Connext_RequestReplyMapping request_reply_mapping
bool cyclone_compatible = {false}
participant_qos_override_policy_t participant_qos_override_policy
endpoint_qos_override_policy_t endpoint_qos_override_policy
std::regex endpoint_qos_override_policy_topics_regex
struct DDS_StringSeq initial_peers = DDS_SEQUENCE_INITIALIZER
size_t node_count = {0}
std::mutex initialization_mutex
bool is_shutdown = {false}
uint32_t client_service_id = {0}
std::map<std::string, RMW_Connext_MessageTypeSupport*> registered_types
std::mutex endpoint_mutex