OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint Struct Reference

Inheritance diagram for OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint:

Collaboration diagram for OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint:

Public Member Functions
	IceEndpoint (RtpsUdpTransport &a_transport)
const ACE_SOCK_Dgram &	choose_recv_socket (ACE_HANDLE fd) const
virtual int	handle_input (ACE_HANDLE fd)
virtual ICE::AddressListType	host_addresses () const
ACE_SOCK_Dgram &	choose_send_socket (const ACE_INET_Addr &address) const
virtual void	send (const ACE_INET_Addr &address, const STUN::Message &message)
virtual ACE_INET_Addr	stun_server_address () const
Public Member Functions inherited from ACE_Event_Handler
virtual	~ACE_Event_Handler (void)
virtual ACE_HANDLE	get_handle (void) const
virtual void	set_handle (ACE_HANDLE)
virtual int	priority (void) const
virtual void	priority (int priority)
virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
virtual int	handle_exit (ACE_Process *)
virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
virtual int	handle_signal (int signum, siginfo_t *=0, ucontext_t *=0)
virtual int	resume_handler (void)
virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual void	reactor (ACE_Reactor *reactor)
virtual ACE_Reactor *	reactor (void) const
virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const
virtual Reference_Count	add_reference (void)
virtual Reference_Count	remove_reference (void)
Reference_Counting_Policy &	reference_counting_policy (void)
Public Member Functions inherited from OpenDDS::ICE::Endpoint
virtual	~Endpoint ()
virtual void	ice_connect (const GuidSetType &, const ACE_INET_Addr &)
virtual void	ice_disconnect (const GuidSetType &, const ACE_INET_Addr &)
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
RtpsUdpTransport &	transport
bool	network_is_unreachable_
Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY
	HI_PRIORITY
	NULL_MASK
	READ_MASK
	WRITE_MASK
	EXCEPT_MASK
	ACCEPT_MASK
	CONNECT_MASK
	TIMER_MASK
	QOS_MASK
	GROUP_QOS_MASK
	SIGNAL_MASK
	ALL_EVENTS_MASK
	RWE_MASK
	DONT_CALL
	ACE_EVENT_HANDLER_NOT_RESUMED
	ACE_REACTOR_RESUMES_HANDLER
	ACE_APPLICATION_RESUMES_HANDLER

Additional Inherited Members
Public Types inherited from ACE_Event_Handler
typedef long	Reference_Count
Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)
static int	register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)
static int	remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)
Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count
Protected Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

Definition at line 161 of file RtpsUdpTransport.h.

Constructor & Destructor Documentation

IceEndpoint()

OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::IceEndpoint ( RtpsUdpTransport &  a_transport )

inline

Definition at line 164 of file RtpsUdpTransport.h.

References send().

      : transport(a_transport)
      , network_is_unreachable_(false)
    {}

Member Function Documentation

choose_recv_socket()

const ACE_SOCK_Dgram & OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::choose_recv_socket

(

ACE_HANDLE

fd

)

const

Definition at line 762 of file RtpsUdpTransport.cpp.

{
#ifdef ACE_HAS_IPV6
  if (fd == transport.ipv6_unicast_socket_.get_handle()) {
    return transport.ipv6_unicast_socket_;
  }
#endif
  ACE_UNUSED_ARG(fd);
  return transport.unicast_socket_;
}

choose_send_socket()

ACE_SOCK_Dgram & OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::choose_send_socket

(

const ACE_INET_Addr &

address

)

const

Definition at line 900 of file RtpsUdpTransport.cpp.

References ACE_Addr::get_type().

{
#ifdef ACE_HAS_IPV6
  if (destination.get_type() == AF_INET6) {
    return transport.link_ ? transport.link_->ipv6_unicast_socket() : transport.ipv6_unicast_socket_;
  }
#endif

  ACE_UNUSED_ARG(destination);
  return transport.link_ ? transport.link_->unicast_socket() : transport.unicast_socket_;
}

handle_input()

int OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::handle_input ( ACE_HANDLE  fd )

virtual

Reimplemented from ACE_Event_Handler.

Definition at line 774 of file RtpsUdpTransport.cpp.

References ACE_ERROR, ACE_TEXT(), code, OpenDDS::DCPS::RtpsUdpTransport::config(), EADDRNOTAVAIL, ENETUNREACH, ENOBUFS, EPERM, LM_ERROR, LM_WARNING, OPENDDS_ASSERT, OpenDDS::DCPS::RtpsUdpReceiveStrategy::receive_bytes_helper(), ACE_SOCK_Dgram::send(), socket(), and TheServiceParticipant.

{
  ThreadStatusManager::Event ev(TheServiceParticipant->get_thread_status_manager());

  struct iovec iov[1];
  char buffer[0x10000];
  iov[0].iov_base = buffer;
  iov[0].iov_len = sizeof buffer;
  ACE_INET_Addr remote_address;

  bool stop;
  RtpsUdpReceiveStrategy::receive_bytes_helper(iov, 1, choose_recv_socket(fd), remote_address,
#ifdef OPENDDS_SECURITY
                                               transport.get_ice_agent(), transport.get_ice_endpoint(),
#endif
                                               transport, stop);

  return 0;
}

