#include <TransportRegistry.h>

Collaboration diagram for OpenDDS::DCPS::TransportRegistry:

[legend]

Classes
struct	TransportEntry

struct	TransportTemplate

Public Member Functions
void	release ()

TransportInst_rch	create_inst (const OPENDDS_STRING &name, const OPENDDS_STRING &transport_type)

TransportInst_rch	get_inst (const OPENDDS_STRING &name) const

void	remove_inst (const TransportInst_rch &inst)

void	remove_inst (const OPENDDS_STRING &inst_name)

TransportConfig_rch	create_config (const OPENDDS_STRING &name)

TransportConfig_rch	get_config (const OPENDDS_STRING &name) const

void	remove_config (const TransportConfig_rch &cfg)

void	remove_config (const OPENDDS_STRING &config_name)

void	remove_transport_template_instance (const OPENDDS_STRING &config_name)

TransportConfig_rch	global_config () const

void	global_config (const TransportConfig_rch &cfg)

void	domain_default_config (DDS::DomainId_t domain, const TransportConfig_rch &cfg)

TransportConfig_rch	domain_default_config (DDS::DomainId_t domain) const

void	bind_config (const OPENDDS_STRING &name, DDS::Entity_ptr entity)

void	bind_config (const TransportConfig_rch &cfg, DDS::Entity_ptr entity)

bool	register_type (const TransportType_rch &type)

int	load_transport_configuration (const OPENDDS_STRING &file_name, ACE_Configuration_Heap &cf)

int	load_transport_templates (ACE_Configuration_Heap &cf)

TransportConfig_rch	fix_empty_default ()

void	load_transport_lib (const OPENDDS_STRING &transport_type)

bool	released () const

bool	config_has_transport_template (const ACE_TString &config_name) const

int	create_transport_template_instance (DDS::DomainId_t domain, const ACE_TString &config_name)

OPENDDS_STRING	get_transport_template_instance_name (DDS::DomainId_t id)

OPENDDS_STRING	get_config_instance_name (DDS::DomainId_t id)

bool	create_new_transport_instance_for_participant (DDS::DomainId_t id, OPENDDS_STRING &transport_config_name, OPENDDS_STRING &transport_instance_name)

void	update_config_template_instance_info (const OPENDDS_STRING &config_name, const OPENDDS_STRING &inst_name)

Static Public Member Functions
static TransportRegistry *	instance ()
	Return a singleton instance of this class. More...

static void	close ()
	Close the singleton instance of this class. More...

Static Public Attributes
static const char	DEFAULT_CONFIG_NAME [] = "_OPENDDS_DEFAULT_CONFIG"

static const char	DEFAULT_INST_PREFIX [] = "_OPENDDS_"

Private Types
typedef ACE_SYNCH_MUTEX	LockType

typedef ACE_Guard< LockType >	GuardType

Private Member Functions
	TransportRegistry ()

	~TransportRegistry ()

typedef	OPENDDS_MAP (OPENDDS_STRING, TransportType_rch) TypeMap

typedef	OPENDDS_MAP (OPENDDS_STRING, TransportConfig_rch) ConfigMap

typedef	OPENDDS_MAP (OPENDDS_STRING, TransportInst_rch) InstMap

typedef	OPENDDS_MAP (OPENDDS_STRING, OPENDDS_STRING) LibDirectiveMap

typedef	OPENDDS_MAP (DDS::DomainId_t, TransportConfig_rch) DomainConfigMap

typedef	OPENDDS_MAP (OPENDDS_STRING, OPENDDS_STRING) ConfigTemplateToInstanceMap

TransportType_rch	load_transport_lib_i (const OPENDDS_STRING &transport_type)

	OPENDDS_VECTOR (TransportTemplate) transport_templates_

bool	get_transport_template_info (const ACE_TString &config_name, TransportTemplate &inst)

bool	process_customizations (const DDS::DomainId_t id, const TransportTemplate &tr_inst, ValueMap &customs)

bool	has_transport_templates () const

	OPENDDS_VECTOR (TransportEntry) transports_

bool	get_transport_info (const ACE_TString &config_name, TransportEntry &inst)

bool	has_transports () const

Private Attributes
TypeMap	type_map_

ConfigMap	config_map_

InstMap	inst_map_

LibDirectiveMap	lib_directive_map_

DomainConfigMap	domain_default_config_map_

ConfigTemplateToInstanceMap	config_template_to_instance_map_

TransportConfig_rch	global_config_

bool	released_

LockType	lock_

Static Private Attributes
static const OPENDDS_STRING	CUSTOM_ADD_DOMAIN_TO_IP = "add_domain_id_to_ip_addr"

static const OPENDDS_STRING	CUSTOM_ADD_DOMAIN_TO_PORT = "add_domain_id_to_port"

Friends
class	ACE_Singleton< TransportRegistry, ACE_Recursive_Thread_Mutex >

Detailed Description

The TransportRegistry is a singleton object which provides a mechanism to the application code to configure OpenDDS's use of the transport layer.

Definition at line 45 of file TransportRegistry.h.

Member Typedef Documentation

◆ GuardType

typedef ACE_Guard<LockType> OpenDDS::DCPS::TransportRegistry::GuardType

private

Definition at line 150 of file TransportRegistry.h.

◆ LockType

typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::TransportRegistry::LockType

private

Definition at line 149 of file TransportRegistry.h.

Constructor & Destructor Documentation

◆ TransportRegistry()

OpenDDS::DCPS::TransportRegistry::TransportRegistry ( )

private

Definition at line 71 of file TransportRegistry.cpp.

References config_map_, DBG_ENTRY_LVL, DEFAULT_CONFIG_NAME, global_config_, and lib_directive_map_.

   : global_config_(make_rch<TransportConfig>(DEFAULT_CONFIG_NAME))
   , released_(false)
 {
   DBG_ENTRY_LVL("TransportRegistry", "TransportRegistry", 6);
   config_map_[DEFAULT_CONFIG_NAME] = global_config_;
 
   lib_directive_map_["tcp"]       = "dynamic OpenDDS_Tcp Service_Object * OpenDDS_Tcp:_make_TcpLoader()";
   lib_directive_map_["udp"]       = "dynamic OpenDDS_Udp Service_Object * OpenDDS_Udp:_make_UdpLoader()";
   lib_directive_map_["multicast"] = "dynamic OpenDDS_Multicast Service_Object * OpenDDS_Multicast:_make_MulticastLoader()";
   lib_directive_map_["rtps_udp"]  = "dynamic OpenDDS_Rtps_Udp Service_Object * OpenDDS_Rtps_Udp:_make_RtpsUdpLoader()";
   lib_directive_map_["shmem"]     = "dynamic OpenDDS_Shmem Service_Object * OpenDDS_Shmem:_make_ShmemLoader()";
 
   // load_transport_lib() is used for discovery as well:
   lib_directive_map_["rtps_discovery"] = lib_directive_map_["rtps_udp"];
   lib_directive_map_["repository"] = "dynamic OpenDDS_InfoRepoDiscovery Service_Object * OpenDDS_InfoRepoDiscovery:_make_IRDiscoveryLoader()";
 }

◆ ~TransportRegistry()

ACE_INLINE OpenDDS::DCPS::TransportRegistry::~TransportRegistry ( )

private

Definition at line 18 of file TransportRegistry.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

 {
   DBG_ENTRY_LVL("TransportRegistry", "~TransportRegistry", 6);
 }

Member Function Documentation

◆ bind_config() [1/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::bind_config	(	const OPENDDS_STRING &	name,
		DDS::Entity_ptr	entity
	)

Definition at line 105 of file TransportRegistry.inl.

References get_config(), and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), DCPS_IR_Domain::init_built_in_topics_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), OpenDDS::Federator::ManagerImpl::initialize(), OpenDDS::DCPS::StaticDiscovery::pre_reader(), and OpenDDS::DCPS::StaticDiscovery::pre_writer().

 {
   this->bind_config(this->get_config(name), entity);
 }

◆ bind_config() [2/2]

void OpenDDS::DCPS::TransportRegistry::bind_config	(	const TransportConfig_rch &	cfg,
		DDS::Entity_ptr	entity
	)

