OpenDDS  Snapshot(2023/04/28-20:55)
Classes | Public Member Functions | Public Attributes | List of all members
OpenDDS::RTPS::DiscoveredParticipant Struct Reference

#include <DiscoveredEntities.h>

Collaboration diagram for OpenDDS::RTPS::DiscoveredParticipant:
Collaboration graph
[legend]

Classes

struct  LocationUpdate
 

Public Member Functions

 DiscoveredParticipant ()
 
 DiscoveredParticipant (const ParticipantData_t &p, const DCPS::SequenceNumber &seq, const DCPS::TimeDuration &resend_period)
 
typedef OPENDDS_VECTOR (LocationUpdate) LocationUpdateList
 
typedef OPENDDS_LIST (BuiltinAssociationRecord) BuiltinAssociationRecords
 
typedef OPENDDS_LIST (WriterAssociationRecord_rch) WriterAssociationRecords
 
typedef OPENDDS_LIST (ReaderAssociationRecord_rch) ReaderAssociationRecords
 
bool has_security_data () const
 

Public Attributes

ParticipantData_t pdata_
 
LocationUpdateList location_updates_
 
DCPS::ParticipantLocationBuiltinTopicData location_data_
 
DDS::InstanceHandle_t location_ih_
 
ACE_INET_Addr last_recv_address_
 
DCPS::MonotonicTimePoint discovered_at_
 
DCPS::MonotonicTimePoint lease_expiration_
 
DDS::InstanceHandle_t bit_ih_
 
DCPS::SequenceNumber max_seq_
 
ACE_UINT16 seq_reset_count_
 
BuiltinAssociationRecords builtin_pending_records_
 
BuiltinAssociationRecords builtin_associated_records_
 
WriterAssociationRecords writer_pending_records_
 
WriterAssociationRecords writer_associated_records_
 
ReaderAssociationRecords reader_pending_records_
 
ReaderAssociationRecords reader_associated_records_
 
bool have_spdp_info_
 
ICE::AgentInfo spdp_info_
 
bool have_sedp_info_
 
ICE::AgentInfo sedp_info_
 
bool have_auth_req_msg_
 
DDS::Security::ParticipantStatelessMessage auth_req_msg_
 
bool have_handshake_msg_
 
DDS::Security::ParticipantStatelessMessage handshake_msg_
 
DCPS::FibonacciSequence< DCPS::TimeDurationhandshake_resend_falloff_
 
DCPS::MonotonicTimePoint stateless_msg_deadline_
 
DCPS::MonotonicTimePoint handshake_deadline_
 
AuthState auth_state_
 
HandshakeState handshake_state_
 
bool is_requester_
 
CORBA::LongLong auth_req_sequence_number_
 
CORBA::LongLong handshake_sequence_number_
 
DDS::Security::IdentityToken identity_token_
 
DDS::Security::PermissionsToken permissions_token_
 
DDS::Security::PropertyQosPolicy property_qos_
 
DDS::Security::ParticipantSecurityInfo security_info_
 
DDS::Security::IdentityStatusToken identity_status_token_
 
DDS::Security::IdentityHandle identity_handle_
 
DDS::Security::HandshakeHandle handshake_handle_
 
DDS::Security::AuthRequestMessageToken local_auth_request_token_
 
DDS::Security::AuthRequestMessageToken remote_auth_request_token_
 
DDS::Security::AuthenticatedPeerCredentialToken authenticated_peer_credential_token_
 
DDS::Security::SharedSecretHandle_var shared_secret_handle_
 
DDS::Security::PermissionsHandle permissions_handle_
 
DDS::Security::ParticipantCryptoTokenSeq crypto_tokens_
 
DDS::Security::ExtendedBuiltinEndpointSet_t extended_builtin_endpoints_
 
bool participant_tokens_sent_
 

Detailed Description

Definition at line 49 of file DiscoveredEntities.h.

Constructor & Destructor Documentation

◆ DiscoveredParticipant() [1/2]

OpenDDS::RTPS::DiscoveredParticipant::DiscoveredParticipant ( )
inline

Definition at line 50 of file DiscoveredEntities.h.

References OpenDDS::Security::SPDPdiscoveredParticipantData::dataKind, OpenDDS::Security::DPDK_NONE, DDS::Security::ParticipantSecurityInfo::participant_security_attributes, pdata_, DDS::Security::ParticipantSecurityInfo::plugin_participant_security_attributes, and security_info_.

