Representative of a Subscription. More...

#include <DCPS_IR_Subscription.h>

Inheritance diagram for DCPS_IR_Subscription:

Collaboration diagram for DCPS_IR_Subscription:

[legend]

Public Member Functions
	DCPS_IR_Subscription (const OpenDDS::DCPS::GUID_t &id, DCPS_IR_Participant participant, DCPS_IR_Topic topic, OpenDDS::DCPS::DataReaderRemote_ptr reader, const DDS::DataReaderQos &qos, const OpenDDS::DCPS::TransportLocatorSeq &info, ACE_CDR::ULong transportContext, const DDS::SubscriberQos &subscriberQos, const char filterClassName, const char filterExpression, const DDS::StringSeq &exprParams, const DDS::OctetSeq &serializedTypeInfo)

	~DCPS_IR_Subscription ()

int	add_associated_publication (DCPS_IR_Publication *pub, bool active)

int	remove_associated_publication (DCPS_IR_Publication *pub, CORBA::Boolean sendNotify, CORBA::Boolean notify_lost, bool notify_both_side=false)

int	remove_associations (CORBA::Boolean notify_lost)

void	disassociate_participant (OpenDDS::DCPS::GUID_t id, bool reassociate=false)
	Remove any publications whose participant has the id. More...

void	disassociate_topic (OpenDDS::DCPS::GUID_t id)
	Remove any publications whose topic has the id. More...

void	disassociate_publication (OpenDDS::DCPS::GUID_t id, bool reassociate=false)
	Remove any publications with id. More...

void	update_incompatible_qos ()

CORBA::Boolean	is_publication_ignored (OpenDDS::DCPS::GUID_t partId, OpenDDS::DCPS::GUID_t topicId, OpenDDS::DCPS::GUID_t pubId)

const DDS::DataReaderQos *	get_datareader_qos ()

const DDS::SubscriberQos *	get_subscriber_qos ()

bool	set_qos (const DDS::DataReaderQos &qos, const DDS::SubscriberQos &subscriberQos, Update::SpecificQos &specificQos)

void	set_qos (const DDS::DataReaderQos &qos)
	Update DataReaderQos only. More...

void	set_qos (const DDS::SubscriberQos &qos)
	Update SubscriberQos only. More...

void	reevaluate_defunct_associations ()

void	reevaluate_existing_associations ()

bool	reevaluate_association (DCPS_IR_Publication *publication)

OpenDDS::DCPS::TransportLocatorSeq	get_transportLocatorSeq () const

ACE_CDR::ULong	get_transportContext () const

OpenDDS::DCPS::IncompatibleQosStatus *	get_incompatibleQosStatus ()

OpenDDS::DCPS::GUID_t	get_id ()

OpenDDS::DCPS::GUID_t	get_topic_id ()

OpenDDS::DCPS::GUID_t	get_participant_id ()

DCPS_IR_Topic_Description *	get_topic_description ()

DCPS_IR_Topic *	get_topic ()

DDS::InstanceHandle_t	get_handle ()

void	set_handle (DDS::InstanceHandle_t handle)

CORBA::Boolean	is_bit ()

void	set_bit_status (CORBA::Boolean isBIT)

OpenDDS::DCPS::DataReaderRemote_ptr	reader ()

std::string	get_filter_class_name () const

std::string	get_filter_expression () const

DDS::StringSeq	get_expr_params () const

void	update_expr_params (const DDS::StringSeq &params)
	Calls associated Publications. More...

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

const DDS::OctetSeq &	get_serialized_type_info () const

Private Attributes
OpenDDS::DCPS::GUID_t	id_

DCPS_IR_Participant *	participant_

DCPS_IR_Topic *	topic_

DDS::InstanceHandle_t	handle_

CORBA::Boolean	isBIT_

OpenDDS::DCPS::DataReaderRemote_var	reader_
	the corresponding DataReaderRemote object More...

DDS::DataReaderQos	qos_

OpenDDS::DCPS::TransportLocatorSeq	info_

ACE_CDR::ULong	transportContext_

DDS::SubscriberQos	subscriberQos_

std::string	filterClassName_

std::string	filterExpression_

DDS::StringSeq	exprParams_

DDS::OctetSeq	serializedTypeInfo_

DCPS_IR_Publication_Set	associations_

DCPS_IR_Publication_Set	defunct_

OpenDDS::DCPS::IncompatibleQosStatus	incompatibleQosStatus_

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

void	_add_ref ()

void	_remove_ref ()

long	ref_count () const

Detailed Description

Representative of a Subscription.

Definition at line 41 of file DCPS_IR_Subscription.h.

Constructor & Destructor Documentation

◆ DCPS_IR_Subscription()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL DCPS_IR_Subscription::DCPS_IR_Subscription	(	const OpenDDS::DCPS::GUID_t &	id,
		DCPS_IR_Participant *	participant,
		DCPS_IR_Topic *	topic,
		OpenDDS::DCPS::DataReaderRemote_ptr	reader,
		const DDS::DataReaderQos &	qos,
		const OpenDDS::DCPS::TransportLocatorSeq &	info,
		ACE_CDR::ULong	transportContext,
		const DDS::SubscriberQos &	subscriberQos,
		const char *	filterClassName,
		const char *	filterExpression,
		const DDS::StringSeq &	exprParams,
		const DDS::OctetSeq &	serializedTypeInfo
	)

Definition at line 25 of file DCPS_IR_Subscription.cpp.

