OpenDDS::DCPS::Discovery Class Reference

Discovery Strategy interface class. More...

#include <Discovery.h>

Inheritance diagram for OpenDDS::DCPS::Discovery:

Collaboration diagram for OpenDDS::DCPS::Discovery:

Classes
class	Config

Public Types
typedef OPENDDS_STRING	RepoKey

Public Member Functions
	Discovery (const RepoKey &key)
virtual bool	active ()
virtual RcHandle< BitSubscriber >	init_bit (DomainParticipantImpl *participant)=0
virtual void	fini_bit (DCPS::DomainParticipantImpl *participant)=0
RepoKey	key () const
virtual bool	attach_participant (DDS::DomainId_t domainId, const GUID_t &participantId)=0
virtual OpenDDS::DCPS::GUID_t	generate_participant_guid ()=0
virtual AddDomainStatus	add_domain_participant (DDS::DomainId_t domain, const DDS::DomainParticipantQos &qos, XTypes::TypeLookupService_rch tls)=0
virtual OpenDDS::DCPS::AddDomainStatus	add_domain_participant_secure (DDS::DomainId_t domain, const DDS::DomainParticipantQos &qos, XTypes::TypeLookupService_rch tls, const OpenDDS::DCPS::GUID_t &guid, DDS::Security::IdentityHandle id, DDS::Security::PermissionsHandle perm, DDS::Security::ParticipantCryptoHandle part_crypto)=0
virtual bool	remove_domain_participant (DDS::DomainId_t domainId, const GUID_t &participantId)=0
virtual bool	ignore_domain_participant (DDS::DomainId_t domainId, const GUID_t &myParticipantId, const GUID_t &ignoreId)=0
virtual bool	update_domain_participant_qos (DDS::DomainId_t domain, const GUID_t &participantId, const DDS::DomainParticipantQos &qos)=0
virtual TopicStatus	assert_topic (GUID_t_out topicId, DDS::DomainId_t domainId, const GUID_t &participantId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, bool hasDcpsKey, TopicCallbacks *topic_callbacks)=0
virtual TopicStatus	find_topic (DDS::DomainId_t domainId, const GUID_t &participantId, const char *topicName, CORBA::String_out dataTypeName, DDS::TopicQos_out qos, GUID_t_out topicId)=0
virtual TopicStatus	remove_topic (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId)=0
virtual bool	ignore_topic (DDS::DomainId_t domainId, const GUID_t &myParticipantId, const GUID_t &ignoreId)=0
virtual bool	update_topic_qos (const GUID_t &topicId, DDS::DomainId_t domainId, const GUID_t &participantId, const DDS::TopicQos &qos)=0
virtual void	pre_writer (DataWriterImpl *)
virtual GUID_t	add_publication (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId, DataWriterCallbacks_rch publication, const DDS::DataWriterQos &qos, const TransportLocatorSeq &transInfo, const DDS::PublisherQos &publisherQos, const XTypes::TypeInformation &type_info)=0
virtual bool	remove_publication (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &publicationId)=0
virtual bool	ignore_publication (DDS::DomainId_t domainId, const GUID_t &myParticipantId, const GUID_t &ignoreId)=0
virtual bool	update_publication_qos (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &dwId, const DDS::DataWriterQos &qos, const DDS::PublisherQos &publisherQos)=0
virtual void	update_publication_locators (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &dwId, const TransportLocatorSeq &transInfo)
virtual void	pre_reader (DataReaderImpl *)
virtual GUID_t	add_subscription (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId, DataReaderCallbacks_rch subscription, const DDS::DataReaderQos &qos, const TransportLocatorSeq &transInfo, const DDS::SubscriberQos &subscriberQos, const char *filterClassName, const char *filterExpression, const DDS::StringSeq &exprParams, const XTypes::TypeInformation &type_info)=0
virtual bool	remove_subscription (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &subscriptionId)=0
virtual bool	ignore_subscription (DDS::DomainId_t domainId, const GUID_t &myParticipantId, const GUID_t &ignoreId)=0
virtual bool	update_subscription_qos (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &drId, const DDS::DataReaderQos &qos, const DDS::SubscriberQos &subscriberQos)=0
virtual bool	update_subscription_params (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &subscriptionId, const DDS::StringSeq &params)=0
virtual void	update_subscription_locators (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &drId, const TransportLocatorSeq &transInfo)
virtual bool	supports_liveliness () const
virtual void	signal_liveliness (const DDS::DomainId_t, const GUID_t &, DDS::LivelinessQosPolicyKind)
virtual void	request_remote_complete_type_objects (DDS::DomainId_t, const GUID_t &, const GUID_t &, const XTypes::TypeInformation &, TypeObjReqCond &cond)
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

