#include <TopicDetails.h>

Collaboration diagram for OpenDDS::DCPS::TopicDetails:

[legend]

Public Member Functions
	TopicDetails ()

void	init (const OPENDDS_STRING &name, const DCPS::GUID_t &topic_id)

void	set_local (const OPENDDS_STRING &data_type_name, const DDS::TopicQos &qos, bool has_dcps_key, TopicCallbacks *topic_callbacks)

void	unset_local ()

void	update (const DDS::TopicQos &qos)

void	add_local_publication (const DCPS::GUID_t &guid)

void	remove_local_publication (const DCPS::GUID_t &guid)

const RepoIdSet &	local_publications () const

void	add_local_subscription (const DCPS::GUID_t &guid)

void	remove_local_subscription (const DCPS::GUID_t &guid)

const RepoIdSet &	local_subscriptions () const

void	add_discovered_publication (const DCPS::GUID_t &guid)

void	remove_discovered_publication (const DCPS::GUID_t &guid)

const RepoIdSet &	discovered_publications () const

void	add_discovered_subscription (const DCPS::GUID_t &guid)

void	remove_discovered_subscription (const DCPS::GUID_t &guid)

const RepoIdSet &	discovered_subscriptions () const

void	increment_inconsistent ()

const OPENDDS_STRING	local_data_type_name () const

const DDS::TopicQos	local_qos () const

const DCPS::GUID_t &	topic_id () const

bool	has_dcps_key () const

bool	local_is_set () const

bool	is_dead () const

Detailed Description

Definition at line 24 of file TopicDetails.h.

Constructor & Destructor Documentation

◆ TopicDetails()

OpenDDS::DCPS::TopicDetails::TopicDetails ( )

inline

Definition at line 26 of file TopicDetails.h.

         : topic_id_()
         , has_dcps_key_(false)
         , topic_callbacks_(0)
         , inconsistent_topic_count_(0)
         , assertion_count_(0)
       {}

Member Function Documentation

◆ add_discovered_publication()

void OpenDDS::DCPS::TopicDetails::add_discovered_publication ( const DCPS::GUID_t & guid )

inline

Definition at line 98 of file TopicDetails.h.

References discovered_publications_.

Referenced by OpenDDS::RTPS::Sedp::process_discovered_writer_data().

       {
         discovered_publications_.insert(guid);
       }

◆ add_discovered_subscription()

void OpenDDS::DCPS::TopicDetails::add_discovered_subscription ( const DCPS::GUID_t & guid )

inline

Definition at line 113 of file TopicDetails.h.

References discovered_subscriptions_.

Referenced by OpenDDS::RTPS::Sedp::process_discovered_reader_data().

       {
         discovered_subscriptions_.insert(guid);
       }

◆ add_local_publication()

void OpenDDS::DCPS::TopicDetails::add_local_publication ( const DCPS::GUID_t & guid )

inline

Definition at line 68 of file TopicDetails.h.

References local_publications_.

Referenced by OpenDDS::RTPS::Sedp::add_publication(), and OpenDDS::DCPS::StaticEndpointManager::add_publication().

       {
         local_publications_.insert(guid);
       }

◆ add_local_subscription()

void OpenDDS::DCPS::TopicDetails::add_local_subscription ( const DCPS::GUID_t & guid )

inline

Definition at line 83 of file TopicDetails.h.

References local_subscriptions_.

Referenced by OpenDDS::RTPS::Sedp::add_subscription(), and OpenDDS::DCPS::StaticEndpointManager::add_subscription().

       {
         local_subscriptions_.insert(guid);
       }

◆ discovered_publications()

const RepoIdSet& OpenDDS::DCPS::TopicDetails::discovered_publications ( ) const

inline

Definition at line 108 of file TopicDetails.h.

References discovered_publications_.

Referenced by OpenDDS::RTPS::Sedp::ignore(), OpenDDS::DCPS::StaticEndpointManager::ignore(), OpenDDS::DCPS::StaticEndpointManager::match_endpoints(), and OpenDDS::RTPS::Sedp::match_endpoints().

       {
         return discovered_publications_;
       }

◆ discovered_subscriptions()

const RepoIdSet& OpenDDS::DCPS::TopicDetails::discovered_subscriptions ( ) const

inline

Definition at line 123 of file TopicDetails.h.

References discovered_subscriptions_.

