Representative of a Topic. More...

#include <DCPS_IR_Topic.h>

Inheritance diagram for DCPS_IR_Topic:

Collaboration diagram for DCPS_IR_Topic:

[legend]

Public Member Functions
	DCPS_IR_Topic (const OpenDDS::DCPS::GUID_t &id, const DDS::TopicQos &qos, DCPS_IR_Domain domain, DCPS_IR_Participant creator, DCPS_IR_Topic_Description *description, bool isBIT)

	~DCPS_IR_Topic ()

void	release (bool removing)

int	add_publication_reference (DCPS_IR_Publication *publication, bool associate=true)

int	remove_publication_reference (DCPS_IR_Publication *publication)

int	add_subscription_reference (DCPS_IR_Subscription *subscription, bool associate=true)

int	remove_subscription_reference (DCPS_IR_Subscription *subscription)

void	try_associate (DCPS_IR_Subscription *subscription)

void	reevaluate_associations (DCPS_IR_Subscription *subscription)

OpenDDS::DCPS::GUID_t	get_id () const

OpenDDS::DCPS::GUID_t	get_participant_id () const

DCPS_IR_Topic_Description *	get_topic_description ()

DDS::TopicQos *	get_topic_qos ()

bool	set_topic_qos (const DDS::TopicQos &qos)

DDS::InstanceHandle_t	get_handle ()

void	set_handle (DDS::InstanceHandle_t handle)

CORBA::Boolean	is_bit ()

void	set_bit_status (CORBA::Boolean isBIT)

void	reassociate_all_publications ()

std::string	dump_to_string (const std::string &prefix, int depth) const

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::EnableContainerSupportedUniquePtr< DCPS_IR_Topic >
	EnableContainerSupportedUniquePtr ()

void	_add_ref ()

void	_remove_ref ()

long	ref_count () const

Detailed Description

Representative of a Topic.

Definition at line 43 of file DCPS_IR_Topic.h.

Constructor & Destructor Documentation

◆ DCPS_IR_Topic()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL DCPS_IR_Topic::DCPS_IR_Topic	(	const OpenDDS::DCPS::GUID_t &	id,
		const DDS::TopicQos &	qos,
		DCPS_IR_Domain *	domain,
		DCPS_IR_Participant *	creator,
		DCPS_IR_Topic_Description *	description,
		bool	isBIT
	)

Definition at line 25 of file DCPS_IR_Topic.cpp.

   : id_(id),
     qos_(qos),
     domain_(domain),
     participant_(creator),
     description_(description),
     handle_(0),
     isBIT_(isBIT),
     removed_(false)
 {
 }

◆ ~DCPS_IR_Topic()

DCPS_IR_Topic::~DCPS_IR_Topic ( )

Definition at line 42 of file DCPS_IR_Topic.cpp.

43 {

44 }

Member Function Documentation

◆ add_publication_reference()

int DCPS_IR_Topic::add_publication_reference	(	DCPS_IR_Publication *	publication,
		bool	associate = `true`
	)

Adds the publication to the list of publications Calls the topic description's try associate if successfully added 'associate' switch toggles association attempt. Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 57 of file DCPS_IR_Topic.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, description_, domain_, DCPS_IR_Publication::get_id(), id_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), LM_DEBUG, LM_ERROR, LM_WARNING, publicationRefs_, DCPS_IR_Domain::publish_publication_bit(), and DCPS_IR_Topic_Description::try_associate_publication().

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

 {
   int status = publicationRefs_.insert(publication);
 
   switch (status) {
   case 0:
 
     // Publish the BIT information
     domain_->publish_publication_bit(publication);
 
     if (associate) {
       description_->try_associate_publication(publication);
       // Do not check incompatible qos here.  The check is done
       // in the DCPS_IR_Topic_Description::try_associate_publication method
     }
 
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Topic::add_publication_reference: ")
                  ACE_TEXT("topic %C added publication %C at %x\n"),
                  std::string(topic_converter).c_str(),
                  std::string(pub_converter).c_str(),
                  publication));
     }
 
     break;
 
   case 1:
 
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
       ACE_DEBUG((LM_WARNING,
                  ACE_TEXT("(%P|%t) WARNING: DCPS_IR_Topic::add_publication_reference: ")
                  ACE_TEXT("topic %C attempt to re-add publication %C.\n"),
                  std::string(topic_converter).c_str(),
                  std::string(pub_converter).c_str()));
     }
 
     break;
 
   case -1: {
     OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
     OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic::add_publication_reference: ")
                ACE_TEXT("topic %C failed to add publication %C\n"),
                std::string(topic_converter).c_str(),
                std::string(pub_converter).c_str()));
   }
   };
 
   return status;
 }