Definition at line 599 of file TransportRegistry.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_TEXT_CHAR_TO_TCHAR, ACE_String_Base< char >::c_str(), create_new_transport_instance_for_participant(), create_transport_template_instance(), get_config(), OpenDDS::DCPS::EntityImpl::get_domain_id(), OpenDDS::DCPS::EntityImpl::get_id(), OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::DCPS::RcHandle< T >::is_nil(), LM_ERROR, OpenDDS::DCPS::TransportConfig::name(), OPENDDS_STRING, OPENDDS_VECTOR(), TheServiceParticipant, OpenDDS::DCPS::EntityImpl::transport_config(), OpenDDS::DCPS::GuidConverter::uniqueParticipantId(), and update_config_template_instance_info().

 {
   if (cfg.is_nil()) {
     throw Transport::NotFound();
   }
   EntityImpl* ei = dynamic_cast<EntityImpl*>(entity);
   if (!ei) {
     throw Transport::MiscProblem();
   }
 
   const DDS::DomainId_t domain_id = ei->get_domain_id();
 
   // if domain is in a domain range and config is a transport template,
   // get the correct config.
   if (TheServiceParticipant->belongs_to_domain_range(domain_id)) {
     bool found = false;
     for (OPENDDS_VECTOR(TransportTemplate)::const_iterator i = transport_templates_.begin(); i != transport_templates_.end(); ++i) {
       if (cfg->name() == i->config_name) {
         found = true;
         break;
       }
     }
 
     if (found)
     {
       ACE_TString cfg_name = ACE_TEXT_CHAR_TO_TCHAR(cfg->name().c_str());
       // create if not already created
       int ret = create_transport_template_instance(domain_id, cfg_name);
 
       if (ret == 0) {
         // get guid and create unique name for transport instance
         GUID_t guid = ei->get_id();
         if (guid == GUID_UNKNOWN) {
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) TransportRegistry::bind_config: ")
                      ACE_TEXT("GUID_UNKNOWN. Can not bind entity to a domain template instance.\n")));
           throw Transport::UnableToCreate();
         }
         OPENDDS_STRING transport_inst_name = GuidConverter(guid).uniqueParticipantId();
         OPENDDS_STRING transport_config_name;
 
         if (cfg_name.c_str() != 0) {
           transport_config_name = ACE_TEXT_ALWAYS_CHAR(cfg_name.c_str());
         } else {
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) TransportRegistry::bind_config: ")
                      ACE_TEXT("Config name is null.\n")));
           throw Transport::UnableToCreate();
         }
 
         bool success = create_new_transport_instance_for_participant(domain_id, transport_config_name, transport_inst_name);
 
         if (success) {
           // update config
           TransportConfig_rch new_cfg = get_config(transport_config_name);
           update_config_template_instance_info(new_cfg->name(), transport_inst_name);
           ei->transport_config(new_cfg);
           return;
         } else {
           ACE_ERROR((LM_ERROR,
                      ACE_TEXT("(%P|%t) TransportRegistry::bind_config: ")
                      ACE_TEXT("Failed to create new transport template instance.\n")));
           throw Transport::UnableToCreate();
         }
       }
     }
   }
 
   ei->transport_config(cfg);
 }

◆ close()

void OpenDDS::DCPS::TransportRegistry::close ( void )

static

Close the singleton instance of this class.

Definition at line 59 of file TransportRegistry.cpp.

References ACE_Unmanaged_Singleton< TYPE, ACE_LOCK >::close(), CUSTOM_ADD_DOMAIN_TO_IP, CUSTOM_ADD_DOMAIN_TO_PORT, DEFAULT_CONFIG_NAME, DEFAULT_INST_PREFIX, and OPENDDS_STRING.

Referenced by OpenDDS::DCPS::Service_Participant::shutdown().

 {
   ACE_Unmanaged_Singleton<TransportRegistry, ACE_Recursive_Thread_Mutex>::close();
 }

◆ config_has_transport_template()

bool OpenDDS::DCPS::TransportRegistry::config_has_transport_template ( const ACE_TString & config_name ) const

Definition at line 943 of file TransportRegistry.cpp.

References ACE_TEXT_ALWAYS_CHAR, ACE_String_Base< char >::c_str(), OPENDDS_VECTOR(), and ACE_OS::strcmp().

Referenced by create_new_transport_instance_for_participant().

 {
   for (OPENDDS_VECTOR(TransportTemplate)::const_iterator i = transport_templates_.begin(); i != transport_templates_.end(); ++i) {
     if (!ACE_OS::strcmp(ACE_TEXT_ALWAYS_CHAR(config_name.c_str()), i->config_name.c_str())) {
       return true;
     }
   }
 
   return false;
 }

◆ create_config()

TransportConfig_rch OpenDDS::DCPS::TransportRegistry::create_config ( const OPENDDS_STRING & name )

Definition at line 568 of file TransportRegistry.cpp.

References ACE_ERROR, ACE_TEXT(), config_map_, LM_ERROR, lock_, and name.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), create_new_transport_instance_for_participant(), TAO_DDS_DCPSInfo_i::init_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), OpenDDS::Federator::ManagerImpl::initialize(), and load_transport_configuration().

 {
   GuardType guard(lock_);
 
   if (config_map_.count(name)) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) TransportRegistry::create_config: ")
                ACE_TEXT("name=%C is already in use.\n"),
                name.c_str()));
     return TransportConfig_rch();
   }
 
   TransportConfig_rch inst  (make_rch<TransportConfig>(name));
   config_map_[name] = inst;
   return inst;
 }

◆ create_inst()

TransportInst_rch OpenDDS::DCPS::TransportRegistry::create_inst	(	const OPENDDS_STRING &	name,
		const OPENDDS_STRING &	transport_type
	)

Definition at line 528 of file TransportRegistry.cpp.

References ACE_ERROR, ACE_TEXT(), inst_map_, LM_ERROR, load_transport_lib_i(), lock_, and name.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), create_new_transport_instance_for_participant(), OpenDDS::DCPS::MulticastLoader::init(), OpenDDS::DCPS::UdpLoader::init(), OpenDDS::DCPS::TcpLoader::init(), TAO_DDS_DCPSInfo_i::init_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), OpenDDS::Federator::ManagerImpl::initialize(), OpenDDS::DCPS::RtpsUdpLoader::load(), and load_transport_configuration().

 {
   GuardType guard(lock_);
 
   TransportType_rch type = load_transport_lib_i(transport_type);
   if (!type) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) TransportRegistry::create_inst: ")
                ACE_TEXT("transport_type=%C is not registered.\n"),
                transport_type.c_str()));
     return TransportInst_rch();
   }
 
   if (inst_map_.count(name)) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) TransportRegistry::create_inst: ")
                ACE_TEXT("name=%C is already in use.\n"),
                name.c_str()));
     return TransportInst_rch();
   }
   TransportInst_rch inst (type->new_inst(name));
   inst_map_[name] = inst;
   return inst;
 }

◆ create_new_transport_instance_for_participant()

bool OpenDDS::DCPS::TransportRegistry::create_new_transport_instance_for_participant	(	DDS::DomainId_t	id,
		OPENDDS_STRING &	transport_config_name,
		OPENDDS_STRING &	transport_instance_name
	)

Definition at line 738 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, config_has_transport_template(), create_config(), create_inst(), OpenDDS::DCPS::DCPS_debug_level, get_config(), get_transport_info(), get_transport_template_info(), OpenDDS::DCPS::TransportConfig::instances_, OpenDDS::DCPS::TransportRegistry::TransportTemplate::instantiate_per_participant, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::TransportInst::load(), OpenDDS::DCPS::TransportConfig::name(), ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, process_customizations(), ACE_Configuration::root_section(), ACE_Configuration_Heap::set_string_value(), TheServiceParticipant, OpenDDS::DCPS::to_dds_string(), and OpenDDS::DCPS::TransportRegistry::TransportEntry::transport_info.

Referenced by bind_config().

 {
   // check per_participant
   TransportTemplate templ;
   if (get_transport_template_info(ACE_TEXT_CHAR_TO_TCHAR(transport_config_name.c_str()), templ)) {
     if (!templ.instantiate_per_participant) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: TransportRegistry::")
                         ACE_TEXT("create_new_transport_instance_for_participant: ")
                         ACE_TEXT("transport_template missing instantiation_rule=per_participant\n")),
                       false);
     }
   }
 
   TransportConfig_rch cfg = get_config(transport_config_name);
 
   OPENDDS_STRING inst_name = cfg->instances_[0]->name() + "_" + to_dds_string(id) + "_" + transport_instance_name;
   OPENDDS_STRING config_name = cfg->name() + "_" + to_dds_string(id) + "_" + transport_instance_name;
 
   // assign new config and inst names
   transport_config_name = config_name;
   transport_instance_name = inst_name;
 
   OpenDDS::DCPS::TransportConfig_rch config = create_config(config_name);
   OpenDDS::DCPS::TransportInst_rch inst = create_inst(inst_name, "rtps_udp");
 
   ACE_Configuration_Heap ach;
   ACE_Configuration_Section_Key sect_key;
 
   ach.open();
   ach.open_section(ach.root_section(), ACE_TEXT("the_transport_setup"), true, sect_key);
 
   if (TheServiceParticipant->belongs_to_domain_range(id) ||
       config_has_transport_template(ACE_TEXT_CHAR_TO_TCHAR(transport_config_name.c_str()))) {
     TransportTemplate tr_inst;
 
     if (get_transport_template_info(ACE_TEXT_CHAR_TO_TCHAR(cfg->name().c_str()), tr_inst)) {
       ValueMap customs;
 
       if (!process_customizations(id, tr_inst, customs)) {
         ACE_ERROR_RETURN((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: TransportRegistry::")
                   ACE_TEXT("create_new_transport_instance_for_participant ")
                   ACE_TEXT("could not process_customizations\n")),
                  false);
       }
 
       // write
       for (ValueMap::const_iterator it = customs.begin(); it != customs.end(); ++it) {
         ach.set_string_value(sect_key, ACE_TEXT_CHAR_TO_TCHAR(it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(it->second.c_str()));
       }
     } else {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: TransportRegistry::")
                         ACE_TEXT("create_new_transport_instance_for_participant ")
                         ACE_TEXT("could not find transport_template for config %C\n"),
                         cfg->name().c_str()),
                        false);
     }
   } else {
     TransportEntry tr_inst;
     get_transport_info(ACE_TEXT_CHAR_TO_TCHAR(cfg->name().c_str()), tr_inst);
 
     for (ValueMap::const_iterator it = tr_inst.transport_info.begin();
          it != tr_inst.transport_info.end(); ++it) {
       ach.set_string_value(sect_key, ACE_TEXT_CHAR_TO_TCHAR(it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(it->second.c_str()));
       if (DCPS_debug_level > 0) {
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) TransportRegistry::")
                        ACE_TEXT("create_new_transport_entry_for_participant adding %C=%C\n"),
                    it->first.c_str(), it->second.c_str()));
       }
     }
   }
 
   inst->load(ach, sect_key);
   config->instances_.push_back(inst);
 
   return true;
 }

