DCPS_IR_Domain Class Reference

Representation of a Domain in the system. More...

#include <DCPS_IR_Domain.h>

Inheritance diagram for DCPS_IR_Domain:

Collaboration diagram for DCPS_IR_Domain:

Public Member Functions
	DCPS_IR_Domain (DDS::DomainId_t id, OpenDDS::DCPS::RepoIdGenerator &generator)
	~DCPS_IR_Domain ()
int	add_participant (DCPS_IR_Participant_rch participant)
int	remove_participant (const OpenDDS::DCPS::GUID_t &particpantId, CORBA::Boolean notify_lost)
DCPS_IR_Participant_rch	participant_rch (const OpenDDS::DCPS::GUID_t &id) const
DCPS_IR_Participant *	participant (const OpenDDS::DCPS::GUID_t &id) const
	Find the participant with the id. More...
OpenDDS::DCPS::TopicStatus	find_topic (const char *topicName, DCPS_IR_Topic *&topic)
DCPS_IR_Topic *	find_topic (const OpenDDS::DCPS::GUID_t &id)
	Find a topic object reference using the topic Id value. More...
OpenDDS::DCPS::TopicStatus	remove_topic (DCPS_IR_Participant *part, DCPS_IR_Topic *&topic)
void	remove_topic_id_mapping (const OpenDDS::DCPS::GUID_t &topicId)
void	add_dead_participant (DCPS_IR_Participant_rch participant)
void	remove_dead_participants (bool part_of_cleanup=false)
	Remove any participants currently marked as dead. More...
DDS::DomainId_t	get_id ()
OpenDDS::DCPS::GUID_t	get_next_participant_id ()
	Next Entity Id value in sequence. More...
void	last_participant_key (long key)
	Ensure no conflicts with sequence values from persistent storage. More...
int	init_built_in_topics (bool federated, bool persistent)
int	cleanup_built_in_topics ()
	Cleans up the Built-In Topic structures. More...
int	reassociate_built_in_topic_pubs ()
void	publish_participant_bit (DCPS_IR_Participant *participant)
	Publish Participant in the Participant Built-In Topic. More...
void	publish_topic_bit (DCPS_IR_Topic *topic)
	Publish Topic in the Topic Built-In Topic. More...
void	publish_subscription_bit (DCPS_IR_Subscription *subscription)
	Publish Subscription in the Subscription Built-In Topic. More...
void	publish_publication_bit (DCPS_IR_Publication *publication)
	Publish Publication in the Publication Built-In Topic. More...
void	dispose_participant_bit (DCPS_IR_Participant *participant)
	Dispose Participant in the Participant Built-In Topic. More...
void	dispose_topic_bit (DCPS_IR_Topic *topic)
	Dispose Topic in the Topic Built-In Topic. More...
void	dispose_subscription_bit (DCPS_IR_Subscription *subscription)
	Dispose Subscription in the Subscription Built-In Topic. More...
void	dispose_publication_bit (DCPS_IR_Publication *publication)
	Dispose Publication in the Publication Built-In Topic. More...
const DCPS_IR_Participant_Map &	participants () const
	Expose a readable reference to the participant map. More...
std::string	dump_to_string (const std::string &prefix, int depth) const
bool	useBIT () const
OpenDDS::DCPS::TopicStatus	add_topic (OpenDDS::DCPS::GUID_t_out topicId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, DCPS_IR_Participant *participantPtr)
OpenDDS::DCPS::TopicStatus	force_add_topic (const OpenDDS::DCPS::GUID_t &topicId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, DCPS_IR_Participant *participantPtr)
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 Types
typedef std::map< OpenDDS::DCPS::GUID_t, OpenDDS::DCPS::container_supported_unique_ptr< DCPS_IR_Topic >, OpenDDS::DCPS::GUID_tKeyLessThan >	IdToTopicMap
	Mapping from GUID_t values to Topic object references. More...

Private Member Functions
OpenDDS::DCPS::TopicStatus	add_topic_i (OpenDDS::DCPS::GUID_t &topicId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, DCPS_IR_Participant *participantPtr, bool isBIT)
int	add_topic_description (OpenDDS::DCPS::unique_ptr< DCPS_IR_Topic_Description > desc)
int	find_topic_description (const char *name, const char *dataTypeName, DCPS_IR_Topic_Description *&desc)
int	remove_topic_description (DCPS_IR_Topic_Description *desc)
	Returns 0 if successful. More...
	DCPS_IR_Domain (const DCPS_IR_Domain &)
int	init_built_in_topics_topics ()
int	init_built_in_topics_datawriters (bool federated)
int	init_built_in_topics_transport (bool persistent)

Private Attributes
DDS::DomainId_t	id_
OpenDDS::DCPS::RepoIdGenerator &	participantIdGenerator_
DCPS_IR_Participant_Map	participants_
	all the participants More...
DCPS_IR_Participant_Set	deadParticipants_
DCPS_IR_Topic_Description_Set	topicDescriptions_
	all the topics More...
IdToTopicMap	idToTopicMap_
	Actual mapping of Id values to Topic object references. More...
OpenDDS::DCPS::AtomicBool	useBIT_
	indicates if the BuiltIn Topics are enabled More...
DDS::DomainParticipantFactory_var	bitParticipantFactory_
DDS::DomainParticipant_var	bitParticipant_
DDS::DomainParticipantListener_var	bitParticipantListener_
DDS::Publisher_var	bitPublisher_
OpenDDS::DCPS::TransportConfig_rch	transportConfig_
DDS::Topic_var	bitParticipantTopic_
DDS::ParticipantBuiltinTopicDataDataWriter_var	bitParticipantDataWriter_
DDS::Topic_var	bitTopicTopic_
DDS::TopicBuiltinTopicDataDataWriter_var	bitTopicDataWriter_
DDS::Topic_var	bitSubscriptionTopic_
DDS::SubscriptionBuiltinTopicDataDataWriter_var	bitSubscriptionDataWriter_
DDS::Topic_var	bitPublicationTopic_
DDS::PublicationBuiltinTopicDataDataWriter_var	bitPublicationDataWriter_

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

Detailed Description

Representation of a Domain in the system.

This represents a Domain in the system. It contains the representatives of the entities that are in the corresponding system's domain.

Definition at line 64 of file DCPS_IR_Domain.h.

Member Typedef Documentation

IdToTopicMap

typedef std::map<OpenDDS::DCPS::GUID_t, OpenDDS::DCPS::container_supported_unique_ptr<DCPS_IR_Topic>, OpenDDS::DCPS::GUID_tKeyLessThan> DCPS_IR_Domain::IdToTopicMap

private

Mapping from GUID_t values to Topic object references.

Definition at line 236 of file DCPS_IR_Domain.h.

Constructor & Destructor Documentation

DCPS_IR_Domain() [1/2]

DCPS_IR_Domain::DCPS_IR_Domain	(	DDS::DomainId_t	id,
		OpenDDS::DCPS::RepoIdGenerator &	generator
	)

Definition at line 39 of file DCPS_IR_Domain.cpp.

  : id_(id),
    participantIdGenerator_(generator),
    useBIT_(false)
{
}

~DCPS_IR_Domain()

DCPS_IR_Domain::~DCPS_IR_Domain

(

)

Definition at line 46 of file DCPS_IR_Domain.cpp.

{
}

DCPS_IR_Domain() [2/2]

DCPS_IR_Domain::DCPS_IR_Domain ( const DCPS_IR_Domain &  )

private

Member Function Documentation

add_dead_participant()

void DCPS_IR_Domain::add_dead_participant

(

DCPS_IR_Participant_rch

participant

)

Mark a participant as being unresponsive (dead) and schedule it to be removed next time remove_dead_participants is called.

Definition at line 966 of file DCPS_IR_Domain.cpp.

References deadParticipants_.

Referenced by DCPS_IR_Participant::mark_dead().

{
  deadParticipants_.insert(participant);
}

add_participant()

int DCPS_IR_Domain::add_participant

(

DCPS_IR_Participant_rch

participant

)

Add the participant Returns 0 if added, 1 if already exists, -1 other failure

Definition at line 75 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, OpenDDS::DCPS::RcHandle< T >::in(), LM_DEBUG, LM_NOTICE, participants_, and publish_participant_bit().

{
  OpenDDS::DCPS::GUID_t participantId = participant->get_id();
  OpenDDS::DCPS::RepoIdConverter converter(participantId);

  DCPS_IR_Participant_Map::iterator where
  = this->participants_.find(participantId);

  if (where == this->participants_.end()) {
    this->participants_.insert(
      DCPS_IR_Participant_Map::value_type(participantId, participant));

    // Publish the BIT information
    publish_participant_bit(participant.in());

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Domain::add_participant: ")
                 ACE_TEXT("added participant %C in domain %d ")
                 ACE_TEXT("at 0x%x.\n"),
                 std::string(converter).c_str(),
                 id_,
                 participant.in()));
    }

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Domain::add_participant: ")
                 ACE_TEXT("attempt to add already existing participant %C in domain %d.\n"),
                 std::string(converter).c_str(),
                 id_));
    }

    return 1;
  }

  return 0;
}