◆ add_subscription_reference()

int DCPS_IR_Topic::add_subscription_reference	(	DCPS_IR_Subscription *	subscription,
		bool	associate = `true`
	)

Adds the subscription to the list of subscriptions and let description handle the association. Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 143 of file DCPS_IR_Topic.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), DCPS_IR_Topic_Description::add_subscription_reference(), OpenDDS::DCPS::DCPS_debug_level, description_, DCPS_IR_Subscription::get_id(), id_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), LM_DEBUG, LM_ERROR, and subscriptionRefs_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

 {
   int status = subscriptionRefs_.insert(subscription);
 
   switch (status) {
   case 0:
 
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Topic::add_subscription_reference: ")
                  ACE_TEXT("topic %C added subscription %C at %x.\n"),
                  std::string(topic_converter).c_str(),
                  std::string(sub_converter).c_str(),
                  subscription));
     }
 
     status = this->description_->add_subscription_reference(subscription, associate);
     break;
 
   case 1: {
     OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic::add_subscription_reference: ")
                ACE_TEXT("topic %C attempt to re-add subscription %C.\n"),
                std::string(topic_converter).c_str(),
                std::string(sub_converter).c_str()));
   }
   break;
 
   case -1: {
     OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic::add_subscription_reference: ")
                ACE_TEXT("topic %C failed to add subscription %C.\n"),
                std::string(topic_converter).c_str(),
                std::string(sub_converter).c_str()));
   }
   };
 
   return status;
 }

◆ dump_to_string()

std::string DCPS_IR_Topic::dump_to_string	(	const std::string &	prefix,
		int	depth
	)		const

Definition at line 375 of file DCPS_IR_Topic.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), id_, isBIT_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, publicationRefs_, and subscriptionRefs_.

 {
   std::string str;
 #if !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
   OpenDDS::DCPS::RepoIdConverter local_converter(id_);
 
   for (int i=0; i < depth; i++)
     str += prefix;
   std::string indent = str + prefix;
   str += "DCPS_IR_Topic[";
   str += std::string(local_converter);
   str += "]";
   if (isBIT_)
     str += " (BIT)";
   str += "\n";
 
   str += indent + "Publications:\n";
   for (DCPS_IR_Publication_Set::const_iterator pub = publicationRefs_.begin();
        pub != publicationRefs_.end();
        pub++)
   {
     OpenDDS::DCPS::RepoIdConverter pub_converter((*pub)->get_id());
     str += indent + std::string(pub_converter);
     str += "\n";
 
   }
 
   str += indent + "Subscriptions:\n";
   for (DCPS_IR_Subscription_Set::const_iterator sub = subscriptionRefs_.begin();
        sub != subscriptionRefs_.end();
        sub++)
   {
     OpenDDS::DCPS::RepoIdConverter sub_converter((*sub)->get_id());
     str += indent + std::string(sub_converter);
     str += "\n";
   }
 #endif // !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
   return str;
 }

◆ get_handle()

DDS::InstanceHandle_t DCPS_IR_Topic::get_handle ( void )

Definition at line 327 of file DCPS_IR_Topic.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_topic_bit().

 {
   return handle_;
 }

◆ get_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Topic::get_id ( void ) const

Definition at line 220 of file DCPS_IR_Topic.cpp.

References id_.