◆ create_transport_template_instance()

int OpenDDS::DCPS::TransportRegistry::create_transport_template_instance	(	DDS::DomainId_t	domain,
		const ACE_TString &	config_name
	)

Definition at line 870 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, config_map_, OpenDDS::DCPS::DCPS_debug_level, get_config_instance_name(), get_transport_template_info(), get_transport_template_instance_name(), has_transport_templates(), LM_DEBUG, LM_ERROR, load_transport_configuration(), ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, process_customizations(), ACE_Configuration::root_section(), ACE_Configuration_Heap::set_string_value(), and OpenDDS::DCPS::to_dds_string().

Referenced by bind_config(), and OpenDDS::DCPS::Service_Participant::configure_domain_range_instance().

 {
   OPENDDS_STRING transport_inst_name = get_transport_template_instance_name(domain);
   OPENDDS_STRING config_inst_name = get_config_instance_name(domain);
 
   // has it already been created?
   ConfigMap::const_iterator i = config_map_.find(config_inst_name);
   if (i != config_map_.end()) {
     return 0; // already created
   }
 
   if (has_transport_templates()) {
     TransportTemplate tr_inst;
 
     if (get_transport_template_info(config_name, tr_inst)) {
       ACE_Configuration_Heap tcf;
       tcf.open();
       const ACE_Configuration_Section_Key& root = tcf.root_section();
 
       // create config
       ACE_Configuration_Section_Key csect;
       tcf.open_section(root, ACE_TEXT("config"), true /* create */, csect);
       ACE_Configuration_Section_Key csub_sect;
       tcf.open_section(csect, ACE_TEXT_CHAR_TO_TCHAR(config_inst_name.c_str()), true /* create */, csub_sect);
       tcf.set_string_value(csub_sect, ACE_TEXT("transports"), ACE_TEXT_CHAR_TO_TCHAR(transport_inst_name.c_str()));
 
       // create matching transport section
       ACE_Configuration_Section_Key tsect;
       tcf.open_section(root, ACE_TEXT("transport"), true /* create */, tsect);
       ACE_Configuration_Section_Key tsub_sect;
       tcf.open_section(tsect, ACE_TEXT_CHAR_TO_TCHAR(transport_inst_name.c_str()), true /* create */, tsub_sect);
 
       ValueMap customs;
 
       if (!process_customizations(domain, tr_inst, customs)) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) ERROR: TransportRegistry::")
                           ACE_TEXT("create_transport_template_instance ")
                           ACE_TEXT("could not process_customizations\n")),
                          false);
       }
 
       // write
       for (ValueMap::const_iterator it = customs.begin(); it != customs.end(); ++it) {
         tcf.set_string_value(tsub_sect, ACE_TEXT_CHAR_TO_TCHAR(it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(it->second.c_str()));
 
         if (DCPS_debug_level > 0) {
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) TransportRegistry::")
                      ACE_TEXT("create_transport_template_instance adding %C=%C\n"),
                      it->first.c_str(), it->second.c_str()));
         }
       }
 
       // load transport
       int status = this->load_transport_configuration("transport_config_" + to_dds_string(domain), tcf);
 
       if (status != 0) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) ERROR: TransportRegistry::create_transport_template_instance ")
                           ACE_TEXT("load_transport_configuration() returned %d\n"),
                           status),
                         -1);
       }
 
     }
 
   }
 
   return 0;
 }

