DCPS_IR_Participant Class Reference

Representative of the Domain Participant. More...

#include <DCPS_IR_Participant.h>

Inheritance diagram for DCPS_IR_Participant:

Collaboration diagram for DCPS_IR_Participant:

Public Types
enum	{ OWNER_NONE }
	Special owner to enforce no callbacks. More...

Public Member Functions
	DCPS_IR_Participant (const TAO_DDS_DCPSFederationId &federationId, OpenDDS::DCPS::GUID_t id, DCPS_IR_Domain *domain, DDS::DomainParticipantQos qos, Update::Manager *um, bool isBit)
virtual	~DCPS_IR_Participant ()
void	takeOwnership ()
	Take local ownership of this participant and publish an update. More...
void	changeOwner (long sender, long owner)
	Process an incoming update that changes ownership. More...
long	owner () const
	Value of the owner for this participant. More...
bool	isOwner () const
	Indication of whether the current repository is the owner of this participant. More...
int	add_publication (OpenDDS::DCPS::unique_ptr< DCPS_IR_Publication > pub)
int	find_publication_reference (OpenDDS::DCPS::GUID_t pubId, DCPS_IR_Publication *&pub)
	Return the publication object. More...
int	remove_publication (OpenDDS::DCPS::GUID_t pubId)
int	add_subscription (OpenDDS::DCPS::unique_ptr< DCPS_IR_Subscription > sub)
int	find_subscription_reference (OpenDDS::DCPS::GUID_t subId, DCPS_IR_Subscription *&sub)
	Return the subscription object. More...
int	remove_subscription (OpenDDS::DCPS::GUID_t subId)
int	add_topic_reference (DCPS_IR_Topic *topic)
int	remove_topic_reference (OpenDDS::DCPS::GUID_t topicId, DCPS_IR_Topic *&topic)
int	find_topic_reference (OpenDDS::DCPS::GUID_t topicId, DCPS_IR_Topic *&topic)
void	remove_all_dependents (CORBA::Boolean notify_lost)
	Removes all topics, publications and. More...
void	mark_dead ()
OpenDDS::DCPS::GUID_t	get_id ()
CORBA::Boolean	is_alive ()
void	set_alive (CORBA::Boolean alive)
void	ignore_participant (OpenDDS::DCPS::GUID_t id)
	Ignore the participant with the id. More...
void	ignore_topic (OpenDDS::DCPS::GUID_t id)
	Ignore the topic with the id. More...
void	ignore_publication (OpenDDS::DCPS::GUID_t id)
	Ignore the publication with the id. More...
void	ignore_subscription (OpenDDS::DCPS::GUID_t id)
	Ignore the subscription with the id. More...
const DDS::DomainParticipantQos *	get_qos ()
bool	set_qos (const DDS::DomainParticipantQos &qos)
DDS::InstanceHandle_t	get_handle ()
void	set_handle (DDS::InstanceHandle_t handle)
DCPS_IR_Domain *	get_domain_reference () const
const DCPS_IR_Publication_Map &	publications () const
	Expose a readable reference to the publication map. More...
const DCPS_IR_Subscription_Map &	subscriptions () const
	Expose a readable reference to the subscription map. More...
const DCPS_IR_Topic_Map &	topics () const
	Expose a readable reference to the topic map. More...
std::string	dump_to_string (const std::string &prefix, int depth) const
bool &	isBitPublisher ()
bool	isBitPublisher () const
CORBA::Boolean	is_participant_ignored (OpenDDS::DCPS::GUID_t id)
CORBA::Boolean	is_topic_ignored (OpenDDS::DCPS::GUID_t id)
CORBA::Boolean	is_publication_ignored (OpenDDS::DCPS::GUID_t id)
CORBA::Boolean	is_subscription_ignored (OpenDDS::DCPS::GUID_t id)
OpenDDS::DCPS::GUID_t	get_next_topic_id (bool builtin)
OpenDDS::DCPS::GUID_t	get_next_publication_id (bool builtin)
OpenDDS::DCPS::GUID_t	get_next_subscription_id (bool builtin)
void	last_topic_key (long key)
void	last_publication_key (long key)
void	last_subscription_key (long key)
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Private Attributes
OpenDDS::DCPS::GUID_t	id_
DCPS_IR_Domain *	domain_
DDS::DomainParticipantQos	qos_
CORBA::Boolean	aliveStatus_
DDS::InstanceHandle_t	handle_
const TAO_DDS_DCPSFederationId &	federationId_
long	owner_
ACE_SYNCH_MUTEX	ownerLock_
	Lock portions ownership processing. More...