References OpenDDS::DCPS::IncompatibleQosStatus::count_since_last_send, incompatibleQosStatus_, reader_, and OpenDDS::DCPS::IncompatibleQosStatus::total_count.

   : id_(id),
     participant_(participant),
     topic_(topic),
     handle_(0),
     isBIT_(0),
     qos_(qos),
     info_(info),
     transportContext_(transportContext),
     subscriberQos_(subscriberQos),
     filterClassName_(filterClassName),
     filterExpression_(filterExpression),
     exprParams_(exprParams),
     serializedTypeInfo_(serializedTypeInfo)
 {
   reader_ =  OpenDDS::DCPS::DataReaderRemote::_duplicate(reader);
 
   incompatibleQosStatus_.total_count = 0;
   incompatibleQosStatus_.count_since_last_send = 0;
 }

◆ ~DCPS_IR_Subscription()

DCPS_IR_Subscription::~DCPS_IR_Subscription ( )

Definition at line 57 of file DCPS_IR_Subscription.cpp.

58 {

59 }

Member Function Documentation

◆ add_associated_publication()

int DCPS_IR_Subscription::add_associated_publication	(	DCPS_IR_Publication *	pub,
		bool	active
	)

Associate with the publication Adds the publication to the list of associated publications and notifies datareader if successfully added This method can mark the participant dead Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 61 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, ACE_TEXT(), associations_, OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Publication::get_datawriter_qos(), DCPS_IR_Publication::get_id(), DCPS_IR_Publication::get_publisher_qos(), DCPS_IR_Publication::get_serialized_type_info(), DCPS_IR_Publication::get_transportContext(), DCPS_IR_Publication::get_transportLocatorSeq(), id_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, LM_ERROR, DCPS_IR_Participant::mark_dead(), participant_, OpenDDS::DCPS::WriterAssociation::pubQos, reader_, OpenDDS::DCPS::WriterAssociation::serializedTypeInfo, OpenDDS::DCPS::WriterAssociation::transportContext, OpenDDS::DCPS::WriterAssociation::writerId, OpenDDS::DCPS::WriterAssociation::writerQos, and OpenDDS::DCPS::WriterAssociation::writerTransInfo.

Referenced by DCPS_IR_Topic_Description::associate().

 {
   // keep track of the association locally
   int status = associations_.insert(pub);
 
   switch (status) {
   case 0: {
     // inform the datareader about the association
     OpenDDS::DCPS::WriterAssociation association;
     association.writerTransInfo = pub->get_transportLocatorSeq();
     association.transportContext = pub->get_transportContext();
     association.writerId = pub->get_id();
     association.pubQos = *(pub->get_publisher_qos());
     association.writerQos = *(pub->get_datawriter_qos());
     association.serializedTypeInfo = pub->get_serialized_type_info();
     if (participant_->is_alive() && this->participant_->isOwner()) {
       try {
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Subscription::add_associated_publication:")
                      ACE_TEXT(" subscription %C adding publication %C.\n"),
                      std::string(sub_converter).c_str(),
                      std::string(pub_converter).c_str()));
         }
 
         reader_->add_association(id_, association, active);
 
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Subscription::add_associated_publication: ")
                      ACE_TEXT("successfully added publication %x\n"),
                      pub));
         }
       } catch (const CORBA::Exception& ex) {
         ex._tao_print_exception(
           "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::add_associated_publication:");
         participant_->mark_dead();
         status = -1;
       }
     }
 
   }
   break;
 
   case 1: {
     OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::add_associated_publication: ")
                ACE_TEXT("subscription %C attempted to re-add publication %C\n"),
                std::string(sub_converter).c_str(),
                std::string(pub_converter).c_str()));
   }
   break;
 
   case -1: {
     OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::add_associated_publication: ")
                ACE_TEXT("subscription %C failed to add publication %C\n"),
                std::string(sub_converter).c_str(),
                std::string(pub_converter).c_str()));
   }
   }
 
   return status;
 }

◆ disassociate_participant()

void DCPS_IR_Subscription::disassociate_participant	(	OpenDDS::DCPS::GUID_t	id,
		bool	reassociate = `false`
	)

Remove any publications whose participant has the id.

Definition at line 236 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), OpenDDS::DCPS::DCPS_debug_level, defunct_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Publication::get_id(), DCPS_IR_Publication::get_participant_id(), id_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, LM_ERROR, DCPS_IR_Participant::mark_dead(), participant_, reader_, remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), send(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size().

 {
   DCPS_IR_Publication* pub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean dontSend = 0;
   CORBA::Boolean send = 1;
   long count = 0;
 
   if (0 < numAssociations) {
     OpenDDS::DCPS::WriterIdSeq idSeq(static_cast<CORBA::ULong>(numAssociations));
     idSeq.length(static_cast<CORBA::ULong>(numAssociations));
 
     DCPS_IR_Publication_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       pub = *iter;
       ++iter;
 
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
         OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
         OpenDDS::DCPS::RepoIdConverter sub_part_converter(id);
         OpenDDS::DCPS::RepoIdConverter pub_part_converter(pub->get_participant_id());
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) DCPS_IR_Subscription::disassociate_participant: ")
                    ACE_TEXT("subscription %C testing if publication %C particpant %C == %C.\n"),
                    std::string(sub_converter).c_str(),
                    std::string(pub_converter).c_str(),
                    std::string(sub_part_converter).c_str(),
                    std::string(pub_part_converter).c_str()));
       }
 
       if (id == pub->get_participant_id()) {
         CORBA::Boolean dont_notify_lost = 0;
         pub->remove_associated_subscription(this, send, dont_notify_lost);
         remove_associated_publication(pub, dontSend, dont_notify_lost);
 
         idSeq[count] = pub->get_id();
         ++count;
 
         if (reassociate && this->defunct_.insert(pub) != 0) {
           OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::disassociate_participant: ")
                      ACE_TEXT("subscription %C failed to reassociate publication %C at %x.\n"),
                      std::string(sub_converter).c_str(),
                      std::string(pub_converter).c_str(),
                      pub));
         }
       }
     }
 
     if (0 < count) {
       idSeq.length(count);
 
       if (participant_->is_alive() && this->participant_->isOwner()) {
         try {
           CORBA::Boolean dont_notify_lost = 0;
           reader_->remove_associations(idSeq, dont_notify_lost);
 
         } catch (const CORBA::Exception& ex) {
           if (OpenDDS::DCPS::DCPS_debug_level > 0) {
             ex._tao_print_exception(
               "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::disassociate_participant:");
           }
 
           participant_->mark_dead();
         }
       }
     }
   }
 }

