Discovery Strategy class that implements InfoRepo discovery. More...

#include <InfoRepoDiscovery.h>

Inheritance diagram for OpenDDS::DCPS::InfoRepoDiscovery:

Collaboration diagram for OpenDDS::DCPS::InfoRepoDiscovery:

[legend]

Classes
class	Config

struct	OrbRunner

class	StaticInitializer

Public Member Functions
	InfoRepoDiscovery (const RepoKey &key, const std::string &ior)

	InfoRepoDiscovery (const RepoKey &key, const DCPSInfo_var &info)

virtual	~InfoRepoDiscovery ()

std::string	get_stringified_dcps_info_ior ()

DCPSInfo_var	get_dcps_info ()

virtual bool	active ()

int	bit_transport_port () const

void	bit_transport_port (int port)

std::string	bit_transport_ip () const

void	bit_transport_ip (const std::string &ip)

bool	set_ORB (CORBA::ORB_ptr orb)

virtual RcHandle< BitSubscriber >	init_bit (DomainParticipantImpl *participant)

virtual void	fini_bit (DCPS::DomainParticipantImpl *participant)

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

virtual OpenDDS::DCPS::GUID_t	generate_participant_guid ()

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

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)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Public Member Functions inherited from OpenDDS::DCPS::Discovery
	Discovery (const RepoKey &key)

RepoKey	key () const

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 void	pre_writer (DataWriterImpl *)

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

Private Member Functions
TransportConfig_rch	bit_config ()

void	removeDataReaderRemote (const GUID_t &subscriptionId)

void	removeDataWriterRemote (const GUID_t &publicationId)

typedef	OPENDDS_MAP_CMP (GUID_t, DataReaderRemote_var, DCPS::GUID_tKeyLessThan) DataReaderMap

typedef	OPENDDS_MAP_CMP (GUID_t, DataWriterRemote_var, DCPS::GUID_tKeyLessThan) DataWriterMap

Private Attributes
std::string	ior_

DCPSInfo_var	info_

std::string	bit_transport_ip_
	The builtin topic transport address. More...

int	bit_transport_port_
	The builtin topic transport port number. More...

bool	use_local_bit_config_

TransportConfig_rch	bit_config_

CORBA::ORB_var	orb_

bool	orb_from_user_

DataReaderMap	dataReaderMap_

DataWriterMap	dataWriterMap_

ACE_Thread_Mutex	lock_

Static Private Attributes
static OrbRunner *	orb_runner_

static ACE_Thread_Mutex	mtx_orb_runner_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::Discovery
typedef OPENDDS_STRING	RepoKey

Static Public Attributes inherited from OpenDDS::DCPS::Discovery
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 inherited from OpenDDS::DCPS::Discovery
DDS::ReturnCode_t	create_bit_topics (DomainParticipantImpl *participant)

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Discovery Strategy class that implements InfoRepo discovery.

This class implements the Discovery interface for InfoRepo-based discovery.

Definition at line 46 of file InfoRepoDiscovery.h.

Constructor & Destructor Documentation

◆ InfoRepoDiscovery() [1/2]

OpenDDS::DCPS::InfoRepoDiscovery::InfoRepoDiscovery	(	const RepoKey &	key,
		const std::string &	ior
	)

Definition at line 137 of file InfoRepoDiscovery.cpp.

   : Discovery(key),
     ior_(ior),
     bit_transport_port_(0),
     use_local_bit_config_(false),
     orb_from_user_(false)
 {
 }

◆ InfoRepoDiscovery() [2/2]

OpenDDS::DCPS::InfoRepoDiscovery::InfoRepoDiscovery	(	const RepoKey &	key,
		const DCPSInfo_var &	info
	)

Definition at line 147 of file InfoRepoDiscovery.cpp.

   : Discovery(key),
     info_(info),
     bit_transport_port_(0),
     use_local_bit_config_(false),
     orb_from_user_(false)
 {
 }

◆ ~InfoRepoDiscovery()

OpenDDS::DCPS::InfoRepoDiscovery::~InfoRepoDiscovery ( )

virtual

Definition at line 157 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), LM_ERROR, orb_from_user_, orb_runner_, OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown(), and OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::use_count_.

 {
   if (!orb_from_user_ && orb_runner_) {
     if (0 == --orb_runner_->use_count_) {
       try {
         orb_runner_->shutdown();
       }
       catch (const CORBA::Exception& ex) {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("ERROR: InfoRepoDiscovery::~InfoRepoDiscovery - ")
           ACE_TEXT("Exception caught during ORB shutdown: %C.\n"),
           ex._info().c_str()));
       }
 
       delete orb_runner_;
       orb_runner_ = 0;
     }
   }
 }

