DCPS_IR_Publication Class Reference

Representative of a Publication. More...

#include <DCPS_IR_Publication.h>

Inheritance diagram for DCPS_IR_Publication:

[legend]

Collaboration diagram for DCPS_IR_Publication:

[legend]

List of all members.

Public Member Functions
	DCPS_IR_Publication (const OpenDDS::DCPS::RepoId &id, DCPS_IR_Participant *participant, DCPS_IR_Topic *topic, OpenDDS::DCPS::DataWriterRemote_ptr writer, const DDS::DataWriterQos &qos, const OpenDDS::DCPS::TransportLocatorSeq &info, const DDS::PublisherQos &publisherQos)
	~DCPS_IR_Publication ()
int	add_associated_subscription (DCPS_IR_Subscription *sub, bool active)
void	association_complete (const OpenDDS::DCPS::RepoId &remote)
void	call_association_complete (const OpenDDS::DCPS::RepoId &remote)
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::RepoId id, bool reassociate=false)
	Remove any subscriptions whose participant has the id.
void	disassociate_topic (OpenDDS::DCPS::RepoId id)
	Remove any subscriptions whose topic has the id.
void	disassociate_subscription (OpenDDS::DCPS::RepoId id, bool reassociate=false)
	Remove any subscriptions with the id.
void	update_incompatible_qos ()
CORBA::Boolean	is_subscription_ignored (OpenDDS::DCPS::RepoId partId, OpenDDS::DCPS::RepoId topicId, OpenDDS::DCPS::RepoId 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.
void	set_qos (const DDS::PublisherQos &qos)
	Update PublisherQos only.
OpenDDS::DCPS::TransportLocatorSeq	get_transportLocatorSeq () const
OpenDDS::DCPS::IncompatibleQosStatus *	get_incompatibleQosStatus ()
OpenDDS::DCPS::RepoId	get_id ()
OpenDDS::DCPS::RepoId	get_topic_id ()
OpenDDS::DCPS::RepoId	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::RepoId readerId, const DDS::StringSeq &params)
std::string	dump_to_string (const std::string &prefix, int depth) const
Private Attributes
OpenDDS::DCPS::RepoId	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
DDS::DataWriterQos	qos_
OpenDDS::DCPS::TransportLocatorSeq	info_
DDS::PublisherQos	publisherQos_
DCPS_IR_Subscription_Set	associations_
DCPS_IR_Subscription_Set	defunct_
OpenDDS::DCPS::IncompatibleQosStatus	incompatibleQosStatus_

---

Detailed Description

Representative of a Publication.

Definition at line 41 of file DCPS_IR_Publication.h.

---

Constructor & Destructor Documentation

DCPS_IR_Publication h OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL DCPS_IR_Publication::DCPS_IR_Publication	(	const OpenDDS::DCPS::RepoId &	id,
		DCPS_IR_Participant *	participant,
		DCPS_IR_Topic *	topic,
		OpenDDS::DCPS::DataWriterRemote_ptr	writer,
		const DDS::DataWriterQos &	qos,
		const OpenDDS::DCPS::TransportLocatorSeq &	info,
		const DDS::PublisherQos &	publisherQos
	)

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),
    publisherQos_(publisherQos)
{
  writer_ =  OpenDDS::DCPS::DataWriterRemote::_duplicate(writer);

  incompatibleQosStatus_.total_count = 0;
  incompatibleQosStatus_.count_since_last_send = 0;
}

DCPS_IR_Publication::~DCPS_IR_Publication

(

)

Definition at line 48 of file DCPS_IR_Publication.cpp.

{
}

---