53  , seq_reset_count_(0)
54 #ifdef OPENDDS_SECURITY
55  , have_spdp_info_(false)
56  , have_sedp_info_(false)
57  , have_auth_req_msg_(false)
58  , have_handshake_msg_(false)
62  , is_requester_(false)
70 #endif
71  {
72 #ifdef OPENDDS_SECURITY
76 #endif
77  }
const InstanceHandle_t HANDLE_NIL
PluginParticipantSecurityAttributesMask plugin_participant_security_attributes
ParticipantSecurityAttributesMask participant_security_attributes
DDS::Security::ParticipantSecurityInfo security_info_
static const TimeDuration zero_value
Definition: TimeDuration.h:31
DDS::Security::HandshakeHandle handshake_handle_
DCPS::FibonacciSequence< DCPS::TimeDuration > handshake_resend_falloff_
DDS::Security::IdentityHandle identity_handle_
DDS::Security::ExtendedBuiltinEndpointSet_t extended_builtin_endpoints_
DDS::Security::PermissionsHandle permissions_handle_
Requester should call begin_handshake_request.

◆ DiscoveredParticipant() [2/2]

OpenDDS::RTPS::DiscoveredParticipant::DiscoveredParticipant ( const ParticipantData_t p,
const DCPS::SequenceNumber seq,
const DCPS::TimeDuration resend_period 
)
inline

Definition at line 79 of file DiscoveredEntities.h.

References OpenDDS::DCPS::assign(), OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::change_mask, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::guid, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::ice6_timestamp, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::ice_timestamp, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::local6_timestamp, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::local_timestamp, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::location, location_data_, OpenDDS::DCPS::make_part_guid(), DDS::Time_t::nanosec, DDS::Security::ParticipantSecurityInfo::participant_security_attributes, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, DDS::Security::ParticipantSecurityInfo::plugin_participant_security_attributes, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::relay6_timestamp, OpenDDS::DCPS::ParticipantLocationBuiltinTopicData::relay_timestamp, DDS::Time_t::sec, and security_info_.

82  : pdata_(p)
85  , max_seq_(seq)
86  , seq_reset_count_(0)
87 #ifdef OPENDDS_SECURITY
88  , have_spdp_info_(false)
89  , have_sedp_info_(false)
90  , have_auth_req_msg_(false)
91  , have_handshake_msg_(false)
92  , handshake_resend_falloff_(resend_period)
95  , is_requester_(false)
102  , participant_tokens_sent_(false)
103 #endif
104  {
105  const DCPS::GUID_t guid = DCPS::make_part_guid(p.participantProxy.guidPrefix);
106  assign(location_data_.guid, guid);
121 
122 #ifdef OPENDDS_SECURITY
125 #else
126  ACE_UNUSED_ARG(resend_period);
127 #endif
128  }
const InstanceHandle_t HANDLE_NIL
PluginParticipantSecurityAttributesMask plugin_participant_security_attributes
ParticipantSecurityAttributesMask participant_security_attributes
DDS::Security::ParticipantSecurityInfo security_info_
OpenDDS_Dcps_Export GUID_t make_part_guid(const GuidPrefix_t &prefix)
Definition: GuidUtils.h:216
unsigned long nanosec
DDS::Security::HandshakeHandle handshake_handle_
BUILT_IN_TOPIC_KEY DDS::OctetArray16 guid
DCPS::ParticipantLocationBuiltinTopicData location_data_
DCPS::FibonacciSequence< DCPS::TimeDuration > handshake_resend_falloff_
void assign(EntityId_t &dest, const EntityId_t &src)
Definition: GuidUtils.h:157
DDS::Security::IdentityHandle identity_handle_
DDS::Security::ExtendedBuiltinEndpointSet_t extended_builtin_endpoints_
DDS::Security::PermissionsHandle permissions_handle_
Requester should call begin_handshake_request.

Member Function Documentation

◆ has_security_data()

bool OpenDDS::RTPS::DiscoveredParticipant::has_security_data ( ) const
inline

◆ OPENDDS_LIST() [1/3]

typedef OpenDDS::RTPS::DiscoveredParticipant::OPENDDS_LIST ( BuiltinAssociationRecord  )

◆ OPENDDS_LIST() [2/3]

