OpenDDS::DCPS::SynWatchdog Class Reference

#include <MulticastSession.h>

Inheritance diagram for OpenDDS::DCPS::SynWatchdog:

[legend]Collaboration diagram for OpenDDS::DCPS::SynWatchdog:

[legend]List of all members.

Public Member Functions
	SynWatchdog (ACE_Reactor *reactor, ACE_thread_t owner, MulticastSession *session)
virtual bool	reactor_is_shut_down () const
Protected Member Functions
virtual ACE_Time_Value	next_interval ()
virtual void	on_interval (const void *arg)
virtual ACE_Time_Value	next_timeout ()
virtual void	on_timeout (const void *arg)
Private Member Functions
	~SynWatchdog ()
Private Attributes
MulticastSession *	session_
size_t	retries_

---

Detailed Description

Definition at line 33 of file MulticastSession.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::SynWatchdog::SynWatchdog	(	ACE_Reactor *	reactor,
		ACE_thread_t	owner,
		MulticastSession *	session
	)			[explicit]

Definition at line 19 of file MulticastSession.cpp.

  : DataLinkWatchdog (reactor, owner)
  , session_(session)
  , retries_(0)
{
}

OpenDDS::DCPS::SynWatchdog::~SynWatchdog

(

)

[inline, private]

Definition at line 50 of file MulticastSession.h.

{ }

---

Member Function Documentation

ACE_Time_Value OpenDDS::DCPS::SynWatchdog::next_interval

(

)

[protected, virtual]

Implements OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 35 of file MulticastSession.cpp.

References OpenDDS::DCPS::MulticastDataLink::config(), OpenDDS::DCPS::MulticastSession::link(), retries_, session_, OpenDDS::DCPS::MulticastInst::syn_backoff_, and OpenDDS::DCPS::MulticastInst::syn_interval_.

{
  MulticastInst* config = this->session_->link()->config();
  ACE_Time_Value interval(config->syn_interval_);

  // Apply exponential backoff based on number of retries:
  if (this->retries_ > 0) {
    interval *= std::pow(config->syn_backoff_, double(this->retries_));
  }
  ++this->retries_;

  return interval;
}

ACE_Time_Value OpenDDS::DCPS::SynWatchdog::next_timeout

(

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 58 of file MulticastSession.cpp.

References OpenDDS::DCPS::MulticastDataLink::config(), OpenDDS::DCPS::MulticastSession::link(), session_, and OpenDDS::DCPS::MulticastInst::syn_timeout_.

{
  MulticastInst* config = this->session_->link()->config();
  return config->syn_timeout_;
}

void OpenDDS::DCPS::SynWatchdog::on_interval

(

const void *

arg

)

[protected, virtual]

Implements OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 50 of file MulticastSession.cpp.

References OpenDDS::DCPS::MulticastSession::send_syn(), and session_.

{
  // Initiate handshake by sending a MULTICAST_SYN control
  // sample to the assigned remote peer:
  this->session_->send_syn();
}

void OpenDDS::DCPS::SynWatchdog::on_timeout

(

const void *

arg

)

[protected, virtual]

Reimplemented from OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 65 of file MulticastSession.cpp.

References OpenDDS::DCPS::MulticastSession::link(), OpenDDS::DCPS::MulticastDataLink::local_peer(), OpenDDS::DCPS::MulticastSession::remote_peer(), and session_.

{
  // There is no recourse if a link is unable to handshake;
  // log an error and return:
  ACE_ERROR((LM_WARNING,
             ACE_TEXT("(%P|%t) WARNING: ")
             ACE_TEXT("SynWatchdog[transport=%C]::on_timeout: ")
             ACE_TEXT("timed out waiting on remote peer: %#08x%08x local: %#08x%08x\n"),
             this->session_->link()->config()->name().c_str(),
             (unsigned int)(this->session_->remote_peer() >> 32),
             (unsigned int) this->session_->remote_peer(),
             (unsigned int)(this->session_->link()->local_peer() >> 32),
             (unsigned int) this->session_->link()->local_peer()));
}

bool OpenDDS::DCPS::SynWatchdog::reactor_is_shut_down

(

)

const [virtual]

Implements OpenDDS::DCPS::ReactorInterceptor.

Definition at line 29 of file MulticastSession.cpp.

References OpenDDS::DCPS::TransportImpl::is_shut_down(), OpenDDS::DCPS::MulticastSession::link(), session_, and OpenDDS::DCPS::MulticastDataLink::transport().

{
  return session_->link()->transport()->is_shut_down();
}

---

Member Data Documentation

size_t OpenDDS::DCPS::SynWatchdog::retries_ [private]

Definition at line 52 of file MulticastSession.h.

Referenced by next_interval().

MulticastSession* OpenDDS::DCPS::SynWatchdog::session_ [private]

Definition at line 51 of file MulticastSession.h.

Referenced by next_interval(), next_timeout(), on_interval(), on_timeout(), and reactor_is_shut_down().

---

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

• MulticastSession.h
• MulticastSession.cpp

---