Update::Manager *	um_
bool	isBitPublisher_
	Flag indicating this participant publishes built-in topics. More...
OpenDDS::DCPS::RepoIdGenerator	topicIdGenerator_
OpenDDS::DCPS::RepoIdGenerator	publicationIdGenerator_
OpenDDS::DCPS::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_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Representative of the Domain Participant.

Definition at line 62 of file DCPS_IR_Participant.h.

Member Enumeration Documentation

anonymous enum

anonymous enum

Special owner to enforce no callbacks.

Enumerator
OWNER_NONE

Definition at line 67 of file DCPS_IR_Participant.h.

{ OWNER_NONE};

Constructor & Destructor Documentation

DCPS_IR_Participant()

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

Definition at line 26 of file DCPS_IR_Participant.cpp.

  : id_(id),
    domain_(domain),
    qos_(qos),
    aliveStatus_(1),
    handle_(0),
    federationId_(federationId),
    owner_(federationId.overridden() ? OWNER_NONE : federationId.id()),
    topicIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      isBit ? OpenDDS::DCPS::KIND_BUILTIN_TOPIC : OpenDDS::DCPS::KIND_USER_TOPIC),
    publicationIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      isBit ? OpenDDS::DCPS::KIND_BUILTIN_WRITER : OpenDDS::DCPS::KIND_USER_WRITER),
    subscriptionIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      isBit ? OpenDDS::DCPS::KIND_BUILTIN_READER : OpenDDS::DCPS::KIND_USER_READER),
    um_(um),
    isBitPublisher_(isBit)
{
}

~DCPS_IR_Participant()

DCPS_IR_Participant::~DCPS_IR_Participant ( )

virtual

Definition at line 56 of file DCPS_IR_Participant.cpp.

{
}

Member Function Documentation

add_publication()

int DCPS_IR_Participant::add_publication

(

OpenDDS::DCPS::unique_ptr< 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 150 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), DCPS_IR_Publication::get_id(), id_, isBitPublisher_, LM_DEBUG, LM_NOTICE, OpenDDS::DCPS::move(), publications_, and DCPS_IR_Publication::set_bit_status().

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

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

  if (where == this->publications_.end()) {
    DCPS_IR_Publication* pubptr = pub.get();
    this->publications_.insert(
      where, DCPS_IR_Publication_Map::value_type(pubId, OpenDDS::DCPS::move(pub)));

    if (isBitPublisher_) {
      pubptr->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(),
                 pubptr));
    }

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

add_subscription()

int DCPS_IR_Participant::add_subscription

(

OpenDDS::DCPS::unique_ptr< 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 276 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), DCPS_IR_Subscription::get_id(), id_, isBitPublisher_, LM_DEBUG, LM_NOTICE, OpenDDS::DCPS::move(), DCPS_IR_Subscription::set_bit_status(), and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

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

  if (where == this->subscriptions_.end()) {

    DCPS_IR_Subscription* subptr = sub.get();
    this->subscriptions_.insert(
      where, DCPS_IR_Subscription_Map::value_type(subId, OpenDDS::DCPS::move(sub)));

    if (isBitPublisher_) {
      subptr->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(),
                 subptr));
    }

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

add_topic_reference()

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 403 of file DCPS_IR_Participant.cpp.

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

Referenced by DCPS_IR_Domain::add_topic_i().

{
  OpenDDS::DCPS::GUID_t 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;
  }
}

changeOwner()

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 104 of file DCPS_IR_Participant.cpp.

References ACE_GUARD, ACE_SYNCH_MUTEX, isOwner(), owner(), owner_, OWNER_NONE, and ownerLock_.

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

dump_to_string()

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

