Inheritance diagram for OpenDDS::RTPS::Sedp::TypeLookupRequestReader:

[legend]

Collaboration diagram for OpenDDS::RTPS::Sedp::TypeLookupRequestReader:

[legend]

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

virtual	~TypeLookupRequestReader ()

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)

bool	process_type_lookup_request (DCPS::Serializer &ser, XTypes::TypeLookup_Reply &type_lookup_reply)

bool	process_get_types_request (const XTypes::TypeLookup_Request &type_lookup_request, XTypes::TypeLookup_Reply &type_lookup_reply)

bool	process_get_dependencies_request (const XTypes::TypeLookup_Request &request, XTypes::TypeLookup_Reply &reply)

void	gen_continuation_point (XTypes::OctetSeq32 &cont_point) const

Private Attributes
OPENDDS_STRING	instance_name_

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

Constructor & Destructor Documentation

◆ TypeLookupRequestReader()

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

inline

Definition at line 694 of file Sedp.h.

References OpenDDS::XTypes::extensibility().

       : Reader(sub_id, sedp)
     {
       instance_name_ = get_instance_name(sub_id);
     }

◆ ~TypeLookupRequestReader()

OpenDDS::RTPS::Sedp::TypeLookupRequestReader::~TypeLookupRequestReader ( )

virtual

Definition at line 3619 of file Sedp.cpp.

3620 {

3621 }

Member Function Documentation

◆ data_received_i()

void OpenDDS::RTPS::Sedp::TypeLookupRequestReader::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 4470 of file Sedp.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_READER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE, OpenDDS::DCPS::ReceivedDataSample::header_, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::make_id(), OpenDDS::DCPS::DataSampleHeader::publication_id_, OpenDDS::RTPS::Sedp::Endpoint::sedp_, OpenDDS::RTPS::Sedp::type_lookup_reply_secure_writer_, and OpenDDS::RTPS::Sedp::type_lookup_reply_writer_.

 {
   if (DCPS::DCPS_debug_level > 8) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::TypeLookupRequestReader::data_received_i: from %C\n",
       DCPS::LogGuid(sample.header_.publication_id_).c_str()));
   }
 
   XTypes::TypeLookup_Reply type_lookup_reply;
   if (!process_type_lookup_request(ser, type_lookup_reply)) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Sedp::TypeLookupRequestReader::data_received_i - ")
       ACE_TEXT("failed to take type lookup request\n")));
     return;
   }
 
 #ifdef OPENDDS_SECURITY
   if (entity_id == ENTITYID_TL_SVC_REQ_WRITER_SECURE) {
     const DCPS::GUID_t reader = make_id(sample.header_.publication_id_, ENTITYID_TL_SVC_REPLY_READER_SECURE);
     if (!sedp_.type_lookup_reply_secure_writer_->send_type_lookup_reply(type_lookup_reply, reader)) {
       if (DCPS::DCPS_debug_level) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Sedp::TypeLookupRequestReader::data_received_i - ")
           ACE_TEXT("failed to send secure type lookup reply\n")));
       }
       return;
     }
   } else if (entity_id == ENTITYID_TL_SVC_REQ_WRITER) {
 #endif
     const DCPS::GUID_t reader = make_id(sample.header_.publication_id_, ENTITYID_TL_SVC_REPLY_READER);
     if (!sedp_.type_lookup_reply_writer_->send_type_lookup_reply(type_lookup_reply, reader)) {
       if (DCPS::DCPS_debug_level) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Sedp::TypeLookupRequestReader::data_received_i - ")
           ACE_TEXT("failed to send type lookup reply\n")));
       }
       return;
     }
 #ifdef OPENDDS_SECURITY
   }
 #else
   ACE_UNUSED_ARG(entity_id);
 #endif
 }

◆ gen_continuation_point()

void OpenDDS::RTPS::Sedp::TypeLookupRequestReader::gen_continuation_point ( XTypes::OctetSeq32 & cont_point ) const

private

Definition at line 3796 of file Sedp.cpp.

 {
   // We are sending all dependencies of requested types in 1 reply, and thus
   // the continuation_point will be "absent" by setting its length to zero.
   cont_point.length(0);
 }

◆ process_get_dependencies_request()

bool OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_dependencies_request	(	const XTypes::TypeLookup_Request &	request,
		XTypes::TypeLookup_Reply &	reply
	)

private

Definition at line 3803 of file Sedp.cpp.

