OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat Struct Reference

Inheritance diagram for OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat:

[legend]Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat:

[legend]List of all members.

Public Member Functions
	HeartBeat (ACE_Reactor *reactor, ACE_thread_t owner, RtpsUdpDataLink *outer, PMF function)
void	schedule_enable ()
int	handle_timeout (const ACE_Time_Value &, const void *)
bool	reactor_is_shut_down () const
void	enable ()
void	disable ()
Public Attributes
RtpsUdpDataLink *	outer_
PMF	function_
bool	enabled_
Classes
struct	ScheduleEnableCommand

---

Detailed Description

Definition at line 376 of file RtpsUdpDataLink.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::HeartBeat	(	ACE_Reactor *	reactor,
		ACE_thread_t	owner,
		RtpsUdpDataLink *	outer,
		PMF	function
	)			[inline, explicit]

Definition at line 378 of file RtpsUdpDataLink.h.

      : ReactorInterceptor(reactor, owner)
      , outer_(outer)
      , function_(function)
      , enabled_(false) {}

---

Member Function Documentation

void OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::disable

(

)

Definition at line 2544 of file RtpsUdpDataLink.cpp.

References enabled_, OpenDDS::DCPS::RtpsUdpDataLink::get_reactor(), and outer_.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), and OpenDDS::DCPS::RtpsUdpDataLink::stop_i().

{
  if (enabled_) {
    outer_->get_reactor()->cancel_timer(this);
    enabled_ = false;
  }
}

void OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::enable

(

)

Definition at line 2527 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::RtpsUdpDataLink::config_, enabled_, OpenDDS::DCPS::RtpsUdpDataLink::get_reactor(), OpenDDS::DCPS::RtpsUdpInst::heartbeat_period_, and outer_.

{
  if (!enabled_) {
    const ACE_Time_Value& per = outer_->config_->heartbeat_period_;
    const long timer =
      outer_->get_reactor()->schedule_timer(this, 0, ACE_Time_Value::zero, per);

    if (timer == -1) {
      ACE_DEBUG((LM_ERROR, "(%P|%t) RtpsUdpDataLink::HeartBeat::enable"
        " failed to schedule timer %p\n", ACE_TEXT("")));
    } else {
      enabled_ = true;
    }
  }
}

int OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::handle_timeout	(	const ACE_Time_Value &	,
		const void *
	)			[inline]

Definition at line 390 of file RtpsUdpDataLink.h.

    {
      (outer_->*function_)();
      return 0;
    }

bool OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::reactor_is_shut_down

(

)

const [inline, virtual]

Implements OpenDDS::DCPS::ReactorInterceptor.

Definition at line 396 of file RtpsUdpDataLink.h.

    {
      return outer_->reactor_is_shut_down();
    }

void OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::schedule_enable

(

)

[inline]

Definition at line 384 of file RtpsUdpDataLink.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::associated(), OpenDDS::DCPS::RtpsUdpDataLink::register_for_reader(), and OpenDDS::DCPS::RtpsUdpDataLink::register_for_writer().

    {
      ScheduleEnableCommand c(this);
      execute_or_enqueue(c);
    }

---

Member Data Documentation

bool OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::enabled_

Definition at line 406 of file RtpsUdpDataLink.h.

Referenced by disable(), and enable().

PMF OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::function_

Definition at line 405 of file RtpsUdpDataLink.h.

RtpsUdpDataLink* OpenDDS::DCPS::RtpsUdpDataLink::HeartBeat::outer_

Definition at line 404 of file RtpsUdpDataLink.h.

Referenced by disable(), and enable().

---

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

• RtpsUdpDataLink.h
• RtpsUdpDataLink.cpp

---