Definition at line 880 of file DCPS_IR_Participant.cpp.

References aliveStatus_, ACE_Unbounded_Set_Ex< T, C >::begin(), ACE_Unbounded_Set_Ex< T, C >::end(), federationId_, TAO_DDS_DCPSFederationId::id(), id_, ignoredParticipants_, ignoredPublications_, ignoredSubscriptions_, ignoredTopics_, isBitPublisher_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, 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 (isBitPublisher_)
    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;
}

find_publication_reference()

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

Return the publication object.

Definition at line 192 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, LM_DEBUG, and publications_.

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

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

find_subscription_reference()

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

Return the subscription object.

Definition at line 319 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, LM_DEBUG, and subscriptions_.

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

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

find_topic_reference()

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

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

Definition at line 481 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, LM_DEBUG, LM_ERROR, 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;
  }
}

get_domain_reference()

DCPS_IR_Domain * DCPS_IR_Participant::get_domain_reference

(

)

const

Definition at line 838 of file DCPS_IR_Participant.cpp.

References domain_.

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

{
  return domain_;
}

get_handle()

DDS::InstanceHandle_t DCPS_IR_Participant::get_handle

(

void

)

Definition at line 809 of file DCPS_IR_Participant.cpp.

References handle_.

Referenced by DCPS_IR_Domain::dispose_participant_bit().

{
  return handle_;
}

get_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Participant::get_id

(

void

)

Definition at line 672 of file DCPS_IR_Participant.cpp.

References id_.

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

{
  return id_;
}

get_next_publication_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Participant::get_next_publication_id

(

bool

builtin

)

Next Entity Id value in sequence.

Definition at line 850 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::next(), and publicationIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

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

get_next_subscription_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Participant::get_next_subscription_id

(

bool

builtin

)

Next Entity Id value in sequence.

Definition at line 856 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::next(), and subscriptionIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

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

get_next_topic_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Participant::get_next_topic_id

(

bool

builtin

)

Next Entity Id value in sequence.

Definition at line 844 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::next(), and topicIdGenerator_.

Referenced by DCPS_IR_Domain::add_topic().

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

get_qos()

const DDS::DomainParticipantQos * DCPS_IR_Participant::get_qos

(

void

)

Return pointer to the participant qos Participant retains ownership

Definition at line 819 of file DCPS_IR_Participant.cpp.

References qos_.

Referenced by DCPS_IR_Domain::publish_participant_bit().

{
  return &qos_;
}

ignore_participant()

void DCPS_IR_Participant::ignore_participant

(

OpenDDS::DCPS::GUID_t

id

)

Ignore the participant with the id.

Definition at line 687 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, ignoredParticipants_, ACE_Unbounded_Set_Ex< T, C >::insert(), LM_DEBUG, 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);
  }
}

ignore_publication()

void DCPS_IR_Participant::ignore_publication

(

OpenDDS::DCPS::GUID_t

id

)

Ignore the publication with the id.

Definition at line 745 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, ignoredPublications_, ACE_Unbounded_Set_Ex< T, C >::insert(), LM_DEBUG, 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);
  }
}

ignore_subscription()

void DCPS_IR_Participant::ignore_subscription

(

OpenDDS::DCPS::GUID_t

id

)

Ignore the subscription with the id.

Definition at line 767 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, ignoredSubscriptions_, ACE_Unbounded_Set_Ex< T, C >::insert(), LM_DEBUG, 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);
  }
}

ignore_topic()

void DCPS_IR_Participant::ignore_topic

(

OpenDDS::DCPS::GUID_t

id

)

Ignore the topic with the id.

Definition at line 716 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, ignoredTopics_, ACE_Unbounded_Set_Ex< T, C >::insert(), LM_DEBUG, 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);
  }
}

is_alive()

CORBA::Boolean DCPS_IR_Participant::is_alive

(

void

)

Definition at line 677 of file DCPS_IR_Participant.cpp.

References aliveStatus_.

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

{
  return aliveStatus_;
}

is_participant_ignored()

CORBA::Boolean DCPS_IR_Participant::is_participant_ignored

(

OpenDDS::DCPS::GUID_t

id

)