Static Public Attributes
static const char *	DEFAULT_REPO = "DEFAULT_REPO"
	Key value for the default repository IOR. More...
static const char *	DEFAULT_RTPS = "DEFAULT_RTPS"
static const char *	DEFAULT_STATIC = "DEFAULT_STATIC"

Protected Member Functions
DDS::ReturnCode_t	create_bit_topics (DomainParticipantImpl *participant)
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Private Attributes
RepoKey	key_

Detailed Description

Discovery Strategy interface class.

This class is an abstract class that acts as an interface for both InfoRepo-based discovery and RTPS Discovery.

Definition at line 76 of file Discovery.h.

Member Typedef Documentation

RepoKey

typedef OPENDDS_STRING OpenDDS::DCPS::Discovery::RepoKey

Key type for storing discovery objects. Probably should just be Discovery::Key

Definition at line 80 of file Discovery.h.

Constructor & Destructor Documentation

Discovery()

OpenDDS::DCPS::Discovery::Discovery ( const RepoKey &  key )

inlineexplicit

Definition at line 82 of file Discovery.h.

: key_(key) { }

Member Function Documentation

active()

virtual bool OpenDDS::DCPS::Discovery::active ( void  )

inlinevirtual

Reimplemented in OpenDDS::DCPS::InfoRepoDiscovery.

Definition at line 90 of file Discovery.h.

{ return true; }

add_domain_participant()

virtual AddDomainStatus OpenDDS::DCPS::Discovery::add_domain_participant ( DDS::DomainId_t  domain, const DDS::DomainParticipantQos &  qos, XTypes::TypeLookupService_rch  tls  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::DCPS::InfoRepoDiscovery, and OpenDDS::RTPS::RtpsDiscovery.

add_domain_participant_secure()

virtual OpenDDS::DCPS::AddDomainStatus OpenDDS::DCPS::Discovery::add_domain_participant_secure ( DDS::DomainId_t  domain, const DDS::DomainParticipantQos &  qos, XTypes::TypeLookupService_rch  tls, const OpenDDS::DCPS::GUID_t &  guid, DDS::Security::IdentityHandle  id, DDS::Security::PermissionsHandle  perm, DDS::Security::ParticipantCryptoHandle  part_crypto  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::DCPS::InfoRepoDiscovery, and OpenDDS::RTPS::RtpsDiscovery.

add_publication()

virtual GUID_t OpenDDS::DCPS::Discovery::add_publication ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  topicId, DataWriterCallbacks_rch  publication, const DDS::DataWriterQos &  qos, const TransportLocatorSeq &  transInfo, const DDS::PublisherQos &  publisherQos, const XTypes::TypeInformation &  type_info  )

pure virtual

add the passed in publication into discovery. Discovery does not participate in memory management for the publication pointer, so it requires that the publication pointer remain valid until remove_publication is called.

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

add_subscription()

virtual GUID_t OpenDDS::DCPS::Discovery::add_subscription ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  topicId, DataReaderCallbacks_rch  subscription, const DDS::DataReaderQos &  qos, const TransportLocatorSeq &  transInfo, const DDS::SubscriberQos &  subscriberQos, const char *  filterClassName, const char *  filterExpression, const DDS::StringSeq &  exprParams, const XTypes::TypeInformation &  type_info  )

pure virtual

add the passed in subscription into discovery. Discovery does not participate in memory management for the subscription pointer, so it requires that the subscription pointer remain valid until remove_subscription is called.

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

assert_topic()

virtual TopicStatus OpenDDS::DCPS::Discovery::assert_topic ( GUID_t_out  topicId, DDS::DomainId_t  domainId, const GUID_t &  participantId, const char *  topicName, const char *  dataTypeName, const DDS::TopicQos &  qos, bool  hasDcpsKey, TopicCallbacks *  topic_callbacks  )

pure virtual

attach_participant()