◆ disassociate_publication()

void DCPS_IR_Subscription::disassociate_publication	(	OpenDDS::DCPS::GUID_t	id,
		bool	reassociate = `false`
	)

Remove any publications with id.

Definition at line 376 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), OpenDDS::DCPS::DCPS_debug_level, defunct_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Publication::get_id(), id_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, LM_ERROR, DCPS_IR_Participant::mark_dead(), participant_, reader_, remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), send(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size().

Referenced by TAO_DDS_DCPSInfo_i::disassociate_subscription().

 {
   DCPS_IR_Publication* pub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean dontSend = 0;
   CORBA::Boolean send = 1;
   long count = 0;
 
   if (0 < numAssociations) {
     OpenDDS::DCPS::WriterIdSeq idSeq(static_cast<CORBA::ULong>(numAssociations));
     idSeq.length(static_cast<CORBA::ULong>(numAssociations));
 
     DCPS_IR_Publication_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       pub = *iter;
       ++iter;
 
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
         OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
         OpenDDS::DCPS::RepoIdConverter sub_pub_converter(id);
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) DCPS_IR_Subscription::disassociate_publication: ")
                    ACE_TEXT("subscription %C testing if publication %C == %C.\n"),
                    std::string(sub_converter).c_str(),
                    std::string(pub_converter).c_str(),
                    std::string(sub_pub_converter).c_str()));
       }
 
       if (id == pub->get_id()) {
         CORBA::Boolean dont_notify_lost = 0;
         pub->remove_associated_subscription(this, send, dont_notify_lost);
         remove_associated_publication(pub, dontSend, dont_notify_lost);
 
         idSeq[count] = pub->get_id();
         ++count;
 
         if (reassociate && this->defunct_.insert(pub) != 0) {
           OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::disassociate_publication: ")
                      ACE_TEXT("subscription %C failed to reassociate publication %C at %x.\n"),
                      std::string(sub_converter).c_str(),
                      std::string(pub_converter).c_str(),
                      pub));
         }
       }
     }
 
     if (0 < count) {
       idSeq.length(count);
 
       if (participant_->is_alive() && this->participant_->isOwner()) {
         try {
           CORBA::Boolean dont_notify_lost = 0;
           reader_->remove_associations(idSeq, dont_notify_lost);
 
         } catch (const CORBA::Exception& ex) {
           if (OpenDDS::DCPS::DCPS_debug_level > 0) {
             ex._tao_print_exception(
               "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::remove_associations:");
           }
 
           participant_->mark_dead();
         }
       }
     }
   }
 }

◆ disassociate_topic()

void DCPS_IR_Subscription::disassociate_topic ( OpenDDS::DCPS::GUID_t id )

Remove any publications whose topic has the id.

Definition at line 312 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), OpenDDS::DCPS::DCPS_debug_level, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Publication::get_id(), DCPS_IR_Publication::get_topic_id(), id_, DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, DCPS_IR_Participant::mark_dead(), participant_, reader_, remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), send(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size().

 {
   DCPS_IR_Publication* pub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean dontSend = 0;
   CORBA::Boolean send = 1;
   long count = 0;
 
   if (0 < numAssociations) {
     OpenDDS::DCPS::WriterIdSeq idSeq(static_cast<CORBA::ULong>(numAssociations));
     idSeq.length(static_cast<CORBA::ULong>(numAssociations));
 
     DCPS_IR_Publication_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       pub = *iter;
       ++iter;
 
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
         OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
         OpenDDS::DCPS::RepoIdConverter sub_topic_converter(id);
         OpenDDS::DCPS::RepoIdConverter pub_topic_converter(pub->get_topic_id());
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) DCPS_IR_Subscription::disassociate_topic: ")
                    ACE_TEXT("subscription %C testing if publication %C topic %C == %C.\n"),
                    std::string(sub_converter).c_str(),
                    std::string(pub_converter).c_str(),
                    std::string(sub_topic_converter).c_str(),
                    std::string(pub_topic_converter).c_str()));
       }
 
       if (id == pub->get_topic_id()) {
         CORBA::Boolean dont_notify_lost = 0;
         pub->remove_associated_subscription(this, send, dont_notify_lost);
         remove_associated_publication(pub, dontSend, dont_notify_lost);
 
         idSeq[count] = pub->get_id();
         ++count;
       }
     }
 
     if (0 < count) {
       idSeq.length(count);
 
       if (participant_->is_alive() && this->participant_->isOwner()) {
         try {
           CORBA::Boolean dont_notify_lost = false;
           reader_->remove_associations(idSeq, dont_notify_lost);
 
         } catch (const CORBA::Exception& ex) {
           if (OpenDDS::DCPS::DCPS_debug_level > 0) {
             ex._tao_print_exception(
               "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::remove_associations:");
           }
 
           participant_->mark_dead();
         }
       }
     }
   }
 }

