#include <HandleRegistry.h>

Inheritance diagram for OpenDDS::Security::HandleRegistry:

Collaboration diagram for OpenDDS::Security::HandleRegistry:

[legend]

Public Types
typedef std::pair< DCPS::GUID_t, DDS::Security::DatareaderCryptoHandle >	GUID_tDrch

typedef std::pair< DCPS::GUID_t, DDS::Security::DatawriterCryptoHandle >	GUID_tDwch

Public Member Functions
typedef	OPENDDS_VECTOR (GUID_tDrch) DatareaderCryptoHandleList

typedef	OPENDDS_VECTOR (GUID_tDwch) DatawriterCryptoHandleList

	HandleRegistry ()

	~HandleRegistry ()

const DDS::Security::EndpointSecurityAttributes &	default_endpoint_security_attributes () const

void	insert_local_datareader_crypto_handle (const DCPS::GUID_t &id, DDS::Security::DatareaderCryptoHandle handle, const DDS::Security::EndpointSecurityAttributes &attributes)

DDS::Security::DatareaderCryptoHandle	get_local_datareader_crypto_handle (const DCPS::GUID_t &id) const

const DDS::Security::EndpointSecurityAttributes &	get_local_datareader_security_attributes (const DCPS::GUID_t &id) const

void	erase_local_datareader_crypto_handle (const DCPS::GUID_t &id)

void	insert_local_datawriter_crypto_handle (const DCPS::GUID_t &id, DDS::Security::DatawriterCryptoHandle handle, const DDS::Security::EndpointSecurityAttributes &attributes)

DDS::Security::DatawriterCryptoHandle	get_local_datawriter_crypto_handle (const DCPS::GUID_t &id) const

const DDS::Security::EndpointSecurityAttributes &	get_local_datawriter_security_attributes (const DCPS::GUID_t &id) const

void	erase_local_datawriter_crypto_handle (const DCPS::GUID_t &id)

void	insert_remote_participant_crypto_handle (const DCPS::GUID_t &id, DDS::Security::ParticipantCryptoHandle handle)

DDS::Security::ParticipantCryptoHandle	get_remote_participant_crypto_handle (const DCPS::GUID_t &id) const

void	erase_remote_participant_crypto_handle (const DCPS::GUID_t &id)

void	insert_remote_participant_permissions_handle (const DCPS::GUID_t &id, DDS::Security::PermissionsHandle handle)

DDS::Security::PermissionsHandle	get_remote_participant_permissions_handle (const DCPS::GUID_t &id) const

void	erase_remote_participant_permissions_handle (const DCPS::GUID_t &id)

void	insert_remote_datareader_crypto_handle (const DCPS::GUID_t &id, DDS::Security::DatareaderCryptoHandle handle, const DDS::Security::EndpointSecurityAttributes &attributes)

DDS::Security::DatareaderCryptoHandle	get_remote_datareader_crypto_handle (const DCPS::GUID_t &id) const

const DDS::Security::EndpointSecurityAttributes &	get_remote_datareader_security_attributes (const DCPS::GUID_t &id) const

DatareaderCryptoHandleList	get_all_remote_datareaders (const DCPS::GUID_t &prefix) const

void	erase_remote_datareader_crypto_handle (const DCPS::GUID_t &id)

void	insert_remote_datawriter_crypto_handle (const DCPS::GUID_t &id, DDS::Security::DatawriterCryptoHandle handle, const DDS::Security::EndpointSecurityAttributes &attributes)

DDS::Security::DatawriterCryptoHandle	get_remote_datawriter_crypto_handle (const DCPS::GUID_t &id) const

const DDS::Security::EndpointSecurityAttributes &	get_remote_datawriter_security_attributes (const DCPS::GUID_t &id) const

DatawriterCryptoHandleList	get_all_remote_datawriters (const DCPS::GUID_t &prefix) const

void	erase_remote_datawriter_crypto_handle (const DCPS::GUID_t &id)

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Private Types
typedef std::pair< DDS::Security::DatareaderCryptoHandle, DDS::Security::EndpointSecurityAttributes >	P1

typedef std::pair< DDS::Security::DatawriterCryptoHandle, DDS::Security::EndpointSecurityAttributes >	P2