Referenced by DCPS_IR_Topic_Description::add_topic(), DCPS_IR_Participant::add_topic_reference(), TAO_DDS_DCPSInfo_i::find_topic(), DCPS_IR_Domain::find_topic(), DCPS_IR_Topic_Description::get_first_topic(), DCPS_IR_Publication::get_topic_id(), DCPS_IR_Subscription::get_topic_id(), DCPS_IR_Domain::publish_topic_bit(), DCPS_IR_Topic_Description::remove_topic(), and DCPS_IR_Domain::remove_topic().

 {
   return id_;
 }

◆ get_participant_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Topic::get_participant_id ( ) const

Definition at line 225 of file DCPS_IR_Topic.cpp.

References DCPS_IR_Participant::get_id(), and participant_.

 {
   return participant_->get_id();
 }

◆ get_topic_description()

DCPS_IR_Topic_Description * DCPS_IR_Topic::get_topic_description ( )

Return pointer to the Topic Description Domain retains ownership

Definition at line 322 of file DCPS_IR_Topic.cpp.

References description_.

Referenced by TAO_DDS_DCPSInfo_i::find_topic(), DCPS_IR_Publication::get_topic_description(), DCPS_IR_Subscription::get_topic_description(), DCPS_IR_Domain::publish_topic_bit(), DCPS_IR_Subscription::reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), DCPS_IR_Domain::remove_topic(), DCPS_IR_Publication::set_qos(), and DCPS_IR_Subscription::set_qos().

 {
   return description_;
 }

◆ get_topic_qos()

DDS::TopicQos * DCPS_IR_Topic::get_topic_qos ( )

Return pointer to the Topic qos Topic retains ownership

Definition at line 230 of file DCPS_IR_Topic.cpp.

References qos_.

Referenced by TAO_DDS_DCPSInfo_i::find_topic(), DCPS_IR_Domain::publish_publication_bit(), DCPS_IR_Domain::publish_subscription_bit(), and DCPS_IR_Domain::publish_topic_bit().

 {
   return &qos_;
 }

◆ is_bit()

CORBA::Boolean DCPS_IR_Topic::is_bit ( )

Definition at line 337 of file DCPS_IR_Topic.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::dispose_topic_bit().

 {
   return isBIT_;
 }

◆ reassociate_all_publications()

void DCPS_IR_Topic::reassociate_all_publications ( )

Try to associate all the current publications. This is used to reconnect Built in Topics after a persistent restart.

Definition at line 363 of file DCPS_IR_Topic.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), description_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), publicationRefs_, and DCPS_IR_Topic_Description::try_associate_publication().

 {
   DCPS_IR_Publication_Set::ITERATOR iter = publicationRefs_.begin();
   DCPS_IR_Publication_Set::ITERATOR end = publicationRefs_.end();
 
   for ( ; iter != end; ++iter)
   {
     description_->try_associate_publication(*iter);
   }
 }

◆ reevaluate_associations()

void DCPS_IR_Topic::reevaluate_associations ( DCPS_IR_Subscription * subscription )

Called by the DCPS_IR_Topic_Description to re-evaluate the association between the publications of this topic and the provided subscription.

Definition at line 347 of file DCPS_IR_Topic.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), publicationRefs_, DCPS_IR_Subscription::reevaluate_association(), and DCPS_IR_Publication::reevaluate_association().

Referenced by DCPS_IR_Topic_Description::reevaluate_associations().

 {
   DCPS_IR_Publication * pub = 0;
   DCPS_IR_Publication_Set::ITERATOR iter = publicationRefs_.begin();
   DCPS_IR_Publication_Set::ITERATOR end = publicationRefs_.end();
 
   while (iter != end) {
     pub = *iter;
     ++iter;
 
     subscription->reevaluate_association(pub);
     pub->reevaluate_association(subscription);
   }
 }

◆ release()

void DCPS_IR_Topic::release ( bool removing )

Delete the topic object upon last topic associated sub/pub and topic object deletion. It's kind of reference counting. The removing true indicates it's called upon delete_topic, otherwise it's upon remove_publication/remove_subscription.

