#include <RtpsUdpInst.h>

Inheritance diagram for OpenDDS::DCPS::RtpsUdpInst:

Collaboration diagram for OpenDDS::DCPS::RtpsUdpInst:

[legend]

Public Member Functions
virtual int	load (ACE_Configuration_Heap &cf, ACE_Configuration_Section_Key &sect)

virtual OPENDDS_STRING	dump_to_str () const
	Diagnostic aid. More...

bool	is_reliable () const
	Does the transport as configured support RELIABLE_RELIABILITY_QOS? More...

bool	requires_cdr_encapsulation () const
	Does the transport require a CDR-encapsulated data payload? More...

virtual size_t	populate_locator (OpenDDS::DCPS::TransportLocator &trans_info, ConnectionInfoFlags flags) const
	Populate a transport locator sequence. Return the number of "locators.". More...

const TransportBLOB *	get_blob (const OpenDDS::DCPS::TransportLocatorSeq &trans_info) const

NetworkAddress	multicast_group_address () const

void	multicast_group_address (const NetworkAddress &addr)

NetworkAddress	local_address () const

void	local_address (const NetworkAddress &addr)

NetworkAddress	advertised_address () const

void	advertised_address (const NetworkAddress &addr)

void	rtps_relay_only (bool flag)

bool	rtps_relay_only () const

void	use_rtps_relay (bool flag)

bool	use_rtps_relay () const

void	rtps_relay_address (const NetworkAddress &address)

NetworkAddress	rtps_relay_address () const

void	use_ice (bool flag)

bool	use_ice () const

void	stun_server_address (const NetworkAddress &address)

NetworkAddress	stun_server_address () const

void	update_locators (const GUID_t &remote_id, const TransportLocatorSeq &locators)
	} More...

void	get_last_recv_locator (const GUID_t &, TransportLocator &)

void	rtps_relay_address_change ()

void	append_transport_statistics (TransportStatisticsSequence &seq)

Public Member Functions inherited from OpenDDS::DCPS::TransportInst
const OPENDDS_STRING &	name () const

void	dump () const
	Diagnostic aid. More...

DCPS::WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()

void	rtps_relay_only_now (bool flag)

void	use_rtps_relay_now (bool flag)

void	use_ice_now (bool flag)

ReactorTask_rch	reactor_task ()

EventDispatcher_rch	event_dispatcher ()

void	count_messages (bool flag)

bool	count_messages () const

void	drop_messages (bool flag)

void	drop_messages_m (double m)

void	drop_messages_b (double b)

bool	should_drop (ssize_t length) const

bool	should_drop (const iovec iov[], int n, ssize_t &length) 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

Public Attributes
ACE_INT32	send_buffer_size_

ACE_INT32	rcv_buffer_size_

bool	use_multicast_

unsigned char	ttl_

OPENDDS_STRING	multicast_interface_

size_t	anticipated_fragments_

size_t	max_message_size_

size_t	nak_depth_

TimeDuration	nak_response_delay_

TimeDuration	heartbeat_period_

TimeDuration	receive_address_duration_

bool	responsive_mode_

TimeDuration	send_delay_

Public Attributes inherited from OpenDDS::DCPS::TransportInst
const OPENDDS_STRING	transport_type_

size_t	queue_messages_per_pool_

size_t	queue_initial_pools_

ACE_UINT32	max_packet_size_
	Max size (in bytes) of a packet (packet header + sample(s)) More...

size_t	max_samples_per_packet_
	Max number of samples that should ever be in a single packet. More...

ACE_UINT32	optimum_packet_size_
	Optimum size (in bytes) of a packet (packet header + sample(s)). More...

bool	thread_per_connection_

long	datalink_release_delay_

size_t	datalink_control_chunks_

TimeDuration	fragment_reassembly_timeout_

size_t	receive_preallocated_message_blocks_

size_t	receive_preallocated_data_blocks_

Static Public Attributes
static const suseconds_t	DEFAULT_NAK_RESPONSE_DELAY_USEC = 200000

static const time_t	DEFAULT_HEARTBEAT_PERIOD_SEC = 1

Static Public Attributes inherited from OpenDDS::DCPS::TransportInst
static const long	DEFAULT_DATALINK_RELEASE_DELAY = 10000

static const size_t	DEFAULT_DATALINK_CONTROL_CHUNKS = 32u

Private Member Functions
	RtpsUdpInst (const OPENDDS_STRING &name)

TransportImpl_rch	new_impl ()

Friends
class	RtpsUdpType

class	RTPS::Sedp

class	RtpsUdpTransport

template<typename T , typename U >
RcHandle< T >	OpenDDS::DCPS::make_rch (U const &)

