Representative of a Publication. More...

#include <DCPS_IR_Publication.h>

Inheritance diagram for DCPS_IR_Publication:

Collaboration diagram for DCPS_IR_Publication:

[legend]

Public Member Functions
	DCPS_IR_Publication (const OpenDDS::DCPS::GUID_t &id, DCPS_IR_Participant participant, DCPS_IR_Topic topic, OpenDDS::DCPS::DataWriterRemote_ptr writer, const DDS::DataWriterQos &qos, const OpenDDS::DCPS::TransportLocatorSeq &info, ACE_CDR::ULong transportContext, const DDS::PublisherQos &publisherQos, const DDS::OctetSeq &serializedTypeInfo)

	~DCPS_IR_Publication ()

int	add_associated_subscription (DCPS_IR_Subscription *sub, bool active)

int	remove_associated_subscription (DCPS_IR_Subscription *sub, 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 subscriptions whose participant has the id. More...

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

void	disassociate_subscription (OpenDDS::DCPS::GUID_t id, bool reassociate=false)
	Remove any subscriptions with the id. More...

void	update_incompatible_qos ()

CORBA::Boolean	is_subscription_ignored (OpenDDS::DCPS::GUID_t partId, OpenDDS::DCPS::GUID_t topicId, OpenDDS::DCPS::GUID_t subId)

DDS::DataWriterQos *	get_datawriter_qos ()

DDS::PublisherQos *	get_publisher_qos ()

bool	set_qos (const DDS::DataWriterQos &qos, const DDS::PublisherQos &publisherQos, Update::SpecificQos &specificQos)

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

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

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 *	get_topic ()

DCPS_IR_Topic_Description *	get_topic_description ()

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::DataWriterRemote_ptr	writer ()

void	reevaluate_defunct_associations ()

void	reevaluate_existing_associations ()

bool	reevaluate_association (DCPS_IR_Subscription *subscription)

void	update_expr_params (OpenDDS::DCPS::GUID_t readerId, const DDS::StringSeq &params)

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::DataWriterRemote_var	writer_
	the corresponding DataWriterRemote object More...

DDS::DataWriterQos	qos_

OpenDDS::DCPS::TransportLocatorSeq	info_

ACE_CDR::ULong	transportContext_

DDS::PublisherQos	publisherQos_

DDS::OctetSeq	serializedTypeInfo_

DCPS_IR_Subscription_Set	associations_

DCPS_IR_Subscription_Set	defunct_

OpenDDS::DCPS::IncompatibleQosStatus	incompatibleQosStatus_

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

void	_add_ref ()

void	_remove_ref ()

long	ref_count () const

Detailed Description

Representative of a Publication.

Definition at line 41 of file DCPS_IR_Publication.h.

Constructor & Destructor Documentation

◆ DCPS_IR_Publication()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL DCPS_IR_Publication::DCPS_IR_Publication	(	const OpenDDS::DCPS::GUID_t &	id,
		DCPS_IR_Participant *	participant,
		DCPS_IR_Topic *	topic,
		OpenDDS::DCPS::DataWriterRemote_ptr	writer,
		const DDS::DataWriterQos &	qos,
		const OpenDDS::DCPS::TransportLocatorSeq &	info,
		ACE_CDR::ULong	transportContext,
		const DDS::PublisherQos &	publisherQos,
		const DDS::OctetSeq &	serializedTypeInfo
	)

Definition at line 26 of file DCPS_IR_Publication.cpp.

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

   : id_(id),
     participant_(participant),
     topic_(topic),
     handle_(0),
     isBIT_(0),
     qos_(qos),
     info_(info),
     transportContext_(transportContext),
     publisherQos_(publisherQos),
     serializedTypeInfo_(serializedTypeInfo)
 {
   writer_ =  OpenDDS::DCPS::DataWriterRemote::_duplicate(writer);
 
   incompatibleQosStatus_.total_count = 0;
   incompatibleQosStatus_.count_since_last_send = 0;
 }

◆ ~DCPS_IR_Publication()

DCPS_IR_Publication::~DCPS_IR_Publication ( )

Definition at line 52 of file DCPS_IR_Publication.cpp.

53 {

54 }

Member Function Documentation

◆ add_associated_subscription()

int DCPS_IR_Publication::add_associated_subscription	(	DCPS_IR_Subscription *	sub,
		bool	active
	)

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

Definition at line 56 of file DCPS_IR_Publication.cpp.

Referenced by DCPS_IR_Topic_Description::associate().

 {
   // keep track of the association locally
   int status = associations_.insert(sub);
 
   switch (status) {
   case 0: {
     // inform the datawriter about the association
     OpenDDS::DCPS::ReaderAssociation association;
     association.readerTransInfo = sub->get_transportLocatorSeq();
     association.transportContext = sub->get_transportContext();
     association.readerId = sub->get_id();
     association.subQos = *(sub->get_subscriber_qos());
     association.readerQos = *(sub->get_datareader_qos());
     association.filterClassName = sub->get_filter_class_name().c_str();
     association.filterExpression = sub->get_filter_expression().c_str();
     association.exprParams = sub->get_expr_params();
     association.serializedTypeInfo = sub->get_serialized_type_info();
 
     if (participant_->is_alive() && this->participant_->isOwner()) {
       try {
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Publication::add_associated_subscription:")
                      ACE_TEXT(" publication %C adding subscription %C.\n"),
                      std::string(pub_converter).c_str(),
                      std::string(sub_converter).c_str()));
         }
 
         writer_->add_association(id_, association, active);
 
         if (OpenDDS::DCPS::DCPS_debug_level > 0) {
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Publication::add_associated_subscription: ")
                      ACE_TEXT("successfully added subscription %x.\n"),
                      sub));
         }
       } catch (const CORBA::Exception& ex) {
         ex._tao_print_exception(
           "(%P|%t) ERROR: Exception caught in DCPS_IR_Publication::add_associated_subscription:");
         participant_->mark_dead();
         status = -1;
       }
     }
   }
   break;
 
   case 1: {
     OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Publication::add_associated_subscription: ")
                ACE_TEXT("publication %C attempted to re-add subscription %C.\n"),
                std::string(pub_converter).c_str(),
                std::string(sub_converter).c_str()));
   }
   break;
 
   case -1: {
     OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Publication::add_associated_subscription: ")
                ACE_TEXT("publication %C failed to add subscription %C.\n"),
                std::string(pub_converter).c_str(),
                std::string(sub_converter).c_str()));
   }
   }
 
   return status;
 }

