core::TimerEventPublisher Class Reference

#include <TimerEventPublisher.h>

Collaboration diagram for core::TimerEventPublisher:

Classes
class	timernode_lt

Public Member Functions
	TimerEventPublisher ()=default
utils::Timeval	getNextTimeout (const utils::Timeval &currentTime)
void	spanActiveEvents (const utils::Timeval &currentTime)
void	unobserveDisableEvents ()
void	remove (TimerEventReceiver *timer)
void	erase (TimerEventReceiver *timer)
void	insert (TimerEventReceiver *timer)
bool	empty ()
void	stop ()

Private Attributes
std::set< TimerEventReceiver *, timernode_lt >	timerList
std::list< TimerEventReceiver * >	removedList

Detailed Description

Definition at line 38 of file TimerEventPublisher.h.

Constructor & Destructor Documentation

TimerEventPublisher()

core::TimerEventPublisher::TimerEventPublisher ( )

default

Member Function Documentation

empty()

bool core::TimerEventPublisher::empty

(

)

Definition at line 76 of file TimerEventPublisher.cpp.

                                    {
        return timerList.empty();
    }

erase()

void core::TimerEventPublisher::erase

(

TimerEventReceiver *

timer

)

Definition at line 68 of file TimerEventPublisher.cpp.

                                                             {
        timerList.erase(timer);
    }

getNextTimeout()

utils::Timeval core::TimerEventPublisher::getNextTimeout

(

const utils::Timeval &

currentTime

)

Definition at line 33 of file TimerEventPublisher.cpp.

                                                                                    {
        utils::Timeval nextTimeout({LONG_MAX, 0});
 
        if (!timerList.empty()) {
            nextTimeout = (*(timerList.begin()))->getTimeoutRelative(currentTime);
        }
 
        return nextTimeout;
    }

Referenced by core::EventMultiplexer::getNextTimeout().

Here is the caller graph for this function:

insert()

void core::TimerEventPublisher::insert

(

TimerEventReceiver *

timer

)

Definition at line 72 of file TimerEventPublisher.cpp.

                                                              {
        timerList.insert(timer);
    }

remove()

void core::TimerEventPublisher::remove

(

TimerEventReceiver *

timer

)

Definition at line 61 of file TimerEventPublisher.cpp.

                                                              {
        if (std::find(timerList.begin(), timerList.end(), timer) != timerList.end() &&
            std::find(removedList.begin(), removedList.end(), timer) == removedList.end()) {
            removedList.push_back(timer);
        }
    }

spanActiveEvents()

void core::TimerEventPublisher::spanActiveEvents

(

const utils::Timeval &

currentTime

)

Definition at line 43 of file TimerEventPublisher.cpp.

                                                                              {
        for (TimerEventReceiver* timerEventReceiver : timerList) {
            if (timerEventReceiver->getTimeoutAbsolut() <= currentTime) {
                timerEventReceiver->span();
            } else {
                break;
            }
        }
    }

Referenced by core::EventMultiplexer::spanActiveEvents().

Here is the caller graph for this function:

stop()

void core::TimerEventPublisher::stop

(

)

Definition at line 80 of file TimerEventPublisher.cpp.

                                   {
        for (TimerEventReceiver* timer : timerList) { // cppcheck-suppress constVariablePointer
            remove(timer);
        }
 
        unobserveDisableEvents();
    }

References unobserveDisableEvents().

Referenced by core::EventMultiplexer::signal(), and core::EventMultiplexer::terminate().

Here is the call graph for this function:

Here is the caller graph for this function:

unobserveDisableEvents()

void core::TimerEventPublisher::unobserveDisableEvents

(

)

Definition at line 53 of file TimerEventPublisher.cpp.

                                                     {
        for (TimerEventReceiver* timerEventReceiver : removedList) {
            timerList.erase(timerEventReceiver);
            timerEventReceiver->unobservedEvent();
        }
        removedList.clear();
    }

Referenced by core::EventMultiplexer::releaseExpiredResources(), and stop().

Here is the caller graph for this function:

Member Data Documentation

removedList

std::list<TimerEventReceiver*> core::TimerEventPublisher::removedList

private

Definition at line 63 of file TimerEventPublisher.h.

timerList

std::set<TimerEventReceiver*, timernode_lt> core::TimerEventPublisher::timerList

private

Definition at line 62 of file TimerEventPublisher.h.

---

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

• core/TimerEventPublisher.h
• core/TimerEventPublisher.cpp