Member Function Documentation

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 52 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_TEXT(), associations_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ReaderAssociation::exprParams, OpenDDS::DCPS::ReaderAssociation::filterClassName, OpenDDS::DCPS::ReaderAssociation::filterExpression, DCPS_IR_Subscription::get_datareader_qos(), DCPS_IR_Subscription::get_expr_params(), DCPS_IR_Subscription::get_filter_class_name(), DCPS_IR_Subscription::get_filter_expression(), DCPS_IR_Subscription::get_id(), DCPS_IR_Subscription::get_subscriber_qos(), DCPS_IR_Subscription::get_transportLocatorSeq(), id_, ACE_Unbounded_Set_Ex< T, C >::insert(), DCPS_IR_Participant::is_alive(), DCPS_IR_Participant::isOwner(), LM_DEBUG, LM_ERROR, DCPS_IR_Participant::mark_dead(), participant_, OpenDDS::DCPS::ReaderAssociation::readerId, OpenDDS::DCPS::ReaderAssociation::readerQos, OpenDDS::DCPS::ReaderAssociation::readerTransInfo, status, OpenDDS::DCPS::ReaderAssociation::subQos, and writer_.

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.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();

    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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Publication::association_complete

(

const OpenDDS::DCPS::RepoId &

remote

)

The service participant that contains this Publication has indicated that the assocation to peer "remote" is complete. This method will locate the Subscription object for "remote" in order to inform it of the completed association.

Definition at line 126 of file DCPS_IR_Publication.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, C >::begin(), ACE_Unbounded_Set_Ex< T, C >::end(), and get_id().

Referenced by TAO_DDS_DCPSInfo_i::association_complete().

{
  typedef DCPS_IR_Subscription_Set::ITERATOR iter_t;
  for (iter_t iter = associations_.begin(); iter != associations_.end(); ++iter) {
    if ((*iter)->get_id() == remote) {
      (*iter)->call_association_complete(get_id());
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Publication::call_association_complete

(

const OpenDDS::DCPS::RepoId &

remote

)

Invoke the DataWriterRemote::association_complete() callback, passing the "remote" parameter (Subscription) to the service participant.

Definition at line 137 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_->association_complete(remote);
  } 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::call_association_complete:");
    }
    participant_->mark_dead();
  }
}

Here is the call graph for this function:

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

Remove any subscriptions whose participant has the id.

Definition at line 249 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, C >::begin(), OpenDDS::DCPS::DCPS_debug_level, defunct_, ACE_Unbounded_Set_Ex< T, C >::end(), DCPS_IR_Subscription::get_id(), DCPS_IR_Subscription::get_participant_id(), id_, ACE_Unbounded_Set_Ex< T, C >::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, C >::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_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();
        }
      }
    }
  }
}

Here is the call graph for this function:

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

Remove any subscriptions with the id.

Definition at line 389 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, C >::begin(), OpenDDS::DCPS::DCPS_debug_level, defunct_, ACE_Unbounded_Set_Ex< T, C >::end(), DCPS_IR_Subscription::get_id(), id_, ACE_Unbounded_Set_Ex< T, C >::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, C >::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();
        }
      }
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Publication::disassociate_topic

(

OpenDDS::DCPS::RepoId

id

)

Remove any subscriptions whose topic has the id.

Definition at line 325 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_TEXT(), associations_, ACE_Unbounded_Set_Ex< T, C >::begin(), OpenDDS::DCPS::DCPS_debug_level, ACE_Unbounded_Set_Ex< T, C >::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, C >::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();
        }
      }
    }
  }
}

Here is the call graph for this function:

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

Definition at line 749 of file DCPS_IR_Publication.cpp.

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

{
  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;
}

Here is the call graph for this function:

DDS::DataWriterQos * DCPS_IR_Publication::get_datawriter_qos

(

)

Return pointer to the DataWriter qos Publication retains ownership

Definition at line 492 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_;
}

Here is the caller graph for this function:

DDS::InstanceHandle_t DCPS_IR_Publication::get_handle

(

void

)

Definition at line 638 of file DCPS_IR_Publication.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_publication_bit().

{
  return handle_;
}

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId DCPS_IR_Publication::get_id

(

void

)

