OpenDDS
Snapshot(2023/04/28-20:55)
|
#include <Sedp.h>
Classes | |
class | DiscoveryReader |
class | DiscoveryWriter |
class | Endpoint |
class | LivelinessReader |
class | LivelinessWriter |
struct | MatchingData |
struct | MatchingPair |
struct | PublicationAgentInfoListener |
class | Reader |
class | ReaderAddAssociation |
class | ReaderRemoveAssociations |
class | SecurityReader |
class | SecurityWriter |
struct | SubscriptionAgentInfoListener |
struct | TypeIdOrigSeqNumber |
class | TypeLookupReplyReader |
class | TypeLookupReplyWriter |
class | TypeLookupRequestReader |
class | TypeLookupRequestWriter |
class | Writer |
class | WriterAddAssociation |
class | WriterRemoveAssociations |
Protected Types | |
typedef MatchingDataMap::iterator | MatchingDataIter |
typedef DCPS::PmfSporadicTask< Sedp > | EndpointManagerSporadic |
![]() | |
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count > | Atomic_Reference_Count |
Static Protected Member Functions | |
static DDS::BuiltinTopicKey_t | get_key (const DiscoveredPublication &pub) |
static DDS::BuiltinTopicKey_t | get_key (const DiscoveredSubscription &sub) |
Static Private Member Functions | |
static void | set_inline_qos (DCPS::TransportLocatorSeq &locators) |
Friends | |
class | Spdp |
Additional Inherited Members | |
![]() | |
typedef long | Reference_Count |
![]() | |
static ACE_THR_FUNC_RETURN | read_adapter (void *event_handler) |
static int | register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED) |
static int | remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr) |
![]() | |
LO_PRIORITY | |
HI_PRIORITY | |
NULL_MASK | |
READ_MASK | |
WRITE_MASK | |
EXCEPT_MASK | |
ACCEPT_MASK | |
CONNECT_MASK | |
TIMER_MASK | |
QOS_MASK | |
GROUP_QOS_MASK | |
SIGNAL_MASK | |
ALL_EVENTS_MASK | |
RWE_MASK | |
DONT_CALL | |
ACE_EVENT_HANDLER_NOT_RESUMED | |
ACE_REACTOR_RESUMES_HANDLER | |
ACE_APPLICATION_RESUMES_HANDLER | |
|
private |
|
private |
|
private |
|
private |
|
protected |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
protected |
|
private |
|
private |
|
private |
OpenDDS::RTPS::Sedp::Sedp | ( | const DCPS::GUID_t & | participant_id, |
Spdp & | owner, | ||
ACE_Thread_Mutex & | lock | ||
) |
Definition at line 283 of file Sedp.cpp.
OpenDDS::RTPS::Sedp::~Sedp | ( | ) |
Definition at line 877 of file Sedp.cpp.
References cleanup_secure_reader(), cleanup_secure_writer(), dcps_participant_secure_reader_, dcps_participant_secure_writer_, OpenDDS::Security::SecurityConfig::erase_handle_registry(), OpenDDS::RTPS::Spdp::get_security_config(), job_queue_, participant_id_, participant_message_secure_reader_, participant_message_secure_writer_, participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, publications_secure_reader_, publications_secure_writer_, reactor_task_, OpenDDS::DCPS::RcHandle< T >::reset(), spdp_, OpenDDS::DCPS::static_rchandle_cast(), subscriptions_secure_reader_, subscriptions_secure_writer_, TheTransportRegistry, transport_cfg_, transport_inst_, and type_lookup_fini().
|
protected |
Definition at line 5616 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredSubscription::have_ice_agent_info_, ice_agent_, OpenDDS::RTPS::DiscoveredSubscription::ice_agent_info_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), and OpenDDS::RTPS::LocalPublication::publication_.
Referenced by match_continue(), and OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener().
|
protected |
Definition at line 5653 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredPublication::have_ice_agent_info_, ice_agent_, OpenDDS::RTPS::DiscoveredPublication::ice_agent_info_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), and OpenDDS::RTPS::LocalSubscription::subscription_.
GUID_t OpenDDS::RTPS::Sedp::add_publication | ( | const GUID_t & | topicId, |
DCPS::DataWriterCallbacks_rch | publication, | ||
const DDS::DataWriterQos & | qos, | ||
const DCPS::TransportLocatorSeq & | transInfo, | ||
const DDS::PublisherQos & | publisherQos, | ||
const XTypes::TypeInformation & | type_info | ||
) |
Definition at line 6122 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::TopicDetails::add_local_publication(), add_publication_i(), assign_publication_key(), DDS::Security::SecurityException::code, crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, get_access_control(), get_crypto_key_factory(), get_domain_id(), get_handle_registry(), get_permissions_handle(), DDS::HANDLE_NIL, OpenDDS::Security::HandleRegistry::insert_local_datawriter_crypto_handle(), DDS::Security::EndpointSecurityAttributes::is_payload_protected, is_security_enabled(), DDS::Security::EndpointSecurityAttributes::is_submessage_protected, DDS::Security::TopicSecurityAttributes::is_write_protected, LM_DEBUG, LM_ERROR, LM_WARNING, local_publications_, OpenDDS::DCPS::TransportClient::lock_, match_endpoints(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, participant_id_, DDS::PublisherQos::partition, OpenDDS::RTPS::LocalPublication::publication_, OpenDDS::RTPS::LocalPublication::publisher_qos_, OpenDDS::RTPS::LocalPublication::qos_, DDS::RETCODE_OK, OpenDDS::RTPS::LocalEntity::security_attribs_, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, OpenDDS::RTPS::LocalEntity::trans_info_, OpenDDS::RTPS::LocalEntity::type_info_, and write_publication_data().
Referenced by ignoring().
|
private |
Definition at line 4806 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::config(), OpenDDS::RTPS::Spdp::get_participant_discovered_at(), OpenDDS::RTPS::LocalEntity::have_ice_agent_info, ice_agent_, OpenDDS::RTPS::LocalEntity::ice_agent_info, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalEntity::participant_discovered_at_, OpenDDS::RTPS::LocalPublication::publication_, publication_agent_info_listener_, DDS::RETCODE_OK, spdp_, start_ice(), and OpenDDS::RTPS::LocalEntity::transport_context_.
Referenced by add_publication().
GUID_t OpenDDS::RTPS::Sedp::add_subscription | ( | const GUID_t & | topicId, |
DCPS::DataReaderCallbacks_rch | subscription, | ||
const DDS::DataReaderQos & | qos, | ||
const DCPS::TransportLocatorSeq & | transInfo, | ||
const DDS::SubscriberQos & | subscriberQos, | ||
const char * | filterClassName, | ||
const char * | filterExpr, | ||
const DDS::StringSeq & | params, | ||
const XTypes::TypeInformation & | type_info | ||
) |
Definition at line 6261 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::TopicDetails::add_local_subscription(), add_subscription_i(), assign_subscription_key(), DDS::Security::SecurityException::code, crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, OpenDDS::DCPS::ContentFilterProperty_t::filterClassName, OpenDDS::DCPS::ContentFilterProperty_t::filterExpression, OpenDDS::RTPS::LocalSubscription::filterProperties, get_access_control(), get_crypto_key_factory(), get_domain_id(), get_handle_registry(), get_permissions_handle(), DDS::HANDLE_NIL, OpenDDS::Security::HandleRegistry::insert_local_datareader_crypto_handle(), DDS::Security::EndpointSecurityAttributes::is_payload_protected, DDS::Security::TopicSecurityAttributes::is_read_protected, is_security_enabled(), DDS::Security::EndpointSecurityAttributes::is_submessage_protected, LM_DEBUG, LM_ERROR, LM_WARNING, local_subscriptions_, OpenDDS::DCPS::TransportClient::lock_, match_endpoints(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, participant_id_, DDS::SubscriberQos::partition, OpenDDS::RTPS::LocalSubscription::qos_, DDS::RETCODE_OK, OpenDDS::RTPS::LocalEntity::security_attribs_, OpenDDS::RTPS::LocalSubscription::subscriber_qos_, OpenDDS::RTPS::LocalSubscription::subscription_, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, OpenDDS::RTPS::LocalEntity::trans_info_, OpenDDS::RTPS::LocalEntity::type_info_, and write_subscription_data().
Referenced by ignoring().
|
private |
Definition at line 4958 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::config(), OpenDDS::RTPS::Spdp::get_participant_discovered_at(), OpenDDS::RTPS::LocalEntity::have_ice_agent_info, ice_agent_, OpenDDS::RTPS::LocalEntity::ice_agent_info, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalEntity::participant_discovered_at_, DDS::RETCODE_OK, spdp_, start_ice(), OpenDDS::RTPS::LocalSubscription::subscription_, subscription_agent_info_listener_, and OpenDDS::RTPS::LocalEntity::transport_context_.
Referenced by add_subscription().
void OpenDDS::RTPS::Sedp::append_transport_statistics | ( | DCPS::TransportStatisticsSequence & | seq | ) |
Definition at line 5977 of file Sedp.cpp.
References OpenDDS::DCPS::TransportInst::append_transport_statistics(), and transport_inst_.
Referenced by job_queue().
DCPS::TopicStatus OpenDDS::RTPS::Sedp::assert_topic | ( | GUID_t & | topicId, |
const char * | topicName, | ||
const char * | dataTypeName, | ||
const DDS::TopicQos & | qos, | ||
bool | hasDcpsKey, | ||
DCPS::TopicCallbacks * | topic_callbacks | ||
) |
Definition at line 6060 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::DCPS::CONFLICTING_TYPENAME, OpenDDS::DCPS::CREATED, OpenDDS::DCPS::FOUND, OpenDDS::DCPS::TopicDetails::init(), OpenDDS::DCPS::INTERNAL_ERROR, OpenDDS::DCPS::TransportClient::lock_, make_topic_guid(), OpenDDS::DCPS::TopicDetails::set_local(), topic_names_, and topics_.
Referenced by OpenDDS::RTPS::Spdp::assert_topic(), and ignoring().
|
private |
Definition at line 954 of file Sedp.cpp.
References OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::guid_to_bit_key(), OpenDDS::DCPS::make_id(), OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::RTPS::DiscoveredPublication::writer_data_, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.
Referenced by process_discovered_reader_data(), and process_discovered_writer_data().
|
private |
Definition at line 962 of file Sedp.cpp.
References OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::guid_to_bit_key(), OpenDDS::DCPS::make_id(), OpenDDS::RTPS::DiscoveredSubscription::reader_data_, OpenDDS::DCPS::DiscoveredReaderData::readerProxy, and OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid.
|
inlineprotectedvirtual |
Definition at line 1018 of file Sedp.h.
References OpenDDS::DCPS::assign(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::EntityId_t::entityKey, OpenDDS::DCPS::EntityId_t::entityKind, OpenDDS::DCPS::ENTITYKIND_USER_WRITER_NO_KEY, OpenDDS::DCPS::ENTITYKIND_USER_WRITER_WITH_KEY, has_dcps_key(), and publication_counter_.
Referenced by add_publication().
|
inlineprotectedvirtual |
Definition at line 1028 of file Sedp.h.
References OpenDDS::DCPS::assign(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::EntityId_t::entityKey, OpenDDS::DCPS::EntityId_t::entityKind, OpenDDS::DCPS::ENTITYKIND_USER_READER_NO_KEY, OpenDDS::DCPS::ENTITYKIND_USER_READER_WITH_KEY, has_dcps_key(), and subscription_counter_.
Referenced by add_subscription().
|
inlineprotectedvirtual |
Definition at line 1038 of file Sedp.h.
References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::assign(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::EntityId_t::entityKey, LM_ERROR, match_endpoints(), remove_assoc(), and topic_counter_.
Referenced by make_topic_guid().
void OpenDDS::RTPS::Sedp::associate | ( | DiscoveredParticipant & | participant, |
const DDS::Security::ParticipantSecurityAttributes & | participant_sec_attr | ||
) |
Definition at line 1044 of file Sedp.cpp.
References OpenDDS::RTPS::AC_EMPTY, OpenDDS::RTPS::AC_GENERATE_REMOTE_MATCHED_CRYPTO_HANDLE, OpenDDS::RTPS::AC_REMOTE_DURABLE, OpenDDS::RTPS::AC_REMOTE_RELIABLE, OpenDDS::RTPS::AC_SEND_LOCAL_TOKEN, associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::Spdp::available_extended_builtin_endpoints(), OpenDDS::RTPS::BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER, DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, DDS::Security::BUILTIN_PARTICIPANT_STATELESS_MESSAGE_READER, DDS::Security::BUILTIN_PARTICIPANT_STATELESS_MESSAGE_WRITER, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_READER, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_WRITER, dcps_participant_secure_reader_, dcps_participant_secure_writer_, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_WRITER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE, OpenDDS::RTPS::Spdp::is_security_enabled(), OpenDDS::DCPS::make_id(), participant_message_reader_, participant_message_secure_reader_, participant_message_secure_writer_, participant_message_writer_, participant_stateless_message_reader_, participant_stateless_message_writer_, participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, process_association_records_i(), publications_reader_, publications_secure_reader_, publications_secure_writer_, publications_writer_, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::RTPS::Spdp::shutting_down(), spdp_, DDS::Security::SPDP_BUILTIN_PARTICIPANT_SECURE_READER, DDS::Security::SPDP_BUILTIN_PARTICIPANT_SECURE_WRITER, subscriptions_reader_, subscriptions_secure_reader_, subscriptions_secure_writer_, subscriptions_writer_, type_lookup_reply_reader_, type_lookup_reply_secure_reader_, type_lookup_reply_secure_writer_, type_lookup_reply_writer_, type_lookup_request_reader_, type_lookup_request_secure_reader_, type_lookup_request_secure_writer_, type_lookup_request_writer_, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_READER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_WRITER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_READER_SECURE, and DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_WRITER_SECURE.
void OpenDDS::RTPS::Sedp::associate_volatile | ( | DiscoveredParticipant & | participant | ) |
Definition at line 1385 of file Sedp.cpp.
References OpenDDS::RTPS::AC_GENERATE_REMOTE_MATCHED_CRYPTO_HANDLE, OpenDDS::RTPS::AC_REMOTE_RELIABLE, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::ParticipantProxy_t::availableBuiltinEndpoints, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_READER, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_WRITER, OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::DCPS::make_id(), participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::RTPS::DiscoveredParticipant::pdata_, and spdp_.
void OpenDDS::RTPS::Sedp::association_complete_i | ( | const DCPS::GUID_t & | localId, |
const DCPS::GUID_t & | remoteId | ||
) |
Definition at line 2920 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE, is_expectant_opendds(), LM_DEBUG, local_subscriptions_, resend_user_crypto_tokens(), send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::send_participant_crypto_tokens(), spdp_, type_lookup_reply_secure_writer_, type_lookup_reply_writer_, type_lookup_request_secure_writer_, type_lookup_request_writer_, write_durable_dcps_participant_secure(), write_durable_participant_message_data(), write_durable_participant_message_data_secure(), write_durable_publication_data(), write_durable_subscription_data(), and write_subscription_data().
Referenced by OpenDDS::RTPS::Sedp::Writer::transport_assoc_done().
|
protected |
Definition at line 6759 of file Sedp.cpp.
References OpenDDS::DCPS::EventDispatcher::dispatch(), OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::equal_guid_prefixes(), event_dispatcher_, OpenDDS::DCPS::make_id(), participant_id_, OpenDDS::DCPS::WriterAssociation::participantDiscoveredAt, OpenDDS::RTPS::Spdp::participants_, OpenDDS::DCPS::WriterAssociation::pubQos, spdp_, TheServiceParticipant, OpenDDS::DCPS::WriterAssociation::transportContext, OpenDDS::DCPS::WriterAssociation::writerId, and OpenDDS::DCPS::WriterAssociation::writerQos.
Referenced by match_continue(), and remove_assoc().
|
private |
Definition at line 6644 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::Security::HandleRegistry::erase_local_datareader_crypto_handle(), get_crypto_key_factory(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), DDS::HANDLE_NIL, LM_ERROR, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and OpenDDS::DCPS::security_debug.
Referenced by purge_dead_topic(), remove_subscription(), and ~Sedp().
|
private |
Definition at line 6617 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::Security::HandleRegistry::erase_local_datawriter_crypto_handle(), get_crypto_key_factory(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), DDS::HANDLE_NIL, LM_ERROR, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and OpenDDS::DCPS::security_debug.
Referenced by purge_dead_topic(), remove_publication(), and ~Sedp().
|
private |
Definition at line 4050 of file Sedp.cpp.
References type_lookup_reply_reader_, and type_lookup_reply_secure_reader_.
Referenced by remove_expired_endpoints().
void OpenDDS::RTPS::Sedp::cleanup_volatile_crypto | ( | const DCPS::GUID_t & | remote | ) |
Definition at line 1379 of file Sedp.cpp.
References OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, and remove_remote_crypto_handle().
|
protected |
Definition at line 6728 of file Sedp.cpp.
References OpenDDS::DCPS::EventDispatcher::dispatch(), OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::equal_guid_prefixes(), event_dispatcher_, OpenDDS::DCPS::make_id(), participant_id_, OpenDDS::DCPS::ReaderAssociation::participantDiscoveredAt, OpenDDS::RTPS::Spdp::participants_, OpenDDS::DCPS::ReaderAssociation::readerId, OpenDDS::DCPS::ReaderAssociation::readerQos, spdp_, OpenDDS::DCPS::ReaderAssociation::subQos, TheServiceParticipant, and OpenDDS::DCPS::ReaderAssociation::transportContext.
Referenced by match_continue(), and remove_assoc().
|
protected |
Definition at line 1462 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), create_datareader_crypto_tokens(), LM_DEBUG, OpenDDS::DCPS::security_debug, and send_datareader_crypto_tokens().
Referenced by match_continue_security_enabled(), resend_user_crypto_tokens(), and send_builtin_crypto_tokens().
|
protected |
Definition at line 1481 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), create_datawriter_crypto_tokens(), LM_DEBUG, OpenDDS::DCPS::security_debug, and send_datawriter_crypto_tokens().
Referenced by match_continue_security_enabled(), resend_user_crypto_tokens(), and send_builtin_crypto_tokens().
|
protected |
Definition at line 5325 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), OpenDDS::RTPS::Spdp::get_security_config(), LM_WARNING, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and spdp_.
Referenced by create_and_send_datareader_crypto_tokens().
|
protected |
Definition at line 5369 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), OpenDDS::RTPS::Spdp::get_security_config(), LM_WARNING, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and spdp_.
Referenced by create_and_send_datawriter_crypto_tokens().
void OpenDDS::RTPS::Sedp::data_acked_i | ( | const DCPS::GUID_t & | local_id, |
const DCPS::GUID_t & | remote_id | ||
) |
Definition at line 2977 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, lock_, OpenDDS::DCPS::make_id(), OpenDDS::RTPS::Spdp::participants_, process_association_records_i(), and spdp_.
Referenced by OpenDDS::RTPS::Sedp::Writer::data_acked().
|
private |
Definition at line 2279 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, OpenDDS::RTPS::Spdp::has_discovered_participant(), OpenDDS::RTPS::DiscoveredPublication::have_ice_agent_info_, OpenDDS::RTPS::DiscoveredPublication::ice_agent_info_, ignoring(), OpenDDS::RTPS::Spdp::initialized(), lock_, OpenDDS::DCPS::make_part_guid(), process_discovered_writer_data(), OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::DCPS::SAMPLE_DATA, should_drop_message(), OpenDDS::RTPS::Spdp::shutting_down(), spdp_, OpenDDS::RTPS::DiscoveredPublication::type_info_, OpenDDS::RTPS::DiscoveredPublication::writer_data_, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.
Referenced by OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::LivelinessReader::data_received_i(), and OpenDDS::RTPS::Sedp::Reader::Reader().
|
private |
Definition at line 2314 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::have_ice_agent_info, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::ice_agent_info, ignoring(), OpenDDS::RTPS::Spdp::initialized(), lock_, OpenDDS::DCPS::make_part_guid(), process_discovered_writer_data(), OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::security_info, OpenDDS::RTPS::Spdp::shutting_down(), spdp_, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::type_info, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.
|
private |
Definition at line 2615 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, OpenDDS::RTPS::Spdp::has_discovered_participant(), OpenDDS::RTPS::DiscoveredSubscription::have_ice_agent_info_, OpenDDS::RTPS::DiscoveredSubscription::ice_agent_info_, ignoring(), OpenDDS::RTPS::Spdp::initialized(), lock_, OpenDDS::DCPS::make_part_guid(), process_discovered_reader_data(), OpenDDS::RTPS::DiscoveredSubscription::reader_data_, OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, OpenDDS::DCPS::SAMPLE_DATA, should_drop_message(), OpenDDS::RTPS::Spdp::shutting_down(), spdp_, and OpenDDS::RTPS::DiscoveredSubscription::type_info_.
|
private |
Definition at line 2649 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::have_ice_agent_info, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::ice_agent_info, ignoring(), OpenDDS::RTPS::Spdp::initialized(), lock_, process_discovered_reader_data(), OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::security_info, OpenDDS::RTPS::Spdp::shutting_down(), spdp_, and OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::type_info.
|
private |
Definition at line 2705 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::RTPS::Spdp::has_discovered_participant(), ignoring(), OpenDDS::RTPS::Spdp::initialized(), lock_, OpenDDS::DCPS::make_part_guid(), notify_liveliness(), OpenDDS::RTPS::ParticipantMessageData::participantGuid, OpenDDS::RTPS::Spdp::shutting_down(), and spdp_.
void OpenDDS::RTPS::Sedp::disassociate | ( | DiscoveredParticipant & | participant | ) |
Definition at line 1544 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::array_count(), associated_participants_, OpenDDS::RTPS::DiscoveredParticipant::builtin_associated_records_, OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_, DDS::Security::SecurityException::code, discovered_publications_, discovered_subscriptions_, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_WRITER_SECURE, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE, OpenDDS::Security::HandleRegistry::erase_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::erase_remote_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_all_remote_datareaders(), OpenDDS::Security::HandleRegistry::get_all_remote_datawriters(), OpenDDS::Security::SecurityConfig::get_crypto_key_factory(), get_handle_registry(), OpenDDS::RTPS::Spdp::get_security_config(), OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::RTPS::Spdp::is_security_enabled(), LM_ERROR, OpenDDS::DCPS::make_id(), OpenDDS::DCPS::make_unknown_guid(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, OPENDDS_VECTOR, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::RTPS::DiscoveredParticipant::pdata_, OpenDDS::RTPS::BuiltinAssociationRecord::remote_id(), remove_entities_belonging_to(), remove_from_bit_i(), remove_remote_crypto_handle(), OpenDDS::DCPS::security_debug, spdp_, and OpenDDS::RTPS::BuiltinAssociationRecord::transport_client_.
Referenced by OpenDDS::RTPS::Spdp::purge_discovered_participant().
void OpenDDS::RTPS::Sedp::disassociate_volatile | ( | DiscoveredParticipant & | participant | ) |
Definition at line 1345 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredParticipant::builtin_associated_records_, OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::RTPS::BuiltinAssociationRecord::local_id(), OpenDDS::DCPS::make_id(), participant_id_, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::RTPS::DiscoveredParticipant::pdata_, OpenDDS::RTPS::BuiltinAssociationRecord::remote_id(), and OpenDDS::RTPS::BuiltinAssociationRecord::transport_client_.
DCPS::TopicStatus OpenDDS::RTPS::Sedp::find_topic | ( | const char * | topicName, |
CORBA::String_out | dataTypeName, | ||
DDS::TopicQos_out | qos, | ||
GUID_t & | topicId | ||
) |
Definition at line 6085 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::DCPS::FOUND, OpenDDS::DCPS::INTERNAL_ERROR, OpenDDS::DCPS::TopicDetails::local_data_type_name(), OpenDDS::DCPS::TopicDetails::local_qos(), OpenDDS::DCPS::TransportClient::lock_, OpenDDS::DCPS::NOT_FOUND, OpenDDS::DCPS::TopicDetails::topic_id(), Update::TopicQos, and topics_.
Referenced by ignoring().
void OpenDDS::RTPS::Sedp::generate_remote_matched_crypto_handle | ( | const BuiltinAssociationRecord & | record | ) |
Definition at line 1012 of file Sedp.cpp.
References generate_remote_matched_reader_crypto_handle(), generate_remote_matched_writer_crypto_handle(), OpenDDS::RTPS::BuiltinAssociationRecord::local_id(), and OpenDDS::RTPS::BuiltinAssociationRecord::remote_id().
Referenced by generate_remote_matched_crypto_handles().
void OpenDDS::RTPS::Sedp::generate_remote_matched_crypto_handles | ( | DiscoveredParticipant & | participant | ) |
Definition at line 1334 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_, OpenDDS::RTPS::BuiltinAssociationRecord::generate_remote_matched_crypto_handle(), and generate_remote_matched_crypto_handle().
|
protected |
Definition at line 5291 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_factory(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datawriter_security_attributes(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, OpenDDS::Security::HandleRegistry::insert_remote_datareader_crypto_handle(), LM_WARNING, OpenDDS::RTPS::Spdp::lookup_participant_crypto_info(), OpenDDS::DCPS::make_id(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and spdp_.
Referenced by generate_remote_matched_crypto_handle(), and match_continue_security_enabled().
|
protected |
Definition at line 5258 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_factory(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datareader_security_attributes(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, OpenDDS::Security::HandleRegistry::insert_remote_datawriter_crypto_handle(), LM_WARNING, OpenDDS::RTPS::Spdp::lookup_participant_crypto_info(), OpenDDS::DCPS::make_id(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, and spdp_.
Referenced by generate_remote_matched_crypto_handle(), and match_continue_security_enabled().
|
inlineprotected |
Definition at line 1196 of file Sedp.h.
References access_control_.
Referenced by add_publication(), add_subscription(), process_discovered_reader_data(), process_discovered_writer_data(), should_drop_message(), and signal_liveliness().
|
inlineprotected |
Definition at line 1216 of file Sedp.h.
References crypto_key_exchange_.
Referenced by match_continue_security_enabled().
|
inlineprotected |
Definition at line 1206 of file Sedp.h.
References crypto_key_factory_.
Referenced by add_publication(), add_subscription(), cleanup_secure_reader(), and cleanup_secure_writer().
|
protected |
Definition at line 5538 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::get_domain_id(), and spdp_.
Referenced by add_publication(), and add_subscription().
|
inline |
Definition at line 257 of file Sedp.h.
References handle_registry_.
Referenced by add_publication(), add_subscription(), cleanup_secure_reader(), cleanup_secure_writer(), disassociate(), generate_remote_matched_reader_crypto_handle(), generate_remote_matched_writer_crypto_handle(), handle_datareader_crypto_tokens(), handle_datawriter_crypto_tokens(), init_security(), local_has_remote_endpoint_token_i(), local_has_remote_participant_token_i(), match_continue_security_enabled(), remote_has_local_endpoint_token_i(), remote_has_local_participant_token_i(), remove_remote_crypto_handle(), resend_user_crypto_tokens(), and send_builtin_crypto_tokens().
DCPS::WeakRcHandle< ICE::Endpoint > OpenDDS::RTPS::Sedp::get_ice_endpoint | ( | ) |
Definition at line 3117 of file Sedp.cpp.
References OpenDDS::DCPS::TransportInst::get_ice_endpoint(), and transport_inst_.
|
inlinestaticprotected |
Definition at line 1009 of file Sedp.h.
References OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, and OpenDDS::RTPS::DiscoveredPublication::writer_data_.
|
inlinestaticprotected |
Definition at line 1013 of file Sedp.h.
References OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, and OpenDDS::RTPS::DiscoveredSubscription::reader_data_.
|
inlineprotected |
Definition at line 1186 of file Sedp.h.
References permissions_handle_.
Referenced by add_publication(), add_subscription(), should_drop_message(), and signal_liveliness().
|
protected |
Definition at line 7529 of file Sedp.cpp.
References OpenDDS::XTypes::Sequence< T >::append(), OpenDDS::XTypes::TypeIdentifierWithDependencies::dependent_typeid_count, OpenDDS::XTypes::TypeIdentifierWithDependencies::dependent_typeids, is_security_enabled(), OpenDDS::XTypes::Sequence< T >::length(), OpenDDS::DCPS::make_part_guid(), max_type_lookup_service_reply_period_, orig_seq_numbers_, OpenDDS::RTPS::Sedp::TypeIdOrigSeqNumber::participant, OpenDDS::RTPS::Sedp::MatchingData::rpc_seqnum_complete, OpenDDS::RTPS::Sedp::MatchingData::rpc_seqnum_minimal, OpenDDS::RTPS::Sedp::TypeIdOrigSeqNumber::secure, send_type_lookup_request(), OpenDDS::RTPS::Sedp::TypeIdOrigSeqNumber::seq_number, OpenDDS::RTPS::Sedp::MatchingData::time_added_to_map, OpenDDS::RTPS::Sedp::TypeIdOrigSeqNumber::time_started, OpenDDS::RTPS::Sedp::TypeIdOrigSeqNumber::type_id, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, type_lookup_reply_deadline_processor_, and OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size.
Referenced by request_type_objects().
|
protected |
Definition at line 5476 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), DDS::Security::SecurityException::code, DDS::Security::ParticipantGenericMessage::destination_endpoint_guid, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, LM_DEBUG, LM_ERROR, LM_WARNING, OpenDDS::DCPS::TransportClient::lock_, OpenDDS::DCPS::make_id(), DDS::Security::SecurityException::message, DDS::Security::ParticipantGenericMessage::message_data, DDS::Security::SecurityException::minor_code, OpenDDS::RTPS::Spdp::participants_, pending_remote_reader_crypto_tokens_, process_association_records_i(), OpenDDS::DCPS::security_debug, DDS::Security::ParticipantGenericMessage::source_endpoint_guid, and spdp_.
Referenced by received_volatile_message_secure().
|
protected |
Definition at line 5413 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), DDS::Security::SecurityException::code, DDS::Security::ParticipantGenericMessage::destination_endpoint_guid, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, LM_DEBUG, LM_ERROR, LM_WARNING, OpenDDS::DCPS::TransportClient::lock_, OpenDDS::DCPS::make_id(), DDS::Security::SecurityException::message, DDS::Security::ParticipantGenericMessage::message_data, DDS::Security::SecurityException::minor_code, OpenDDS::RTPS::Spdp::participants_, pending_remote_writer_crypto_tokens_, process_association_records_i(), OpenDDS::DCPS::security_debug, DDS::Security::ParticipantGenericMessage::source_endpoint_guid, and spdp_.
Referenced by received_volatile_message_secure().
|
inlineprotected |
Definition at line 1163 of file Sedp.h.
References OPENDDS_MAP_CMP(), topic_names_, and topics_.
Referenced by assign_publication_key(), and assign_subscription_key().
void OpenDDS::RTPS::Sedp::ignore | ( | const GUID_t & | to_ignore | ) |
Definition at line 5988 of file Sedp.cpp.
References OpenDDS::DCPS::TopicDetails::discovered_publications(), discovered_publications_, OpenDDS::DCPS::TopicDetails::discovered_subscriptions(), discovered_subscriptions_, ignored_guids_, OpenDDS::DCPS::TopicDetails::is_dead(), match_endpoints(), OpenDDS::DCPS::TransportClient::OPENDDS_MAP_CMP(), purge_dead_topic(), OpenDDS::DCPS::TopicDetails::remove_discovered_publication(), OpenDDS::DCPS::TopicDetails::remove_discovered_subscription(), remove_from_bit(), OpenDDS::RTPS::Sedp::Endpoint::shutting_down(), topic_names_, and topics_.
Referenced by OpenDDS::RTPS::Spdp::ignore_domain_participant(), and job_queue().
|
inline |
Definition at line 205 of file Sedp.h.
References ignored_guids_.
Referenced by data_received(), received_participant_message_data_secure(), should_drop_stateless_message(), and should_drop_volatile_message().
|
inline |
Definition at line 209 of file Sedp.h.
References add_publication(), add_subscription(), assert_topic(), find_topic(), remove_publication(), remove_subscription(), remove_topic(), update_publication_locators(), and update_subscription_locators().
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::init | ( | const DCPS::GUID_t & | guid, |
const RtpsDiscovery & | disco, | ||
DDS::DomainId_t | domainId, | ||
XTypes::TypeLookupService_rch | tls | ||
) |
Definition at line 378 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::Spdp::available_extended_builtin_endpoints(), OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER, DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::RTPS::RtpsDiscovery::config(), OpenDDS::RTPS::Spdp::crypto_handle(), dcps_participant_secure_reader_, dcps_participant_secure_writer_, OpenDDS::DCPS::TransportRegistry::DEFAULT_INST_PREFIX, OpenDDS::RTPS::RtpsDiscovery::default_multicast_group(), OpenDDS::RTPS::RtpsDiscovery::dg(), OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER, OpenDDS::RTPS::RtpsDiscovery::dx(), OpenDDS::DCPS::TransportClient::enable_transport_using_config(), OpenDDS::DCPS::TransportInst::event_dispatcher(), event_dispatcher_, OpenDDS::DCPS::ReactorTask::get_reactor(), OpenDDS::DCPS::TransportConfig::instances_, OpenDDS::DCPS::ReactorTask::interceptor(), job_queue_, max_type_lookup_service_reply_period_, OpenDDS::RTPS::RtpsDiscovery::multicast_interface(), OPENDDS_STRING, participant_message_reader_, participant_message_secure_reader_, participant_message_secure_writer_, participant_message_writer_, participant_stateless_message_reader_, participant_stateless_message_writer_, participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, OpenDDS::DCPS::TransportConfig::passive_connect_duration_, OpenDDS::RTPS::RtpsDiscovery::pb(), publications_reader_, publications_secure_reader_, publications_secure_writer_, publications_writer_, ACE_Event_Handler::reactor(), OpenDDS::DCPS::TransportInst::reactor_task(), reactor_task_, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::RTPS::RtpsDiscovery::sedp_multicast(), OpenDDS::RTPS::Sedp::Endpoint::set_crypto_handles(), ACE_INET_Addr::set_port_number(), spdp_, OpenDDS::DCPS::static_rchandle_cast(), subscriptions_reader_, subscriptions_secure_reader_, subscriptions_secure_writer_, subscriptions_writer_, TheTransportRegistry, OpenDDS::DCPS::to_dds_string(), transport_cfg_, transport_inst_, OpenDDS::RTPS::RtpsDiscovery::ttl(), type_lookup_init(), type_lookup_reply_reader_, type_lookup_reply_secure_reader_, type_lookup_reply_secure_writer_, type_lookup_reply_writer_, type_lookup_request_reader_, type_lookup_request_secure_reader_, type_lookup_request_secure_writer_, type_lookup_request_writer_, type_lookup_service_, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_READER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_WRITER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_READER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_WRITER_SECURE, OpenDDS::DCPS::GuidConverter::uniqueParticipantId(), OpenDDS::RTPS::RtpsDiscovery::use_xtypes(), use_xtypes_, OpenDDS::RTPS::RtpsDiscovery::use_xtypes_complete(), and use_xtypes_complete_.
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::init_security | ( | DDS::Security::IdentityHandle | id_handle, |
DDS::Security::PermissionsHandle | perm_handle, | ||
DDS::Security::ParticipantCryptoHandle | crypto_handle | ||
) |
Definition at line 579 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, crypto_handle_, dcps_participant_secure_reader_, dcps_participant_secure_writer_, OpenDDS::Security::HandleRegistry::default_endpoint_security_attributes(), OpenDDS::Security::SecurityConfig::get_access_control(), OpenDDS::Security::SecurityConfig::get_authentication(), OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), OpenDDS::Security::SecurityConfig::get_crypto_key_factory(), OpenDDS::Security::SecurityConfig::get_handle_registry(), get_handle_registry(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, OpenDDS::Security::HandleRegistry::insert_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::insert_local_datawriter_crypto_handle(), LM_WARNING, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, participant_id_, participant_message_secure_reader_, participant_message_secure_writer_, participant_sec_attr_, participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, publications_secure_reader_, publications_secure_writer_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, set_access_control(), set_crypto_key_exchange(), set_crypto_key_factory(), set_handle_registry(), set_permissions_handle(), spdp_, subscriptions_secure_reader_, subscriptions_secure_writer_, TheServiceParticipant, type_lookup_reply_secure_reader_, type_lookup_reply_secure_writer_, type_lookup_request_secure_reader_, and type_lookup_request_secure_writer_.
|
privatevirtual |
Definition at line 2912 of file Sedp.cpp.
References OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::Spdp::is_expectant_opendds(), and spdp_.
Referenced by association_complete_i(), and process_discovered_reader_data().
|
inlineprotected |
Definition at line 1176 of file Sedp.h.
References access_control_, DDS::HANDLE_NIL, and permissions_handle_.
Referenced by add_publication(), add_subscription(), get_remote_type_objects(), match_continue(), process_discovered_reader_data(), process_discovered_writer_data(), remove_publication(), remove_publication_i(), remove_subscription(), remove_subscription_i(), send_type_lookup_request(), should_drop_message(), signal_liveliness(), write_durable_subscription_data(), write_publication_data(), and write_subscription_data().
|
inline |
Definition at line 199 of file Sedp.h.
References append_transport_statistics(), ignore(), and job_queue_.
const DCPS::NetworkAddress & OpenDDS::RTPS::Sedp::local_address | ( | ) | const |
Definition at line 928 of file Sedp.cpp.
References OpenDDS::DCPS::static_rchandle_cast(), and transport_inst_.
|
private |
Definition at line 6536 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datareader_security_attributes(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_security_attributes(), DDS::HANDLE_NIL, DDS::Security::EndpointSecurityAttributes::is_payload_protected, DDS::Security::EndpointSecurityAttributes::is_submessage_protected, LM_INFO, OpenDDS::RTPS::Spdp::security_config_, and spdp_.
Referenced by ready().
|
private |
Definition at line 6481 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::crypto_handle_, crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_remote_participant_crypto_handle(), DDS::HANDLE_NIL, LM_INFO, OpenDDS::DCPS::make_id(), OpenDDS::RTPS::Spdp::security_config_, and spdp_.
Referenced by ready().
|
inlineprotected |
Definition at line 1154 of file Sedp.h.
References assign_topic_key(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::EntityId_t::entityKind, OpenDDS::DCPS::ENTITYKIND_OPENDDS_TOPIC, and participant_id_.
Referenced by assert_topic(), process_discovered_reader_data(), and process_discovered_writer_data().
Definition at line 6824 of file Sedp.cpp.
References ACE_DEBUG, OpenDDS::DCPS::DCPS_debug_level, discovered_publications_, discovered_subscriptions_, OpenDDS::XTypes::TypeIdentifier::kind(), LM_DEBUG, local_publications_, local_subscriptions_, match_continue(), OpenDDS::XTypes::TypeInformation::minimal, need_minimal_and_or_complete_types(), request_type_objects(), OpenDDS::XTypes::TK_NONE, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, and use_xtypes_.
Referenced by match_endpoints().
Definition at line 7049 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), add_assoc_i(), OpenDDS::DCPS::RecorderImpl::add_to_dynamic_type_map(), DDS::ALLOW_TYPE_COERCION, OpenDDS::XTypes::TypeAssignability::assignable(), cleanup_reader_association(), cleanup_writer_association(), OpenDDS::DCPS::compatibleQOS(), OpenDDS::XTypes::TypeInformation::complete, OpenDDS::DCPS::IncompatibleQosStatus::count_since_last_send, OpenDDS::DCPS::DCPS_debug_level, DDS::DataWriterQos::deadline, DDS::DataReaderQos::deadline, OpenDDS::XTypes::deserialize_type_info(), DDS::DataWriterQos::destination_order, DDS::DataReaderQos::destination_order, discovered_publications_, discovered_subscriptions_, OpenDDS::DCPS::EventDispatcher::dispatch(), DDS::DataWriterQos::durability, DDS::DataReaderQos::durability, DDS::DataWriterQos::durability_service, DDS::PublisherQos::entity_factory, DDS::SubscriberQos::entity_factory, OpenDDS::DCPS::ENTITYID_PARTICIPANT, event_dispatcher_, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, OpenDDS::DCPS::ContentFilterProperty_t::filterClassName, OpenDDS::DCPS::ContentFilterProperty_t::filterExpression, DDS::TypeConsistencyEnforcementQosPolicy::force_type_validation, DDS::PublisherQos::group_data, DDS::SubscriberQos::group_data, DDS::DataWriterQos::history, DDS::DataReaderQos::history, OpenDDS::XTypes::TypeConsistencyAttributes::ignore_member_names, DDS::TypeConsistencyEnforcementQosPolicy::ignore_member_names, OpenDDS::XTypes::TypeConsistencyAttributes::ignore_sequence_bounds, DDS::TypeConsistencyEnforcementQosPolicy::ignore_sequence_bounds, OpenDDS::XTypes::TypeConsistencyAttributes::ignore_string_bounds, DDS::TypeConsistencyEnforcementQosPolicy::ignore_string_bounds, OpenDDS::DCPS::RcHandle< T >::in(), OpenDDS::XTypes::IS_APPENDABLE, is_security_enabled(), DDS::TypeConsistencyEnforcementQosPolicy::kind, OpenDDS::XTypes::TypeIdentifier::kind(), OpenDDS::DCPS::Encoding::KIND_XCDR1, DDS::DataWriterQos::latency_budget, DDS::DataReaderQos::latency_budget, DDS::DataWriterQos::lifespan, DDS::DataWriterQos::liveliness, DDS::DataReaderQos::liveliness, LM_DEBUG, LM_ERROR, LM_WARNING, local_publications_, local_subscriptions_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::DCPS::make_id(), match_continue_security_enabled(), OpenDDS::XTypes::TypeInformation::minimal, OPENDDS_ASSERT, DDS::DataWriterQos::ownership, DDS::DataReaderQos::ownership, DDS::DataWriterQos::ownership_strength, OpenDDS::RTPS::Spdp::participants_, DDS::PublisherQos::partition, DDS::SubscriberQos::partition, populate_origination_locator(), populate_transport_locator_sequence(), DDS::PublisherQos::presentation, DDS::SubscriberQos::presentation, OpenDDS::XTypes::TypeConsistencyAttributes::prevent_type_widening, DDS::TypeConsistencyEnforcementQosPolicy::prevent_type_widening, process_association_records_i(), DDS::DataReaderQos::reader_data_lifecycle, OpenDDS::DCPS::ReaderAssociation::readerTransInfo, DDS::DataWriterQos::reliability, DDS::DataReaderQos::reliability, remove_assoc_i(), OpenDDS::DCPS::repr_to_encoding_kind(), DDS::DataWriterQos::representation, DDS::DataReaderQos::representation, DDS::DataWriterQos::resource_limits, DDS::DataReaderQos::resource_limits, OpenDDS::XTypes::serialize_type_info(), spdp_, TheServiceParticipant, DDS::DataReaderQos::time_based_filter, OpenDDS::XTypes::TK_NONE, topic_names_, topics_, DDS::DataWriterQos::transport_priority, DDS::DataReaderQos::type_consistency, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, type_lookup_service_, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, use_xtypes_complete_, DDS::DataWriterQos::user_data, DDS::DataReaderQos::user_data, DDS::DataRepresentationQosPolicy::value, DDS::DataWriterQos::writer_data_lifecycle, and OpenDDS::DCPS::WriterAssociation::writerTransInfo.
Referenced by match(), and OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply().
|
protected |
Definition at line 7570 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), DDS::Security::SecurityException::code, create_and_send_datareader_crypto_tokens(), create_and_send_datawriter_crypto_tokens(), generate_remote_matched_reader_crypto_handle(), generate_remote_matched_writer_crypto_handle(), get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datareader_security_attributes(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datawriter_security_attributes(), DDS::HANDLE_NIL, DDS::Security::EndpointSecurityAttributes::is_payload_protected, DDS::Security::EndpointSecurityAttributes::is_submessage_protected, LM_ERROR, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, pending_remote_reader_crypto_tokens_, and pending_remote_writer_crypto_tokens_.
Referenced by match_continue().
|
protected |
Definition at line 6673 of file Sedp.cpp.
References ACE_DEBUG, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TopicDetails::discovered_publications(), OpenDDS::DCPS::TopicDetails::discovered_subscriptions(), OpenDDS::DCPS::equal_guid_prefixes(), OpenDDS::DCPS::GuidConverter::isReader(), LM_DEBUG, OpenDDS::DCPS::TopicDetails::local_publications(), OpenDDS::DCPS::TopicDetails::local_subscriptions(), match(), participant_id_, and remove_assoc().
Referenced by add_publication(), add_subscription(), assign_topic_key(), ignore(), process_discovered_reader_data(), process_discovered_writer_data(), remove_entities_belonging_to(), remove_publication(), remove_subscription(), update_publication_qos(), and update_subscription_qos().
const DCPS::NetworkAddress & OpenDDS::RTPS::Sedp::multicast_group | ( | ) | const |
Definition at line 946 of file Sedp.cpp.
References OpenDDS::DCPS::static_rchandle_cast(), and transport_inst_.
DCPS::LocatorSeq OpenDDS::RTPS::Sedp::multicast_locators | ( | ) | const |
Definition at line 920 of file Sedp.cpp.
References OpenDDS::DCPS::CONNINFO_MULTICAST, OpenDDS::DCPS::TransportInst::populate_locator(), transport_inst_, and OpenDDS::RTPS::transport_locator_to_locator_seq().
|
protected |
Definition at line 6964 of file Sedp.cpp.
References OpenDDS::XTypes::TypeInformation::complete, OpenDDS::XTypes::TypeIdentifier::kind(), OpenDDS::XTypes::TypeInformation::minimal, OpenDDS::XTypes::TK_NONE, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, type_lookup_service_, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, and use_xtypes_complete_.
Referenced by match().
|
private |
This is a function to unify the notification of liveliness within RTPS The local participant map is checked for associated entities and then they are notified of liveliness if their QoS is compatible
Definition at line 2671 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::AUTOMATIC_LIVELINESS_QOS, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::equal_guid_prefixes(), LM_DEBUG, local_subscriptions_, OpenDDS::DCPS::make_part_guid(), OpenDDS::DCPS::make_unknown_guid(), DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE, and OpenDDS::RTPS::ParticipantMessageData::participantGuid.
Referenced by data_received(), received_participant_message_data_secure(), and write_participant_message_data().
|
private |
Referenced by OpenDDS::RTPS::Sedp::Writer::get_seq(), and OpenDDS::RTPS::Sedp::MatchingPair::operator<().
|
protected |
|
private |
Referenced by has_dcps_key(), purge_dead_topic(), transport_inst(), and update_topic_qos().
|
private |
|
private |
|
private |
|
private |
|
protected |
|
protected |
|
protected |
|
protected |
|
private |
Definition at line 4586 of file Sedp.cpp.
References OpenDDS::DCPS::ReaderProxy_t::allLocators, OpenDDS::DCPS::ReaderProxy_t::associatedWriters, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::ContentFilterProperty_t::contentFilteredTopicName, OpenDDS::DCPS::DiscoveredReaderData::contentFilterProperty, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, DDS::DataReaderQos::deadline, DDS::DataReaderQos::destination_order, DDS::DataReaderQos::durability, OpenDDS::DCPS::ReaderProxy_t::expectsInlineQos, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, OpenDDS::DCPS::ContentFilterProperty_t::filterClassName, OpenDDS::DCPS::ContentFilterProperty_t::filterExpression, OpenDDS::RTPS::LocalSubscription::filterProperties, DDS::SubscriberQos::group_data, DDS::DataReaderQos::latency_budget, DDS::DataReaderQos::liveliness, OpenDDS::DCPS::TopicDetails::local_data_type_name(), OpenDDS::DCPS::TopicDetails::local_qos(), OPENDDS_STRING, DDS::DataReaderQos::ownership, DDS::SubscriberQos::partition, DDS::SubscriberQos::presentation, OpenDDS::RTPS::LocalSubscription::qos_, OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::DCPS::ContentFilterProperty_t::relatedTopicName, DDS::DataReaderQos::reliability, OpenDDS::RTPS::LocalEntity::remote_expectant_opendds_associations_, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, DDS::DataReaderQos::representation, OpenDDS::RTPS::LocalSubscription::subscriber_qos_, DDS::DataReaderQos::time_based_filter, DDS::TopicQos::topic_data, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, OpenDDS::RTPS::LocalEntity::trans_info_, DDS::DataReaderQos::type_consistency, and DDS::DataReaderQos::user_data.
Referenced by write_subscription_data_secure(), and write_subscription_data_unsecure().
|
private |
Definition at line 4551 of file Sedp.cpp.
References OpenDDS::DCPS::WriterProxy_t::allLocators, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, DDS::DataWriterQos::deadline, DDS::DataWriterQos::destination_order, DDS::DataWriterQos::durability, DDS::DataWriterQos::durability_service, DDS::PublisherQos::group_data, DDS::DataWriterQos::latency_budget, DDS::DataWriterQos::lifespan, DDS::DataWriterQos::liveliness, OpenDDS::DCPS::TopicDetails::local_data_type_name(), OpenDDS::DCPS::TopicDetails::local_qos(), OPENDDS_STRING, DDS::DataWriterQos::ownership, DDS::DataWriterQos::ownership_strength, DDS::PublisherQos::partition, DDS::PublisherQos::presentation, OpenDDS::RTPS::LocalPublication::publisher_qos_, OpenDDS::RTPS::LocalPublication::qos_, DDS::DataWriterQos::reliability, OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, DDS::DataWriterQos::representation, DDS::TopicQos::topic_data, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, OpenDDS::RTPS::LocalEntity::trans_info_, DDS::DataWriterQos::user_data, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.
Referenced by write_publication_data_secure(), and write_publication_data_unsecure().
|
private |
Definition at line 7017 of file Sedp.cpp.
References OpenDDS::DCPS::TransportLocator::data, OpenDDS::STUN::encoding(), OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, OpenDDS::RTPS::Spdp::get_last_recv_locator(), OpenDDS::DCPS::TransportInst::get_last_recv_locator(), OpenDDS::RTPS::get_locators_encoding(), OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity(), OpenDDS::DCPS::GuidConverter::isReader(), OpenDDS::DCPS::make_id(), OpenDDS::RTPS::message_block_to_sequence(), OpenDDS::DCPS::primitive_serialized_size_boolean(), OpenDDS::DCPS::serialized_size(), spdp_, transport_inst_, and OpenDDS::DCPS::TransportLocator::transport_type.
Referenced by match_continue(), and process_association_records_i().
|
privatevirtual |
Definition at line 5176 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::TransportLocator::data, OpenDDS::STUN::encoding(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::Spdp::get_default_locators(), OpenDDS::RTPS::get_locators_encoding(), LM_WARNING, OpenDDS::RTPS::message_block_to_sequence(), OpenDDS::DCPS::primitive_serialized_size_boolean(), OpenDDS::DCPS::serialized_size(), spdp_, and OpenDDS::DCPS::TransportLocator::transport_type.
Referenced by match_continue().
|
privatevirtual |
Definition at line 5218 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::TransportLocator::data, OpenDDS::STUN::encoding(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::RTPS::Spdp::get_default_locators(), OpenDDS::RTPS::get_locators_encoding(), LM_WARNING, OpenDDS::RTPS::message_block_to_sequence(), OpenDDS::DCPS::primitive_serialized_size_boolean(), OpenDDS::DCPS::serialized_size(), spdp_, and OpenDDS::DCPS::TransportLocator::transport_type.
void OpenDDS::RTPS::Sedp::process_association_records_i | ( | DiscoveredParticipant & | participant | ) |
Definition at line 1264 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::DiscoveredParticipant::builtin_associated_records_, OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_, OpenDDS::RTPS::create_association_data_proto(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::AssociationData::discovery_locator_, OpenDDS::DCPS::EventDispatcher::dispatch(), event_dispatcher_, OpenDDS::DCPS::GuidConverter::isReader(), LM_INFO, OpenDDS::RTPS::BuiltinAssociationRecord::local_id(), OpenDDS::RTPS::BuiltinAssociationRecord::local_tokens_sent(), OpenDDS::RTPS::DiscoveredParticipant::pdata_, populate_origination_locator(), OpenDDS::RTPS::DiscoveredParticipant::reader_associated_records_, OpenDDS::RTPS::WriterAssociationRecord::reader_id(), OpenDDS::RTPS::ReaderAssociationRecord::reader_id(), OpenDDS::RTPS::DiscoveredParticipant::reader_pending_records_, ready(), OpenDDS::RTPS::BuiltinAssociationRecord::remote_durable(), OpenDDS::DCPS::AssociationData::remote_durable_, OpenDDS::RTPS::BuiltinAssociationRecord::remote_id(), OpenDDS::DCPS::AssociationData::remote_id_, OpenDDS::RTPS::BuiltinAssociationRecord::remote_reliable(), OpenDDS::DCPS::AssociationData::remote_reliable_, OpenDDS::RTPS::BuiltinAssociationRecord::transport_client_, OpenDDS::RTPS::DiscoveredParticipant::writer_associated_records_, OpenDDS::RTPS::WriterAssociationRecord::writer_id(), OpenDDS::RTPS::ReaderAssociationRecord::writer_id(), and OpenDDS::RTPS::DiscoveredParticipant::writer_pending_records_.
Referenced by associate(), data_acked_i(), handle_datareader_crypto_tokens(), handle_datawriter_crypto_tokens(), and match_continue().
|
private |
Definition at line 2336 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::TopicDetails::add_discovered_subscription(), OpenDDS::DCPS::ReaderProxy_t::allLocators, assign_bit_key(), OpenDDS::DCPS::ReaderProxy_t::associatedWriters, OpenDDS::RTPS::AUTH_STATE_AUTHENTICATED, OpenDDS::RTPS::AUTH_STATE_UNAUTHENTICATED, DDS::Security::SubscriptionBuiltinTopicData::base, DDS::Security::SubscriptionBuiltinTopicDataSecure::base, OpenDDS::RTPS::DiscoveredSubscription::bit_ih_, OpenDDS::RTPS::Spdp::bit_subscriber_, DDS::Security::SecurityException::code, OpenDDS::DCPS::DiscoveredReaderData::contentFilterProperty, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, discovered_subscriptions_, OpenDDS::DCPS::DISPOSE_INSTANCE, OpenDDS::DCPS::DISPOSE_UNREGISTER_INSTANCE, DDS::Security::EndpointSecurityInfo::endpoint_security_attributes, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, get_access_control(), OpenDDS::RTPS::Spdp::get_domain_id(), OpenDDS::RTPS::Spdp::get_participant_discovered_at(), OpenDDS::RTPS::Spdp::get_participant_flags(), OpenDDS::RTPS::DiscoveredSubscription::get_topic_name(), OpenDDS::RTPS::DiscoveredSubscription::have_ice_agent_info_, OpenDDS::RTPS::DiscoveredSubscription::ice_agent_info_, DDS::Security::ParticipantSecurityAttributes::is_access_protected, is_expectant_opendds(), DDS::Security::TopicSecurityAttributes::is_read_protected, is_security_enabled(), LM_DEBUG, LM_WARNING, local_publications_, OpenDDS::DCPS::log_progress(), OpenDDS::RTPS::Spdp::lookup_participant_auth_state(), OpenDDS::RTPS::Spdp::lookup_participant_permissions(), make_topic_guid(), match_endpoints(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, DDS::NEW_VIEW_STATE, DDS::NOT_NEW_VIEW_STATE, OPENDDS_ASSERT, OPENDDS_STRING, OpenDDS::RTPS::DiscoveredSubscription::participant_discovered_at_, participant_id_, participant_sec_attr_, DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes, purge_dead_topic(), OpenDDS::RTPS::DiscoveredSubscription::reader_data_, OpenDDS::DCPS::DiscoveredReaderData::readerProxy, remove_from_bit(), OpenDDS::DCPS::SAMPLE_DATA, DDS::Security::SubscriptionBuiltinTopicData::security_info, OpenDDS::RTPS::Spdp::shutting_down(), spdp_, start_ice(), stop_ice(), topic_names_, topics_, OpenDDS::RTPS::DiscoveredSubscription::transport_context_, OpenDDS::DCPS::transport_debug, OpenDDS::RTPS::DiscoveredSubscription::type_info_, and OpenDDS::DCPS::UNREGISTER_INSTANCE.
Referenced by data_received().
|
private |
Definition at line 2042 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::TopicDetails::add_discovered_publication(), OpenDDS::DCPS::WriterProxy_t::allLocators, assign_bit_key(), OpenDDS::RTPS::AUTH_STATE_AUTHENTICATED, OpenDDS::RTPS::AUTH_STATE_UNAUTHENTICATED, DDS::Security::PublicationBuiltinTopicData::base, DDS::Security::PublicationBuiltinTopicDataSecure::base, OpenDDS::RTPS::DiscoveredPublication::bit_ih_, OpenDDS::RTPS::Spdp::bit_subscriber_, DDS::Security::SecurityException::code, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, discovered_publications_, OpenDDS::DCPS::DISPOSE_INSTANCE, OpenDDS::DCPS::DISPOSE_UNREGISTER_INSTANCE, DDS::Security::EndpointSecurityInfo::endpoint_security_attributes, get_access_control(), OpenDDS::RTPS::Spdp::get_domain_id(), OpenDDS::RTPS::Spdp::get_participant_discovered_at(), OpenDDS::RTPS::Spdp::get_participant_flags(), OpenDDS::RTPS::DiscoveredPublication::get_topic_name(), OpenDDS::RTPS::DiscoveredPublication::have_ice_agent_info_, OpenDDS::RTPS::DiscoveredPublication::ice_agent_info_, DDS::Security::ParticipantSecurityAttributes::is_access_protected, is_security_enabled(), DDS::Security::TopicSecurityAttributes::is_write_protected, LM_DEBUG, LM_WARNING, local_subscriptions_, OpenDDS::DCPS::log_progress(), OpenDDS::RTPS::Spdp::lookup_participant_auth_state(), OpenDDS::RTPS::Spdp::lookup_participant_permissions(), OpenDDS::DCPS::make_part_guid(), make_topic_guid(), match_endpoints(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, DDS::NEW_VIEW_STATE, DDS::NOT_NEW_VIEW_STATE, OPENDDS_STRING, OpenDDS::RTPS::DiscoveredPublication::participant_discovered_at_, participant_id_, participant_sec_attr_, DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes, purge_dead_topic(), remove_from_bit(), OpenDDS::DCPS::SAMPLE_DATA, DDS::Security::PublicationBuiltinTopicData::security_info, OpenDDS::RTPS::Spdp::shutting_down(), spdp_, start_ice(), stop_ice(), topic_names_, topics_, OpenDDS::RTPS::DiscoveredPublication::transport_context_, OpenDDS::DCPS::transport_debug, OpenDDS::RTPS::DiscoveredPublication::type_info_, OpenDDS::DCPS::UNREGISTER_INSTANCE, OpenDDS::RTPS::DiscoveredPublication::writer_data_, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.
Referenced by data_received().
|
inlineprivate |
Definition at line 307 of file Sedp.h.
References cleanup_secure_reader(), cleanup_secure_writer(), OPENDDS_MAP_CMP(), topic_names_, and topics_.
Referenced by ignore(), process_discovered_reader_data(), process_discovered_writer_data(), remove_entities_belonging_to(), and remove_topic().
|
inline |
bool OpenDDS::RTPS::Sedp::ready | ( | const DiscoveredParticipant & | participant, |
const GUID_t & | local_id, | ||
const GUID_t & | remote_id, | ||
bool | local_tokens_sent | ||
) | const |
Definition at line 1022 of file Sedp.cpp.
References local_has_remote_endpoint_token_i(), local_has_remote_participant_token_i(), remote_has_local_endpoint_token_i(), remote_has_local_participant_token_i(), remote_is_authenticated_i(), and remote_knows_about_local_i().
Referenced by process_association_records_i().
|
private |
Definition at line 2729 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::RTPS::Spdp::has_discovered_participant(), ignoring(), lock_, OpenDDS::DCPS::make_part_guid(), notify_liveliness(), OpenDDS::RTPS::ParticipantMessageData::participantGuid, OpenDDS::RTPS::Spdp::shutting_down(), and spdp_.
Referenced by OpenDDS::RTPS::Sedp::LivelinessReader::data_received_i().
|
private |
Definition at line 2846 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::GMCLASSID_SECURITY_AUTH_HANDSHAKE, DDS::Security::GMCLASSID_SECURITY_AUTH_REQUEST, OpenDDS::RTPS::Spdp::handle_auth_request(), OpenDDS::RTPS::Spdp::handle_handshake_message(), LM_DEBUG, DDS::Security::ParticipantGenericMessage::message_class_id, OpenDDS::DCPS::security_debug, should_drop_stateless_message(), OpenDDS::RTPS::Spdp::shutting_down(), and spdp_.
Referenced by OpenDDS::RTPS::Sedp::SecurityReader::data_received_i().
|
private |
Definition at line 2876 of file Sedp.cpp.
References ACE_DEBUG, DDS::Security::GMCLASSID_SECURITY_DATAREADER_CRYPTO_TOKENS, DDS::Security::GMCLASSID_SECURITY_DATAWRITER_CRYPTO_TOKENS, DDS::Security::GMCLASSID_SECURITY_PARTICIPANT_CRYPTO_TOKENS, handle_datareader_crypto_tokens(), handle_datawriter_crypto_tokens(), OpenDDS::RTPS::Spdp::handle_participant_crypto_tokens(), LM_DEBUG, DDS::Security::ParticipantGenericMessage::message_class_id, should_drop_volatile_message(), OpenDDS::RTPS::Spdp::shutting_down(), and spdp_.
Referenced by OpenDDS::RTPS::Sedp::SecurityReader::data_received_i().
|
private |
Definition at line 6581 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), DDS::HANDLE_NIL, LM_INFO, OpenDDS::DCPS::make_id(), participant_volatile_message_secure_writer_, OpenDDS::RTPS::Spdp::security_config_, and spdp_.
Referenced by ready().
|
private |
Definition at line 6508 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::crypto_handle_, crypto_handle_, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::Security::SecurityConfig::get_crypto_key_exchange(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_remote_participant_crypto_handle(), DDS::HANDLE_NIL, LM_INFO, OpenDDS::DCPS::make_id(), OpenDDS::RTPS::DiscoveredParticipant::participant_tokens_sent_, participant_volatile_message_secure_writer_, OpenDDS::RTPS::Spdp::security_config_, and spdp_.
Referenced by ready().
|
private |
Definition at line 6455 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::ParticipantSecurityAttributes::allow_unauthenticated_participants, OpenDDS::RTPS::DiscoveredParticipant::auth_state_, OpenDDS::RTPS::AUTH_STATE_AUTHENTICATED, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::DiscoveredParticipant::has_security_data(), OpenDDS::RTPS::Spdp::is_security_enabled(), LM_INFO, participant_sec_attr_, and spdp_.
Referenced by ready().
|
private |
Definition at line 6408 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity(), OpenDDS::DCPS::GuidConverter::isWriter(), LM_ERROR, LM_INFO, local_publications_, local_subscriptions_, OpenDDS::DCPS::make_id(), OPENDDS_ASSERT, publications_secure_writer_, publications_writer_, subscriptions_secure_writer_, and subscriptions_writer_.
Referenced by ready().
|
protected |
Definition at line 6790 of file Sedp.cpp.
References cleanup_reader_association(), cleanup_writer_association(), discovered_publications_, discovered_subscriptions_, local_publications_, local_subscriptions_, remove_assoc_i(), and write_subscription_data().
Referenced by assign_topic_key(), and match_endpoints().
|
protected |
Definition at line 5635 of file Sedp.cpp.
References ice_agent_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), and OpenDDS::RTPS::LocalPublication::publication_.
Referenced by match_continue(), remove_assoc(), and OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener().
|
protected |
Definition at line 5672 of file Sedp.cpp.
References ice_agent_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), and OpenDDS::RTPS::LocalSubscription::subscription_.
|
private |
Definition at line 1795 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_UNKNOWN, OpenDDS::DCPS::GUID_t::guidPrefix, LM_DEBUG, match_endpoints(), purge_dead_topic(), OpenDDS::RTPS::Spdp::shutting_down(), spdp_, and topics_.
Referenced by disassociate().
|
protected |
Definition at line 6978 of file Sedp.cpp.
References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::LogGuid::c_str(), cleanup_type_lookup_data(), OpenDDS::DCPS::DCPS_debug_level, LM_DEBUG, OpenDDS::DCPS::TransportClient::lock_, matching_data_buffer_, max_type_lookup_service_reply_period_, orig_seq_numbers_, and DDS::RETCODE_TIMEOUT.
Referenced by type_lookup_init().
|
inlineprotected |
Definition at line 1144 of file Sedp.h.
References remove_from_bit_i().
Referenced by ignore(), process_discovered_reader_data(), and process_discovered_writer_data().
|
inlineprotected |
Definition at line 1149 of file Sedp.h.
References remove_from_bit_i().
|
private |
Definition at line 1828 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredPublication::bit_ih_, OpenDDS::RTPS::Spdp::bit_subscriber_, and spdp_.
Referenced by disassociate(), and remove_from_bit().
|
private |
Definition at line 1834 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredSubscription::bit_ih_, OpenDDS::RTPS::Spdp::bit_subscriber_, and spdp_.
void OpenDDS::RTPS::Sedp::remove_publication | ( | const GUID_t & | publicationId | ) |
Definition at line 6218 of file Sedp.cpp.
References ACE_ERROR, ACE_GUARD, ACE_TEXT(), cleanup_secure_writer(), is_security_enabled(), LM_ERROR, local_publications_, OpenDDS::DCPS::TransportClient::lock_, match_endpoints(), remove_publication_i(), DDS::RETCODE_OK, topic_names_, and topics_.
Referenced by ignoring().
|
privatevirtual |
Definition at line 1878 of file Sedp.cpp.
References DDS::Security::EndpointSecurityAttributes::base, ice_agent_, DDS::Security::TopicSecurityAttributes::is_discovery_protected, is_security_enabled(), OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalPublication::publication_, publications_secure_writer_, publications_writer_, and OpenDDS::RTPS::LocalEntity::security_attribs_.
Referenced by remove_publication().
void OpenDDS::RTPS::Sedp::remove_remote_crypto_handle | ( | const DCPS::GUID_t & | participant, |
const EntityId_t & | entity | ||
) |
Definition at line 1421 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), DDS::Security::SecurityException::code, OpenDDS::Security::HandleRegistry::erase_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::erase_remote_datawriter_crypto_handle(), OpenDDS::Security::SecurityConfig::get_crypto_key_factory(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), OpenDDS::RTPS::Spdp::get_security_config(), DDS::HANDLE_NIL, OpenDDS::DCPS::GuidConverter::isReader(), OpenDDS::DCPS::GuidConverter::isWriter(), LM_ERROR, OpenDDS::DCPS::make_id(), DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, OpenDDS::DCPS::security_debug, and spdp_.
Referenced by cleanup_volatile_crypto(), and disassociate().
void OpenDDS::RTPS::Sedp::remove_subscription | ( | const GUID_t & | subscriptionId | ) |
Definition at line 6364 of file Sedp.cpp.
References ACE_ERROR, ACE_GUARD, ACE_TEXT(), cleanup_secure_reader(), is_security_enabled(), LM_ERROR, local_subscriptions_, OpenDDS::DCPS::TransportClient::lock_, match_endpoints(), remove_subscription_i(), DDS::RETCODE_OK, topic_names_, and topics_.
Referenced by ignoring().
|
privatevirtual |
Definition at line 1927 of file Sedp.cpp.
References DDS::Security::EndpointSecurityAttributes::base, ice_agent_, DDS::Security::TopicSecurityAttributes::is_discovery_protected, is_security_enabled(), OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalEntity::security_attribs_, OpenDDS::RTPS::LocalSubscription::subscription_, subscriptions_secure_writer_, and subscriptions_writer_.
Referenced by remove_subscription().
DCPS::TopicStatus OpenDDS::RTPS::Sedp::remove_topic | ( | const GUID_t & | topicId | ) |
Definition at line 6105 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::DCPS::INTERNAL_ERROR, OpenDDS::DCPS::TopicDetails::is_dead(), OpenDDS::DCPS::TransportClient::lock_, name, OpenDDS::DCPS::NOT_FOUND, purge_dead_topic(), OpenDDS::DCPS::REMOVED, topic_names_, topics_, and OpenDDS::DCPS::TopicDetails::unset_local().
Referenced by ignoring().
|
protected |
Definition at line 1634 of file Sedp.cpp.
References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, LM_DEBUG, lock_, OPENDDS_STRING, write_durable_dcps_participant_secure(), write_durable_participant_message_data(), write_durable_participant_message_data_secure(), write_durable_publication_data(), and write_durable_subscription_data().
Referenced by OpenDDS::RTPS::Sedp::Writer::remove_associations(), OpenDDS::RTPS::Sedp::Writer::replay_durable_data_for(), and OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener().
void OpenDDS::RTPS::Sedp::request_remote_complete_type_objects | ( | const GUID_t & | remote_entity, |
const XTypes::TypeInformation & | remote_type_info, | ||
DCPS::TypeObjReqCond & | cond | ||
) |
Definition at line 6925 of file Sedp.cpp.
References ACE_ERROR, discovered_publications_, discovered_subscriptions_, OpenDDS::DCPS::TypeObjReqCond::done(), OpenDDS::DCPS::GuidConverter::isReader(), OpenDDS::DCPS::GuidConverter::isWriter(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, request_type_objects(), and DDS::RETCODE_BAD_PARAMETER.
Referenced by transport_inst().
|
protected |
Definition at line 7484 of file Sedp.cpp.
References ACE_DEBUG, OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::XTypes::TypeInformation::complete, OpenDDS::DCPS::DCPS_debug_level, get_remote_type_objects(), OpenDDS::DCPS::SequenceNumber::getValue(), OpenDDS::RTPS::Sedp::MatchingData::got_complete, OpenDDS::RTPS::Sedp::MatchingData::got_minimal, LM_DEBUG, matching_data_buffer_, OpenDDS::XTypes::TypeInformation::minimal, OPENDDS_ASSERT, OpenDDS::DCPS::GuidPair::remote, OpenDDS::RTPS::Sedp::MatchingData::rpc_seqnum_complete, OpenDDS::RTPS::Sedp::MatchingData::rpc_seqnum_minimal, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), OpenDDS::RTPS::Sedp::MatchingData::time_added_to_map, and type_lookup_service_sequence_number_.
Referenced by match(), and request_remote_complete_type_objects().
void OpenDDS::RTPS::Sedp::resend_user_crypto_tokens | ( | const DCPS::GUID_t & | remote_participant | ) |
Definition at line 5542 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), create_and_send_datareader_crypto_tokens(), create_and_send_datawriter_crypto_tokens(), OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::equal_guid_prefixes(), get_handle_registry(), OpenDDS::Security::HandleRegistry::get_local_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_local_datawriter_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datareader_crypto_handle(), OpenDDS::Security::HandleRegistry::get_remote_datawriter_crypto_handle(), DDS::HANDLE_NIL, OpenDDS::DCPS::GuidConverter::isUserDomainEntity(), LM_DEBUG, local_publications_, local_subscriptions_, OpenDDS::DCPS::make_id(), and OpenDDS::DCPS::security_debug.
Referenced by association_complete_i().
void OpenDDS::RTPS::Sedp::rtps_relay_address | ( | const ACE_INET_Addr & | address | ) |
Definition at line 5958 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::DCPS::static_rchandle_cast(), and transport_inst_.
void OpenDDS::RTPS::Sedp::rtps_relay_only_now | ( | bool | f | ) |
Definition at line 5905 of file Sedp.cpp.
References OpenDDS::DCPS::TransportInst::rtps_relay_only_now(), and transport_inst_.
void OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens | ( | const DCPS::GUID_t & | remoteId | ) |
Definition at line 1512 of file Sedp.cpp.
References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::ENTITYID_PARTICIPANT, LM_ERROR, OpenDDS::RTPS::BuiltinAssociationRecord::local_id(), OpenDDS::RTPS::BuiltinAssociationRecord::local_tokens_sent(), OpenDDS::DCPS::make_id(), OpenDDS::RTPS::Spdp::participants_, OpenDDS::RTPS::BuiltinAssociationRecord::remote_id(), OpenDDS::DCPS::security_debug, OpenDDS::RTPS::BuiltinAssociationRecord::send_local_token(), and spdp_.
Referenced by association_complete_i().
void OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens | ( | const DCPS::GUID_t & | dst, |
const DCPS::GUID_t & | src | ||
) |
Create and send keys for individual endpoints.
Definition at line 1500 of file Sedp.cpp.
References create_and_send_datareader_crypto_tokens(), create_and_send_datawriter_crypto_tokens(), and get_handle_registry().
|
protected |
Definition at line 5341 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::ParticipantGenericMessage::destination_endpoint_guid, DDS::Security::ParticipantGenericMessage::destination_participant_guid, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, DDS::Security::GMCLASSID_SECURITY_DATAREADER_CRYPTO_TOKENS, LM_WARNING, OpenDDS::DCPS::make_id(), DDS::Security::ParticipantGenericMessage::message_class_id, DDS::Security::ParticipantGenericMessage::message_data, DDS::Security::ParticipantGenericMessage::message_identity, participant_id_, DDS::Security::ParticipantGenericMessage::related_message_identity, DDS::RETCODE_OK, DDS::Security::ParticipantGenericMessage::source_endpoint_guid, DDS::Security::MessageIdentity::source_guid, and write_volatile_message().
Referenced by create_and_send_datareader_crypto_tokens().
|
protected |
Definition at line 5385 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::ParticipantGenericMessage::destination_endpoint_guid, DDS::Security::ParticipantGenericMessage::destination_participant_guid, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, DDS::Security::GMCLASSID_SECURITY_DATAWRITER_CRYPTO_TOKENS, LM_WARNING, OpenDDS::DCPS::make_id(), DDS::Security::ParticipantGenericMessage::message_class_id, DDS::Security::ParticipantGenericMessage::message_data, DDS::Security::ParticipantGenericMessage::message_identity, participant_id_, DDS::Security::ParticipantGenericMessage::related_message_identity, DDS::RETCODE_OK, DDS::Security::ParticipantGenericMessage::source_endpoint_guid, DDS::Security::MessageIdentity::source_guid, and write_volatile_message().
Referenced by create_and_send_datawriter_crypto_tokens().
bool OpenDDS::RTPS::Sedp::send_type_lookup_request | ( | const XTypes::TypeIdentifierSeq & | type_ids, |
const DCPS::GUID_t & | reader, | ||
bool | is_discovery_protected, | ||
bool | send_get_types, | ||
const SequenceNumber & | seq_num | ||
) |
Definition at line 3064 of file Sedp.cpp.
References OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE, is_security_enabled(), OpenDDS::DCPS::make_id(), type_lookup_request_secure_writer_, type_lookup_request_writer_, OpenDDS::XTypes::TypeLookup_getDependencies_HashId, and OpenDDS::XTypes::TypeLookup_getTypes_HashId.
Referenced by get_remote_type_objects(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_dependencies_reply(), and OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::TypeLookupRequestWriter().
|
inlineprotected |
Definition at line 1191 of file Sedp.h.
References access_control_.
Referenced by init_security().
|
inlineprotected |
Definition at line 1211 of file Sedp.h.
References crypto_key_exchange_.
Referenced by init_security().
|
inlineprotected |
Definition at line 1201 of file Sedp.h.
References crypto_key_factory_.
Referenced by init_security().
|
inlineprotected |
Definition at line 1221 of file Sedp.h.
References handle_registry_.
Referenced by init_security().
|
staticprivate |
Definition at line 5159 of file Sedp.cpp.
References OPENDDS_STRING, and OpenDDS::DCPS::push_back().
Referenced by OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i().
|
inlineprotected |
Definition at line 1181 of file Sedp.h.
References permissions_handle_.
Referenced by init_security().
|
private |
Definition at line 2825 of file Sedp.cpp.
References get_access_control(), get_permissions_handle(), DDS::Security::TopicSecurityAttributes::is_discovery_protected, and is_security_enabled().
Referenced by data_received().
|
private |
Definition at line 2752 of file Sedp.cpp.
References ACE_GUARD_RETURN, DDS::Security::ParticipantGenericMessage::destination_endpoint_guid, DDS::Security::ParticipantGenericMessage::destination_participant_guid, OpenDDS::DCPS::GUID_UNKNOWN, ignoring(), lock_, participant_id_, participant_stateless_message_reader_, and DDS::Security::ParticipantGenericMessage::source_endpoint_guid.
Referenced by received_stateless_message().
|
private |
Definition at line 2779 of file Sedp.cpp.
References ACE_DEBUG, ACE_GUARD_RETURN, ACE_TEXT(), DDS::Security::ParticipantGenericMessage::destination_participant_guid, OpenDDS::DCPS::GUID_UNKNOWN, ignoring(), LM_DEBUG, lock_, DDS::Security::ParticipantGenericMessage::message_data, participant_id_, OpenDDS::DCPS::security_debug, and DDS::Security::ParticipantGenericMessage::source_endpoint_guid.
Referenced by received_volatile_message_secure().
void OpenDDS::RTPS::Sedp::shutdown | ( | void | ) |
Definition at line 2008 of file Sedp.cpp.
References dcps_participant_secure_reader_, dcps_participant_secure_writer_, participant_message_reader_, participant_message_secure_reader_, participant_message_secure_writer_, participant_message_writer_, participant_stateless_message_reader_, participant_stateless_message_writer_, participant_volatile_message_secure_reader_, participant_volatile_message_secure_writer_, publications_reader_, publications_secure_reader_, publications_secure_writer_, publications_writer_, subscriptions_reader_, subscriptions_secure_reader_, subscriptions_secure_writer_, subscriptions_writer_, type_lookup_reply_reader_, type_lookup_reply_secure_reader_, type_lookup_reply_secure_writer_, type_lookup_reply_writer_, type_lookup_request_reader_, type_lookup_request_secure_reader_, type_lookup_request_secure_writer_, and type_lookup_request_writer_.
|
privatevirtual |
Definition at line 5170 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::shutting_down(), and spdp_.
void OpenDDS::RTPS::Sedp::signal_liveliness | ( | DDS::LivelinessQosPolicyKind | kind | ) |
Definition at line 2997 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), DDS::Security::SecurityException::code, get_access_control(), get_permissions_handle(), DDS::Security::TopicSecurityAttributes::is_liveliness_protected, is_security_enabled(), LM_WARNING, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, signal_liveliness_secure(), and signal_liveliness_unsecure().
void OpenDDS::RTPS::Sedp::signal_liveliness_secure | ( | DDS::LivelinessQosPolicyKind | kind | ) |
Definition at line 3089 of file Sedp.cpp.
References DDS::AUTOMATIC_LIVELINESS_QOS, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::GUID_UNKNOWN, local_participant_automatic_liveliness_sn_secure_, local_participant_manual_liveliness_sn_secure_, OpenDDS::DCPS::make_id(), DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS, DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS, participant_id_, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE, spdp_, and write_participant_message_data_secure().
Referenced by signal_liveliness().
void OpenDDS::RTPS::Sedp::signal_liveliness_unsecure | ( | DDS::LivelinessQosPolicyKind | kind | ) |
Definition at line 3036 of file Sedp.cpp.
References DDS::AUTOMATIC_LIVELINESS_QOS, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, OpenDDS::DCPS::GUID_UNKNOWN, local_participant_automatic_liveliness_sn_, local_participant_manual_liveliness_sn_, OpenDDS::DCPS::make_id(), DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS, DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS, participant_id_, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE, spdp_, and write_participant_message_data().
Referenced by signal_liveliness().
|
protected |
Definition at line 5740 of file Sedp.cpp.
References discovered_subscriptions_, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, ice_agent_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalEntity::matched_endpoints_, and OpenDDS::RTPS::LocalPublication::publication_.
Referenced by add_publication_i(), add_subscription_i(), process_discovered_reader_data(), process_discovered_writer_data(), OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener(), and use_ice_now().
|
protected |
Definition at line 5767 of file Sedp.cpp.
References discovered_publications_, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, ice_agent_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::RTPS::LocalEntity::matched_endpoints_, and OpenDDS::RTPS::LocalSubscription::subscription_.
|
protected |
Definition at line 5794 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredPublication::have_ice_agent_info_, ice_agent_, OpenDDS::RTPS::DiscoveredPublication::ice_agent_info_, local_subscriptions_, and OpenDDS::RTPS::DiscoveredPublication::matched_endpoints_.
|
protected |
Definition at line 5821 of file Sedp.cpp.
References OpenDDS::RTPS::DiscoveredSubscription::have_ice_agent_info_, ice_agent_, OpenDDS::RTPS::DiscoveredSubscription::ice_agent_info_, OpenDDS::DCPS::GuidConverter::isWriter(), local_publications_, and OpenDDS::RTPS::DiscoveredSubscription::matched_endpoints_.
|
protected |
Definition at line 5851 of file Sedp.cpp.
References ice_agent_, OpenDDS::DCPS::GuidConverter::isReader(), local_subscriptions_, and OpenDDS::RTPS::DiscoveredPublication::matched_endpoints_.
Referenced by process_discovered_reader_data(), process_discovered_writer_data(), and OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener().
|
protected |
Definition at line 5878 of file Sedp.cpp.
References ice_agent_, OpenDDS::DCPS::GuidConverter::isWriter(), local_publications_, and OpenDDS::RTPS::DiscoveredSubscription::matched_endpoints_.
void OpenDDS::RTPS::Sedp::stun_server_address | ( | const ACE_INET_Addr & | address | ) |
Definition at line 5969 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::DCPS::static_rchandle_cast(), and transport_inst_.
|
inline |
Definition at line 263 of file Sedp.h.
References OPENDDS_MAP_CMP(), request_remote_complete_type_objects(), and transport_inst_.
|
inlineprivate |
Definition at line 299 of file Sedp.h.
References type_lookup_reply_deadline_processor_.
Referenced by ~Sedp().
|
inlineprivate |
Definition at line 290 of file Sedp.h.
References OpenDDS::DCPS::rchandle_from(), remove_expired_endpoints(), TheServiceParticipant, and type_lookup_reply_deadline_processor_.
Referenced by init().
DCPS::LocatorSeq OpenDDS::RTPS::Sedp::unicast_locators | ( | ) | const |
Definition at line 912 of file Sedp.cpp.
References OpenDDS::DCPS::CONNINFO_UNICAST, OpenDDS::DCPS::TransportInst::populate_locator(), transport_inst_, and OpenDDS::RTPS::transport_locator_to_locator_seq().
void OpenDDS::RTPS::Sedp::update_locators | ( | const ParticipantData_t & | pdata | ) |
Definition at line 1659 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::ParticipantProxy_t::availableBuiltinEndpoints, OpenDDS::RTPS::ParticipantProxy_t::availableExtendedBuiltinEndpoints, OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER, OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER, DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, DDS::Security::BUILTIN_PARTICIPANT_STATELESS_MESSAGE_READER, DDS::Security::BUILTIN_PARTICIPANT_STATELESS_MESSAGE_WRITER, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_READER, DDS::Security::BUILTIN_PARTICIPANT_VOLATILE_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_DETECTOR, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, OpenDDS::DCPS::ENTITYID_SPDP_BUILTIN_PARTICIPANT_READER, OpenDDS::DCPS::ENTITYID_SPDP_BUILTIN_PARTICIPANT_WRITER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_WRITER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, LM_INFO, OpenDDS::DCPS::make_id(), OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::RTPS::populate_locators(), DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, DDS::Security::SPDP_BUILTIN_PARTICIPANT_SECURE_READER, DDS::Security::SPDP_BUILTIN_PARTICIPANT_SECURE_WRITER, transport_inst_, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_READER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REPLY_WRITER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_READER_SECURE, DDS::Security::TYPE_LOOKUP_SERVICE_REQUEST_WRITER_SECURE, and OpenDDS::DCPS::TransportInst::update_locators().
void OpenDDS::RTPS::Sedp::update_publication_locators | ( | const GUID_t & | publicationId, |
const DCPS::TransportLocatorSeq & | transInfo | ||
) |
Definition at line 6245 of file Sedp.cpp.
References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_INFO, local_publications_, OpenDDS::DCPS::TransportClient::lock_, and write_publication_data().
Referenced by ignoring().
bool OpenDDS::RTPS::Sedp::update_publication_qos | ( | const DCPS::GUID_t & | publicationId, |
const DDS::DataWriterQos & | qos, | ||
const DDS::PublisherQos & | publisherQos | ||
) |
Definition at line 1901 of file Sedp.cpp.
References ACE_GUARD_RETURN, local_publications_, lock_, match_endpoints(), OpenDDS::RTPS::LocalPublication::publisher_qos_, OpenDDS::RTPS::LocalPublication::qos_, DDS::RETCODE_OK, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, and write_publication_data().
void OpenDDS::RTPS::Sedp::update_subscription_locators | ( | const GUID_t & | subscriptionId, |
const DCPS::TransportLocatorSeq & | transInfo | ||
) |
Definition at line 6391 of file Sedp.cpp.
References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_INFO, local_subscriptions_, OpenDDS::DCPS::TransportClient::lock_, and write_subscription_data().
Referenced by ignoring().
bool OpenDDS::RTPS::Sedp::update_subscription_params | ( | const DCPS::GUID_t & | subId, |
const DDS::StringSeq & | params | ||
) |
Definition at line 1977 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, OpenDDS::RTPS::LocalSubscription::filterProperties, local_publications_, local_subscriptions_, lock_, DDS::RETCODE_OK, and write_subscription_data().
bool OpenDDS::RTPS::Sedp::update_subscription_qos | ( | const DCPS::GUID_t & | subscriptionId, |
const DDS::DataReaderQos & | qos, | ||
const DDS::SubscriberQos & | subscriberQos | ||
) |
Definition at line 1951 of file Sedp.cpp.
References ACE_GUARD_RETURN, local_subscriptions_, lock_, match_endpoints(), OpenDDS::RTPS::LocalSubscription::qos_, DDS::RETCODE_OK, OpenDDS::RTPS::LocalSubscription::subscriber_qos_, OpenDDS::RTPS::LocalEntity::topic_id_, topic_names_, topics_, and write_subscription_data().
bool OpenDDS::RTPS::Sedp::update_topic_qos | ( | const DCPS::GUID_t & | topicId, |
const DDS::TopicQos & | qos | ||
) |
Definition at line 1840 of file Sedp.cpp.
References ACE_GUARD_RETURN, OpenDDS::DCPS::TopicDetails::local_publications(), local_publications_, OpenDDS::DCPS::TopicDetails::local_qos(), OpenDDS::DCPS::TopicDetails::local_subscriptions(), local_subscriptions_, lock_, name, OPENDDS_ASSERT, OPENDDS_MAP_CMP(), OPENDDS_STRING, DDS::TopicQos::topic_data, topic_names_, topics_, OpenDDS::DCPS::TopicDetails::update(), write_publication_data(), and write_subscription_data().
void OpenDDS::RTPS::Sedp::use_ice_now | ( | bool | f | ) |
Definition at line 5917 of file Sedp.cpp.
References ACE_GUARD, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, ice_agent_, OpenDDS::RTPS::LocalEntity::ice_agent_info, local_publications_, local_subscriptions_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), OpenDDS::DCPS::TransportClient::lock_, OpenDDS::RTPS::LocalPublication::publication_, publication_agent_info_listener_, start_ice(), OpenDDS::RTPS::LocalSubscription::subscription_, subscription_agent_info_listener_, transport_inst_, and OpenDDS::DCPS::TransportInst::use_ice_now().
void OpenDDS::RTPS::Sedp::use_rtps_relay_now | ( | bool | f | ) |
Definition at line 5911 of file Sedp.cpp.
References transport_inst_, and OpenDDS::DCPS::TransportInst::use_rtps_relay_now().
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::write_dcps_participant_dispose | ( | const DCPS::GUID_t & | part | ) |
Definition at line 4799 of file Sedp.cpp.
References dcps_participant_secure_writer_, and OpenDDS::RTPS::PID_PARTICIPANT_GUID.
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::write_dcps_participant_secure | ( | const Security::SPDPdiscoveredParticipantData & | msg, |
const DCPS::GUID_t & | part | ||
) |
Definition at line 4787 of file Sedp.cpp.
References dcps_participant_secure_writer_, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER, OpenDDS::DCPS::GUID_UNKNOWN, and participant_secure_sequence_.
Referenced by OpenDDS::RTPS::Sedp::DiscoveryWriter::DiscoveryWriter(), and write_durable_dcps_participant_secure().
void OpenDDS::RTPS::Sedp::write_durable_dcps_participant_secure | ( | const DCPS::GUID_t & | reader | ) |
Definition at line 4775 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::Spdp::build_local_pdata(), dcps_participant_secure_writer_, OpenDDS::Security::DPDK_SECURE, spdp_, DDS::Security::SPDP_BUILTIN_PARTICIPANT_SECURE_WRITER, and write_dcps_participant_secure().
Referenced by association_complete_i(), and replay_durable_data_for().
|
private |
Definition at line 4713 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, local_participant_automatic_liveliness_sn_, local_participant_manual_liveliness_sn_, OpenDDS::DCPS::make_id(), participant_id_, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE, participant_message_writer_, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), spdp_, and write_participant_message_data().
Referenced by association_complete_i(), and replay_durable_data_for().
|
private |
Definition at line 4736 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::available_builtin_endpoints(), DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, local_participant_automatic_liveliness_sn_secure_, local_participant_manual_liveliness_sn_secure_, OpenDDS::DCPS::make_id(), participant_id_, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE, OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE, participant_message_secure_writer_, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), spdp_, and write_participant_message_data_secure().
Referenced by association_complete_i(), and replay_durable_data_for().
|
private |
Definition at line 4641 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER, local_publications_, publications_secure_writer_, publications_writer_, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, spdp_, write_publication_data(), and write_publication_data_secure().
Referenced by association_complete_i(), and replay_durable_data_for().
|
private |
Definition at line 4677 of file Sedp.cpp.
References OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER, is_security_enabled(), local_subscriptions_, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, spdp_, subscriptions_secure_writer_, subscriptions_writer_, write_subscription_data(), and write_subscription_data_secure().
Referenced by association_complete_i(), and replay_durable_data_for().
|
private |
Definition at line 5110 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::GUID_UNKNOWN, LM_INFO, notify_liveliness(), participant_message_writer_, OpenDDS::RTPS::ParticipantMessageData::participantGuid, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, and spdp_.
Referenced by signal_liveliness_unsecure(), and write_durable_participant_message_data().
|
private |
Definition at line 5135 of file Sedp.cpp.
References ACE_DEBUG, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), DDS::Security::BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::GUID_UNKNOWN, LM_INFO, participant_message_secure_writer_, OpenDDS::RTPS::ParticipantMessageData::participantGuid, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, and spdp_.
Referenced by signal_liveliness_secure(), and write_durable_participant_message_data_secure().
|
private |
Definition at line 4830 of file Sedp.cpp.
References DDS::Security::EndpointSecurityAttributes::base, DDS::Security::TopicSecurityAttributes::is_discovery_protected, is_security_enabled(), DDS::RETCODE_OK, OpenDDS::RTPS::LocalEntity::security_attribs_, write_publication_data_secure(), and write_publication_data_unsecure().
Referenced by add_publication(), update_publication_locators(), update_publication_qos(), update_topic_qos(), and write_durable_publication_data().
|
private |
Definition at line 4904 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data, OpenDDS::DCPS::DCPS_debug_level, DDS::Security::EndpointSecurityInfo::endpoint_security_attributes, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER, OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, OpenDDS::RTPS::LocalEntity::ice_agent_info, LM_ERROR, LM_INFO, DDS::Security::EndpointSecurityAttributes::plugin_endpoint_attributes, DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes, populate_discovered_writer_msg(), publications_secure_writer_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::RTPS::LocalEntity::security_attribs_, OpenDDS::RTPS::security_attributes_to_bitmask(), OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::security_info, DDS::Security::SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::RTPS::LocalEntity::sequence_, spdp_, OpenDDS::RTPS::ParameterListConverter::to_param_list(), OpenDDS::RTPS::LocalEntity::type_info_, and use_xtypes_.
Referenced by write_durable_publication_data(), and write_publication_data().
|
private |
Definition at line 4854 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER, OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, OpenDDS::RTPS::LocalEntity::ice_agent_info, LM_ERROR, LM_INFO, populate_discovered_writer_msg(), publications_writer_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::RTPS::LocalEntity::sequence_, spdp_, OpenDDS::RTPS::ParameterListConverter::to_param_list(), OpenDDS::RTPS::LocalEntity::type_info_, and use_xtypes_.
Referenced by write_publication_data().
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::write_stateless_message | ( | const DDS::Security::ParticipantStatelessMessage & | msg, |
const DCPS::GUID_t & | reader | ||
) |
Definition at line 4758 of file Sedp.cpp.
References participant_stateless_message_writer_, and OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN().
Referenced by OpenDDS::RTPS::Sedp::SecurityWriter::SecurityWriter().
|
private |
Definition at line 4982 of file Sedp.cpp.
References DDS::Security::EndpointSecurityAttributes::base, DDS::Security::TopicSecurityAttributes::is_discovery_protected, is_security_enabled(), DDS::RETCODE_OK, OpenDDS::RTPS::LocalEntity::security_attribs_, write_subscription_data_secure(), and write_subscription_data_unsecure().
Referenced by add_subscription(), association_complete_i(), remove_assoc(), update_subscription_locators(), update_subscription_params(), update_subscription_qos(), update_topic_qos(), and write_durable_subscription_data().
|
private |
Definition at line 5056 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data, OpenDDS::DCPS::DCPS_debug_level, DDS::Security::EndpointSecurityInfo::endpoint_security_attributes, OpenDDS::DCPS::GUID_t::entityId, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER, OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, OpenDDS::RTPS::LocalEntity::ice_agent_info, LM_ERROR, LM_INFO, DDS::Security::EndpointSecurityAttributes::plugin_endpoint_attributes, DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes, populate_discovered_reader_msg(), DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::RTPS::LocalEntity::security_attribs_, OpenDDS::RTPS::security_attributes_to_bitmask(), OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::security_info, DDS::Security::SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::RTPS::LocalEntity::sequence_, spdp_, subscriptions_secure_writer_, OpenDDS::RTPS::ParameterListConverter::to_param_list(), OpenDDS::RTPS::LocalEntity::type_info_, and use_xtypes_.
Referenced by write_durable_subscription_data(), and write_subscription_data().
|
private |
Definition at line 5006 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::Spdp::associated(), associated_participants_, OpenDDS::RTPS::Spdp::available_builtin_endpoints(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER, OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::RTPS::LocalEntity::have_ice_agent_info, OpenDDS::RTPS::LocalEntity::ice_agent_info, LM_ERROR, LM_INFO, populate_discovered_reader_msg(), DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::RTPS::LocalEntity::sequence_, spdp_, subscriptions_writer_, OpenDDS::RTPS::ParameterListConverter::to_param_list(), OpenDDS::RTPS::LocalEntity::type_info_, and use_xtypes_.
Referenced by write_subscription_data().
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::write_volatile_message | ( | DDS::Security::ParticipantVolatileMessageSecure & | msg, |
const DCPS::GUID_t & | reader | ||
) |
Definition at line 4766 of file Sedp.cpp.
References DDS::Security::ParticipantGenericMessage::message_identity, participant_volatile_message_secure_writer_, DDS::Security::MessageIdentity::sequence_number, and OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN().
Referenced by send_datareader_crypto_tokens(), and send_datawriter_crypto_tokens().
|
protected |
Definition at line 1258 of file Sedp.h.
Referenced by get_access_control(), is_security_enabled(), and set_access_control().
|
private |
Definition at line 864 of file Sedp.h.
Referenced by associate(), disassociate(), write_participant_message_data(), write_participant_message_data_secure(), write_publication_data_secure(), write_publication_data_unsecure(), write_subscription_data_secure(), and write_subscription_data_unsecure().
|
protected |
Definition at line 1264 of file Sedp.h.
Referenced by add_publication(), add_subscription(), init_security(), local_has_remote_participant_token_i(), and remote_has_local_participant_token_i().
|
protected |
Definition at line 1260 of file Sedp.h.
Referenced by get_crypto_key_exchange(), and set_crypto_key_exchange().
|
protected |
Definition at line 1259 of file Sedp.h.
Referenced by get_crypto_key_factory(), and set_crypto_key_factory().
|
protected |
Definition at line 1311 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), and ~Sedp().
|
protected |
Definition at line 1288 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), write_dcps_participant_dispose(), write_dcps_participant_secure(), write_durable_dcps_participant_secure(), and ~Sedp().
|
protected |
Definition at line 1234 of file Sedp.h.
Referenced by disassociate(), ignore(), match(), match_continue(), process_discovered_writer_data(), remove_assoc(), request_remote_complete_type_objects(), and start_ice().
|
protected |
Definition at line 1235 of file Sedp.h.
Referenced by disassociate(), ignore(), match(), match_continue(), process_discovered_reader_data(), remove_assoc(), request_remote_complete_type_objects(), and start_ice().
|
private |
Definition at line 774 of file Sedp.h.
Referenced by cleanup_reader_association(), cleanup_writer_association(), init(), match_continue(), and process_association_records_i().
|
protected |
Definition at line 1261 of file Sedp.h.
Referenced by get_handle_registry(), and set_handle_registry().
|
protected |
Definition at line 1321 of file Sedp.h.
Referenced by add_assoc_i(), add_publication_i(), add_subscription_i(), remove_assoc_i(), remove_publication_i(), remove_subscription_i(), start_ice(), stop_ice(), use_ice_now(), and OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure().
|
protected |
Definition at line 1230 of file Sedp.h.
Referenced by ignore(), and ignoring().
|
private |
Definition at line 773 of file Sedp.h.
Referenced by init(), job_queue(), and ~Sedp().
|
protected |
Definition at line 1250 of file Sedp.h.
Referenced by signal_liveliness_unsecure(), and write_durable_participant_message_data().
|
protected |
Definition at line 1253 of file Sedp.h.
Referenced by signal_liveliness_secure(), and write_durable_participant_message_data_secure().
|
protected |
Definition at line 1251 of file Sedp.h.
Referenced by signal_liveliness_unsecure(), and write_durable_participant_message_data().
|
protected |
Definition at line 1254 of file Sedp.h.
Referenced by signal_liveliness_secure(), and write_durable_participant_message_data_secure().
|
protected |
Definition at line 1232 of file Sedp.h.
Referenced by add_publication(), match(), match_continue(), process_discovered_reader_data(), remote_knows_about_local_i(), remove_assoc(), remove_publication(), resend_user_crypto_tokens(), start_ice(), stop_ice(), update_publication_locators(), update_publication_qos(), update_subscription_params(), update_topic_qos(), use_ice_now(), and write_durable_publication_data().
|
protected |
Definition at line 1233 of file Sedp.h.
Referenced by add_subscription(), association_complete_i(), match(), match_continue(), notify_liveliness(), process_discovered_writer_data(), remote_knows_about_local_i(), remove_assoc(), remove_subscription(), resend_user_crypto_tokens(), start_ice(), stop_ice(), update_subscription_locators(), update_subscription_params(), update_subscription_qos(), update_topic_qos(), use_ice_now(), and write_durable_subscription_data().
|
protected |
Definition at line 1228 of file Sedp.h.
Referenced by data_acked_i(), data_received(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), received_participant_message_data_secure(), replay_durable_data_for(), should_drop_stateless_message(), should_drop_volatile_message(), update_publication_qos(), update_subscription_params(), update_subscription_qos(), and update_topic_qos().
|
protected |
Definition at line 1242 of file Sedp.h.
Referenced by OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), remove_expired_endpoints(), and request_type_objects().
|
protected |
Definition at line 1244 of file Sedp.h.
Referenced by get_remote_type_objects(), init(), and remove_expired_endpoints().
|
protected |
Definition at line 1241 of file Sedp.h.
Referenced by get_remote_type_objects(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_dependencies_reply(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), and remove_expired_endpoints().
|
protected |
Definition at line 1229 of file Sedp.h.
Referenced by add_publication(), add_subscription(), cleanup_reader_association(), cleanup_writer_association(), disassociate_volatile(), init_security(), make_topic_guid(), match_endpoints(), process_discovered_reader_data(), process_discovered_writer_data(), send_datareader_crypto_tokens(), send_datawriter_crypto_tokens(), should_drop_stateless_message(), should_drop_volatile_message(), signal_liveliness_secure(), signal_liveliness_unsecure(), write_durable_participant_message_data(), write_durable_participant_message_data_secure(), and ~Sedp().
|
protected |
Definition at line 1306 of file Sedp.h.
Referenced by associate(), init(), and shutdown().
|
protected |
Definition at line 1308 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), and ~Sedp().
|
protected |
Definition at line 1286 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), write_durable_participant_message_data_secure(), write_participant_message_data_secure(), and ~Sedp().
|
protected |
Definition at line 1284 of file Sedp.h.
Referenced by associate(), init(), shutdown(), write_durable_participant_message_data(), and write_participant_message_data().
|
protected |
Definition at line 1256 of file Sedp.h.
Referenced by init_security(), process_discovered_reader_data(), process_discovered_writer_data(), and remote_is_authenticated_i().
|
protected |
Definition at line 1273 of file Sedp.h.
Referenced by write_dcps_participant_secure().
|
protected |
Definition at line 1309 of file Sedp.h.
Referenced by associate(), init(), should_drop_stateless_message(), and shutdown().
|
protected |
Definition at line 1287 of file Sedp.h.
Referenced by associate(), init(), shutdown(), and write_stateless_message().
|
protected |
Definition at line 1310 of file Sedp.h.
Referenced by associate(), associate_volatile(), init(), init_security(), shutdown(), and ~Sedp().
|
protected |
Definition at line 1290 of file Sedp.h.
Referenced by associate(), associate_volatile(), init(), init_security(), remote_has_local_endpoint_token_i(), remote_has_local_participant_token_i(), shutdown(), write_volatile_message(), and ~Sedp().
|
protected |
Definition at line 1268 of file Sedp.h.
Referenced by handle_datareader_crypto_tokens(), and match_continue_security_enabled().
|
protected |
Definition at line 1271 of file Sedp.h.
Referenced by handle_datawriter_crypto_tokens(), and match_continue_security_enabled().
|
protected |
Definition at line 1263 of file Sedp.h.
Referenced by get_permissions_handle(), is_security_enabled(), and set_permissions_handle().
|
protected |
Definition at line 1322 of file Sedp.h.
Referenced by add_publication_i(), and use_ice_now().
|
protected |
Definition at line 1231 of file Sedp.h.
Referenced by assign_publication_key().
|
protected |
Definition at line 1298 of file Sedp.h.
Referenced by associate(), init(), and shutdown().
|
protected |
Definition at line 1300 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), and ~Sedp().
|
protected |
Definition at line 1278 of file Sedp.h.
Referenced by associate(), init(), init_security(), remote_knows_about_local_i(), remove_publication_i(), shutdown(), write_durable_publication_data(), write_publication_data_secure(), and ~Sedp().
|
protected |
Definition at line 1276 of file Sedp.h.
Referenced by associate(), init(), remote_knows_about_local_i(), remove_publication_i(), shutdown(), write_durable_publication_data(), and write_publication_data_unsecure().
|
private |
Definition at line 772 of file Sedp.h.
Referenced by init(), reactor_task(), and ~Sedp().
|
protected |
Definition at line 1227 of file Sedp.h.
Referenced by add_publication_i(), add_subscription_i(), associate(), associate_volatile(), association_complete_i(), cleanup_reader_association(), cleanup_writer_association(), create_datareader_crypto_tokens(), create_datawriter_crypto_tokens(), data_acked_i(), data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), disassociate(), generate_remote_matched_reader_crypto_handle(), generate_remote_matched_writer_crypto_handle(), get_domain_id(), handle_datareader_crypto_tokens(), handle_datawriter_crypto_tokens(), init(), init_security(), is_expectant_opendds(), local_has_remote_endpoint_token_i(), local_has_remote_participant_token_i(), match_continue(), populate_origination_locator(), populate_transport_locator_sequence(), process_discovered_reader_data(), process_discovered_writer_data(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), received_participant_message_data_secure(), received_stateless_message(), received_volatile_message_secure(), remote_has_local_endpoint_token_i(), remote_has_local_participant_token_i(), remote_is_authenticated_i(), remove_entities_belonging_to(), remove_from_bit_i(), remove_remote_crypto_handle(), send_builtin_crypto_tokens(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), shutting_down(), signal_liveliness_secure(), signal_liveliness_unsecure(), OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure(), write_durable_dcps_participant_secure(), write_durable_participant_message_data(), write_durable_participant_message_data_secure(), write_durable_publication_data(), write_durable_subscription_data(), write_participant_message_data(), write_participant_message_data_secure(), write_publication_data_secure(), write_publication_data_unsecure(), write_subscription_data_secure(), write_subscription_data_unsecure(), and ~Sedp().
|
protected |
Definition at line 1323 of file Sedp.h.
Referenced by add_subscription_i(), and use_ice_now().
|
protected |
Definition at line 1231 of file Sedp.h.
Referenced by assign_subscription_key().
|
protected |
Definition at line 1302 of file Sedp.h.
Referenced by associate(), init(), and shutdown().
|
protected |
Definition at line 1304 of file Sedp.h.
Referenced by associate(), init(), init_security(), shutdown(), and ~Sedp().
|
protected |
Definition at line 1282 of file Sedp.h.
Referenced by associate(), init(), init_security(), remote_knows_about_local_i(), remove_subscription_i(), shutdown(), write_durable_subscription_data(), write_subscription_data_secure(), and ~Sedp().
|
protected |
Definition at line 1280 of file Sedp.h.
Referenced by associate(), init(), remote_knows_about_local_i(), remove_subscription_i(), shutdown(), write_durable_subscription_data(), and write_subscription_data_unsecure().
|
protected |
Definition at line 1231 of file Sedp.h.
Referenced by assign_topic_key().
|
protected |
Definition at line 1237 of file Sedp.h.
Referenced by add_publication(), add_subscription(), assert_topic(), has_dcps_key(), ignore(), match_continue(), populate_discovered_reader_msg(), populate_discovered_writer_msg(), process_discovered_reader_data(), process_discovered_writer_data(), purge_dead_topic(), remove_publication(), remove_subscription(), remove_topic(), update_publication_qos(), update_subscription_qos(), and update_topic_qos().
|
protected |
Definition at line 1236 of file Sedp.h.
Referenced by add_publication(), add_subscription(), assert_topic(), find_topic(), has_dcps_key(), ignore(), match_continue(), populate_discovered_reader_msg(), populate_discovered_writer_msg(), process_discovered_reader_data(), process_discovered_writer_data(), purge_dead_topic(), remove_entities_belonging_to(), remove_publication(), remove_subscription(), remove_topic(), update_publication_qos(), update_subscription_qos(), and update_topic_qos().
|
private |
|
private |
Definition at line 770 of file Sedp.h.
Referenced by append_transport_statistics(), get_ice_endpoint(), init(), local_address(), multicast_group(), multicast_locators(), populate_origination_locator(), rtps_relay_address(), rtps_relay_only_now(), stun_server_address(), transport_inst(), unicast_locators(), update_locators(), use_ice_now(), use_rtps_relay_now(), and ~Sedp().
|
protected |
Definition at line 1243 of file Sedp.h.
Referenced by get_remote_type_objects(), type_lookup_fini(), and type_lookup_init().
|
protected |
Definition at line 1314 of file Sedp.h.
Referenced by associate(), cleanup_type_lookup_data(), init(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), and shutdown().
|
protected |
Definition at line 1317 of file Sedp.h.
Referenced by associate(), cleanup_type_lookup_data(), init(), init_security(), and shutdown().
|
protected |
Definition at line 1296 of file Sedp.h.
Referenced by associate(), association_complete_i(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), init(), init_security(), and shutdown().
|
protected |
Definition at line 1293 of file Sedp.h.
Referenced by associate(), association_complete_i(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), init(), and shutdown().
|
protected |
Definition at line 1313 of file Sedp.h.
Referenced by associate(), init(), and shutdown().
|
protected |
Definition at line 1316 of file Sedp.h.
Referenced by associate(), init(), init_security(), and shutdown().
|
protected |
Definition at line 1295 of file Sedp.h.
Referenced by associate(), association_complete_i(), init(), init_security(), send_type_lookup_request(), and shutdown().
|
protected |
Definition at line 1292 of file Sedp.h.
Referenced by associate(), association_complete_i(), init(), send_type_lookup_request(), and shutdown().
|
protected |
Definition at line 1240 of file Sedp.h.
Referenced by OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), init(), match_continue(), need_minimal_and_or_complete_types(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_dependencies_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_dependencies_request(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_types_reply(), and OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_types_request().
|
protected |
Definition at line 1245 of file Sedp.h.
Referenced by OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_dependencies_reply(), and request_type_objects().
|
protected |
Definition at line 1246 of file Sedp.h.
Referenced by OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), init(), match(), write_publication_data_secure(), write_publication_data_unsecure(), write_subscription_data_secure(), and write_subscription_data_unsecure().
|
protected |
Definition at line 1247 of file Sedp.h.
Referenced by init(), match_continue(), and need_minimal_and_or_complete_types().