Definition at line 46 of file DCPS_IR_Topic.cpp.

References domain_, id_, publicationRefs_, DCPS_IR_Domain::remove_topic_id_mapping(), removed_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size(), and subscriptionRefs_.

Referenced by DCPS_IR_Participant::remove_all_dependents(), DCPS_IR_Participant::remove_publication(), DCPS_IR_Participant::remove_subscription(), and DCPS_IR_Domain::remove_topic().

 {
   if (removing || this->removed_) {
     this->removed_ = true;
 
     if (publicationRefs_.size() == 0 && subscriptionRefs_.size() == 0) {
       this->domain_->remove_topic_id_mapping(this->id_);
     }
   }
 }

◆ remove_publication_reference()

int DCPS_IR_Topic::remove_publication_reference ( DCPS_IR_Publication * publication )

Removes the publication from the list of publications Returns 0 if successful

Definition at line 115 of file DCPS_IR_Topic.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Publication::get_id(), id_, LM_DEBUG, LM_ERROR, publicationRefs_, and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove().

Referenced by DCPS_IR_Participant::remove_all_dependents(), and DCPS_IR_Participant::remove_publication().

 {
   int status = publicationRefs_.remove(publication);
 
   if (0 == status) {
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Topic::remove_publication_reference: ")
                  ACE_TEXT("topic %C removed publication %C.\n"),
                  std::string(topic_converter).c_str(),
                  std::string(pub_converter).c_str()));
     }
 
   } else {
     OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
     OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic::remove_publication_reference: ")
                ACE_TEXT("topic %C failed to remove publication %C.\n"),
                std::string(topic_converter).c_str(),
                std::string(pub_converter).c_str()));
   }
 
   return status;
 }

◆ remove_subscription_reference()

int DCPS_IR_Topic::remove_subscription_reference ( DCPS_IR_Subscription * subscription )

Removes the subscription from the list of subscriptions Returns 0 if successful

Definition at line 190 of file DCPS_IR_Topic.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, description_, DCPS_IR_Subscription::get_id(), id_, LM_DEBUG, LM_ERROR, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove(), DCPS_IR_Topic_Description::remove_subscription_reference(), and subscriptionRefs_.

Referenced by DCPS_IR_Participant::remove_all_dependents(), and DCPS_IR_Participant::remove_subscription().

 {
   int status = subscriptionRefs_.remove(subscription);
 
   if (0 == status) {
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Topic::remove_subscription_reference: ")
                  ACE_TEXT("topic %C removed subscription %C.\n"),
                  std::string(topic_converter).c_str(),
                  std::string(sub_converter).c_str()));
     }
 
     this->description_->remove_subscription_reference(subscription);
 
   } else {
     OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic::remove_subscription_reference: ")
                ACE_TEXT("topic %C failed to remove subscription %C.\n"),
                std::string(topic_converter).c_str(),
                std::string(sub_converter).c_str()));
   } // if (0 == status)
 
   return status;
 }

◆ set_bit_status()

void DCPS_IR_Topic::set_bit_status ( CORBA::Boolean isBIT )

Definition at line 342 of file DCPS_IR_Topic.cpp.

References isBIT_.

Referenced by DCPS_IR_Participant::add_topic_reference(), and DCPS_IR_Domain::publish_topic_bit().

 {
   isBIT_ = isBIT;
 }

◆ set_handle()

void DCPS_IR_Topic::set_handle ( DDS::InstanceHandle_t handle )

Definition at line 332 of file DCPS_IR_Topic.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_topic_bit().

 {
   handle_ = handle;
 }

◆ set_topic_qos()

bool DCPS_IR_Topic::set_topic_qos ( const DDS::TopicQos & qos )

Reset topic qos and also propagate the qos change to related BITs that has the qos copy. Return false if the provided QoS makes the DataWriter and DataReader QoS incompatible. Currently supported changeable QoS in TopicQos do not affect.