host_addresses()

ICE::AddressListType OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::host_addresses ( ) const

virtual

Implements OpenDDS::ICE::Endpoint.

Definition at line 853 of file RtpsUdpTransport.cpp.

References AF_INET, OpenDDS::DCPS::get_interface_addrs(), ACE_INET_Addr::get_port_number(), and ACE_INET_Addr::is_any().

                                                  {
  ICE::AddressListType addresses;

  RtpsUdpInst_rch cfg = transport.config();

  if (!cfg) {
    return addresses;
  }

  ACE_INET_Addr addr = cfg->local_address().to_addr();
  if (addr != ACE_INET_Addr()) {
    if (addr.is_any()) {
      ICE::AddressListType addrs;
      DCPS::get_interface_addrs(addrs);
      for (ICE::AddressListType::iterator pos = addrs.begin(), limit = addrs.end(); pos != limit; ++pos) {
        if (pos->get_type() == AF_INET) {
          pos->set_port_number(addr.get_port_number());
          addresses.push_back(*pos);
        }
      }
    } else {
      addresses.push_back(addr);
    }
  }

#ifdef ACE_HAS_IPV6
  addr = cfg->ipv6_local_address().to_addr();
  if (addr != ACE_INET_Addr()) {
    if (addr.is_any()) {
      ICE::AddressListType addrs;
      DCPS::get_interface_addrs(addrs);
      for (ICE::AddressListType::iterator pos = addrs.begin(), limit = addrs.end(); pos != limit; ++pos) {
        if (pos->get_type() == AF_INET6) {
          pos->set_port_number(addr.get_port_number());
          addresses.push_back(*pos);
        }
      }
    } else {
      addresses.push_back(addr);
    }
  }
#endif

  return addresses;
}

send()

void OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::send ( const ACE_INET_Addr &  address, const STUN::Message &  message  )

virtual

Implements OpenDDS::ICE::Endpoint.

Definition at line 913 of file RtpsUdpTransport.cpp.

References ACE_ERROR, ACE_GUARD, OpenDDS::STUN::encoding(), OpenDDS::STUN::Message::length(), LM_ERROR, LM_WARNING, OpenDDS::DCPS::MAX_SEND_BLOCKS, OpenDDS::DCPS::TransportSendStrategy::mb_to_iov(), OpenDDS::DCPS::MCK_STUN, and socket().

{
  ACE_SOCK_Dgram& socket = choose_send_socket(destination);

  ACE_Message_Block block(20 + message.length());
  DCPS::Serializer serializer(&block, STUN::encoding);
  const_cast<STUN::Message&>(message).block = &block;
  serializer << message;

  iovec iov[MAX_SEND_BLOCKS];
  const int num_blocks = RtpsUdpSendStrategy::mb_to_iov(block, iov);
  const ssize_t result = send_single_i(transport.config(), socket, iov, num_blocks, destination, network_is_unreachable_);

  RtpsUdpInst_rch cfg = transport.config();
  if (result < 0) {
    if (cfg && cfg->count_messages()) {
      ssize_t bytes = 0;
      for (int i = 0; i < num_blocks; ++i) {
        bytes += iov[i].iov_len;
      }
      const NetworkAddress da(destination);
      const InternalMessageCountKey key(da, MCK_STUN, da == cfg->rtps_relay_address());
      ACE_GUARD(ACE_Thread_Mutex, g, transport.transport_statistics_mutex_);
      transport.transport_statistics_.message_count[key].send_fail(bytes);
    }
    if (!network_is_unreachable_) {
      const ACE_Log_Priority prio = shouldWarn(errno) ? LM_WARNING : LM_ERROR;
      ACE_ERROR((prio, "(%P|%t) RtpsUdpTransport::send() - "
                 "failed to send STUN message\n"));
    }
  } else if (cfg && cfg->count_messages()) {
    const NetworkAddress da(destination);
    const InternalMessageCountKey key(da, MCK_STUN, da == cfg->rtps_relay_address());
    ACE_GUARD(ACE_Thread_Mutex, g, transport.transport_statistics_mutex_);
    transport.transport_statistics_.message_count[key].send(result);
  }
}

stun_server_address()

ACE_INET_Addr OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::stun_server_address ( ) const

virtual

Implements OpenDDS::ICE::Endpoint.

Definition at line 952 of file RtpsUdpTransport.cpp.

                                                       {
  RtpsUdpInst_rch cfg = transport.config();
  return cfg ? cfg->stun_server_address().to_addr() : ACE_INET_Addr();
}

Member Data Documentation

network_is_unreachable_

bool OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::network_is_unreachable_

Definition at line 176 of file RtpsUdpTransport.h.

transport

RtpsUdpTransport& OpenDDS::DCPS::RtpsUdpTransport::IceEndpoint::transport

Definition at line 162 of file RtpsUdpTransport.h.

---

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

• RtpsUdpTransport.h
• RtpsUdpTransport.cpp