virtual bool OpenDDS::DCPS::Discovery::attach_participant ( DDS::DomainId_t  domainId, const GUID_t &  participantId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

create_bit_topics()

DDS::ReturnCode_t OpenDDS::DCPS::Discovery::create_bit_topics ( DomainParticipantImpl *  participant )

protected

Definition at line 51 of file Discovery.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::BUILT_IN_CONNECTION_RECORD_TOPIC, OpenDDS::DCPS::BUILT_IN_CONNECTION_RECORD_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_INTERNAL_THREAD_TOPIC, OpenDDS::DCPS::BUILT_IN_INTERNAL_THREAD_TOPIC_TYPE, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_LOCATION_TOPIC, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_LOCATION_TOPIC_TYPE, 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::DomainParticipantImpl::create_topic(), OpenDDS::DCPS::DEFAULT_STATUS_MASK, CORBA::is_nil(), LM_ERROR, Registered_Data_Types, DDS::RETCODE_ERROR, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), and TOPIC_QOS_DEFAULT.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), and OpenDDS::DCPS::StaticDiscovery::init_bit().

{
#ifndef DDS_HAS_MINIMUM_BIT

  TypeSupport_var type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_PARTICIPANT_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    // Participant topic
    DDS::ParticipantBuiltinTopicDataTypeSupport_var ts =
      new DDS::ParticipantBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_PARTICIPANT_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ")
                        ACE_TEXT("Discovery::create_bit_topics, ")
                        ACE_TEXT("register BUILT_IN_PARTICIPANT_TOPIC_TYPE returned %d.\n"),
                        ret),
                       ret);
    }
  }

  DDS::Topic_var bit_part_topic =
    participant->create_topic(BUILT_IN_PARTICIPANT_TOPIC,
                              BUILT_IN_PARTICIPANT_TOPIC_TYPE,
                              TOPIC_QOS_DEFAULT,
                              DDS::TopicListener::_nil(),
                              DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_part_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ")
                      ACE_TEXT("Discovery::create_bit_topics, ")
                      ACE_TEXT("Nil %C Topic\n"),
                      BUILT_IN_PARTICIPANT_TOPIC),
                     DDS::RETCODE_ERROR);
  }

  // Participant location topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_PARTICIPANT_LOCATION_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    OpenDDS::DCPS::ParticipantLocationBuiltinTopicDataTypeSupport_var ts =
      new OpenDDS::DCPS::ParticipantLocationBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_PARTICIPANT_LOCATION_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
        ACE_TEXT("(%P|%t) ")
        ACE_TEXT("Discovery::create_bit_topics, ")
        ACE_TEXT("register BUILT_IN_PARTICIPANT_LOCATION_TOPIC_TYPE returned %C.\n"),
        retcode_to_string(ret)),
        ret);
    }
  }

  DDS::Topic_var bit_part_loc_topic =
    participant->create_topic(BUILT_IN_PARTICIPANT_LOCATION_TOPIC,
      BUILT_IN_PARTICIPANT_LOCATION_TOPIC_TYPE,
      TOPIC_QOS_DEFAULT,
      DDS::TopicListener::_nil(),
      DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_part_loc_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
      ACE_TEXT("(%P|%t) ")
      ACE_TEXT("Discovery::create_bit_topics, ")
      ACE_TEXT("Nil %C Topic\n"),
      BUILT_IN_PARTICIPANT_LOCATION_TOPIC),
      DDS::RETCODE_ERROR);
  }

  // Internal thread status topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_INTERNAL_THREAD_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    OpenDDS::DCPS::InternalThreadBuiltinTopicDataTypeSupport_var ts =
      new OpenDDS::DCPS::InternalThreadBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_INTERNAL_THREAD_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
        ACE_TEXT("(%P|%t) ")
        ACE_TEXT("Discovery::create_bit_topics, ")
        ACE_TEXT("register BUILT_IN_INTERNAL_THREAD_TOPIC_TYPE returned %C.\n"),
        retcode_to_string(ret)),
        ret);
    }
  }

  DDS::Topic_var bit_internal_thread_topic =
    participant->create_topic(BUILT_IN_INTERNAL_THREAD_TOPIC,
      BUILT_IN_INTERNAL_THREAD_TOPIC_TYPE,
      TOPIC_QOS_DEFAULT,
      DDS::TopicListener::_nil(),
      DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_internal_thread_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
      ACE_TEXT("(%P|%t) ")
      ACE_TEXT("Discovery::create_bit_topics, ")
      ACE_TEXT("Nil %C Topic\n"),
      BUILT_IN_INTERNAL_THREAD_TOPIC),
      DDS::RETCODE_ERROR);
  }

    // Connection Record Topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_CONNECTION_RECORD_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    OpenDDS::DCPS::ConnectionRecordTypeSupport_var ts =
      new OpenDDS::DCPS::ConnectionRecordTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_CONNECTION_RECORD_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
        ACE_TEXT("(%P|%t) ")
        ACE_TEXT("Discovery::create_bit_topics, ")
        ACE_TEXT("register BUILT_IN_CONNECTION_RECORD_TOPIC_TYPE returned %C.\n"),
        retcode_to_string(ret)),
        ret);
    }
  }

  DDS::Topic_var bit_connection_record_topic =
    participant->create_topic(BUILT_IN_CONNECTION_RECORD_TOPIC,
      BUILT_IN_CONNECTION_RECORD_TOPIC_TYPE,
      TOPIC_QOS_DEFAULT,
      DDS::TopicListener::_nil(),
      DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_connection_record_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
      ACE_TEXT("(%P|%t) ")
      ACE_TEXT("Discovery::create_bit_topics, ")
      ACE_TEXT("Nil %C Topic\n"),
      BUILT_IN_CONNECTION_RECORD_TOPIC),
      DDS::RETCODE_ERROR);
  }

  // Topic topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_TOPIC_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    DDS::TopicBuiltinTopicDataTypeSupport_var ts =
      new DDS::TopicBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_TOPIC_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ")
                        ACE_TEXT("Discovery::create_bit_topics, ")
                        ACE_TEXT("register BUILT_IN_TOPIC_TOPIC_TYPE returned %d.\n"),
                        ret),
                       ret);
    }
  }

  DDS::Topic_var bit_topic_topic =
    participant->create_topic(BUILT_IN_TOPIC_TOPIC,
                              BUILT_IN_TOPIC_TOPIC_TYPE,
                              TOPIC_QOS_DEFAULT,
                              DDS::TopicListener::_nil(),
                              DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_topic_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ")
                      ACE_TEXT("Discovery::create_bit_topics, ")
                      ACE_TEXT("Nil %C Topic\n"),
                      BUILT_IN_TOPIC_TOPIC),
                     DDS::RETCODE_ERROR);
  }

  // Subscription topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_SUBSCRIPTION_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    DDS::SubscriptionBuiltinTopicDataTypeSupport_var ts =
      new DDS::SubscriptionBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_SUBSCRIPTION_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ")
                        ACE_TEXT("Discovery::create_bit_topics, ")
                        ACE_TEXT("register BUILT_IN_SUBSCRIPTION_TOPIC_TYPE returned %d.\n"),
                        ret),
                       ret);
    }
  }

  DDS::Topic_var bit_sub_topic =
    participant->create_topic(BUILT_IN_SUBSCRIPTION_TOPIC,
                              BUILT_IN_SUBSCRIPTION_TOPIC_TYPE,
                              TOPIC_QOS_DEFAULT,
                              DDS::TopicListener::_nil(),
                              DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_sub_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ")
                      ACE_TEXT("Discovery::create_bit_topics, ")
                      ACE_TEXT("Nil %C Topic\n"),
                      BUILT_IN_SUBSCRIPTION_TOPIC),
                     DDS::RETCODE_ERROR);
  }

  // Publication topic
  type_support =
    Registered_Data_Types->lookup(participant, BUILT_IN_PUBLICATION_TOPIC_TYPE);

  if (CORBA::is_nil(type_support)) {
    DDS::PublicationBuiltinTopicDataTypeSupport_var ts =
      new DDS::PublicationBuiltinTopicDataTypeSupportImpl;

    const DDS::ReturnCode_t ret = ts->register_type(participant,
                                                    BUILT_IN_PUBLICATION_TOPIC_TYPE);

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ")
                        ACE_TEXT("Discovery::create_bit_topics, ")
                        ACE_TEXT("register BUILT_IN_PUBLICATION_TOPIC_TYPE returned %d.\n"),
                        ret),
                       ret);
    }
  }

  DDS::Topic_var bit_pub_topic =
    participant->create_topic(BUILT_IN_PUBLICATION_TOPIC,
                              BUILT_IN_PUBLICATION_TOPIC_TYPE,
                              TOPIC_QOS_DEFAULT,
                              DDS::TopicListener::_nil(),
                              DEFAULT_STATUS_MASK);

  if (CORBA::is_nil(bit_pub_topic)) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Discovery::create_bit_topics, ")
                      ACE_TEXT("Nil %C Topic\n"),
                      BUILT_IN_PUBLICATION_TOPIC),
                     DDS::RETCODE_ERROR);
  }


  bit_part_topic->enable();
  bit_topic_topic->enable();
  bit_sub_topic->enable();
  bit_pub_topic->enable();

  bit_part_loc_topic->enable();
  bit_connection_record_topic->enable();
  bit_internal_thread_topic->enable();