Private Member Functions
typedef	OPENDDS_MAP_CMP (DCPS::GUID_t, DDS::Security::ParticipantCryptoHandle, DCPS::GUID_tKeyLessThan) ParticipantCryptoHandleMap

typedef	OPENDDS_MAP_CMP (DCPS::GUID_t, DDS::Security::PermissionsHandle, DCPS::GUID_tKeyLessThan) PermissionsHandleMap

typedef	OPENDDS_MAP_CMP (DCPS::GUID_t, P1, DCPS::GUID_tKeyLessThan) DatareaderCryptoHandleMap

typedef	OPENDDS_MAP_CMP (DCPS::GUID_t, P2, DCPS::GUID_tKeyLessThan) DatawriterCryptoHandleMap

Private Attributes
DDS::Security::EndpointSecurityAttributes	default_endpoint_security_attributes_

ACE_Thread_Mutex	mutex_

ParticipantCryptoHandleMap	remote_participant_crypto_handles_

PermissionsHandleMap	remote_participant_permissions_handles_

DatareaderCryptoHandleMap	local_datareader_crypto_handles_

DatawriterCryptoHandleMap	local_datawriter_crypto_handles_

DatareaderCryptoHandleMap	remote_datareader_crypto_handles_

DatawriterCryptoHandleMap	remote_datawriter_crypto_handles_

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

Detailed Description

Definition at line 27 of file HandleRegistry.h.

Member Typedef Documentation

◆ GUID_tDrch

typedef std::pair<DCPS::GUID_t, DDS::Security::DatareaderCryptoHandle> OpenDDS::Security::HandleRegistry::GUID_tDrch

Definition at line 29 of file HandleRegistry.h.

◆ GUID_tDwch

typedef std::pair<DCPS::GUID_t, DDS::Security::DatawriterCryptoHandle> OpenDDS::Security::HandleRegistry::GUID_tDwch

Definition at line 31 of file HandleRegistry.h.

◆ P1

typedef std::pair<DDS::Security::DatareaderCryptoHandle, DDS::Security::EndpointSecurityAttributes> OpenDDS::Security::HandleRegistry::P1

private

Definition at line 87 of file HandleRegistry.h.

◆ P2

typedef std::pair<DDS::Security::DatawriterCryptoHandle, DDS::Security::EndpointSecurityAttributes> OpenDDS::Security::HandleRegistry::P2

private

Definition at line 90 of file HandleRegistry.h.

Constructor & Destructor Documentation

◆ HandleRegistry()

OpenDDS::Security::HandleRegistry::HandleRegistry ( )

Definition at line 20 of file HandleRegistry.cpp.

References DDS::Security::EndpointSecurityAttributes::base, default_endpoint_security_attributes_, DDS::Security::TopicSecurityAttributes::is_discovery_protected, DDS::Security::EndpointSecurityAttributes::is_key_protected, DDS::Security::TopicSecurityAttributes::is_liveliness_protected, DDS::Security::EndpointSecurityAttributes::is_payload_protected, DDS::Security::TopicSecurityAttributes::is_read_protected, DDS::Security::EndpointSecurityAttributes::is_submessage_protected, DDS::Security::TopicSecurityAttributes::is_write_protected, and DDS::Security::EndpointSecurityAttributes::plugin_endpoint_attributes.

 {
   default_endpoint_security_attributes_.base.is_read_protected = false;
   default_endpoint_security_attributes_.base.is_write_protected = false;
   default_endpoint_security_attributes_.base.is_discovery_protected = false;
   default_endpoint_security_attributes_.base.is_liveliness_protected = false;
   default_endpoint_security_attributes_.is_submessage_protected = false;
   default_endpoint_security_attributes_.is_payload_protected = false;
   default_endpoint_security_attributes_.is_key_protected = false;
   default_endpoint_security_attributes_.plugin_endpoint_attributes = 0;
 }

◆ ~HandleRegistry()

OpenDDS::Security::HandleRegistry::~HandleRegistry ( )

Definition at line 32 of file HandleRegistry.cpp.

