DCPS_IR_Topic_Description Class Reference

Representative of a Topic Description. More...

#include <DCPS_IR_Topic_Description.h>

Inheritance diagram for DCPS_IR_Topic_Description:

Collaboration diagram for DCPS_IR_Topic_Description:

Public Member Functions
	DCPS_IR_Topic_Description (DCPS_IR_Domain *domain, const char *name, const char *dataTypeName)
	~DCPS_IR_Topic_Description ()
int	add_subscription_reference (DCPS_IR_Subscription *subscription, bool associate=true)
int	remove_subscription_reference (DCPS_IR_Subscription *subscription)
int	add_topic (DCPS_IR_Topic *topic)
int	remove_topic (DCPS_IR_Topic *topic)
DCPS_IR_Topic *	get_first_topic ()
	Gets the first topic in the topic list. More...
void	try_associate_publication (DCPS_IR_Publication *publication)
void	try_associate_subscription (DCPS_IR_Subscription *subscription)
bool	try_associate (DCPS_IR_Publication *publication, DCPS_IR_Subscription *subscription)
void	associate (DCPS_IR_Publication *publication, DCPS_IR_Subscription *subscription)
	Associate the publication and subscription. More...
void	reevaluate_associations (DCPS_IR_Publication *publication)
void	reevaluate_associations (DCPS_IR_Subscription *subscription)
const char *	get_name () const
const char *	get_dataTypeName () const
CORBA::ULong	get_number_topics () const
	Returns the number of topics. More...
std::string	dump_to_string (const std::string &prefix, int depth) const

Private Attributes
ACE_CString	name_
ACE_CString	dataTypeName_
DCPS_IR_Domain *	domain_
DCPS_IR_Subscription_Set	subscriptionRefs_
DCPS_IR_Topic_Set	topics_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::EnableContainerSupportedUniquePtr< DCPS_IR_Topic_Description >
	EnableContainerSupportedUniquePtr ()
void	_add_ref ()
void	_remove_ref ()
long	ref_count () const

Detailed Description

Representative of a Topic Description.

Definition at line 43 of file DCPS_IR_Topic_Description.h.

Constructor & Destructor Documentation

DCPS_IR_Topic_Description()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL DCPS_IR_Topic_Description::DCPS_IR_Topic_Description	(	DCPS_IR_Domain *	domain,
		const char *	name,
		const char *	dataTypeName
	)

Definition at line 25 of file DCPS_IR_Topic_Description.cpp.

  : name_(name),
    dataTypeName_(dataTypeName),
    domain_(domain)
{
}

~DCPS_IR_Topic_Description()

DCPS_IR_Topic_Description::~DCPS_IR_Topic_Description

(

)

Definition at line 34 of file DCPS_IR_Topic_Description.cpp.

{
}

Member Function Documentation

add_subscription_reference()

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

Adds the subscription to the list of subscriptions Tries to associate with existing publications if successfully added 'associate' switch toggles association attempt. Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 38 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, domain_, DCPS_IR_Subscription::get_id(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), LM_DEBUG, LM_ERROR, name_, DCPS_IR_Domain::publish_subscription_bit(), subscriptionRefs_, and try_associate_subscription().

Referenced by DCPS_IR_Topic::add_subscription_reference().

{
  int status = subscriptionRefs_.insert(subscription);

  switch (status) {
  case 0:

    // Publish the BIT information
    domain_->publish_subscription_bit(subscription);

    if (associate) {
      try_associate_subscription(subscription);
      // Do not check incompatible qos here.  The check is done
      // in the DCPS_IR_Topic_Description::try_associate_subscription method
    }

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::add_subscription_reference: ")
                 ACE_TEXT("topic description %C added subscription %C at %x\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str(),
                 subscription));
    }

    break;

  case 1: {
    OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::add_subscription_reference: ")
               ACE_TEXT("topic description %C attempt to re-add subscription %C.\n"),
               this->name_.c_str(),
               std::string(converter).c_str()));
  }
  break;

  case -1: {
    OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::add_subscription_reference: ")
               ACE_TEXT("topic description %C failed to add subscription %C.\n"),
               this->name_.c_str(),
               std::string(converter).c_str()));
  }
  };

  return status;
}