◆ disassociate_participant()

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

Remove any subscriptions whose participant has the id.

Definition at line 230 of file DCPS_IR_Publication.cpp.

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

◆ disassociate_subscription()

void DCPS_IR_Publication::disassociate_subscription	(	OpenDDS::DCPS::GUID_t	id,
		bool	reassociate = `false`
	)

Remove any subscriptions with the id.

Definition at line 370 of file DCPS_IR_Publication.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_Subscription::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_, DCPS_IR_Subscription::remove_associated_publication(), remove_associated_subscription(), send(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size(), and writer_.

Referenced by TAO_DDS_DCPSInfo_i::disassociate_publication().

 {
   DCPS_IR_Subscription* sub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean send = 1;
   CORBA::Boolean dontSend = 0;
   long count = 0;
 
   if (0 < numAssociations) {
     OpenDDS::DCPS::ReaderIdSeq idSeq(static_cast<CORBA::ULong>(numAssociations));
     idSeq.length(static_cast<CORBA::ULong>(numAssociations));
 
     DCPS_IR_Subscription_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Subscription_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       sub = *iter;
       ++iter;
 
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
         OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
         OpenDDS::DCPS::RepoIdConverter pub_sub_converter(id);
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) DCPS_IR_Publication::disassociate_subscription: ")
                    ACE_TEXT("publication %C testing if subscription %C == %C.\n"),
                    std::string(pub_converter).c_str(),
                    std::string(sub_converter).c_str(),
                    std::string(pub_sub_converter).c_str()));
       }
 
       if (id == sub->get_id()) {
         CORBA::Boolean dont_notify_lost = 0;
         sub->remove_associated_publication(this, send, dont_notify_lost);
         remove_associated_subscription(sub, dontSend, dont_notify_lost);
 
         idSeq[count] = sub->get_id();
         ++count;
 
         if (reassociate && this->defunct_.insert(sub) != 0) {
           OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Publication::disassociate_subscription: ")
                      ACE_TEXT("publication %C failed to reassociate subscription %C at %x.\n"),
                      std::string(pub_converter).c_str(),
                      std::string(sub_converter).c_str(),
                      sub));
         }
       }
     }
 
     if (0 < count) {
       idSeq.length(count);
 
       if (participant_->is_alive() && this->participant_->isOwner()) {
         try {
           CORBA::Boolean dont_notify_lost = 0;
           writer_->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_Publication::remove_associations:");
           }
 
           participant_->mark_dead();
         }
       }
     }
   }
 }