◆ dump_to_string()

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

Definition at line 748 of file DCPS_IR_Subscription.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), defunct_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), id_, and isBIT_.

 {
   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_Subscription[";
   str += std::string(local_converter);
   str += "]";
   if (isBIT_)
     str += " (BIT)";
   str += "\n";
 
   str += indent + "Associations [ ";
   for (DCPS_IR_Publication_Set::const_iterator assoc = associations_.begin();
        assoc != associations_.end();
        assoc++)
   {
     OpenDDS::DCPS::RepoIdConverter assoc_converter((*assoc)->get_id());
     str += std::string(assoc_converter);
     str += " ";
   }
   str += "]\n";
 
   str += indent + "Defunct Associations [ ";
   for (DCPS_IR_Publication_Set::const_iterator def = defunct_.begin();
        def != defunct_.end();
        def++)
   {
     OpenDDS::DCPS::RepoIdConverter def_converter((*def)->get_id());
     str += std::string(def_converter);
     str += " ";
   }
   str += "]\n";
 
 #endif // !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
   return str;
 }

◆ get_datareader_qos()

const DDS::DataReaderQos * DCPS_IR_Subscription::get_datareader_qos ( )

Return pointer to the DataReader qos Subscription retains ownership

Definition at line 488 of file DCPS_IR_Subscription.cpp.

References qos_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Domain::publish_subscription_bit(), OpenDDS::Federator::ManagerImpl::pushState(), reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return &qos_;
 }

◆ get_expr_params()

DDS::StringSeq DCPS_IR_Subscription::get_expr_params ( ) const

Definition at line 732 of file DCPS_IR_Subscription.cpp.

References exprParams_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), and OpenDDS::Federator::ManagerImpl::pushState().

 {
   return exprParams_;
 }

◆ get_filter_class_name()

std::string DCPS_IR_Subscription::get_filter_class_name ( ) const

Definition at line 720 of file DCPS_IR_Subscription.cpp.

References filterClassName_.

Referenced by DCPS_IR_Publication::add_associated_subscription().

 {
   return filterClassName_;
 }

◆ get_filter_expression()

std::string DCPS_IR_Subscription::get_filter_expression ( ) const

Definition at line 726 of file DCPS_IR_Subscription.cpp.

References filterExpression_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), and OpenDDS::Federator::ManagerImpl::pushState().

 {
   return filterExpression_;
 }

◆ get_handle()

DDS::InstanceHandle_t DCPS_IR_Subscription::get_handle ( void )

Definition at line 693 of file DCPS_IR_Subscription.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_subscription_bit().

 {
   return handle_;
 }

◆ get_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Subscription::get_id ( void )

Definition at line 668 of file DCPS_IR_Subscription.cpp.

References id_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Participant::add_subscription(), DCPS_IR_Topic_Description::add_subscription_reference(), DCPS_IR_Topic::add_subscription_reference(), DCPS_IR_Topic_Description::associate(), DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Publication::disassociate_topic(), DCPS_IR_Domain::publish_subscription_bit(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Publication::reevaluate_defunct_associations(), DCPS_IR_Publication::remove_associated_subscription(), DCPS_IR_Topic_Description::remove_subscription_reference(), DCPS_IR_Topic::remove_subscription_reference(), DCPS_IR_Topic_Description::try_associate(), DCPS_IR_Topic::try_associate(), and DCPS_IR_Topic_Description::try_associate_subscription().

 {
   return id_;
 }

◆ get_incompatibleQosStatus()

OpenDDS::DCPS::IncompatibleQosStatus * DCPS_IR_Subscription::get_incompatibleQosStatus ( )

Return pointer to the incompatible qos status Subscription retains ownership

Definition at line 483 of file DCPS_IR_Subscription.cpp.

References incompatibleQosStatus_.

Referenced by reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), DCPS_IR_Topic_Description::try_associate(), DCPS_IR_Topic_Description::try_associate_publication(), and DCPS_IR_Topic_Description::try_associate_subscription().

 {
   return &incompatibleQosStatus_;
 }

◆ get_participant_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Subscription::get_participant_id ( )

Definition at line 678 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Participant::get_id(), and participant_.

Referenced by DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Domain::publish_subscription_bit(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Topic_Description::try_associate(), and DCPS_IR_Topic::try_associate().

 {
   return participant_->get_id();
 }

◆ get_serialized_type_info()

const DDS::OctetSeq & DCPS_IR_Subscription::get_serialized_type_info ( ) const

Definition at line 791 of file DCPS_IR_Subscription.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and serializedTypeInfo_.

Referenced by DCPS_IR_Publication::add_associated_subscription().

 {
   return serializedTypeInfo_;
 }

◆ get_subscriber_qos()

const DDS::SubscriberQos * DCPS_IR_Subscription::get_subscriber_qos ( )

Return pointer to the Subscriber qos Subscription retains ownership

Definition at line 493 of file DCPS_IR_Subscription.cpp.

References subscriberQos_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Domain::publish_subscription_bit(), OpenDDS::Federator::ManagerImpl::pushState(), reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return &subscriberQos_;
 }

◆ get_topic()

DCPS_IR_Topic * DCPS_IR_Subscription::get_topic ( )

Definition at line 688 of file DCPS_IR_Subscription.cpp.

References topic_.

Referenced by DCPS_IR_Domain::publish_subscription_bit().

 {
   return topic_;
 }

◆ get_topic_description()

DCPS_IR_Topic_Description * DCPS_IR_Subscription::get_topic_description ( )

Definition at line 683 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Topic::get_topic_description(), and topic_.