add_topic()

OpenDDS::DCPS::TopicStatus DCPS_IR_Domain::add_topic	(	OpenDDS::DCPS::GUID_t_out	topicId,
		const char *	topicName,
		const char *	dataTypeName,
		const DDS::TopicQos &	qos,
		DCPS_IR_Participant *	participantPtr
	)

Add a topic to the domain Returns OpenDDS::DCPS::CREATED if successful

Definition at line 156 of file DCPS_IR_Domain.cpp.

References add_topic_i(), OpenDDS::DCPS::CREATED, DCPS_IR_Participant::get_next_topic_id(), OpenDDS::DCPS::GUID_UNKNOWN, and OpenDDS::DCPS::topicIsBIT().

{
  topicId = OpenDDS::DCPS::GUID_UNKNOWN;

  bool isBIT = OpenDDS::DCPS::topicIsBIT(topicName, dataTypeName);
  OpenDDS::DCPS::GUID_t new_topic_id = participantPtr->get_next_topic_id(isBIT);
  OpenDDS::DCPS::TopicStatus status = add_topic_i(new_topic_id, topicName
                                                  , dataTypeName
                                                  , qos, participantPtr, isBIT);

  if (status == OpenDDS::DCPS::CREATED) {
    topicId = new_topic_id;
  }

  return status;
}

add_topic_description()

int DCPS_IR_Domain::add_topic_description ( OpenDDS::DCPS::unique_ptr< DCPS_IR_Topic_Description >  desc )

private

Takes ownership of the memory pointed to by desc if successful returns 0 if successful, 1 if description already exists -1 unknown error 2 if confliciting dataTypeName

Definition at line 899 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, find_topic_description(), OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), DCPS_IR_Topic_Description::get_dataTypeName(), DCPS_IR_Topic_Description::get_name(), id_, LM_DEBUG, LM_ERROR, LM_NOTICE, OpenDDS::DCPS::move(), and topicDescriptions_.

Referenced by add_topic_i().

{
  using OpenDDS::DCPS::move;
  DCPS_IR_Topic_Description* discard = 0;
  DCPS_IR_Topic_Description* desc_ptr = desc.get();

  switch (this->find_topic_description(
            desc->get_name(),
            desc->get_dataTypeName(),
            discard)) {
  case -1:
    this->topicDescriptions_[desc_ptr->get_name()] = move(desc);

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Domain::add_topic_description: ")
                 ACE_TEXT("added Topic Description 0x%x in domain %d.\n"),
                 desc_ptr,
                 id_));
    }

    return 0;

  case 0:
    ACE_DEBUG((LM_NOTICE,
               ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Domain::add_topic_description: ")
               ACE_TEXT("attempt to add existing Topic Description 0x%x to domain %d.\n"),
               desc_ptr,
               id_));
    return 1;

  case 1:
    ACE_DEBUG((LM_NOTICE,
               ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Domain::add_topic_description: ")
               ACE_TEXT("attempt to add incompatible Topic Description 0x%x to domain %d.\n"),
               desc_ptr,
               id_));
    return 2;

  default:
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::add_topic_description: ")
               ACE_TEXT("unknown error adding Topic Description 0x%x to domain %d.\n"),
               desc_ptr,
               id_));
    return 2;
  }
}

add_topic_i()

OpenDDS::DCPS::TopicStatus DCPS_IR_Domain::add_topic_i ( OpenDDS::DCPS::GUID_t &  topicId, const char *  topicName, const char *  dataTypeName, const DDS::TopicQos &  qos, DCPS_IR_Participant *  participantPtr, bool  isBIT  )

private

Definition at line 193 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), DCPS_IR_Topic_Description::add_topic(), add_topic_description(), DCPS_IR_Participant::add_topic_reference(), OpenDDS::DCPS::CONFLICTING_TYPENAME, OpenDDS::DCPS::CREATED, OpenDDS::DCPS::DCPS_debug_level, find_topic_description(), OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), OpenDDS::DCPS::GUID_UNKNOWN, id_, idToTopicMap_, LM_DEBUG, LM_ERROR, LM_NOTICE, OpenDDS::DCPS::move(), OpenDDS::DCPS::NOT_FOUND, publish_topic_bit(), and DCPS_IR_Topic_Description::remove_topic().

Referenced by add_topic(), and force_add_topic().

{
  DCPS_IR_Topic_Description* description;
  int descriptionLookup = find_topic_description(topicName, dataTypeName, description);

  if (1 == descriptionLookup) {
    topicId = OpenDDS::DCPS::GUID_UNKNOWN;
    return OpenDDS::DCPS::CONFLICTING_TYPENAME;

  } else if (-1 == descriptionLookup) {
    using namespace OpenDDS::DCPS;
    unique_ptr<DCPS_IR_Topic_Description> desc( new
                   DCPS_IR_Topic_Description(
                     this,
                     topicName,
                     dataTypeName));
    description = desc.get();
    int descriptionAddition = add_topic_description(move(desc));

    if (0 != descriptionAddition) {
      topicId = OpenDDS::DCPS::GUID_UNKNOWN;

      if (2 == descriptionAddition) {
        return OpenDDS::DCPS::CONFLICTING_TYPENAME;

      } else {
        return OpenDDS::DCPS::NOT_FOUND;
      }
    }
  }

  OpenDDS::DCPS::unique_ptr<DCPS_IR_Topic> topic( new
                 DCPS_IR_Topic(
                   topicId,
                   qos,
                   this,
                   participantPtr,
                   description,
                   isBIT));

  OpenDDS::DCPS::TopicStatus topicStatus = OpenDDS::DCPS::NOT_FOUND;

  switch (description->add_topic(topic.get())) {
  case 0: {
    switch (participantPtr->add_topic_reference(topic.get())) {
    case 0: {
      if (OpenDDS::DCPS::DCPS_debug_level > 0) {
        OpenDDS::DCPS::RepoIdConverter converter(topicId);
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) DCPS_IR_Domain::add_topic_i: ")
                   ACE_TEXT("Domain %d successfully added topic %C ")
                   ACE_TEXT("at 0x%x.\n"),
                   this->id_,
                   std::string(converter).c_str(),
                   topic.get()));
      }

      topicStatus = OpenDDS::DCPS::CREATED;

      // Publish the BIT information
      publish_topic_bit(topic.get());

      // Keep a reference to easily locate the topic by id.
      this->idToTopicMap_[topicId] = move(topic);

    }
    break;

    case 1:

      if (OpenDDS::DCPS::DCPS_debug_level > 0) {
        OpenDDS::DCPS::RepoIdConverter converter(topicId);
        ACE_DEBUG((LM_NOTICE,
                   ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Domain::add_topic_i: ")
                   ACE_TEXT("Domain %d declined to add duplicate topic %C at 0x%x.\n"),
                   this->id_,
                   std::string(converter).c_str(),
                   topic.get()));
      }

      topicStatus = OpenDDS::DCPS::NOT_FOUND;
      topicId = OpenDDS::DCPS::GUID_UNKNOWN;
      description->remove_topic(topic.get());
      break;

    case -1: {
      OpenDDS::DCPS::RepoIdConverter converter(topicId);
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::add_topic_i: ")
                 ACE_TEXT("Domain %d failed to add topic %C at 0x%x.\n"),
                 this->id_,
                 std::string(converter).c_str(),
                 topic.get()));
      topicStatus = OpenDDS::DCPS::NOT_FOUND;
      topicId = OpenDDS::DCPS::GUID_UNKNOWN;
      description->remove_topic(topic.get());
    }
    break;
    }
  }
  break;

  case 1:

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(topicId);
      ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) WARNING: DCPS_IR_Domain::add_topic ")
                 ACE_TEXT("Unable to add topic 0x%x id %C to Topic Description\n"),
                 topic.get(),
                 std::string(converter).c_str()));
    }

    topicStatus = OpenDDS::DCPS::NOT_FOUND;
    topicId = OpenDDS::DCPS::GUID_UNKNOWN;
    break;

  case -1: {
    OpenDDS::DCPS::RepoIdConverter converter(topicId);
    ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::add_topic ")
               ACE_TEXT("Unable to add topic 0x%x id %C to Topic Description\n"),
               topic.get(),
               std::string(converter).c_str()));
    topicStatus = OpenDDS::DCPS::NOT_FOUND;
    topicId = OpenDDS::DCPS::GUID_UNKNOWN;
  }
  break;
  }

  return topicStatus;
}

cleanup_built_in_topics()

int DCPS_IR_Domain::cleanup_built_in_topics

(

)

Cleans up the Built-In Topic structures.

Definition at line 857 of file DCPS_IR_Domain.cpp.

References ACE_ERROR, bitParticipant_, bitParticipantDataWriter_, bitParticipantFactory_, bitParticipantTopic_, bitPublicationDataWriter_, bitPublicationTopic_, bitPublisher_, bitSubscriptionDataWriter_, bitSubscriptionTopic_, bitTopicDataWriter_, bitTopicTopic_, LM_ERROR, OpenDDS::DCPS::retcode_to_string(), and useBIT_.