Member Function Documentation

◆ active()

bool OpenDDS::DCPS::InfoRepoDiscovery::active ( void )

virtual

Reimplemented from OpenDDS::DCPS::Discovery.

Definition at line 421 of file InfoRepoDiscovery.cpp.

References get_dcps_info().

 {
   try {
     // invoke a CORBA call, if we are active then there will be no exception
     get_dcps_info()->_is_a("Not_An_IDL_Type");
     return true;
   } catch (const CORBA::Exception&) {
     return false;
   }
 }

◆ add_domain_participant()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 453 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), get_dcps_info(), OpenDDS::DCPS::GUID_UNKNOWN, and CORBA::is_nil().

 {
   try {
     const DCPSInfo_var info = get_dcps_info();
     if (!CORBA::is_nil(info)) {
       return info->add_domain_participant(domainId, qos);
     }
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::add_domain_participant: ");
   }
   const DCPS::AddDomainStatus ads = {OpenDDS::DCPS::GUID_UNKNOWN, false /*federated*/};
   return ads;
 }

◆ add_domain_participant_secure()

DCPS::AddDomainStatus OpenDDS::DCPS::InfoRepoDiscovery::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
	)

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 471 of file InfoRepoDiscovery.cpp.

References OpenDDS::DCPS::GUID_UNKNOWN.

 {
   const DCPS::AddDomainStatus ads = {OpenDDS::DCPS::GUID_UNKNOWN, false /*federated*/};
   return ads;
 }

◆ add_publication()

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

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.

Implements OpenDDS::DCPS::Discovery.

Definition at line 599 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_GUARD_RETURN, ACE_NEW_RETURN, dataWriterMap_, get_dcps_info(), OpenDDS::DCPS::GUID_UNKNOWN, lock_, orb_, and OpenDDS::XTypes::serialize_type_info().

 {
   GUID_t pubId;
 
   try {
     DCPS::DataWriterRemoteImpl* writer_remote_impl = 0;
     ACE_NEW_RETURN(writer_remote_impl,
                    DataWriterRemoteImpl(*publication),
                    DCPS::GUID_UNKNOWN);
 
     //this is taking ownership of the DataWriterRemoteImpl (server side) allocated above
     PortableServer::ServantBase_var writer_remote(writer_remote_impl);
 
     //this is the client reference to the DataWriterRemoteImpl
     OpenDDS::DCPS::DataWriterRemote_var dr_remote_obj =
       servant_to_remote_reference(writer_remote_impl, orb_);
     //turn into a octet seq to pass through generated files
     DDS::OctetSeq serializedTypeInfo;
     XTypes::serialize_type_info(type_info, serializedTypeInfo);
 
     pubId = get_dcps_info()->add_publication(domainId, participantId, topicId,
       dr_remote_obj, qos, transInfo, publisherQos, serializedTypeInfo);
 
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, this->lock_, DCPS::GUID_UNKNOWN);
     // take ownership of the client allocated above
     dataWriterMap_[pubId] = dr_remote_obj;
 
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::add_publication: ");
     pubId = DCPS::GUID_UNKNOWN;
   }
 
   return pubId;
 }

◆ add_subscription()

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

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.

Implements OpenDDS::DCPS::Discovery.

Definition at line 695 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_GUARD_RETURN, ACE_NEW_RETURN, dataReaderMap_, get_dcps_info(), OpenDDS::DCPS::GUID_UNKNOWN, lock_, orb_, and OpenDDS::XTypes::serialize_type_info().

 {
   GUID_t subId;
 
   try {
     DCPS::DataReaderRemoteImpl* reader_remote_impl = 0;
     ACE_NEW_RETURN(reader_remote_impl,
                    DataReaderRemoteImpl(*subscription),
                    DCPS::GUID_UNKNOWN);
 
     //this is taking ownership of the DataReaderRemoteImpl (server side) allocated above
     PortableServer::ServantBase_var reader_remote(reader_remote_impl);
 
     //this is the client reference to the DataReaderRemoteImpl
     OpenDDS::DCPS::DataReaderRemote_var dr_remote_obj =
       servant_to_remote_reference(reader_remote_impl, orb_);
     //turn into a octet seq to pass through generated files
     DDS::OctetSeq serializedTypeInfo;
     XTypes::serialize_type_info(type_info, serializedTypeInfo);
 
     subId = get_dcps_info()->add_subscription(domainId, participantId, topicId,
                                               dr_remote_obj, qos, transInfo, subscriberQos,
                                               filterClassName, filterExpr, params,
                                               serializedTypeInfo);
 
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, this->lock_, DCPS::GUID_UNKNOWN);
     // take ownership of the client allocated above
     dataReaderMap_[subId] = dr_remote_obj;
 
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::add_subscription: ");
     subId = DCPS::GUID_UNKNOWN;
   }
   return subId;
 }