◆ disassociate_topic()

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

Remove any subscriptions whose topic has the id.

Definition at line 306 of file DCPS_IR_Publication.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_Subscription::get_id(), DCPS_IR_Subscription::get_topic_id(), id_, DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, DCPS_IR_Participant::mark_dead(), participant_, DCPS_IR_Subscription::remove_associated_publication(), remove_associated_subscription(), send(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size(), and writer_.

 {
   DCPS_IR_Subscription* sub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean send = 1;
   CORBA::Boolean dontSend = 0;
   long count = 0;
 
   if (0 < numAssociations) {
     OpenDDS::DCPS::ReaderIdSeq idSeq(static_cast<CORBA::ULong>(numAssociations));
     idSeq.length(static_cast<CORBA::ULong>(numAssociations));
 
     DCPS_IR_Subscription_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Subscription_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       sub = *iter;
       ++iter;
 
       if (OpenDDS::DCPS::DCPS_debug_level > 0) {
         OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
         OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
         OpenDDS::DCPS::RepoIdConverter pub_topic_converter(id);
         OpenDDS::DCPS::RepoIdConverter sub_topic_converter(sub->get_topic_id());
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) DCPS_IR_Publication::disassociate_topic: ")
                    ACE_TEXT("publication %C testing if subscription %C topic %C == %C.\n"),
                    std::string(pub_converter).c_str(),
                    std::string(sub_converter).c_str(),
                    std::string(sub_topic_converter).c_str(),
                    std::string(pub_topic_converter).c_str()));
       }
 
       if (id == sub->get_topic_id()) {
         CORBA::Boolean dont_notify_lost = 0;
         sub->remove_associated_publication(this, send, dont_notify_lost);
         remove_associated_subscription(sub, dontSend, dont_notify_lost);
 
         idSeq[count] = sub->get_id();
         ++count;
       }
     }
 
     if (0 < count) {
       idSeq.length(count);
 
       if (participant_->is_alive() && this->participant_->isOwner()) {
         try {
           CORBA::Boolean dont_notify_lost = 0;
           writer_->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_Publication::remove_associations:");
           }
 
           participant_->mark_dead();
         }
       }
     }
   }
 }

◆ dump_to_string()

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