typedef OpenDDS::RTPS::DiscoveredParticipant::OPENDDS_LIST ( WriterAssociationRecord_rch  )

◆ OPENDDS_LIST() [3/3]

typedef OpenDDS::RTPS::DiscoveredParticipant::OPENDDS_LIST ( ReaderAssociationRecord_rch  )

◆ OPENDDS_VECTOR()

typedef OpenDDS::RTPS::DiscoveredParticipant::OPENDDS_VECTOR ( LocationUpdate  )

Member Data Documentation

◆ auth_req_msg_

DDS::Security::ParticipantStatelessMessage OpenDDS::RTPS::DiscoveredParticipant::auth_req_msg_

Definition at line 168 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::attempt_authentication().

◆ auth_req_sequence_number_

CORBA::LongLong OpenDDS::RTPS::DiscoveredParticipant::auth_req_sequence_number_

Definition at line 178 of file DiscoveredEntities.h.

◆ auth_state_

AuthState OpenDDS::RTPS::DiscoveredParticipant::auth_state_

◆ authenticated_peer_credential_token_

DDS::Security::AuthenticatedPeerCredentialToken OpenDDS::RTPS::DiscoveredParticipant::authenticated_peer_credential_token_

Definition at line 190 of file DiscoveredEntities.h.

◆ bit_ih_

DDS::InstanceHandle_t OpenDDS::RTPS::DiscoveredParticipant::bit_ih_

Definition at line 150 of file DiscoveredEntities.h.

◆ builtin_associated_records_

BuiltinAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::builtin_associated_records_

◆ builtin_pending_records_

BuiltinAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::builtin_pending_records_

◆ crypto_tokens_

DDS::Security::ParticipantCryptoTokenSeq OpenDDS::RTPS::DiscoveredParticipant::crypto_tokens_

Definition at line 193 of file DiscoveredEntities.h.

◆ discovered_at_

DCPS::MonotonicTimePoint OpenDDS::RTPS::DiscoveredParticipant::discovered_at_

Definition at line 148 of file DiscoveredEntities.h.

◆ extended_builtin_endpoints_

DDS::Security::ExtendedBuiltinEndpointSet_t OpenDDS::RTPS::DiscoveredParticipant::extended_builtin_endpoints_

Definition at line 194 of file DiscoveredEntities.h.

◆ handshake_deadline_

DCPS::MonotonicTimePoint OpenDDS::RTPS::DiscoveredParticipant::handshake_deadline_

Definition at line 174 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::attempt_authentication().

◆ handshake_handle_

DDS::Security::HandshakeHandle OpenDDS::RTPS::DiscoveredParticipant::handshake_handle_

◆ handshake_msg_

DDS::Security::ParticipantStatelessMessage OpenDDS::RTPS::DiscoveredParticipant::handshake_msg_

◆ handshake_resend_falloff_

DCPS::FibonacciSequence<DCPS::TimeDuration> OpenDDS::RTPS::DiscoveredParticipant::handshake_resend_falloff_

◆ handshake_sequence_number_

CORBA::LongLong OpenDDS::RTPS::DiscoveredParticipant::handshake_sequence_number_

Definition at line 179 of file DiscoveredEntities.h.

◆ handshake_state_

HandshakeState OpenDDS::RTPS::DiscoveredParticipant::handshake_state_

◆ have_auth_req_msg_

bool OpenDDS::RTPS::DiscoveredParticipant::have_auth_req_msg_

◆ have_handshake_msg_

bool OpenDDS::RTPS::DiscoveredParticipant::have_handshake_msg_

Definition at line 169 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::send_handshake_message().

◆ have_sedp_info_

bool OpenDDS::RTPS::DiscoveredParticipant::have_sedp_info_

Definition at line 165 of file DiscoveredEntities.h.

◆ have_spdp_info_

bool OpenDDS::RTPS::DiscoveredParticipant::have_spdp_info_

Definition at line 163 of file DiscoveredEntities.h.

◆ identity_handle_

DDS::Security::IdentityHandle OpenDDS::RTPS::DiscoveredParticipant::identity_handle_

◆ identity_status_token_

DDS::Security::IdentityStatusToken OpenDDS::RTPS::DiscoveredParticipant::identity_status_token_

Definition at line 185 of file DiscoveredEntities.h.

◆ identity_token_