Test if an entity is ignored by this participant.

Definition at line 789 of file DCPS_IR_Participant.cpp.

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

is_publication_ignored()

CORBA::Boolean DCPS_IR_Participant::is_publication_ignored

(

OpenDDS::DCPS::GUID_t

id

)

Test if an entity is ignored by this participant.

Definition at line 799 of file DCPS_IR_Participant.cpp.

References ACE_Unbounded_Set_Ex< T, C >::find(), and ignoredPublications_.

Referenced by DCPS_IR_Subscription::is_publication_ignored().

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

is_subscription_ignored()

CORBA::Boolean DCPS_IR_Participant::is_subscription_ignored

(

OpenDDS::DCPS::GUID_t

id

)

Test if an entity is ignored by this participant.

Definition at line 804 of file DCPS_IR_Participant.cpp.

References ACE_Unbounded_Set_Ex< T, C >::find(), and ignoredSubscriptions_.

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

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

is_topic_ignored()

CORBA::Boolean DCPS_IR_Participant::is_topic_ignored

(

OpenDDS::DCPS::GUID_t

id

)

Test if an entity is ignored by this participant.

Definition at line 794 of file DCPS_IR_Participant.cpp.

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

isBitPublisher() [1/2]

bool & DCPS_IR_Participant::isBitPublisher

(

)

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

Definition at line 139 of file DCPS_IR_Participant.cpp.

References isBitPublisher_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::add_subscription(), TAO_DDS_DCPSInfo_i::assert_topic(), DCPS_IR_Domain::dispose_participant_bit(), DCPS_IR_Domain::publish_participant_bit(), remove_all_dependents(), TAO_DDS_DCPSInfo_i::remove_publication(), TAO_DDS_DCPSInfo_i::remove_subscription(), TAO_DDS_DCPSInfo_i::remove_topic(), takeOwnership(), 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_;
}

isBitPublisher() [2/2]

bool DCPS_IR_Participant::isBitPublisher

(

)

const

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

Definition at line 145 of file DCPS_IR_Participant.cpp.

References isBitPublisher_.

{
  return this->isBitPublisher_;
}

isOwner()

bool DCPS_IR_Participant::isOwner

(

)

const

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

Definition at line 133 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(), changeOwner(), DCPS_IR_Publication::disassociate_participant(), DCPS_IR_Subscription::disassociate_participant(), DCPS_IR_Subscription::disassociate_publication(), DCPS_IR_Publication::disassociate_subscription(), DCPS_IR_Publication::disassociate_topic(), DCPS_IR_Subscription::disassociate_topic(), DCPS_IR_Subscription::remove_associated_publication(), DCPS_IR_Publication::remove_associated_subscription(), 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_Publication::update_incompatible_qos(), DCPS_IR_Subscription::update_incompatible_qos(), and TAO_DDS_DCPSInfo_i::update_topic_qos().

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

last_publication_key()

void DCPS_IR_Participant::last_publication_key

(

long

key

)

Ensure no conflicts with sequence values from persistent storage.

Definition at line 868 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::last(), and publicationIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_publication().

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

last_subscription_key()

void DCPS_IR_Participant::last_subscription_key

(

long

key

)

Ensure no conflicts with sequence values from persistent storage.

Definition at line 874 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::last(), and subscriptionIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

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

last_topic_key()

void DCPS_IR_Participant::last_topic_key

(

long

key

)

Ensure no conflicts with sequence values from persistent storage.

Definition at line 862 of file DCPS_IR_Participant.cpp.

References OpenDDS::DCPS::RepoIdGenerator::last(), and topicIdGenerator_.

Referenced by TAO_DDS_DCPSInfo_i::add_topic().

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

mark_dead()

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 666 of file DCPS_IR_Participant.cpp.

References DCPS_IR_Domain::add_dead_participant(), aliveStatus_, domain_, and OpenDDS::DCPS::rchandle_from().

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

{
  aliveStatus_ = 0;
  domain_->add_dead_participant(OpenDDS::DCPS::rchandle_from(this));
}

owner()

long DCPS_IR_Participant::owner

(

void

)

const

Value of the owner for this participant.