◆ assert_topic()

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

virtual

Definition at line 528 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), get_dcps_info(), and OpenDDS::DCPS::INTERNAL_ERROR.

 {
   try {
     return get_dcps_info()->assert_topic(topicId, domainId, participantId, topicName,
       dataTypeName, qos, hasDcpsKey);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::assert_topic: ");
     return DCPS::INTERNAL_ERROR;
   }
 }

◆ attach_participant()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 435 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->attach_participant(domainId, participantId);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::attach_participant: ");
     return false;
   }
 }

◆ bit_config()

TransportConfig_rch OpenDDS::DCPS::InfoRepoDiscovery::bit_config ( )

private

Definition at line 267 of file InfoRepoDiscovery.cpp.

References ACE_DEBUG, ACE_TEXT(), bit_config_, bit_transport_ip_, bit_transport_port_, OpenDDS::DCPS::TransportRegistry::create_config(), OpenDDS::DCPS::TransportRegistry::create_inst(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TransportRegistry::DEFAULT_INST_PREFIX, OpenDDS::DCPS::TransportRegistry::instance(), OpenDDS::DCPS::TransportConfig::instances_, OpenDDS::DCPS::RcHandle< T >::is_nil(), OpenDDS::DCPS::Discovery::key(), LM_INFO, lock_, OpenDDS::DCPS::static_rchandle_cast(), TheServiceParticipant, and use_local_bit_config_.

Referenced by init_bit().

 {
 #if !defined (DDS_HAS_MINIMUM_BIT)
   ACE_Guard<ACE_Thread_Mutex> guard(lock_);
   if (bit_config_.is_nil()) {
     const std::string cfg_name = TransportRegistry::DEFAULT_INST_PREFIX +
                                  std::string("_BITTransportConfig_") + key();
     bit_config_ = TransportRegistry::instance()->create_config(cfg_name);
 
     const std::string inst_name = TransportRegistry::DEFAULT_INST_PREFIX +
                                   std::string("_BITTCPTransportInst_") + key();
     TransportInst_rch inst =
       TransportRegistry::instance()->create_inst(inst_name, "tcp");
     bit_config_->instances_.push_back(inst);
 
     if (!use_local_bit_config_) {
       bit_transport_ip_ = TheServiceParticipant->bit_transport_ip();
       bit_transport_port_ = TheServiceParticipant->bit_transport_port();
     }
 
     // Use a static cast to avoid dependency on the Tcp library
     TcpInst_rch tcp_inst = static_rchandle_cast<TcpInst>(inst);
 
     tcp_inst->datalink_release_delay_ = 0;
     if (!bit_transport_ip_.empty()) {
       tcp_inst->local_address(bit_transport_port_,
                               bit_transport_ip_.c_str());
     } else {
       tcp_inst->local_address_set_port(bit_transport_port_);
     }
 
     if (DCPS_debug_level) {
       ACE_DEBUG((LM_INFO, ACE_TEXT("(%P|%t) InfoRepoDiscovery::bit_config")
                  ACE_TEXT(" - BIT tcp transport %C\n"), tcp_inst->local_address_string().c_str()));
     }
   }
   return bit_config_;
 #else
   return TransportConfig_rch();
 #endif
 }

◆ bit_transport_ip() [1/2]

std::string OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_ip ( ) const

inline

Definition at line 64 of file InfoRepoDiscovery.h.

64 { return bit_transport_ip_; }

OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_ip_

std::string bit_transport_ip_

The builtin topic transport address.

Definition: InfoRepoDiscovery.h:232

◆ bit_transport_ip() [2/2]

void OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_ip ( const std::string & ip )

inline

Definition at line 65 of file InfoRepoDiscovery.h.

                                              {
     bit_transport_ip_ = ip;
     use_local_bit_config_ = true;
   }

◆ bit_transport_port() [1/2]

int OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_port ( ) const

inline

Definition at line 58 of file InfoRepoDiscovery.h.

58 { return bit_transport_port_; }

OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_port_

int bit_transport_port_

The builtin topic transport port number.

Definition: InfoRepoDiscovery.h:235

◆ bit_transport_port() [2/2]

void OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_port ( int port )

inline

Definition at line 59 of file InfoRepoDiscovery.h.

                                     {
     bit_transport_port_ = port;
     use_local_bit_config_ = true;
   }

◆ find_topic()

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

virtual

Definition at line 543 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), get_dcps_info(), and OpenDDS::DCPS::INTERNAL_ERROR.

 {
   try {
     return get_dcps_info()->find_topic(domainId, topicName, dataTypeName, qos, topicId);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::find_topic: ");
     return DCPS::INTERNAL_ERROR;
   }
 }