{
#ifndef DDS_HAS_MINIMUM_BIT
  if (useBIT_ && bitParticipant_) {
    useBIT_ = false;
    using OpenDDS::DCPS::retcode_to_string;

    // clean up the Built-in Topic objects
    const DDS::ReturnCode_t entities_error = bitParticipant_->delete_contained_entities();
    if (entities_error) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DCPS_IR_Domain::cleanup_built_in_topics: "
                 "failed to delete entities: %C\n",
                 retcode_to_string(entities_error)));
      return 1;
    }

    bitPublisher_ = 0;
    bitParticipantDataWriter_ = 0;
    bitTopicDataWriter_ = 0;
    bitSubscriptionDataWriter_ = 0;
    bitPublicationDataWriter_ = 0;
    bitParticipantTopic_ = 0;
    bitTopicTopic_ = 0;
    bitSubscriptionTopic_ = 0;
    bitPublicationTopic_ = 0;

    const DDS::ReturnCode_t part_error =
      bitParticipantFactory_->delete_participant(bitParticipant_);
    if (part_error) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DCPS_IR_Domain::cleanup_built_in_topics: "
                 "failed to delete participant: %C\n",
                 retcode_to_string(part_error)));
      return 1;
    }
  }

  return 0;
#else
  return 1;
#endif
}

dispose_participant_bit()

void DCPS_IR_Domain::dispose_participant_bit

(

DCPS_IR_Participant *

participant

)

Dispose Participant in the Participant Built-In Topic.

Definition at line 1266 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_TEXT(), bitParticipantDataWriter_, DCPS_IR_Participant::get_handle(), DCPS_IR_Participant::get_id(), DCPS_IR_Participant::isBitPublisher(), LM_ERROR, DDS::RETCODE_OK, and useBIT_.

Referenced by remove_participant().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    if (!participant->isBitPublisher()) {
      try {
        DDS::ParticipantBuiltinTopicData key_data;
        DDS::InstanceHandle_t handle = participant->get_handle();

        DDS::ReturnCode_t retGetKey
        = bitParticipantDataWriter_->get_key_value(key_data,
                                                   handle);

        if (DDS::RETCODE_OK != retGetKey) {
          OpenDDS::DCPS::RepoIdConverter converter(participant->get_id());
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_participant_bit ")
                     ACE_TEXT("Unable to get_key_value for participant %C handle %d.\n"),
                     std::string(converter).c_str(),
                     handle));
        }

        DDS::ReturnCode_t retDispose =
          bitParticipantDataWriter_->dispose(key_data,
                                             handle);

        if (DDS::RETCODE_OK != retDispose) {
          OpenDDS::DCPS::RepoIdConverter converter(participant->get_id());
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_participant_bit ")
                     ACE_TEXT("Unable to dispose for participant %C handle %d.\n"),
                     std::string(converter).c_str(),
                     handle));
        }

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "ERROR: Exception caught in DCPS_IR_Domain::dispose_participant_bit:");
      }
    }
  }

#else
  ACE_UNUSED_ARG(participant);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

dispose_publication_bit()

void DCPS_IR_Domain::dispose_publication_bit

(

DCPS_IR_Publication *

publication

)

Dispose Publication in the Publication Built-In Topic.

Definition at line 1414 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_TEXT(), bitPublicationDataWriter_, DCPS_IR_Publication::get_handle(), DCPS_IR_Publication::is_bit(), LM_ERROR, DDS::RETCODE_OK, and useBIT_.

Referenced by DCPS_IR_Participant::remove_publication().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    if (!publication->is_bit()) {
      try {
        DDS::PublicationBuiltinTopicData key_data;
        DDS::InstanceHandle_t handle = publication->get_handle();

        DDS::ReturnCode_t retGetKey
        = bitPublicationDataWriter_->get_key_value(key_data, handle);

        if (DDS::RETCODE_OK != retGetKey) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_publication_bit ")
                     ACE_TEXT("Unable to get_key_value for publication ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     publication,
                     handle,
                     retGetKey));
        }

        DDS::ReturnCode_t retDispose =
          bitPublicationDataWriter_->dispose(key_data,
                                             handle);

        if (DDS::RETCODE_OK != retDispose) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_publication_bit ")
                     ACE_TEXT("Unable to dispose for publication ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     publication,
                     handle,
                     retDispose));
        }

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::dispose_publication_bit:");
      }
    }
  }

#else
  ACE_UNUSED_ARG(publication);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

dispose_subscription_bit()

void DCPS_IR_Domain::dispose_subscription_bit

(

DCPS_IR_Subscription *

subscription

)

Dispose Subscription in the Subscription Built-In Topic.

Definition at line 1364 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_TEXT(), bitSubscriptionDataWriter_, DCPS_IR_Subscription::get_handle(), DCPS_IR_Subscription::is_bit(), LM_ERROR, DDS::RETCODE_OK, and useBIT_.

Referenced by DCPS_IR_Participant::remove_subscription().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    if (!subscription->is_bit()) {
      try {
        DDS::SubscriptionBuiltinTopicData key_data;
        DDS::InstanceHandle_t handle = subscription->get_handle();

        DDS::ReturnCode_t retGetKey
        = bitSubscriptionDataWriter_->get_key_value(key_data,
                                                    handle);

        if (DDS::RETCODE_OK != retGetKey) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_subscription_bit ")
                     ACE_TEXT("Unable to get_key_value for subscription ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     subscription,
                     handle,
                     retGetKey));
        }

        DDS::ReturnCode_t retDispose =
          bitSubscriptionDataWriter_->dispose(key_data,
                                              handle);

        if (DDS::RETCODE_OK != retDispose) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_subscription_bit ")
                     ACE_TEXT("Unable to dispose for subscription ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     subscription,
                     handle,
                     retDispose));
        }

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::dispose_subscription_bit:");
      }
    }
  }

#else
  ACE_UNUSED_ARG(subscription);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

dispose_topic_bit()

void DCPS_IR_Domain::dispose_topic_bit

(

DCPS_IR_Topic *

topic

)

Dispose Topic in the Topic Built-In Topic.

Definition at line 1314 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_TEXT(), bitTopicDataWriter_, DCPS_IR_Topic::get_handle(), DCPS_IR_Topic::is_bit(), LM_ERROR, DDS::RETCODE_OK, and useBIT_.

Referenced by remove_topic().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    if (!topic->is_bit()) {
      try {
        DDS::TopicBuiltinTopicData key_data;
        DDS::InstanceHandle_t handle = topic->get_handle();

        DDS::ReturnCode_t retGetKey
        = bitTopicDataWriter_->get_key_value(key_data,
                                             handle);

        if (DDS::RETCODE_OK != retGetKey) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_topic_bit ")
                     ACE_TEXT("Unable to get_key_value for topic ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     topic,
                     handle,
                     retGetKey));
        }

        DDS::ReturnCode_t retDispose =
          bitTopicDataWriter_->dispose(key_data,
                                       handle);

        if (DDS::RETCODE_OK != retDispose) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::dispose_topic_bit ")
                     ACE_TEXT("Unable to dispose for topic ptr 0x%x handle %d.  ")
                     ACE_TEXT("Call returned %d.\n"),
                     topic,
                     handle,
                     retDispose));
        }

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::dispose_topic_bit:");
      }
    }
  }

#else
  ACE_UNUSED_ARG(topic);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

dump_to_string()

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

Definition at line 1470 of file DCPS_IR_Domain.cpp.

References deadParticipants_, id_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, participants_, topicDescriptions_, and useBIT_.

{
  std::string str;
#if !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
  for (int i=0; i < depth; i++)
    str += prefix;
  std::string indent = str + prefix;
  std::ostringstream os;
  os << "DCPS_IR_Domain[" << id_ << "]";
  str += os.str();
  if (useBIT_)
    str += " BITS";
  str += "\n";

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

  str += indent + "Dead Participants:\n";
  for (DCPS_IR_Participant_Set::const_iterator dp = deadParticipants_.begin();
       dp != deadParticipants_.end();
       dp++)
  {
    OpenDDS::DCPS::RepoIdConverter sub_converter((*dp)->get_id());
    str += indent + std::string(sub_converter);
    str += "\n";
  }

  str += indent + "Topic Descriptions:\n";
  for (DCPS_IR_Topic_Description_Set::const_iterator tdi = topicDescriptions_.begin();
       tdi != topicDescriptions_.end();
       tdi++)
  {
    str += tdi->second->dump_to_string(prefix, depth+1);
  }
#endif // !defined (OPENDDS_INFOREPO_REDUCED_FOOTPRINT)
  return str;
}

find_topic() [1/2]

OpenDDS::DCPS::TopicStatus DCPS_IR_Domain::find_topic	(	const char *	topicName,
		DCPS_IR_Topic *&	topic
	)

Find the topic with the topic name Does NOT take ownership of any initial memory pointed to by topic Returns OpenDDS::DCPS::FOUND if exists and topic is changed, -1 otherwise

Definition at line 330 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::FOUND, DCPS_IR_Topic::get_id(), id_, LM_DEBUG, OpenDDS::DCPS::NOT_FOUND, and topicDescriptions_.