Definition at line 235 of file DCPS_IR_Topic.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), domain_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), publicationRefs_, DCPS_IR_Domain::publish_publication_bit(), DCPS_IR_Domain::publish_subscription_bit(), DCPS_IR_Domain::publish_topic_bit(), qos_, subscriptionRefs_, and DDS::TopicQos::topic_data.

Referenced by TAO_DDS_DCPSInfo_i::update_topic_qos().

 {
   // Do not need re-evaluate compatibility and associations when
   // TopicQos changes since only datareader and datawriter QoS
   // are evaludated during normal associations establishment.
   using OpenDDS::DCPS::operator==;
   bool pub_to_rd_wr = !(qos.topic_data == qos_.topic_data);
 
   qos_ = qos;
   domain_->publish_topic_bit(this);
 
   if (!pub_to_rd_wr)
     return true;
 
   // The only changeable TopicQos used by DataWriter and DataReader
   // is topic_data so we need publish it to DW/DR BIT to make they
   // are consistent.
 
   // Update qos in datawriter BIT for associated datawriters.
 
   {
     DCPS_IR_Publication_Set::ITERATOR iter = publicationRefs_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = publicationRefs_.end();
 
     while (iter != end) {
       domain_->publish_publication_bit(*iter);
       ++iter;
     }
   }
 
   // Update qos in datareader BIT for associated datareader.
 
   {
     DCPS_IR_Subscription_Set::ITERATOR iter = subscriptionRefs_.begin();
     DCPS_IR_Subscription_Set::ITERATOR end = subscriptionRefs_.end();
 
     while (iter != end) {
       domain_->publish_subscription_bit(*iter);
       ++iter;
     }
   }
 
   return true;
 }

◆ try_associate()

void DCPS_IR_Topic::try_associate ( DCPS_IR_Subscription * subscription )

Called by the DCPS_IR_Topic_Description Find any compatible publications and associate them using the DCPS_IR_Topic_Description's associate method. This method does not check the subscription's incompatible qos status.

Definition at line 280 of file DCPS_IR_Topic.cpp.

References ACE_DEBUG, ACE_TEXT(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), OpenDDS::DCPS::IncompatibleQosStatus::count_since_last_send, OpenDDS::DCPS::DCPS_debug_level, description_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Subscription::get_id(), DCPS_IR_Publication::get_incompatibleQosStatus(), DCPS_IR_Subscription::get_participant_id(), DCPS_IR_Subscription::get_topic_id(), id_, DCPS_IR_Participant::is_participant_ignored(), DCPS_IR_Participant::is_subscription_ignored(), DCPS_IR_Participant::is_topic_ignored(), LM_DEBUG, participant_, publicationRefs_, DCPS_IR_Topic_Description::try_associate(), and DCPS_IR_Publication::update_incompatible_qos().

Referenced by DCPS_IR_Topic_Description::try_associate_subscription().

 {
   // check if we should ignore this subscription
   if (participant_->is_subscription_ignored(subscription->get_id()) ||
       participant_->is_participant_ignored(subscription->get_participant_id()) ||
       participant_->is_topic_ignored(subscription->get_topic_id())) {
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter topic_converter(id_);
       OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Topic::try_associate: ")
                  ACE_TEXT("topic %C ignoring subscription %C.\n"),
                  std::string(topic_converter).c_str(),
                  std::string(sub_converter).c_str()));
     }
 
   } else {
     // check all publications for compatibility
     DCPS_IR_Publication* pub = 0;
     OpenDDS::DCPS::IncompatibleQosStatus* qosStatus = 0;
 
     DCPS_IR_Publication_Set::ITERATOR iter = publicationRefs_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = publicationRefs_.end();
 
     while (iter != end) {
       pub = *iter;
       ++iter;
       description_->try_associate(pub, subscription);
       // Check the publications QOS status
       qosStatus = pub->get_incompatibleQosStatus();
 
       if (0 < qosStatus->count_since_last_send) {
         pub->update_incompatible_qos();
       }
     } /* while (iter != end) */
 
     // The subscription QOS is not checked because
     // we don't know if the subscription is finished cycling
     // through topics.
   }
 }

Member Data Documentation

◆ description_