◆ fini_bit()

void OpenDDS::DCPS::InfoRepoDiscovery::fini_bit ( DCPS::DomainParticipantImpl * participant )

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 415 of file InfoRepoDiscovery.cpp.

 {
   // nothing to do for DCPSInfoRepo
 }

◆ generate_participant_guid()

OpenDDS::DCPS::GUID_t OpenDDS::DCPS::InfoRepoDiscovery::generate_participant_guid ( )

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 447 of file InfoRepoDiscovery.cpp.

References OpenDDS::DCPS::GUID_UNKNOWN.

 {
   return GUID_UNKNOWN;
 }

◆ get_dcps_info()

DCPSInfo_var OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info ( )

Definition at line 211 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), ACE_Task_Base::activate(), ACE_ARGV_T< CHAR_TYPE >::argc(), ACE_ARGV_T< CHAR_TYPE >::argv(), OpenDDS::DCPS::DEFAULT_ORB_NAME, info_, ior_, CORBA::is_nil(), OpenDDS::DCPS::Discovery::key(), LM_ERROR, lock_, mtx_orb_runner_, orb_, OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::orb_, CORBA::ORB_init(), orb_runner_, TheServiceParticipant, and OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::use_count_.

Referenced by active(), add_domain_participant(), add_publication(), add_subscription(), assert_topic(), attach_participant(), find_topic(), ignore_domain_participant(), ignore_publication(), ignore_subscription(), ignore_topic(), remove_domain_participant(), remove_publication(), remove_subscription(), remove_topic(), update_domain_participant_qos(), update_publication_qos(), update_subscription_params(), update_subscription_qos(), and update_topic_qos().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(lock_);
   if (CORBA::is_nil(this->info_.in())) {
 
     if (!orb_) {
       ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mtx_orb_runner_, 0);
       if (!orb_runner_) {
         orb_runner_ = new OrbRunner;
         ACE_ARGV* argv = TheServiceParticipant->ORB_argv();
         int argc = argv->argc();
         orb_runner_->orb_ =
           CORBA::ORB_init(argc, argv->argv(), DEFAULT_ORB_NAME);
         orb_runner_->use_count_ = 1;
         orb_runner_->activate();
 
         CORBA::Object_var rp =
           orb_runner_->orb_->resolve_initial_references(ROOT_POA);
         PortableServer::POA_var poa = PortableServer::POA::_narrow(rp);
         PortableServer::POAManager_var poa_manager = poa->the_POAManager();
         poa_manager->activate();
       } else {
         ++orb_runner_->use_count_;
       }
       orb_ = orb_runner_->orb_;
     }
 
     try {
       this->info_ = get_repo(this->ior_.c_str(), orb_);
 
       if (CORBA::is_nil(this->info_.in())) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: InfoRepoDiscovery::get_dcps_info: ")
                    ACE_TEXT("unable to narrow DCPSInfo (%C) for key %C.\n"),
                    this->ior_.c_str(),
                    this->key().c_str()));
         return DCPSInfo::_nil();
       }
 
     } catch (const CORBA::Exception& ex) {
       ex._tao_print_exception("ERROR: InfoRepoDiscovery::get_dcps_info: failed to resolve ior - ");
       return DCPSInfo::_nil();
     }
   }
 
   return this->info_;
 }

◆ get_stringified_dcps_info_ior()

std::string OpenDDS::DCPS::InfoRepoDiscovery::get_stringified_dcps_info_ior ( )

Definition at line 260 of file InfoRepoDiscovery.cpp.

References ior_, and lock_.

 {
   ACE_Guard<ACE_Thread_Mutex> guard(lock_);
   return this->ior_;
 }