{
  DCPS_IR_Topic_Description_Set::iterator which
  = this->topicDescriptions_.find(topicName);

  if (which != this->topicDescriptions_.end()) {
    // Extract the topic from the description.
    topic = which->second->get_first_topic();

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::GUID_t topicId = topic->get_id();
      OpenDDS::DCPS::RepoIdConverter converter(topicId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Domain::find_topic: ")
                 ACE_TEXT("located topic %C in domain %d.\n"),
                 std::string(converter).c_str(),
                 id_));
    }

    return OpenDDS::DCPS::FOUND;

  } else {
    // topic = 0;
    return OpenDDS::DCPS::NOT_FOUND;
  }
}

find_topic() [2/2]

DCPS_IR_Topic * DCPS_IR_Domain::find_topic

(

const OpenDDS::DCPS::GUID_t &

id

)

Find a topic object reference using the topic Id value.

Definition at line 358 of file DCPS_IR_Domain.cpp.

References idToTopicMap_.

{
  IdToTopicMap::const_iterator location = this->idToTopicMap_.find(id);

  if (location == this->idToTopicMap_.end()) {
    return 0;
  }

  return location->second.get();
}

find_topic_description()

int DCPS_IR_Domain::find_topic_description ( const char *  name, const char *  dataTypeName, DCPS_IR_Topic_Description *&  desc  )

private

Find the topic description with the name and data type name Does NOT take ownership of any initial memory pointed to by desc Returns 0 if found and desc is changed, -1 if not found and 1 if conflicting dataTypeName

Definition at line 418 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, id_, init_built_in_topics(), LM_DEBUG, LM_NOTICE, ACE_OS::strcmp(), and topicDescriptions_.

Referenced by add_topic_description(), and add_topic_i().

{
  DCPS_IR_Topic_Description_Set::iterator which
  = this->topicDescriptions_.find(name);

  if (which != this->topicDescriptions_.end()) {
    if (0 == ACE_OS::strcmp(dataTypeName, which->second->get_dataTypeName())) {
      if (OpenDDS::DCPS::DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) DCPS_IR_Domain::find_topic_description: ")
                   ACE_TEXT("located topic description %C/%C in domain %d.\n"),
                   name,
                   dataTypeName,
                   id_));
      }

      desc = which->second.get();
      return 0;

    } else {
      if (OpenDDS::DCPS::DCPS_debug_level > 0) {
        ACE_DEBUG((LM_NOTICE,
                   ACE_TEXT("(%P|%t) NOTICE: DCPS_IR_Domain::find_topic_description: ")
                   ACE_TEXT("searching for topic description %C/%C, ")
                   ACE_TEXT("located topic description %C/%C instead in domain %d.\n"),
                   name,
                   dataTypeName,
                   which->second->get_name(),
                   which->second->get_dataTypeName(),
                   id_));
      }

      // desc = 0;
      return 1;
    }

  } else {
    // desc = 0;
    return -1;
  }
}

force_add_topic()

OpenDDS::DCPS::TopicStatus DCPS_IR_Domain::force_add_topic	(	const OpenDDS::DCPS::GUID_t &	topicId,
		const char *	topicName,
		const char *	dataTypeName,
		const DDS::TopicQos &	qos,
		DCPS_IR_Participant *	participantPtr
	)

Add a topic to the domain Returns OpenDDS::DCPS::CREATED if successful

Definition at line 178 of file DCPS_IR_Domain.cpp.

References add_topic_i(), and OpenDDS::DCPS::topicIsBIT().

{
  OpenDDS::DCPS::GUID_t topic_id = topicId;
  bool isBIT = OpenDDS::DCPS::topicIsBIT(topicName, dataTypeName);
  OpenDDS::DCPS::TopicStatus status = add_topic_i(topic_id, topicName
                                                  , dataTypeName
                                                  , qos, participantPtr, isBIT);

  return status;
}

get_id()

DDS::DomainId_t DCPS_IR_Domain::get_id

(

void

)

Definition at line 1006 of file DCPS_IR_Domain.cpp.

References id_.

Referenced by DCPS_IR_Participant::remove_all_dependents(), and DCPS_IR_Participant::takeOwnership().

{
  return id_;
}

get_next_participant_id()

OpenDDS::DCPS::GUID_t DCPS_IR_Domain::get_next_participant_id

(

)

Next Entity Id value in sequence.

Definition at line 1012 of file DCPS_IR_Domain.cpp.

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

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant().

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

init_built_in_topics()

int DCPS_IR_Domain::init_built_in_topics	(	bool	federated,
		bool	persistent
	)

Initialize the Built-In Topic structures This needs to be called before the run begins Returns 0 (zero) if successful

Definition at line 469 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), bitParticipant_, bitParticipantFactory_, bitParticipantListener_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DEFAULT_STATUS_MASK, id_, init_built_in_topics_datawriters(), init_built_in_topics_topics(), init_built_in_topics_transport(), CORBA::is_nil(), LM_DEBUG, LM_ERROR, PARTICIPANT_QOS_DEFAULT, reassociate_built_in_topic_pubs(), TheParticipantFactory, TheTransientKludge, and useBIT_.

Referenced by TAO_DDS_DCPSInfo_i::domain(), and find_topic_description().

{
  // Indicates that BIT subscriber and datareaders should not be created.
  TheTransientKludge->enable();

  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Domain::init_built_in_topics() ")
               ACE_TEXT(" Initializing Built In Topics for domain %d\n"),
               id_));
  }

  try {
    bitParticipantFactory_ = TheParticipantFactory;

    bitParticipantListener_ = new OPENDDS_DCPS_DomainParticipantListener_i;

    bitParticipant_ =
      bitParticipantFactory_->create_participant(id_,
                                                 PARTICIPANT_QOS_DEFAULT,
                                                 bitParticipantListener_.in(),
                                                 OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitParticipant_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil DomainParticipant in ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }


    int transportResult = init_built_in_topics_transport(persistent);

    if (0 != transportResult) {
      return transportResult;
    }

    int topicsResult = init_built_in_topics_topics();

    if (0 != topicsResult) {
      return topicsResult;
    }

    int datawritersResult = init_built_in_topics_datawriters(federated);

    if (0 != datawritersResult) {
      return datawritersResult;
    }

  } catch (const CORBA::Exception& ex) {
    ex._tao_print_exception("ERROR: Exception caught in DCPS_IR_Domain::init_built_in-topics()");
    return 1;
  }

  // enable the Built-In Topics
  useBIT_ = true;
  return 0;
}

init_built_in_topics_datawriters()

int DCPS_IR_Domain::init_built_in_topics_datawriters ( bool  federated )

private

work of initializing the built in topics is done in these private methods. They were broken up for readability.

Definition at line 705 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR_RETURN, ACE_TEXT(), bitParticipantDataWriter_, bitParticipantTopic_, bitPublicationDataWriter_, bitPublicationTopic_, bitPublisher_, bitSubscriptionDataWriter_, bitSubscriptionTopic_, bitTopicDataWriter_, bitTopicTopic_, OpenDDS::DCPS::DEFAULT_STATUS_MASK, DDS::DataWriterQos::durability, CORBA::is_nil(), DDS::DurabilityQosPolicy::kind, DDS::LivelinessQosPolicy::lease_duration, DDS::DataWriterQos::liveliness, LM_ERROR, DDS::Duration_t::nanosec, DDS::Duration_t::sec, TheServiceParticipant, and DDS::TRANSIENT_LOCAL_DURABILITY_QOS.

Referenced by init_built_in_topics(), and init_built_in_topics_topics().

