DCPS_IR_Participant Class Reference

Representative of the Domain Participant. More...

#include <DCPS_IR_Participant.h>

Collaboration diagram for DCPS_IR_Participant:

[legend]List of all members.

Public Types
	OWNER_NONE
enum	{ OWNER_NONE }
	Special owner to enforce no callbacks. More...
Public Member Functions
	DCPS_IR_Participant (const TAO_DDS_DCPSFederationId &federationId, OpenDDS::DCPS::RepoId id, DCPS_IR_Domain *domain, DDS::DomainParticipantQos qos, Update::Manager *um)
virtual	~DCPS_IR_Participant ()
void	takeOwnership ()
	Take local ownership of this participant and publish an update.
void	changeOwner (long sender, long owner)
	Process an incoming update that changes ownership.
long	owner () const
	Value of the owner for this participant.
bool	isOwner () const
	Indication of whether the current repository is the owner of this participant.
bool &	isBitPublisher ()
	Flag to discriminate the built-in topic publishing participant within a domain.
bool	isBitPublisher () const
int	add_publication (DCPS_IR_Publication *pub)
int	find_publication_reference (OpenDDS::DCPS::RepoId pubId, DCPS_IR_Publication *&pub)
	Return the publication object.
int	remove_publication (OpenDDS::DCPS::RepoId pubId)
int	add_subscription (DCPS_IR_Subscription *sub)
int	find_subscription_reference (OpenDDS::DCPS::RepoId subId, DCPS_IR_Subscription *&sub)
	Return the subscription object.
int	remove_subscription (OpenDDS::DCPS::RepoId subId)
int	add_topic_reference (DCPS_IR_Topic *topic)
int	remove_topic_reference (OpenDDS::DCPS::RepoId topicId, DCPS_IR_Topic *&topic)
int	find_topic_reference (OpenDDS::DCPS::RepoId topicId, DCPS_IR_Topic *&topic)
void	remove_all_dependents (CORBA::Boolean notify_lost)
	Removes all topics, publications and.
void	mark_dead ()
OpenDDS::DCPS::RepoId	get_id ()
CORBA::Boolean	is_alive ()
void	set_alive (CORBA::Boolean alive)
void	ignore_participant (OpenDDS::DCPS::RepoId id)
	Ignore the participant with the id.
void	ignore_topic (OpenDDS::DCPS::RepoId id)
	Ignore the topic with the id.
void	ignore_publication (OpenDDS::DCPS::RepoId id)
	Ignore the publication with the id.
void	ignore_subscription (OpenDDS::DCPS::RepoId id)
	Ignore the subscription with the id.
const DDS::DomainParticipantQos *	get_qos ()
bool	set_qos (const DDS::DomainParticipantQos &qos)
CORBA::Boolean	is_participant_ignored (OpenDDS::DCPS::RepoId id)
CORBA::Boolean	is_topic_ignored (OpenDDS::DCPS::RepoId id)
CORBA::Boolean	is_publication_ignored (OpenDDS::DCPS::RepoId id)
CORBA::Boolean	is_subscription_ignored (OpenDDS::DCPS::RepoId id)
DDS::InstanceHandle_t	get_handle ()
void	set_handle (DDS::InstanceHandle_t handle)
CORBA::Boolean	is_bit ()
void	set_bit_status (CORBA::Boolean isBIT)
DCPS_IR_Domain *	get_domain_reference () const
OpenDDS::DCPS::RepoId	get_next_topic_id ()
OpenDDS::DCPS::RepoId	get_next_publication_id ()
OpenDDS::DCPS::RepoId	get_next_subscription_id ()
void	last_topic_key (long key)
void	last_publication_key (long key)
void	last_subscription_key (long key)
const DCPS_IR_Publication_Map &	publications () const
	Expose a readable reference to the publication map.
const DCPS_IR_Subscription_Map &	subscriptions () const
	Expose a readable reference to the subscription map.
const DCPS_IR_Topic_Map &	topics () const
	Expose a readable reference to the topic map.
std::string	dump_to_string (const std::string &prefix, int depth) const
Private Attributes
OpenDDS::DCPS::RepoId	id_
DCPS_IR_Domain *	domain_
DDS::DomainParticipantQos	qos_
CORBA::Boolean	aliveStatus_
DDS::InstanceHandle_t	handle_
CORBA::Boolean	isBIT_
const TAO_DDS_DCPSFederationId &	federationId_
long	owner_
ACE_SYNCH_MUTEX	ownerLock_
	Lock portions ownership processing.
RepoIdGenerator	topicIdGenerator_
RepoIdGenerator	publicationIdGenerator_
RepoIdGenerator	subscriptionIdGenerator_
DCPS_IR_Subscription_Map	subscriptions_
DCPS_IR_Publication_Map	publications_
DCPS_IR_Topic_Map	topicRefs_
TAO_DDS_RepoId_Set	ignoredParticipants_
TAO_DDS_RepoId_Set	ignoredTopics_
TAO_DDS_RepoId_Set	ignoredPublications_
TAO_DDS_RepoId_Set	ignoredSubscriptions_
Update::Manager *	um_
bool	isBitPublisher_
	Flag indicating this participant publishes built-in topics.

---

Detailed Description

Representative of the Domain Participant.

Definition at line 56 of file DCPS_IR_Participant.h.

---

Member Enumeration Documentation

anonymous enum

Special owner to enforce no callbacks.

Enumerator:

OWNER_NONE

Definition at line 59 of file DCPS_IR_Participant.h.

{ OWNER_NONE};

---

Constructor & Destructor Documentation

DCPS_IR_Participant::DCPS_IR_Participant	(	const TAO_DDS_DCPSFederationId &	federationId,
		OpenDDS::DCPS::RepoId	id,
		DCPS_IR_Domain *	domain,
		DDS::DomainParticipantQos	qos,
		Update::Manager *	um
	)