References ACE_DEBUG, LM_DEBUG, local_datareader_crypto_handles_, local_datawriter_crypto_handles_, remote_datareader_crypto_handles_, remote_datawriter_crypto_handles_, remote_participant_crypto_handles_, and OpenDDS::DCPS::security_debug.

 {
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) {bookkeeping} "
                "HandleRegistry::~HandleRegistry local datareader %B local datawriter %B "
                "remote participant %B remote datareader %B remote datawriter %B\n",
                local_datareader_crypto_handles_.size(),
                local_datawriter_crypto_handles_.size(),
                remote_participant_crypto_handles_.size(),
                remote_datareader_crypto_handles_.size(),
                remote_datawriter_crypto_handles_.size()));
   }
 }

Member Function Documentation

◆ default_endpoint_security_attributes()

const DDS::Security::EndpointSecurityAttributes& OpenDDS::Security::HandleRegistry::default_endpoint_security_attributes ( ) const

inline

Definition at line 37 of file HandleRegistry.h.

References OPENDDS_MAP_CMP.

Referenced by OpenDDS::RTPS::Sedp::init_security().

   {
     return default_endpoint_security_attributes_;
   }

◆ erase_local_datareader_crypto_handle()

void OpenDDS::Security::HandleRegistry::erase_local_datareader_crypto_handle ( const DCPS::GUID_t & id )

Definition at line 88 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, local_datareader_crypto_handles_, mutex_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::cleanup_secure_reader().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   local_datareader_crypto_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_local_datareader_crypto_handle %C (%B)\n"),
                DCPS::LogGuid(id).c_str(),
                local_datareader_crypto_handles_.size()));
   }
 }

◆ erase_local_datawriter_crypto_handle()

void OpenDDS::Security::HandleRegistry::erase_local_datawriter_crypto_handle ( const DCPS::GUID_t & id )

Definition at line 143 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, local_datawriter_crypto_handles_, mutex_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::cleanup_secure_writer().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   local_datawriter_crypto_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_local_datawriter_crypto_handle %C (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                local_datawriter_crypto_handles_.size()));
   }
 }

◆ erase_remote_datareader_crypto_handle()

void OpenDDS::Security::HandleRegistry::erase_remote_datareader_crypto_handle ( const DCPS::GUID_t & id )

Definition at line 298 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, mutex_, remote_datareader_crypto_handles_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Sedp::remove_remote_crypto_handle().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   remote_datareader_crypto_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_remote_datareader_crypto_handle %C (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                remote_datareader_crypto_handles_.size()));
   }
 }

◆ erase_remote_datawriter_crypto_handle()

void OpenDDS::Security::HandleRegistry::erase_remote_datawriter_crypto_handle ( const DCPS::GUID_t & id )

Definition at line 368 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, mutex_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, remote_datawriter_crypto_handles_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Sedp::remove_remote_crypto_handle().

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   remote_datawriter_crypto_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_remote_datawriter_crypto_handle %C (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                remote_datawriter_crypto_handles_.size()));
   }
 }

◆ erase_remote_participant_crypto_handle()

void OpenDDS::Security::HandleRegistry::erase_remote_participant_crypto_handle ( const DCPS::GUID_t & id )

Definition at line 186 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, mutex_, remote_participant_crypto_handles_, and OpenDDS::DCPS::security_debug.

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   remote_participant_crypto_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_remote_participant_crypto_handle %C (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                remote_participant_crypto_handles_.size()));
   }
 }

◆ erase_remote_participant_permissions_handle()

void OpenDDS::Security::HandleRegistry::erase_remote_participant_permissions_handle ( const DCPS::GUID_t & id )

Definition at line 229 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), LM_DEBUG, mutex_, remote_participant_permissions_handles_, and OpenDDS::DCPS::security_debug.

 {
   ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
   remote_participant_permissions_handles_.erase(id);
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::erase_remote_participant_permissions_handle %C (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                remote_participant_permissions_handles_.size()));
   }
 }

◆ get_all_remote_datareaders()

HandleRegistry::DatareaderCryptoHandleList OpenDDS::Security::HandleRegistry::get_all_remote_datareaders ( const DCPS::GUID_t & prefix ) const

Definition at line 284 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::ENTITYID_UNKNOWN, OpenDDS::DCPS::equal_guid_prefixes(), OpenDDS::DCPS::make_id(), mutex_, and remote_datareader_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::disassociate().

 {
   DatareaderCryptoHandleList retval;
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, retval);
   for (DatareaderCryptoHandleMap::const_iterator pos =
          remote_datareader_crypto_handles_.lower_bound(DCPS::make_id(prefix, DCPS::ENTITYID_UNKNOWN)),
          limit = remote_datareader_crypto_handles_.end();
        pos != limit && DCPS::equal_guid_prefixes(pos->first, prefix); ++pos) {
     retval.push_back(std::make_pair(pos->first, pos->second.first));
   }
   return retval;
 }

