Inheritance diagram for OpenDDS::RTPS::Sedp::SecurityReader:

[legend]

Collaboration diagram for OpenDDS::RTPS::Sedp::SecurityReader:

[legend]

Public Member Functions
	SecurityReader (const DCPS::GUID_t &sub_id, Sedp &sedp)

virtual	~SecurityReader ()

Public Member Functions inherited from OpenDDS::RTPS::Sedp::Reader
	Reader (const DCPS::GUID_t &sub_id, Sedp &sedp)

virtual	~Reader ()

bool	assoc (const DCPS::AssociationData &publication)

void	data_received (const DCPS::ReceivedDataSample &sample)

void	notify_subscription_disconnected (const DCPS::WriterIdSeq &)

void	notify_subscription_reconnected (const DCPS::WriterIdSeq &)

void	notify_subscription_lost (const DCPS::WriterIdSeq &)

void	remove_associations (const DCPS::WriterIdSeq &, bool)

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

virtual void	transport_discovery_change ()

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

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Public Member Functions inherited from OpenDDS::RTPS::Sedp::Endpoint
	Endpoint (const DCPS::GUID_t &repo_id, Sedp &sedp)

virtual	~Endpoint ()

bool	check_transport_qos (const DCPS::TransportInst &)

DCPS::GUID_t	get_guid () const

DDS::DomainId_t	domain_id () const

CORBA::Long	get_priority_value (const DCPS::AssociationData &) const

void	set_crypto_handles (DDS::Security::ParticipantCryptoHandle p, DDS::Security::NativeCryptoHandle e=DDS::HANDLE_NIL)

DDS::Security::ParticipantCryptoHandle	get_crypto_handle () const

DDS::Security::NativeCryptoHandle	get_endpoint_crypto_handle () const

void	shutting_down ()

OPENDDS_STRING	get_instance_name (const DCPS::GUID_t &id) const

EntityId_t	counterpart_entity_id () const

GUID_t	make_counterpart_guid (const DCPS::GUID_t &remote_part) const

bool	associated_with_counterpart (const DCPS::GUID_t &remote_part) const

bool	pending_association_with_counterpart (const DCPS::GUID_t &remote_part) const

bool	associated_with_counterpart_if_not_pending (const DCPS::GUID_t &remote_part) const

RcHandle< DCPS::BitSubscriber >	get_builtin_subscriber_proxy () const

Public Member Functions inherited from OpenDDS::DCPS::TransportClient
void	use_datalink (const GUID_t &remote_id, const DataLink_rch &link)

	TransportClient ()

virtual	~TransportClient ()

void	enable_transport (bool reliable, bool durable)

void	enable_transport_using_config (bool reliable, bool durable, const TransportConfig_rch &tc)

bool	swap_bytes () const

bool	cdr_encapsulation () const

const TransportLocatorSeq &	connection_info () const

void	populate_connection_info ()

bool	is_reliable () const

bool	associate (const AssociationData &peer, bool active)

void	disassociate (const GUID_t &peerId)

void	stop_associating ()

void	stop_associating (const GUID_t *repos, CORBA::ULong length)

void	send_final_acks ()

void	transport_stop ()

void	register_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid, const TransportLocatorSeq &locators, OpenDDS::DCPS::DiscoveryListener *listener)

void	unregister_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid)

void	register_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)

void	unregister_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid)

void	update_locators (const GUID_t &remote, const TransportLocatorSeq &locators)

WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()

bool	send_response (const GUID_t &peer, const DataSampleHeader &header, Message_Block_Ptr payload)

void	send (SendStateDataSampleList send_list, ACE_UINT64 transaction_id=0)

SendControlStatus	send_w_control (SendStateDataSampleList send_list, const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)

SendControlStatus	send_control (const DataSampleHeader &header, Message_Block_Ptr msg)

SendControlStatus	send_control_to (const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)

bool	remove_sample (const DataSampleElement *sample)

