Inheritance diagram for OpenDDS::RTPS::Sedp::Reader:

[legend]

Collaboration diagram for OpenDDS::RTPS::Sedp::Reader:

[legend]

Public Member Functions
	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)=0

Private Attributes
DCPS::TransportMessageBlockAllocator	mb_alloc_

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 607 of file Sedp.h.

Constructor & Destructor Documentation

◆ Reader()

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

inline

Definition at line 612 of file Sedp.h.

References OpenDDS::RTPS::Sedp::data_received().

       : Endpoint(sub_id, sedp)
       , mb_alloc_(DCPS::DEFAULT_TRANSPORT_RECEIVE_BUFFERS)
     {}

◆ ~Reader()

OpenDDS::RTPS::Sedp::Reader::~Reader ( )

virtual

Definition at line 4066 of file Sedp.cpp.

4067 {

4068 }

Member Function Documentation

◆ assoc()

bool OpenDDS::RTPS::Sedp::Reader::assoc ( const DCPS::AssociationData & publication )

Definition at line 4083 of file Sedp.cpp.

References OpenDDS::DCPS::TransportClient::associate().

 {
   return associate(publication, false);
 }

◆ data_received()

void OpenDDS::RTPS::Sedp::Reader::data_received ( const DCPS::ReceivedDataSample & sample )

virtual

Implements OpenDDS::DCPS::TransportReceiveListener.

Definition at line 4109 of file Sedp.cpp.

 {
   if (shutting_down_) {
     return;
   }
 
   if (DCPS::DCPS_debug_level >= 9) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::Reader::data_received: from %C\n",
       DCPS::LogGuid(sample.header_.publication_id_).c_str()));
   }
 
   const DCPS::MessageId id =
     static_cast<DCPS::MessageId>(sample.header_.message_id_);
 
   switch (id) {
   case DCPS::SAMPLE_DATA:
   case DCPS::DISPOSE_INSTANCE:
   case DCPS::UNREGISTER_INSTANCE:
   case DCPS::DISPOSE_UNREGISTER_INSTANCE: {
     const DCPS::EntityId_t entity_id = sample.header_.publication_id_.entityId;
     const bool full_message = !sample.header_.key_fields_only_;
 
     // Figure Out Extensibility of Data Based On Entity Id
     const bool is_mutable =
       entity_id == ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER ||
 #ifdef OPENDDS_SECURITY
       entity_id == ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER ||
 #endif
       entity_id == ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER ||
 #ifdef OPENDDS_SECURITY
       entity_id == ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER ||
       entity_id == ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER ||
 #endif
       false;
     const bool is_final =
       (entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER && full_message) ||
 #ifdef OPENDDS_SECURITY
       (entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER && full_message) ||
       entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER ||
       entity_id == ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER ||
 #endif
       entity_id == ENTITYID_TL_SVC_REQ_WRITER ||
       entity_id == ENTITYID_TL_SVC_REPLY_WRITER ||
 #ifdef OPENDDS_SECURITY
       entity_id == ENTITYID_TL_SVC_REQ_WRITER_SECURE ||
       entity_id == ENTITYID_TL_SVC_REPLY_WRITER_SECURE ||
 #endif
       false;
     if (is_mutable == is_final) {
       if (is_mutable) {
         ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: Sedp::Reader::data_received: "
           "entity id extensibility error over %C: both is_final and is_mutable are %d\n",
           to_string(entity_id).c_str(), is_mutable));
       }
       break;
     }
     const DCPS::Extensibility extensibility =
       is_mutable ? DCPS::MUTABLE : DCPS::FINAL;
 
     // Get Encoding from Encapsulation
     Encoding encoding;
     DCPS::Message_Block_Ptr payload(sample.data(&mb_alloc_));
     Serializer ser(payload.get(), encoding);
     DCPS::EncapsulationHeader encap;
     if (!(ser >> encap)) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Sedp::Reader::data_received - ")
         ACE_TEXT("failed to deserialize encapsulation header\n")));
       return;
     }
     if (!encap.to_encoding(encoding, extensibility)) {
       return;
     }
     ser.encoding(encoding);
 
     data_received_i(sample, entity_id, ser, extensibility);
     break;
   }
 
   default:
     break;
   }
 }

◆ data_received_i()

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

privatepure virtual

Implemented in OpenDDS::RTPS::Sedp::TypeLookupReplyReader, OpenDDS::RTPS::Sedp::TypeLookupRequestReader, OpenDDS::RTPS::Sedp::SecurityReader, OpenDDS::RTPS::Sedp::LivelinessReader, and OpenDDS::RTPS::Sedp::DiscoveryReader.

◆ notify_subscription_disconnected()

void OpenDDS::RTPS::Sedp::Reader::notify_subscription_disconnected ( const DCPS::WriterIdSeq & )

inlinevirtual

Implements OpenDDS::DCPS::TransportReceiveListener.

Definition at line 625 of file Sedp.h.

625 {}

◆ notify_subscription_lost()

void OpenDDS::RTPS::Sedp::Reader::notify_subscription_lost ( const DCPS::WriterIdSeq & )

inlinevirtual

Implements OpenDDS::DCPS::TransportReceiveListener.

Definition at line 627 of file Sedp.h.

627 {}

◆ notify_subscription_reconnected()

void OpenDDS::RTPS::Sedp::Reader::notify_subscription_reconnected ( const DCPS::WriterIdSeq & )

inlinevirtual

Implements OpenDDS::DCPS::TransportReceiveListener.

Definition at line 626 of file Sedp.h.

626 {}

◆ remove_associations()

void OpenDDS::RTPS::Sedp::Reader::remove_associations	(	const DCPS::WriterIdSeq &	,
		bool
	)

inlinevirtual

Implements OpenDDS::DCPS::TransportReceiveListener.

Definition at line 628 of file Sedp.h.

References OpenDDS::XTypes::extensibility().

628 {}

Member Data Documentation

◆ mb_alloc_

DCPS::TransportMessageBlockAllocator OpenDDS::RTPS::Sedp::Reader::mb_alloc_

private

Definition at line 636 of file Sedp.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Reader()

◆ ~Reader()

Member Function Documentation

◆ assoc()

◆ data_received()

◆ data_received_i()

◆ notify_subscription_disconnected()

◆ notify_subscription_lost()

◆ notify_subscription_reconnected()

◆ remove_associations()

Member Data Documentation

◆ mb_alloc_