◆ get_all_remote_datawriters()

HandleRegistry::DatawriterCryptoHandleList OpenDDS::Security::HandleRegistry::get_all_remote_datawriters ( const DCPS::GUID_t & prefix ) const

Definition at line 354 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::ENTITYID_UNKNOWN, OpenDDS::DCPS::equal_guid_prefixes(), OpenDDS::DCPS::make_id(), mutex_, and remote_datawriter_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::disassociate().

 {
   DatawriterCryptoHandleList retval;
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, retval);
   for (DatawriterCryptoHandleMap::const_iterator pos =
          remote_datawriter_crypto_handles_.lower_bound(DCPS::make_id(prefix, DCPS::ENTITYID_UNKNOWN)),
          limit = remote_datawriter_crypto_handles_.end();
        pos != limit && DCPS::equal_guid_prefixes(pos->first, prefix); ++pos) {
     retval.push_back(std::make_pair(pos->first, pos->second.first));
   }
   return retval;
 }

◆ get_local_datareader_crypto_handle()

DDS::Security::DatareaderCryptoHandle OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle ( const DCPS::GUID_t & id ) const

Definition at line 66 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, local_datareader_crypto_handles_, and mutex_.

Referenced by OpenDDS::RTPS::Sedp::cleanup_secure_reader(), OpenDDS::RTPS::Sedp::generate_remote_matched_writer_crypto_handle(), OpenDDS::RTPS::Sedp::handle_datawriter_crypto_tokens(), OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i(), OpenDDS::RTPS::Sedp::match_continue_security_enabled(), OpenDDS::RTPS::Sedp::remote_has_local_endpoint_token_i(), and OpenDDS::RTPS::Sedp::resend_user_crypto_tokens().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   DatareaderCryptoHandleMap::const_iterator pos = local_datareader_crypto_handles_.find(id);
   if (pos != local_datareader_crypto_handles_.end()) {
     return pos->second.first;
   }
   return DDS::HANDLE_NIL;
 }

◆ get_local_datareader_security_attributes()

const DDS::Security::EndpointSecurityAttributes & OpenDDS::Security::HandleRegistry::get_local_datareader_security_attributes ( const DCPS::GUID_t & id ) const

Definition at line 77 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, default_endpoint_security_attributes_, local_datareader_crypto_handles_, and mutex_.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_writer_crypto_handle(), and OpenDDS::RTPS::Sedp::match_continue_security_enabled().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, default_endpoint_security_attributes_);
   DatareaderCryptoHandleMap::const_iterator pos = local_datareader_crypto_handles_.find(id);
   if (pos != local_datareader_crypto_handles_.end()) {
     return pos->second.second;
   }
   return default_endpoint_security_attributes_;
 }

◆ get_local_datawriter_crypto_handle()

DDS::Security::DatawriterCryptoHandle OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle ( const DCPS::GUID_t & id ) const

Definition at line 121 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, local_datawriter_crypto_handles_, and mutex_.

Referenced by OpenDDS::RTPS::Sedp::cleanup_secure_writer(), OpenDDS::RTPS::Sedp::generate_remote_matched_reader_crypto_handle(), OpenDDS::RTPS::Sedp::handle_datareader_crypto_tokens(), OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i(), OpenDDS::RTPS::Sedp::match_continue_security_enabled(), OpenDDS::RTPS::Sedp::remote_has_local_endpoint_token_i(), and OpenDDS::RTPS::Sedp::resend_user_crypto_tokens().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   DatawriterCryptoHandleMap::const_iterator pos = local_datawriter_crypto_handles_.find(id);
   if (pos != local_datawriter_crypto_handles_.end()) {
     return pos->second.first;
   }
   return DDS::HANDLE_NIL;
 }

◆ get_local_datawriter_security_attributes()

const DDS::Security::EndpointSecurityAttributes & OpenDDS::Security::HandleRegistry::get_local_datawriter_security_attributes ( const DCPS::GUID_t & id ) const