Definition at line 613 of file DCPS_IR_Publication.cpp.

References id_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Topic::add_publication_reference(), DCPS_IR_Topic_Description::associate(), association_complete(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), DCPS_IR_Subscription::disassociate_topic(), DCPS_IR_Domain::publish_publication_bit(), OpenDDS::Federator::ManagerImpl::pushState(), DCPS_IR_Subscription::reevaluate_defunct_associations(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Topic::remove_publication_reference(), and DCPS_IR_Topic_Description::try_associate().

{
  return id_;
}

Here is the caller graph for this function:

OpenDDS::DCPS::IncompatibleQosStatus * DCPS_IR_Publication::get_incompatibleQosStatus

(

)

Return pointer to the incompatible qos status Publication retains ownership

Definition at line 608 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_;
}

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId DCPS_IR_Publication::get_participant_id

(

)

Definition at line 623 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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

DDS::PublisherQos * DCPS_IR_Publication::get_publisher_qos

(

)

Return pointer to the Publisher qos Publication retains ownership

Definition at line 598 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_;
}

Here is the caller graph for this function:

DCPS_IR_Topic * DCPS_IR_Publication::get_topic

(

)

Definition at line 628 of file DCPS_IR_Publication.cpp.

References topic_.

Referenced by DCPS_IR_Domain::publish_publication_bit().

{
  return topic_;
}

Here is the caller graph for this function:

DCPS_IR_Topic_Description * DCPS_IR_Publication::get_topic_description

(

)

Definition at line 633 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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId DCPS_IR_Publication::get_topic_id

(

)

Definition at line 618 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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::TransportLocatorSeq DCPS_IR_Publication::get_transportLocatorSeq

(

)

const

Definition at line 603 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_;
}

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Publication::is_bit

(

)

Definition at line 648 of file DCPS_IR_Publication.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::dispose_publication_bit().

{
  return isBIT_;
}

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Publication::is_subscription_ignored	(	OpenDDS::DCPS::RepoId	partId,
		OpenDDS::DCPS::RepoId	topicId,
		OpenDDS::DCPS::RepoId	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 480 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool DCPS_IR_Publication::reevaluate_association

(

DCPS_IR_Subscription *

subscription

)

Definition at line 703 of file DCPS_IR_Publication.cpp.

References associations_, OpenDDS::DCPS::compatibleQOS(), ACE_Unbounded_Set_Ex< T, C >::find(), DCPS_IR_Subscription::get_datareader_qos(), get_datawriter_qos(), DCPS_IR_Subscription::get_incompatibleQosStatus(), get_incompatibleQosStatus(), get_publisher_qos(), DCPS_IR_Subscription::get_subscriber_qos(), DCPS_IR_Topic::get_topic_description(), DCPS_IR_Subscription::get_transportLocatorSeq(), get_transportLocatorSeq(), remove_associated_subscription(), status, topic_, and DCPS_IR_Topic_Description::try_associate().

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

{
  int status = this->associations_.find(subscription);

  if (status == 0) {
    // verify if they are still compatiable 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Publication::reevaluate_defunct_associations

(

)

Definition at line 665 of file DCPS_IR_Publication.cpp.

References ACE_TEXT(), ACE_Unbounded_Set_Ex< T, C >::begin(), defunct_, ACE_Unbounded_Set_Ex< T, C >::end(), DCPS_IR_Subscription::get_id(), id_, LM_ERROR, reevaluate_association(), and ACE_Unbounded_Set_Ex< T, C >::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));
    }
  }
}

Here is the call graph for this function:

void DCPS_IR_Publication::reevaluate_existing_associations

(

)

Definition at line 688 of file DCPS_IR_Publication.cpp.

References associations_, ACE_Unbounded_Set_Ex< T, C >::begin(), ACE_Unbounded_Set_Ex< T, C >::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);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

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 150 of file DCPS_IR_Publication.cpp.