Referenced by OpenDDS::RTPS::Sedp::ignore(), OpenDDS::DCPS::StaticEndpointManager::ignore(), OpenDDS::DCPS::StaticEndpointManager::match_endpoints(), and OpenDDS::RTPS::Sedp::match_endpoints().

       {
         return discovered_subscriptions_;
       }

◆ has_dcps_key()

bool OpenDDS::DCPS::TopicDetails::has_dcps_key ( ) const

inline

Definition at line 137 of file TopicDetails.h.

References has_dcps_key_.

Referenced by set_local().

137 { return has_dcps_key_; }

OpenDDS::DCPS::TopicDetails::has_dcps_key_

bool has_dcps_key_

Definition: TopicDetails.h:154

◆ increment_inconsistent()

void OpenDDS::DCPS::TopicDetails::increment_inconsistent ( )

inline

Definition at line 128 of file TopicDetails.h.

References OpenDDS::DCPS::TopicCallbacks::inconsistent_topic(), inconsistent_topic_count_, and topic_callbacks_.

       {
         ++inconsistent_topic_count_;
         topic_callbacks_->inconsistent_topic(inconsistent_topic_count_);
       }

◆ init()

void OpenDDS::DCPS::TopicDetails::init	(	const OPENDDS_STRING &	name,
		const DCPS::GUID_t &	topic_id
	)

inline

Definition at line 34 of file TopicDetails.h.

References name, name_, topic_id(), and topic_id_.

Referenced by OpenDDS::RTPS::Sedp::assert_topic(), and OpenDDS::DCPS::StaticEndpointManager::assert_topic().

                                             {
         name_ = name;
         topic_id_ = topic_id;
       }

◆ is_dead()

bool OpenDDS::DCPS::TopicDetails::is_dead ( ) const

inline

Definition at line 140 of file TopicDetails.h.

References discovered_publications_, discovered_subscriptions_, local_publications_, local_subscriptions_, and topic_callbacks_.

Referenced by OpenDDS::RTPS::Sedp::ignore(), OpenDDS::DCPS::StaticEndpointManager::ignore(), OpenDDS::RTPS::Sedp::remove_topic(), and OpenDDS::DCPS::StaticEndpointManager::remove_topic().

       {
         return topic_callbacks_ == 0 &&
           local_publications_.empty() &&
           local_subscriptions_.empty() &&
           discovered_publications_.empty() &&
           discovered_subscriptions_.empty();
       }

◆ local_data_type_name()

const OPENDDS_STRING OpenDDS::DCPS::TopicDetails::local_data_type_name ( ) const

inline

Definition at line 134 of file TopicDetails.h.

References local_data_type_name_.

Referenced by OpenDDS::RTPS::Sedp::find_topic(), OpenDDS::DCPS::StaticEndpointManager::find_topic(), OpenDDS::RTPS::Sedp::populate_discovered_reader_msg(), and OpenDDS::RTPS::Sedp::populate_discovered_writer_msg().

134 { return local_data_type_name_; }

OpenDDS::DCPS::TopicDetails::local_data_type_name_

OPENDDS_STRING local_data_type_name_

Definition: TopicDetails.h:151

◆ local_is_set()

bool OpenDDS::DCPS::TopicDetails::local_is_set ( ) const

inline

Definition at line 138 of file TopicDetails.h.

References topic_callbacks_.

138 { return topic_callbacks_; }

OpenDDS::DCPS::TopicDetails::topic_callbacks_

TopicCallbacks * topic_callbacks_

Definition: TopicDetails.h:155

◆ local_publications()

const RepoIdSet& OpenDDS::DCPS::TopicDetails::local_publications ( ) const

inline

Definition at line 78 of file TopicDetails.h.

References local_publications_.

Referenced by OpenDDS::DCPS::StaticEndpointManager::match_endpoints(), OpenDDS::RTPS::Sedp::match_endpoints(), and OpenDDS::RTPS::Sedp::update_topic_qos().

       {
         return local_publications_;
       }

◆ local_qos()

const DDS::TopicQos OpenDDS::DCPS::TopicDetails::local_qos ( ) const

inline

Definition at line 135 of file TopicDetails.h.

References local_qos_.

Referenced by OpenDDS::RTPS::Sedp::find_topic(), OpenDDS::DCPS::StaticEndpointManager::find_topic(), OpenDDS::RTPS::Sedp::populate_discovered_reader_msg(), OpenDDS::RTPS::Sedp::populate_discovered_writer_msg(), and OpenDDS::RTPS::Sedp::update_topic_qos().

135 { return local_qos_; }