Definition at line 730 of file DCPS_IR_Publication.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_Publication[";
   str += std::string(local_converter);
   str += "]";
   if (isBIT_)
     str += " (BIT)";
   str += "\n";
 
   str += indent + "Associations [ ";
   for (DCPS_IR_Subscription_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_Subscription_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_datawriter_qos()

DDS::DataWriterQos * DCPS_IR_Publication::get_datawriter_qos ( )

Return pointer to the DataWriter qos Publication retains ownership

Definition at line 473 of file DCPS_IR_Publication.cpp.

References qos_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Domain::publish_publication_bit(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Subscription::reevaluate_association(), reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return &qos_;
 }

◆ get_handle()

DDS::InstanceHandle_t DCPS_IR_Publication::get_handle ( void )

Definition at line 619 of file DCPS_IR_Publication.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_publication_bit().

 {
   return handle_;
 }

◆ get_id()

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

◆ get_incompatibleQosStatus()

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

Return pointer to the incompatible qos status Publication retains ownership

Definition at line 589 of file DCPS_IR_Publication.cpp.

References incompatibleQosStatus_.

Referenced by DCPS_IR_Subscription::reevaluate_association(), reevaluate_association(), DCPS_IR_Topic_Description::try_associate(), DCPS_IR_Topic::try_associate(), and DCPS_IR_Topic_Description::try_associate_publication().

 {
   return &incompatibleQosStatus_;
 }

◆ get_participant_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Publication::get_participant_id ( )

Definition at line 604 of file DCPS_IR_Publication.cpp.

References DCPS_IR_Participant::get_id(), and participant_.

Referenced by DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Domain::publish_publication_bit(), OpenDDS::Federator::ManagerImpl::pushState(), and DCPS_IR_Topic_Description::try_associate().

 {
   return participant_->get_id();
 }

◆ get_publisher_qos()

DDS::PublisherQos * DCPS_IR_Publication::get_publisher_qos ( )

Return pointer to the Publisher qos Publication retains ownership

Definition at line 579 of file DCPS_IR_Publication.cpp.

References publisherQos_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Domain::publish_publication_bit(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Subscription::reevaluate_association(), reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return &publisherQos_;
 }

◆ get_serialized_type_info()

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

Definition at line 772 of file DCPS_IR_Publication.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and serializedTypeInfo_.

Referenced by DCPS_IR_Subscription::add_associated_publication().

 {
   return serializedTypeInfo_;
 }

◆ get_topic()

DCPS_IR_Topic * DCPS_IR_Publication::get_topic ( )

Definition at line 609 of file DCPS_IR_Publication.cpp.

References topic_.

Referenced by DCPS_IR_Domain::publish_publication_bit().

 {
   return topic_;
 }

◆ get_topic_description()

DCPS_IR_Topic_Description * DCPS_IR_Publication::get_topic_description ( )

Definition at line 614 of file DCPS_IR_Publication.cpp.

References DCPS_IR_Topic::get_topic_description(), and topic_.

Referenced by DCPS_IR_Domain::publish_publication_bit().

 {
   return topic_->get_topic_description();
 }

◆ get_topic_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Publication::get_topic_id ( )

Definition at line 599 of file DCPS_IR_Publication.cpp.

References DCPS_IR_Topic::get_id(), and topic_.

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

 {
   return topic_->get_id();
 }

◆ get_transportContext()

ACE_CDR::ULong DCPS_IR_Publication::get_transportContext ( ) const

inline

Definition at line 131 of file DCPS_IR_Publication.h.

References get_handle().

Referenced by DCPS_IR_Subscription::add_associated_publication().

131 { return transportContext_; }

DCPS_IR_Publication::transportContext_

ACE_CDR::ULong transportContext_

Definition: DCPS_IR_Publication.h:188

◆ get_transportLocatorSeq()

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

Definition at line 584 of file DCPS_IR_Publication.cpp.

References info_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Subscription::reevaluate_association(), reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

 {
   return info_;
 }

◆ is_bit()

CORBA::Boolean DCPS_IR_Publication::is_bit ( )

Definition at line 629 of file DCPS_IR_Publication.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::dispose_publication_bit().

 {
   return isBIT_;
 }

◆ is_subscription_ignored()

CORBA::Boolean DCPS_IR_Publication::is_subscription_ignored	(	OpenDDS::DCPS::GUID_t	partId,
		OpenDDS::DCPS::GUID_t	topicId,
		OpenDDS::DCPS::GUID_t	subId
	)

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

Definition at line 461 of file DCPS_IR_Publication.cpp.

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

Referenced by DCPS_IR_Topic_Description::try_associate().

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

◆ reevaluate_association()

bool DCPS_IR_Publication::reevaluate_association ( DCPS_IR_Subscription * subscription )

Definition at line 684 of file DCPS_IR_Publication.cpp.

References associations_, OpenDDS::DCPS::compatibleQOS(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::find(), DCPS_IR_Subscription::get_datareader_qos(), get_datawriter_qos(), get_incompatibleQosStatus(), DCPS_IR_Subscription::get_incompatibleQosStatus(), get_publisher_qos(), DCPS_IR_Subscription::get_subscriber_qos(), DCPS_IR_Topic::get_topic_description(), get_transportLocatorSeq(), DCPS_IR_Subscription::get_transportLocatorSeq(), remove_associated_subscription(), 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(subscription);
 
   if (status == 0) {
     // verify if they are still compatible after change
 
 
     if (!OpenDDS::DCPS::compatibleQOS(this->get_incompatibleQosStatus(),
                                       subscription->get_incompatibleQosStatus(),
                                       this->get_transportLocatorSeq(),
                                       subscription->get_transportLocatorSeq(),
                                       this->get_datawriter_qos(),
                                       subscription->get_datareader_qos(),
                                       this->get_publisher_qos(),
                                       subscription->get_subscriber_qos())) {
       bool sendNotify = true; // inform datawriter
       bool notify_lost = true; // invoke listerner callback
 
       this->remove_associated_subscription(subscription, sendNotify, notify_lost, true);
     }
 
   } else {
     DCPS_IR_Topic_Description* description = this->topic_->get_topic_description();
     return description->try_associate(this, subscription);
   }
 
   return false;
 }

◆ reevaluate_defunct_associations()

void DCPS_IR_Publication::reevaluate_defunct_associations ( )

Definition at line 646 of file DCPS_IR_Publication.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_Subscription::get_id(), id_, LM_ERROR, reevaluate_association(), and ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove().

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

◆ reevaluate_existing_associations()

void DCPS_IR_Publication::reevaluate_existing_associations ( )

Definition at line 669 of file DCPS_IR_Publication.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_Subscription* sub = 0;
   DCPS_IR_Subscription_Set::ITERATOR iter = associations_.begin();
   DCPS_IR_Subscription_Set::ITERATOR end = associations_.end();
 
   while (iter != end) {
     sub = *iter;
     ++iter;
 
     this->reevaluate_association(sub);
   }
 }

◆ remove_associated_subscription()

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

Remove the associated subscription Removes the subscription from the list of associated subscriptions if return successful sendNotify indicates whether to tell the datawriter about removing the subscription The notify_lost parameter is passed to the remove_associations() The notify_both_side parameter indicates if it needs call sub to remove association as well. See the comments of remove_associations() in DataWriterRemote.idl or DataReaderRemote.idl. This method can mark the participant dead Returns 0 if successful

Definition at line 131 of file DCPS_IR_Publication.cpp.

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

Referenced by disassociate_participant(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), disassociate_subscription(), disassociate_topic(), DCPS_IR_Subscription::disassociate_topic(), reevaluate_association(), DCPS_IR_Subscription::remove_associated_publication(), remove_associations(), and DCPS_IR_Subscription::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 pub_converter(id_);
           OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) DCPS_IR_Publication::remove_associated_subscription:")
                      ACE_TEXT(" calling pub %C with sub %C\n"),
                      OPENDDS_STRING(pub_converter).c_str(),
                      OPENDDS_STRING(sub_converter).c_str()));
         }
 
         OpenDDS::DCPS::ReaderIdSeq idSeq(1);
         idSeq.length(1);
         idSeq[0] = sub->get_id();
 
         writer_->remove_associations(idSeq, notify_lost);
 
         if (notify_both_side) {
           sub->remove_associated_publication(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_Publication::remove_associated_subscription:");
         }
 
         participant_->mark_dead();
         marked_dead = true;
       }
     }
   }
 
   int status = associations_.remove(sub);
 
   if (0 == status) {
     if (OpenDDS::DCPS::DCPS_debug_level > 0) {
       OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
       OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) DCPS_IR_Publication::remove_associated_subscription: ")
                  ACE_TEXT("publication %C removed subscription %C at %x.\n"),
                  std::string(pub_converter).c_str(),
                  std::string(sub_converter).c_str(),
                  sub));
     }
 
   } else {
     OpenDDS::DCPS::RepoIdConverter pub_converter(id_);
     OpenDDS::DCPS::RepoIdConverter sub_converter(sub->get_id());
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Publication::remove_associated_subscription: ")
                ACE_TEXT("publication %C failed to remove subscription %C at %x.\n"),
                std::string(pub_converter).c_str(),
                std::string(sub_converter).c_str(),
                sub));
   } // if (0 == status)
 
   if (marked_dead) {
     return -1;
 
   } else {
     return status;
   }
 }