bool	remove_all_msgs ()

virtual void	add_link (const DataLink_rch &link, const GUID_t &peer)

void	terminate_send_if_suspended ()

bool	associated_with (const GUID_t &remote) const

bool	pending_association_with (const GUID_t &remote) const

GUID_t	repo_id () const

void	data_acked (const GUID_t &remote)

bool	is_leading (const GUID_t &reader_id) const

Private Member Functions
virtual void	data_received_i (const DCPS::ReceivedDataSample &sample, const DCPS::EntityId_t &entity_id, DCPS::Serializer &ser, DCPS::Extensibility extensibility)

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::TransportClient
enum	{ ASSOC_OK = 1, ASSOC_ACTIVE = 2 }

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

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

Protected Member Functions inherited from OpenDDS::DCPS::TransportClient
void	cdr_encapsulation (bool encap)

Protected Attributes inherited from OpenDDS::RTPS::Sedp::Endpoint
DCPS::GUID_t	repo_id_

Sedp &	sedp_

AtomicBool	shutting_down_

DDS::Security::ParticipantCryptoHandle	participant_crypto_handle_

DDS::Security::NativeCryptoHandle	endpoint_crypto_handle_

Detailed Description

Definition at line 675 of file Sedp.h.

Constructor & Destructor Documentation

◆ SecurityReader()

OpenDDS::RTPS::Sedp::SecurityReader::SecurityReader	(	const DCPS::GUID_t &	sub_id,
		Sedp &	sedp
	)

inline

Definition at line 677 of file Sedp.h.

References OpenDDS::XTypes::extensibility().

678 : Reader(sub_id, sedp)

679 {}

OpenDDS::RTPS::Sedp::Reader::Reader

Reader(const DCPS::GUID_t &sub_id, Sedp &sedp)

Definition: Sedp.h:612

◆ ~SecurityReader()

OpenDDS::RTPS::Sedp::SecurityReader::~SecurityReader ( )

virtual

Definition at line 4078 of file Sedp.cpp.

4079 {

4080 }

Member Function Documentation

◆ data_received_i()

void OpenDDS::RTPS::Sedp::SecurityReader::data_received_i	(	const DCPS::ReceivedDataSample &	sample,
		const DCPS::EntityId_t &	entity_id,
		DCPS::Serializer &	ser,
		DCPS::Extensibility	extensibility
	)

privatevirtual

Implements OpenDDS::RTPS::Sedp::Reader.

Definition at line 4224 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::DCPS::ReceivedDataSample::header_, LM_ERROR, OpenDDS::DCPS::DataSampleHeader::message_id_, OpenDDS::RTPS::Sedp::received_stateless_message(), OpenDDS::RTPS::Sedp::received_volatile_message_secure(), OpenDDS::DCPS::Serializer::reset_alignment(), and OpenDDS::RTPS::Sedp::Endpoint::sedp_.

 {
 #ifdef OPENDDS_SECURITY
   const DCPS::MessageId id = static_cast<DCPS::MessageId>(sample.header_.message_id_);
 
   if (entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER) {
     DDS::Security::ParticipantStatelessMessage data;
     ser.reset_alignment(); // https://issues.omg.org/browse/DDSIRTP23-63
     if (!(ser >> data)) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::SecurityReader::data_received_i - ")
                  ACE_TEXT("failed to deserialize data\n")));
       return;
     }
     sedp_.received_stateless_message(id, data);
   } else if (entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER) {
     DDS::Security::ParticipantVolatileMessageSecure data;
     if (!(ser >> data)) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::SecurityReader::data_received_i - ")
                  ACE_TEXT("failed to deserialize data\n")));
       return;
     }
     sedp_.received_volatile_message_secure(id, data);
   }
 #else
   ACE_UNUSED_ARG(sample);
   ACE_UNUSED_ARG(entity_id);
   ACE_UNUSED_ARG(ser);
 #endif
 }

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

Public Member Functions