Referenced by DCPS_IR_Domain::publish_subscription_bit().

 {
   return topic_->get_topic_description();
 }

◆ get_topic_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Subscription::get_topic_id ( )

Definition at line 673 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Topic::get_id(), and topic_.

Referenced by DCPS_IR_Publication::disassociate_topic(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Topic_Description::try_associate(), and DCPS_IR_Topic::try_associate().

 {
   return topic_->get_id();
 }

◆ get_transportContext()

ACE_CDR::ULong DCPS_IR_Subscription::get_transportContext ( ) const

inline

Definition at line 150 of file DCPS_IR_Subscription.h.

References get_handle().

Referenced by DCPS_IR_Publication::add_associated_subscription().

150 { return transportContext_; }

DCPS_IR_Subscription::transportContext_

ACE_CDR::ULong transportContext_

Definition: DCPS_IR_Subscription.h:196

◆ get_transportLocatorSeq()

OpenDDS::DCPS::TransportLocatorSeq DCPS_IR_Subscription::get_transportLocatorSeq ( ) const

Definition at line 478 of file DCPS_IR_Subscription.cpp.

References info_.

Referenced by DCPS_IR_Publication::add_associated_subscription(), OpenDDS::Federator::ManagerImpl::pushState(), reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return info_;
 }

◆ is_bit()

CORBA::Boolean DCPS_IR_Subscription::is_bit ( )

Definition at line 703 of file DCPS_IR_Subscription.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::dispose_subscription_bit().

 {
   return isBIT_;
 }

◆ is_publication_ignored()

CORBA::Boolean DCPS_IR_Subscription::is_publication_ignored	(	OpenDDS::DCPS::GUID_t	partId,
		OpenDDS::DCPS::GUID_t	topicId,
		OpenDDS::DCPS::GUID_t	pubId
	)

Check that none of the ids given are ones that this subscription should ignore. returns 1 if one of these ids is an ignored id

Definition at line 467 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Participant::is_participant_ignored(), DCPS_IR_Participant::is_publication_ignored(), DCPS_IR_Participant::is_topic_ignored(), and participant_.

Referenced by DCPS_IR_Topic_Description::try_associate().

 {
   CORBA::Boolean ignored = (participant_->is_participant_ignored(partId) ||
                             participant_->is_topic_ignored(topicId) ||
                             participant_->is_publication_ignored(pubId));
 
   return ignored;
 }

◆ reader()

OpenDDS::DCPS::DataReaderRemote_ptr DCPS_IR_Subscription::reader ( void )

Definition at line 714 of file DCPS_IR_Subscription.cpp.

References reader_.

Referenced by OpenDDS::Federator::ManagerImpl::pushState().

 {
   return OpenDDS::DCPS::DataReaderRemote::_duplicate(this->reader_.in());
 }

◆ reevaluate_association()

bool DCPS_IR_Subscription::reevaluate_association ( DCPS_IR_Publication * publication )

Definition at line 639 of file DCPS_IR_Subscription.cpp.

References associations_, OpenDDS::DCPS::compatibleQOS(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::find(), get_datareader_qos(), DCPS_IR_Publication::get_datawriter_qos(), DCPS_IR_Publication::get_incompatibleQosStatus(), get_incompatibleQosStatus(), DCPS_IR_Publication::get_publisher_qos(), get_subscriber_qos(), DCPS_IR_Topic::get_topic_description(), DCPS_IR_Publication::get_transportLocatorSeq(), get_transportLocatorSeq(), remove_associated_publication(), topic_, and DCPS_IR_Topic_Description::try_associate().

Referenced by DCPS_IR_Topic::reevaluate_associations(), DCPS_IR_Topic_Description::reevaluate_associations(), reevaluate_defunct_associations(), and reevaluate_existing_associations().

 {
   int status = this->associations_.find(publication);
 
   if (status == 0) {
     // verify if they are still compatible after change
 
     if (!OpenDDS::DCPS::compatibleQOS(publication->get_incompatibleQosStatus(),
                                       this->get_incompatibleQosStatus(),
                                       publication->get_transportLocatorSeq(),
                                       this->get_transportLocatorSeq(),
                                       publication->get_datawriter_qos(),
                                       this->get_datareader_qos(),
                                       publication->get_publisher_qos(),
                                       this->get_subscriber_qos())) {
       bool sendNotify = true; // inform datareader
       bool notify_lost = true; // invoke listerner callback
 
       this->remove_associated_publication(publication, sendNotify, notify_lost, true);
     }
 
   } else {
     DCPS_IR_Topic_Description* description = this->topic_->get_topic_description();
     return description->try_associate(publication, this);
   }
 
   return false;
 }

◆ reevaluate_defunct_associations()

void DCPS_IR_Subscription::reevaluate_defunct_associations ( )

Definition at line 601 of file DCPS_IR_Subscription.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), defunct_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Publication::get_id(), id_, LM_ERROR, reevaluate_association(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove().

 {
   DCPS_IR_Publication_Set::iterator it(this->defunct_.begin());
   while (it != this->defunct_.end()) {
     DCPS_IR_Publication* publication = *it;
     ++it;
 
     if (reevaluate_association(publication)) {
       this->defunct_.remove(publication); // no longer defunct
 
     } else {
       OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
       OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
       ACE_ERROR((LM_ERROR,
                  ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::reevaluate_defunct_associations: ")
                  ACE_TEXT("subscription %C failed to reassociate publication %C at %x.\n"),
                  std::string(sub_converter).c_str(),
                  std::string(pub_converter).c_str(),
                  publication));
     }
   }
 }

◆ reevaluate_existing_associations()

void DCPS_IR_Subscription::reevaluate_existing_associations ( )

Definition at line 624 of file DCPS_IR_Subscription.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), and reevaluate_association().