Definition at line 132 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, default_endpoint_security_attributes_, local_datawriter_crypto_handles_, and mutex_.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_reader_crypto_handle(), and OpenDDS::RTPS::Sedp::match_continue_security_enabled().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, default_endpoint_security_attributes_);
   DatawriterCryptoHandleMap::const_iterator pos = local_datawriter_crypto_handles_.find(id);
   if (pos != local_datawriter_crypto_handles_.end()) {
     return pos->second.second;
   }
   return default_endpoint_security_attributes_;
 }

◆ get_remote_datareader_crypto_handle()

DDS::Security::DatareaderCryptoHandle OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle ( const DCPS::GUID_t & id ) const

Definition at line 262 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, mutex_, and remote_datareader_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_reader_crypto_handle(), OpenDDS::RTPS::Sedp::handle_datareader_crypto_tokens(), OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i(), OpenDDS::RTPS::Sedp::remote_has_local_endpoint_token_i(), OpenDDS::RTPS::Sedp::remove_remote_crypto_handle(), and OpenDDS::RTPS::Sedp::resend_user_crypto_tokens().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   DatareaderCryptoHandleMap::const_iterator pos = remote_datareader_crypto_handles_.find(id);
   if (pos != remote_datareader_crypto_handles_.end()) {
     return pos->second.first;
   }
   return DDS::HANDLE_NIL;
 }

◆ get_remote_datareader_security_attributes()

const DDS::Security::EndpointSecurityAttributes & OpenDDS::Security::HandleRegistry::get_remote_datareader_security_attributes ( const DCPS::GUID_t & id ) const

Definition at line 273 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, default_endpoint_security_attributes_, mutex_, and remote_datareader_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, default_endpoint_security_attributes_);
   DatareaderCryptoHandleMap::const_iterator pos = remote_datareader_crypto_handles_.find(id);
   if (pos != remote_datareader_crypto_handles_.end()) {
     return pos->second.second;
   }
   return default_endpoint_security_attributes_;
 }

◆ get_remote_datawriter_crypto_handle()

DDS::Security::DatawriterCryptoHandle OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle ( const DCPS::GUID_t & id ) const

Definition at line 332 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, mutex_, and remote_datawriter_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_writer_crypto_handle(), OpenDDS::RTPS::Sedp::handle_datawriter_crypto_tokens(), OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i(), OpenDDS::RTPS::Sedp::remote_has_local_endpoint_token_i(), OpenDDS::RTPS::Sedp::remove_remote_crypto_handle(), and OpenDDS::RTPS::Sedp::resend_user_crypto_tokens().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   DatawriterCryptoHandleMap::const_iterator pos = remote_datawriter_crypto_handles_.find(id);
   if (pos != remote_datawriter_crypto_handles_.end()) {
     return pos->second.first;
   }
   return DDS::HANDLE_NIL;
 }

◆ get_remote_datawriter_security_attributes()

const DDS::Security::EndpointSecurityAttributes & OpenDDS::Security::HandleRegistry::get_remote_datawriter_security_attributes ( const DCPS::GUID_t & id ) const

Definition at line 343 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, default_endpoint_security_attributes_, mutex_, and remote_datawriter_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::local_has_remote_endpoint_token_i().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, default_endpoint_security_attributes_);
   DatawriterCryptoHandleMap::const_iterator pos = remote_datawriter_crypto_handles_.find(id);
   if (pos != remote_datawriter_crypto_handles_.end()) {
     return pos->second.second;
   }
   return default_endpoint_security_attributes_;
 }

◆ get_remote_participant_crypto_handle()

DDS::Security::ParticipantCryptoHandle OpenDDS::Security::HandleRegistry::get_remote_participant_crypto_handle ( const DCPS::GUID_t & id ) const

Definition at line 175 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, mutex_, and remote_participant_crypto_handles_.

Referenced by OpenDDS::RTPS::Sedp::local_has_remote_participant_token_i(), and OpenDDS::RTPS::Sedp::remote_has_local_participant_token_i().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   ParticipantCryptoHandleMap::const_iterator pos = remote_participant_crypto_handles_.find(id);
   if (pos != remote_participant_crypto_handles_.end()) {
     return pos->second;
   }
   return DDS::HANDLE_NIL;
 }

◆ get_remote_participant_permissions_handle()