{

  try {
    DDS::DataWriter_var datawriter;

    DDS::DataWriterQos participantWriterQos;
    bitPublisher_->get_default_datawriter_qos(participantWriterQos);
    participantWriterQos.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;

    if (federated) {
      participantWriterQos.liveliness.lease_duration.nanosec = 0;
      participantWriterQos.liveliness.lease_duration.sec
      = TheServiceParticipant->federation_liveliness();
    }

    // Participant DataWriter
    datawriter =
      bitPublisher_->create_datawriter(bitParticipantTopic_.in(),
                                       participantWriterQos,
                                       DDS::DataWriterListener::_nil(),
                                       OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    bitParticipantDataWriter_ =
      DDS::ParticipantBuiltinTopicDataDataWriter::_narrow(datawriter.in());

    if (CORBA::is_nil(bitParticipantDataWriter_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil DomainParticipant DataWriter from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }

    DDS::DataWriterQos dw_qos;
    bitPublisher_->get_default_datawriter_qos(dw_qos);
    dw_qos.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;

    // Topic DataWriter
    datawriter =
      bitPublisher_->create_datawriter(bitTopicTopic_.in(),
                                       dw_qos,
                                       DDS::DataWriterListener::_nil(),
                                       OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    bitTopicDataWriter_ =
      DDS::TopicBuiltinTopicDataDataWriter::_narrow(datawriter.in());

    if (CORBA::is_nil(bitTopicDataWriter_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil Topic DataWriter from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }

    // Subscription DataWriter
    datawriter =
      bitPublisher_->create_datawriter(bitSubscriptionTopic_.in(),
                                       dw_qos,
                                       DDS::DataWriterListener::_nil(),
                                       OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    bitSubscriptionDataWriter_ =
      DDS::SubscriptionBuiltinTopicDataDataWriter::_narrow(
        datawriter.in());

    if (CORBA::is_nil(bitSubscriptionDataWriter_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil Subscription DataWriter from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }

    // Publication DataWriter
    datawriter =
      bitPublisher_->create_datawriter(bitPublicationTopic_.in(),
                                       dw_qos,
                                       DDS::DataWriterListener::_nil(),
                                       OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    bitPublicationDataWriter_ =
      DDS::PublicationBuiltinTopicDataDataWriter::_narrow(datawriter.in());

    if (CORBA::is_nil(bitPublicationDataWriter_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil Publication DataWriter from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }

  } catch (const CORBA::Exception& ex) {
    ex._tao_print_exception(
      "ERROR: Exception caught in DCPS_IR_Domain::init_built_in_topics_datawriters:");
    return 1;
  }
  return 0;
}

init_built_in_topics_topics()

int DCPS_IR_Domain::init_built_in_topics_topics ( )

private

work of initializing the built in topics is done in these private methods. They were broken up for readability.

Definition at line 565 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_ERROR_RETURN, ACE_TEXT(), bitParticipant_, bitParticipantTopic_, bitPublicationTopic_, bitSubscriptionTopic_, bitTopicTopic_, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE, OpenDDS::DCPS::DEFAULT_STATUS_MASK, init_built_in_topics_datawriters(), CORBA::is_nil(), LM_ERROR, and DDS::RETCODE_OK.

Referenced by init_built_in_topics().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  try {
    DDS::TopicQos topic_qos;
    bitParticipant_->get_default_topic_qos(topic_qos);

    // Participant topic
    DDS::ParticipantBuiltinTopicDataTypeSupport_var
    participantTypeSupport(new DDS::ParticipantBuiltinTopicDataTypeSupportImpl());

    if (DDS::RETCODE_OK !=
        participantTypeSupport->register_type(bitParticipant_.in(),
                                              OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE)) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: Failed to register the ParticipantBuiltinTopicDataTypeSupport.")));
      return 1;
    }

    bitParticipantTopic_ =
      bitParticipant_->create_topic(OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC,
                                    OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE,
                                    topic_qos,
                                    DDS::TopicListener::_nil(),
                                    OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitParticipantTopic_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil %C Topic from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n"),
                        OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC),
                       1);
    }

    // Topic topic
    DDS::TopicBuiltinTopicDataTypeSupport_var
    topicTypeSupport(new DDS::TopicBuiltinTopicDataTypeSupportImpl());

    if (DDS::RETCODE_OK !=
        topicTypeSupport->register_type(bitParticipant_.in(),
                                        OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE)) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: Failed to register the TopicBuiltinTopicDataTypeSupport.")));
      return 1;
    }

    bitTopicTopic_ =
      bitParticipant_->create_topic(OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC,
                                    OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE,
                                    topic_qos,
                                    DDS::TopicListener::_nil(),
                                    OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitTopicTopic_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil %C Topic from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n"),
                        OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC),
                       1);
    }

    // Subscription topic
    DDS::SubscriptionBuiltinTopicDataTypeSupport_var
    subscriptionTypeSupport(new DDS::SubscriptionBuiltinTopicDataTypeSupportImpl());

    if (DDS::RETCODE_OK !=
        subscriptionTypeSupport->register_type(bitParticipant_.in(),
                                               OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE)) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: Failed to register the SubscriptionBuiltinTopicDataTypeSupport.")));
      return 1;
    }

    bitSubscriptionTopic_ =
      bitParticipant_->create_topic(OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC,
                                    OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE,
                                    topic_qos,
                                    DDS::TopicListener::_nil(),
                                    OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitSubscriptionTopic_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil %C Topic from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n"),
                        OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC),
                       1);
    }

    // Publication topic
    DDS::PublicationBuiltinTopicDataTypeSupport_var
    publicationTypeSupport(new DDS::PublicationBuiltinTopicDataTypeSupportImpl());

    if (DDS::RETCODE_OK !=
        publicationTypeSupport->register_type(bitParticipant_.in(),
                                              OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE)) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: Failed to register the PublicationBuiltinTopicDataTypeSupport.")));
      return 1;
    }

    bitPublicationTopic_ =
      bitParticipant_->create_topic(OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC,
                                    OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE,
                                    topic_qos,
                                    DDS::TopicListener::_nil(),
                                    OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitPublicationTopic_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil %C Topic from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n"),
                        OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC),
                       1);
    }

  } catch (const CORBA::Exception& ex) {
    ex._tao_print_exception(
      "ERROR: Exception caught in DCPS_IR_Domain::init_built_in_topics_topics:");
    return 1;
  }

  return 0;

#else

  return 1;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

init_built_in_topics_transport()

int DCPS_IR_Domain::init_built_in_topics_transport ( bool  persistent )

private

work of initializing the built in topics is done in these private methods. They were broken up for readability.

Definition at line 807 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR_RETURN, ACE_TEXT(), DDS::WriterDataLifecycleQosPolicy::autodispose_unregistered_instances, OpenDDS::DCPS::TransportRegistry::bind_config(), bitParticipant_, bitPublisher_, OpenDDS::DCPS::TransportRegistry::DEFAULT_INST_PREFIX, OpenDDS::DCPS::DEFAULT_STATUS_MASK, OpenDDS::DCPS::TransportRegistry::get_config(), OpenDDS::DCPS::TransportRegistry::instance(), CORBA::is_nil(), LM_ERROR, PUBLISHER_QOS_DEFAULT, transportConfig_, and DDS::DataWriterQos::writer_data_lifecycle.

Referenced by init_built_in_topics().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  try {
    std::string config_name =
      OpenDDS::DCPS::TransportRegistry::DEFAULT_INST_PREFIX
      + std::string("InfoRepoBITTransportConfig");
    transportConfig_ =
      OpenDDS::DCPS::TransportRegistry::instance()->get_config(config_name);

    // Create the Publisher
    bitPublisher_ =
      bitParticipant_->create_publisher(PUBLISHER_QOS_DEFAULT,
                                        DDS::PublisherListener::_nil(),
                                        OpenDDS::DCPS::DEFAULT_STATUS_MASK);

    if (CORBA::is_nil(bitPublisher_.in())) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ")
                        ACE_TEXT("Nil Publisher from ")
                        ACE_TEXT("DCPS_IR_Domain::init_built_in_topics.\n")),
                       1);
    }

    // If persistence is active, do not have remote readers autodispose data
    if (persistent) {
      DDS::DataWriterQos qos;
      bitPublisher_->get_default_datawriter_qos(qos);
      qos.writer_data_lifecycle.autodispose_unregistered_instances = false;
      bitPublisher_->set_default_datawriter_qos(qos);
    }

    // Attach the Publisher with the TransportImpl.
    OpenDDS::DCPS::TransportRegistry::instance()->bind_config(transportConfig_,
                                                              bitPublisher_.in());

  } catch (const CORBA::Exception& ex) {
    ex._tao_print_exception(
      "ERROR: Exception caught in DCPS_IR_Domain::init_built_in_topics_transport:");
    return 1;
  }

  return 0;
#else
  ACE_UNUSED_ARG (persistent);
  return 1;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

last_participant_key()

void DCPS_IR_Domain::last_participant_key

(

long

key

)

Ensure no conflicts with sequence values from persistent storage.

Definition at line 1018 of file DCPS_IR_Domain.cpp.

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

{
  this->participantIdGenerator_.last(key);
}

participant()

DCPS_IR_Participant * DCPS_IR_Domain::participant

(

const OpenDDS::DCPS::GUID_t &

id

)

const

Find the participant with the id.

Definition at line 69 of file DCPS_IR_Domain.cpp.

References OpenDDS::DCPS::RcHandle< T >::in(), and participant_rch().

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant(), TAO_DDS_DCPSInfo_i::add_subscription(), and remove_participant().

{
  DCPS_IR_Participant_rch p = participant_rch(id);
  return p ? p.in() : 0;
}

participant_rch()

DCPS_IR_Participant_rch DCPS_IR_Domain::participant_rch

(

const OpenDDS::DCPS::GUID_t &

id

)

const

Definition at line 56 of file DCPS_IR_Domain.cpp.

References participants_.

Referenced by participant().

{
  DCPS_IR_Participant_Map::const_iterator where = participants_.find(id);

  if (where != participants_.end()) {
    return where->second;

  } else {
    return DCPS_IR_Participant_rch();
  }
}

participants()

const DCPS_IR_Participant_Map & DCPS_IR_Domain::participants

(

)

const

Expose a readable reference to the participant map.

Definition at line 51 of file DCPS_IR_Domain.cpp.

References participants_.

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant().

{
  return this->participants_;
}

publish_participant_bit()

void DCPS_IR_Domain::publish_participant_bit

(

DCPS_IR_Participant *

participant

)

Publish Participant in the Participant Built-In Topic.