◆ ignore_domain_participant()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 499 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     get_dcps_info()->ignore_domain_participant(domainId, myParticipantId, ignoreId);
     return true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::ignore_domain_participant: ");
     return false;
   }
 }

◆ ignore_publication()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 662 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     get_dcps_info()->ignore_publication(domainId, participantId, ignoreId);
     return true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::ignore_publication: ");
     return false;
   }
 }

◆ ignore_subscription()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 762 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     get_dcps_info()->ignore_subscription(domainId, participantId, ignoreId);
     return true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::ignore_subscription: ");
     return false;
   }
 }

◆ ignore_topic()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 571 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     get_dcps_info()->ignore_topic(domainId, myParticipantId, ignoreId);
     return true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::ignore_topic: ");
     return false;
   }
 }

◆ init_bit()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 310 of file InfoRepoDiscovery.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::TransportRegistry::bind_config(), bit_config(), OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC, OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::DomainParticipantImpl::create_subscriber(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DEFAULT_STATUS_MASK, DDS::DataReaderQos::durability, OpenDDS::DCPS::DomainParticipantImpl::federated(), OpenDDS::DCPS::TransportRegistry::instance(), OpenDDS::DCPS::Discovery::key(), DDS::DurabilityQosPolicy::kind, DDS::LivelinessQosPolicy::lease_duration, DDS::DataReaderQos::liveliness, LM_ERROR, LM_INFO, OpenDDS::DCPS::DomainParticipantImpl::lookup_topicdescription(), DDS::Duration_t::nanosec, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), DDS::Duration_t::sec, SUBSCRIBER_QOS_DEFAULT, TheServiceParticipant, and DDS::TRANSIENT_LOCAL_DURABILITY_QOS.

 {
 #if defined (DDS_HAS_MINIMUM_BIT)
   ACE_UNUSED_ARG(participant);
   return RcHandle<BitSubscriber>();
 #else
   if (!TheServiceParticipant->get_BIT()) {
     return RcHandle<BitSubscriber>();
   }
 
   if (create_bit_topics(participant) != DDS::RETCODE_OK) {
     return RcHandle<BitSubscriber>();
   }
 
   DDS::Subscriber_var bit_subscriber =
     participant->create_subscriber(SUBSCRIBER_QOS_DEFAULT,
                                    DDS::SubscriberListener::_nil(),
                                    DEFAULT_STATUS_MASK);
   try {
     TransportConfig_rch config = bit_config();
     TransportRegistry::instance()->bind_config(config, bit_subscriber);
 
   } catch (const Transport::Exception&) {
     ACE_ERROR((LM_ERROR, "(%P|%t) InfoRepoDiscovery::init_bit, "
                          "exception during transport initialization\n"));
     return RcHandle<BitSubscriber>();
   }
 
   // DataReaders
   try {
     DDS::DataReaderQos participantReaderQos;
     bit_subscriber->get_default_datareader_qos(participantReaderQos);
     participantReaderQos.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
 
     if (participant->federated()) {
       participantReaderQos.liveliness.lease_duration.nanosec = 0;
       participantReaderQos.liveliness.lease_duration.sec =
         TheServiceParticipant->federation_liveliness();
     }
 
     DDS::TopicDescription_var bit_part_topic =
       participant->lookup_topicdescription(BUILT_IN_PARTICIPANT_TOPIC);
 
     DDS::DataReader_var dr =
       bit_subscriber->create_datareader(bit_part_topic,
                                         participantReaderQos,
                                         DDS::DataReaderListener::_nil(),
                                         DEFAULT_STATUS_MASK);
 
     if (participant->federated()) {
       DDS::ParticipantBuiltinTopicDataDataReader_var pbit_dr =
         DDS::ParticipantBuiltinTopicDataDataReader::_narrow(dr.in());
 
       DataReaderListener_var failover = new FailoverListener(key());
       pbit_dr->set_listener(failover, DEFAULT_STATUS_MASK);
       // No need to invoke the listener.
     }
 
     DDS::DataReaderQos dr_qos;
     bit_subscriber->get_default_datareader_qos(dr_qos);
     dr_qos.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
 
     DDS::TopicDescription_var bit_topic_topic =
       participant->lookup_topicdescription(BUILT_IN_TOPIC_TOPIC);
 
     dr = bit_subscriber->create_datareader(bit_topic_topic,
                                            dr_qos,
                                            DDS::DataReaderListener::_nil(),
                                            DEFAULT_STATUS_MASK);
 
     DDS::TopicDescription_var bit_pub_topic =
       participant->lookup_topicdescription(BUILT_IN_PUBLICATION_TOPIC);
 
     dr = bit_subscriber->create_datareader(bit_pub_topic,
                                            dr_qos,
                                            DDS::DataReaderListener::_nil(),
                                            OpenDDS::DCPS::DEFAULT_STATUS_MASK);
 
     DDS::TopicDescription_var bit_sub_topic =
       participant->lookup_topicdescription(BUILT_IN_SUBSCRIPTION_TOPIC);
 
     dr = bit_subscriber->create_datareader(bit_sub_topic,
                                            dr_qos,
                                            DDS::DataReaderListener::_nil(),
                                            OpenDDS::DCPS::DEFAULT_STATUS_MASK);
 
     const DDS::ReturnCode_t ret = bit_subscriber->enable();
     if (ret != DDS::RETCODE_OK) {
       if (DCPS_debug_level) {
         ACE_DEBUG((LM_INFO, ACE_TEXT("(%P|%t) InfoRepoDiscovery::init_bit")
                    ACE_TEXT(" - Error <%C> enabling subscriber\n"), retcode_to_string(ret)));
       }
       return RcHandle<BitSubscriber>();
     }
 
   } catch (const CORBA::Exception&) {
     ACE_ERROR((LM_ERROR, "(%P|%t) InfoRepoDiscovery::init_bit, "
                          "exception during DataReader initialization\n"));
     return RcHandle<BitSubscriber>();
   }
   return make_rch<BitSubscriber>(bit_subscriber);
 #endif
 }