Referenced by set_qos().

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

◆ remove_associated_publication()

int DCPS_IR_Subscription::remove_associated_publication	(	DCPS_IR_Publication *	pub,
		CORBA::Boolean	sendNotify,
		CORBA::Boolean	notify_lost,
		bool	notify_both_side = `false`
	)

Remove the associated publication Removes the publication from the list of associated publications if return successful sendNotify indicates whether to tell the datareader about removing the publication The notify_lost flag true indicates this remove_associations is called when the InfoRepo detects this subscription is lost because of the failure of invocation on this subscription. The notify_both_side parameter indicates if it needs call pub to remove association as well. This method can mark the participant dead Returns 0 if successful

Definition at line 133 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, ACE_TEXT(), associations_, OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Publication::get_id(), id_, DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, LM_ERROR, DCPS_IR_Participant::mark_dead(), participant_, reader_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove(), and DCPS_IR_Publication::remove_associated_subscription().

Referenced by DCPS_IR_Publication::disassociate_participant(), disassociate_participant(), disassociate_publication(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Publication::disassociate_topic(), disassociate_topic(), reevaluate_association(), DCPS_IR_Publication::remove_associated_subscription(), DCPS_IR_Publication::remove_associations(), and remove_associations().

 {
   bool marked_dead = false;
 
   if (sendNotify) {
 
     if (participant_->is_alive() && this->participant_->isOwner()) {
       try {
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Subscription::remove_associated_publication:")
                      ACE_TEXT(" calling sub %C with pub %C\n"),
                      std::string(sub_converter).c_str(),
                      std::string(pub_converter).c_str()
                      ));
         }
 
         OpenDDS::DCPS::WriterIdSeq idSeq(5);
         idSeq.length(1);
         idSeq[0] = pub->get_id();
 
         reader_->remove_associations(idSeq, notify_lost);
 
         if (notify_both_side) {
           pub->remove_associated_subscription(this, sendNotify, notify_lost);
         }
 
       } catch (const CORBA::Exception& ex) {
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           ex._tao_print_exception(
             "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::remove_associated_publication:");
         }
 
         participant_->mark_dead();
         marked_dead = true;
       }
     }
   }
 
   int status = associations_.remove(pub);
 
   if (0 == status) {
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
       OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Subscription::remove_associated_publication: ")
                  ACE_TEXT("subscription %C removed publication %C at %x.\n"),
                  std::string(sub_converter).c_str(),
                  std::string(pub_converter).c_str(),
                  pub));
     }
 
   } else {
     OpenDDS::DCPS::RepoIdConverter sub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter pub_converter(pub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Subscription::remove_associated_publication: ")
                ACE_TEXT("subscription %C failed to remove publication %C at %x.\n"),
                std::string(sub_converter).c_str(),
                std::string(pub_converter).c_str(),
                pub));
   } // if (0 == status)
 
   if (marked_dead) {
     return -1;
 
   } else {
     return status;
   }
 }

◆ remove_associations()

int DCPS_IR_Subscription::remove_associations ( CORBA::Boolean notify_lost )

Removes all the associated publications This method can mark the participant dead The notify_lost flag true indicates this remove_associations is called when the InfoRepo detects this subscription is lost because of the failure of invocation on this subscription. Returns 0 if successful

Definition at line 210 of file DCPS_IR_Subscription.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), defunct_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::reset(), send(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size().

 {
   int status = 0;
   DCPS_IR_Publication* pub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean dontSend = 0;
   CORBA::Boolean send = 1;
 
   if (0 < numAssociations) {
     DCPS_IR_Publication_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Publication_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       pub = *iter;
       ++iter;
 
       pub->remove_associated_subscription(this, send, notify_lost);
       CORBA::Boolean dont_notify_lost = 0;
       remove_associated_publication(pub, dontSend, dont_notify_lost);
     }
   }
   this->defunct_.reset();
 
   return status;
 }

◆ set_bit_status()

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

Definition at line 708 of file DCPS_IR_Subscription.cpp.

References isBIT_.

Referenced by DCPS_IR_Participant::add_subscription(), and DCPS_IR_Domain::publish_subscription_bit().

 {
   isBIT_ = isBIT;
 }

◆ set_handle()

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

Definition at line 698 of file DCPS_IR_Subscription.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_subscription_bit().

 {
   handle_ = handle;
 }

◆ set_qos() [1/3]

bool DCPS_IR_Subscription::set_qos	(	const DDS::DataReaderQos &	qos,
		const DDS::SubscriberQos &	subscriberQos,
		Update::SpecificQos &	specificQos
	)

Update the DataReader or Subscriber qos and also publish the qos changes to datereader BIT.

Definition at line 559 of file DCPS_IR_Subscription.cpp.

References Update::DataReaderQos, DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), Update::NoQos, participant_, DCPS_IR_Domain::publish_subscription_bit(), qos_, DCPS_IR_Topic_Description::reevaluate_associations(), reevaluate_existing_associations(), OpenDDS::DCPS::should_check_association_upon_change(), Update::SubscriberQos, subscriberQos_, and topic_.