DDS::Security::PermissionsHandle OpenDDS::Security::HandleRegistry::get_remote_participant_permissions_handle ( const DCPS::GUID_t & id ) const

Definition at line 218 of file HandleRegistry.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, mutex_, and remote_participant_permissions_handles_.

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, mutex_, DDS::HANDLE_NIL);
   PermissionsHandleMap::const_iterator pos = remote_participant_permissions_handles_.find(id);
   if (pos != remote_participant_permissions_handles_.end()) {
     return pos->second;
   }
   return DDS::HANDLE_NIL;
 }

◆ insert_local_datareader_crypto_handle()

void OpenDDS::Security::HandleRegistry::insert_local_datareader_crypto_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::DatareaderCryptoHandle	handle,
		const DDS::Security::EndpointSecurityAttributes &	attributes
	)

Definition at line 47 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), DDS::HANDLE_NIL, LM_DEBUG, local_datareader_crypto_handles_, mutex_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::add_subscription(), and OpenDDS::RTPS::Sedp::init_security().

 {
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     local_datareader_crypto_handles_[id] = std::make_pair(handle, attributes);
 
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("HandleRegistry::insert_local_datareader_crypto_handle %C %d (total %B)\n"),
                  DCPS::LogGuid(id).c_str(),
                  handle,
                  local_datareader_crypto_handles_.size()));
     }
   }
 }

◆ insert_local_datawriter_crypto_handle()

void OpenDDS::Security::HandleRegistry::insert_local_datawriter_crypto_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::DatawriterCryptoHandle	handle,
		const DDS::Security::EndpointSecurityAttributes &	attributes
	)

Definition at line 102 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), DDS::HANDLE_NIL, LM_DEBUG, local_datawriter_crypto_handles_, mutex_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::add_publication(), and OpenDDS::RTPS::Sedp::init_security().

 {
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     local_datawriter_crypto_handles_[id] = std::make_pair(handle, attributes);
 
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("HandleRegistry::insert_local_datawriter_crypto_handle %C %d (total %B)\n"),
                  DCPS::LogGuid(id).c_str(),
                  handle,
                  local_datawriter_crypto_handles_.size()));
     }
   }
 }

◆ insert_remote_datareader_crypto_handle()

void OpenDDS::Security::HandleRegistry::insert_remote_datareader_crypto_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::DatareaderCryptoHandle	handle,
		const DDS::Security::EndpointSecurityAttributes &	attributes
	)

Definition at line 243 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), DDS::HANDLE_NIL, LM_DEBUG, mutex_, remote_datareader_crypto_handles_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_reader_crypto_handle().

 {
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     remote_datareader_crypto_handles_[id] = std::make_pair(handle, attributes);
   }
 
   if (DCPS::security_debug.bookkeeping) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                ACE_TEXT("HandleRegistry::insert_remote_datareader_crypto_handle %C %d (total %B)\n"),
                DCPS::LogGuid(id).c_str(),
                handle,
                remote_datareader_crypto_handles_.size()));
   }
 }

◆ insert_remote_datawriter_crypto_handle()

void OpenDDS::Security::HandleRegistry::insert_remote_datawriter_crypto_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::DatawriterCryptoHandle	handle,
		const DDS::Security::EndpointSecurityAttributes &	attributes
	)

Definition at line 312 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::ENTITYID_UNKNOWN, DDS::HANDLE_NIL, LM_DEBUG, mutex_, OPENDDS_ASSERT, remote_datawriter_crypto_handles_, and OpenDDS::DCPS::security_debug.

Referenced by OpenDDS::RTPS::Sedp::generate_remote_matched_writer_crypto_handle().

 {
   OPENDDS_ASSERT(id.entityId != DCPS::ENTITYID_UNKNOWN);
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     remote_datawriter_crypto_handles_[id] = std::make_pair(handle, attributes);
 
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("HandleRegistry::insert_remote_datawriter_crypto_handle %C %d (total %B)\n"),
                  DCPS::LogGuid(id).c_str(),
                  handle,
                  remote_datawriter_crypto_handles_.size()));
     }
   }
 }

◆ insert_remote_participant_crypto_handle()

void OpenDDS::Security::HandleRegistry::insert_remote_participant_crypto_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::ParticipantCryptoHandle	handle
	)