Definition at line 1023 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, OpenDDS::DCPS::bit_key_to_guid(), bitParticipantDataWriter_, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, DCPS_IR_Participant::get_id(), DCPS_IR_Participant::get_qos(), OpenDDS::DCPS::guid_to_bit_key(), DCPS_IR_Participant::isBitPublisher(), LM_DEBUG, DCPS_IR_Participant::set_handle(), useBIT_, and DDS::DomainParticipantQos::user_data.

Referenced by add_participant(), and DCPS_IR_Participant::set_qos().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_ && !participant->isBitPublisher()) {
    try {
      const DDS::DomainParticipantQos* participantQos = participant->get_qos();

      DDS::ParticipantBuiltinTopicData data;
      data.key = guid_to_bit_key(participant->get_id());
      data.user_data = participantQos->user_data;

      DDS::InstanceHandle_t handle = bitParticipantDataWriter_->register_instance(data);

      participant->set_handle(handle);

      if (OpenDDS::DCPS::DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   "(%P|%t) DCPS_IR_Domain::publish_participant_bit: %C, handle %d.\n",
                   OpenDDS::DCPS::LogGuid(OpenDDS::DCPS::bit_key_to_guid(data.key)).c_str(), handle));
      }

      bitParticipantDataWriter_->write(data, handle);

    } catch (const CORBA::Exception& ex) {
      ex._tao_print_exception(
        "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::publish_participant_bit:");
    }
  }

#else
  ACE_UNUSED_ARG(participant);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

publish_publication_bit()

void DCPS_IR_Domain::publish_publication_bit

(

DCPS_IR_Publication *

publication

)

Publish Publication in the Publication Built-In Topic.

Definition at line 1186 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, OpenDDS::DCPS::bit_key_to_guid(), bitPublicationDataWriter_, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, DDS::DataWriterQos::deadline, DDS::DataWriterQos::destination_order, DDS::DataWriterQos::durability, DDS::DataWriterQos::durability_service, DCPS_IR_Topic_Description::get_dataTypeName(), DCPS_IR_Publication::get_datawriter_qos(), DCPS_IR_Publication::get_id(), DCPS_IR_Topic_Description::get_name(), DCPS_IR_Publication::get_participant_id(), DCPS_IR_Publication::get_publisher_qos(), DCPS_IR_Publication::get_topic(), DCPS_IR_Publication::get_topic_description(), DCPS_IR_Topic::get_topic_qos(), DDS::PublisherQos::group_data, OpenDDS::DCPS::guid_to_bit_key(), DDS::DataWriterQos::latency_budget, DDS::DataWriterQos::lifespan, DDS::DataWriterQos::liveliness, LM_DEBUG, LM_ERROR, DDS::DataWriterQos::ownership, DDS::DataWriterQos::ownership_strength, DDS::PublisherQos::partition, DDS::PublisherQos::presentation, DDS::DataWriterQos::reliability, DDS::RETCODE_OK, DCPS_IR_Publication::set_bit_status(), DCPS_IR_Publication::set_handle(), ACE_OS::strcmp(), DDS::TopicQos::topic_data, useBIT_, and DDS::DataWriterQos::user_data.

Referenced by DCPS_IR_Topic::add_publication_reference(), DCPS_IR_Publication::set_qos(), and DCPS_IR_Topic::set_topic_qos().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {

    DCPS_IR_Topic_Description* desc =
      publication->get_topic_description();

    const char* dataTypeName = desc->get_dataTypeName();

    bool isNotBIT =
      ACE_OS::strcmp(dataTypeName, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE) &&
      ACE_OS::strcmp(dataTypeName, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE) &&
      ACE_OS::strcmp(dataTypeName, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE) &&
      ACE_OS::strcmp(dataTypeName, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE);

    if (isNotBIT) {
      try {
        const DDS::DataWriterQos* writerQos = publication->get_datawriter_qos();
        const DDS::PublisherQos* publisherQos = publication->get_publisher_qos();

        DCPS_IR_Topic* topic = publication->get_topic();
        const DDS::TopicQos* topicQos = topic->get_topic_qos();

        DDS::PublicationBuiltinTopicData data;
        data.key = guid_to_bit_key(publication->get_id());
        data.participant_key = guid_to_bit_key(publication->get_participant_id());
        data.topic_name = desc->get_name();
        data.type_name = desc->get_dataTypeName();
        data.durability = writerQos->durability;
        data.durability_service = writerQos->durability_service;
        data.deadline = writerQos->deadline;
        data.latency_budget = writerQos->latency_budget;
        data.liveliness = writerQos->liveliness;
        data.reliability = writerQos->reliability;
        data.lifespan = writerQos->lifespan;
        data.user_data = writerQos->user_data;
        data.ownership = writerQos->ownership;
        data.ownership_strength = writerQos->ownership_strength;
        data.destination_order = writerQos->destination_order;
        data.presentation = publisherQos->presentation;
        data.partition = publisherQos->partition;
        data.topic_data = topicQos->topic_data;
        data.group_data = publisherQos->group_data;

        DDS::InstanceHandle_t handle
        = bitPublicationDataWriter_->register_instance(data);

        publication->set_handle(handle);

        if (OpenDDS::DCPS::DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     "(%P|%t) DCPS_IR_Domain::publish_publication_bit: %C, handle %d.\n",
                     OpenDDS::DCPS::LogGuid(OpenDDS::DCPS::bit_key_to_guid(data.key)).c_str(), handle));
        }

        DDS::ReturnCode_t status = bitPublicationDataWriter_->write(data, handle);
        if (status != DDS::RETCODE_OK) {
          ACE_ERROR((LM_ERROR,
                       "(%P|%t) DCPS_IR_Domain::publish_publication_bit: write() status of %d\n",
                       status));
        }

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::publish_publication_bit:");
      }

    } else {
      publication->set_bit_status(1);
    }
  }

#else
  ACE_UNUSED_ARG(publication);
#endif // !defined (DDS_HAS_MINIMUM_BIT)

}

publish_subscription_bit()

void DCPS_IR_Domain::publish_subscription_bit

(

DCPS_IR_Subscription *

subscription

)

Publish Subscription in the Subscription Built-In Topic.

Definition at line 1118 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, OpenDDS::DCPS::bit_key_to_guid(), bitSubscriptionDataWriter_, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, DDS::DataReaderQos::deadline, DDS::DataReaderQos::destination_order, DDS::DataReaderQos::durability, DCPS_IR_Subscription::get_datareader_qos(), DCPS_IR_Topic_Description::get_dataTypeName(), DCPS_IR_Subscription::get_id(), DCPS_IR_Topic_Description::get_name(), DCPS_IR_Subscription::get_participant_id(), DCPS_IR_Subscription::get_subscriber_qos(), DCPS_IR_Subscription::get_topic(), DCPS_IR_Subscription::get_topic_description(), DCPS_IR_Topic::get_topic_qos(), DDS::SubscriberQos::group_data, OpenDDS::DCPS::guid_to_bit_key(), DDS::DataReaderQos::latency_budget, DDS::DataReaderQos::liveliness, LM_DEBUG, name, DDS::DataReaderQos::ownership, DDS::SubscriberQos::partition, DDS::SubscriberQos::presentation, DDS::DataReaderQos::reliability, DCPS_IR_Subscription::set_bit_status(), DCPS_IR_Subscription::set_handle(), DDS::DataReaderQos::time_based_filter, DDS::TopicQos::topic_data, OpenDDS::DCPS::topicIsBIT(), useBIT_, and DDS::DataReaderQos::user_data.

Referenced by DCPS_IR_Topic_Description::add_subscription_reference(), DCPS_IR_Subscription::set_qos(), and DCPS_IR_Topic::set_topic_qos().

{

#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    DCPS_IR_Topic_Description* desc =
      subscription->get_topic_description();
    const char* name = desc->get_name();
    const char* type = desc->get_dataTypeName();

    if (!OpenDDS::DCPS::topicIsBIT(name, type)) {
      try {
        const DDS::DataReaderQos* readerQos = subscription->get_datareader_qos();
        const DDS::SubscriberQos* publisherQos = subscription->get_subscriber_qos();

        DCPS_IR_Topic* topic = subscription->get_topic();
        const DDS::TopicQos* topicQos = topic->get_topic_qos();

        DDS::SubscriptionBuiltinTopicData data;
        data.key = guid_to_bit_key(subscription->get_id());
        data.participant_key = guid_to_bit_key(subscription->get_participant_id());
        data.topic_name = name;
        data.type_name = type;
        data.durability = readerQos->durability;
        data.deadline = readerQos->deadline;
        data.latency_budget = readerQos->latency_budget;
        data.liveliness = readerQos->liveliness;
        data.reliability = readerQos->reliability;
        data.ownership = readerQos->ownership;
        data.destination_order = readerQos->destination_order;
        data.user_data = readerQos->user_data;
        data.time_based_filter = readerQos->time_based_filter;
        data.presentation = publisherQos->presentation;
        data.partition = publisherQos->partition;
        data.topic_data = topicQos->topic_data;
        data.group_data = publisherQos->group_data;

        DDS::InstanceHandle_t handle
        = bitSubscriptionDataWriter_->register_instance(data);

        subscription->set_handle(handle);

        if (OpenDDS::DCPS::DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     "(%P|%t) DCPS_IR_Domain::publish_subscription_bit: %C, handle %d.\n",
                     OpenDDS::DCPS::LogGuid(OpenDDS::DCPS::bit_key_to_guid(data.key)).c_str(), handle));
        }

        bitSubscriptionDataWriter_->write(data,
                                          handle);

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::publish_subscription_bit:");
      }

    } else {
      subscription->set_bit_status(1);
    }
  }