add_topic()

int DCPS_IR_Topic_Description::add_topic

(

DCPS_IR_Topic *

topic

)

Add a topic Takes ownership of memory pointed to by topic Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 116 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Topic::get_id(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::insert(), LM_DEBUG, LM_ERROR, LM_WARNING, name_, and topics_.

Referenced by DCPS_IR_Domain::add_topic_i().

{
  int status = topics_.insert(topic);

  switch (status) {
  case 0:

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::add_topic: ")
                 ACE_TEXT("topic description %C added topic %C at %x.\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str(),
                 topic));
    }

    break;
  case 1:

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
      ACE_DEBUG((LM_WARNING,
                 ACE_TEXT("(%P|%t) WARNING: DCPS_IR_Topic_Description::add_topic: ")
                 ACE_TEXT("topic description %C attempt to re-add topic %C.\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str()));
    }

    break;
  case -1: {
    OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::add_topic: ")
               ACE_TEXT("topic description %C failed to add topic %C.\n"),
               this->name_.c_str(),
               std::string(converter).c_str()));
  }
  break;
  };

  return status;
}

associate()

void DCPS_IR_Topic_Description::associate	(	DCPS_IR_Publication *	publication,
		DCPS_IR_Subscription *	subscription
	)

Associate the publication and subscription.

Definition at line 339 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_TEXT(), DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Publication::add_associated_subscription(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Publication::get_id(), DCPS_IR_Subscription::get_id(), LM_DEBUG, LM_INFO, and name_.

Referenced by try_associate().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
    OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::associate: ")
               ACE_TEXT("topic description %C associating ")
               ACE_TEXT("publication %C with subscription %C.\n"),
               this->name_.c_str(),
               std::string(pub_converter).c_str(),
               std::string(sub_converter).c_str()));
  }

  // The publication must be told first because it will be the connector
  // if a data link needs to be created.
  // This is only required if the publication and subscription are being
  // handed by the same process and thread.  Order when there is
  // another thread or process is not important.
  // Note: the client thread may process the add_associations() oneway
  //       call instead of the ORB thread because it is currently
  //       in a two-way call to the Repo.
  int error = publication->add_associated_subscription(subscription, true);

  // If there was no TAO error contacting the publication (This can happen if
  // an old publisher has exited non-gracefully)
  if (error != -1) {
    // Associate the subscription with the publication
    subscription->add_associated_publication(publication, false);
  } else {
    ACE_DEBUG((LM_INFO, ACE_TEXT("Invalid publication detected, NOT notifying subscription of association\n")));
  }
}

dump_to_string()

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

Definition at line 419 of file DCPS_IR_Topic_Description.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_String_Base< char >::c_str(), dataTypeName_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), name_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, subscriptionRefs_, and topics_.

{
  std::string str;
#if !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
  for (int i=0; i < depth; i++)
    str += prefix;
  std::string indent = str + prefix;
  str += "DCPS_IR_Topic_Description [";
  str += name_.c_str();
  str += "][";
  str += dataTypeName_.c_str();
  str += "]\n";

  str += indent + "Subscription References [ ";
  for (DCPS_IR_Subscription_Set::const_iterator sub = subscriptionRefs_.begin();
       sub != subscriptionRefs_.end();
       sub++)
  {
    OpenDDS::DCPS::RepoIdConverter sub_converter((*sub)->get_id());
    str += std::string(sub_converter);
    str += " ";
  }
  str += "]\n";

  str += indent + "Topics [ ";
  for (DCPS_IR_Topic_Set::const_iterator top = topics_.begin();
       top != topics_.end();
       top++)
  {
    OpenDDS::DCPS::RepoIdConverter top_converter((*top)->get_id());
    str += std::string(top_converter);
    str += " ";
  }
  str += "]\n";
#endif // !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
  return str;
}

get_dataTypeName()

const char * DCPS_IR_Topic_Description::get_dataTypeName

(

)

const

Definition at line 408 of file DCPS_IR_Topic_Description.cpp.

References ACE_String_Base< char >::c_str(), and dataTypeName_.

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

{
  return dataTypeName_.c_str();
}

get_first_topic()

DCPS_IR_Topic * DCPS_IR_Topic_Description::get_first_topic

