DCPS_IR_Participant Class Reference

Representative of the Domain Participant. More...

#include <DCPS_IR_Participant.h>

Inheritance diagram for DCPS_IR_Participant:

[legend]

Collaboration diagram for DCPS_IR_Participant:

[legend]

List of all members.

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::RepoId 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.
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.
int	add_publication (OpenDDS::DCPS::unique_ptr< 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 (OpenDDS::DCPS::unique_ptr< 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)
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.
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_
const TAO_DDS_DCPSFederationId &	federationId_
long	owner_
ACE_SYNCH_MUTEX	ownerLock_
	Lock portions ownership processing.
Update::Manager *	um_
bool	isBitPublisher_
	Flag indicating this participant publishes built-in topics.
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_
bool &	isBitPublisher ()
bool	isBitPublisher () const
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)
OpenDDS::DCPS::RepoId	get_next_topic_id (bool builtin)
OpenDDS::DCPS::RepoId	get_next_publication_id (bool builtin)
OpenDDS::DCPS::RepoId	get_next_subscription_id (bool builtin)
void	last_topic_key (long key)
void	last_publication_key (long key)
void	last_subscription_key (long key)

---

Detailed Description

Representative of the Domain Participant.

Definition at line 62 of file DCPS_IR_Participant.h.

---

Member Enumeration Documentation

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 h OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 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,
		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_TOPIC),
    publicationIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      isBit ? OpenDDS::DCPS::KIND_BUILTIN_WRITER : OpenDDS::DCPS::KIND_WRITER),
    subscriptionIdGenerator_(
      federationId.id(),
      OpenDDS::DCPS::RepoIdConverter(id).participantId(),
      isBit ? OpenDDS::DCPS::KIND_BUILTIN_READER : OpenDDS::DCPS::KIND_READER),
    um_(um),
    isBitPublisher_(isBit)
{
}

DCPS_IR_Participant::~DCPS_IR_Participant

(

)

[virtual]

Definition at line 56 of file DCPS_IR_Participant.cpp.

{
}

---

Member Function Documentation

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_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), 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::RepoId 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;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

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_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), 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::RepoId 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;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the call graph for this function:

Here is the caller graph for this function:

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 isOwner(), 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.
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

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_, TAO_DDS_DCPSFederationId::overridden(), owner_, publications_, str, 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;
}

Here is the call graph for this function:

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

Return the publication object.

Definition at line 192 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Return the subscription object.

Definition at line 319 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

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_Subscription::set_qos(), and DCPS_IR_Publication::set_qos().

{
  return domain_;
}

Here is the caller graph for this function:

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

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId 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_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_;
}

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_next_publication_id

(

bool

builtin

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId DCPS_IR_Participant::get_next_subscription_id

(

bool

builtin

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::RepoId 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);
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the caller graph for this function:

void DCPS_IR_Participant::ignore_participant

(

OpenDDS::DCPS::RepoId

id

)

Ignore the participant with the id.

Definition at line 687 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::ignore_publication

(

OpenDDS::DCPS::RepoId

id

)

Ignore the publication with the id.

Definition at line 745 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::ignore_subscription

(

OpenDDS::DCPS::RepoId

id

)

Ignore the subscription with the id.

Definition at line 767 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::ignore_topic

(

OpenDDS::DCPS::RepoId

id

)

Ignore the topic with the id.

Definition at line 716 of file DCPS_IR_Participant.cpp.

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Participant::is_participant_ignored

(

OpenDDS::DCPS::RepoId

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

Here is the call graph for this function:

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Participant::is_publication_ignored

(

OpenDDS::DCPS::RepoId

id

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Participant::is_subscription_ignored

(

OpenDDS::DCPS::RepoId

id

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

CORBA::Boolean DCPS_IR_Participant::is_topic_ignored

(

OpenDDS::DCPS::RepoId

id

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

bool DCPS_IR_Participant::isBitPublisher

(

)

const

Entity GUID Id generators.

Definition at line 145 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 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_domain_participant(), 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_;
}

Here is the caller graph for this function:

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::last_publication_key

(

long

key

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::last_subscription_key

(

long

key

)

Entity GUID Id generators.

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the call graph for this function:

Here is the caller graph for this function:

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_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(OpenDDS::DCPS::rchandle_from(this));
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

{
  return this->owner_;
}

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

Here is the caller graph for this function:

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_TEXT(), Update::Actor, Update::DataReader, Update::DataWriter, OpenDDS::DCPS::DCPS_debug_level, Update::Manager::destroy(), domain_, get_id(), DCPS_IR_Domain::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::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()));
      }
    }
  }

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

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

Here is the call graph for this function:

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

void DCPS_IR_Participant::set_alive

(

CORBA::Boolean

alive

)

Definition at line 682 of file DCPS_IR_Participant.cpp.

References aliveStatus_.

{
  aliveStatus_ = alive;
}

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

Here is the caller graph for this function:

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the caller graph for this function:

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

Here is the caller graph for this function:

---

Member Data Documentation

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

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

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

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

OpenDDS::DCPS::RepoId 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().

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

TAO_DDS_RepoId_Set DCPS_IR_Participant::ignoredPublications_ [private]

Entity GUID Id generators.

Definition at line 245 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]

Entity GUID Id generators.

Definition at line 246 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]

Entity GUID Id generators.

Definition at line 244 of file DCPS_IR_Participant.h.

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

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

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

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

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

DCPS_IR_Publication_Map DCPS_IR_Participant::publications_ [private]

Entity GUID Id generators.

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

DDS::DomainParticipantQos DCPS_IR_Participant::qos_ [private]

Definition at line 217 of file DCPS_IR_Participant.h.

Referenced by get_qos(), and set_qos().

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

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

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

DCPS_IR_Topic_Map DCPS_IR_Participant::topicRefs_ [private]

Entity GUID Id generators.

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

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