◆ remove_associations()

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

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

Definition at line 206 of file DCPS_IR_Publication.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(), DCPS_IR_Subscription::remove_associated_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_Subscription* sub = 0;
   size_t numAssociations = associations_.size();
   CORBA::Boolean dontSend = 0;
   CORBA::Boolean send = 1;
 
   if (0 < numAssociations) {
     DCPS_IR_Subscription_Set::ITERATOR iter = associations_.begin();
     DCPS_IR_Subscription_Set::ITERATOR end = associations_.end();
 
     while (iter != end) {
       sub = *iter;
       ++iter;
       sub->remove_associated_publication(this, send, notify_lost);
       remove_associated_subscription(sub, dontSend, notify_lost);
     }
   }
   this->defunct_.reset();
 
   return status;
 }

◆ set_bit_status()

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

Definition at line 634 of file DCPS_IR_Publication.cpp.

References isBIT_.

Referenced by DCPS_IR_Participant::add_publication(), and DCPS_IR_Domain::publish_publication_bit().

 {
   isBIT_ = isBIT;
 }

◆ set_handle()

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

Definition at line 624 of file DCPS_IR_Publication.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_publication_bit().

 {
   handle_ = handle;
 }

◆ set_qos() [1/3]

bool DCPS_IR_Publication::set_qos	(	const DDS::DataWriterQos &	qos,
		const DDS::PublisherQos &	publisherQos,
		Update::SpecificQos &	specificQos
	)