(

)

Gets the first topic in the topic list.

Definition at line 186 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_TEXT(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Topic::get_id(), LM_DEBUG, name_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size(), and topics_.

{
  DCPS_IR_Topic* topic = 0;

  if (0 < topics_.size()) {
    DCPS_IR_Topic_Set::ITERATOR iter = topics_.begin();
    topic = *iter;

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::get_first_topic: ")
                 ACE_TEXT("topic description %C first topic %C.\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str()));
    }
  }

  return topic;
}

get_name()

const char * DCPS_IR_Topic_Description::get_name

(

void

)

const

Definition at line 403 of file DCPS_IR_Topic_Description.cpp.

References ACE_String_Base< char >::c_str(), and name_.

Referenced by DCPS_IR_Domain::add_topic_description(), DCPS_IR_Domain::publish_publication_bit(), DCPS_IR_Domain::publish_subscription_bit(), DCPS_IR_Domain::publish_topic_bit(), DCPS_IR_Domain::remove_topic(), and DCPS_IR_Domain::remove_topic_description().

{
  return name_.c_str();
}

get_number_topics()

CORBA::ULong DCPS_IR_Topic_Description::get_number_topics

(

)

const

Returns the number of topics.

Definition at line 413 of file DCPS_IR_Topic_Description.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::size(), and topics_.

Referenced by DCPS_IR_Domain::remove_topic().

{
  return static_cast<CORBA::ULong>(topics_.size());
}

reevaluate_associations() [1/2]

void DCPS_IR_Topic_Description::reevaluate_associations

(

DCPS_IR_Publication *

publication

)

Re-evaluate the association between the provided publication and the subscriptions it maintains.

Definition at line 389 of file DCPS_IR_Topic_Description.cpp.

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

Referenced by DCPS_IR_Publication::set_qos(), and DCPS_IR_Subscription::set_qos().

{
  DCPS_IR_Subscription * sub = 0;
  DCPS_IR_Subscription_Set::ITERATOR iter = subscriptionRefs_.begin();
  DCPS_IR_Subscription_Set::ITERATOR end = subscriptionRefs_.end();

  while (iter != end) {
    sub = *iter;
    ++iter;
    publication->reevaluate_association(sub);
    sub->reevaluate_association(publication);
  }
}

reevaluate_associations() [2/2]

void DCPS_IR_Topic_Description::reevaluate_associations

(

DCPS_IR_Subscription *

subscription

)

Re-evaluate the association between the provided subscription and the publications in all its maintained topics.

Definition at line 374 of file DCPS_IR_Topic_Description.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Topic::reevaluate_associations(), and topics_.

{
  DCPS_IR_Topic* topic = 0;

  DCPS_IR_Topic_Set::ITERATOR iter = topics_.begin();
  DCPS_IR_Topic_Set::ITERATOR end = topics_.end();

  while (iter != end) {
    topic = *iter;
    ++iter;

    topic->reevaluate_associations(subscription);
  }
}

remove_subscription_reference()

int DCPS_IR_Topic_Description::remove_subscription_reference

(

DCPS_IR_Subscription *

subscription

)

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

Definition at line 90 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Subscription::get_id(), LM_DEBUG, LM_ERROR, name_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove(), and subscriptionRefs_.

Referenced by DCPS_IR_Topic::remove_subscription_reference().

{
  int status = subscriptionRefs_.remove(subscription);

  if (0 == status) {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::remove_subscription_reference: ")
                 ACE_TEXT("topic description %C removed subscription %C.\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str()));
    }

  } else {
    OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::remove_subscription_reference: ")
               ACE_TEXT("topic description %C failed to remove subscription %C.\n"),
               this->name_.c_str(),
               std::string(converter).c_str()));
  } // if (0 == status)

  return status;
}

remove_topic()

int DCPS_IR_Topic_Description::remove_topic

(

DCPS_IR_Topic *

topic

)

Removes the topic from the list of topics Gives ownership of the memory pointed to by topic to the caller Returns 0 if successful

Definition at line 160 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Topic::get_id(), LM_DEBUG, LM_ERROR, name_, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::remove(), and topics_.