◆ domain_default_config() [1/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::domain_default_config	(	DDS::DomainId_t	domain,
		const TransportConfig_rch &	cfg
	)

Definition at line 43 of file TransportRegistry.inl.

References ACE_INLINE, domain_default_config_map_, and lock_.

Referenced by OpenDDS::DCPS::TransportClient::enable_transport(), and OpenDDS::DCPS::Service_Participant::load_domain_configuration().

 {
   GuardType guard(this->lock_);
   domain_default_config_map_[domain] = cfg;
 }

◆ domain_default_config() [2/2]

ACE_INLINE TransportConfig_rch OpenDDS::DCPS::TransportRegistry::domain_default_config ( DDS::DomainId_t domain ) const

Definition at line 52 of file TransportRegistry.inl.

References ACE_INLINE, domain_default_config_map_, and lock_.

 {
   GuardType guard(this->lock_);
   const DomainConfigMap::const_iterator iter =
     domain_default_config_map_.find(domain);
   return (iter == domain_default_config_map_.end())
     ? TransportConfig_rch() : iter->second;
 }

◆ fix_empty_default()

TransportConfig_rch OpenDDS::DCPS::TransportRegistry::fix_empty_default ( )

For internal use by OpenDDS DCPS layer: If the default config is empty when it's about to be used, allow the TransportRegistry to attempt to load a fallback option.

Definition at line 702 of file TransportRegistry.cpp.

References DBG_ENTRY_LVL, DEFAULT_CONFIG_NAME, global_config(), global_config_, OpenDDS::DCPS::TransportConfig::instances_, OpenDDS::DCPS::RcHandle< T >::is_nil(), load_transport_lib_i(), lock_, and OpenDDS::DCPS::TransportConfig::name().

Referenced by OpenDDS::DCPS::TransportClient::enable_transport().

 {
   DBG_ENTRY_LVL("TransportRegistry", "fix_empty_default", 6);
   GuardType guard(lock_);
   if (global_config_.is_nil()
       || !global_config_->instances_.empty()
       || global_config_->name() != DEFAULT_CONFIG_NAME) {
     return global_config_;
   }
   TransportConfig_rch global_config = global_config_;
   load_transport_lib_i(FALLBACK_TYPE);
   return global_config;
 }

◆ get_config()

TransportConfig_rch OpenDDS::DCPS::TransportRegistry::get_config ( const OPENDDS_STRING & name ) const

Definition at line 587 of file TransportRegistry.cpp.

References config_map_, and lock_.

Referenced by bind_config(), create_new_transport_instance_for_participant(), OpenDDS::DCPS::UdpLoader::init(), OpenDDS::DCPS::MulticastLoader::init(), OpenDDS::DCPS::TcpLoader::init(), DCPS_IR_Domain::init_built_in_topics_transport(), OpenDDS::DCPS::RtpsUdpLoader::load(), OpenDDS::DCPS::Service_Participant::load_configuration(), and OpenDDS::DCPS::Service_Participant::load_domain_configuration().

 {
   GuardType guard(lock_);
   ConfigMap::const_iterator found = config_map_.find(name);
   if (found != config_map_.end()) {
     return found->second;
   }
   return TransportConfig_rch();
 }

◆ get_config_instance_name()

OPENDDS_STRING OpenDDS::DCPS::TransportRegistry::get_config_instance_name ( DDS::DomainId_t id )

Definition at line 862 of file TransportRegistry.cpp.

References OpenDDS::DCPS::to_dds_string().

Referenced by OpenDDS::DCPS::Service_Participant::configure_domain_range_instance(), and create_transport_template_instance().

 {
   OpenDDS::DCPS::Discovery::RepoKey configured_name = "templ_config_";
   configured_name += to_dds_string(id);
   return configured_name;
 }

◆ get_inst()

TransportInst_rch OpenDDS::DCPS::TransportRegistry::get_inst ( const OPENDDS_STRING & name ) const

Definition at line 556 of file TransportRegistry.cpp.

References inst_map_, and lock_.

Referenced by load_transport_configuration().

 {
   GuardType guard(lock_);
   InstMap::const_iterator found = inst_map_.find(name);
   if (found != inst_map_.end()) {
     return found->second;
   }
   return TransportInst_rch();
 }

◆ get_transport_info()

bool OpenDDS::DCPS::TransportRegistry::get_transport_info	(	const ACE_TString &	config_name,
		TransportEntry &	inst
	)

private

Definition at line 1141 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::TransportRegistry::TransportEntry::config_name, OpenDDS::DCPS::DCPS_debug_level, has_transports(), LM_DEBUG, OPENDDS_VECTOR(), ACE_OS::strcmp(), OpenDDS::DCPS::TransportRegistry::TransportEntry::transport_info, and OpenDDS::DCPS::TransportRegistry::TransportEntry::transport_name.

Referenced by create_new_transport_instance_for_participant().

 {
   bool ret = false;
   if (has_transports()) {
     for (OPENDDS_VECTOR(TransportEntry)::const_iterator i = transports_.begin(); i != transports_.end(); ++i) {
       if (!ACE_OS::strcmp(ACE_TEXT_ALWAYS_CHAR(config_name.c_str()), ACE_TEXT_ALWAYS_CHAR(i->config_name.c_str()))) {
         inst.transport_name = i->transport_name;
         inst.config_name = i->config_name;
         inst.transport_info = i->transport_info;
 
         ret = true;
         break;
       }
     }
   }
 
   if (DCPS_debug_level > 0) {
     ACE_DEBUG((LM_DEBUG,
                ACE_TEXT("(%P|%t) TransportRegistry::get_transport_info: ")
                ACE_TEXT("%C config %s\n"),
                ret ? "found" : "did not find", config_name.c_str()));
   }
 
   return ret;
 }

◆ get_transport_template_info()

bool OpenDDS::DCPS::TransportRegistry::get_transport_template_info	(	const ACE_TString &	config_name,
		TransportTemplate &	inst
	)

private

Definition at line 955 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::TransportRegistry::TransportTemplate::config_name, OpenDDS::DCPS::TransportRegistry::TransportTemplate::customizations, OpenDDS::DCPS::DCPS_debug_level, has_transport_templates(), OpenDDS::DCPS::TransportRegistry::TransportTemplate::instantiate_per_participant, LM_DEBUG, OPENDDS_VECTOR(), ACE_OS::strcmp(), OpenDDS::DCPS::TransportRegistry::TransportTemplate::transport_info, and OpenDDS::DCPS::TransportRegistry::TransportTemplate::transport_template_name.

Referenced by create_new_transport_instance_for_participant(), and create_transport_template_instance().

 {
   bool ret = false;
   if (has_transport_templates()) {
     for (OPENDDS_VECTOR(TransportTemplate)::const_iterator i = transport_templates_.begin(); i != transport_templates_.end(); ++i) {
       if (!ACE_OS::strcmp(ACE_TEXT_ALWAYS_CHAR(config_name.c_str()), i->config_name.c_str())) {
         inst.transport_template_name = i->transport_template_name;
         inst.config_name = i->config_name;
         inst.instantiate_per_participant = i->instantiate_per_participant;
         inst.customizations = i->customizations;
         inst.transport_info = i->transport_info;
 
         ret = true;
         break;
       }
     }
   }
 
   if (DCPS_debug_level > 0) {
     ACE_DEBUG((LM_DEBUG,
                ACE_TEXT("(%P|%t) TransportRegistry::get_transport_template_info: ")
                ACE_TEXT("%C config %s\n"),
                ret ? "found" : "did not find", config_name.c_str()));
   }
 
   return ret;
 }

◆ get_transport_template_instance_name()

OPENDDS_STRING OpenDDS::DCPS::TransportRegistry::get_transport_template_instance_name ( DDS::DomainId_t id )

Definition at line 854 of file TransportRegistry.cpp.

References OPENDDS_STRING, and OpenDDS::DCPS::to_dds_string().

Referenced by create_transport_template_instance().

 {
   OpenDDS::DCPS::Discovery::RepoKey configured_name = "transport_template_instance_";
   configured_name += to_dds_string(id);
   return configured_name;
 }

◆ global_config() [1/2]

ACE_INLINE TransportConfig_rch OpenDDS::DCPS::TransportRegistry::global_config ( ) const

Definition at line 25 of file TransportRegistry.inl.

References ACE_INLINE, DBG_ENTRY_LVL, global_config_, and lock_.

Referenced by OpenDDS::DCPS::TransportClient::enable_transport(), fix_empty_default(), and OpenDDS::DCPS::Service_Participant::load_configuration().

 {
   DBG_ENTRY_LVL("TransportRegistry", "global_config()", 6);
   GuardType guard(this->lock_);
   return this->global_config_;
 }

◆ global_config() [2/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::global_config ( const TransportConfig_rch & cfg )

Definition at line 34 of file TransportRegistry.inl.

References ACE_INLINE, DBG_ENTRY_LVL, global_config_, and lock_.

 {
   DBG_ENTRY_LVL("TransportRegistry", "global_config(cfg)", 6);
   GuardType guard(this->lock_);
   this->global_config_ = cfg;
 }

◆ has_transport_templates()

bool OpenDDS::DCPS::TransportRegistry::has_transport_templates ( ) const

private

Definition at line 1135 of file TransportRegistry.cpp.

Referenced by create_transport_template_instance(), and get_transport_template_info().

 {
   return !transport_templates_.empty();
 }

◆ has_transports()

bool OpenDDS::DCPS::TransportRegistry::has_transports ( ) const

private

Definition at line 1167 of file TransportRegistry.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by get_transport_info().

 {
   return !transports_.empty();
 }

◆ instance()

TransportRegistry * OpenDDS::DCPS::TransportRegistry::instance ( void )

static

Return a singleton instance of this class.

Definition at line 53 of file TransportRegistry.cpp.

References ACE_Unmanaged_Singleton< TYPE, ACE_LOCK >::instance().

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), OpenDDS::DCPS::Service_Participant::configure_domain_range_instance(), OpenDDS::DCPS::TransportClient::enable_transport(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), DCPS_IR_Domain::init_built_in_topics_transport(), TAO_DDS_DCPSInfo_i::init_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), OpenDDS::Federator::ManagerImpl::initialize(), OpenDDS::DCPS::Service_Participant::load_configuration(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), OpenDDS::DCPS::StaticDiscovery::pre_reader(), OpenDDS::DCPS::StaticDiscovery::pre_writer(), OpenDDS::DCPS::Service_Participant::shutdown(), OpenDDS::DCPS::DataWriterImpl::wait_pending(), and OpenDDS::DCPS::WriteDataContainer::~WriteDataContainer().

 {
   return ACE_Unmanaged_Singleton<TransportRegistry, ACE_Recursive_Thread_Mutex>::instance();
 }

◆ load_transport_configuration()

int OpenDDS::DCPS::TransportRegistry::load_transport_configuration	(	const OPENDDS_STRING &	file_name,
		ACE_Configuration_Heap &	cf
	)

For internal use by OpenDDS DCPS layer: Transfer the configuration in ACE_Configuration_Heap object to the TransportRegistry. This is called by the Service_Participant at initialization time. This function iterates each section in the configuration file, and creates TransportInst and TransportConfig objects and adds them to the registry.

Definition at line 90 of file TransportRegistry.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_TEXT_CHAR_TO_TCHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::CONFIG_SECTION_NAME, OpenDDS::DCPS::convertToInteger(), create_config(), create_inst(), ACE_Configuration_Heap::enumerate_sections(), get_inst(), OpenDDS::DCPS::TransportConfig::instances_, LM_ERROR, OpenDDS::DCPS::TransportConfig::name(), name, ACE_Configuration_Heap::open_section(), OpenDDS::DCPS::OPENDDS_LIST(), OPENDDS_STRING, OPENDDS_VECTOR(), OpenDDS::DCPS::TransportConfig::passive_connect_duration_, OpenDDS::DCPS::processSections(), OpenDDS::DCPS::pullValues(), ACE_Configuration::root_section(), ACE_OS::strcmp(), OpenDDS::DCPS::TransportConfig::swap_bytes_, OpenDDS::DCPS::TransportRegistry::TransportEntry::transport_info, OpenDDS::DCPS::TransportRegistry::TransportEntry::transport_name, OpenDDS::DCPS::TRANSPORT_SECTION_NAME, OpenDDS::DCPS::TRANSPORT_TEMPLATE_SECTION_NAME, and value.

