OpenDDS::RTPS::Sedp::Endpoint Class Reference

Inheritance diagram for OpenDDS::RTPS::Sedp::Endpoint:

Collaboration diagram for OpenDDS::RTPS::Sedp::Endpoint:

Public Member Functions
	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
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

Protected Attributes
DCPS::GUID_t	repo_id_
Sedp &	sedp_
AtomicBool	shutting_down_
DDS::Security::ParticipantCryptoHandle	participant_crypto_handle_
DDS::Security::NativeCryptoHandle	endpoint_crypto_handle_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::TransportClient
enum	{ ASSOC_OK = 1, ASSOC_ACTIVE = 2 }
Protected Member Functions inherited from OpenDDS::DCPS::TransportClient
void	cdr_encapsulation (bool encap)
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 344 of file Sedp.h.

Constructor & Destructor Documentation

Endpoint()

OpenDDS::RTPS::Sedp::Endpoint::Endpoint ( const DCPS::GUID_t &  repo_id, Sedp &  sedp  )

inline

Definition at line 346 of file Sedp.h.

      : repo_id_(repo_id)
      , sedp_(sedp)
      , shutting_down_(false)
#ifdef OPENDDS_SECURITY
      , participant_crypto_handle_(DDS::HANDLE_NIL)
      , endpoint_crypto_handle_(DDS::HANDLE_NIL)
#endif
    {}

~Endpoint()

OpenDDS::RTPS::Sedp::Endpoint::~Endpoint ( )

virtual

Definition at line 3121 of file Sedp.cpp.

{
  remove_all_msgs();
  transport_stop();
}

Member Function Documentation

associated_with_counterpart()

bool OpenDDS::RTPS::Sedp::Endpoint::associated_with_counterpart

(

const DCPS::GUID_t &

remote_part

)

const

Definition at line 3162 of file Sedp.cpp.

Referenced by OpenDDS::RTPS::Sedp::Writer::send_sample().

{
  return associated_with(make_counterpart_guid(remote_part));
}

associated_with_counterpart_if_not_pending()

bool OpenDDS::RTPS::Sedp::Endpoint::associated_with_counterpart_if_not_pending

(

const DCPS::GUID_t &

remote_part

)

const

Definition at line 3167 of file Sedp.cpp.

{
  const GUID_t counterpart = make_counterpart_guid(remote_part);
  return associated_with(counterpart) || !pending_association_with(counterpart);
}

check_transport_qos()

bool OpenDDS::RTPS::Sedp::Endpoint::check_transport_qos ( const DCPS::TransportInst &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportClient.

Definition at line 359 of file Sedp.h.

    {
      return true;
    }

counterpart_entity_id()

EntityId_t OpenDDS::RTPS::Sedp::Endpoint::counterpart_entity_id

(

)

const

Definition at line 3127 of file Sedp.cpp.

References ACE_ERROR, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::EntityId_t::entityKind, OpenDDS::DCPS::ENTITYKIND_BUILTIN_READER_NO_KEY, OpenDDS::DCPS::ENTITYKIND_BUILTIN_READER_WITH_KEY, OpenDDS::DCPS::ENTITYKIND_BUILTIN_UNKNOWN, OpenDDS::DCPS::ENTITYKIND_BUILTIN_WRITER_NO_KEY, OpenDDS::DCPS::ENTITYKIND_BUILTIN_WRITER_WITH_KEY, and LM_ERROR.

{
  EntityId_t rv = repo_id_.entityId;
  switch (rv.entityKind) {
  case DCPS::ENTITYKIND_BUILTIN_WRITER_WITH_KEY:
    rv.entityKind = DCPS::ENTITYKIND_BUILTIN_READER_WITH_KEY;
    break;

  case DCPS::ENTITYKIND_BUILTIN_WRITER_NO_KEY:
    rv.entityKind = DCPS::ENTITYKIND_BUILTIN_READER_NO_KEY;
    break;

  case DCPS::ENTITYKIND_BUILTIN_READER_NO_KEY:
    rv.entityKind = DCPS::ENTITYKIND_BUILTIN_WRITER_NO_KEY;
    break;

  case DCPS::ENTITYKIND_BUILTIN_READER_WITH_KEY:
    rv.entityKind = DCPS::ENTITYKIND_BUILTIN_WRITER_WITH_KEY;
    break;

  default:
    if (DCPS::DCPS_debug_level) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: Sedp::Endpoint::counterpart_entity_id: "
        "Unexpected entityKind: %u\n", rv.entityKind));
    }
    rv.entityKind = DCPS::ENTITYKIND_BUILTIN_UNKNOWN;
  }
  return rv;
}

domain_id()

DDS::DomainId_t OpenDDS::RTPS::Sedp::Endpoint::domain_id ( ) const

inlinevirtual

Implements OpenDDS::DCPS::TransportClient.

Definition at line 369 of file Sedp.h.

    {
      return 0; // not used for SEDP
    }

get_builtin_subscriber_proxy()

RcHandle< DCPS::BitSubscriber > OpenDDS::RTPS::Sedp::Endpoint::get_builtin_subscriber_proxy ( ) const

virtual

Reimplemented from OpenDDS::DCPS::TransportClient.

Definition at line 3174 of file Sedp.cpp.

{
  return sedp_.spdp_.bit_subscriber_;
}

get_crypto_handle()

DDS::Security::ParticipantCryptoHandle OpenDDS::RTPS::Sedp::Endpoint::get_crypto_handle ( ) const

inlinevirtual