Additional Inherited Members
Static Public Member Functions inherited from OpenDDS::DCPS::TransportInst
static OPENDDS_STRING	formatNameForDump (const char *name)

Protected Member Functions inherited from OpenDDS::DCPS::TransportInst
	TransportInst (const char *type, const OPENDDS_STRING &name)

virtual	~TransportInst ()

void	set_port_in_addr_string (OPENDDS_STRING &addr_str, u_short port_number)

TransportImpl_rch	get_or_create_impl ()

TransportImpl_rch	get_impl ()

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

Protected Attributes inherited from OpenDDS::DCPS::TransportInst
ACE_SYNCH_MUTEX	lock_

bool	shutting_down_

Detailed Description

Definition at line 31 of file RtpsUdpInst.h.

Constructor & Destructor Documentation

◆ RtpsUdpInst()

OpenDDS::DCPS::RtpsUdpInst::RtpsUdpInst ( const OPENDDS_STRING & name )

explicitprivate

Definition at line 29 of file RtpsUdpInst.cpp.

References ACE_DEFAULT_MAX_SOCKET_BUFSIZ, and if().

   : TransportInst("rtps_udp", name)
 #if defined (ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
   , send_buffer_size_(ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
   , rcv_buffer_size_(ACE_DEFAULT_MAX_SOCKET_BUFSIZ)
 #else
   , send_buffer_size_(0)
   , rcv_buffer_size_(0)
 #endif
   , use_multicast_(true)
   , ttl_(1)
   , anticipated_fragments_(RtpsUdpSendStrategy::UDP_MAX_MESSAGE_SIZE / RtpsSampleHeader::FRAG_SIZE)
   , max_message_size_(RtpsUdpSendStrategy::UDP_MAX_MESSAGE_SIZE)
   , nak_depth_(0)
   , nak_response_delay_(0, DEFAULT_NAK_RESPONSE_DELAY_USEC)
   , heartbeat_period_(DEFAULT_HEARTBEAT_PERIOD_SEC)
   , receive_address_duration_(5)
   , responsive_mode_(false)
   , send_delay_(0, 10 * 1000)
   , opendds_discovery_guid_(GUID_UNKNOWN)
   , multicast_group_address_(7401, "239.255.0.2")
   , local_address_(u_short(0), "0.0.0.0")
 #ifdef ACE_HAS_IPV6
   , ipv6_multicast_group_address_(7401, "FF03::2")
   , ipv6_local_address_(u_short(0), "::")
 #endif
   , rtps_relay_only_(false)
   , use_rtps_relay_(false)
   , use_ice_(false)
 {}

Member Function Documentation

◆ advertised_address() [1/2]

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::advertised_address ( ) const

inline

Definition at line 85 of file RtpsUdpInst.h.

Referenced by load(), and populate_locator().

85 { return advertised_address_; }

OpenDDS::DCPS::RtpsUdpInst::advertised_address_

NetworkAddress advertised_address_

Definition: RtpsUdpInst.h:165

◆ advertised_address() [2/2]

void OpenDDS::DCPS::RtpsUdpInst::advertised_address ( const NetworkAddress & addr )

inline

Definition at line 86 of file RtpsUdpInst.h.

References ACE_ERROR, ACE_TEXT(), AF_INET, OpenDDS::DCPS::NetworkAddress::get_type(), and LM_ERROR.

   {
     if (addr.get_type() == AF_INET) {
       advertised_address_ = addr;
     } else {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsUdpInst::advertised_address set failed because address family is not AF_INET\n")));
     }
   }

◆ append_transport_statistics()

void OpenDDS::DCPS::RtpsUdpInst::append_transport_statistics ( TransportStatisticsSequence & seq )

virtual

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 319 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::TransportInst::get_or_create_impl(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and OpenDDS::DCPS::static_rchandle_cast().

 {
   TransportImpl_rch imp = get_or_create_impl();
   if (imp) {
     RtpsUdpTransport_rch rtps_impl = static_rchandle_cast<RtpsUdpTransport>(imp);
     rtps_impl->append_transport_statistics(seq);
   }
 }

◆ dump_to_str()

OPENDDS_STRING OpenDDS::DCPS::RtpsUdpInst::dump_to_str ( ) const

virtual

Diagnostic aid.

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 174 of file RtpsUdpInst.cpp.

References anticipated_fragments_, OpenDDS::DCPS::TransportInst::dump_to_str(), OpenDDS::DCPS::TransportInst::formatNameForDump(), heartbeat_period_, local_address(), max_message_size_, multicast_group_address_, multicast_interface_, nak_depth_, nak_response_delay_, OPENDDS_STRING, rcv_buffer_size_, responsive_mode_, send_buffer_size_, OpenDDS::DCPS::LogAddr::str(), OpenDDS::DCPS::TimeDuration::str(), OpenDDS::DCPS::to_dds_string(), ttl_, and use_multicast_.

 {
   OPENDDS_STRING ret = TransportInst::dump_to_str();
   ret += formatNameForDump("local_address") + LogAddr(local_address()).str() + '\n';
   ret += formatNameForDump("use_multicast") + (use_multicast_ ? "true" : "false") + '\n';
   ret += formatNameForDump("multicast_group_address") + LogAddr(multicast_group_address_).str() + '\n';
   ret += formatNameForDump("multicast_interface") + multicast_interface_ + '\n';
   ret += formatNameForDump("nak_depth") + to_dds_string(unsigned(nak_depth_)) + '\n';
   ret += formatNameForDump("anticipated_fragments") + to_dds_string(unsigned(anticipated_fragments_)) + '\n';
   ret += formatNameForDump("max_message_size") + to_dds_string(unsigned(max_message_size_)) + '\n';
   ret += formatNameForDump("nak_response_delay") + nak_response_delay_.str() + '\n';
   ret += formatNameForDump("heartbeat_period") + heartbeat_period_.str() + '\n';
   ret += formatNameForDump("send_buffer_size") + to_dds_string(send_buffer_size_) + '\n';
   ret += formatNameForDump("rcv_buffer_size") + to_dds_string(rcv_buffer_size_) + '\n';
   ret += formatNameForDump("ttl") + to_dds_string(ttl_) + '\n';
   ret += formatNameForDump("responsive_mode") + (responsive_mode_ ? "true" : "false") + '\n';
   return ret;
 }

◆ get_blob()

const TransportBLOB * OpenDDS::DCPS::RtpsUdpInst::get_blob ( const OpenDDS::DCPS::TransportLocatorSeq & trans_info ) const

Definition at line 275 of file RtpsUdpInst.cpp.

 {
   for (CORBA::ULong idx = 0, limit = trans_info.length(); idx != limit; ++idx) {
     if (std::strcmp(trans_info[idx].transport_type, "rtps_udp") == 0) {
       return &trans_info[idx].data;
     }
   }
 
   return 0;
 }

◆ get_last_recv_locator()

void OpenDDS::DCPS::RtpsUdpInst::get_last_recv_locator	(	const GUID_t &	remote_id,
		TransportLocator &	locator
	)

virtual

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 298 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::TransportInst::get_or_create_impl(), and OpenDDS::DCPS::static_rchandle_cast().

 {
   TransportImpl_rch imp = get_or_create_impl();
   if (imp) {
     RtpsUdpTransport_rch rtps_impl = static_rchandle_cast<RtpsUdpTransport>(imp);
     rtps_impl->get_last_recv_locator(remote_id, locator);
   }
 }

◆ is_reliable()

bool OpenDDS::DCPS::RtpsUdpInst::is_reliable ( ) const

inlinevirtual

Does the transport as configured support RELIABLE_RELIABILITY_QOS?

Implements OpenDDS::DCPS::TransportInst.

Definition at line 59 of file RtpsUdpInst.h.

59 { return true; }

◆ load()

int OpenDDS::DCPS::RtpsUdpInst::load	(	ACE_Configuration_Heap &	cf,
		ACE_Configuration_Section_Key &	sect
	)

virtual

Overwrite the default configurations with the configuration from the given section in the ACE_Configuration_Heap object.

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 67 of file RtpsUdpInst.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), advertised_address(), anticipated_fragments_, ACE_String_Base< char >::c_str(), GET_CONFIG_STRING_VALUE, GET_CONFIG_TIME_VALUE, GET_CONFIG_TSTRING_VALUE, GET_CONFIG_VALUE, heartbeat_period_, ACE_String_Base< char >::is_empty(), LM_ERROR, OpenDDS::DCPS::TransportInst::load(), local_address(), max_message_size_, multicast_group_address(), multicast_interface_, nak_depth_, nak_response_delay_, ACE_String_Base_Const::npos, OPENDDS_STRING, rcv_buffer_size_, responsive_mode_, ACE_String_Base< char >::rfind(), rtps_relay_address(), rtps_relay_only_, send_buffer_size_, send_delay_, stun_server_address(), TheServiceParticipant, ttl_, use_ice_, use_multicast_, and use_rtps_relay_.

 {
   TransportInst::load(cf, sect); // delegate to parent
 
   ACE_TString local_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("local_address"),
                            local_address_s);
   if (!local_address_s.is_empty()) {
     NetworkAddress addr(local_address_s.c_str());
     local_address(addr);
   }
 
   ACE_TString advertised_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("advertised_address"),
                            advertised_address_s);
   if (!advertised_address_s.is_empty()) {
     NetworkAddress addr(advertised_address_s.c_str());
     advertised_address(addr);
   }
 
 #ifdef ACE_HAS_IPV6
   ACE_TString ipv6_local_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("ipv6_local_address"),
                            ipv6_local_address_s);
   if (!ipv6_local_address_s.is_empty()) {
     NetworkAddress addr(ipv6_local_address_s.c_str());
     ipv6_local_address(addr);
   }
 
   ACE_TString ipv6_advertised_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("ipv6_advertised_address"),
                            ipv6_advertised_address_s);
   if (!ipv6_advertised_address_s.is_empty()) {
     NetworkAddress addr(ipv6_advertised_address_s.c_str());
     ipv6_advertised_address(addr);
   }
 #endif
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("send_buffer_size"), send_buffer_size_, ACE_UINT32);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("rcv_buffer_size"), rcv_buffer_size_, ACE_UINT32);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("use_multicast"), use_multicast_, bool);
 
   ACE_TString group_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("multicast_group_address"),
                            group_address_s);
   if (!group_address_s.is_empty()) {
     if (group_address_s.rfind(':') == group_address_s.npos) {
       // Concatenate a port number if the user does not supply one.
       group_address_s += ACE_TEXT(":7401");
     }
     NetworkAddress addr(group_address_s.c_str());
     multicast_group_address(addr);
   }
 
   GET_CONFIG_STRING_VALUE(cf, sect, ACE_TEXT("multicast_interface"),
                           multicast_interface_);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("anticipated_fragments"), anticipated_fragments_, size_t);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("max_message_size"), max_message_size_, size_t);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("nak_depth"), nak_depth_, size_t);
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("ttl"), ttl_, unsigned char);
 
   GET_CONFIG_TIME_VALUE(cf, sect, ACE_TEXT("nak_response_delay"),
                         nak_response_delay_);
   GET_CONFIG_TIME_VALUE(cf, sect, ACE_TEXT("heartbeat_period"),
                         heartbeat_period_);
   GET_CONFIG_TIME_VALUE(cf, sect, ACE_TEXT("send_delay"),
                         send_delay_);
 
   ACE_TString rtps_relay_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DataRtpsRelayAddress"),
                            rtps_relay_address_s);
   if (!rtps_relay_address_s.is_empty()) {
     NetworkAddress addr(rtps_relay_address_s.c_str());
     rtps_relay_address(addr);
   }
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("RtpsRelayOnly"), rtps_relay_only_, bool);
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("UseRtpsRelay"), use_rtps_relay_, bool);
 
   ACE_TString stun_server_address_s;
   GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DataStunServerAddress"),
                            stun_server_address_s);
   if (!stun_server_address_s.is_empty()) {
     NetworkAddress addr(stun_server_address_s.c_str());
     stun_server_address(addr);
   }
 
 #ifdef OPENDDS_SECURITY
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("UseIce"), use_ice_, bool);
   if (use_ice_ && !TheServiceParticipant->get_security()) {
     ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: Security must be enabled (-DCPSSecurity 1) when using ICE (UseIce)\n")), -1);
   }
 #endif
 
   GET_CONFIG_VALUE(cf, sect, ACE_TEXT("ResponsiveMode"), responsive_mode_, bool);
 
   return 0;
 }