Referenced by create_transport_template_instance(), and OpenDDS::DCPS::Service_Participant::load_configuration().

 {
   const ACE_Configuration_Section_Key& root = cf.root_section();
 
   // Create a vector to hold configuration information so we can populate
   // them after the transports instances are created.
   typedef std::pair<TransportConfig_rch, OPENDDS_VECTOR(OPENDDS_STRING) > ConfigInfo;
   OPENDDS_VECTOR(ConfigInfo) configInfoVec;
 
   // Record the transport instances created, so we can place them
   // in the implicit transport configuration for this file.
   OPENDDS_LIST(TransportInst_rch) instances;
 
   ACE_TString sect_name;
 
   for (int index = 0;
        cf.enumerate_sections(root, index, sect_name) == 0;
        ++index) {
     if (ACE_OS::strcmp(sect_name.c_str(), TRANSPORT_SECTION_NAME) == 0 ||
         ACE_OS::strcmp(sect_name.c_str(), TRANSPORT_TEMPLATE_SECTION_NAME) == 0) {
       // found the [transport/*] or [transport_template/*] section,
       // now iterate through subsections...
       ACE_Configuration_Section_Key sect;
       if (cf.open_section(root, sect_name.c_str(), false, sect) != 0) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                           ACE_TEXT("failed to open section %C\n"),
                           sect_name.c_str()),
                          -1);
       } else {
         // Ensure there are no properties in this section
         ValueMap vm;
         if (pullValues(cf, sect, vm) > 0) {
           // There are values inside [transport]
           ACE_ERROR_RETURN((LM_ERROR,
                             ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                             ACE_TEXT("transport sections must have a section name\n"),
                             sect_name.c_str()),
                            -1);
         }
         // Process the subsections of this section (the individual transport
         // impls).
         KeyList keys;
         if (processSections(cf, sect, keys) != 0) {
           ACE_ERROR_RETURN((LM_ERROR,
                             ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                             ACE_TEXT("too many nesting layers in [%C] section.\n"),
                             sect_name.c_str()),
                            -1);
         }
         for (KeyList::const_iterator it = keys.begin(); it != keys.end(); ++it) {
           ACE_TString transport_id = ACE_TEXT_CHAR_TO_TCHAR(it->first.c_str());
           ACE_Configuration_Section_Key inst_sect = it->second;
 
           ValueMap values;
           if (pullValues(cf, it->second, values) != 0) {
             // Get the factory_id for the transport.
             OPENDDS_STRING transport_type;
             ValueMap::const_iterator vm_it = values.find("transport_type");
             if (vm_it != values.end()) {
               transport_type = vm_it->second;
             } else {
               ACE_ERROR_RETURN((LM_ERROR,
                                 ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                                 ACE_TEXT("missing transport_type in [transport/%C] section.\n"),
                                 transport_id.c_str()),
                                -1);
             }
 
             // Create the TransportInst object and load the transport
             // configuration in ACE_Configuration_Heap to the TransportInst
             // object.
             const OPENDDS_STRING tid_str = transport_id.c_str() ? ACE_TEXT_ALWAYS_CHAR(transport_id.c_str()) : "";
             TransportInst_rch inst = create_inst(tid_str, transport_type);
             if (!inst) {
               ACE_ERROR_RETURN((LM_ERROR,
                                 ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                                 ACE_TEXT("Unable to create transport instance in [transport/%C] section.\n"),
                                 transport_id.c_str()),
                                -1);
             }
 
             instances.push_back(inst);
             inst->load(cf, inst_sect);
 
             // store the transport info
             TransportEntry entry;
             entry.transport_name = transport_id;
             entry.transport_info = values;
             transports_.push_back(entry);
           } else {
             ACE_ERROR_RETURN((LM_ERROR,
                               ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                               ACE_TEXT("missing transport_type in [transport/%C] section.\n"),
                               transport_id.c_str()),
                              -1);
           }
         }
       }
     } else if (ACE_OS::strcmp(sect_name.c_str(), CONFIG_SECTION_NAME) == 0) {
       // found the [config/*] section, now iterate through subsections...
       ACE_Configuration_Section_Key sect;
       if (cf.open_section(root, sect_name.c_str(), false, sect) != 0) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                           ACE_TEXT("failed to open section [%C]\n"),
                           sect_name.c_str()),
                          -1);
       } else {
         // Ensure there are no properties in this section
         ValueMap vm;
         if (pullValues(cf, sect, vm) > 0) {
           // There are values inside [config]
           ACE_ERROR_RETURN((LM_ERROR,
                             ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                             ACE_TEXT("config sections must have a section name\n"),
                             sect_name.c_str()),
                            -1);
         }
         // Process the subsections of this section (the individual config
         // impls).
         KeyList keys;
         if (processSections(cf, sect, keys) != 0) {
           // Don't allow multiple layers of nesting ([config/x/y]).
           ACE_ERROR_RETURN((LM_ERROR,
                             ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                             ACE_TEXT("too many nesting layers in [%C] section.\n"),
                             sect_name.c_str()),
                            -1);
         }
         for (KeyList::const_iterator it = keys.begin(); it != keys.end(); ++it) {
           OPENDDS_STRING config_id = it->first;
 
           // Create a TransportConfig object.
           TransportConfig_rch config = create_config(config_id);
           if (!config) {
             ACE_ERROR_RETURN((LM_ERROR,
                               ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                               ACE_TEXT("Unable to create transport config in [config/%C] section.\n"),
                               config_id.c_str()),
                              -1);
           }
 
           ValueMap values;
           pullValues(cf, it->second, values);
 
           ConfigInfo configInfo;
           configInfo.first = config;
           for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
             OPENDDS_STRING name = it->first;
             OPENDDS_STRING value = it->second;
             if (name == "transports") {
               char delim = ',';
               size_t pos = 0;
               OPENDDS_STRING token;
               while ((pos = value.find(delim)) != OPENDDS_STRING::npos) {
                 token = value.substr(0, pos);
                 configInfo.second.push_back(token);
                 value.erase(0, pos + 1);
               }
 
               // does this config specify a transport_template?
               for (OPENDDS_VECTOR(TransportTemplate)::iterator it = transport_templates_.begin(); it != transport_templates_.end(); ++it) {
                 if (it->transport_template_name == value) {
                   it->config_name = config_id;
                   break;
                 }
               }
 
               // store the config name for the transport entry
               for (OPENDDS_VECTOR(TransportEntry)::iterator it = transports_.begin(); it != transports_.end(); ++it) {
                 if (!ACE_OS::strcmp(ACE_TEXT_ALWAYS_CHAR(it->transport_name.c_str()), value.c_str())) {
                   it->config_name = ACE_TEXT_CHAR_TO_TCHAR(config_id.c_str());
                   break;
                 }
               }
 
               configInfo.second.push_back(value);
 
               configInfoVec.push_back(configInfo);
             } else if (name == "swap_bytes") {
               if ((value == "1") || (value == "true")) {
                 config->swap_bytes_ = true;
               } else if ((value != "0") && (value != "false")) {
                 ACE_ERROR_RETURN((LM_ERROR,
                                   ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                                   ACE_TEXT("Illegal value for swap_bytes (%C) in [config/%C] section.\n"),
                                   value.c_str(), config_id.c_str()),
                                  -1);
               }
             } else if (name == "passive_connect_duration") {
               if (!convertToInteger(value,
                                     config->passive_connect_duration_)) {
                 ACE_ERROR_RETURN((LM_ERROR,
                                   ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                                   ACE_TEXT("Illegal integer value for passive_connect_duration (%C) in [config/%C] section.\n"),
                                   value.c_str(), config_id.c_str()),
                                  -1);
               }
             } else {
               ACE_ERROR_RETURN((LM_ERROR,
                                 ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                                 ACE_TEXT("Unexpected entry (%C) in [config/%C] section.\n"),
                                 name.c_str(), config_id.c_str()),
                                -1);
             }
           }
           if (configInfo.second.empty()) {
             ACE_ERROR_RETURN((LM_ERROR,
                               ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                               ACE_TEXT("No transport instances listed in [config/%C] section.\n"),
                               config_id.c_str()),
                              -1);
           }
         }
       }
     }
   }
 
   // Populate the configurations with instances
   for (unsigned int i = 0; i < configInfoVec.size(); ++i) {
     TransportConfig_rch config = configInfoVec[i].first;
     OPENDDS_VECTOR(OPENDDS_STRING)& insts = configInfoVec[i].second;
     for (unsigned int j = 0; j < insts.size(); ++j) {
       TransportInst_rch inst = get_inst(insts[j]);
       if (!inst) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                           ACE_TEXT("The inst (%C) in [config/%C] section is undefined.\n"),
                           insts[j].c_str(), config->name().c_str()),
                          -1);
       }
       config->instances_.push_back(inst);
     }
   }
 
   // Create and populate the default configuration for this
   // file with all the instances from this file.
   if (!instances.empty()) {
     TransportConfig_rch config = create_config(file_name);
     if (!config) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) TransportRegistry::load_transport_configuration: ")
                         ACE_TEXT("Unable to create default transport config.\n"),
                         file_name.c_str()),
                        -1);
     }
     instances.sort(predicate);
     for (OPENDDS_LIST(TransportInst_rch)::const_iterator it = instances.begin();
          it != instances.end(); ++it) {
       config->instances_.push_back(*it);
     }
   }
 
   return 0;
 }

◆ load_transport_lib()

void OpenDDS::DCPS::TransportRegistry::load_transport_lib ( const OPENDDS_STRING & transport_type )

For internal use by OpenDDS DCPS layer: Dynamically load the library for the supplied transport type.

Definition at line 482 of file TransportRegistry.cpp.

References ACE_ERROR, ACE_TEXT(), LM_ERROR, load_transport_lib_i(), and lock_.

 {
   GuardType guard(lock_);
   if (!load_transport_lib_i(transport_type)) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) TransportRegistry::load_transport_lib: ")
                ACE_TEXT("could not load transport_type=%C.\n"),
                transport_type.c_str()));
   }
 }

◆ load_transport_lib_i()

TransportType_rch OpenDDS::DCPS::TransportRegistry::load_transport_lib_i ( const OPENDDS_STRING & transport_type )

private

Definition at line 494 of file TransportRegistry.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::find(), lib_directive_map_, LM_ERROR, lock_, ACE_Service_Config::process_directive(), and type_map_.