Definition at line 157 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), DDS::HANDLE_NIL, LM_DEBUG, mutex_, remote_participant_crypto_handles_, and OpenDDS::DCPS::security_debug.

 {
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     remote_participant_crypto_handles_[id] = handle;
 
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("HandleRegistry::insert_remote_participant_crypto_handle %C %d (total %B)\n"),
                  DCPS::LogGuid(id).c_str(),
                  handle,
                  remote_participant_crypto_handles_.size()));
     }
   }
 }

◆ insert_remote_participant_permissions_handle()

void OpenDDS::Security::HandleRegistry::insert_remote_participant_permissions_handle	(	const DCPS::GUID_t &	id,
		DDS::Security::PermissionsHandle	handle
	)

Definition at line 200 of file HandleRegistry.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), DDS::HANDLE_NIL, LM_DEBUG, mutex_, remote_participant_permissions_handles_, and OpenDDS::DCPS::security_debug.

 {
   if (handle != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, guard, mutex_);
     remote_participant_permissions_handles_[id] = handle;
 
     if (DCPS::security_debug.bookkeeping) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) {bookkeeping} ")
                  ACE_TEXT("HandleRegistry::insert_remote_participant_permissions_handle %C %d (total %B)\n"),
                  DCPS::LogGuid(id).c_str(),
                  handle,
                  remote_participant_permissions_handles_.size()));
     }
   }
 }