Definition at line 24 of file DCPS_IR_Participant.cpp.

  : id_(id),
    domain_(domain),
    qos_(qos),
    aliveStatus_(1),
    handle_(0),
    isBIT_(0),
    federationId_(federationId),
    owner_(federationId.overridden() ? OWNER_NONE : federationId.id()),
    topicIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      OpenDDS::DCPS::KIND_TOPIC),
    publicationIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      OpenDDS::DCPS::KIND_WRITER),
    subscriptionIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      OpenDDS::DCPS::KIND_READER),
    um_(um),
    isBitPublisher_(false)
{
}

DCPS_IR_Participant::~DCPS_IR_Participant

(

)

[virtual]

Definition at line 54 of file DCPS_IR_Participant.cpp.

References id_, publications_, remove_publication(), remove_subscription(), subscriptions_, and topicRefs_.

{
  for (DCPS_IR_Subscription_Map::const_iterator current = this->subscriptions_.begin();
       current != this->subscriptions_.end();
       ++current) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter sub_converter(current->first);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::~DCPS_IR_Participant: ")
               ACE_TEXT("domain %d participant %C removing subscription %C.\n"),
               this->domain_->get_id(),
               std::string(part_converter).c_str(),
               std::string(sub_converter).c_str()));
    remove_subscription(current->first);
  }

  for (DCPS_IR_Publication_Map::const_iterator current = this->publications_.begin();
       current != this->publications_.end();
       ++current) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter pub_converter(current->first);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::~DCPS_IR_Participant: ")
               ACE_TEXT("domain %d participant %C removing publication %C.\n"),
               this->domain_->get_id(),
               std::string(part_converter).c_str(),
               std::string(pub_converter).c_str()));
    remove_publication(current->first);
  }

  for (DCPS_IR_Topic_Map::const_iterator current = this->topicRefs_.begin();
       current != this->topicRefs_.end();
       ++current) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter topic_converter(current->first);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::~DCPS_IR_Participant: ")
               ACE_TEXT("domain %d participant %C retained topic %C.\n"),
               this->domain_->get_id(),
               std::string(part_converter).c_str(),
               std::string(topic_converter).c_str()));
  }
}

---

Member Function Documentation

int DCPS_IR_Participant::add_publication

(

DCPS_IR_Publication *

pub

)

Add a publication This takes ownership of the memory pointed to by pub Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 188 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Publication::get_id(), id_, isBitPublisher_, publications_, and DCPS_IR_Publication::set_bit_status().

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