OpenDDS::DCPS::TopicDetails::local_qos_

DDS::TopicQos local_qos_

Definition: TopicDetails.h:152

◆ local_subscriptions()

const RepoIdSet& OpenDDS::DCPS::TopicDetails::local_subscriptions ( ) const

inline

Definition at line 93 of file TopicDetails.h.

References local_subscriptions_.

Referenced by OpenDDS::DCPS::StaticEndpointManager::match_endpoints(), OpenDDS::RTPS::Sedp::match_endpoints(), and OpenDDS::RTPS::Sedp::update_topic_qos().

       {
         return local_subscriptions_;
       }

◆ remove_discovered_publication()

void OpenDDS::DCPS::TopicDetails::remove_discovered_publication ( const DCPS::GUID_t & guid )

inline

Definition at line 103 of file TopicDetails.h.

References discovered_publications_.

Referenced by OpenDDS::RTPS::Sedp::ignore(), and OpenDDS::DCPS::StaticEndpointManager::ignore().

       {
         discovered_publications_.erase(guid);
       }

◆ remove_discovered_subscription()

void OpenDDS::DCPS::TopicDetails::remove_discovered_subscription ( const DCPS::GUID_t & guid )

inline

Definition at line 118 of file TopicDetails.h.

References discovered_subscriptions_.

Referenced by OpenDDS::RTPS::Sedp::ignore(), and OpenDDS::DCPS::StaticEndpointManager::ignore().

       {
         discovered_subscriptions_.erase(guid);
       }

◆ remove_local_publication()

void OpenDDS::DCPS::TopicDetails::remove_local_publication ( const DCPS::GUID_t & guid )

inline

Definition at line 73 of file TopicDetails.h.

References local_publications_.

       {
         local_publications_.erase(guid);
       }

◆ remove_local_subscription()

void OpenDDS::DCPS::TopicDetails::remove_local_subscription ( const DCPS::GUID_t & guid )

inline

Definition at line 88 of file TopicDetails.h.

References local_subscriptions_.

       {
         local_subscriptions_.erase(guid);
       }

◆ set_local()

void OpenDDS::DCPS::TopicDetails::set_local	(	const OPENDDS_STRING &	data_type_name,
		const DDS::TopicQos &	qos,
		bool	has_dcps_key,
		TopicCallbacks *	topic_callbacks
	)

inline

Definition at line 40 of file TopicDetails.h.

References assertion_count_, has_dcps_key(), has_dcps_key_, local_data_type_name_, local_qos_, OPENDDS_ASSERT, and topic_callbacks_.

Referenced by OpenDDS::RTPS::Sedp::assert_topic(), and OpenDDS::DCPS::StaticEndpointManager::assert_topic().

       {
         OPENDDS_ASSERT(topic_callbacks != 0);
 
         local_data_type_name_ = data_type_name;
         local_qos_ = qos;
         has_dcps_key_ = has_dcps_key;
         topic_callbacks_ = topic_callbacks;
         ++assertion_count_;
       }

◆ topic_id()

const DCPS::GUID_t& OpenDDS::DCPS::TopicDetails::topic_id ( ) const

inline

Definition at line 136 of file TopicDetails.h.

References topic_id_.

Referenced by OpenDDS::RTPS::Sedp::find_topic(), OpenDDS::DCPS::StaticEndpointManager::find_topic(), and init().

136 { return topic_id_; }

OpenDDS::DCPS::TopicDetails::topic_id_

DCPS::GUID_t topic_id_

Definition: TopicDetails.h:153

◆ unset_local()

void OpenDDS::DCPS::TopicDetails::unset_local ( )

inline

Definition at line 54 of file TopicDetails.h.

References assertion_count_, local_publications_, local_subscriptions_, OPENDDS_ASSERT, and topic_callbacks_.

Referenced by OpenDDS::RTPS::Sedp::remove_topic(), and OpenDDS::DCPS::StaticEndpointManager::remove_topic().

       {
         if (--assertion_count_ == 0) {
           OPENDDS_ASSERT(local_publications_.empty());
           OPENDDS_ASSERT(local_subscriptions_.empty());
           topic_callbacks_ = 0;
         }
       }

◆ update()

void OpenDDS::DCPS::TopicDetails::update ( const DDS::TopicQos & qos )

inline

Definition at line 63 of file TopicDetails.h.

References local_qos_.

Referenced by OpenDDS::RTPS::Sedp::update_topic_qos().

       {
         local_qos_ = qos;
       }