◆ OPENDDS_MAP_CMP() [1/2]

typedef OpenDDS::DCPS::InfoRepoDiscovery::OPENDDS_MAP_CMP	(	GUID_t	,
		DataReaderRemote_var	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ OPENDDS_MAP_CMP() [2/2]

typedef OpenDDS::DCPS::InfoRepoDiscovery::OPENDDS_MAP_CMP	(	GUID_t	,
		DataWriterRemote_var	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ remove_domain_participant()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 486 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     get_dcps_info()->remove_domain_participant(domainId, participantId);
     return true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::remove_domain_participant: ");
     return false;
   }
 }

◆ remove_publication()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 642 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_GUARD_RETURN, get_dcps_info(), lock_, and removeDataWriterRemote().

 {
   {
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, this->lock_, false);
     removeDataWriterRemote(publicationId);
   }
   bool removed = false;
   try {
     get_dcps_info()->remove_publication(domainId, participantId, publicationId);
     removed = true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::remove_publication: ");
   }
 
   return removed;
 }

◆ remove_subscription()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 742 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_GUARD_RETURN, get_dcps_info(), lock_, and removeDataReaderRemote().

 {
   {
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, this->lock_, false);
     removeDataReaderRemote(subscriptionId);
   }
   bool removed = false;
   try {
     get_dcps_info()->remove_subscription(domainId, participantId, subscriptionId);
     removed = true;
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::remove_subscription: ");
   }
 
   return removed;
 }

◆ remove_topic()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 559 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), get_dcps_info(), and OpenDDS::DCPS::INTERNAL_ERROR.

 {
   try {
     return get_dcps_info()->remove_topic(domainId, participantId, topicId);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::remove_topic: ");
     return DCPS::INTERNAL_ERROR;
   }
 }

◆ removeDataReaderRemote()

void OpenDDS::DCPS::InfoRepoDiscovery::removeDataReaderRemote ( const GUID_t & subscriptionId )

private

Definition at line 811 of file InfoRepoDiscovery.cpp.

References ACE_ERROR, ACE_TEXT(), dataReaderMap_, OpenDDS::DCPS::DataReaderRemoteImpl::detach_parent(), LM_ERROR, and orb_.

Referenced by remove_subscription().

 {
   DataReaderMap::iterator drr = dataReaderMap_.find(subscriptionId);
   if (drr == dataReaderMap_.end()) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: InfoRepoDiscovery::removeDataReaderRemote: ")
                ACE_TEXT(" could not find DataReader for subscriptionId.\n")));
     return;
   }
 
   try {
     DataReaderRemoteImpl* impl =
       remote_reference_to_servant<DataReaderRemoteImpl>(drr->second.in(), orb_);
     impl->detach_parent();
     deactivate_remote_object(drr->second.in(), orb_);
   } catch (const CORBA::BAD_INV_ORDER&) {
     // The orb may throw ::CORBA::BAD_INV_ORDER when is has been shutdown.
     // Ignore it anyway.
   } catch (const CORBA::OBJECT_NOT_EXIST&) {
     // Same for CORBA::OBJECT_NOT_EXIST
   }
 
   dataReaderMap_.erase(drr);
 }