Referenced by TAO_DDS_DCPSInfo_i::update_subscription_qos().

 {
   bool need_evaluate = false;
   bool u_dr_qos = !(qos_ == qos);
 
   if (u_dr_qos) {
     if (OpenDDS::DCPS::should_check_association_upon_change(qos_, qos)) {
       need_evaluate = true;
     }
 
     qos_ = qos;
   }
 
   bool u_sub_qos = !(subscriberQos_ == subscriberQos);
 
   if (u_sub_qos) {
     if (OpenDDS::DCPS::should_check_association_upon_change(subscriberQos_, subscriberQos)) {
       need_evaluate = true;
     }
 
     subscriberQos_ = subscriberQos;
   }
 
   if (need_evaluate) {
     // Check if any existing association need be removed first.
     this->reevaluate_existing_associations();
 
     DCPS_IR_Topic_Description* description = this->topic_->get_topic_description();
     description->reevaluate_associations(this);
   }
 
   participant_->get_domain_reference()->publish_subscription_bit(this);
   specificQos = u_dr_qos?  Update::DataReaderQos:
                 u_sub_qos? Update::SubscriberQos:
                 Update::NoQos;
 
   return true;
 }

◆ set_qos() [2/3]

void DCPS_IR_Subscription::set_qos ( const DDS::DataReaderQos & qos )

Update DataReaderQos only.

Definition at line 501 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), participant_, DCPS_IR_Domain::publish_subscription_bit(), qos_, DCPS_IR_Topic_Description::reevaluate_associations(), reevaluate_existing_associations(), OpenDDS::DCPS::should_check_association_upon_change(), ACE_OS::sleep(), and topic_.

 {
   if (false == (qos == this->qos_)) {
     // Check if we should check while we have both values.
     bool check =
       OpenDDS::DCPS::should_check_association_upon_change(qos, this->qos_);
 
     // Store the new, compatible, value.
     this->qos_ = qos;
 
     if (check) {
       // This will remove any newly stale associations.
       this->reevaluate_existing_associations();
 
       // Sleep a while to let remove_association handled by DataWriter
       // before add_association. Otherwise, new association will have
       // trouble to connect each other.
       ACE_OS::sleep(ACE_Time_Value(0, 250000));
 
       // This will establish any newly made associations.
       DCPS_IR_Topic_Description* description
       = this->topic_->get_topic_description();
       description->reevaluate_associations(this);
     }
 
     this->participant_->get_domain_reference()->publish_subscription_bit(this);
   }
 }

◆ set_qos() [3/3]

void DCPS_IR_Subscription::set_qos ( const DDS::SubscriberQos & qos )

Update SubscriberQos only.

Definition at line 531 of file DCPS_IR_Subscription.cpp.

References DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), participant_, DCPS_IR_Domain::publish_subscription_bit(), DCPS_IR_Topic_Description::reevaluate_associations(), reevaluate_existing_associations(), OpenDDS::DCPS::should_check_association_upon_change(), ACE_OS::sleep(), subscriberQos_, and topic_.

 {
   if (false == (qos == this->subscriberQos_)) {
     // Check if we should check while we have both values.
     bool check = OpenDDS::DCPS::should_check_association_upon_change(qos, this->subscriberQos_);
 
     // Store the new, compatible, value.
     this->subscriberQos_ = qos;
 
     if (check) {
       // This will remove any newly stale associations.
       this->reevaluate_existing_associations();
 
       // Sleep a while to let remove_association handled by DataWriter
       // before add_association. Otherwise, new association will have
       // trouble to connect each other.
       ACE_OS::sleep(ACE_Time_Value(0, 250000));
 
       // This will establish any newly made associations.
       DCPS_IR_Topic_Description* description
       = this->topic_->get_topic_description();
       description->reevaluate_associations(this);
     }
 
     this->participant_->get_domain_reference()->publish_subscription_bit(this);
   }
 }

◆ update_expr_params()

void DCPS_IR_Subscription::update_expr_params ( const DDS::StringSeq & params )

Calls associated Publications.

Definition at line 738 of file DCPS_IR_Subscription.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), exprParams_, and id_.

Referenced by TAO_DDS_DCPSInfo_i::update_subscription_params().

 {
   exprParams_ = params;
   typedef DCPS_IR_Publication_Set::ITERATOR iter_t;
   for (iter_t i(associations_.begin()), e(associations_.end()); i != e; ++i) {
     (*i)->update_expr_params(id_, params);
   }
 }

◆ update_incompatible_qos()

void DCPS_IR_Subscription::update_incompatible_qos ( )

Notify the reader of incompatible qos status and reset the status' count_since_last_send to 0

Definition at line 450 of file DCPS_IR_Subscription.cpp.

References CORBA::Exception::_tao_print_exception(), OpenDDS::DCPS::IncompatibleQosStatus::count_since_last_send, OpenDDS::DCPS::DCPS_debug_level, incompatibleQosStatus_, DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), DCPS_IR_Participant::mark_dead(), participant_, and reader_.

Referenced by DCPS_IR_Topic_Description::try_associate_publication(), and DCPS_IR_Topic_Description::try_associate_subscription().

 {
   if (participant_->is_alive() && this->participant_->isOwner()) {
     try {
       reader_->update_incompatible_qos(incompatibleQosStatus_);
       incompatibleQosStatus_.count_since_last_send = 0;
     } catch (const CORBA::Exception& ex) {
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         ex._tao_print_exception(
           "(%P|%t) ERROR: Exception caught in DCPS_IR_Subscription::update_incompatible_qos:");
       }
 
       participant_->mark_dead();
     }
   }
 }

Member Data Documentation

◆ associations_

DCPS_IR_Publication_Set DCPS_IR_Subscription::associations_

private

Definition at line 202 of file DCPS_IR_Subscription.h.

Referenced by add_associated_publication(), disassociate_participant(), disassociate_publication(), disassociate_topic(), dump_to_string(), reevaluate_association(), reevaluate_existing_associations(), remove_associated_publication(), remove_associations(), and update_expr_params().

◆ defunct_

DCPS_IR_Publication_Set DCPS_IR_Subscription::defunct_