#else
  ACE_UNUSED_ARG(participant);
#endif /* DDS_HAS_MINIMUM_BIT */

  return DDS::RETCODE_OK;
}

find_topic()

virtual TopicStatus OpenDDS::DCPS::Discovery::find_topic ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const char *  topicName, CORBA::String_out  dataTypeName, DDS::TopicQos_out  qos, GUID_t_out  topicId  )

pure virtual

fini_bit()

virtual void OpenDDS::DCPS::Discovery::fini_bit ( DCPS::DomainParticipantImpl *  participant )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

generate_participant_guid()

virtual OpenDDS::DCPS::GUID_t OpenDDS::DCPS::Discovery::generate_participant_guid ( )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::DCPS::InfoRepoDiscovery, and OpenDDS::RTPS::RtpsDiscovery.

ignore_domain_participant()

virtual bool OpenDDS::DCPS::Discovery::ignore_domain_participant ( DDS::DomainId_t  domainId, const GUID_t &  myParticipantId, const GUID_t &  ignoreId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

ignore_publication()

virtual bool OpenDDS::DCPS::Discovery::ignore_publication ( DDS::DomainId_t  domainId, const GUID_t &  myParticipantId, const GUID_t &  ignoreId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

ignore_subscription()

virtual bool OpenDDS::DCPS::Discovery::ignore_subscription ( DDS::DomainId_t  domainId, const GUID_t &  myParticipantId, const GUID_t &  ignoreId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

ignore_topic()

virtual bool OpenDDS::DCPS::Discovery::ignore_topic ( DDS::DomainId_t  domainId, const GUID_t &  myParticipantId, const GUID_t &  ignoreId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

init_bit()

virtual RcHandle<BitSubscriber> OpenDDS::DCPS::Discovery::init_bit ( DomainParticipantImpl *  participant )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

key()

RepoKey OpenDDS::DCPS::Discovery::key ( void  ) const

inline

Definition at line 96 of file Discovery.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info(), and OpenDDS::DCPS::InfoRepoDiscovery::init_bit().

{ return this->key_; }

pre_reader()

virtual void OpenDDS::DCPS::Discovery::pre_reader ( DataReaderImpl *  )

inlinevirtual

Reimplemented in OpenDDS::DCPS::StaticDiscovery.

Definition at line 224 of file Discovery.h.

{}

pre_writer()

virtual void OpenDDS::DCPS::Discovery::pre_writer ( DataWriterImpl *  )

inlinevirtual

Reimplemented in OpenDDS::DCPS::StaticDiscovery.

Definition at line 182 of file Discovery.h.

{}

remove_domain_participant()

virtual bool OpenDDS::DCPS::Discovery::remove_domain_participant ( DDS::DomainId_t  domainId, const GUID_t &  participantId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

remove_publication()

virtual bool OpenDDS::DCPS::Discovery::remove_publication ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  publicationId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

remove_subscription()

virtual bool OpenDDS::DCPS::Discovery::remove_subscription ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  subscriptionId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

remove_topic()

virtual TopicStatus OpenDDS::DCPS::Discovery::remove_topic ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  topicId  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

request_remote_complete_type_objects()

virtual void OpenDDS::DCPS::Discovery::request_remote_complete_type_objects ( DDS::DomainId_t  , const GUID_t &  , const GUID_t &  , const XTypes::TypeInformation &  , TypeObjReqCond &  cond  )

inlinevirtual

Reimplemented in OpenDDS::RTPS::RtpsDiscovery.

Definition at line 281 of file Discovery.h.

References OpenDDS::DCPS::TypeObjReqCond::done(), and DDS::RETCODE_UNSUPPORTED.

  {
    cond.done(DDS::RETCODE_UNSUPPORTED);
  }

signal_liveliness()

virtual void OpenDDS::DCPS::Discovery::signal_liveliness ( const DDS::DomainId_t  , const GUID_t &  , DDS::LivelinessQosPolicyKind    )

inlinevirtual

Reimplemented in OpenDDS::RTPS::RtpsDiscovery.

Definition at line 277 of file Discovery.h.

                                                               { }

supports_liveliness()

virtual bool OpenDDS::DCPS::Discovery::supports_liveliness ( ) const

inlinevirtual

Reimplemented in OpenDDS::RTPS::RtpsDiscovery.

Definition at line 275 of file Discovery.h.

{ return false; }

update_domain_participant_qos()

virtual bool OpenDDS::DCPS::Discovery::update_domain_participant_qos ( DDS::DomainId_t  domain, const GUID_t &  participantId, const DDS::DomainParticipantQos &  qos  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

update_publication_locators()

void OpenDDS::DCPS::Discovery::update_publication_locators ( DDS::DomainId_t  domainId, const GUID_t &  partId, const GUID_t &  dwId, const TransportLocatorSeq &  transInfo  )

virtual

Reimplemented in OpenDDS::DCPS::StaticDiscovery, and OpenDDS::RTPS::RtpsDiscovery.

Definition at line 334 of file Discovery.cpp.

{}

update_publication_qos()

virtual bool OpenDDS::DCPS::Discovery::update_publication_qos ( DDS::DomainId_t  domainId, const GUID_t &  partId, const GUID_t &  dwId, const DDS::DataWriterQos &  qos, const DDS::PublisherQos &  publisherQos  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

update_subscription_locators()

void OpenDDS::DCPS::Discovery::update_subscription_locators ( DDS::DomainId_t  domainId, const GUID_t &  partId, const GUID_t &  drId, const TransportLocatorSeq &  transInfo  )

virtual

Reimplemented in OpenDDS::DCPS::StaticDiscovery, and OpenDDS::RTPS::RtpsDiscovery.

Definition at line 340 of file Discovery.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

{}

update_subscription_params()

virtual bool OpenDDS::DCPS::Discovery::update_subscription_params ( DDS::DomainId_t  domainId, const GUID_t &  participantId, const GUID_t &  subscriptionId, const DDS::StringSeq &  params  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

update_subscription_qos()

virtual bool OpenDDS::DCPS::Discovery::update_subscription_qos ( DDS::DomainId_t  domainId, const GUID_t &  partId, const GUID_t &  drId, const DDS::DataReaderQos &  qos, const DDS::SubscriberQos &  subscriberQos  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

update_topic_qos()

virtual bool OpenDDS::DCPS::Discovery::update_topic_qos ( const GUID_t &  topicId, DDS::DomainId_t  domainId, const GUID_t &  participantId, const DDS::TopicQos &  qos  )

pure virtual

Implemented in OpenDDS::DCPS::StaticDiscovery, OpenDDS::RTPS::RtpsDiscovery, and OpenDDS::DCPS::InfoRepoDiscovery.

Member Data Documentation

DEFAULT_REPO

const char * OpenDDS::DCPS::Discovery::DEFAULT_REPO = "DEFAULT_REPO"

static

Key value for the default repository IOR.

Definition at line 85 of file Discovery.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::domain_to_repo(), OpenDDS::DCPS::TypeObjReqCond::done(), OpenDDS::DCPS::Service_Participant::get_discovery(), InfoRepo::init(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), OpenDDS::DCPS::Service_Participant::parse_args(), OpenDDS::DCPS::Service_Participant::set_repo_domain(), and OpenDDS::DCPS::Service_Participant::set_repo_ior().

DEFAULT_RTPS

const char * OpenDDS::DCPS::Discovery::DEFAULT_RTPS = "DEFAULT_RTPS"

static

Definition at line 86 of file Discovery.h.

Referenced by OpenDDS::DCPS::TypeObjReqCond::done(), OpenDDS::DCPS::Service_Participant::get_discovery(), and OpenDDS::DCPS::Service_Participant::load_domain_configuration().

DEFAULT_STATIC

const char * OpenDDS::DCPS::Discovery::DEFAULT_STATIC = "DEFAULT_STATIC"

static

Definition at line 87 of file Discovery.h.

Referenced by OpenDDS::DCPS::TypeObjReqCond::done(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), and OpenDDS::DCPS::StaticDiscovery::pre_reader().

key_

RepoKey OpenDDS::DCPS::Discovery::key_

private

Definition at line 293 of file Discovery.h.

---

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

• Discovery.h
• Discovery.cpp