OpenDDS::DCPS::NakWatchdog Class Reference

#include <ReliableSession.h>

Inheritance diagram for OpenDDS::DCPS::NakWatchdog:

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

[legend]List of all members.

Public Member Functions
	NakWatchdog (ACE_Reactor *reactor, ACE_thread_t owner, ReliableSession *session)
virtual bool	reactor_is_shut_down () const
Protected Member Functions
virtual ACE_Time_Value	next_interval ()
virtual void	on_interval (const void *arg)
Private Member Functions
	~NakWatchdog ()
Private Attributes
ReliableSession *	session_

---

Detailed Description

Definition at line 26 of file ReliableSession.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::NakWatchdog::NakWatchdog	(	ACE_Reactor *	reactor,
		ACE_thread_t	owner,
		ReliableSession *	session
	)			[explicit]

Definition at line 26 of file ReliableSession.cpp.

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

OpenDDS::DCPS::NakWatchdog::~NakWatchdog

(

)

[inline, private]

Definition at line 40 of file ReliableSession.h.

{ }

---

Member Function Documentation

ACE_Time_Value OpenDDS::DCPS::NakWatchdog::next_interval

(

)

[protected, virtual]

Implements OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 35 of file ReliableSession.cpp.

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

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

  // Apply random backoff to minimize potential collisions:
  interval *= static_cast<double>(std::rand()) /
              static_cast<double>(RAND_MAX) + 1.0;

  return interval;
}

void OpenDDS::DCPS::NakWatchdog::on_interval

(

const void *

arg

)

[protected, virtual]

Implements OpenDDS::DCPS::DataLinkWatchdog.

Definition at line 48 of file ReliableSession.cpp.

References OpenDDS::DCPS::ReliableSession::expire_naks(), OpenDDS::DCPS::ReliableSession::send_naks(), and session_.

{
  // Expire outstanding repair requests that have not yet been
  // fulfilled; this prevents NAK implosions due to remote
  // peers becoming unresponsive:
  this->session_->expire_naks();

  // Initiate repairs by sending MULTICAST_NAK control samples
  // to remote peers from which we are missing data:
  this->session_->send_naks();
}

bool OpenDDS::DCPS::NakWatchdog::reactor_is_shut_down

(

)

const [virtual]

Implements OpenDDS::DCPS::ReactorInterceptor.

Definition at line 77 of file ReliableSession.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

ReliableSession* OpenDDS::DCPS::NakWatchdog::session_ [private]

Definition at line 41 of file ReliableSession.h.

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

---

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

• ReliableSession.h
• ReliableSession.cpp

---