{
  OpenDDS::DCPS::RepoId pubId = pub->get_id();
  DCPS_IR_Publication_Map::iterator where = this->publications_.find(pubId);

  if (where == this->publications_.end()) {
    this->publications_.insert(
      where, DCPS_IR_Publication_Map::value_type(pubId, pub));

    if (isBitPublisher_) {
      pub->set_bit_status(isBitPublisher_);
    }

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::add_publication: ")
                 ACE_TEXT("participant %C successfully added publication %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str(),
                 pub));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_ERROR((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Participant::add_publication: ")
                 ACE_TEXT("participant %C attempted to add existing publication %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str()));
    }

    return 1;
  }
}

int DCPS_IR_Participant::add_subscription

(

DCPS_IR_Subscription *

sub

)

Add a subscription This takes ownership of the memory pointed to by aub Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 314 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Subscription::get_id(), id_, isBitPublisher_, DCPS_IR_Subscription::set_bit_status(), and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

{
  OpenDDS::DCPS::RepoId subId = sub->get_id();
  DCPS_IR_Subscription_Map::iterator where = this->subscriptions_.find(subId);

  if (where == this->subscriptions_.end()) {
    this->subscriptions_.insert(
      where, DCPS_IR_Subscription_Map::value_type(subId, sub));

    if (isBitPublisher_) {
      sub->set_bit_status(isBitPublisher_);
    }

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::add_subscription: ")
                 ACE_TEXT("participant %C successfully added subscription %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str(),
                 sub));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_ERROR((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Participant::add_subscription: ")
                 ACE_TEXT("participant %C attempted to add existing subscription %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }

    return 1;
  }
}

int DCPS_IR_Participant::add_topic_reference

(

DCPS_IR_Topic *

topic

)

Add a topic Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 440 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Topic::get_id(), id_, isBitPublisher_, DCPS_IR_Topic::set_bit_status(), and topicRefs_.

Referenced by DCPS_IR_Domain::add_topic_i().

{
  OpenDDS::DCPS::RepoId topicId = topic->get_id();
  DCPS_IR_Topic_Map::iterator where = this->topicRefs_.find(topicId);

  if (where == this->topicRefs_.end()) {
    this->topicRefs_.insert(
      where, DCPS_IR_Topic_Map::value_type(topicId, topic));

    if (isBitPublisher_) {
      topic->set_bit_status(isBitPublisher_);
    }

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::add_topic_reference: ")
                 ACE_TEXT("participant %C successfully added topic %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(topic_converter).c_str(),
                 topic));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Participant::add_topic_reference: ")
                 ACE_TEXT("participant %C attempted to add existing topic %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(topic_converter).c_str()));
    }

    return 1;
  }
}

void DCPS_IR_Participant::changeOwner	(	long	sender,
		long	owner
	)

Process an incoming update that changes ownership.

: Ensure that any stalled callbacks are made.

Definition at line 142 of file DCPS_IR_Participant.cpp.

References owner_, and OWNER_NONE.

Referenced by TAO_DDS_DCPSInfo_i::changeOwnership(), and takeOwnership().

{
  {
    ACE_GUARD(ACE_SYNCH_MUTEX, guard, this->ownerLock_);

    if ((owner == OWNER_NONE)
        && (this->isOwner() || (this->owner_ != sender))) {
      // Do not eliminate ownership if we are the owner or if the update
      // does not come from the current owner.
      return;
    }

    // Finally.  Change the value.
    this->owner_ = owner;

  } // End of lock scope.

  if (this->isOwner()) {
    /// @TODO: Ensure that any stalled callbacks are made.
  }
}

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

Definition at line 931 of file DCPS_IR_Participant.cpp.

References aliveStatus_, federationId_, TAO_DDS_DCPSFederationId::id(), id_, ignoredParticipants_, ignoredPublications_, ignoredSubscriptions_, ignoredTopics_, isBIT_, TAO_DDS_DCPSFederationId::overridden(), owner_, publications_, subscriptions_, and topicRefs_.

{
  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_Participant[";
  str += std::string(local_converter);
  str += "]";
  if (isBIT_)
    str += " (BIT)";
  std::ostringstream os;
  os << "federation id[" << federationId_.id();
  if (federationId_.overridden())
    os << "(federated)";

  os << "]  owner[" << owner_ << "]";
  str += os.str();
  str += aliveStatus_ ? " (alive)" : " (not alive)";
  str += "\n";

  str += indent + "Topics:\n";
  for (DCPS_IR_Topic_Map::const_iterator tm = topicRefs_.begin();
       tm != topicRefs_.end();
       tm++)
  {
    str += tm->second->dump_to_string(prefix, depth+1);
  }

  str += indent + "Publications:\n";
  for (DCPS_IR_Publication_Map::const_iterator pm = publications_.begin();
       pm != publications_.end();
       pm++)
  {
    str += pm->second->dump_to_string(prefix, depth+1);
  }

  str += indent + "Subscriptions:\n";
  for (DCPS_IR_Subscription_Map::const_iterator sm = subscriptions_.begin();
       sm != subscriptions_.end();
       sm++)
  {
    str += sm->second->dump_to_string(prefix, depth+1);
  }

  str += indent + "ignored Participants [ ";
  for (TAO_DDS_RepoId_Set::const_iterator ipart = ignoredParticipants_.begin();
       ipart != ignoredParticipants_.end();
       ipart++)
  {
    OpenDDS::DCPS::RepoIdConverter ipart_converter(*ipart);
    str += std::string(ipart_converter);
    str += " ";
  }
  str += "]\n";
  str += indent + "ignored Topics [ ";

  for (TAO_DDS_RepoId_Set::const_iterator itop = ignoredTopics_.begin();
       itop != ignoredTopics_.end();
       itop++)
  {
    OpenDDS::DCPS::RepoIdConverter itop_converter(*itop);
    str += std::string(itop_converter);
    str += " ";
  }
  str += "]\n";
  str += indent + "ignored Publications [ ";

  for (TAO_DDS_RepoId_Set::const_iterator ipub = ignoredPublications_.begin();
       ipub != ignoredPublications_.end();
       ipub++)
  {
    OpenDDS::DCPS::RepoIdConverter ipub_converter(*ipub);
    str += std::string(ipub_converter);
    str += " ";
  }
  str += "]\n";
  str += indent + "ignored Subscriptions [ ";

  for (TAO_DDS_RepoId_Set::const_iterator isub = ignoredSubscriptions_.begin();
       isub != ignoredSubscriptions_.end();
       isub++)
  {
    OpenDDS::DCPS::RepoIdConverter isub_converter(*isub);
    str += std::string(isub_converter);
    str += " ";
  }
  str += "]\n";

#endif // !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
  return str;
}

int DCPS_IR_Participant::find_publication_reference	(	OpenDDS::DCPS::RepoId	pubId,
		DCPS_IR_Publication *&	pub
	)

Return the publication object.

Definition at line 229 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, and publications_.

Referenced by TAO_DDS_DCPSInfo_i::association_complete(), TAO_DDS_DCPSInfo_i::disassociate_publication(), and TAO_DDS_DCPSInfo_i::update_publication_qos().

{
  DCPS_IR_Publication_Map::iterator where = this->publications_.find(pubId);

  if (where != this->publications_.end()) {
    pub = where->second;

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_publication_reference: ")
                 ACE_TEXT("participant %C found publication %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str(),
                 pub));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_publication_reference: ")
                 ACE_TEXT("participant %C could not find publication %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str()));
    }
    pub = 0;
    return -1;
  }
}

int DCPS_IR_Participant::find_subscription_reference	(	OpenDDS::DCPS::RepoId	subId,
		DCPS_IR_Subscription *&	sub
	)

Return the subscription object.

Definition at line 355 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::association_complete(), TAO_DDS_DCPSInfo_i::disassociate_subscription(), TAO_DDS_DCPSInfo_i::update_subscription_params(), and TAO_DDS_DCPSInfo_i::update_subscription_qos().

{
  DCPS_IR_Subscription_Map::iterator where = this->subscriptions_.find(subId);

  if (where != this->subscriptions_.end()) {
    sub = where->second;

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_subscription_reference: ")
                 ACE_TEXT("participant %C found subscription %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str(),
                 sub));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_subscription_reference: ")
                 ACE_TEXT("participant %C could not find subscription %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }
    sub = 0;
    return -1;
  }
}

int DCPS_IR_Participant::find_topic_reference	(	OpenDDS::DCPS::RepoId	topicId,
		DCPS_IR_Topic *&	topic
	)

Find topic reference with id Does NOT give ownership of memory Returns 0 if successful

Definition at line 518 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, and topicRefs_.

Referenced by TAO_DDS_DCPSInfo_i::remove_topic(), and TAO_DDS_DCPSInfo_i::update_topic_qos().

{
  DCPS_IR_Topic_Map::iterator where = this->topicRefs_.find(topicId);

  if (where != this->topicRefs_.end()) {
    topic = where->second;

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::find_topic_reference: ")
                 ACE_TEXT("participant %C found topic %C at %x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(topic_converter).c_str(),
                 topic));
    }

    return 0;

  } else {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::find_topic_reference: ")
               ACE_TEXT("participant %C unable to find topic %C.\n"),
               std::string(part_converter).c_str(),
               std::string(topic_converter).c_str()));
    topic = 0;
    return -1;
  }
}

