Struct rmw_context_impl_s

Defined in File context.hpp

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

explicit rmw_context_impl_s(rmw_context_t *const base)

~rmw_context_impl_s()

rmw_ret_t initialize_node()

rmw_ret_t finalize_node()

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

std::mutex common_mutex

rmw_context_t *base

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

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}

std::map<std::string, RMW_Connext_MessageTypeSupport*> registered_types

std::mutex endpoint_mutex