#else
  ACE_UNUSED_ARG(subscription);
#endif // !defined (DDS_HAS_MINIMUM_BIT)

}

publish_topic_bit()

void DCPS_IR_Domain::publish_topic_bit

(

DCPS_IR_Topic *

topic

)

Publish Topic in the Topic Built-In Topic.

Definition at line 1058 of file DCPS_IR_Domain.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, OpenDDS::DCPS::bit_key_to_guid(), bitTopicDataWriter_, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, DDS::TopicQos::deadline, DDS::TopicQos::destination_order, DDS::TopicQos::durability, DDS::TopicQos::durability_service, DCPS_IR_Topic_Description::get_dataTypeName(), DCPS_IR_Topic::get_id(), DCPS_IR_Topic_Description::get_name(), DCPS_IR_Topic::get_topic_description(), DCPS_IR_Topic::get_topic_qos(), OpenDDS::DCPS::guid_to_bit_key(), DDS::TopicQos::history, DDS::TopicQos::latency_budget, DDS::TopicQos::lifespan, DDS::TopicQos::liveliness, LM_DEBUG, name, DDS::TopicQos::ownership, DDS::TopicQos::reliability, DDS::TopicQos::resource_limits, DCPS_IR_Topic::set_bit_status(), DCPS_IR_Topic::set_handle(), DDS::TopicQos::topic_data, OpenDDS::DCPS::topicIsBIT(), DDS::TopicQos::transport_priority, and useBIT_.

Referenced by add_topic_i(), and DCPS_IR_Topic::set_topic_qos().

{
#if !defined (DDS_HAS_MINIMUM_BIT)

  if (useBIT_) {
    DCPS_IR_Topic_Description* desc =
      topic->get_topic_description();
    const char* name = desc->get_name();
    const char* type = desc->get_dataTypeName();

    if (!OpenDDS::DCPS::topicIsBIT(name, type)) {
      try {
        const DDS::TopicQos* topicQos = topic->get_topic_qos();

        DDS::TopicBuiltinTopicData data;
        data.key = guid_to_bit_key(topic->get_id());
        data.name = name;
        data.type_name = type;
        data.durability = topicQos->durability;
        data.durability_service = topicQos->durability_service;
        data.deadline = topicQos->deadline;
        data.latency_budget = topicQos->latency_budget;
        data.liveliness = topicQos->liveliness;
        data.reliability = topicQos->reliability;
        data.transport_priority = topicQos->transport_priority;
        data.lifespan = topicQos->lifespan;
        data.destination_order = topicQos->destination_order;
        data.history = topicQos->history;
        data.resource_limits = topicQos->resource_limits;
        data.ownership = topicQos->ownership;
        data.topic_data = topicQos->topic_data;

        DDS::InstanceHandle_t handle =
          bitTopicDataWriter_->register_instance(data);

        topic->set_handle(handle);

        if (OpenDDS::DCPS::DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     "(%P|%t) DCPS_IR_Domain::publish_topic_bit: %C, handle %d.\n",
                     OpenDDS::DCPS::LogGuid(OpenDDS::DCPS::bit_key_to_guid(data.key)).c_str(), handle));
        }

        bitTopicDataWriter_->write(data, handle);

      } catch (const CORBA::Exception& ex) {
        ex._tao_print_exception(
          "(%P|%t) ERROR: Exception caught in DCPS_IR_Domain::publish_topic_bit:");
      }

    } else {
      topic->set_bit_status(1);
    }
  }

#else
  ACE_UNUSED_ARG(topic);
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

reassociate_built_in_topic_pubs()

int DCPS_IR_Domain::reassociate_built_in_topic_pubs

(

)

Reassociate the Built-In Topic datawriters This needs to be called after reincarnating from persistence and before the run begins Returns 0 (zero) if successful

Definition at line 536 of file DCPS_IR_Domain.cpp.

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

Referenced by init_built_in_topics().

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DCPS_IR_Domain::reassociate_built_in_topic_pubs() ")
               ACE_TEXT(" Re-associating Built In Topics for domain %d\n"),
               id_));
  }

  DCPS_IR_Participant_Map::iterator participantIter = participants_.begin();
  DCPS_IR_Participant_Map::iterator end = participants_.end();
  while (participantIter != end
         && !participantIter->second->isBitPublisher() ) {
    participantIter++;
  }

  if (participantIter != end) {
    for (DCPS_IR_Topic_Map::const_iterator topicIter
           = participantIter->second->topics().begin();
           topicIter != participantIter->second->topics().end();
           ++topicIter) {
      topicIter->second->reassociate_all_publications();
    }
  }

  return 0;
}

remove_dead_participants()

void DCPS_IR_Domain::remove_dead_participants

(

bool

part_of_cleanup = false

)

Remove any participants currently marked as dead.

Definition at line 971 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_ERROR, dead, deadParticipants_, OpenDDS::DCPS::RcHandle< T >::in(), LM_DEBUG, LM_WARNING, and remove_participant().

Referenced by TAO_DDS_DCPSInfo_i::add_subscription().

{
  if (0 < deadParticipants_.size()) {
    DCPS_IR_Participant_rch dead;
    DCPS_IR_Participant_Set::iterator iter = deadParticipants_.begin();

    // repeat end() due to the value possibly changing from additional dead
    // participants during notifications
    while (iter != deadParticipants_.end()) {
      dead = *iter;
      ++iter;

      if (part_of_cleanup) {
        // If part of cleanup, then this is expected, especially if this is
        // part of a test that failed.
        ACE_DEBUG((LM_DEBUG,
                   "(%P|%t) DCPS_IR_Domain::remove_dead_participants: "
                   "Removing dead participant 0x%x id %C\n",
                   dead.in(),
                   LogGuid(dead->get_id()).c_str()));
      } else {
        ACE_ERROR((LM_WARNING,
                   "(%P|%t) WARNING: DCPS_IR_Domain::remove_dead_participants: "
                   "Removing dead participant 0x%x id %C\n",
                   dead.in(),
                   LogGuid(dead->get_id()).c_str()));
      }

      deadParticipants_.erase(dead);
      dead->set_alive(false);
      remove_participant(dead->get_id(), true);
    }
  }
}

remove_participant()

int DCPS_IR_Domain::remove_participant	(	const OpenDDS::DCPS::GUID_t &	particpantId,
		CORBA::Boolean	notify_lost
	)

Remove the particpant The participant has been deleted if returns successful. Returns 0 if successful. The notify_lost parameter is passed to the remove_associations() See the comments of remove_associations() in DataWriterRemote.idl or DataReaderRemote.idl.

Definition at line 115 of file DCPS_IR_Domain.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, dispose_participant_bit(), OpenDDS::DCPS::RcHandle< T >::get(), id_, OpenDDS::DCPS::RcHandle< T >::in(), LM_DEBUG, LM_ERROR, participant(), and participants_.

Referenced by remove_dead_participants().

{
  DCPS_IR_Participant_Map::iterator where
  = this->participants_.find(participantId);

  if (where != this->participants_.end()) {
    // Extract the participant from the map.
    DCPS_IR_Participant_rch participant = where->second;

    // make sure the participant has cleaned up all publications,
    // subscriptions, and any topic references
    participant->remove_all_dependents(notify_lost);

    // Then remove it from the map.
    this->participants_.erase(where);

    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      OpenDDS::DCPS::RepoIdConverter converter(participantId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) DCPS_IR_Domain::remove_participant: ")
                 ACE_TEXT("removed participant %C at 0x%x from domain %d.\n"),
                 std::string(converter).c_str(),
                 participant.in(),
                 id_));
    }

    dispose_participant_bit(participant.get());
    return 0;

  } else {
    OpenDDS::DCPS::RepoIdConverter converter(participantId);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::remove_participant: ")
               ACE_TEXT("unable to find participant %C in domain %d.\n"),
               std::string(converter).c_str(),
               id_));
    return 1;
  }
}

remove_topic()

OpenDDS::DCPS::TopicStatus DCPS_IR_Domain::remove_topic	(	DCPS_IR_Participant *	part,
		DCPS_IR_Topic *&	topic
	)

Remove the topic The topic has been deleted if returns successful Returns OpenDDS::DCPS::REMOVED if successful

Definition at line 369 of file DCPS_IR_Domain.cpp.

References ACE_ERROR, ACE_TEXT(), dispose_topic_bit(), DCPS_IR_Topic_Description::get_dataTypeName(), DCPS_IR_Topic::get_id(), DCPS_IR_Participant::get_id(), DCPS_IR_Topic_Description::get_name(), DCPS_IR_Topic_Description::get_number_topics(), DCPS_IR_Topic::get_topic_description(), id_, LM_ERROR, DCPS_IR_Topic::release(), DCPS_IR_Topic_Description::remove_topic(), remove_topic_description(), DCPS_IR_Participant::remove_topic_reference(), and OpenDDS::DCPS::REMOVED.

