OpenDDS::RTPS::Spdp::SendStun Class Reference

Inheritance diagram for OpenDDS::RTPS::Spdp::SendStun:

Collaboration diagram for OpenDDS::RTPS::Spdp::SendStun:

Public Member Functions
	SendStun (const DCPS::RcHandle< SpdpTransport > &tport, const ACE_INET_Addr &address, const STUN::Message &message)
void	execute ()
Public Member Functions inherited from OpenDDS::DCPS::Job
virtual	~Job ()
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
DCPS::WeakRcHandle< SpdpTransport >	tport_
ACE_INET_Addr	address_
STUN::Message	message_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 559 of file Spdp.h.

Constructor & Destructor Documentation

SendStun()

OpenDDS::RTPS::Spdp::SendStun::SendStun ( const DCPS::RcHandle< SpdpTransport > &  tport, const ACE_INET_Addr &  address, const STUN::Message &  message  )

inline

Definition at line 561 of file Spdp.h.

      : tport_(tport)
      , address_(address)
      , message_(message)
    {}

Member Function Documentation

execute()

void OpenDDS::RTPS::Spdp::SendStun::execute ( void  )

virtual

Implements OpenDDS::DCPS::Job.

Definition at line 3302 of file Spdp.cpp.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::STUN::encoding(), ENETUNREACH, if(), LM_WARNING, OpenDDS::DCPS::MCK_STUN, OpenDDS::DCPS::RcHandle< T >::reset(), ACE_SOCK_Dgram::send(), socket(), and OpenDDS::RTPS::Spdp::tport_.

{
  DCPS::RcHandle<SpdpTransport> tport = tport_.lock();
  if (!tport) return;

  DCPS::RcHandle<Spdp> outer = tport->outer_.lock();
  if (!outer) return;

  ACE_GUARD(ACE_Thread_Mutex, g, outer->lock_);
  tport->wbuff_.reset();
  Serializer serializer(&tport->wbuff_, STUN::encoding);
  const_cast<STUN::Message&>(message_).block = &tport->wbuff_;
  serializer << message_;

#ifdef OPENDDS_TESTING_FEATURES
  if (outer->sedp_->transport_inst()->should_drop(tport->wbuff_.length())) {
    return;
  }
#endif

  const ACE_SOCK_Dgram& socket = tport->choose_send_socket(address_);
  const ssize_t res = socket.send(tport->wbuff_.rd_ptr(), tport->wbuff_.length(), address_);
  if (res < 0) {
    if (outer->sedp_->transport_inst()->count_messages()) {
      // Have the lock.
      const DCPS::InternalMessageCountKey key(DCPS::NetworkAddress(address_), DCPS::MCK_STUN, address_ == outer->config_->spdp_stun_server_address());
      tport->transport_statistics_.message_count[key].send_fail(tport->wbuff_.length());
    }
    const int err = errno;
    if (err != ENETUNREACH || !tport->network_is_unreachable_) {
      errno = err;
      if (DCPS::DCPS_debug_level > 0) {
        ACE_ERROR((LM_WARNING,
                  ACE_TEXT("(%P|%t) WARNING: Spdp::SendStun::execute() - ")
                  ACE_TEXT("destination %C failed send: %m\n"), DCPS::LogAddr(address_).c_str()));
      }
    }
    if (err == ENETUNREACH) {
      tport->network_is_unreachable_ = true;
    }
  } else {
    if (outer->sedp_->transport_inst()->count_messages()) {
      // Have the lock.
      const DCPS::InternalMessageCountKey key(DCPS::NetworkAddress(address_), DCPS::MCK_STUN, address_ == outer->config_->spdp_stun_server_address());
      tport->transport_statistics_.message_count[key].send(tport->wbuff_.length());
    }
    tport->network_is_unreachable_ = false;
  }
}

Member Data Documentation

address_

ACE_INET_Addr OpenDDS::RTPS::Spdp::SendStun::address_

private

Definition at line 571 of file Spdp.h.

message_

STUN::Message OpenDDS::RTPS::Spdp::SendStun::message_

private

Definition at line 572 of file Spdp.h.

tport_

DCPS::WeakRcHandle<SpdpTransport> OpenDDS::RTPS::Spdp::SendStun::tport_

private

Definition at line 570 of file Spdp.h.

---

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

• Spdp.h
• Spdp.cpp