DCPS_IR_Domain * DCPS_IR_Participant::get_domain_reference

(

)

const

Definition at line 889 of file DCPS_IR_Participant.cpp.

References domain_.

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

{
  return domain_;
}

DDS::InstanceHandle_t DCPS_IR_Participant::get_handle

(

)

Definition at line 850 of file DCPS_IR_Participant.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_participant_bit().

{
  return handle_;
}

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_id

(

)

Definition at line 713 of file DCPS_IR_Participant.cpp.

References id_.

Referenced by DCPS_IR_Domain::add_participant(), DCPS_IR_Domain::dispose_participant_bit(), DCPS_IR_Topic::get_participant_id(), DCPS_IR_Subscription::get_participant_id(), DCPS_IR_Publication::get_participant_id(), DCPS_IR_Domain::publish_participant_bit(), remove_all_dependents(), and DCPS_IR_Domain::remove_topic().

{
  return id_;
}

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_next_publication_id

(

)

Definition at line 901 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::next(), and publicationIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

{
  return this->publicationIdGenerator_.next();
}

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_next_subscription_id

(

)

Definition at line 907 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::next(), and subscriptionIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

{
  return this->subscriptionIdGenerator_.next();
}

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_next_topic_id

(

)

Definition at line 895 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::next(), and topicIdGenerator_.

Referenced by DCPS_IR_Domain::add_topic().

{
  return this->topicIdGenerator_.next();
}

const DDS::DomainParticipantQos * DCPS_IR_Participant::get_qos

(

)

Return pointer to the participant qos Participant retains ownership

Definition at line 860 of file DCPS_IR_Participant.cpp.

References qos_.

Referenced by DCPS_IR_Domain::publish_participant_bit().

{
  return &qos_;
}

void DCPS_IR_Participant::ignore_participant

(

OpenDDS::DCPS::RepoId

id

)

Ignore the participant with the id.

Definition at line 728 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, ignoredParticipants_, publications_, and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::ignore_domain_participant().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter ignore_converter(id);
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Participant::ignore_participant: ")
               ACE_TEXT("participant %C now ignoring participant %C.\n"),
               std::string(part_converter).c_str(),
               std::string(ignore_converter).c_str()));
  }

  ignoredParticipants_.insert(id);

  // disassociate any publications
  for (DCPS_IR_Publication_Map::const_iterator current = this->publications_.begin();
       current != this->publications_.end();
       ++current) {
    current->second->disassociate_participant(id);
  }

  // disassociate any subscriptions
  for (DCPS_IR_Subscription_Map::const_iterator current = this->subscriptions_.begin();
       current != this->subscriptions_.end();
       ++current) {
    current->second->disassociate_participant(id);
  }
}

void DCPS_IR_Participant::ignore_publication

(

OpenDDS::DCPS::RepoId

id

)

Ignore the publication with the id.

Definition at line 786 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, ignoredPublications_, and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::ignore_publication().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter ignore_converter(id);
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Participant::ignore_publication: ")
               ACE_TEXT("participant %C now ignoring publication %C.\n"),
               std::string(part_converter).c_str(),
               std::string(ignore_converter).c_str()));
  }

  ignoredPublications_.insert(id);

  // disassociate any subscriptions
  for (DCPS_IR_Subscription_Map::const_iterator current = this->subscriptions_.begin();
       current != this->subscriptions_.end();
       ++current) {
    current->second->disassociate_publication(id);
  }
}

void DCPS_IR_Participant::ignore_subscription

(

OpenDDS::DCPS::RepoId

id

)

Ignore the subscription with the id.

Definition at line 808 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, ignoredSubscriptions_, and publications_.

Referenced by TAO_DDS_DCPSInfo_i::ignore_subscription().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter ignore_converter(id);
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Participant::ignore_subscription: ")
               ACE_TEXT("participant %C now ignoring subscription %C.\n"),
               std::string(part_converter).c_str(),
               std::string(ignore_converter).c_str()));
  }

  ignoredSubscriptions_.insert(id);

  // disassociate any publications
  for (DCPS_IR_Publication_Map::const_iterator current = this->publications_.begin();
       current != this->publications_.end();
       ++current) {
    current->second->disassociate_subscription(id);
  }
}

void DCPS_IR_Participant::ignore_topic

(

OpenDDS::DCPS::RepoId

id

)

Ignore the topic with the id.

Definition at line 757 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, ignoredTopics_, publications_, and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::ignore_topic().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter ignore_converter(id);
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Participant::ignore_topic: ")
               ACE_TEXT("participant %C now ignoring topic %C.\n"),
               std::string(part_converter).c_str(),
               std::string(ignore_converter).c_str()));
  }

  ignoredTopics_.insert(id);

  // disassociate any publications
  for (DCPS_IR_Publication_Map::const_iterator current = this->publications_.begin();
       current != this->publications_.end();
       ++current) {
    current->second->disassociate_topic(id);
  }

  // disassociate any subscriptions
  for (DCPS_IR_Subscription_Map::const_iterator current = this->subscriptions_.begin();
       current != this->subscriptions_.end();
       ++current) {
    current->second->disassociate_topic(id);
  }
}

CORBA::Boolean DCPS_IR_Participant::is_alive

(

)

Definition at line 718 of file DCPS_IR_Participant.cpp.

References aliveStatus_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Subscription::disassociate_topic(), DCPS_IR_Publication::disassociate_topic(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), DCPS_IR_Subscription::update_incompatible_qos(), and DCPS_IR_Publication::update_incompatible_qos().

{
  return aliveStatus_;
}

CORBA::Boolean DCPS_IR_Participant::is_bit

(

)

Definition at line 879 of file DCPS_IR_Participant.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::dispose_participant_bit(), and DCPS_IR_Domain::publish_participant_bit().

{
  return isBIT_;
}

CORBA::Boolean DCPS_IR_Participant::is_participant_ignored

