core::TimerEventReceiver Class Reference

#include <TimerEventReceiver.h>

Inheritance diagram for core::TimerEventReceiver:

Collaboration diagram for core::TimerEventReceiver:

Public Member Functions
	TimerEventReceiver (const TimerEventReceiver &)=delete
TimerEventReceiver &	operator= (const TimerEventReceiver &)=delete
void	restart ()
Public Member Functions inherited from core::EventReceiver
	EventReceiver (const std::string &name)
	EventReceiver (EventReceiver &)=delete
	EventReceiver (EventReceiver &&)=delete
EventReceiver &	operator= (EventReceiver &)=delete
EventReceiver &	operator= (EventReceiver &&)=delete
virtual void	destruct ()
void	span ()
void	relax ()
const std::string &	getName () const

Protected Member Functions
	TimerEventReceiver (const std::string &name, const utils::Timeval &delay)
	~TimerEventReceiver () override
utils::Timeval	getTimeoutAbsolut () const
utils::Timeval	getTimeoutRelative (const utils::Timeval &currentTime) const
void	enable ()
void	update ()
void	cancel ()
Protected Member Functions inherited from core::EventReceiver
virtual	~EventReceiver ()=default

Private Member Functions
void	onEvent (const utils::Timeval &currentTime) final
virtual void	dispatchEvent ()=0
virtual void	unobservedEvent ()=0
void	setTimer (Timer *timer)

Private Attributes
TimerEventPublisher &	timerEventPublisher
Timer *	timer = nullptr
utils::Timeval	absoluteTimeout
utils::Timeval	delay

Friends
class	Timer
class	TimerEventPublisher

Additional Inherited Members
Static Public Member Functions inherited from core::EventReceiver
static void	atNextTick (const std::function< void(void)> &callBack)

Detailed Description

Definition at line 40 of file TimerEventReceiver.h.

Constructor & Destructor Documentation

TimerEventReceiver() [1/2]

core::TimerEventReceiver::TimerEventReceiver ( const TimerEventReceiver & )

delete

TimerEventReceiver() [2/2]

core::TimerEventReceiver::TimerEventReceiver ( const std::string & name, const utils::Timeval & delay )

protected

Definition at line 35 of file TimerEventReceiver.cpp.

        : EventReceiver(name)
        , timerEventPublisher(EventLoop::instance().getEventMultiplexer().getTimerEventPublisher())
        , absoluteTimeout(utils::Timeval::currentTime() + delay)
        , delay(delay) {
    }

Referenced by core::timer::IntervalTimer::IntervalTimer(), core::timer::IntervalTimerStopable::IntervalTimerStopable(), and core::timer::SingleshotTimer::SingleshotTimer().

Here is the caller graph for this function:

~TimerEventReceiver()

core::TimerEventReceiver::~TimerEventReceiver ( )

overrideprotected

Definition at line 48 of file TimerEventReceiver.cpp.

                                            {
        if (timer != nullptr) {
            timer->removeTimerEventReceiver();
        }
    }

Member Function Documentation

cancel()

void core::TimerEventReceiver::cancel ( )

protected

Definition at line 77 of file TimerEventReceiver.cpp.

                                    {
        timerEventPublisher.remove(this);
    }

Referenced by core::Timer::cancel(), and core::timer::SingleshotTimer::dispatchEvent().

Here is the caller graph for this function:

dispatchEvent()

virtual void core::TimerEventReceiver::dispatchEvent ( )

privatepure virtual

Implemented in core::timer::IntervalTimer, core::timer::IntervalTimerStopable, and core::timer::SingleshotTimer.

enable()

void core::TimerEventReceiver::enable ( )

protected

Definition at line 62 of file TimerEventReceiver.cpp.

                                    {
        if (core::eventLoopState() != core::State::STOPPING) {
            timerEventPublisher.insert(this);
        } else {
            LOG(WARNING) << "TimerEventReceiver - Enable after signal: Not enabled";
            delete this;
        }
    }

Referenced by core::Timer::Timer().

Here is the caller graph for this function:

getTimeoutAbsolut()

utils::Timeval core::TimerEventReceiver::getTimeoutAbsolut ( ) const

protected

Definition at line 54 of file TimerEventReceiver.cpp.

                                                             {
        return absoluteTimeout;
    }

Referenced by core::TimerEventPublisher::timernode_lt::operator()().

Here is the caller graph for this function:

getTimeoutRelative()

utils::Timeval core::TimerEventReceiver::getTimeoutRelative ( const utils::Timeval & currentTime ) const

protected

Definition at line 58 of file TimerEventReceiver.cpp.

                                                                                             {
        return absoluteTimeout > currentTime ? absoluteTimeout - currentTime : 0;
    }

onEvent()

void core::TimerEventReceiver::onEvent ( const utils::Timeval & currentTime )

finalprivatevirtual

Implements core::EventReceiver.

Definition at line 81 of file TimerEventReceiver.cpp.

                                                                    {
        LOG(TRACE) << "TimerEventReceiver: Dispatch delta = " << (currentTime - getTimeoutAbsolut()).getMsd() << " ms";
 
        dispatchEvent();
    }

operator=()

TimerEventReceiver & core::TimerEventReceiver::operator= ( const TimerEventReceiver & )

delete

restart()

void core::TimerEventReceiver::restart

(

)

Definition at line 42 of file TimerEventReceiver.cpp.

                                     {
        timerEventPublisher.erase(this);
        absoluteTimeout = utils::Timeval::currentTime() + delay;
        timerEventPublisher.insert(this);
    }

Referenced by core::Timer::restart().

Here is the caller graph for this function:

setTimer()

void core::TimerEventReceiver::setTimer ( Timer * timer )

private

Definition at line 87 of file TimerEventReceiver.cpp.

                                                  {
        this->timer = timer;
    }

Referenced by core::Timer::operator=(), core::Timer::Timer(), core::Timer::Timer(), and core::Timer::~Timer().

Here is the caller graph for this function:

unobservedEvent()

virtual void core::TimerEventReceiver::unobservedEvent ( )

privatepure virtual

Implemented in core::timer::IntervalTimer, core::timer::IntervalTimerStopable, and core::timer::SingleshotTimer.

update()

void core::TimerEventReceiver::update ( )

protected

Definition at line 71 of file TimerEventReceiver.cpp.

                                    {
        timerEventPublisher.erase(this);
        absoluteTimeout += delay;
        timerEventPublisher.insert(this);
    }

Referenced by core::timer::IntervalTimer::dispatchEvent(), and core::timer::IntervalTimerStopable::dispatchEvent().

Here is the caller graph for this function:

Friends And Related Symbol Documentation

Timer

friend class Timer

friend

Definition at line 73 of file TimerEventReceiver.h.

TimerEventPublisher

friend class TimerEventPublisher

friend

Definition at line 74 of file TimerEventReceiver.h.

Member Data Documentation

absoluteTimeout

utils::Timeval core::TimerEventReceiver::absoluteTimeout

private

Definition at line 70 of file TimerEventReceiver.h.

delay

utils::Timeval core::TimerEventReceiver::delay

private

Definition at line 71 of file TimerEventReceiver.h.

timer

Timer* core::TimerEventReceiver::timer = nullptr

private

Definition at line 69 of file TimerEventReceiver.h.

timerEventPublisher

TimerEventPublisher& core::TimerEventReceiver::timerEventPublisher

private

Definition at line 67 of file TimerEventReceiver.h.

---

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

• core/TimerEventReceiver.h
• core/TimerEventReceiver.cpp