Referenced by create_inst(), fix_empty_default(), and load_transport_lib().

 {
   TransportType_rch type;
   if (find(type_map_, transport_type, type) == 0) {
     return type;
   }
 
 #if !defined(ACE_AS_STATIC_LIBS)
   // Attempt to load it.
   LibDirectiveMap::iterator lib_iter = lib_directive_map_.find(transport_type);
   if (lib_iter == lib_directive_map_.end()) {
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) TransportRegistry::load_transport_lib_i: ")
                ACE_TEXT("no directive for transport_type=%C.\n"),
                transport_type.c_str()));
     return type;
   }
 
   ACE_TString directive = ACE_TEXT_CHAR_TO_TCHAR(lib_iter->second.c_str());
   // Release the lock because the transport will call back into the registry.
   ACE_Reverse_Lock<LockType> rev_lock(lock_);
   {
     ACE_Guard<ACE_Reverse_Lock<LockType> > guard(rev_lock);
     if (0 != ACE_Service_Config::process_directive(directive.c_str())) {
       return TransportType_rch();
     }
   }
 #endif
 
   find(type_map_, transport_type, type);
   return type;
 }

◆ load_transport_templates()

int OpenDDS::DCPS::TransportRegistry::load_transport_templates ( ACE_Configuration_Heap & cf )

For internal use by OpenDDS DCPS layer: Process the transport_template configuration in the ACE_Configuration_Heap object. Called by the Service_Participant at initialization time.

Definition at line 349 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, OpenDDS::DCPS::CUSTOMIZATION_SECTION_NAME, OpenDDS::DCPS::TransportRegistry::TransportTemplate::customizations, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TransportRegistry::TransportTemplate::instantiate_per_participant, LM_DEBUG, LM_ERROR, LM_NOTICE, name, ACE_Configuration_Heap::open_section(), OPENDDS_STRING, OpenDDS::DCPS::processSections(), OpenDDS::DCPS::pullValues(), ACE_Configuration::root_section(), OpenDDS::DCPS::TransportRegistry::TransportTemplate::transport_info, OpenDDS::DCPS::TransportRegistry::TransportTemplate::transport_template_name, and OpenDDS::DCPS::TRANSPORT_TEMPLATE_SECTION_NAME.

Referenced by OpenDDS::DCPS::Service_Participant::load_configuration().

 {
   const ACE_Configuration_Section_Key& root = cf.root_section();
   ACE_Configuration_Section_Key transport_sect;
 
   if (cf.open_section(root, TRANSPORT_TEMPLATE_SECTION_NAME, false, transport_sect) != 0) {
     if (DCPS_debug_level > 0) {
       // This is not an error if the configuration file does not have
       // any domain range (sub)section.
       ACE_DEBUG((LM_NOTICE,
                  ACE_TEXT("(%P|%t) NOTICE: TransportRegistry::load_transport_templates(): ")
                  ACE_TEXT("config does not have a [%s] section.\n"),
                  TRANSPORT_TEMPLATE_SECTION_NAME));
     }
 
     return 0;
 
   } else {
     if (DCPS_debug_level > 0) {
       ACE_DEBUG((LM_NOTICE,
                    ACE_TEXT("(%P|%t) NOTICE: TransportRegistry::load_transport_templates(): ")
                    ACE_TEXT("config has %s sections.\n"),
                    TRANSPORT_TEMPLATE_SECTION_NAME));
     }
 
     // Ensure there are no properties in this section
     ValueMap vm;
     if (pullValues(cf, transport_sect, vm) > 0) {
       // There are values inside [transport_template]
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: TransportRegistry::load_transport_templates(): ")
                         ACE_TEXT("%s sections must have a subsection name\n"),
                         TRANSPORT_TEMPLATE_SECTION_NAME),
                      -1);
     }
     // Process the subsections of this section (the individual domains)
     KeyList keys;
     if (processSections(cf, transport_sect, keys) != 0) {
       ACE_ERROR_RETURN((LM_ERROR,
                         ACE_TEXT("(%P|%t) ERROR: TransportRegistry::load_transport_templates(): ")
                         ACE_TEXT("too many nesting layers in the [%s] section.\n"),
                         TRANSPORT_TEMPLATE_SECTION_NAME),
                        -1);
     }
 
     // Loop through the [transport_template/*] sections
     for (KeyList::const_iterator it = keys.begin(); it != keys.end(); ++it) {
       TransportTemplate element;
       element.instantiate_per_participant = false;
       element.transport_template_name = it->first;
 
       if (DCPS_debug_level > 0) {
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) TransportRegistry::load_transport_templates(): ")
                    ACE_TEXT("processing [%s/%C]\n"),
                    TRANSPORT_TEMPLATE_SECTION_NAME, element.transport_template_name.c_str()));
       }
 
       ValueMap values;
       pullValues(cf, it->second, values);
       OPENDDS_STRING rule;
       OPENDDS_STRING customization;
 
       for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
         OPENDDS_STRING name = it->first;
         if (name == "instantiation_rule") {
           rule = it->second;
           if (rule == "per_participant") {
             element.instantiate_per_participant = true;
           }
           if (DCPS_debug_level > 0) {
             OPENDDS_STRING flag = element.instantiate_per_participant ? "true" : "false";
             ACE_DEBUG((LM_DEBUG,
                        ACE_TEXT("(%P|%t) TransportRegistry::load_transport_templates(): ")
                        ACE_TEXT("[%s/%C]: instantiantion rule == %C\n"),
                        TRANSPORT_TEMPLATE_SECTION_NAME, element.transport_template_name.c_str(), flag.c_str()));
           }
         } else if (name == ACE_TEXT_ALWAYS_CHAR(CUSTOMIZATION_SECTION_NAME)) {
           customization = it->second;
           if (DCPS_debug_level > 0) {
             ACE_DEBUG((LM_DEBUG,
                        ACE_TEXT("(%P|%t) TransportRegistry::load_transport_templates(): ")
                        ACE_TEXT("[%s/%C]: customization == %C\n"),
                        TRANSPORT_TEMPLATE_SECTION_NAME, element.transport_template_name.c_str(), customization.c_str()));
           }
 
           ACE_Configuration_Section_Key custom_sect;
           if (cf.open_section(root, CUSTOMIZATION_SECTION_NAME, false, custom_sect) == 0) {
             ValueMap vcm;
 
             if (pullValues(cf, custom_sect, vcm) > 0) {
               ACE_ERROR_RETURN((LM_ERROR,
                                 ACE_TEXT("(%P|%t) ERROR: TransportRegistry::load_transport_templates(): ")
                                 ACE_TEXT("%s sections must have a subsection name\n"),
                                 CUSTOMIZATION_SECTION_NAME),
                                 -1);
             }
 
             // Process the subsections of the custom section
             KeyList keys;
             if (processSections(cf, custom_sect, keys) != 0) {
               ACE_ERROR_RETURN((LM_ERROR,
                                 ACE_TEXT("(%P|%t) TransportRegistry::load_transport_templates(): ")
                                 ACE_TEXT("too many nesting layers in the [%s] section.\n"),
                                 CUSTOMIZATION_SECTION_NAME),
                                 -1);
               }
 
               // add customizations to domain range
               for (KeyList::const_iterator iter = keys.begin(); iter != keys.end(); ++iter) {
                 if (customization == iter->first) {
                   ValueMap values;
                   pullValues(cf, iter->second, values);
 
                   for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
                     element.customizations[it->first] = it->second;
                   }
                 }
               }
             }
         } else {
           element.transport_info[it->first] = it->second;
         }
       }
 
       transport_templates_.push_back(element);
     }
   }
 
   return 0;
 }

◆ OPENDDS_MAP() [1/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	OPENDDS_STRING	,
		TransportType_rch
	)

private

◆ OPENDDS_MAP() [2/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	OPENDDS_STRING	,
		TransportConfig_rch
	)

private

◆ OPENDDS_MAP() [3/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	OPENDDS_STRING	,
		TransportInst_rch
	)

private

◆ OPENDDS_MAP() [4/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	OPENDDS_STRING	,
		OPENDDS_STRING
	)

private

◆ OPENDDS_MAP() [5/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	DDS::DomainId_t	,
		TransportConfig_rch
	)

private

◆ OPENDDS_MAP() [6/6]

typedef OpenDDS::DCPS::TransportRegistry::OPENDDS_MAP	(	OPENDDS_STRING	,
		OPENDDS_STRING
	)

private

◆ OPENDDS_VECTOR() [1/2]

OpenDDS::DCPS::TransportRegistry::OPENDDS_VECTOR ( TransportTemplate )

private

Referenced by bind_config(), config_has_transport_template(), get_transport_info(), get_transport_template_info(), and load_transport_configuration().

◆ OPENDDS_VECTOR() [2/2]

OpenDDS::DCPS::TransportRegistry::OPENDDS_VECTOR ( TransportEntry )

private

◆ process_customizations()

bool OpenDDS::DCPS::TransportRegistry::process_customizations	(	const DDS::DomainId_t	id,
		const TransportTemplate &	tr_inst,
		ValueMap &	customs
	)

private

Definition at line 983 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::convertToInteger(), CUSTOM_ADD_DOMAIN_TO_IP, CUSTOM_ADD_DOMAIN_TO_PORT, OpenDDS::DCPS::TransportRegistry::TransportTemplate::customizations, OpenDDS::DCPS::DCPS_debug_level, LM_DEBUG, LM_ERROR, OPENDDS_STRING, OpenDDS::DCPS::remove(), OpenDDS::DCPS::to_dds_string(), and OpenDDS::DCPS::TransportRegistry::TransportTemplate::transport_info.