Reimplemented from OpenDDS::DCPS::TransportClient.

Definition at line 390 of file Sedp.h.

    {
      return participant_crypto_handle_;
    }

get_endpoint_crypto_handle()

DDS::Security::NativeCryptoHandle OpenDDS::RTPS::Sedp::Endpoint::get_endpoint_crypto_handle ( ) const

inline

Definition at line 395 of file Sedp.h.

    {
      return endpoint_crypto_handle_;
    }

get_guid()

DCPS::GUID_t OpenDDS::RTPS::Sedp::Endpoint::get_guid ( ) const

inlinevirtual

Implements OpenDDS::DCPS::TransportClient.

Definition at line 364 of file Sedp.h.

Referenced by OpenDDS::RTPS::Sedp::Writer::data_acked(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), and OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request().

    {
      return repo_id_;
    }

get_instance_name()

OPENDDS_STRING OpenDDS::RTPS::Sedp::Endpoint::get_instance_name ( const DCPS::GUID_t &  id ) const

inline

Definition at line 405 of file Sedp.h.

References OpenDDS::DCPS::GUID_t::entityId, OpenDDS::DCPS::ENTITYID_PARTICIPANT, OpenDDS::DCPS::EntityId_t::entityKey, OpenDDS::DCPS::EntityId_t::entityKind, OpenDDS::DCPS::GUID_t::guidPrefix, OpenDDS::DCPS::make_id(), OPENDDS_STRING, OpenDDS::DCPS::to_dds_string(), and OpenDDS::DCPS::to_hex_dds_string().

Referenced by OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request().

    {
      const DCPS::GUID_t participant = make_id(id, ENTITYID_PARTICIPANT);
      return OPENDDS_STRING("dds.builtin.TOS.") +
        DCPS::to_hex_dds_string(&participant.guidPrefix[0], sizeof(DCPS::GuidPrefix_t)) +
        DCPS::to_hex_dds_string(&participant.entityId.entityKey[0], sizeof(DCPS::EntityKey_t)) +
        DCPS::to_dds_string(unsigned(participant.entityId.entityKind), true);
    }

get_priority_value()

CORBA::Long OpenDDS::RTPS::Sedp::Endpoint::get_priority_value ( const DCPS::AssociationData &  ) const

inlinevirtual

Implements OpenDDS::DCPS::TransportClient.

Definition at line 374 of file Sedp.h.

References OpenDDS::DCPS::TransportClient::disassociate(), and OpenDDS::DCPS::TransportClient::enable_transport_using_config().

    {
      return 0;
    }

make_counterpart_guid()

GUID_t OpenDDS::RTPS::Sedp::Endpoint::make_counterpart_guid

(

const DCPS::GUID_t &

remote_part

)

const

Definition at line 3157 of file Sedp.cpp.

References OpenDDS::DCPS::make_id().

{
  return make_id(remote_part, counterpart_entity_id());
}

pending_association_with_counterpart()

bool OpenDDS::RTPS::Sedp::Endpoint::pending_association_with_counterpart

(

const DCPS::GUID_t &

remote_part

)

const

set_crypto_handles()

void OpenDDS::RTPS::Sedp::Endpoint::set_crypto_handles ( DDS::Security::ParticipantCryptoHandle  p, DDS::Security::NativeCryptoHandle  e = DDS::HANDLE_NIL  )

inline

Definition at line 383 of file Sedp.h.

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

    {
      participant_crypto_handle_ = p;
      endpoint_crypto_handle_ = e;
    }

shutting_down()

void OpenDDS::RTPS::Sedp::Endpoint::shutting_down ( void  )

inline

Definition at line 401 of file Sedp.h.

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

{ shutting_down_ = true; }

Member Data Documentation

endpoint_crypto_handle_

DDS::Security::NativeCryptoHandle OpenDDS::RTPS::Sedp::Endpoint::endpoint_crypto_handle_

protected

Definition at line 428 of file Sedp.h.

participant_crypto_handle_

DDS::Security::ParticipantCryptoHandle OpenDDS::RTPS::Sedp::Endpoint::participant_crypto_handle_

protected

Definition at line 427 of file Sedp.h.

repo_id_

DCPS::GUID_t OpenDDS::RTPS::Sedp::Endpoint::repo_id_

protected

Definition at line 423 of file Sedp.h.

Referenced by OpenDDS::RTPS::Sedp::Writer::send_sample(), OpenDDS::RTPS::Sedp::Writer::set_header_fields(), and OpenDDS::RTPS::Sedp::Writer::transport_assoc_done().

sedp_

Sedp& OpenDDS::RTPS::Sedp::Endpoint::sedp_

protected

Definition at line 424 of file Sedp.h.

Referenced by OpenDDS::RTPS::Sedp::Writer::data_acked(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::LivelinessReader::data_received_i(), OpenDDS::RTPS::Sedp::SecurityReader::data_received_i(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_dependencies_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_dependencies_request(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_get_types_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_get_types_request(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), OpenDDS::RTPS::Sedp::Writer::replay_durable_data_for(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), OpenDDS::RTPS::Sedp::Writer::transport_assoc_done(), and OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure().

shutting_down_

AtomicBool OpenDDS::RTPS::Sedp::Endpoint::shutting_down_

protected

Definition at line 425 of file Sedp.h.

Referenced by OpenDDS::RTPS::Sedp::Reader::data_received(), and OpenDDS::RTPS::Sedp::Writer::transport_assoc_done().

---

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

• Sedp.h
• Sedp.cpp