private

Definition at line 203 of file DCPS_IR_Subscription.h.

Referenced by disassociate_participant(), disassociate_publication(), dump_to_string(), reevaluate_defunct_associations(), and remove_associations().

◆ exprParams_

DDS::StringSeq DCPS_IR_Subscription::exprParams_

private

Definition at line 200 of file DCPS_IR_Subscription.h.

Referenced by get_expr_params(), and update_expr_params().

◆ filterClassName_

std::string DCPS_IR_Subscription::filterClassName_

private

Definition at line 198 of file DCPS_IR_Subscription.h.

Referenced by get_filter_class_name().

◆ filterExpression_

std::string DCPS_IR_Subscription::filterExpression_

private

Definition at line 199 of file DCPS_IR_Subscription.h.

Referenced by get_filter_expression().

◆ handle_

DDS::InstanceHandle_t DCPS_IR_Subscription::handle_

private

Definition at line 189 of file DCPS_IR_Subscription.h.

Referenced by get_handle(), and set_handle().

◆ id_

OpenDDS::DCPS::GUID_t DCPS_IR_Subscription::id_

private

Definition at line 186 of file DCPS_IR_Subscription.h.

Referenced by add_associated_publication(), disassociate_participant(), disassociate_publication(), disassociate_topic(), dump_to_string(), get_id(), reevaluate_defunct_associations(), remove_associated_publication(), and update_expr_params().

◆ incompatibleQosStatus_

OpenDDS::DCPS::IncompatibleQosStatus DCPS_IR_Subscription::incompatibleQosStatus_

private

Definition at line 205 of file DCPS_IR_Subscription.h.

Referenced by DCPS_IR_Subscription(), get_incompatibleQosStatus(), and update_incompatible_qos().

◆ info_

OpenDDS::DCPS::TransportLocatorSeq DCPS_IR_Subscription::info_

private

Definition at line 195 of file DCPS_IR_Subscription.h.

Referenced by get_transportLocatorSeq().

◆ isBIT_

CORBA::Boolean DCPS_IR_Subscription::isBIT_

private

Definition at line 190 of file DCPS_IR_Subscription.h.

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

◆ participant_

DCPS_IR_Participant* DCPS_IR_Subscription::participant_

private

Definition at line 187 of file DCPS_IR_Subscription.h.

Referenced by add_associated_publication(), disassociate_participant(), disassociate_publication(), disassociate_topic(), get_participant_id(), is_publication_ignored(), remove_associated_publication(), set_qos(), and update_incompatible_qos().

◆ qos_

DDS::DataReaderQos DCPS_IR_Subscription::qos_

private

Definition at line 194 of file DCPS_IR_Subscription.h.

Referenced by get_datareader_qos(), and set_qos().

◆ reader_

OpenDDS::DCPS::DataReaderRemote_var DCPS_IR_Subscription::reader_

private

the corresponding DataReaderRemote object

Definition at line 193 of file DCPS_IR_Subscription.h.

Referenced by add_associated_publication(), DCPS_IR_Subscription(), disassociate_participant(), disassociate_publication(), disassociate_topic(), reader(), remove_associated_publication(), and update_incompatible_qos().

◆ serializedTypeInfo_

DDS::OctetSeq DCPS_IR_Subscription::serializedTypeInfo_

private

Definition at line 201 of file DCPS_IR_Subscription.h.

Referenced by get_serialized_type_info().

◆ subscriberQos_

DDS::SubscriberQos DCPS_IR_Subscription::subscriberQos_

private

Definition at line 197 of file DCPS_IR_Subscription.h.

Referenced by get_subscriber_qos(), and set_qos().

◆ topic_

DCPS_IR_Topic* DCPS_IR_Subscription::topic_

private

Definition at line 188 of file DCPS_IR_Subscription.h.

Referenced by get_topic(), get_topic_description(), get_topic_id(), reevaluate_association(), and set_qos().

◆ transportContext_

ACE_CDR::ULong DCPS_IR_Subscription::transportContext_

private

Definition at line 196 of file DCPS_IR_Subscription.h.

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

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DCPS_IR_Subscription()

◆ ~DCPS_IR_Subscription()

Member Function Documentation

◆ add_associated_publication()

◆ disassociate_participant()

◆ disassociate_publication()

◆ disassociate_topic()

◆ dump_to_string()

◆ get_datareader_qos()

◆ get_expr_params()

◆ get_filter_class_name()

◆ get_filter_expression()

◆ get_handle()

◆ get_id()

◆ get_incompatibleQosStatus()

◆ get_participant_id()

◆ get_serialized_type_info()

◆ get_subscriber_qos()

◆ get_topic()

◆ get_topic_description()

◆ get_topic_id()

◆ get_transportContext()

◆ get_transportLocatorSeq()

◆ is_bit()

◆ is_publication_ignored()

◆ reader()

◆ reevaluate_association()

◆ reevaluate_defunct_associations()

◆ reevaluate_existing_associations()

◆ remove_associated_publication()

◆ remove_associations()

◆ set_bit_status()

◆ set_handle()

◆ set_qos() [1/3]

◆ set_qos() [2/3]

◆ set_qos() [3/3]

◆ update_expr_params()

◆ update_incompatible_qos()

Member Data Documentation

◆ associations_

◆ defunct_

◆ exprParams_

◆ filterClassName_

◆ filterExpression_

◆ handle_

◆ id_

◆ incompatibleQosStatus_

◆ info_

◆ isBIT_

◆ participant_

◆ qos_

◆ reader_

◆ serializedTypeInfo_

◆ subscriberQos_

◆ topic_

◆ transportContext_