Referenced by DCPS_IR_Domain::add_topic_i(), and DCPS_IR_Domain::remove_topic().

{
  int status = topics_.remove(topic);

  if (0 == status) {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::remove_topic: ")
                 ACE_TEXT("topic description %C removed topic %C.\n"),
                 this->name_.c_str(),
                 std::string(converter).c_str()));
    }

  } else {
    OpenDDS::DCPS::RepoIdConverter converter(topic->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::remove_topic: ")
               ACE_TEXT("topic description failed to remove topic %C.\n"),
               this->name_.c_str(),
               std::string(converter).c_str()));
  }

  return status;
}

try_associate()

bool DCPS_IR_Topic_Description::try_associate	(	DCPS_IR_Publication *	publication,
		DCPS_IR_Subscription *	subscription
	)

Checks to see if the publication and subscription can be associated.

Definition at line 274 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_TEXT(), associate(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::compatibleQOS(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Subscription::get_datareader_qos(), DCPS_IR_Publication::get_datawriter_qos(), DCPS_IR_Publication::get_id(), DCPS_IR_Subscription::get_id(), DCPS_IR_Publication::get_incompatibleQosStatus(), DCPS_IR_Subscription::get_incompatibleQosStatus(), DCPS_IR_Publication::get_participant_id(), DCPS_IR_Subscription::get_participant_id(), DCPS_IR_Publication::get_publisher_qos(), DCPS_IR_Subscription::get_subscriber_qos(), DCPS_IR_Publication::get_topic_id(), DCPS_IR_Subscription::get_topic_id(), DCPS_IR_Publication::get_transportLocatorSeq(), DCPS_IR_Subscription::get_transportLocatorSeq(), DCPS_IR_Subscription::is_publication_ignored(), DCPS_IR_Publication::is_subscription_ignored(), LM_DEBUG, and name_.

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

{
  if (publication->is_subscription_ignored(subscription->get_participant_id(),
                                           subscription->get_topic_id(),
                                           subscription->get_id())) {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
      OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::try_associate: ")
                 ACE_TEXT("topic description %C publication %C ignores subscription %C.\n"),
                 this->name_.c_str(),
                 std::string(pub_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }
  }

  else if (subscription->is_publication_ignored(publication->get_participant_id(),
                                                publication->get_topic_id(),
                                                publication->get_id())) {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
      OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::try_associate: ")
                 ACE_TEXT("topic description %C subscription %C ignores publication %C.\n"),
                 this->name_.c_str(),
                 std::string(pub_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter pub_converter(publication->get_id());
      OpenDDS::DCPS::RepoIdConverter sub_converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::try_associate: ")
                 ACE_TEXT("topic description %C checking compatibility of ")
                 ACE_TEXT("publication %C with subscription %C.\n"),
                 this->name_.c_str(),
                 std::string(pub_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }

    if (OpenDDS::DCPS::compatibleQOS(publication->get_incompatibleQosStatus(),
                                     subscription->get_incompatibleQosStatus(),
                                     publication->get_transportLocatorSeq(),
                                     subscription->get_transportLocatorSeq(),
                                     publication->get_datawriter_qos(),
                                     subscription->get_datareader_qos(),
                                     publication->get_publisher_qos(),
                                     subscription->get_subscriber_qos())) {
      associate(publication, subscription);
      return true;
    }

    // Dont notify that there is an incompatible qos here
    // notify where we can distinguish which one is being added
    // so we only send one response(with all incompatible qos) to it
  }

  return false;
}

try_associate_publication()

void DCPS_IR_Topic_Description::try_associate_publication

(

DCPS_IR_Publication *

publication

)

Tries to associate the publication will each of the subscriptions in the subscription list

Definition at line 207 of file DCPS_IR_Topic_Description.cpp.

References ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), OpenDDS::DCPS::IncompatibleQosStatus::count_since_last_send, ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::end(), DCPS_IR_Publication::get_incompatibleQosStatus(), DCPS_IR_Subscription::get_incompatibleQosStatus(), subscriptionRefs_, try_associate(), DCPS_IR_Publication::update_incompatible_qos(), and DCPS_IR_Subscription::update_incompatible_qos().

Referenced by DCPS_IR_Topic::add_publication_reference(), and DCPS_IR_Topic::reassociate_all_publications().

{
  // for each subscription check for compatibility
  DCPS_IR_Subscription* subscription = 0;
  OpenDDS::DCPS::IncompatibleQosStatus* qosStatus = 0;

  DCPS_IR_Subscription_Set::ITERATOR iter = subscriptionRefs_.begin();
  DCPS_IR_Subscription_Set::ITERATOR end = subscriptionRefs_.end();

  while (iter != end) {
    subscription = *iter;
    ++iter;
    try_associate(publication, subscription);

    // Check the subscriptions QOS status
    qosStatus = subscription->get_incompatibleQosStatus();

    if (0 < qosStatus->count_since_last_send) {
      subscription->update_incompatible_qos();
    }
  }

  // Check the publications QOS status
  qosStatus = publication->get_incompatibleQosStatus();

  if (0 < qosStatus->count_since_last_send) {
    publication->update_incompatible_qos();
  }
}

try_associate_subscription()

void DCPS_IR_Topic_Description::try_associate_subscription

(

DCPS_IR_Subscription *

subscription

)

Tries to associate the subscription will each of the publications in each topic in the topic list

Definition at line 237 of file DCPS_IR_Topic_Description.cpp.

References ACE_DEBUG, ACE_TEXT(), ACE_Unbounded_Set_Ex< T, ACE_Unbounded_Set_Default_Comparator< T > >::begin(), ACE_String_Base< char >::c_str(), 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_incompatibleQosStatus(), LM_DEBUG, name_, topics_, OpenDDS::DCPS::IncompatibleQosStatus::total_count, DCPS_IR_Topic::try_associate(), and DCPS_IR_Subscription::update_incompatible_qos().

Referenced by add_subscription_reference().

{
  // check all topics for compatible publications

  DCPS_IR_Topic* topic = 0;

  DCPS_IR_Topic_Set::ITERATOR iter = topics_.begin();
  DCPS_IR_Topic_Set::ITERATOR end = topics_.end();

  while (iter != end) {
    topic = *iter;
    ++iter;

    topic->try_associate(subscription);
  }

  // Check the subscriptions QOS status
  OpenDDS::DCPS::IncompatibleQosStatus* qosStatus =
    subscription->get_incompatibleQosStatus();

  if (0 < qosStatus->total_count) {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id());
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::try_associate_subscription: ")
                 ACE_TEXT("topic description %C has %d incompatible publications ")
                 ACE_TEXT("with subscription %C.\n"),
                 this->name_.c_str(),
                 qosStatus->total_count,
                 std::string(converter).c_str()));
    }

    subscription->update_incompatible_qos();
  }
}