◆ OPENDDS_MAP_CMP() [1/4]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_MAP_CMP	(	DCPS::GUID_t	,
		DDS::Security::ParticipantCryptoHandle	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ OPENDDS_MAP_CMP() [2/4]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_MAP_CMP	(	DCPS::GUID_t	,
		DDS::Security::PermissionsHandle	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ OPENDDS_MAP_CMP() [3/4]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_MAP_CMP	(	DCPS::GUID_t	,
		P1	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ OPENDDS_MAP_CMP() [4/4]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_MAP_CMP	(	DCPS::GUID_t	,
		P2	,
		DCPS::GUID_tKeyLessThan
	)

private

◆ OPENDDS_VECTOR() [1/2]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_VECTOR ( GUID_tDrch )

◆ OPENDDS_VECTOR() [2/2]

typedef OpenDDS::Security::HandleRegistry::OPENDDS_VECTOR ( GUID_tDwch )

Member Data Documentation

◆ default_endpoint_security_attributes_

DDS::Security::EndpointSecurityAttributes OpenDDS::Security::HandleRegistry::default_endpoint_security_attributes_

private

Definition at line 94 of file HandleRegistry.h.

Referenced by get_local_datareader_security_attributes(), get_local_datawriter_security_attributes(), get_remote_datareader_security_attributes(), get_remote_datawriter_security_attributes(), and HandleRegistry().

◆ local_datareader_crypto_handles_

DatareaderCryptoHandleMap OpenDDS::Security::HandleRegistry::local_datareader_crypto_handles_

private

Definition at line 100 of file HandleRegistry.h.

Referenced by erase_local_datareader_crypto_handle(), get_local_datareader_crypto_handle(), get_local_datareader_security_attributes(), insert_local_datareader_crypto_handle(), and ~HandleRegistry().

◆ local_datawriter_crypto_handles_

DatawriterCryptoHandleMap OpenDDS::Security::HandleRegistry::local_datawriter_crypto_handles_

private

Definition at line 101 of file HandleRegistry.h.

Referenced by erase_local_datawriter_crypto_handle(), get_local_datawriter_crypto_handle(), get_local_datawriter_security_attributes(), insert_local_datawriter_crypto_handle(), and ~HandleRegistry().

◆ mutex_

ACE_Thread_Mutex OpenDDS::Security::HandleRegistry::mutex_

mutableprivate

Definition at line 96 of file HandleRegistry.h.

Referenced by erase_local_datareader_crypto_handle(), erase_local_datawriter_crypto_handle(), erase_remote_datareader_crypto_handle(), erase_remote_datawriter_crypto_handle(), erase_remote_participant_crypto_handle(), erase_remote_participant_permissions_handle(), get_all_remote_datareaders(), get_all_remote_datawriters(), get_local_datareader_crypto_handle(), get_local_datareader_security_attributes(), get_local_datawriter_crypto_handle(), get_local_datawriter_security_attributes(), get_remote_datareader_crypto_handle(), get_remote_datareader_security_attributes(), get_remote_datawriter_crypto_handle(), get_remote_datawriter_security_attributes(), get_remote_participant_crypto_handle(), get_remote_participant_permissions_handle(), insert_local_datareader_crypto_handle(), insert_local_datawriter_crypto_handle(), insert_remote_datareader_crypto_handle(), insert_remote_datawriter_crypto_handle(), insert_remote_participant_crypto_handle(), and insert_remote_participant_permissions_handle().

◆ remote_datareader_crypto_handles_

DatareaderCryptoHandleMap OpenDDS::Security::HandleRegistry::remote_datareader_crypto_handles_

private

Definition at line 103 of file HandleRegistry.h.

Referenced by erase_remote_datareader_crypto_handle(), get_all_remote_datareaders(), get_remote_datareader_crypto_handle(), get_remote_datareader_security_attributes(), insert_remote_datareader_crypto_handle(), and ~HandleRegistry().

◆ remote_datawriter_crypto_handles_

DatawriterCryptoHandleMap OpenDDS::Security::HandleRegistry::remote_datawriter_crypto_handles_

private

Definition at line 104 of file HandleRegistry.h.

Referenced by erase_remote_datawriter_crypto_handle(), get_all_remote_datawriters(), get_remote_datawriter_crypto_handle(), get_remote_datawriter_security_attributes(), insert_remote_datawriter_crypto_handle(), and ~HandleRegistry().

◆ remote_participant_crypto_handles_

ParticipantCryptoHandleMap OpenDDS::Security::HandleRegistry::remote_participant_crypto_handles_

private

Definition at line 97 of file HandleRegistry.h.

Referenced by erase_remote_participant_crypto_handle(), get_remote_participant_crypto_handle(), insert_remote_participant_crypto_handle(), and ~HandleRegistry().

◆ remote_participant_permissions_handles_

PermissionsHandleMap OpenDDS::Security::HandleRegistry::remote_participant_permissions_handles_

private

Definition at line 98 of file HandleRegistry.h.

Referenced by erase_remote_participant_permissions_handle(), get_remote_participant_permissions_handle(), and insert_remote_participant_permissions_handle().

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

Public Types

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ GUID_tDrch

◆ GUID_tDwch

◆ P1

◆ P2

Constructor & Destructor Documentation

◆ HandleRegistry()

◆ ~HandleRegistry()

Member Function Documentation

◆ default_endpoint_security_attributes()

◆ erase_local_datareader_crypto_handle()

◆ erase_local_datawriter_crypto_handle()

◆ erase_remote_datareader_crypto_handle()

◆ erase_remote_datawriter_crypto_handle()

◆ erase_remote_participant_crypto_handle()

◆ erase_remote_participant_permissions_handle()

◆ get_all_remote_datareaders()

◆ get_all_remote_datawriters()

◆ get_local_datareader_crypto_handle()

◆ get_local_datareader_security_attributes()

◆ get_local_datawriter_crypto_handle()

◆ get_local_datawriter_security_attributes()

◆ get_remote_datareader_crypto_handle()

◆ get_remote_datareader_security_attributes()

◆ get_remote_datawriter_crypto_handle()

◆ get_remote_datawriter_security_attributes()

◆ get_remote_participant_crypto_handle()

◆ get_remote_participant_permissions_handle()

◆ insert_local_datareader_crypto_handle()

◆ insert_local_datawriter_crypto_handle()

◆ insert_remote_datareader_crypto_handle()

◆ insert_remote_datawriter_crypto_handle()

◆ insert_remote_participant_crypto_handle()

◆ insert_remote_participant_permissions_handle()

◆ OPENDDS_MAP_CMP() [1/4]

◆ OPENDDS_MAP_CMP() [2/4]

◆ OPENDDS_MAP_CMP() [3/4]

◆ OPENDDS_MAP_CMP() [4/4]

◆ OPENDDS_VECTOR() [1/2]

◆ OPENDDS_VECTOR() [2/2]

Member Data Documentation

◆ default_endpoint_security_attributes_

◆ local_datareader_crypto_handles_

◆ local_datawriter_crypto_handles_

◆ mutex_

◆ remote_datareader_crypto_handles_

◆ remote_datawriter_crypto_handles_

◆ remote_participant_crypto_handles_

◆ remote_participant_permissions_handles_