Definition at line 127 of file DCPS_IR_Participant.cpp.

References owner_.

Referenced by changeOwner().

{
  return this->owner_;
}

publications()

const DCPS_IR_Publication_Map & DCPS_IR_Participant::publications

(

void

)

const

Expose a readable reference to the publication map.

Definition at line 61 of file DCPS_IR_Participant.cpp.

References publications_.

Referenced by TAO_DDS_DCPSInfo_i::disassociate_participant(), and TAO_DDS_DCPSInfo_i::remove_by_owner().

{
  return this->publications_;
}

remove_all_dependents()

void DCPS_IR_Participant::remove_all_dependents

(

CORBA::Boolean

notify_lost

)

Removes all topics, publications and.

Definition at line 515 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), Update::Actor, Update::DataReader, Update::DataWriter, OpenDDS::DCPS::DCPS_debug_level, Update::Manager::destroy(), domain_, DCPS_IR_Domain::get_id(), get_id(), id_, isBitPublisher(), LM_DEBUG, 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_.

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

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

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

  // 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::GUID_t 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()));
      }
    }
  }

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

remove_publication()

int DCPS_IR_Participant::remove_publication

(

OpenDDS::DCPS::GUID_t

pubId

)

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

Definition at line 228 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Domain::dispose_publication_bit(), domain_, id_, LM_DEBUG, LM_ERROR, publications_, DCPS_IR_Topic::release(), and DCPS_IR_Topic::remove_publication_reference().

Referenced by TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::remove_by_owner(), and TAO_DDS_DCPSInfo_i::remove_publication().

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

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

remove_subscription()

int DCPS_IR_Participant::remove_subscription

(

OpenDDS::DCPS::GUID_t

subId

)

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

Definition at line 355 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Domain::dispose_subscription_bit(), domain_, id_, LM_DEBUG, LM_ERROR, DCPS_IR_Topic::release(), DCPS_IR_Topic::remove_subscription_reference(), and subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::add_subscription(), TAO_DDS_DCPSInfo_i::remove_by_owner(), and TAO_DDS_DCPSInfo_i::remove_subscription().

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

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

remove_topic_reference()

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

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

Definition at line 444 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, LM_DEBUG, LM_WARNING, and topicRefs_.

Referenced by TAO_DDS_DCPSInfo_i::remove_by_owner(), and 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;
  }
}

set_alive()

void DCPS_IR_Participant::set_alive

(

CORBA::Boolean

alive

)

Definition at line 682 of file DCPS_IR_Participant.cpp.

References aliveStatus_.

{
  aliveStatus_ = alive;
}

set_handle()

void DCPS_IR_Participant::set_handle

(

DDS::InstanceHandle_t

handle

)

Definition at line 814 of file DCPS_IR_Participant.cpp.

References handle_.

Referenced by DCPS_IR_Domain::publish_participant_bit().

{
  handle_ = handle;
}

set_qos()

bool DCPS_IR_Participant::set_qos

(

const DDS::DomainParticipantQos &

qos

)

Update qos and also propagate 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 824 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;
}

subscriptions()

const DCPS_IR_Subscription_Map & DCPS_IR_Participant::subscriptions

(

void

)

const

Expose a readable reference to the subscription map.

Definition at line 67 of file DCPS_IR_Participant.cpp.

References subscriptions_.

Referenced by TAO_DDS_DCPSInfo_i::disassociate_participant(), and TAO_DDS_DCPSInfo_i::remove_by_owner().

{
  return this->subscriptions_;
}

takeOwnership()

void DCPS_IR_Participant::takeOwnership

(

)

Take local ownership of this participant and publish an update.

Publish an update with our ownership.

Definition at line 79 of file DCPS_IR_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), changeOwner(), Update::Manager::create(), OpenDDS::DCPS::DCPS_debug_level, domain_, federationId_, DCPS_IR_Domain::get_id(), TAO_DDS_DCPSFederationId::id(), id_, isBitPublisher(), LM_DEBUG, and um_.

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

topics()

const DCPS_IR_Topic_Map & DCPS_IR_Participant::topics

(

)

const

Expose a readable reference to the topic map.