References OpenDDS::XTypes::TypeLookup_Request::data, OpenDDS::XTypes::TypeLookup_Call::getTypeDependencies, OpenDDS::XTypes::TypeLookup_Request::header, OpenDDS::XTypes::TypeLookup_Reply::header, DDS::RPC::ReplyHeader::relatedRequestId, DDS::RPC::RequestHeader::requestId, OpenDDS::XTypes::TypeLookup_getTypeDependencies_Result::result, OpenDDS::RTPS::Sedp::Endpoint::sedp_, and OpenDDS::RTPS::Sedp::type_lookup_service_.

 {
   // Send all dependencies (may be empty) of the requested types
   XTypes::TypeLookup_getTypeDependencies_Out result;
   sedp_.type_lookup_service_->get_type_dependencies(request.data.getTypeDependencies().type_ids,
     result.dependent_typeids);
   gen_continuation_point(result.continuation_point);
 
   XTypes::TypeLookup_getTypeDependencies_Result typeDependencies;
   typeDependencies.result(result);
   reply._cxx_return.getTypeDependencies(typeDependencies);
 
   reply.header.relatedRequestId = request.header.requestId;
   return true;
 }

◆ process_get_types_request()

bool OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_types_request	(	const XTypes::TypeLookup_Request &	type_lookup_request,
		XTypes::TypeLookup_Reply &	type_lookup_reply
	)

private

Definition at line 3771 of file Sedp.cpp.

References ACE_ERROR, OpenDDS::XTypes::TypeLookup_Request::data, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::TypeLookup_Call::getTypes, OpenDDS::XTypes::TypeLookup_Request::header, OpenDDS::XTypes::TypeLookup_Reply::header, LM_ERROR, DDS::RPC::ReplyHeader::relatedRequestId, DDS::RPC::RequestHeader::requestId, OpenDDS::XTypes::TypeLookup_getTypes_Result::result, OpenDDS::RTPS::Sedp::Endpoint::sedp_, and OpenDDS::RTPS::Sedp::type_lookup_service_.

 {
   XTypes::TypeLookup_getTypes_Out result;
   sedp_.type_lookup_service_->get_type_objects(type_lookup_request.data.getTypes().type_ids,
     result.types);
   if (result.types.length() > 0) {
     result.complete_to_minimal.length(0);
 
     XTypes::TypeLookup_getTypes_Result typeResult;
     typeResult.result(result);
 
     type_lookup_reply._cxx_return.getType(typeResult);
 
     type_lookup_reply.header.relatedRequestId = type_lookup_request.header.requestId;
     return true;
   }
   if (DCPS::DCPS_debug_level) {
     ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: Sedp::TypeLookupRequestReader::process_get_types_request: "
       "No types received\n"));
   }
   return false;
 }

◆ process_type_lookup_request()

bool OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_type_lookup_request	(	DCPS::Serializer &	ser,
		XTypes::TypeLookup_Reply &	type_lookup_reply
	)

private

Definition at line 3737 of file Sedp.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::XTypes::TypeLookup_Request::data, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::SequenceNumber::getValue(), OpenDDS::XTypes::TypeLookup_Request::header, LM_DEBUG, LM_ERROR, OPENDDS_STRING, DDS::RPC::RequestHeader::requestId, DDS::SampleIdentity::sequence_number, OpenDDS::RTPS::to_opendds_seqnum(), OpenDDS::XTypes::TypeLookup_getDependencies_HashId, OpenDDS::XTypes::TypeLookup_getTypes_HashId, and DDS::SampleIdentity::writer_guid.

 {
   XTypes::TypeLookup_Request type_lookup_request;
   if (!(ser >> type_lookup_request)) {
     if (DCPS::DCPS_debug_level) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Sedp::TypeLookupRequestReader::process_type_lookup_request - ")
                  ACE_TEXT("failed to deserialize type lookup request\n")));
     }
     return false;
   }
 
   if (DCPS::DCPS_debug_level >= 8) {
     const DDS::SampleIdentity& request_id = type_lookup_request.header.requestId;
     ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::TypeLookupReplyWriter::process_type_lookup_request: "
       "from %C seq: %q\n",
       DCPS::LogGuid(request_id.writer_guid).c_str(),
       to_opendds_seqnum(request_id.sequence_number).getValue()));
   }
 
   if (OPENDDS_STRING(type_lookup_request.header.instanceName) != instance_name_) {
     return true;
   }
 
   switch (type_lookup_request.data._d()) {
   case XTypes::TypeLookup_getTypes_HashId:
     return process_get_types_request(type_lookup_request, type_lookup_reply);
   case XTypes::TypeLookup_getDependencies_HashId:
     return process_get_dependencies_request(type_lookup_request, type_lookup_reply);
   default:
     return false;
   }
 }

Member Data Documentation

◆ instance_name_

OPENDDS_STRING OpenDDS::RTPS::Sedp::TypeLookupRequestReader::instance_name_

private

Definition at line 720 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

◆ TypeLookupRequestReader()

◆ ~TypeLookupRequestReader()

Member Function Documentation

◆ data_received_i()

◆ gen_continuation_point()

◆ process_get_dependencies_request()

◆ process_get_types_request()

◆ process_type_lookup_request()

Member Data Documentation

◆ instance_name_