DDS::Security::IdentityToken OpenDDS::RTPS::DiscoveredParticipant::identity_token_

Definition at line 181 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::attempt_authentication().

◆ is_requester_

bool OpenDDS::RTPS::DiscoveredParticipant::is_requester_

◆ last_recv_address_

ACE_INET_Addr OpenDDS::RTPS::DiscoveredParticipant::last_recv_address_

Definition at line 147 of file DiscoveredEntities.h.

◆ lease_expiration_

DCPS::MonotonicTimePoint OpenDDS::RTPS::DiscoveredParticipant::lease_expiration_

Definition at line 149 of file DiscoveredEntities.h.

◆ local_auth_request_token_

DDS::Security::AuthRequestMessageToken OpenDDS::RTPS::DiscoveredParticipant::local_auth_request_token_

Definition at line 188 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::attempt_authentication().

◆ location_data_

DCPS::ParticipantLocationBuiltinTopicData OpenDDS::RTPS::DiscoveredParticipant::location_data_

Definition at line 144 of file DiscoveredEntities.h.

Referenced by DiscoveredParticipant().

◆ location_ih_

DDS::InstanceHandle_t OpenDDS::RTPS::DiscoveredParticipant::location_ih_

Definition at line 145 of file DiscoveredEntities.h.

◆ location_updates_

LocationUpdateList OpenDDS::RTPS::DiscoveredParticipant::location_updates_

Definition at line 143 of file DiscoveredEntities.h.

◆ max_seq_

DCPS::SequenceNumber OpenDDS::RTPS::DiscoveredParticipant::max_seq_

Definition at line 151 of file DiscoveredEntities.h.

◆ participant_tokens_sent_

bool OpenDDS::RTPS::DiscoveredParticipant::participant_tokens_sent_

◆ pdata_

ParticipantData_t OpenDDS::RTPS::DiscoveredParticipant::pdata_

◆ permissions_handle_

DDS::Security::PermissionsHandle OpenDDS::RTPS::DiscoveredParticipant::permissions_handle_

Definition at line 192 of file DiscoveredEntities.h.

◆ permissions_token_

DDS::Security::PermissionsToken OpenDDS::RTPS::DiscoveredParticipant::permissions_token_

Definition at line 182 of file DiscoveredEntities.h.

◆ property_qos_

DDS::Security::PropertyQosPolicy OpenDDS::RTPS::DiscoveredParticipant::property_qos_

Definition at line 183 of file DiscoveredEntities.h.

◆ reader_associated_records_

ReaderAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::reader_associated_records_

◆ reader_pending_records_

ReaderAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::reader_pending_records_

◆ remote_auth_request_token_

DDS::Security::AuthRequestMessageToken OpenDDS::RTPS::DiscoveredParticipant::remote_auth_request_token_

Definition at line 189 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::attempt_authentication().

◆ security_info_

DDS::Security::ParticipantSecurityInfo OpenDDS::RTPS::DiscoveredParticipant::security_info_

Definition at line 184 of file DiscoveredEntities.h.

Referenced by DiscoveredParticipant().

◆ sedp_info_

ICE::AgentInfo OpenDDS::RTPS::DiscoveredParticipant::sedp_info_

Definition at line 166 of file DiscoveredEntities.h.

◆ seq_reset_count_

ACE_UINT16 OpenDDS::RTPS::DiscoveredParticipant::seq_reset_count_

Definition at line 152 of file DiscoveredEntities.h.

◆ shared_secret_handle_

DDS::Security::SharedSecretHandle_var OpenDDS::RTPS::DiscoveredParticipant::shared_secret_handle_

Definition at line 191 of file DiscoveredEntities.h.

◆ spdp_info_

ICE::AgentInfo OpenDDS::RTPS::DiscoveredParticipant::spdp_info_

Definition at line 164 of file DiscoveredEntities.h.

◆ stateless_msg_deadline_

DCPS::MonotonicTimePoint OpenDDS::RTPS::DiscoveredParticipant::stateless_msg_deadline_

Definition at line 172 of file DiscoveredEntities.h.

Referenced by OpenDDS::RTPS::Spdp::send_handshake_message().

◆ writer_associated_records_

WriterAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::writer_associated_records_

◆ writer_pending_records_

WriterAssociationRecords OpenDDS::RTPS::DiscoveredParticipant::writer_pending_records_

The documentation for this struct was generated from the following file: