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.

Classes
struct	ScheduleEnableCommand
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_

---

Detailed Description

Definition at line 406 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 408 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 2791 of file RtpsUdpDataLink.cpp.

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

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

Here is the call graph for this function:

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

(

)

Definition at line 2774 of file RtpsUdpDataLink.cpp.

References ACE_TEXT(), OpenDDS::DCPS::RtpsUdpDataLink::config(), enabled_, OpenDDS::DCPS::RtpsUdpDataLink::get_reactor(), OpenDDS::DCPS::RtpsUdpInst::heartbeat_period_, LM_ERROR, outer_, ACE_Reactor::schedule_timer(), and ACE_Time_Value::zero.

{
  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_ERROR((LM_ERROR, "(%P|%t) RtpsUdpDataLink::HeartBeat::enable"
        " failed to schedule timer %p\n", ACE_TEXT("")));
    } else {
      enabled_ = true;
    }
  }
}

Here is the call graph for this function:

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

Reimplemented from ACE_Event_Handler.

Definition at line 420 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 426 of file RtpsUdpDataLink.h.

    {
      return outer_->reactor_is_shut_down();
    }

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

(

)

[inline]

Definition at line 414 of file RtpsUdpDataLink.h.

References c.

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

---

Member Data Documentation

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

Definition at line 436 of file RtpsUdpDataLink.h.

Referenced by disable(), and enable().

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

Definition at line 435 of file RtpsUdpDataLink.h.

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

Definition at line 434 of file RtpsUdpDataLink.h.

Referenced by disable(), and enable().

---

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

• RtpsUdpDataLink.h
• RtpsUdpDataLink.cpp