Update the DataWriter or Publisher qos and also publish the qos changes to datawriter BIT.

Definition at line 538 of file DCPS_IR_Publication.cpp.

References Update::DataWriterQos, DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), Update::NoQos, participant_, DCPS_IR_Domain::publish_publication_bit(), Update::PublisherQos, publisherQos_, qos_, DCPS_IR_Topic_Description::reevaluate_associations(), reevaluate_existing_associations(), OpenDDS::DCPS::should_check_association_upon_change(), and topic_.

Referenced by TAO_DDS_DCPSInfo_i::update_publication_qos().

 {
   bool need_evaluate = false;
   bool u_dw_qos = !(qos_ == qos);
 
   if (u_dw_qos) {
     if (OpenDDS::DCPS::should_check_association_upon_change(qos_, qos)) {
       need_evaluate = true;
     }
 
     qos_ = qos;
   }
 
   bool u_pub_qos = !(publisherQos_ == publisherQos);
 
   if (u_pub_qos) {
     if (OpenDDS::DCPS::should_check_association_upon_change(publisherQos_, publisherQos)) {
       need_evaluate = true;
     }
 
     publisherQos_ = publisherQos;
   }
 
   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_publication_bit(this);
   specificQos = u_dw_qos?  Update::DataWriterQos:
                 u_pub_qos? Update::PublisherQos:
                 Update::NoQos;
 
   return true;
 }

◆ set_qos() [2/3]

void DCPS_IR_Publication::set_qos ( const DDS::DataWriterQos & qos )

Update DataWriterQos only.

Definition at line 481 of file DCPS_IR_Publication.cpp.

References DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), participant_, DCPS_IR_Domain::publish_publication_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_publication_bit(this);
   }
 }

◆ set_qos() [3/3]

void DCPS_IR_Publication::set_qos ( const DDS::PublisherQos & qos )

Update PublisherQos only.

Definition at line 510 of file DCPS_IR_Publication.cpp.

References DCPS_IR_Participant::get_domain_reference(), DCPS_IR_Topic::get_topic_description(), participant_, DCPS_IR_Domain::publish_publication_bit(), publisherQos_, 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->publisherQos_)) {
     // Check if we should check while we have both values.
     bool check = OpenDDS::DCPS::should_check_association_upon_change(qos, this->publisherQos_);
 
     // Store the new, compatible, value.
     this->publisherQos_ = 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_publication_bit(this);
   }
 }

◆ update_expr_params()

void DCPS_IR_Publication::update_expr_params	(	OpenDDS::DCPS::GUID_t	readerId,
		const DDS::StringSeq &	params
	)

Definition at line 715 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Participant::mark_dead(), participant_, and writer_.

 {
   try {
     writer_->update_subscription_params(readerId, params);
   } catch (const CORBA::SystemException& ex) {
     if (OpenDDS::DCPS::DCPS_debug_level) {
       ex._tao_print_exception("(%P|%t) ERROR: Exception caught in "
         "DCPS_IR_Publication::update_expr_params:");
     }
     participant_->mark_dead();
   }
 }

◆ update_incompatible_qos()

void DCPS_IR_Publication::update_incompatible_qos ( )

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

Definition at line 444 of file DCPS_IR_Publication.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 writer_.

Referenced by DCPS_IR_Topic::try_associate(), and DCPS_IR_Topic_Description::try_associate_publication().

 {
   if (participant_->is_alive() && this->participant_->isOwner()) {
     try {
       writer_->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_Publication::update_incompatible_qos:");
       }
 
       participant_->mark_dead();
     }
   }
 }

◆ writer()

OpenDDS::DCPS::DataWriterRemote_ptr DCPS_IR_Publication::writer ( void )

Definition at line 640 of file DCPS_IR_Publication.cpp.

References writer_.

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

 {
   return OpenDDS::DCPS::DataWriterRemote::_duplicate(this->writer_.in());
 }

Member Data Documentation

◆ associations_

DCPS_IR_Subscription_Set DCPS_IR_Publication::associations_

private

Definition at line 191 of file DCPS_IR_Publication.h.

Referenced by add_associated_subscription(), disassociate_participant(), disassociate_subscription(), disassociate_topic(), dump_to_string(), reevaluate_association(), reevaluate_existing_associations(), remove_associated_subscription(), and remove_associations().