Referenced by DCPS_IR_Participant::remove_all_dependents().

{
  DCPS_IR_Topic_Description* description = topic->get_topic_description();

  if (description->remove_topic(topic) != 0) {
    // An unknown error means that the description may still
    // have the topic in its topic set.  We can't remove it.
    // The system is an inconsistent state!
    throw OpenDDS::DCPS::Invalid_Topic();
  }

  if (description->get_number_topics() == 0) {
    // Remove the topic description
    if (remove_topic_description(description) != 0) {
      // An unknown error means that the description may still
      // have the topic in its topic set.
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: Topic Description %C %C  ")
                 ACE_TEXT("was not correctly removed from Domain %d"),
                 description->get_name(),
                 description->get_dataTypeName(),
                 id_));

    }
  }

  // description variable is invalid after this point

  if (part->remove_topic_reference(topic->get_id(), topic) != 0) {
    OpenDDS::DCPS::RepoIdConverter part_converter(part->get_id());
    OpenDDS::DCPS::RepoIdConverter topic_converter(topic->get_id());
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Domain %d Topic %C ")
               ACE_TEXT("was not correctly removed from Participant %C"),
               id_,
               std::string(topic_converter).c_str(),
               std::string(part_converter).c_str()));
  }

  // Dispose the BIT information
  dispose_topic_bit(topic);

  topic->release(true);
  topic = 0;
  return OpenDDS::DCPS::REMOVED;
}

remove_topic_description()

int DCPS_IR_Domain::remove_topic_description ( DCPS_IR_Topic_Description *  desc )

private

Returns 0 if successful.

Definition at line 948 of file DCPS_IR_Domain.cpp.

References ACE_ERROR, ACE_TEXT(), DCPS_IR_Topic_Description::get_name(), id_, LM_ERROR, and topicDescriptions_.

Referenced by remove_topic().

{
  DCPS_IR_Topic_Description_Set::iterator where = topicDescriptions_.find(desc->get_name());

  if (where != this->topicDescriptions_.end()) {
    this->topicDescriptions_.erase(where);
    return 0;

  } else {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Domain::remove_topic_description: ")
               ACE_TEXT("unable to remove Topic Description 0x%x from domain %d.\n"),
               desc,
               id_));
    return -1;
  }
}

remove_topic_id_mapping()

void DCPS_IR_Domain::remove_topic_id_mapping

(

const OpenDDS::DCPS::GUID_t &

topicId

)

Remove the topic from the id to topic map. This method should only be called by the DCPS_IR_Topic when deleting the topic.

Definition at line 1463 of file DCPS_IR_Domain.cpp.

References idToTopicMap_.

Referenced by DCPS_IR_Topic::release().

{
  IdToTopicMap::iterator map_entry = this->idToTopicMap_.find(topicId);
  if (map_entry != this->idToTopicMap_.end())
    idToTopicMap_.erase(map_entry);
}

useBIT()

bool DCPS_IR_Domain::useBIT ( ) const

inline

Definition at line 178 of file DCPS_IR_Domain.h.

References name.

Referenced by TAO_DDS_DCPSInfo_i::domain().

{ return useBIT_; }

Member Data Documentation

bitParticipant_

DDS::DomainParticipant_var DCPS_IR_Domain::bitParticipant_

private

Built-in Topic variables

Definition at line 247 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics(), init_built_in_topics_topics(), and init_built_in_topics_transport().

bitParticipantDataWriter_

DDS::ParticipantBuiltinTopicDataDataWriter_var DCPS_IR_Domain::bitParticipantDataWriter_

private

Built-in Topic variables

Definition at line 255 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), dispose_participant_bit(), init_built_in_topics_datawriters(), and publish_participant_bit().

bitParticipantFactory_

DDS::DomainParticipantFactory_var DCPS_IR_Domain::bitParticipantFactory_

private

Built-in Topic variables

Definition at line 246 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), and init_built_in_topics().

bitParticipantListener_

DDS::DomainParticipantListener_var DCPS_IR_Domain::bitParticipantListener_

private

Built-in Topic variables

Definition at line 248 of file DCPS_IR_Domain.h.

Referenced by init_built_in_topics().

bitParticipantTopic_

DDS::Topic_var DCPS_IR_Domain::bitParticipantTopic_

private

Built-in Topic variables

Definition at line 254 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics_datawriters(), and init_built_in_topics_topics().

bitPublicationDataWriter_

DDS::PublicationBuiltinTopicDataDataWriter_var DCPS_IR_Domain::bitPublicationDataWriter_

private

Built-in Topic variables

Definition at line 264 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), dispose_publication_bit(), init_built_in_topics_datawriters(), and publish_publication_bit().

bitPublicationTopic_

DDS::Topic_var DCPS_IR_Domain::bitPublicationTopic_

private

Built-in Topic variables

Definition at line 263 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics_datawriters(), and init_built_in_topics_topics().

bitPublisher_

DDS::Publisher_var DCPS_IR_Domain::bitPublisher_

private

Built-in Topic variables

Definition at line 249 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics_datawriters(), and init_built_in_topics_transport().

bitSubscriptionDataWriter_

DDS::SubscriptionBuiltinTopicDataDataWriter_var DCPS_IR_Domain::bitSubscriptionDataWriter_

private

Built-in Topic variables

Definition at line 261 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), dispose_subscription_bit(), init_built_in_topics_datawriters(), and publish_subscription_bit().

bitSubscriptionTopic_

DDS::Topic_var DCPS_IR_Domain::bitSubscriptionTopic_

private

Built-in Topic variables

Definition at line 260 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics_datawriters(), and init_built_in_topics_topics().

bitTopicDataWriter_

DDS::TopicBuiltinTopicDataDataWriter_var DCPS_IR_Domain::bitTopicDataWriter_

private

Built-in Topic variables

Definition at line 258 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), dispose_topic_bit(), init_built_in_topics_datawriters(), and publish_topic_bit().

bitTopicTopic_

DDS::Topic_var DCPS_IR_Domain::bitTopicTopic_

private

Built-in Topic variables

Definition at line 257 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), init_built_in_topics_datawriters(), and init_built_in_topics_topics().

deadParticipants_

DCPS_IR_Participant_Set DCPS_IR_Domain::deadParticipants_

private

the dead participants dead participants exist in both this and participants_

Definition at line 228 of file DCPS_IR_Domain.h.

Referenced by add_dead_participant(), dump_to_string(), and remove_dead_participants().

id_

DDS::DomainId_t DCPS_IR_Domain::id_

private

Definition at line 217 of file DCPS_IR_Domain.h.

Referenced by add_participant(), add_topic_description(), add_topic_i(), dump_to_string(), find_topic(), find_topic_description(), get_id(), init_built_in_topics(), reassociate_built_in_topic_pubs(), remove_participant(), remove_topic(), and remove_topic_description().

idToTopicMap_

IdToTopicMap DCPS_IR_Domain::idToTopicMap_

private

Actual mapping of Id values to Topic object references.

Definition at line 239 of file DCPS_IR_Domain.h.

Referenced by add_topic_i(), find_topic(), and remove_topic_id_mapping().

participantIdGenerator_

OpenDDS::DCPS::RepoIdGenerator& DCPS_IR_Domain::participantIdGenerator_

private

Participant GUID Id generator. The remaining Entities have their values generated within the containing Participant.

Definition at line 221 of file DCPS_IR_Domain.h.

Referenced by get_next_participant_id(), and last_participant_key().

participants_

DCPS_IR_Participant_Map DCPS_IR_Domain::participants_

private

all the participants

Definition at line 224 of file DCPS_IR_Domain.h.

Referenced by add_participant(), dump_to_string(), participant_rch(), participants(), reassociate_built_in_topic_pubs(), and remove_participant().

topicDescriptions_

DCPS_IR_Topic_Description_Set DCPS_IR_Domain::topicDescriptions_

private

all the topics

Definition at line 231 of file DCPS_IR_Domain.h.

Referenced by add_topic_description(), dump_to_string(), find_topic(), find_topic_description(), and remove_topic_description().

transportConfig_

OpenDDS::DCPS::TransportConfig_rch DCPS_IR_Domain::transportConfig_

private

Built-in Topic variables

Definition at line 252 of file DCPS_IR_Domain.h.

Referenced by init_built_in_topics_transport().

useBIT_

OpenDDS::DCPS::AtomicBool DCPS_IR_Domain::useBIT_

private

indicates if the BuiltIn Topics are enabled

Definition at line 242 of file DCPS_IR_Domain.h.

Referenced by cleanup_built_in_topics(), dispose_participant_bit(), dispose_publication_bit(), dispose_subscription_bit(), dispose_topic_bit(), dump_to_string(), init_built_in_topics(), publish_participant_bit(), publish_publication_bit(), publish_subscription_bit(), and publish_topic_bit().

---

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

• DCPS_IR_Domain.h
• DCPS_IR_Domain.cpp