◆ local_address() [1/2]

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::local_address ( ) const

inline

Definition at line 75 of file RtpsUdpInst.h.

Referenced by dump_to_str(), load(), and populate_locator().

75 { return local_address_; }

OpenDDS::DCPS::RtpsUdpInst::local_address_

NetworkAddress local_address_

Definition: RtpsUdpInst.h:164

◆ local_address() [2/2]

void OpenDDS::DCPS::RtpsUdpInst::local_address ( const NetworkAddress & addr )

inline

Definition at line 76 of file RtpsUdpInst.h.

References ACE_ERROR, ACE_TEXT(), AF_INET, OpenDDS::DCPS::NetworkAddress::get_type(), and LM_ERROR.

   {
     if (addr.get_type() == AF_INET) {
       local_address_ = addr;
     } else {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsUdpInst::local_address set failed because address family is not AF_INET\n")));
     }
   }

◆ multicast_group_address() [1/2]

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::multicast_group_address ( ) const

inline

Definition at line 65 of file RtpsUdpInst.h.

Referenced by load().

65 { return multicast_group_address_; }

OpenDDS::DCPS::RtpsUdpInst::multicast_group_address_

NetworkAddress multicast_group_address_

Definition: RtpsUdpInst.h:163

◆ multicast_group_address() [2/2]

void OpenDDS::DCPS::RtpsUdpInst::multicast_group_address ( const NetworkAddress & addr )

inline

Definition at line 66 of file RtpsUdpInst.h.

References ACE_ERROR, ACE_TEXT(), AF_INET, OpenDDS::DCPS::NetworkAddress::get_type(), and LM_ERROR.

   {
     if (addr.get_type() == AF_INET) {
       multicast_group_address_ = addr;
     } else {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: RtpsUdpInst::multicast_group_address set failed because address family is not AF_INET\n")));
     }
   }

◆ new_impl()

TransportImpl_rch OpenDDS::DCPS::RtpsUdpInst::new_impl ( )

privatevirtual

Implements OpenDDS::DCPS::TransportInst.

Definition at line 61 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::rchandle_from().

 {
   return make_rch<RtpsUdpTransport>(rchandle_from(this));
 }

◆ populate_locator()

size_t OpenDDS::DCPS::RtpsUdpInst::populate_locator	(	OpenDDS::DCPS::TransportLocator &	trans_info,
		ConnectionInfoFlags	flags
	)		const

virtual

Populate a transport locator sequence. Return the number of "locators.".

Implements OpenDDS::DCPS::TransportInst.

Definition at line 194 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::address_to_locator(), advertised_address(), AF_INET, OpenDDS::DCPS::CONNINFO_MULTICAST, OpenDDS::DCPS::CONNINFO_UNICAST, OpenDDS::DCPS::TransportLocator::data, OpenDDS::DCPS::get_interface_addrs(), OpenDDS::DCPS::NetworkAddress::get_port_number(), ACE_Addr::get_type(), OpenDDS::DCPS::grow(), local_address(), OpenDDS::RTPS::locators_to_blob(), multicast_group_address_, OpenDDS::DCPS::OPENDDS_VECTOR(), OpenDDS::DCPS::NetworkAddress::to_addr(), OpenDDS::DCPS::TransportLocator::transport_type, and use_multicast_.

 {
   using namespace OpenDDS::RTPS;
 
   LocatorSeq locators;
   CORBA::ULong idx = 0;
 
   // multicast first so it's preferred by remote peers
   if ((flags & CONNINFO_MULTICAST) && use_multicast_ && multicast_group_address_ != NetworkAddress()) {
     grow(locators);
     address_to_locator(locators[idx++], multicast_group_address_.to_addr());
   }
 #ifdef ACE_HAS_IPV6
   if ((flags & CONNINFO_MULTICAST) && use_multicast_ && ipv6_multicast_group_address_ != NetworkAddress()) {
     grow(locators);
     address_to_locator(locators[idx++], ipv6_multicast_group_address_.to_addr());
   }
 #endif
 
   if (flags & CONNINFO_UNICAST) {
     if (local_address() != NetworkAddress()) {
       if (advertised_address() != NetworkAddress()) {
         grow(locators);
         address_to_locator(locators[idx], advertised_address().to_addr());
         if (locators[idx].port == 0) {
           locators[idx].port = local_address().get_port_number();
         }
         ++idx;
       } else if (local_address().is_any()) {
         typedef OPENDDS_VECTOR(ACE_INET_Addr) AddrVector;
         AddrVector addrs;
         get_interface_addrs(addrs);
         for (AddrVector::iterator adr_it = addrs.begin(); adr_it != addrs.end(); ++adr_it) {
           if (*adr_it != ACE_INET_Addr() && adr_it->get_type() == AF_INET) {
             grow(locators);
             address_to_locator(locators[idx], *adr_it);
             locators[idx].port = local_address().get_port_number();
             ++idx;
           }
         }
       } else {
         grow(locators);
         address_to_locator(locators[idx++], local_address().to_addr());
       }
     }
 #ifdef ACE_HAS_IPV6
     if (ipv6_local_address() != NetworkAddress()) {
       if (ipv6_advertised_address() != NetworkAddress()) {
         grow(locators);
         address_to_locator(locators[idx], ipv6_advertised_address().to_addr());
         if (locators[idx].port == 0) {
           locators[idx].port = ipv6_local_address().get_port_number();
         }
         ++idx;
       } else if (ipv6_local_address().is_any()) {
         typedef OPENDDS_VECTOR(ACE_INET_Addr) AddrVector;
         AddrVector addrs;
         get_interface_addrs(addrs);
         for (AddrVector::iterator adr_it = addrs.begin(); adr_it != addrs.end(); ++adr_it) {
           if (*adr_it != ACE_INET_Addr() && adr_it->get_type() == AF_INET6) {
             grow(locators);
             address_to_locator(locators[idx], *adr_it);
             locators[idx].port = ipv6_local_address().get_port_number();
             ++idx;
           }
         }
       } else {
         grow(locators);
         address_to_locator(locators[idx++], ipv6_local_address().to_addr());
       }
     }
 #endif
   }
 
   info.transport_type = "rtps_udp";
   RTPS::locators_to_blob(locators, info.data);
 
   return locators.length();
 }

◆ requires_cdr_encapsulation()

bool OpenDDS::DCPS::RtpsUdpInst::requires_cdr_encapsulation ( ) const

inlinevirtual

Does the transport require a CDR-encapsulated data payload?

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 60 of file RtpsUdpInst.h.

60 { return true; }

◆ rtps_relay_address() [1/2]

void OpenDDS::DCPS::RtpsUdpInst::rtps_relay_address ( const NetworkAddress & address )

inline

Definition at line 210 of file RtpsUdpInst.h.

References ACE_GUARD.

 {
   ACE_GUARD(ACE_Thread_Mutex, g, config_lock_);
   rtps_relay_address_ = address;
 }

◆ rtps_relay_address() [2/2]

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::rtps_relay_address ( ) const

inline

Definition at line 216 of file RtpsUdpInst.h.

References ACE_GUARD_RETURN.

Referenced by load().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, config_lock_, NetworkAddress());
   return rtps_relay_address_;
 }

◆ rtps_relay_address_change()

void OpenDDS::DCPS::RtpsUdpInst::rtps_relay_address_change ( )

virtual

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 309 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::TransportInst::get_impl(), and OpenDDS::DCPS::static_rchandle_cast().

 {
   TransportImpl_rch imp = get_impl();
   if (imp) {
     RtpsUdpTransport_rch rtps_impl = static_rchandle_cast<RtpsUdpTransport>(imp);
     rtps_impl->rtps_relay_address_change();
   }
 }