Member Data Documentation

◆ assertion_count_

int OpenDDS::DCPS::TopicDetails::assertion_count_

private

Definition at line 162 of file TopicDetails.h.

Referenced by set_local(), and unset_local().

◆ discovered_publications_

RepoIdSet OpenDDS::DCPS::TopicDetails::discovered_publications_

private

Definition at line 159 of file TopicDetails.h.

Referenced by add_discovered_publication(), discovered_publications(), is_dead(), and remove_discovered_publication().

◆ discovered_subscriptions_

RepoIdSet OpenDDS::DCPS::TopicDetails::discovered_subscriptions_

private

Definition at line 160 of file TopicDetails.h.

Referenced by add_discovered_subscription(), discovered_subscriptions(), is_dead(), and remove_discovered_subscription().

◆ has_dcps_key_

bool OpenDDS::DCPS::TopicDetails::has_dcps_key_

private

Definition at line 154 of file TopicDetails.h.

Referenced by has_dcps_key(), and set_local().

◆ inconsistent_topic_count_

int OpenDDS::DCPS::TopicDetails::inconsistent_topic_count_

private

Definition at line 161 of file TopicDetails.h.

Referenced by increment_inconsistent().

◆ local_data_type_name_

OPENDDS_STRING OpenDDS::DCPS::TopicDetails::local_data_type_name_

private

Definition at line 151 of file TopicDetails.h.

Referenced by local_data_type_name(), and set_local().

◆ local_publications_

RepoIdSet OpenDDS::DCPS::TopicDetails::local_publications_

private

Definition at line 157 of file TopicDetails.h.

Referenced by add_local_publication(), is_dead(), local_publications(), remove_local_publication(), and unset_local().

◆ local_qos_

DDS::TopicQos OpenDDS::DCPS::TopicDetails::local_qos_

private

Definition at line 152 of file TopicDetails.h.

Referenced by local_qos(), set_local(), and update().

◆ local_subscriptions_

RepoIdSet OpenDDS::DCPS::TopicDetails::local_subscriptions_

private

Definition at line 158 of file TopicDetails.h.

Referenced by add_local_subscription(), is_dead(), local_subscriptions(), remove_local_subscription(), and unset_local().

◆ name_

OPENDDS_STRING OpenDDS::DCPS::TopicDetails::name_

private

Definition at line 150 of file TopicDetails.h.

Referenced by init().

◆ topic_callbacks_

TopicCallbacks* OpenDDS::DCPS::TopicDetails::topic_callbacks_

private

Definition at line 155 of file TopicDetails.h.

Referenced by increment_inconsistent(), is_dead(), local_is_set(), set_local(), and unset_local().

◆ topic_id_

DCPS::GUID_t OpenDDS::DCPS::TopicDetails::topic_id_

private

Definition at line 153 of file TopicDetails.h.

Referenced by init(), and topic_id().

The documentation for this struct was generated from the following file:

TopicDetails.h

Private Attributes
OPENDDS_STRING	name_

OPENDDS_STRING	local_data_type_name_

DDS::TopicQos	local_qos_

DCPS::GUID_t	topic_id_

bool	has_dcps_key_

TopicCallbacks *	topic_callbacks_

RepoIdSet	local_publications_

RepoIdSet	local_subscriptions_

RepoIdSet	discovered_publications_

RepoIdSet	discovered_subscriptions_

int	inconsistent_topic_count_

int	assertion_count_

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ TopicDetails()

Member Function Documentation

◆ add_discovered_publication()

◆ add_discovered_subscription()

◆ add_local_publication()

◆ add_local_subscription()

◆ discovered_publications()

◆ discovered_subscriptions()

◆ has_dcps_key()

◆ increment_inconsistent()

◆ init()

◆ is_dead()

◆ local_data_type_name()

◆ local_is_set()

◆ local_publications()

◆ local_qos()

◆ local_subscriptions()

◆ remove_discovered_publication()

◆ remove_discovered_subscription()

◆ remove_local_publication()

◆ remove_local_subscription()

◆ set_local()

◆ topic_id()

◆ unset_local()

◆ update()

Member Data Documentation

◆ assertion_count_

◆ discovered_publications_

◆ discovered_subscriptions_

◆ has_dcps_key_

◆ inconsistent_topic_count_

◆ local_data_type_name_

◆ local_publications_

◆ local_qos_

◆ local_subscriptions_

◆ name_

◆ topic_callbacks_

◆ topic_id_