Definition at line 73 of file DCPS_IR_Participant.cpp.

References topicRefs_.

Referenced by TAO_DDS_DCPSInfo_i::remove_by_owner().

{
  return this->topicRefs_;
}

Member Data Documentation

aliveStatus_

CORBA::Boolean DCPS_IR_Participant::aliveStatus_

private

Definition at line 218 of file DCPS_IR_Participant.h.

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

domain_

DCPS_IR_Domain* DCPS_IR_Participant::domain_

private

Definition at line 216 of file DCPS_IR_Participant.h.

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

federationId_

const TAO_DDS_DCPSFederationId& DCPS_IR_Participant::federationId_

private

Definition at line 221 of file DCPS_IR_Participant.h.

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

handle_

DDS::InstanceHandle_t DCPS_IR_Participant::handle_

private

Definition at line 219 of file DCPS_IR_Participant.h.

Referenced by get_handle(), and set_handle().

id_

OpenDDS::DCPS::GUID_t DCPS_IR_Participant::id_

private

Definition at line 215 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(), and takeOwnership().

ignoredParticipants_

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredParticipants_

private

Lists of Ignored Entities

Definition at line 243 of file DCPS_IR_Participant.h.

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

ignoredPublications_

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredPublications_

private

Lists of Ignored Entities

Definition at line 245 of file DCPS_IR_Participant.h.

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

ignoredSubscriptions_

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredSubscriptions_

private

Lists of Ignored Entities

Definition at line 246 of file DCPS_IR_Participant.h.

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

ignoredTopics_

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredTopics_

private

Lists of Ignored Entities

Definition at line 244 of file DCPS_IR_Participant.h.

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

isBitPublisher_

bool DCPS_IR_Participant::isBitPublisher_

private

Flag indicating this participant publishes built-in topics.

Definition at line 259 of file DCPS_IR_Participant.h.

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

owner_

long DCPS_IR_Participant::owner_

private

Definition at line 222 of file DCPS_IR_Participant.h.

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

ownerLock_

ACE_SYNCH_MUTEX DCPS_IR_Participant::ownerLock_

private

Lock portions ownership processing.

Definition at line 225 of file DCPS_IR_Participant.h.

Referenced by changeOwner().

publicationIdGenerator_

OpenDDS::DCPS::RepoIdGenerator DCPS_IR_Participant::publicationIdGenerator_

private

Entity GUID Id generators.

Definition at line 230 of file DCPS_IR_Participant.h.

Referenced by get_next_publication_id(), and last_publication_key().

publications_

DCPS_IR_Publication_Map DCPS_IR_Participant::publications_

private

Entities in the Participant

Definition at line 237 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(), and remove_publication().

qos_

DDS::DomainParticipantQos DCPS_IR_Participant::qos_

private

Definition at line 217 of file DCPS_IR_Participant.h.

Referenced by get_qos(), and set_qos().

subscriptionIdGenerator_

OpenDDS::DCPS::RepoIdGenerator DCPS_IR_Participant::subscriptionIdGenerator_

private

Entity GUID Id generators.

Definition at line 231 of file DCPS_IR_Participant.h.

Referenced by get_next_subscription_id(), and last_subscription_key().

subscriptions_

DCPS_IR_Subscription_Map DCPS_IR_Participant::subscriptions_

private

Entities in the Participant

Definition at line 236 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(), and subscriptions().

topicIdGenerator_

OpenDDS::DCPS::RepoIdGenerator DCPS_IR_Participant::topicIdGenerator_

private

Entity GUID Id generators.

Definition at line 229 of file DCPS_IR_Participant.h.

Referenced by get_next_topic_id(), and last_topic_key().

topicRefs_

DCPS_IR_Topic_Map DCPS_IR_Participant::topicRefs_

private

Entities in the Participant

Definition at line 238 of file DCPS_IR_Participant.h.

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

um_

Update::Manager* DCPS_IR_Participant::um_

private

The participant is the only entity that has and deals with dependencies (topics, actors). In handling dependencies it encompasses a bigger role. Therefore it needs to update other entities (specifically the Update::Manager) the changes it makes.

Definition at line 256 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