◆ rtps_relay_only() [1/2]

void OpenDDS::DCPS::RtpsUdpInst::rtps_relay_only ( bool flag )

inline

Relay address and stun server address may change, these use a mutex {

Definition at line 180 of file RtpsUdpInst.h.

References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::DCPS_debug_level, and LM_INFO.

 {
   ACE_GUARD(ACE_Thread_Mutex, g, config_lock_);
   rtps_relay_only_ = flag;
   if (DCPS::DCPS_debug_level > 3) {
     ACE_DEBUG((LM_INFO, "(%P|%t) RtpsUdpInst::rtps_relay_only is now %d\n", rtps_relay_only_));
   }
 }

◆ rtps_relay_only() [2/2]

bool OpenDDS::DCPS::RtpsUdpInst::rtps_relay_only ( ) const

inline

Definition at line 189 of file RtpsUdpInst.h.

References ACE_GUARD_RETURN.

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, config_lock_, false);
   return rtps_relay_only_;
 }

◆ stun_server_address() [1/2]

void OpenDDS::DCPS::RtpsUdpInst::stun_server_address ( const NetworkAddress & address )

inline

Definition at line 237 of file RtpsUdpInst.h.

References ACE_GUARD.

 {
   ACE_GUARD(ACE_Thread_Mutex, g, config_lock_);
   stun_server_address_ = address;
 }

◆ stun_server_address() [2/2]

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::stun_server_address ( ) const

inline

Definition at line 243 of file RtpsUdpInst.h.

References ACE_GUARD_RETURN, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by load().

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, config_lock_, NetworkAddress());
   return stun_server_address_;
 }

◆ update_locators()

void OpenDDS::DCPS::RtpsUdpInst::update_locators	(	const GUID_t &	remote_id,
		const TransportLocatorSeq &	locators
	)

virtual

}

Reimplemented from OpenDDS::DCPS::TransportInst.

Definition at line 287 of file RtpsUdpInst.cpp.

References OpenDDS::DCPS::TransportInst::get_or_create_impl(), and OpenDDS::DCPS::static_rchandle_cast().

 {
   TransportImpl_rch imp = get_or_create_impl();
   if (imp) {
     RtpsUdpTransport_rch rtps_impl = static_rchandle_cast<RtpsUdpTransport>(imp);
     rtps_impl->update_locators(remote_id, locators);
   }
 }

◆ use_ice() [1/2]

void OpenDDS::DCPS::RtpsUdpInst::use_ice ( bool flag )

inline

Definition at line 222 of file RtpsUdpInst.h.

References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::DCPS_debug_level, and LM_INFO.

 {
   ACE_GUARD(ACE_Thread_Mutex, g, config_lock_);
   use_ice_ = flag;
   if (DCPS::DCPS_debug_level > 3) {
     ACE_DEBUG((LM_INFO, "(%P|%t) RtpsUdpInst::use_ice is now %d\n", use_ice_));
   }
 }

◆ use_ice() [2/2]

