OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer Class Reference

Inheritance diagram for OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer:

Collaboration diagram for OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer:

Public Member Functions
	LivelinessTimer (DomainParticipantImpl &impl, DDS::LivelinessQosPolicyKind kind)
virtual	~LivelinessTimer ()
void	add_adjust (OpenDDS::DCPS::DataWriterImpl *writer)
void	remove_adjust ()
void	execute (const MonotonicTimePoint &now)
virtual void	dispatch (const MonotonicTimePoint &tv)=0
virtual void	cancel ()=0
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

Protected Member Functions
TimeDuration	interval () const
virtual void	schedule (const TimeDuration &interval)=0
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Attributes
DomainParticipantImpl &	impl_
const DDS::LivelinessQosPolicyKind	kind_

Private Attributes
TimeDuration	interval_
bool	recalculate_interval_
MonotonicTimePoint	last_liveliness_check_
bool	scheduled_
ACE_Thread_Mutex	lock_

Detailed Description

Definition at line 579 of file DomainParticipantImpl.h.

Constructor & Destructor Documentation

LivelinessTimer()

OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::LivelinessTimer	(	DomainParticipantImpl &	impl,
		DDS::LivelinessQosPolicyKind	kind
	)

Definition at line 2320 of file DomainParticipantImpl.cpp.

  : impl_(impl)
  , kind_(kind)
  , interval_(TimeDuration::max_value)
  , recalculate_interval_(false)
  , scheduled_(false)
{ }

~LivelinessTimer()

OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::~LivelinessTimer ( )

virtual

Definition at line 2329 of file DomainParticipantImpl.cpp.

{
}

Member Function Documentation

add_adjust()

void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::add_adjust

(

OpenDDS::DCPS::DataWriterImpl *

writer

)

Definition at line 2334 of file DomainParticipantImpl.cpp.

References ACE_GUARD, cancel(), interval_, kind_, last_liveliness_check_, OpenDDS::DCPS::DataWriterImpl::liveliness_check_interval(), lock_, OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), schedule(), and scheduled_.

{
  ACE_GUARD(ACE_Thread_Mutex, guard, lock_);

  const MonotonicTimePoint now = MonotonicTimePoint::now();

  // Calculate the time remaining to liveliness check.
  const TimeDuration remaining = interval_ - (now - last_liveliness_check_);

  // Adopt a smaller interval.
  interval_ = std::min(interval_, writer->liveliness_check_interval(kind_));

  // Reschedule or schedule a timer if necessary.
  if (scheduled_ && interval_ < remaining) {
    cancel();
    schedule(interval_);
  } else if (!scheduled_) {
    schedule(interval_);
    scheduled_ = true;
    last_liveliness_check_ = now;
  }
}

cancel()

virtual void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::cancel ( )

pure virtual

Implemented in OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer, and OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer.

Referenced by add_adjust().

dispatch()

virtual void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::dispatch ( const MonotonicTimePoint &  tv )

pure virtual

Implemented in OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer, and OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer.

Referenced by execute().

execute()

void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::execute

(

const MonotonicTimePoint &

now

)

Definition at line 2365 of file DomainParticipantImpl.cpp.

References ACE_GUARD, dispatch(), impl_, interval(), interval_, OpenDDS::DCPS::TimeDuration::is_max(), kind_, last_liveliness_check_, OpenDDS::DCPS::DomainParticipantImpl::liveliness_check_interval(), lock_, recalculate_interval_, schedule(), and scheduled_.

{
  ACE_GUARD(ACE_Thread_Mutex, guard, lock_);

  if (recalculate_interval_) {
    ACE_Reverse_Lock<ACE_Thread_Mutex> rev_lock(lock_);
    TimeDuration interval;
    while (recalculate_interval_) {
      recalculate_interval_ = false;
      ACE_GUARD(ACE_Reverse_Lock<ACE_Thread_Mutex>, rev_guard, rev_lock);
      interval = impl_.liveliness_check_interval(kind_);
    }
    interval_ = interval;
  }

  scheduled_ = false;

  if (!interval_.is_max()) {
    dispatch(now);
    last_liveliness_check_ = now;
    schedule(interval_);
    scheduled_ = true;
  }
}

interval()

TimeDuration OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::interval ( void  ) const

inlineprotected

Definition at line 593 of file DomainParticipantImpl.h.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer::dispatch(), and execute().

{ return interval_; }

remove_adjust()

void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::remove_adjust

(

)

Definition at line 2358 of file DomainParticipantImpl.cpp.

References ACE_GUARD, lock_, and recalculate_interval_.

{
  ACE_GUARD(ACE_Thread_Mutex, guard, lock_);

  recalculate_interval_ = true;
}

schedule()

virtual void OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::schedule ( const TimeDuration &  interval )

protectedpure virtual

Implemented in OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer, and OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer.

Referenced by add_adjust(), and execute().

Member Data Documentation

impl_

DomainParticipantImpl& OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::impl_

protected

Definition at line 590 of file DomainParticipantImpl.h.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer::dispatch(), OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer::dispatch(), and execute().

interval_

TimeDuration OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::interval_

private

Definition at line 598 of file DomainParticipantImpl.h.

Referenced by add_adjust(), and execute().

kind_

const DDS::LivelinessQosPolicyKind OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::kind_

protected

Definition at line 591 of file DomainParticipantImpl.h.

Referenced by add_adjust(), OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer::dispatch(), OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer::dispatch(), and execute().

last_liveliness_check_

MonotonicTimePoint OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::last_liveliness_check_

private

Definition at line 600 of file DomainParticipantImpl.h.

Referenced by add_adjust(), and execute().

lock_

ACE_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::lock_

private

Definition at line 602 of file DomainParticipantImpl.h.

Referenced by add_adjust(), execute(), and remove_adjust().

recalculate_interval_

bool OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::recalculate_interval_

private

Definition at line 599 of file DomainParticipantImpl.h.

Referenced by execute(), and remove_adjust().

scheduled_

bool OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::scheduled_

private

Definition at line 601 of file DomainParticipantImpl.h.

Referenced by add_adjust(), and execute().

---

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

• DomainParticipantImpl.h
• DomainParticipantImpl.cpp