(

OpenDDS::DCPS::RepoId

id

)

Definition at line 830 of file DCPS_IR_Participant.cpp.

References ignoredParticipants_.

Referenced by DCPS_IR_Subscription::is_publication_ignored(), DCPS_IR_Publication::is_subscription_ignored(), and DCPS_IR_Topic::try_associate().

{
  return (0 == ignoredParticipants_.find(id));
}

CORBA::Boolean DCPS_IR_Participant::is_publication_ignored

(

OpenDDS::DCPS::RepoId

id

)

Definition at line 840 of file DCPS_IR_Participant.cpp.

References ignoredPublications_.

Referenced by DCPS_IR_Subscription::is_publication_ignored().

{
  return (0 == ignoredPublications_.find(id));
}

CORBA::Boolean DCPS_IR_Participant::is_subscription_ignored

(

OpenDDS::DCPS::RepoId

id

)

Definition at line 845 of file DCPS_IR_Participant.cpp.

References ignoredSubscriptions_.

Referenced by DCPS_IR_Publication::is_subscription_ignored(), and DCPS_IR_Topic::try_associate().

{
  return (0 == ignoredSubscriptions_.find(id));
}

CORBA::Boolean DCPS_IR_Participant::is_topic_ignored

(

OpenDDS::DCPS::RepoId

id

)

Definition at line 835 of file DCPS_IR_Participant.cpp.

References ignoredTopics_.

Referenced by DCPS_IR_Subscription::is_publication_ignored(), DCPS_IR_Publication::is_subscription_ignored(), and DCPS_IR_Topic::try_associate().

{
  return (0 == ignoredTopics_.find(id));
}

bool DCPS_IR_Participant::isBitPublisher

(

)

const

Definition at line 183 of file DCPS_IR_Participant.cpp.

References isBitPublisher_.

{
  return this->isBitPublisher_;
}

bool & DCPS_IR_Participant::isBitPublisher

(

)

Flag to discriminate the built-in topic publishing participant within a domain.

Definition at line 177 of file DCPS_IR_Participant.cpp.

References isBitPublisher_.

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant(), TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::add_subscription(), TAO_DDS_DCPSInfo_i::assert_topic(), TAO_DDS_DCPSInfo_i::remove_domain_participant(), TAO_DDS_DCPSInfo_i::remove_publication(), TAO_DDS_DCPSInfo_i::remove_subscription(), TAO_DDS_DCPSInfo_i::remove_topic(), TAO_DDS_DCPSInfo_i::update_domain_participant_qos(), TAO_DDS_DCPSInfo_i::update_publication_qos(), TAO_DDS_DCPSInfo_i::update_subscription_params(), TAO_DDS_DCPSInfo_i::update_subscription_qos(), and TAO_DDS_DCPSInfo_i::update_topic_qos().

{
  return this->isBitPublisher_;
}

bool DCPS_IR_Participant::isOwner

(

)

const

Indication of whether the current repository is the owner of this participant.

Definition at line 171 of file DCPS_IR_Participant.cpp.

References federationId_, TAO_DDS_DCPSFederationId::id(), and owner_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Subscription::disassociate_topic(), DCPS_IR_Publication::disassociate_topic(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), TAO_DDS_DCPSInfo_i::remove_domain_participant(), TAO_DDS_DCPSInfo_i::remove_publication(), TAO_DDS_DCPSInfo_i::remove_subscription(), TAO_DDS_DCPSInfo_i::remove_topic(), TAO_DDS_DCPSInfo_i::update_domain_participant_qos(), DCPS_IR_Subscription::update_incompatible_qos(), DCPS_IR_Publication::update_incompatible_qos(), and TAO_DDS_DCPSInfo_i::update_topic_qos().

{
  return this->owner_ == this->federationId_.id();
}

void DCPS_IR_Participant::last_publication_key

(

long

key

)

Definition at line 919 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::last(), and publicationIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

{
  return this->publicationIdGenerator_.last(key);
}

void DCPS_IR_Participant::last_subscription_key

(

long

key

)

Definition at line 925 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::last(), and subscriptionIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

{
  return this->subscriptionIdGenerator_.last(key);
}

void DCPS_IR_Participant::last_topic_key

(

long

key

)

Definition at line 913 of file DCPS_IR_Participant.cpp.

References RepoIdGenerator::last(), and topicIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_topic().

{
  return this->topicIdGenerator_.last(key);
}

void DCPS_IR_Participant::mark_dead

(

)

Changes aliveStatus to false then adds itself to the domain's list of dead participants for removal

Definition at line 707 of file DCPS_IR_Participant.cpp.

References DCPS_IR_Domain::add_dead_participant(), aliveStatus_, and domain_.