bool OpenDDS::DCPS::RtpsUdpInst::use_ice ( ) const

inline

Definition at line 231 of file RtpsUdpInst.h.

References ACE_GUARD_RETURN.

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, config_lock_, false);
   return use_ice_;
 }

◆ use_rtps_relay() [1/2]

void OpenDDS::DCPS::RtpsUdpInst::use_rtps_relay ( bool flag )

inline

Definition at line 195 of file RtpsUdpInst.h.

References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::DCPS_debug_level, and LM_INFO.

 {
   ACE_GUARD(ACE_Thread_Mutex, g, config_lock_);
   use_rtps_relay_ = flag;
   if (DCPS::DCPS_debug_level > 3) {
     ACE_DEBUG((LM_INFO, "(%P|%t) RtpsUdpInst::use_rtps_relay is now %d\n", use_rtps_relay_));
   }
 }

◆ use_rtps_relay() [2/2]

bool OpenDDS::DCPS::RtpsUdpInst::use_rtps_relay ( ) const

inline

Definition at line 204 of file RtpsUdpInst.h.

References ACE_GUARD_RETURN.

 {
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, config_lock_, false);
   return use_rtps_relay_;
 }

Friends And Related Function Documentation

◆ OpenDDS::DCPS::make_rch

template<typename T , typename U >

RcHandle<T> OpenDDS::DCPS::make_rch ( U const & )

friend

◆ RTPS::Sedp

friend class RTPS::Sedp

friend

Definition at line 158 of file RtpsUdpInst.h.

◆ RtpsUdpTransport

friend class RtpsUdpTransport

friend

Definition at line 159 of file RtpsUdpInst.h.

◆ RtpsUdpType

friend class RtpsUdpType

friend

Definition at line 151 of file RtpsUdpInst.h.

Member Data Documentation

◆ advertised_address_

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::advertised_address_

private

Definition at line 165 of file RtpsUdpInst.h.

◆ anticipated_fragments_

size_t OpenDDS::DCPS::RtpsUdpInst::anticipated_fragments_

Definition at line 44 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ config_lock_

ACE_SYNCH_MUTEX OpenDDS::DCPS::RtpsUdpInst::config_lock_

mutableprivate

Definition at line 172 of file RtpsUdpInst.h.

◆ DEFAULT_HEARTBEAT_PERIOD_SEC

const time_t OpenDDS::DCPS::RtpsUdpInst::DEFAULT_HEARTBEAT_PERIOD_SEC = 1

static

Definition at line 35 of file RtpsUdpInst.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::check_heartbeats(), OpenDDS::DCPS::RtpsUdpTransport::make_datalink(), OpenDDS::DCPS::RtpsUdpDataLink::register_for_reader(), OpenDDS::DCPS::RtpsUdpDataLink::register_for_writer(), OpenDDS::DCPS::RtpsUdpTransport::rtps_relay_address_change(), OpenDDS::DCPS::RtpsUdpTransport::rtps_relay_only_now(), and OpenDDS::DCPS::RtpsUdpTransport::use_rtps_relay_now().

◆ DEFAULT_NAK_RESPONSE_DELAY_USEC

const suseconds_t OpenDDS::DCPS::RtpsUdpInst::DEFAULT_NAK_RESPONSE_DELAY_USEC = 200000

static

Definition at line 34 of file RtpsUdpInst.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_nackfrag().

◆ heartbeat_period_

TimeDuration OpenDDS::DCPS::RtpsUdpInst::heartbeat_period_

Definition at line 48 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ local_address_

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::local_address_

private

Definition at line 164 of file RtpsUdpInst.h.

◆ max_message_size_

size_t OpenDDS::DCPS::RtpsUdpInst::max_message_size_

Definition at line 45 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ multicast_group_address_

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::multicast_group_address_

private

Definition at line 163 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and populate_locator().

◆ multicast_interface_

OPENDDS_STRING OpenDDS::DCPS::RtpsUdpInst::multicast_interface_

Definition at line 42 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ nak_depth_

size_t OpenDDS::DCPS::RtpsUdpInst::nak_depth_

Definition at line 46 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ nak_response_delay_

TimeDuration OpenDDS::DCPS::RtpsUdpInst::nak_response_delay_

Definition at line 47 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ opendds_discovery_default_listener_

TransportReceiveListener_rch OpenDDS::DCPS::RtpsUdpInst::opendds_discovery_default_listener_

private

Definition at line 160 of file RtpsUdpInst.h.

◆ opendds_discovery_guid_

GUID_t OpenDDS::DCPS::RtpsUdpInst::opendds_discovery_guid_

private

Definition at line 161 of file RtpsUdpInst.h.