◆ removeDataWriterRemote()

void OpenDDS::DCPS::InfoRepoDiscovery::removeDataWriterRemote ( const GUID_t & publicationId )

private

Definition at line 837 of file InfoRepoDiscovery.cpp.

References ACE_ERROR, ACE_TEXT(), dataWriterMap_, OpenDDS::DCPS::DataWriterRemoteImpl::detach_parent(), LM_ERROR, orb_, and OpenDDS::DCPS::REPO_SECTION_NAME.

Referenced by remove_publication().

 {
   DataWriterMap::iterator dwr = dataWriterMap_.find(publicationId);
   if (dwr == dataWriterMap_.end()) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: InfoRepoDiscovery::removeDataWriterRemote: ")
                ACE_TEXT(" could not find DataWriter for publicationId.\n")));
     return;
   }
 
   try {
     DataWriterRemoteImpl* impl =
       remote_reference_to_servant<DataWriterRemoteImpl>(dwr->second.in(), orb_);
     impl->detach_parent();
     deactivate_remote_object(dwr->second.in(), orb_);
   } catch (const CORBA::BAD_INV_ORDER&) {
     // The orb may throw ::CORBA::BAD_INV_ORDER when is has been shutdown.
     // Ignore it anyway.
   } catch (const CORBA::OBJECT_NOT_EXIST&) {
     // Same for CORBA::OBJECT_NOT_EXIST
   }
 
   dataWriterMap_.erase(dwr);
 }

◆ set_ORB()

bool OpenDDS::DCPS::InfoRepoDiscovery::set_ORB ( CORBA::ORB_ptr orb )

User provides an ORB for OpenDDS to use.

Note: The user is responsible for running the ORB. true if the operation succeeds

Definition at line 178 of file InfoRepoDiscovery.cpp.

References CORBA::ORB::_duplicate(), TAO_Pseudo_Var_T< ORB >::in(), TAO_Pseudo_Var_T< Object >::in(), CORBA::is_nil(), orb_, orb_from_user_, and CORBA::ORB::string_to_object().

 {
   if (!CORBA::is_nil (orb_.in()) || CORBA::is_nil (orb)) {
     return false;
   }
 
   orb_ = CORBA::ORB::_duplicate(orb);
   orb_from_user_ = true;
   return true;
 }

◆ update_domain_participant_qos()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 513 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->update_domain_participant_qos(domainId, participant, qos);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::update_domain_participant_qos: ");
     return false;
   }
 }

◆ update_publication_qos()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 676 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->update_publication_qos(domainId, participantId, dwId,
       qos, publisherQos);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::update_publication_qos: ");
     return false;
   }
 }

◆ update_subscription_params()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 792 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->update_subscription_params(domainId, participantId,
       subId, params);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::update_subscription_params: ");
     return false;
   }
 }

◆ update_subscription_qos()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 776 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->update_subscription_qos(domainId, participantId,
       drId, qos, subQos);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::update_subscription_qos: ");
     return false;
   }
 }

◆ update_topic_qos()

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

virtual

Implements OpenDDS::DCPS::Discovery.

Definition at line 584 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), and get_dcps_info().

 {
   try {
     return get_dcps_info()->update_topic_qos(topicId, domainId, participantId, qos);
   } catch (const CORBA::Exception& ex) {
     ex._tao_print_exception("ERROR: InfoRepoDiscovery::update_topic_qos: ");
     return false;
   }
 }

Member Data Documentation

◆ bit_config_

TransportConfig_rch OpenDDS::DCPS::InfoRepoDiscovery::bit_config_

private

Definition at line 238 of file InfoRepoDiscovery.h.

Referenced by bit_config().

◆ bit_transport_ip_

std::string OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_ip_

private

The builtin topic transport address.

Definition at line 232 of file InfoRepoDiscovery.h.

Referenced by bit_config().

◆ bit_transport_port_

int OpenDDS::DCPS::InfoRepoDiscovery::bit_transport_port_

private

The builtin topic transport port number.

Definition at line 235 of file InfoRepoDiscovery.h.

Referenced by bit_config().

◆ dataReaderMap_