Referenced by create_new_transport_instance_for_participant(), and create_transport_template_instance().

 {
   for (ValueMap::const_iterator it = tr_inst.transport_info.begin();
        it != tr_inst.transport_info.end(); ++it) {
     // customization.
     ValueMap::const_iterator idx = tr_inst.customizations.find(it->first);
     if (idx != tr_inst.customizations.end()) {
       OPENDDS_STRING addr = it->second;
       OPENDDS_STRING custom = idx->second;
 
       // check for 'add_domain_id_to_ip_addr' and 'add_domain_id_to_port'
       bool add_to_ip = false;
       bool add_to_port = false;
 
       OPENDDS_STRING val1;
       OPENDDS_STRING val2;
 
       size_t comma_pos = custom.find(',');
       if (comma_pos != OPENDDS_STRING::npos) {
         val1 = custom.substr(0, comma_pos);
         // remove spaces
         val1.erase(std::remove(val1.begin(), val1.end(), ' '), val1.end());
 
         val2 = custom.substr(comma_pos + 1);
         val2.erase(std::remove(val2.begin(), val2.end(), ' '), val2.end());
 
         add_to_ip = (val1 == CUSTOM_ADD_DOMAIN_TO_IP || val2 == CUSTOM_ADD_DOMAIN_TO_IP);
         add_to_port = (val1 == CUSTOM_ADD_DOMAIN_TO_PORT || val2 == CUSTOM_ADD_DOMAIN_TO_PORT);
 
       } else {
         custom.erase(std::remove(custom.begin(), custom.end(), ' '), custom.end());
 
         add_to_ip = (custom == CUSTOM_ADD_DOMAIN_TO_IP);
         add_to_port = (custom == CUSTOM_ADD_DOMAIN_TO_PORT);
       }
 
       if (!add_to_ip && !add_to_port) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) TransportRegistry::process_customizations: ")
                           ACE_TEXT("%C customization is not supported. Supported values are %C and %C\n"),
                           custom.c_str(), CUSTOM_ADD_DOMAIN_TO_IP.c_str(), CUSTOM_ADD_DOMAIN_TO_PORT.c_str()),
                          false);
       }
 
       // only add_domain_id_to_ip_addr and add_domain_id_to_port are supported at this time.
       if (add_to_ip) {
         size_t pos = addr.find_last_of(".");
         if (pos != OPENDDS_STRING::npos) {
           OPENDDS_STRING custom = addr.substr(pos + 1);
 
           OPENDDS_STRING port = "";
           OPENDDS_STRING last_octet = "";
 
           size_t cpos = custom.find(":");
           if (cpos != OPENDDS_STRING::npos) {
             port = custom.substr(cpos);
             last_octet = custom.substr(0, cpos);
           } else {
             last_octet = custom;
           }
           int val = 0;
 
           if (!convertToInteger(last_octet, val)) {
             ACE_ERROR_RETURN((LM_ERROR,
                               ACE_TEXT("(%P|%t) ERROR: TransportRegistry::")
                               ACE_TEXT("process_customizations ")
                               ACE_TEXT("could not convert %C to integer\n"),
                               custom.c_str()),
                              false);
           }
 
           val += id;
           addr = addr.substr(0, pos);
           addr += "." + to_dds_string(val);
           if (port != "") {
             addr += port;
           }
         } else {
           ACE_ERROR_RETURN((LM_ERROR,
                             ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                             ACE_TEXT("process_customizations ")
                             ACE_TEXT("could not add_domain_id_to_ip_addr for address %C\n"),
                             idx->second.c_str()),
                            false);
         }
 
         if (DCPS_debug_level > 0) {
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) TransportRegistry::")
                      ACE_TEXT("process_customizations processing add_domain_id_to_ip_addr: %C=%C\n"),
                      it->first.c_str(), addr.c_str()));
         }
       }
 
       if (add_to_port) {
         size_t pos = addr.find_last_of(":");
         if (pos == OPENDDS_STRING::npos) {
           // use default port + domainId. See 9.6.1.3 in the RTPS 2.2 protocol specification.
           const int PB = 7400;
           const int DG = 250;
           const int D2 = 1;
           int rtpsPort = PB + DG * id + D2;
           rtpsPort += id;
           addr += ":" + to_dds_string(rtpsPort);
         } else {
           // address has a port supplied
           int rtpsPort = -1;
           if (convertToInteger(addr.substr(pos + 1), rtpsPort)) {
             addr = addr.substr(0, pos);
             rtpsPort += id;
             addr += ":" + to_dds_string(rtpsPort);
           } else {
             ACE_ERROR_RETURN((LM_ERROR,
                               ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                               ACE_TEXT("process_customizations ")
                               ACE_TEXT("could not add_domain_id_to_port for %C.\n"),
                               idx->second.c_str()),
                              false);
           }
 
           if (DCPS_debug_level > 0) {
             ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) TransportRegistry::")
                      ACE_TEXT("process_customizations processing add_domain_id_to_port: %C ==> %C\n"),
                      it->first.c_str(), addr.c_str()));
           }
 
         }
 
         if (DCPS_debug_level > 0) {
           ACE_DEBUG((LM_DEBUG,
                      ACE_TEXT("(%P|%t) TransportRegistry::")
                      ACE_TEXT("process_customizations processing add_domain_id_to_port: %C=%C\n"),
                      it->first.c_str(), addr.c_str()));
         }
       }
 
       customs[idx->first] = addr.c_str();
     } else {
       customs[it->first] = it->second.c_str();
       if (DCPS_debug_level > 0) {
         ACE_DEBUG((LM_DEBUG,
                    ACE_TEXT("(%P|%t) TransportRegistry::")
                    ACE_TEXT("process_customizations adding %C=%C\n"),
                    it->first.c_str(), it->second.c_str()));
       }
     }
   }
 
   return true;
 }

◆ register_type()

bool OpenDDS::DCPS::TransportRegistry::register_type ( const TransportType_rch & type )

SPI (Service Provider Interface) for specific transport types: This function is called as the concrete transport library is loaded. The concrete transport library creates a concrete transport type object and registers it with TransportRegistry singleton. Returns true for success.

Definition at line 718 of file TransportRegistry.cpp.

References DBG_ENTRY_LVL, lock_, name, OPENDDS_STRING, and type_map_.

Referenced by OpenDDS::DCPS::MulticastLoader::init(), OpenDDS::DCPS::ShmemLoader::init(), OpenDDS::DCPS::UdpLoader::init(), OpenDDS::DCPS::TcpLoader::init(), OpenDDS::DCPS::RtpsUdpLoader::load(), and OpenDDS::DCPS::InfoRepoDiscovery::StaticInitializer::StaticInitializer().

 {
   DBG_ENTRY_LVL("TransportRegistry", "register_type", 6);
   const OPENDDS_STRING name = type->name();
 
   GuardType guard(this->lock_);
   if (type_map_.count(name)) {
     return false;
   }
 
   type_map_[name] = type;
 
   if (name == "rtps_udp") {
     type_map_["rtps_discovery"] = type;
   }
 
   return true;
 }

◆ release()

void OpenDDS::DCPS::TransportRegistry::release ( void )

This will shutdown all TransportImpl objects.

Client Application calls this method to tear down the transport framework.

Definition at line 826 of file TransportRegistry.cpp.

References config_map_, config_template_to_instance_map_, DBG_ENTRY_LVL, domain_default_config_map_, global_config_, inst_map_, lock_, released_, OpenDDS::DCPS::RcHandle< T >::reset(), and type_map_.

Referenced by OpenDDS::DCPS::Service_Participant::shutdown().

 {
   DBG_ENTRY_LVL("TransportRegistry", "release", 6);
   GuardType guard(lock_);
   released_ = true;
 
   for (InstMap::iterator iter = inst_map_.begin(); iter != inst_map_.end(); ++iter) {
     iter->second->shutdown();
   }
 
   config_template_to_instance_map_.clear();
   transport_templates_.clear();
   transports_.clear();
   type_map_.clear();
   inst_map_.clear();
   config_map_.clear();
   domain_default_config_map_.clear();
   global_config_.reset();
 }

◆ released()

bool OpenDDS::DCPS::TransportRegistry::released ( ) const

Definition at line 847 of file TransportRegistry.cpp.

References lock_, OPENDDS_STRING, and released_.

Referenced by OpenDDS::DCPS::WriteDataContainer::~WriteDataContainer().

 {
   GuardType guard(lock_);
   return released_;
 }