◆ rcv_buffer_size_

ACE_INT32 OpenDDS::DCPS::RtpsUdpInst::rcv_buffer_size_

Definition at line 38 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ receive_address_duration_

TimeDuration OpenDDS::DCPS::RtpsUdpInst::receive_address_duration_

Definition at line 49 of file RtpsUdpInst.h.

◆ responsive_mode_

bool OpenDDS::DCPS::RtpsUdpInst::responsive_mode_

Definition at line 50 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ rtps_relay_address_

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::rtps_relay_address_

private

Definition at line 175 of file RtpsUdpInst.h.

◆ rtps_relay_only_

bool OpenDDS::DCPS::RtpsUdpInst::rtps_relay_only_

private

Definition at line 173 of file RtpsUdpInst.h.

Referenced by load().

◆ send_buffer_size_

ACE_INT32 OpenDDS::DCPS::RtpsUdpInst::send_buffer_size_

Definition at line 37 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ send_delay_

TimeDuration OpenDDS::DCPS::RtpsUdpInst::send_delay_

Definition at line 51 of file RtpsUdpInst.h.

Referenced by load().

◆ stun_server_address_

NetworkAddress OpenDDS::DCPS::RtpsUdpInst::stun_server_address_

private

Definition at line 177 of file RtpsUdpInst.h.

◆ ttl_

unsigned char OpenDDS::DCPS::RtpsUdpInst::ttl_

Definition at line 41 of file RtpsUdpInst.h.

Referenced by dump_to_str(), and load().

◆ use_ice_

bool OpenDDS::DCPS::RtpsUdpInst::use_ice_

private

Definition at line 176 of file RtpsUdpInst.h.

Referenced by load().

◆ use_multicast_

bool OpenDDS::DCPS::RtpsUdpInst::use_multicast_

Definition at line 40 of file RtpsUdpInst.h.

Referenced by dump_to_str(), load(), and populate_locator().

◆ use_rtps_relay_

bool OpenDDS::DCPS::RtpsUdpInst::use_rtps_relay_

private

Definition at line 174 of file RtpsUdpInst.h.

Referenced by load().

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

Private Attributes
TransportReceiveListener_rch	opendds_discovery_default_listener_

GUID_t	opendds_discovery_guid_

NetworkAddress	multicast_group_address_

NetworkAddress	local_address_

NetworkAddress	advertised_address_

ACE_SYNCH_MUTEX	config_lock_

bool	rtps_relay_only_

bool	use_rtps_relay_

NetworkAddress	rtps_relay_address_

bool	use_ice_

NetworkAddress	stun_server_address_

Public Member Functions

Public Attributes

Static Public Attributes

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ RtpsUdpInst()

Member Function Documentation

◆ advertised_address() [1/2]

◆ advertised_address() [2/2]

◆ append_transport_statistics()

◆ dump_to_str()

◆ get_blob()

◆ get_last_recv_locator()

◆ is_reliable()

◆ load()

◆ local_address() [1/2]

◆ local_address() [2/2]

◆ multicast_group_address() [1/2]

◆ multicast_group_address() [2/2]

◆ new_impl()

◆ populate_locator()

◆ requires_cdr_encapsulation()

◆ rtps_relay_address() [1/2]

◆ rtps_relay_address() [2/2]

◆ rtps_relay_address_change()

◆ rtps_relay_only() [1/2]

◆ rtps_relay_only() [2/2]

◆ stun_server_address() [1/2]

◆ stun_server_address() [2/2]

◆ update_locators()

◆ use_ice() [1/2]

◆ use_ice() [2/2]

◆ use_rtps_relay() [1/2]

◆ use_rtps_relay() [2/2]

Friends And Related Function Documentation

◆ OpenDDS::DCPS::make_rch

◆ RTPS::Sedp

◆ RtpsUdpTransport

◆ RtpsUdpType

Member Data Documentation

◆ advertised_address_

◆ anticipated_fragments_

◆ config_lock_

◆ DEFAULT_HEARTBEAT_PERIOD_SEC

◆ DEFAULT_NAK_RESPONSE_DELAY_USEC

◆ heartbeat_period_

◆ local_address_

◆ max_message_size_

◆ multicast_group_address_

◆ multicast_interface_

◆ nak_depth_

◆ nak_response_delay_

◆ opendds_discovery_default_listener_

◆ opendds_discovery_guid_

◆ rcv_buffer_size_

◆ receive_address_duration_

◆ responsive_mode_

◆ rtps_relay_address_

◆ rtps_relay_only_

◆ send_buffer_size_

◆ send_delay_

◆ stun_server_address_

◆ ttl_

◆ use_ice_

◆ use_multicast_

◆ use_rtps_relay_