2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
20#ifndef CORE_TIMEREVENTPUBLISHER_H
21#define CORE_TIMEREVENTPUBLISHER_H
27#ifndef DOXYGEN_SHOULD_SKIP_THIS
29#include "utils/Timeval.h"
static void execDlCloseDeleyed()
void insert(Event *event)
void execute(const utils::Timeval ¤tTime)
void remove(Event *event)
virtual int monitorDescriptors(utils::Timeval &tickTimeOut, const sigset_t &sigMask)=0
void releaseExpiredResources(const utils::Timeval ¤tTime)
utils::Timeval getNextTimeout(const utils::Timeval ¤tTime)
void checkTimedOutEvents(const utils::Timeval ¤tTime)
TickStatus waitForEvents(const utils::Timeval &tickTimeOut, const utils::Timeval ¤tTime, const sigset_t &sigMask, int &activeDescriptorCount)
TimerEventPublisher & getTimerEventPublisher()
TickStatus tick(const utils::Timeval &tickTimeOut, const sigset_t &sigMask)
void spanActiveEvents(const utils::Timeval ¤tTime, int activeDescriptorCount)
void span(core::Event *event)
virtual void spanActiveEvents(int activeDescriptorCount)=0
DescriptorEventPublisher & getDescriptorEventPublisher(DISP_TYPE dispType)
void relax(core::Event *event)
int observedEventReceiverCount()
EventMultiplexer(DescriptorEventPublisher *readDescriptorEventPublisher, DescriptorEventPublisher *writeDescriptorEventPublisher, DescriptorEventPublisher *exceptionDescriptorEventPublisher)
void executeEventQueue(const utils::Timeval ¤tTime)
core::TimerEventPublisher *const timerEventPublisher
virtual ~EventMultiplexer()
bool operator()(const TimerEventReceiver *t1, const TimerEventReceiver *t2) const
void insert(TimerEventReceiver *timer)
TimerEventPublisher()=default
std::list< TimerEventReceiver * > removedList
utils::Timeval getNextTimeout(const utils::Timeval ¤tTime)
void spanActiveEvents(const utils::Timeval ¤tTime)
void unobserveDisableEvents()
void erase(TimerEventReceiver *timer)
std::set< TimerEventReceiver *, timernode_lt > timerList
void remove(TimerEventReceiver *timer)
static Timeval currentTime()
Timeval & operator=(const Timeval &timeVal)
static const utils::Timeval MAX