Referenced by DCPS_IR_Subscription::add_associated_publication(), DCPS_IR_Publication::add_associated_subscription(), DCPS_IR_Subscription::call_association_complete(), DCPS_IR_Publication::call_association_complete(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Subscription::disassociate_topic(), DCPS_IR_Publication::disassociate_topic(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), DCPS_IR_Publication::update_expr_params(), DCPS_IR_Subscription::update_incompatible_qos(), and DCPS_IR_Publication::update_incompatible_qos().

{
  aliveStatus_ = 0;
  domain_->add_dead_participant(this);
}

long DCPS_IR_Participant::owner

(

)

const

Value of the owner for this participant.

Definition at line 165 of file DCPS_IR_Participant.cpp.

References owner_.

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant().

{
  return this->owner_;
}

const DCPS_IR_Publication_Map & DCPS_IR_Participant::publications

(

)

const

Expose a readable reference to the publication map.

Definition at line 99 of file DCPS_IR_Participant.cpp.

References publications_.

Referenced by TAO_DDS_DCPSInfo_i::disassociate_participant().

{
  return this->publications_;
}

void DCPS_IR_Participant::remove_all_dependents

(

CORBA::Boolean

notify_lost

)

Removes all topics, publications and.

Definition at line 552 of file DCPS_IR_Participant.cpp.

References Update::Actor, Update::DataReader, Update::DataWriter, OpenDDS::DCPS::DCPS_debug_level, Update::Manager::destroy(), domain_, get_id(), id_, publications_, DCPS_IR_Topic::release(), DCPS_IR_Topic::remove_publication_reference(), DCPS_IR_Topic::remove_subscription_reference(), DCPS_IR_Domain::remove_topic(), subscriptions_, Update::Topic, topicRefs_, and um_.

Referenced by DCPS_IR_Domain::remove_participant().

{
  // remove all the publications associations
  {
    DCPS_IR_Publication_Map::const_iterator next = this->publications_.begin();

    while (next != this->publications_.end()) {
      DCPS_IR_Publication_Map::const_iterator current = next;
      ++ next;
      DCPS_IR_Topic* topic = current->second->get_topic();
      topic->remove_publication_reference(current->second);

      if (0 != current->second->remove_associations(notify_lost)) {
        return;
      }

      topic->release(false);
    }
  }

  {
    DCPS_IR_Subscription_Map::const_iterator next = this->subscriptions_.begin();

    while (next != this->subscriptions_.end()) {
      DCPS_IR_Subscription_Map::const_iterator current = next;
      ++ next;
      DCPS_IR_Topic* topic = current->second->get_topic();
      topic->remove_subscription_reference(current->second);

      if (0 != current->second->remove_associations(notify_lost)) {
        return;
      }

      topic->release(false);
    }
  }

  {
    DCPS_IR_Topic_Map::const_iterator next = this->topicRefs_.begin();

    while (next != this->topicRefs_.end()) {
      DCPS_IR_Topic_Map::const_iterator current = next;
      ++ next;

      // Notify the federation to remove the topic.
      if (this->um_ && (this->isBitPublisher() == false)) {
        Update::IdPath path(
          this->domain_->get_id(),
          this->get_id(),
          current->second->get_id());
        this->um_->destroy(path, Update::Topic);

        if (OpenDDS::DCPS::DCPS_debug_level > 4) {
          OpenDDS::DCPS::RepoId id = current->second->get_id();
          OpenDDS::DCPS::RepoIdConverter converter(id);
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_all_dependents: ")
                     ACE_TEXT("pushing deletion of topic %C in domain %d.\n"),
                     std::string(converter).c_str(),
                     this->domain_->get_id()));
        }

        // Remove the topic ourselves.
        // N.B. This call sets the second (reference) argument to 0, so when
        //      clear() is called below, no destructor is (re)called.

        // Get the topic id and topic point before remove_topic since it
        // invalidates the iterator. Accessing after removal got SEGV.
        OpenDDS::DCPS::RepoId id = current->first;
        DCPS_IR_Topic* topic = current->second;

        this->domain_->remove_topic(this, topic);

        if (OpenDDS::DCPS::DCPS_debug_level > 9) {
          OpenDDS::DCPS::RepoIdConverter part_converter(id_);
          OpenDDS::DCPS::RepoIdConverter topic_converter(id);
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_all_dependents: ")
                     ACE_TEXT("domain %d participant %C removed topic %C.\n"),
                     this->domain_->get_id(),
                     std::string(part_converter).c_str(),
                     std::string(topic_converter).c_str()));
        }
      }
    }
  }

  // Clear the Topic container of null pointers.
  this->topicRefs_.clear();

  // The publications and subscriptions can NOT be deleted until after all
  // the associations have been removed.  Otherwise an access violation
  // can occur because a publication and subscription of this participant
  // could be associated.

  // delete all the publications
  for (DCPS_IR_Publication_Map::const_iterator current = this->publications_.begin();
       current != this->publications_.end();
       ++current) {
    // Notify the federation to destroy the publication.
    if (this->um_ && (this->isBitPublisher() == false)) {
      Update::IdPath path(
        this->domain_->get_id(),
        this->get_id(),
        current->second->get_id());
      this->um_->destroy(path, Update::Actor, Update::DataWriter);

      if (OpenDDS::DCPS::DCPS_debug_level > 4) {
        OpenDDS::DCPS::RepoId id = current->second->get_id();
        OpenDDS::DCPS::RepoIdConverter converter(id);
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_all_dependents: ")
                   ACE_TEXT("pushing deletion of publication %C in domain %d.\n"),
                   std::string(converter).c_str(),
                   this->domain_->get_id()));
      }
    }
    // delete the publication
    delete current->second;
  }

  // Clear the container.
  this->publications_.clear();

  // delete all the subscriptions
  for (DCPS_IR_Subscription_Map::const_iterator current
       = this->subscriptions_.begin();
       current != this->subscriptions_.end();
       ++current) {
    // Notify the federation to destroy the subscription.
    if (this->um_ && (this->isBitPublisher() == false)) {
      Update::IdPath path(
        this->domain_->get_id(),
        this->get_id(),
        current->second->get_id());
      this->um_->destroy(path, Update::Actor, Update::DataReader);

      if (OpenDDS::DCPS::DCPS_debug_level > 4) {
        OpenDDS::DCPS::RepoId id = current->second->get_id();
        OpenDDS::DCPS::RepoIdConverter converter(id);
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_all_dependents: ")
                   ACE_TEXT("pushing deletion of subscription %C in domain %d.\n"),
                   std::string(converter).c_str(),
                   this->domain_->get_id()));
      }
    }
    // delete the subscription
    delete current->second;
  }

  // Clear the container.
  this->subscriptions_.clear();
}

int DCPS_IR_Participant::remove_publication

(

OpenDDS::DCPS::RepoId

pubId

)

Removes the publication with the id Deletes the publication object if returns successful Returns 0 if successful

Definition at line 265 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Domain::dispose_publication_bit(), domain_, id_, and publications_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::remove_publication(), and ~DCPS_IR_Participant().