DCPS_IR_Topic_Description* DCPS_IR_Topic::description_

private

Definition at line 131 of file DCPS_IR_Topic.h.

Referenced by add_publication_reference(), add_subscription_reference(), get_topic_description(), reassociate_all_publications(), remove_subscription_reference(), and try_associate().

◆ domain_

DCPS_IR_Domain* DCPS_IR_Topic::domain_

private

Definition at line 129 of file DCPS_IR_Topic.h.

Referenced by add_publication_reference(), release(), and set_topic_qos().

◆ handle_

DDS::InstanceHandle_t DCPS_IR_Topic::handle_

private

Definition at line 132 of file DCPS_IR_Topic.h.

Referenced by get_handle(), and set_handle().

◆ id_

OpenDDS::DCPS::GUID_t DCPS_IR_Topic::id_

private

Definition at line 127 of file DCPS_IR_Topic.h.

Referenced by add_publication_reference(), add_subscription_reference(), dump_to_string(), get_id(), release(), remove_publication_reference(), remove_subscription_reference(), and try_associate().

◆ isBIT_

CORBA::Boolean DCPS_IR_Topic::isBIT_

private

Definition at line 133 of file DCPS_IR_Topic.h.

Referenced by dump_to_string(), is_bit(), and set_bit_status().

◆ participant_

DCPS_IR_Participant* DCPS_IR_Topic::participant_

private

Definition at line 130 of file DCPS_IR_Topic.h.

Referenced by get_participant_id(), and try_associate().

◆ publicationRefs_

DCPS_IR_Publication_Set DCPS_IR_Topic::publicationRefs_

private

Definition at line 135 of file DCPS_IR_Topic.h.

Referenced by add_publication_reference(), dump_to_string(), reassociate_all_publications(), reevaluate_associations(), release(), remove_publication_reference(), set_topic_qos(), and try_associate().

◆ qos_

DDS::TopicQos DCPS_IR_Topic::qos_

private

Definition at line 128 of file DCPS_IR_Topic.h.

Referenced by get_topic_qos(), and set_topic_qos().

◆ removed_

bool DCPS_IR_Topic::removed_

private

True means release() is called upon delete_topic, but topic object is not deleted because there are still pub/sub associated.

Definition at line 142 of file DCPS_IR_Topic.h.

Referenced by release().

◆ subscriptionRefs_

DCPS_IR_Subscription_Set DCPS_IR_Topic::subscriptionRefs_

private

Keep track the subscriptions of this topic so the TopicQos change can be published for those subscriptions.

Definition at line 138 of file DCPS_IR_Topic.h.

Referenced by add_subscription_reference(), dump_to_string(), release(), remove_subscription_reference(), and set_topic_qos().

The documentation for this class was generated from the following files:

Private Attributes
OpenDDS::DCPS::GUID_t	id_

DDS::TopicQos	qos_

DCPS_IR_Domain *	domain_

DCPS_IR_Participant *	participant_

DCPS_IR_Topic_Description *	description_

DDS::InstanceHandle_t	handle_

CORBA::Boolean	isBIT_

DCPS_IR_Publication_Set	publicationRefs_

DCPS_IR_Subscription_Set	subscriptionRefs_

bool	removed_

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DCPS_IR_Topic()

◆ ~DCPS_IR_Topic()

Member Function Documentation

◆ add_publication_reference()

◆ add_subscription_reference()

◆ dump_to_string()

◆ get_handle()

◆ get_id()

◆ get_participant_id()

◆ get_topic_description()

◆ get_topic_qos()

◆ is_bit()

◆ reassociate_all_publications()

◆ reevaluate_associations()

◆ release()

◆ remove_publication_reference()

◆ remove_subscription_reference()

◆ set_bit_status()

◆ set_handle()

◆ set_topic_qos()

◆ try_associate()

Member Data Documentation

◆ description_

◆ domain_

◆ handle_

◆ id_

◆ isBIT_

◆ participant_

◆ publicationRefs_

◆ qos_

◆ removed_

◆ subscriptionRefs_