◆ defunct_

DCPS_IR_Subscription_Set DCPS_IR_Publication::defunct_

private

Definition at line 192 of file DCPS_IR_Publication.h.

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

◆ handle_

DDS::InstanceHandle_t DCPS_IR_Publication::handle_

private

Definition at line 181 of file DCPS_IR_Publication.h.

Referenced by get_handle(), and set_handle().

◆ id_

OpenDDS::DCPS::GUID_t DCPS_IR_Publication::id_

private

Definition at line 178 of file DCPS_IR_Publication.h.

Referenced by add_associated_subscription(), disassociate_participant(), disassociate_subscription(), disassociate_topic(), dump_to_string(), get_id(), reevaluate_defunct_associations(), and remove_associated_subscription().

◆ incompatibleQosStatus_

OpenDDS::DCPS::IncompatibleQosStatus DCPS_IR_Publication::incompatibleQosStatus_

private

Definition at line 194 of file DCPS_IR_Publication.h.

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

◆ info_

OpenDDS::DCPS::TransportLocatorSeq DCPS_IR_Publication::info_

private

Definition at line 187 of file DCPS_IR_Publication.h.

Referenced by get_transportLocatorSeq().

◆ isBIT_

CORBA::Boolean DCPS_IR_Publication::isBIT_

private

Definition at line 182 of file DCPS_IR_Publication.h.

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

◆ participant_

DCPS_IR_Participant* DCPS_IR_Publication::participant_

private

Definition at line 179 of file DCPS_IR_Publication.h.

Referenced by add_associated_subscription(), disassociate_participant(), disassociate_subscription(), disassociate_topic(), get_participant_id(), is_subscription_ignored(), remove_associated_subscription(), set_qos(), update_expr_params(), and update_incompatible_qos().

◆ publisherQos_

DDS::PublisherQos DCPS_IR_Publication::publisherQos_

private

Definition at line 189 of file DCPS_IR_Publication.h.

Referenced by get_publisher_qos(), and set_qos().

◆ qos_

DDS::DataWriterQos DCPS_IR_Publication::qos_

private

Definition at line 186 of file DCPS_IR_Publication.h.

Referenced by get_datawriter_qos(), and set_qos().

◆ serializedTypeInfo_

DDS::OctetSeq DCPS_IR_Publication::serializedTypeInfo_

private

Definition at line 190 of file DCPS_IR_Publication.h.

Referenced by get_serialized_type_info().

◆ topic_

DCPS_IR_Topic* DCPS_IR_Publication::topic_

private

Definition at line 180 of file DCPS_IR_Publication.h.

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

◆ transportContext_

ACE_CDR::ULong DCPS_IR_Publication::transportContext_

private

Definition at line 188 of file DCPS_IR_Publication.h.

◆ writer_

OpenDDS::DCPS::DataWriterRemote_var DCPS_IR_Publication::writer_

private

the corresponding DataWriterRemote object

Definition at line 185 of file DCPS_IR_Publication.h.

Referenced by add_associated_subscription(), DCPS_IR_Publication(), disassociate_participant(), disassociate_subscription(), disassociate_topic(), remove_associated_subscription(), update_expr_params(), update_incompatible_qos(), and writer().

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_Publication()

◆ ~DCPS_IR_Publication()

Member Function Documentation

◆ add_associated_subscription()

◆ disassociate_participant()

◆ disassociate_subscription()

◆ disassociate_topic()

◆ dump_to_string()

◆ get_datawriter_qos()

◆ get_handle()

◆ get_id()

◆ get_incompatibleQosStatus()

◆ get_participant_id()

◆ get_publisher_qos()

◆ get_serialized_type_info()

◆ get_topic()

◆ get_topic_description()

◆ get_topic_id()

◆ get_transportContext()

◆ get_transportLocatorSeq()

◆ is_bit()

◆ is_subscription_ignored()

◆ reevaluate_association()

◆ reevaluate_defunct_associations()

◆ reevaluate_existing_associations()

◆ remove_associated_subscription()

◆ 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()

◆ writer()

Member Data Documentation

◆ associations_

◆ defunct_

◆ handle_

◆ id_

◆ incompatibleQosStatus_

◆ info_

◆ isBIT_

◆ participant_

◆ publisherQos_

◆ qos_

◆ serializedTypeInfo_

◆ topic_

◆ transportContext_

◆ writer_