◆ remove_config() [1/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::remove_config ( const TransportConfig_rch & cfg )

Definition at line 90 of file TransportRegistry.inl.

References ACE_INLINE, and OpenDDS::DCPS::TransportConfig::name().

Referenced by remove_transport_template_instance().

 {
   remove_config(cfg->name());
 }

◆ remove_config() [2/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::remove_config ( const OPENDDS_STRING & config_name )

Definition at line 97 of file TransportRegistry.inl.

References ACE_INLINE, config_map_, and lock_.

 {
   GuardType guard(this->lock_);
   config_map_.erase(config_name);
 }

◆ remove_inst() [1/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::remove_inst ( const TransportInst_rch & inst )

Removing a TransportInst from the registry shuts down the underlying transport implementation (if one was started) and therefore should only be attempted after DDS Entities using this transport have been deleted.

Definition at line 63 of file TransportRegistry.inl.

References ACE_INLINE, and OpenDDS::DCPS::TransportInst::name().

Referenced by remove_transport_template_instance().

 {
   remove_inst(inst->name());
 }

◆ remove_inst() [2/2]

ACE_INLINE void OpenDDS::DCPS::TransportRegistry::remove_inst ( const OPENDDS_STRING & inst_name )

Definition at line 70 of file TransportRegistry.inl.

References ACE_INLINE, inst_map_, lock_, and OpenDDS::DCPS::TransportInst::shutdown().

 {
   TransportInst_rch inst;
   {
     GuardType guard(this->lock_);
     InstMap::iterator iter = inst_map_.find(inst_name);
     if (iter == inst_map_.end()) {
       return;
     }
     inst = iter->second;
     inst_map_.erase(iter);
   }
 
   if (inst) {
     inst->shutdown();
   }
 }

◆ remove_transport_template_instance()

void OpenDDS::DCPS::TransportRegistry::remove_transport_template_instance ( const OPENDDS_STRING & config_name )

Definition at line 673 of file TransportRegistry.cpp.

References ACE_DEBUG, ACE_TEXT(), config_template_to_instance_map_, OpenDDS::DCPS::DCPS_debug_level, LM_DEBUG, OPENDDS_STRING, remove_config(), and remove_inst().

 {
   ConfigTemplateToInstanceMap::iterator i = config_template_to_instance_map_.find(config_name);
   if (i == config_template_to_instance_map_.end()) {
     if (DCPS_debug_level > 4) {
       ACE_DEBUG((LM_DEBUG,
                ACE_TEXT("(%P|%t) TransportRegistry::remove_transport_template_instance: ")
                ACE_TEXT("%C is not a transport template instance.\n"),
                config_name.c_str()));
     }
     return;
   }
 
   const OPENDDS_STRING inst_name = i->second;
   remove_config(config_name);
   remove_inst(inst_name);
 
   if (DCPS_debug_level > 0) {
     ACE_DEBUG((LM_DEBUG,
                ACE_TEXT("(%P|%t) DomainParticipantFactoryImpl::delete_participant ")
                ACE_TEXT("deleted TransportRegistry's dynamically created config %C and instance %C\n"),
                config_name.c_str(), inst_name.c_str()));
   }
 
   config_template_to_instance_map_.erase(i);
 }

◆ update_config_template_instance_info()

void OpenDDS::DCPS::TransportRegistry::update_config_template_instance_info	(	const OPENDDS_STRING &	config_name,
		const OPENDDS_STRING &	inst_name
	)

Definition at line 820 of file TransportRegistry.cpp.

References config_template_to_instance_map_.

Referenced by bind_config().

 {
   config_template_to_instance_map_[config_name] = inst_name;
 }

Friends And Related Function Documentation

◆ ACE_Singleton< TransportRegistry, ACE_Recursive_Thread_Mutex >

friend class ACE_Singleton< TransportRegistry, ACE_Recursive_Thread_Mutex >

friend

Definition at line 137 of file TransportRegistry.h.

Member Data Documentation

◆ config_map_

ConfigMap OpenDDS::DCPS::TransportRegistry::config_map_

private

Definition at line 153 of file TransportRegistry.h.

Referenced by create_config(), create_transport_template_instance(), get_config(), release(), remove_config(), and TransportRegistry().

◆ config_template_to_instance_map_

ConfigTemplateToInstanceMap OpenDDS::DCPS::TransportRegistry::config_template_to_instance_map_

private

Definition at line 157 of file TransportRegistry.h.

Referenced by release(), remove_transport_template_instance(), and update_config_template_instance_info().

◆ CUSTOM_ADD_DOMAIN_TO_IP

const OPENDDS_STRING OpenDDS::DCPS::TransportRegistry::CUSTOM_ADD_DOMAIN_TO_IP = "add_domain_id_to_ip_addr"

staticprivate

Definition at line 165 of file TransportRegistry.h.

Referenced by close(), and process_customizations().

◆ CUSTOM_ADD_DOMAIN_TO_PORT

const OPENDDS_STRING OpenDDS::DCPS::TransportRegistry::CUSTOM_ADD_DOMAIN_TO_PORT = "add_domain_id_to_port"

staticprivate

Definition at line 166 of file TransportRegistry.h.

Referenced by close(), and process_customizations().

◆ DEFAULT_CONFIG_NAME

const char OpenDDS::DCPS::TransportRegistry::DEFAULT_CONFIG_NAME = "_OPENDDS_DEFAULT_CONFIG"

static

Definition at line 70 of file TransportRegistry.h.

Referenced by close(), OpenDDS::DCPS::TransportClient::enable_transport(), fix_empty_default(), and TransportRegistry().

◆ DEFAULT_INST_PREFIX

const char OpenDDS::DCPS::TransportRegistry::DEFAULT_INST_PREFIX = "_OPENDDS_"

static

Definition at line 71 of file TransportRegistry.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), close(), OpenDDS::RTPS::Sedp::init(), DCPS_IR_Domain::init_built_in_topics_transport(), TAO_DDS_DCPSInfo_i::init_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), and OpenDDS::Federator::ManagerImpl::initialize().

◆ domain_default_config_map_

DomainConfigMap OpenDDS::DCPS::TransportRegistry::domain_default_config_map_

private

Definition at line 156 of file TransportRegistry.h.

Referenced by domain_default_config(), and release().

◆ global_config_

TransportConfig_rch OpenDDS::DCPS::TransportRegistry::global_config_

private

Definition at line 159 of file TransportRegistry.h.

Referenced by fix_empty_default(), global_config(), release(), and TransportRegistry().

◆ inst_map_

InstMap OpenDDS::DCPS::TransportRegistry::inst_map_

private

Definition at line 154 of file TransportRegistry.h.

Referenced by create_inst(), get_inst(), release(), and remove_inst().

◆ lib_directive_map_

LibDirectiveMap OpenDDS::DCPS::TransportRegistry::lib_directive_map_

private

Definition at line 155 of file TransportRegistry.h.

Referenced by load_transport_lib_i(), and TransportRegistry().

◆ lock_

LockType OpenDDS::DCPS::TransportRegistry::lock_

mutableprivate

Definition at line 162 of file TransportRegistry.h.

Referenced by create_config(), create_inst(), domain_default_config(), fix_empty_default(), get_config(), get_inst(), global_config(), load_transport_lib(), load_transport_lib_i(), register_type(), release(), released(), remove_config(), and remove_inst().

◆ released_

bool OpenDDS::DCPS::TransportRegistry::released_

private

Definition at line 160 of file TransportRegistry.h.

Referenced by release(), and released().

◆ type_map_

TypeMap OpenDDS::DCPS::TransportRegistry::type_map_

private

Definition at line 152 of file TransportRegistry.h.

Referenced by load_transport_lib_i(), register_type(), and release().

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

Classes

Public Member Functions

Static Public Member Functions

Static Public Attributes

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ GuardType

◆ LockType

Constructor & Destructor Documentation

◆ TransportRegistry()

◆ ~TransportRegistry()

Member Function Documentation

◆ bind_config() [1/2]

◆ bind_config() [2/2]

◆ close()

◆ config_has_transport_template()

◆ create_config()

◆ create_inst()

◆ create_new_transport_instance_for_participant()

◆ create_transport_template_instance()

◆ domain_default_config() [1/2]

◆ domain_default_config() [2/2]

◆ fix_empty_default()

◆ get_config()

◆ get_config_instance_name()

◆ get_inst()

◆ get_transport_info()

◆ get_transport_template_info()

◆ get_transport_template_instance_name()

◆ global_config() [1/2]

◆ global_config() [2/2]

◆ has_transport_templates()

◆ has_transports()

◆ instance()

◆ load_transport_configuration()

◆ load_transport_lib()

◆ load_transport_lib_i()

◆ load_transport_templates()

◆ OPENDDS_MAP() [1/6]

◆ OPENDDS_MAP() [2/6]

◆ OPENDDS_MAP() [3/6]

◆ OPENDDS_MAP() [4/6]

◆ OPENDDS_MAP() [5/6]

◆ OPENDDS_MAP() [6/6]

◆ OPENDDS_VECTOR() [1/2]

◆ OPENDDS_VECTOR() [2/2]

◆ process_customizations()

◆ register_type()

◆ release()

◆ released()

◆ remove_config() [1/2]

◆ remove_config() [2/2]

◆ remove_inst() [1/2]

◆ remove_inst() [2/2]

◆ remove_transport_template_instance()

◆ update_config_template_instance_info()

Friends And Related Function Documentation

◆ ACE_Singleton< TransportRegistry, ACE_Recursive_Thread_Mutex >

Member Data Documentation

◆ config_map_

◆ config_template_to_instance_map_

◆ CUSTOM_ADD_DOMAIN_TO_IP

◆ CUSTOM_ADD_DOMAIN_TO_PORT

◆ DEFAULT_CONFIG_NAME

◆ DEFAULT_INST_PREFIX

◆ domain_default_config_map_

◆ global_config_

◆ inst_map_

◆ lib_directive_map_

◆ lock_

◆ released_

◆ type_map_