OpenDDS  Snapshot(2023/04/07-19:43)
Public Types | Public Member Functions | Private Attributes | List of all members
OpenDDS::RTPS::RtpsDiscoveryConfig Class Reference

#include <RtpsDiscoveryConfig.h>

Inheritance diagram for OpenDDS::RTPS::RtpsDiscoveryConfig:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::RTPS::RtpsDiscoveryConfig:
Collaboration graph
[legend]

Public Types

enum  UseXTypes { XTYPES_NONE = 0, XTYPES_MINIMAL, XTYPES_COMPLETE }
 

Public Member Functions

typedef OPENDDS_VECTOR (OPENDDS_STRING) AddrVec
 
 RtpsDiscoveryConfig ()
 
DCPS::TimeDuration resend_period () const
 
void resend_period (const DCPS::TimeDuration &period)
 
double quick_resend_ratio () const
 
void quick_resend_ratio (double ratio)
 
DCPS::TimeDuration min_resend_delay () const
 
void min_resend_delay (const DCPS::TimeDuration &delay)
 
DCPS::TimeDuration lease_duration () const
 
void lease_duration (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration max_lease_duration () const
 
void max_lease_duration (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration security_unsecure_lease_duration () const
 
void security_unsecure_lease_duration (const DCPS::TimeDuration &period)
 
size_t max_participants_in_authentication () const
 
void max_participants_in_authentication (size_t m)
 
DCPS::TimeDuration lease_extension () const
 
void lease_extension (const DCPS::TimeDuration &period)
 
u_short pb () const
 
void pb (u_short port_base)
 
u_short dg () const
 
void dg (u_short domain_gain)
 
u_short pg () const
 
void pg (u_short participant_gain)
 
u_short d0 () const
 
void d0 (u_short offset_zero)
 
u_short d1 () const
 
void d1 (u_short offset_one)
 
u_short dx () const
 
void dx (u_short offset_two)
 
unsigned char ttl () const
 
void ttl (unsigned char time_to_live)
 
ACE_INT32 send_buffer_size () const
 
void send_buffer_size (ACE_INT32 buffer_size)
 
ACE_INT32 recv_buffer_size () const
 
void recv_buffer_size (ACE_INT32 buffer_size)
 
ACE_INET_Addr sedp_local_address () const
 
void sedp_local_address (const ACE_INET_Addr &mi)
 
ACE_INET_Addr sedp_advertised_address () const
 
void sedp_advertised_address (const ACE_INET_Addr &mi)
 
ACE_INET_Addr spdp_local_address () const
 
void spdp_local_address (const ACE_INET_Addr &mi)
 
bool sedp_multicast () const
 
void sedp_multicast (bool sm)
 
OPENDDS_STRING multicast_interface () const
 
void multicast_interface (const OPENDDS_STRING &mi)
 
ACE_INET_Addr default_multicast_group () const
 
void default_multicast_group (const ACE_INET_Addr &group)
 
u_short port_common (DDS::DomainId_t domain) const
 
ACE_INET_Addr multicast_address (u_short port_common) const
 
bool spdp_request_random_port () const
 
void spdp_request_random_port (bool f)
 
OPENDDS_STRING guid_interface () const
 
void guid_interface (const OPENDDS_STRING &gi)
 
AddrVec spdp_send_addrs () const
 
void spdp_send_addrs (const AddrVec &addrs)
 
DCPS::TimeDuration max_auth_time () const
 
void max_auth_time (const DCPS::TimeDuration &x)
 
DCPS::TimeDuration auth_resend_period () const
 
void auth_resend_period (const DCPS::TimeDuration &x)
 
u_short max_spdp_sequence_msg_reset_check () const
 
void max_spdp_sequence_msg_reset_check (u_short reset_value)
 
ACE_INET_Addr spdp_rtps_relay_address () const
 
void spdp_rtps_relay_address (const ACE_INET_Addr &address)
 
DCPS::TimeDuration spdp_rtps_relay_send_period () const
 
void spdp_rtps_relay_send_period (const DCPS::TimeDuration &period)
 
ACE_INET_Addr sedp_rtps_relay_address () const
 
void sedp_rtps_relay_address (const ACE_INET_Addr &address)
 
bool use_rtps_relay () const
 
void use_rtps_relay (bool f)
 
bool rtps_relay_only () const
 
void rtps_relay_only (bool f)
 
ACE_INET_Addr spdp_stun_server_address () const
 
void spdp_stun_server_address (const ACE_INET_Addr &address)
 
ACE_INET_Addr sedp_stun_server_address () const
 
void sedp_stun_server_address (const ACE_INET_Addr &address)
 
bool use_ice () const
 
void use_ice (bool ui)
 
size_t sedp_max_message_size () const
 
void sedp_max_message_size (size_t value)
 
bool undirected_spdp () const
 
void undirected_spdp (bool value)
 
bool periodic_directed_spdp () const
 
void periodic_directed_spdp (bool value)
 
bool secure_participant_user_data () const
 
void secure_participant_user_data (bool value)
 
DCPS::TimeDuration max_type_lookup_service_reply_period () const
 
void max_type_lookup_service_reply_period (const DCPS::TimeDuration &x)
 
bool use_xtypes () const
 
void use_xtypes (UseXTypes use_xtypes)
 
bool use_xtypes (const char *str)
 
bool use_xtypes_complete () const
 
DCPS::TimeDuration sedp_heartbeat_period () const
 
void sedp_heartbeat_period (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration sedp_nak_response_delay () const
 
void sedp_nak_response_delay (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration sedp_send_delay () const
 
void sedp_send_delay (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration sedp_passive_connect_duration () const
 
void sedp_passive_connect_duration (const DCPS::TimeDuration &period)
 
DCPS::TimeDuration sedp_fragment_reassembly_timeout () const
 
void sedp_fragment_reassembly_timeout (const DCPS::TimeDuration &timeout)
 
CORBA::ULong participant_flags () const
 
void participant_flags (CORBA::ULong participant_flags)
 
bool sedp_responsive_mode () const
 
void sedp_responsive_mode (bool sedp_responsive_mode)
 
size_t sedp_receive_preallocated_message_blocks () const
 
void sedp_receive_preallocated_message_blocks (size_t n)
 
size_t sedp_receive_preallocated_data_blocks () const
 
void sedp_receive_preallocated_data_blocks (size_t n)
 
bool check_source_ip () const
 
void check_source_ip (bool flag)
 
- 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
 

Private Attributes

ACE_Thread_Mutex lock_
 
DCPS::TimeDuration resend_period_
 
double quick_resend_ratio_
 
DCPS::TimeDuration min_resend_delay_
 
DCPS::TimeDuration lease_duration_
 
DCPS::TimeDuration max_lease_duration_
 
DCPS::TimeDuration security_unsecure_lease_duration_
 
size_t max_participants_in_authentication_
 
DCPS::TimeDuration lease_extension_
 
u_short pb_
 
u_short dg_
 
u_short pg_
 
u_short d0_
 
u_short d1_
 
u_short dx_
 
unsigned char ttl_
 
ACE_INT32 send_buffer_size_
 
ACE_INT32 recv_buffer_size_
 
AtomicBool sedp_multicast_
 
OPENDDS_STRING multicast_interface_
 
ACE_INET_Addr sedp_local_address_
 
ACE_INET_Addr sedp_advertised_address_
 
ACE_INET_Addr spdp_local_address_
 
ACE_INET_Addr default_multicast_group_
 
AtomicBool spdp_request_random_port_
 FUTURE: handle > 1 group. More...
 
OPENDDS_STRING guid_interface_
 
AddrVec spdp_send_addrs_
 
DCPS::TimeDuration max_auth_time_
 
DCPS::TimeDuration auth_resend_period_
 
u_short max_spdp_sequence_msg_reset_check_
 
ACE_INET_Addr spdp_rtps_relay_address_
 
DCPS::TimeDuration spdp_rtps_relay_send_period_
 
ACE_INET_Addr sedp_rtps_relay_address_
 
AtomicBool use_rtps_relay_
 
AtomicBool rtps_relay_only_
 
ACE_INET_Addr spdp_stun_server_address_
 
ACE_INET_Addr sedp_stun_server_address_
 
AtomicBool use_ice_
 
size_t sedp_max_message_size_
 
AtomicBool undirected_spdp_
 
AtomicBool periodic_directed_spdp_
 
AtomicBool secure_participant_user_data_
 Should participant user data QoS only be sent when the message is secure? More...
 
DCPS::TimeDuration max_type_lookup_service_reply_period_
 
UseXTypes use_xtypes_
 
DCPS::TimeDuration sedp_heartbeat_period_
 
DCPS::TimeDuration sedp_nak_response_delay_
 
DCPS::TimeDuration sedp_send_delay_
 
DCPS::TimeDuration sedp_passive_connect_duration_
 
DCPS::TimeDuration sedp_fragment_reassembly_timeout_
 
CORBA::ULong participant_flags_
 
AtomicBool sedp_responsive_mode_
 
size_t sedp_receive_preallocated_message_blocks_
 
size_t sedp_receive_preallocated_data_blocks_
 
bool check_source_ip_
 

Additional Inherited Members

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

Detailed Description

Definition at line 23 of file RtpsDiscoveryConfig.h.

Member Enumeration Documentation

◆ UseXTypes

Enumerator
XTYPES_NONE 

Turn off support for XTypes.

XTYPES_MINIMAL 

Only use minimal TypeObjects.

XTYPES_COMPLETE 

Use both minimal and complete TypeObjects.

Definition at line 27 of file RtpsDiscoveryConfig.h.

27  {
28  XTYPES_NONE = 0, ///< Turn off support for XTypes
29  XTYPES_MINIMAL, ///< Only use minimal TypeObjects
30  XTYPES_COMPLETE ///< Use both minimal and complete TypeObjects
31  };
Use both minimal and complete TypeObjects.

Constructor & Destructor Documentation

◆ RtpsDiscoveryConfig()

OpenDDS::RTPS::RtpsDiscoveryConfig::RtpsDiscoveryConfig ( )

Definition at line 28 of file RtpsDiscoveryConfig.cpp.

References ACE_DEFAULT_MAX_SOCKET_BUFSIZ, if(), and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

29  : resend_period_(30 /*seconds*/) // see RTPS v2.1 9.6.1.4.2
30  , quick_resend_ratio_(0.1)
32  , lease_duration_(300)
33  , max_lease_duration_(300)
34 #ifdef OPENDDS_SECURITY
37 #endif
38  , lease_extension_(0)
39  , pb_(7400) // see RTPS v2.1 9.6.1.3 for PB, DG, PG, D0, D1 defaults
40  , dg_(250)
41  , pg_(2)
42  , d0_(get_default_d0(0))
43  , d1_(10)
44  , dx_(2)
45  , ttl_(1)
46 #if defined (ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
47  , send_buffer_size_(ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
48  , recv_buffer_size_(ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
49 #else
52 #endif
53  , sedp_multicast_(true)
54  , sedp_local_address_(u_short(0), "0.0.0.0")
55  , spdp_local_address_(u_short(0), "0.0.0.0")
56  , default_multicast_group_(u_short(0), "239.255.0.1") /*RTPS v2.1 9.6.1.4.1*/
57 #ifdef ACE_HAS_IPV6
58  , ipv6_sedp_local_address_(u_short(0), "::")
59  , ipv6_spdp_local_address_(u_short(0), "::")
60  , ipv6_default_multicast_group_(u_short(0), "FF03::1")
61 #endif
63  , max_auth_time_(300, 0)
64  , auth_resend_period_(1, 0)
67  , use_rtps_relay_(false)
68  , rtps_relay_only_(false)
69  , use_ice_(false)
71  , undirected_spdp_(true)
76  , sedp_heartbeat_period_(0, 200*1000 /*microseconds*/)
77  , sedp_nak_response_delay_(0, 100*1000 /*microseconds*/)
78  , sedp_send_delay_(0, 10 * 1000)
81  , sedp_responsive_mode_(false)
84  , check_source_ip_(true)
85 {}
DCPS::TimeDuration security_unsecure_lease_duration_
const OpenDDSParticipantFlagsBits_t PFLAGS_THIS_VERSION
Definition: RtpsCore.idl:325
AtomicBool secure_participant_user_data_
Should participant user data QoS only be sent when the message is secure?
static TimeDuration from_msec(const ACE_UINT64 &ms)
static const unsigned long DEFAULT_PASSIVE_CONNECT_DURATION
DCPS::TimeDuration sedp_passive_connect_duration_
AtomicBool spdp_request_random_port_
FUTURE: handle > 1 group.
DCPS::TimeDuration max_type_lookup_service_reply_period_

Member Function Documentation

◆ auth_resend_period() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::auth_resend_period ( ) const
inline

Definition at line 435 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

436  {
437  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
438  return auth_resend_period_;
439  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ auth_resend_period() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::auth_resend_period ( const DCPS::TimeDuration x)
inline

Definition at line 440 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

441  {
444  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ check_source_ip() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::check_source_ip ( ) const
inline

Definition at line 726 of file RtpsDiscoveryConfig.h.

727  {
728  return check_source_ip_;
729  }

◆ check_source_ip() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::check_source_ip ( bool  flag)
inline

Definition at line 730 of file RtpsDiscoveryConfig.h.

731  {
732  check_source_ip_ = flag;
733  }

◆ d0() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::d0 ( ) const
inline

Definition at line 157 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

158  {
159  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
160  return d0_;
161  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ d0() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::d0 ( u_short  offset_zero)
inline

Definition at line 162 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

163  {
165  d0_ = offset_zero;
166  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ d1() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::d1 ( ) const
inline

Definition at line 168 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

169  {
170  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
171  return d1_;
172  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ d1() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::d1 ( u_short  offset_one)
inline

Definition at line 173 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

174  {
176  d1_ = offset_one;
177  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ default_multicast_group() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::default_multicast_group ( ) const
inline

Definition at line 288 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

289  {
292  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ default_multicast_group() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::default_multicast_group ( const ACE_INET_Addr group)
inline

Definition at line 293 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), AF_INET, ACE_Addr::get_type(), LM_ERROR, and lock_.

294  {
295  if (group.get_type() == AF_INET) {
297  default_multicast_group_ = group;
298  } else {
299  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsDiscoveryConfig::default_multicast_group set failed because address family is not AF_INET\n")));
300  }
301  }
#define ACE_ERROR(X)
#define ACE_GUARD(MUTEX, OBJ, LOCK)
int get_type(void) const
#define AF_INET
ACE_TEXT("TCP_Factory")

◆ dg() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::dg ( ) const
inline

Definition at line 135 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

136  {
137  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
138  return dg_;
139  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ dg() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::dg ( u_short  domain_gain)
inline

Definition at line 140 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

141  {
143  dg_ = domain_gain;
144  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ dx() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::dx ( ) const
inline

Definition at line 179 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

180  {
181  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
182  return dx_;
183  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ dx() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::dx ( u_short  offset_two)
inline

Definition at line 184 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

185  {
187  dx_ = offset_two;
188  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ guid_interface() [1/2]

OPENDDS_STRING OpenDDS::RTPS::RtpsDiscoveryConfig::guid_interface ( ) const
inline

Definition at line 402 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

403  {
405  return guid_interface_;
406  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ guid_interface() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::guid_interface ( const OPENDDS_STRING gi)
inline

Definition at line 407 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

408  {
410  guid_interface_ = gi;
411  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ lease_duration() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::lease_duration ( ) const
inline

Definition at line 67 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

68  {
69  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
70  return lease_duration_;
71  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ lease_duration() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::lease_duration ( const DCPS::TimeDuration period)
inline

Definition at line 72 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

73  {
75  lease_duration_ = period;
76  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ lease_extension() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::lease_extension ( ) const
inline

Definition at line 113 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

114  {
115  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
116  return lease_extension_;
117  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ lease_extension() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::lease_extension ( const DCPS::TimeDuration period)
inline

Definition at line 118 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

119  {
121  lease_extension_ = period;
122  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ max_auth_time() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_auth_time ( ) const
inline

Definition at line 424 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

425  {
426  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
427  return max_auth_time_;
428  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ max_auth_time() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::max_auth_time ( const DCPS::TimeDuration x)
inline

Definition at line 429 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

430  {
432  max_auth_time_ = x;
433  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ max_lease_duration() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_lease_duration ( ) const
inline

Definition at line 78 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

79  {
80  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
81  return max_lease_duration_;
82  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ max_lease_duration() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::max_lease_duration ( const DCPS::TimeDuration period)
inline

Definition at line 83 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

84  {
86  max_lease_duration_ = period;
87  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ max_participants_in_authentication() [1/2]

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::max_participants_in_authentication ( ) const
inline

◆ max_participants_in_authentication() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::max_participants_in_authentication ( size_t  m)
inline

◆ max_spdp_sequence_msg_reset_check() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::max_spdp_sequence_msg_reset_check ( ) const
inline

Definition at line 446 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

447  {
448  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
450  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ max_spdp_sequence_msg_reset_check() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::max_spdp_sequence_msg_reset_check ( u_short  reset_value)
inline

Definition at line 451 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

452  {
455  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ max_type_lookup_service_reply_period() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_type_lookup_service_reply_period ( ) const
inline

Definition at line 577 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

578  {
579  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
581  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)
DCPS::TimeDuration max_type_lookup_service_reply_period_

◆ max_type_lookup_service_reply_period() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::max_type_lookup_service_reply_period ( const DCPS::TimeDuration x)
inline

Definition at line 582 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

583  {
586  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)
DCPS::TimeDuration max_type_lookup_service_reply_period_

◆ min_resend_delay() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::min_resend_delay ( ) const
inline

Definition at line 56 of file RtpsDiscoveryConfig.h.

References lock_.

◆ min_resend_delay() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::min_resend_delay ( const DCPS::TimeDuration delay)
inline

Definition at line 61 of file RtpsDiscoveryConfig.h.

References lock_.

◆ multicast_address()

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::multicast_address ( u_short  port_common) const
inline

Definition at line 310 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD, ACE_GUARD_RETURN, ACE_TEXT(), ACE_Addr::get_type(), LM_ERROR, lock_, and ACE_INET_Addr::set_port_number().

311  {
313 
315  // Ports are set by the formulas in RTPS v2.1 Table 9.8
317  return addr;
318  }
u_short port_common(DDS::DomainId_t domain) const
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)
void set_port_number(u_short, int encode=1)

◆ multicast_interface() [1/2]

OPENDDS_STRING OpenDDS::RTPS::RtpsDiscoveryConfig::multicast_interface ( ) const
inline

Definition at line 277 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

278  {
280  return multicast_interface_;
281  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ multicast_interface() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::multicast_interface ( const OPENDDS_STRING mi)
inline

Definition at line 282 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

283  {
286  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ OPENDDS_VECTOR()

typedef OpenDDS::RTPS::RtpsDiscoveryConfig::OPENDDS_VECTOR ( OPENDDS_STRING  )

◆ participant_flags() [1/2]

CORBA::ULong OpenDDS::RTPS::RtpsDiscoveryConfig::participant_flags ( ) const
inline

Definition at line 684 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

685  {
687  return participant_flags_;
688  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ participant_flags() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::participant_flags ( CORBA::ULong  participant_flags)
inline

Definition at line 689 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

690  {
693  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ pb() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::pb ( ) const
inline

Definition at line 124 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

125  {
126  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
127  return pb_;
128  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ pb() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::pb ( u_short  port_base)
inline

Definition at line 129 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

130  {
132  pb_ = port_base;
133  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ periodic_directed_spdp() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::periodic_directed_spdp ( ) const
inline

Definition at line 559 of file RtpsDiscoveryConfig.h.

560  {
562  }

◆ periodic_directed_spdp() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::periodic_directed_spdp ( bool  value)
inline

Definition at line 563 of file RtpsDiscoveryConfig.h.

References value.

564  {
566  }
const LogLevel::Value value
Definition: debug.cpp:61

◆ pg() [1/2]

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::pg ( ) const
inline

Definition at line 146 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

147  {
148  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, u_short());
149  return pg_;
150  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ pg() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::pg ( u_short  participant_gain)
inline

Definition at line 151 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

152  {
154  pg_ = participant_gain;
155  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ port_common()

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::port_common ( DDS::DomainId_t  domain) const
inline

Definition at line 303 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

304  {
306  // Ports are set by the formulas in RTPS v2.1 Table 9.8
307  return pb_ + (dg_ * domain);
308  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ quick_resend_ratio() [1/2]

double OpenDDS::RTPS::RtpsDiscoveryConfig::quick_resend_ratio ( ) const
inline

◆ quick_resend_ratio() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::quick_resend_ratio ( double  ratio)
inline

◆ recv_buffer_size() [1/2]

ACE_INT32 OpenDDS::RTPS::RtpsDiscoveryConfig::recv_buffer_size ( void  ) const
inline

Definition at line 212 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

213  {
215  return recv_buffer_size_;
216  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ recv_buffer_size() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::recv_buffer_size ( ACE_INT32  buffer_size)
inline

Definition at line 217 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

218  {
220  recv_buffer_size_ = buffer_size;
221  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ resend_period() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::resend_period ( ) const
inline

Definition at line 35 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

36  {
37  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
38  return resend_period_;
39  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ resend_period() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::resend_period ( const DCPS::TimeDuration period)
inline

Definition at line 40 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

41  {
43  resend_period_ = period;
44  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ rtps_relay_only() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::rtps_relay_only ( ) const
inline

Definition at line 499 of file RtpsDiscoveryConfig.h.

500  {
501  return rtps_relay_only_;
502  }

◆ rtps_relay_only() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::rtps_relay_only ( bool  f)
inline

Definition at line 503 of file RtpsDiscoveryConfig.h.

504  {
505  rtps_relay_only_ = f;
506  }

◆ secure_participant_user_data() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::secure_participant_user_data ( ) const
inline

Definition at line 568 of file RtpsDiscoveryConfig.h.

569  {
571  }
AtomicBool secure_participant_user_data_
Should participant user data QoS only be sent when the message is secure?

◆ secure_participant_user_data() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::secure_participant_user_data ( bool  value)
inline

Definition at line 572 of file RtpsDiscoveryConfig.h.

References value.

573  {
575  }
const LogLevel::Value value
Definition: debug.cpp:61
AtomicBool secure_participant_user_data_
Should participant user data QoS only be sent when the message is secure?

◆ security_unsecure_lease_duration() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::security_unsecure_lease_duration ( ) const
inline

Definition at line 90 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

91  {
92  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
94  }
DCPS::TimeDuration security_unsecure_lease_duration_
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ security_unsecure_lease_duration() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::security_unsecure_lease_duration ( const DCPS::TimeDuration period)
inline

Definition at line 95 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

96  {
99  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)
DCPS::TimeDuration security_unsecure_lease_duration_

◆ sedp_advertised_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_advertised_address ( ) const
inline

Definition at line 238 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

239  {
242  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_advertised_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_advertised_address ( const ACE_INET_Addr mi)
inline

Definition at line 243 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), AF_INET, ACE_Addr::get_type(), LM_ERROR, and lock_.

244  {
245  if (mi.get_type() == AF_INET) {
248  } else {
249  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsDiscoveryConfig::sedp_local_address set failed because address family is not AF_INET\n")));
250  }
251  }
#define ACE_ERROR(X)
#define ACE_GUARD(MUTEX, OBJ, LOCK)
int get_type(void) const
#define AF_INET
ACE_TEXT("TCP_Factory")

◆ sedp_fragment_reassembly_timeout() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_fragment_reassembly_timeout ( ) const
inline

Definition at line 673 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

674  {
675  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
677  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)
DCPS::TimeDuration sedp_fragment_reassembly_timeout_

◆ sedp_fragment_reassembly_timeout() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_fragment_reassembly_timeout ( const DCPS::TimeDuration timeout)
inline

Definition at line 678 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

679  {
682  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)
DCPS::TimeDuration sedp_fragment_reassembly_timeout_

◆ sedp_heartbeat_period() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_heartbeat_period ( ) const
inline

Definition at line 629 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

630  {
631  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
632  return sedp_heartbeat_period_;
633  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_heartbeat_period() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_heartbeat_period ( const DCPS::TimeDuration period)
inline

Definition at line 634 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

635  {
637  sedp_heartbeat_period_ = period;
638  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_local_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_local_address ( ) const
inline

Definition at line 223 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

224  {
226  return sedp_local_address_;
227  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_local_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_local_address ( const ACE_INET_Addr mi)
inline

Definition at line 228 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), AF_INET, ACE_Addr::get_type(), LM_ERROR, and lock_.

229  {
230  if (mi.get_type() == AF_INET) {
232  sedp_local_address_ = mi;
233  } else {
234  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsDiscoveryConfig::sedp_local_address set failed because address family is not AF_INET\n")));
235  }
236  }
#define ACE_ERROR(X)
#define ACE_GUARD(MUTEX, OBJ, LOCK)
int get_type(void) const
#define AF_INET
ACE_TEXT("TCP_Factory")

◆ sedp_max_message_size() [1/2]

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_max_message_size ( ) const
inline

Definition at line 539 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

540  {
541  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, size_t());
542  return sedp_max_message_size_;
543  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_max_message_size() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_max_message_size ( size_t  value)
inline

Definition at line 544 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, lock_, and value.

545  {
548  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)
const LogLevel::Value value
Definition: debug.cpp:61

◆ sedp_multicast() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_multicast ( ) const
inline

Definition at line 268 of file RtpsDiscoveryConfig.h.

269  {
270  return sedp_multicast_;
271  }

◆ sedp_multicast() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_multicast ( bool  sm)
inline

Definition at line 272 of file RtpsDiscoveryConfig.h.

273  {
274  sedp_multicast_ = sm;
275  }

◆ sedp_nak_response_delay() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_nak_response_delay ( ) const
inline

Definition at line 640 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

641  {
642  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
644  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_nak_response_delay() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_nak_response_delay ( const DCPS::TimeDuration period)
inline

Definition at line 645 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

646  {
648  sedp_nak_response_delay_ = period;
649  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_passive_connect_duration() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_passive_connect_duration ( ) const
inline

Definition at line 662 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

663  {
664  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
666  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)
DCPS::TimeDuration sedp_passive_connect_duration_

◆ sedp_passive_connect_duration() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_passive_connect_duration ( const DCPS::TimeDuration period)
inline

Definition at line 667 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

668  {
671  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)
DCPS::TimeDuration sedp_passive_connect_duration_

◆ sedp_receive_preallocated_data_blocks() [1/2]

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_data_blocks ( ) const
inline

Definition at line 715 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

716  {
719  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_receive_preallocated_data_blocks() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_data_blocks ( size_t  n)
inline

Definition at line 720 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

721  {
724  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_receive_preallocated_message_blocks() [1/2]

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_message_blocks ( ) const
inline

Definition at line 704 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

705  {
708  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_receive_preallocated_message_blocks() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_message_blocks ( size_t  n)
inline

Definition at line 709 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

710  {
713  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_responsive_mode() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_responsive_mode ( ) const
inline

Definition at line 695 of file RtpsDiscoveryConfig.h.

696  {
697  return sedp_responsive_mode_;
698  }

◆ sedp_responsive_mode() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_responsive_mode ( bool  sedp_responsive_mode)
inline

◆ sedp_rtps_relay_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_rtps_relay_address ( ) const
inline

Definition at line 479 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

480  {
483  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_rtps_relay_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_rtps_relay_address ( const ACE_INET_Addr address)
inline

Definition at line 484 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

485  {
487  sedp_rtps_relay_address_ = address;
488  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_send_delay() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_send_delay ( ) const
inline

Definition at line 651 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

652  {
653  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
654  return sedp_send_delay_;
655  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_send_delay() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_send_delay ( const DCPS::TimeDuration period)
inline

Definition at line 656 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

657  {
659  sedp_send_delay_ = period;
660  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ sedp_stun_server_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_stun_server_address ( ) const
inline

Definition at line 519 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

520  {
523  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ sedp_stun_server_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_stun_server_address ( const ACE_INET_Addr address)
inline

Definition at line 524 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

525  {
527  sedp_stun_server_address_ = address;
528  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ send_buffer_size() [1/2]

ACE_INT32 OpenDDS::RTPS::RtpsDiscoveryConfig::send_buffer_size ( void  ) const
inline

Definition at line 201 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

202  {
204  return send_buffer_size_;
205  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ send_buffer_size() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::send_buffer_size ( ACE_INT32  buffer_size)
inline

Definition at line 206 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

207  {
209  send_buffer_size_ = buffer_size;
210  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ spdp_local_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_local_address ( ) const
inline

Definition at line 253 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

254  {
256  return spdp_local_address_;
257  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ spdp_local_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_local_address ( const ACE_INET_Addr mi)
inline

Definition at line 258 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), AF_INET, ACE_Addr::get_type(), LM_ERROR, and lock_.

259  {
260  if (mi.get_type() == AF_INET) {
262  spdp_local_address_ = mi;
263  } else {
264  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsDiscoveryConfig::spdp_local_address set failed because address family is not AF_INET\n")));
265  }
266  }
#define ACE_ERROR(X)
#define ACE_GUARD(MUTEX, OBJ, LOCK)
int get_type(void) const
#define AF_INET
ACE_TEXT("TCP_Factory")

◆ spdp_request_random_port() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_request_random_port ( ) const
inline

Definition at line 393 of file RtpsDiscoveryConfig.h.

394  {
396  }
AtomicBool spdp_request_random_port_
FUTURE: handle > 1 group.

◆ spdp_request_random_port() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_request_random_port ( bool  f)
inline

Definition at line 397 of file RtpsDiscoveryConfig.h.

398  {
400  }
AtomicBool spdp_request_random_port_
FUTURE: handle > 1 group.

◆ spdp_rtps_relay_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_address ( ) const
inline

Definition at line 457 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

458  {
461  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ spdp_rtps_relay_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_address ( const ACE_INET_Addr address)
inline

Definition at line 462 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

463  {
465  spdp_rtps_relay_address_ = address;
466  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ spdp_rtps_relay_send_period() [1/2]

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_send_period ( ) const
inline

Definition at line 468 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

469  {
470  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DCPS::TimeDuration());
472  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ spdp_rtps_relay_send_period() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_send_period ( const DCPS::TimeDuration period)
inline

Definition at line 473 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

474  {
477  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ spdp_send_addrs() [1/2]

AddrVec OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_send_addrs ( ) const
inline

Definition at line 413 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

414  {
415  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, AddrVec());
416  return spdp_send_addrs_;
417  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ spdp_send_addrs() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_send_addrs ( const AddrVec &  addrs)
inline

Definition at line 418 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

419  {
421  spdp_send_addrs_ = addrs;
422  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ spdp_stun_server_address() [1/2]

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_stun_server_address ( ) const
inline

Definition at line 508 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

509  {
512  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ spdp_stun_server_address() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_stun_server_address ( const ACE_INET_Addr address)
inline

Definition at line 513 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

514  {
516  spdp_stun_server_address_ = address;
517  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ ttl() [1/2]

unsigned char OpenDDS::RTPS::RtpsDiscoveryConfig::ttl ( void  ) const
inline

Definition at line 190 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

191  {
193  return ttl_;
194  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ ttl() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::ttl ( unsigned char  time_to_live)
inline

Definition at line 195 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

196  {
198  ttl_ = time_to_live;
199  }
#define ACE_GUARD(MUTEX, OBJ, LOCK)

◆ undirected_spdp() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::undirected_spdp ( ) const
inline

Definition at line 550 of file RtpsDiscoveryConfig.h.

551  {
552  return undirected_spdp_;
553  }

◆ undirected_spdp() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::undirected_spdp ( bool  value)
inline

Definition at line 554 of file RtpsDiscoveryConfig.h.

References value.

555  {
557  }
const LogLevel::Value value
Definition: debug.cpp:61

◆ use_ice() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::use_ice ( ) const
inline

Definition at line 530 of file RtpsDiscoveryConfig.h.

531  {
532  return use_ice_;
533  }

◆ use_ice() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::use_ice ( bool  ui)
inline

Definition at line 534 of file RtpsDiscoveryConfig.h.

535  {
536  use_ice_ = ui;
537  }

◆ use_rtps_relay() [1/2]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::use_rtps_relay ( ) const
inline

Definition at line 490 of file RtpsDiscoveryConfig.h.

491  {
492  return use_rtps_relay_;
493  }

◆ use_rtps_relay() [2/2]

void OpenDDS::RTPS::RtpsDiscoveryConfig::use_rtps_relay ( bool  f)
inline

Definition at line 494 of file RtpsDiscoveryConfig.h.

495  {
496  use_rtps_relay_ = f;
497  }

◆ use_xtypes() [1/3]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::use_xtypes ( ) const
inline

Definition at line 588 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

589  {
591  return use_xtypes_ != XTYPES_NONE;
592  }
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

◆ use_xtypes() [2/3]

void OpenDDS::RTPS::RtpsDiscoveryConfig::use_xtypes ( UseXTypes  use_xtypes)
inline

Definition at line 593 of file RtpsDiscoveryConfig.h.

References ACE_GUARD, and lock_.

◆ use_xtypes() [3/3]

bool OpenDDS::RTPS::RtpsDiscoveryConfig::use_xtypes ( const char *  str)
inline

Definition at line 598 of file RtpsDiscoveryConfig.h.

References ACE_ERROR, ACE_GUARD_RETURN, LM_WARNING, lock_, OpenDDS::DCPS::log_level, name, value, and OpenDDS::DCPS::LogLevel::Warning.

599  {
601  struct NameValue {
602  const char* name;
604  };
605  static const NameValue entries[] = {
606  {"no", XTYPES_NONE},
607  {"minimal", XTYPES_MINIMAL},
608  {"complete", XTYPES_COMPLETE}
609  };
610 
611  for (size_t i = 0; i < sizeof entries / sizeof entries[0]; ++i) {
612  if (0 == std::strcmp(entries[i].name, str)) {
613  use_xtypes_ = entries[i].value;
614  return true;
615  }
616  }
617  if (log_level >= LogLevel::Warning) {
618  ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: RtpsDiscoveryConfig::use_xtypes: "
619  "invalid XTypes configuration: %C\n", str));
620  }
621  return false;
622  }
OpenDDS_Dcps_Export LogLevel log_level
#define ACE_ERROR(X)
const LogLevel::Value value
Definition: debug.cpp:61
Use both minimal and complete TypeObjects.
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)
const char *const name
Definition: debug.cpp:60

◆ use_xtypes_complete()

bool OpenDDS::RTPS::RtpsDiscoveryConfig::use_xtypes_complete ( ) const
inline

Definition at line 623 of file RtpsDiscoveryConfig.h.

References ACE_GUARD_RETURN, and lock_.

624  {
626  return use_xtypes_ == XTYPES_COMPLETE;
627  }
Use both minimal and complete TypeObjects.
#define ACE_GUARD_RETURN(MUTEX, OBJ, LOCK, RETURN)

Member Data Documentation

◆ auth_resend_period_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::auth_resend_period_
private

Definition at line 763 of file RtpsDiscoveryConfig.h.

◆ check_source_ip_

bool OpenDDS::RTPS::RtpsDiscoveryConfig::check_source_ip_
private

Definition at line 788 of file RtpsDiscoveryConfig.h.

◆ d0_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::d0_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ d1_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::d1_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ default_multicast_group_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::default_multicast_group_
private

Definition at line 754 of file RtpsDiscoveryConfig.h.

◆ dg_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::dg_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ dx_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::dx_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ guid_interface_

OPENDDS_STRING OpenDDS::RTPS::RtpsDiscoveryConfig::guid_interface_
private

Definition at line 760 of file RtpsDiscoveryConfig.h.

◆ lease_duration_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::lease_duration_
private

Definition at line 740 of file RtpsDiscoveryConfig.h.

◆ lease_extension_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::lease_extension_
private

Definition at line 746 of file RtpsDiscoveryConfig.h.

◆ lock_

ACE_Thread_Mutex OpenDDS::RTPS::RtpsDiscoveryConfig::lock_
mutableprivate

Definition at line 736 of file RtpsDiscoveryConfig.h.

◆ max_auth_time_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_auth_time_
private

Definition at line 762 of file RtpsDiscoveryConfig.h.

◆ max_lease_duration_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_lease_duration_
private

Definition at line 741 of file RtpsDiscoveryConfig.h.

◆ max_participants_in_authentication_

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::max_participants_in_authentication_
private

Definition at line 744 of file RtpsDiscoveryConfig.h.

◆ max_spdp_sequence_msg_reset_check_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::max_spdp_sequence_msg_reset_check_
private

Definition at line 764 of file RtpsDiscoveryConfig.h.

◆ max_type_lookup_service_reply_period_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::max_type_lookup_service_reply_period_
private

Definition at line 778 of file RtpsDiscoveryConfig.h.

◆ min_resend_delay_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::min_resend_delay_
private

Definition at line 739 of file RtpsDiscoveryConfig.h.

◆ multicast_interface_

OPENDDS_STRING OpenDDS::RTPS::RtpsDiscoveryConfig::multicast_interface_
private

Definition at line 752 of file RtpsDiscoveryConfig.h.

◆ participant_flags_

CORBA::ULong OpenDDS::RTPS::RtpsDiscoveryConfig::participant_flags_
private

Definition at line 785 of file RtpsDiscoveryConfig.h.

◆ pb_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::pb_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ periodic_directed_spdp_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::periodic_directed_spdp_
private

Definition at line 775 of file RtpsDiscoveryConfig.h.

◆ pg_

u_short OpenDDS::RTPS::RtpsDiscoveryConfig::pg_
private

Definition at line 747 of file RtpsDiscoveryConfig.h.

◆ quick_resend_ratio_

double OpenDDS::RTPS::RtpsDiscoveryConfig::quick_resend_ratio_
private

Definition at line 738 of file RtpsDiscoveryConfig.h.

◆ recv_buffer_size_

ACE_INT32 OpenDDS::RTPS::RtpsDiscoveryConfig::recv_buffer_size_
private

Definition at line 750 of file RtpsDiscoveryConfig.h.

◆ resend_period_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::resend_period_
private

Definition at line 737 of file RtpsDiscoveryConfig.h.

◆ rtps_relay_only_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::rtps_relay_only_
private

Definition at line 769 of file RtpsDiscoveryConfig.h.

◆ secure_participant_user_data_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::secure_participant_user_data_
private

Should participant user data QoS only be sent when the message is secure?

Definition at line 777 of file RtpsDiscoveryConfig.h.

◆ security_unsecure_lease_duration_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::security_unsecure_lease_duration_
private

Definition at line 743 of file RtpsDiscoveryConfig.h.

◆ sedp_advertised_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_advertised_address_
private

Definition at line 753 of file RtpsDiscoveryConfig.h.

◆ sedp_fragment_reassembly_timeout_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_fragment_reassembly_timeout_
private

Definition at line 784 of file RtpsDiscoveryConfig.h.

◆ sedp_heartbeat_period_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_heartbeat_period_
private

Definition at line 780 of file RtpsDiscoveryConfig.h.

◆ sedp_local_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_local_address_
private

Definition at line 753 of file RtpsDiscoveryConfig.h.

◆ sedp_max_message_size_

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_max_message_size_
private

Definition at line 773 of file RtpsDiscoveryConfig.h.

◆ sedp_multicast_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_multicast_
private

Definition at line 751 of file RtpsDiscoveryConfig.h.

◆ sedp_nak_response_delay_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_nak_response_delay_
private

Definition at line 781 of file RtpsDiscoveryConfig.h.

◆ sedp_passive_connect_duration_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_passive_connect_duration_
private

Definition at line 783 of file RtpsDiscoveryConfig.h.

◆ sedp_receive_preallocated_data_blocks_

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_data_blocks_
private

Definition at line 787 of file RtpsDiscoveryConfig.h.

◆ sedp_receive_preallocated_message_blocks_

size_t OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_receive_preallocated_message_blocks_
private

Definition at line 787 of file RtpsDiscoveryConfig.h.

◆ sedp_responsive_mode_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_responsive_mode_
private

Definition at line 786 of file RtpsDiscoveryConfig.h.

◆ sedp_rtps_relay_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_rtps_relay_address_
private

Definition at line 767 of file RtpsDiscoveryConfig.h.

◆ sedp_send_delay_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_send_delay_
private

Definition at line 782 of file RtpsDiscoveryConfig.h.

◆ sedp_stun_server_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::sedp_stun_server_address_
private

Definition at line 771 of file RtpsDiscoveryConfig.h.

◆ send_buffer_size_

ACE_INT32 OpenDDS::RTPS::RtpsDiscoveryConfig::send_buffer_size_
private

Definition at line 749 of file RtpsDiscoveryConfig.h.

◆ spdp_local_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_local_address_
private

Definition at line 753 of file RtpsDiscoveryConfig.h.

◆ spdp_request_random_port_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_request_random_port_
private

FUTURE: handle > 1 group.

Definition at line 759 of file RtpsDiscoveryConfig.h.

◆ spdp_rtps_relay_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_address_
private

Definition at line 765 of file RtpsDiscoveryConfig.h.

◆ spdp_rtps_relay_send_period_

DCPS::TimeDuration OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_rtps_relay_send_period_
private

Definition at line 766 of file RtpsDiscoveryConfig.h.

◆ spdp_send_addrs_

AddrVec OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_send_addrs_
private

Definition at line 761 of file RtpsDiscoveryConfig.h.

◆ spdp_stun_server_address_

ACE_INET_Addr OpenDDS::RTPS::RtpsDiscoveryConfig::spdp_stun_server_address_
private

Definition at line 770 of file RtpsDiscoveryConfig.h.

◆ ttl_

unsigned char OpenDDS::RTPS::RtpsDiscoveryConfig::ttl_
private

Definition at line 748 of file RtpsDiscoveryConfig.h.

◆ undirected_spdp_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::undirected_spdp_
private

Definition at line 774 of file RtpsDiscoveryConfig.h.

◆ use_ice_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::use_ice_
private

Definition at line 772 of file RtpsDiscoveryConfig.h.

◆ use_rtps_relay_

AtomicBool OpenDDS::RTPS::RtpsDiscoveryConfig::use_rtps_relay_
private

Definition at line 768 of file RtpsDiscoveryConfig.h.

◆ use_xtypes_

UseXTypes OpenDDS::RTPS::RtpsDiscoveryConfig::use_xtypes_
private

Definition at line 779 of file RtpsDiscoveryConfig.h.


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