{
  DCPS_IR_Publication_Map::iterator where = this->publications_.find(pubId);

  if (where != this->publications_.end()) {
    DCPS_IR_Topic* topic = where->second->get_topic();
    topic->remove_publication_reference(where->second);

    if (0 != where->second->remove_associations(false)) {
      // N.B. As written today, this branch will never be taken.
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::remove_publication: ")
                 ACE_TEXT("participant %C unable to remove associations from publication %C\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str()));
      return -1;
    }

    this->domain_->dispose_publication_bit(where->second);
    delete where->second;
    topic->release(false);
    this->publications_.erase(where);

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_publication: ")
                 ACE_TEXT("participant %C removed publication %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(pub_converter).c_str()));
    }

    return 0;

  } else {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter pub_converter(pubId);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::remove_publication: ")
               ACE_TEXT("participant %C unable to remove publication %C.\n"),
               std::string(part_converter).c_str(),
               std::string(pub_converter).c_str()));
    return -1;
  }
}

int DCPS_IR_Participant::remove_subscription

(

OpenDDS::DCPS::RepoId

subId

)

Removes the subscription with the id Deletes the subscription object if returns successful Returns 0 if successful

Definition at line 391 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Domain::dispose_subscription_bit(), domain_, id_, and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription(), TAO_DDS_DCPSInfo_i::remove_subscription(), and ~DCPS_IR_Participant().

{
  DCPS_IR_Subscription_Map::iterator where = this->subscriptions_.find(subId);

  if (where != this->subscriptions_.end()) {
    DCPS_IR_Topic* topic = where->second->get_topic();
    topic->remove_subscription_reference(where->second);

    if (0 != where->second->remove_associations(false)) {
      // N.B. As written today, this branch will never be taken.
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::remove_subscription: ")
                 ACE_TEXT("participant %C unable to remove associations from subscription %C\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str()));
      return -1;
    }

    this->domain_->dispose_subscription_bit(where->second);
    delete where->second;
    topic->release(false);
    this->subscriptions_.erase(where);

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_subscription: ")
                 ACE_TEXT("participant %C removed subscription %C.\n"),
                 std::string(part_converter).c_str(),
                 std::string(sub_converter).c_str()));
    }

    return 0;

  } else {
    OpenDDS::DCPS::RepoIdConverter part_converter(id_);
    OpenDDS::DCPS::RepoIdConverter sub_converter(subId);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Participant::remove_subscription: ")
               ACE_TEXT("participant %C unable to remove subscription %C.\n"),
               std::string(part_converter).c_str(),
               std::string(sub_converter).c_str()));
    return -1;
  }
}

int DCPS_IR_Participant::remove_topic_reference	(	OpenDDS::DCPS::RepoId	topicId,
		DCPS_IR_Topic *&	topic
	)

Remove a topic reference Does not change or take ownership of topic Returns 0 if successful

Definition at line 481 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::DCPS_debug_level, id_, and topicRefs_.

Referenced by DCPS_IR_Domain::remove_topic().

{
  DCPS_IR_Topic_Map::iterator where = this->topicRefs_.find(topicId);

  if (where != this->topicRefs_.end()) {
    topic = where->second;
    this->topicRefs_.erase(where);

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::remove_topic_reference: ")
                 ACE_TEXT("participant %C removed topic %C at 0x%x.\n"),
                 std::string(part_converter).c_str(),
                 std::string(topic_converter).c_str(),
                 topic));
    }

    return 0;

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter part_converter(id_);
      OpenDDS::DCPS::RepoIdConverter topic_converter(topicId);
      ACE_ERROR((LM_WARNING,
                 ACE_TEXT("(%P|%t) WARNING: DCPS_IR_Participant::remove_topic_reference: ")
                 ACE_TEXT("participant %C unable to find topic %C for removal.\n"),
                 std::string(part_converter).c_str(),
                 std::string(topic_converter).c_str()));
    }

    return -1;
  }
}

void DCPS_IR_Participant::set_alive

(

CORBA::Boolean

alive

)

Definition at line 723 of file DCPS_IR_Participant.cpp.

References aliveStatus_.

{
  aliveStatus_ = alive;
}

void DCPS_IR_Participant::set_bit_status

(

CORBA::Boolean

isBIT

)

Definition at line 884 of file DCPS_IR_Participant.cpp.

References isBIT_.

Referenced by DCPS_IR_Domain::publish_participant_bit().

{
  isBIT_ = isBIT;
}

void DCPS_IR_Participant::set_handle

(

DDS::InstanceHandle_t

handle

)

Definition at line 855 of file DCPS_IR_Participant.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_participant_bit().

{
  handle_ = handle;
}

bool DCPS_IR_Participant::set_qos

(

const DDS::DomainParticipantQos &

qos

)

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

Definition at line 865 of file DCPS_IR_Participant.cpp.

References domain_, DCPS_IR_Domain::publish_participant_bit(), and qos_.

Referenced by TAO_DDS_DCPSInfo_i::update_domain_participant_qos().

{
  // Do not need re-evaluate compatibility and associations when
  // DomainParticipantQos changes since only datareader and datawriter
  // QoS are evaludated during normal associations establishment.

  // Do not need publish the QoS change to topics or datareader or
  // datawriter BIT as they are independent.
  qos_ = qos;
  this->domain_->publish_participant_bit(this);

  return true;
}

const DCPS_IR_Subscription_Map & DCPS_IR_Participant::subscriptions

(

)

const

Expose a readable reference to the subscription map.

Definition at line 105 of file DCPS_IR_Participant.cpp.

References subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::disassociate_participant().

{
  return this->subscriptions_;
}

void DCPS_IR_Participant::takeOwnership

(

)

Take local ownership of this participant and publish an update.

Publish an update with our ownership.

Definition at line 117 of file DCPS_IR_Participant.cpp.

References changeOwner(), Update::Manager::create(), OpenDDS::DCPS::DCPS_debug_level, federationId_, TAO_DDS_DCPSFederationId::id(), id_, and um_.

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant(), and TAO_DDS_DCPSInfo_i::attach_participant().

{
  /// Publish an update with our ownership.
  if (this->um_ && (this->isBitPublisher() == false)) {
    this->um_->create(
      Update::OwnershipData(
        this->domain_->get_id(),
        this->id_,
        this->federationId_.id()));

    if (OpenDDS::DCPS::DCPS_debug_level > 4) {
      OpenDDS::DCPS::RepoIdConverter converter(id_);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Participant::take_ownership: ")
                 ACE_TEXT("pushing ownership %C in domain %d.\n"),
                 std::string(converter).c_str(),
                 this->domain_->get_id()));
    }
  }

  // And now handle our internal ownership processing.
  this->changeOwner(this->federationId_.id(), this->federationId_.id());
}

const DCPS_IR_Topic_Map & DCPS_IR_Participant::topics

(

)

const

Expose a readable reference to the topic map.

Definition at line 111 of file DCPS_IR_Participant.cpp.

References topicRefs_.

{
  return this->topicRefs_;
}

---

Member Data Documentation

CORBA::Boolean DCPS_IR_Participant::aliveStatus_ [private]

Definition at line 203 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), is_alive(), mark_dead(), and set_alive().

DCPS_IR_Domain* DCPS_IR_Participant::domain_ [private]

Definition at line 201 of file DCPS_IR_Participant.h.

Referenced by get_domain_reference(), mark_dead(), remove_all_dependents(), remove_publication(), remove_subscription(), and set_qos().

const TAO_DDS_DCPSFederationId& DCPS_IR_Participant::federationId_ [private]

Definition at line 207 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), isOwner(), and takeOwnership().

DDS::InstanceHandle_t DCPS_IR_Participant::handle_ [private]

Definition at line 204 of file DCPS_IR_Participant.h.

Referenced by get_handle(), and set_handle().

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

Definition at line 200 of file DCPS_IR_Participant.h.

Referenced by add_publication(), add_subscription(), add_topic_reference(), dump_to_string(), find_publication_reference(), find_subscription_reference(), find_topic_reference(), get_id(), ignore_participant(), ignore_publication(), ignore_subscription(), ignore_topic(), remove_all_dependents(), remove_publication(), remove_subscription(), remove_topic_reference(), takeOwnership(), and ~DCPS_IR_Participant().

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredParticipants_ [private]

Definition at line 223 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), ignore_participant(), and is_participant_ignored().

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredPublications_ [private]

Definition at line 225 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), ignore_publication(), and is_publication_ignored().

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredSubscriptions_ [private]

Definition at line 226 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), ignore_subscription(), and is_subscription_ignored().

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredTopics_ [private]

Definition at line 224 of file DCPS_IR_Participant.h.

Referenced by dump_to_string(), ignore_topic(), and is_topic_ignored().

CORBA::Boolean DCPS_IR_Participant::isBIT_ [private]

Definition at line 205 of file DCPS_IR_Participant.h.

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

bool DCPS_IR_Participant::isBitPublisher_ [private]

Flag indicating this participant publishes built-in topics.

Definition at line 236 of file DCPS_IR_Participant.h.

Referenced by add_publication(), add_subscription(), add_topic_reference(), and isBitPublisher().

long DCPS_IR_Participant::owner_ [private]

Definition at line 208 of file DCPS_IR_Participant.h.

Referenced by changeOwner(), dump_to_string(), isOwner(), and owner().

ACE_SYNCH_MUTEX DCPS_IR_Participant::ownerLock_ [private]

Lock portions ownership processing.

Definition at line 211 of file DCPS_IR_Participant.h.

RepoIdGenerator DCPS_IR_Participant::publicationIdGenerator_ [private]

Definition at line 215 of file DCPS_IR_Participant.h.

Referenced by get_next_publication_id(), and last_publication_key().

DCPS_IR_Publication_Map DCPS_IR_Participant::publications_ [private]

Definition at line 219 of file DCPS_IR_Participant.h.

Referenced by add_publication(), dump_to_string(), find_publication_reference(), ignore_participant(), ignore_subscription(), ignore_topic(), publications(), remove_all_dependents(), remove_publication(), and ~DCPS_IR_Participant().

DDS::DomainParticipantQos DCPS_IR_Participant::qos_ [private]

Definition at line 202 of file DCPS_IR_Participant.h.

Referenced by get_qos(), and set_qos().

RepoIdGenerator DCPS_IR_Participant::subscriptionIdGenerator_ [private]

Definition at line 216 of file DCPS_IR_Participant.h.

Referenced by get_next_subscription_id(), and last_subscription_key().

DCPS_IR_Subscription_Map DCPS_IR_Participant::subscriptions_ [private]

Definition at line 218 of file DCPS_IR_Participant.h.

Referenced by add_subscription(), dump_to_string(), find_subscription_reference(), ignore_participant(), ignore_publication(), ignore_topic(), remove_all_dependents(), remove_subscription(), subscriptions(), and ~DCPS_IR_Participant().

RepoIdGenerator DCPS_IR_Participant::topicIdGenerator_ [private]

Definition at line 214 of file DCPS_IR_Participant.h.

Referenced by get_next_topic_id(), and last_topic_key().

DCPS_IR_Topic_Map DCPS_IR_Participant::topicRefs_ [private]

Definition at line 220 of file DCPS_IR_Participant.h.

Referenced by add_topic_reference(), dump_to_string(), find_topic_reference(), remove_all_dependents(), remove_topic_reference(), topics(), and ~DCPS_IR_Participant().

Update::Manager* DCPS_IR_Participant::um_ [private]

Definition at line 233 of file DCPS_IR_Participant.h.

Referenced by remove_all_dependents(), and takeOwnership().

---

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

• DCPS_IR_Participant.h
• DCPS_IR_Participant.cpp

---