DataReaderMap OpenDDS::DCPS::InfoRepoDiscovery::dataReaderMap_

private

Definition at line 260 of file InfoRepoDiscovery.h.

Referenced by add_subscription(), and removeDataReaderRemote().

◆ dataWriterMap_

DataWriterMap OpenDDS::DCPS::InfoRepoDiscovery::dataWriterMap_

private

Definition at line 264 of file InfoRepoDiscovery.h.

Referenced by add_publication(), and removeDataWriterRemote().

◆ info_

DCPSInfo_var OpenDDS::DCPS::InfoRepoDiscovery::info_

private

Definition at line 229 of file InfoRepoDiscovery.h.

Referenced by get_dcps_info().

◆ ior_

std::string OpenDDS::DCPS::InfoRepoDiscovery::ior_

private

Definition at line 228 of file InfoRepoDiscovery.h.

Referenced by get_dcps_info(), and get_stringified_dcps_info_ior().

◆ lock_

ACE_Thread_Mutex OpenDDS::DCPS::InfoRepoDiscovery::lock_

mutableprivate

Definition at line 266 of file InfoRepoDiscovery.h.

Referenced by add_publication(), add_subscription(), bit_config(), get_dcps_info(), get_stringified_dcps_info_ior(), remove_publication(), and remove_subscription().

◆ mtx_orb_runner_

ACE_Thread_Mutex OpenDDS::DCPS::InfoRepoDiscovery::mtx_orb_runner_

staticprivate

Definition at line 256 of file InfoRepoDiscovery.h.

Referenced by get_dcps_info(), and OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown().

◆ orb_

CORBA::ORB_var OpenDDS::DCPS::InfoRepoDiscovery::orb_

private

Definition at line 240 of file InfoRepoDiscovery.h.

Referenced by add_publication(), add_subscription(), get_dcps_info(), removeDataReaderRemote(), removeDataWriterRemote(), set_ORB(), OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown(), and OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::svc().

◆ orb_from_user_

bool OpenDDS::DCPS::InfoRepoDiscovery::orb_from_user_

private

Definition at line 241 of file InfoRepoDiscovery.h.

Referenced by set_ORB(), and ~InfoRepoDiscovery().

◆ orb_runner_

InfoRepoDiscovery::OrbRunner * OpenDDS::DCPS::InfoRepoDiscovery::orb_runner_

staticprivate

Definition at line 255 of file InfoRepoDiscovery.h.

Referenced by get_dcps_info(), OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown(), and ~InfoRepoDiscovery().

◆ use_local_bit_config_

bool OpenDDS::DCPS::InfoRepoDiscovery::use_local_bit_config_

private

Definition at line 237 of file InfoRepoDiscovery.h.

Referenced by bit_config().

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

Classes

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ InfoRepoDiscovery() [1/2]

◆ InfoRepoDiscovery() [2/2]

◆ ~InfoRepoDiscovery()

Member Function Documentation

◆ active()

◆ add_domain_participant()

◆ add_domain_participant_secure()

◆ add_publication()

◆ add_subscription()

◆ assert_topic()

◆ attach_participant()

◆ bit_config()

◆ bit_transport_ip() [1/2]

◆ bit_transport_ip() [2/2]

◆ bit_transport_port() [1/2]

◆ bit_transport_port() [2/2]

◆ find_topic()

◆ fini_bit()

◆ generate_participant_guid()

◆ get_dcps_info()

◆ get_stringified_dcps_info_ior()

◆ ignore_domain_participant()

◆ ignore_publication()

◆ ignore_subscription()

◆ ignore_topic()

◆ init_bit()

◆ OPENDDS_MAP_CMP() [1/2]

◆ OPENDDS_MAP_CMP() [2/2]

◆ remove_domain_participant()

◆ remove_publication()

◆ remove_subscription()

◆ remove_topic()

◆ removeDataReaderRemote()

◆ removeDataWriterRemote()

◆ set_ORB()

◆ update_domain_participant_qos()

◆ update_publication_qos()

◆ update_subscription_params()

◆ update_subscription_qos()

◆ update_topic_qos()

Member Data Documentation

◆ bit_config_

◆ bit_transport_ip_

◆ bit_transport_port_

◆ dataReaderMap_

◆ dataWriterMap_

◆ info_

◆ ior_

◆ lock_

◆ mtx_orb_runner_

◆ orb_

◆ orb_from_user_

◆ orb_runner_

◆ use_local_bit_config_