References CORBA::Exception::_tao_print_exception(), 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, C >::remove(), DCPS_IR_Subscription::remove_associated_publication(), status, and writer_.

Referenced by DCPS_IR_Subscription::disassociate_participant(), disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), disassociate_subscription(), DCPS_IR_Subscription::disassociate_topic(), disassociate_topic(), reevaluate_association(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Subscription::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 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;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

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 225 of file DCPS_IR_Publication.cpp.

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

{
  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;
}

Here is the call graph for this function:

void DCPS_IR_Publication::set_bit_status

(

CORBA::Boolean

isBIT

)

Definition at line 653 of file DCPS_IR_Publication.cpp.

References isBIT_.

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

{
  isBIT_ = isBIT;
}

Here is the caller graph for this function:

void DCPS_IR_Publication::set_handle

(

DDS::InstanceHandle_t

handle

)

Definition at line 643 of file DCPS_IR_Publication.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_publication_bit().

{
  handle_ = handle;
}

Here is the caller graph for this function:

void DCPS_IR_Publication::set_qos

(

const DDS::PublisherQos &

qos

)

Update PublisherQos only.

Definition at line 529 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);
  }
}

Here is the call graph for this function:

void DCPS_IR_Publication::set_qos

(

const DDS::DataWriterQos &

qos

)

Update DataWriterQos only.

Definition at line 500 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);
  }
}

Here is the call graph for this function:

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 557 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 734 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();
  }
}

Here is the call graph for this function:

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 463 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();
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::DataWriterRemote_ptr DCPS_IR_Publication::writer

(

void

)

Definition at line 659 of file DCPS_IR_Publication.cpp.

References writer_.

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

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

Here is the caller graph for this function:

---

Member Data Documentation

DCPS_IR_Subscription_Set DCPS_IR_Publication::associations_ [private]

Definition at line 195 of file DCPS_IR_Publication.h.

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

DCPS_IR_Subscription_Set DCPS_IR_Publication::defunct_ [private]

Definition at line 196 of file DCPS_IR_Publication.h.

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

DDS::InstanceHandle_t DCPS_IR_Publication::handle_ [private]

Definition at line 186 of file DCPS_IR_Publication.h.

Referenced by get_handle(), and set_handle().

OpenDDS::DCPS::RepoId DCPS_IR_Publication::id_ [private]

Definition at line 183 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().

OpenDDS::DCPS::IncompatibleQosStatus DCPS_IR_Publication::incompatibleQosStatus_ [private]

Definition at line 198 of file DCPS_IR_Publication.h.

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

OpenDDS::DCPS::TransportLocatorSeq DCPS_IR_Publication::info_ [private]

Definition at line 192 of file DCPS_IR_Publication.h.

Referenced by get_transportLocatorSeq().

CORBA::Boolean DCPS_IR_Publication::isBIT_ [private]

Definition at line 187 of file DCPS_IR_Publication.h.

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

DCPS_IR_Participant* DCPS_IR_Publication::participant_ [private]

Definition at line 184 of file DCPS_IR_Publication.h.

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

DDS::PublisherQos DCPS_IR_Publication::publisherQos_ [private]

Definition at line 193 of file DCPS_IR_Publication.h.

Referenced by get_publisher_qos(), and set_qos().

DDS::DataWriterQos DCPS_IR_Publication::qos_ [private]

Definition at line 191 of file DCPS_IR_Publication.h.

Referenced by get_datawriter_qos(), and set_qos().

DCPS_IR_Topic* DCPS_IR_Publication::topic_ [private]

Definition at line 185 of file DCPS_IR_Publication.h.

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

OpenDDS::DCPS::DataWriterRemote_var DCPS_IR_Publication::writer_ [private]

the corresponding DataWriterRemote object

Definition at line 190 of file DCPS_IR_Publication.h.

Referenced by add_associated_subscription(), call_association_complete(), 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:

• DCPS_IR_Publication.h
• DCPS_IR_Publication.cpp