Member Data Documentation

dataTypeName_

ACE_CString DCPS_IR_Topic_Description::dataTypeName_

private

Definition at line 113 of file DCPS_IR_Topic_Description.h.

Referenced by dump_to_string(), and get_dataTypeName().

domain_

DCPS_IR_Domain* DCPS_IR_Topic_Description::domain_

private

Definition at line 114 of file DCPS_IR_Topic_Description.h.

Referenced by add_subscription_reference().

name_

ACE_CString DCPS_IR_Topic_Description::name_

private

Definition at line 112 of file DCPS_IR_Topic_Description.h.

Referenced by add_subscription_reference(), add_topic(), associate(), dump_to_string(), get_first_topic(), get_name(), remove_subscription_reference(), remove_topic(), try_associate(), and try_associate_subscription().

subscriptionRefs_

DCPS_IR_Subscription_Set DCPS_IR_Topic_Description::subscriptionRefs_

private

Definition at line 116 of file DCPS_IR_Topic_Description.h.

Referenced by add_subscription_reference(), dump_to_string(), reevaluate_associations(), remove_subscription_reference(), and try_associate_publication().

topics_

DCPS_IR_Topic_Set DCPS_IR_Topic_Description::topics_

private

Definition at line 117 of file DCPS_IR_Topic_Description.h.

Referenced by add_topic(), dump_to_string(), get_first_topic(), get_number_topics(), reevaluate_associations(), remove_topic(), and try_associate_subscription().

---

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

• DCPS_IR_Topic_Description.h
• DCPS_IR_Topic_Description.cpp