#include <DescriptorEventPublisher.h>

Inheritance diagram for core::DescriptorEventPublisher:

Collaboration diagram for core::DescriptorEventPublisher:

Public Member Functions
	DescriptorEventPublisher ()=delete

virtual	~DescriptorEventPublisher ()

	DescriptorEventPublisher (const DescriptorEventPublisher &)=delete

DescriptorEventPublisher &	operator= (const DescriptorEventPublisher &)=delete

void	enable (DescriptorEventReceiver *descriptorEventReceiver)

void	disable (DescriptorEventReceiver *descriptorEventReceiver)

void	suspend (DescriptorEventReceiver *descriptorEventReceiver)

void	resume (DescriptorEventReceiver *descriptorEventReceiver)

virtual void	spanActiveEvents ()=0

void	checkTimedOutEvents (const utils::Timeval &currentTime)

void	releaseDisabledEvents (const utils::Timeval &currentTime)

int	getObservedEventReceiverCount () const

int	maxFd () const

utils::Timeval	getNextTimeout (const utils::Timeval &currentTime) const

void	signal (int sigNum)

void	disable ()

const std::string &	getName () const

Protected Member Functions
	DescriptorEventPublisher (std::string name)

Protected Attributes
std::map< int, std::list< DescriptorEventReceiver * > >	observedEventReceiverLists

unsigned long	eventCounter = 0

Private Member Functions
virtual void	muxAdd (DescriptorEventReceiver *descriptorEventReceiver)=0

virtual void	muxDel (int fd)=0

virtual void	muxOn (DescriptorEventReceiver *descriptorEventReceiver)=0

virtual void	muxOff (DescriptorEventReceiver *descriptorEventReceiver)=0

Private Attributes
std::string	name

std::map< std::list< DescriptorEventReceiver * > , std::list< DescriptorEventReceiver > >	dirtyEventReceiverLists

Detailed Description

Definition at line 41 of file DescriptorEventPublisher.h.

Constructor & Destructor Documentation

◆ DescriptorEventPublisher() [1/3]

core::DescriptorEventPublisher::DescriptorEventPublisher ( std::string name )

protected

Definition at line 36 of file DescriptorEventPublisher.cpp.

37 : name(std::move(name)) {

38 }

core::DescriptorEventPublisher::name

std::string name

Definition DescriptorEventPublisher.h:83

References name.

◆ DescriptorEventPublisher() [2/3]

core::DescriptorEventPublisher::DescriptorEventPublisher ( )

delete

◆ ~DescriptorEventPublisher()

core::DescriptorEventPublisher::~DescriptorEventPublisher ( )

virtual

Definition at line 40 of file DescriptorEventPublisher.cpp.

40 {

41 }

◆ DescriptorEventPublisher() [3/3]

core::DescriptorEventPublisher::DescriptorEventPublisher ( const DescriptorEventPublisher & )

delete

Member Function Documentation

◆ checkTimedOutEvents()

void core::DescriptorEventPublisher::checkTimedOutEvents ( const utils::Timeval & currentTime )

Definition at line 68 of file DescriptorEventPublisher.cpp.

                                                                                      {
        for (auto& [fd, eventReceivers] : observedEventReceiverLists) {
            eventReceivers.front()->checkTimeout(currentTime);
        }
    }

◆ disable() [1/2]

void core::DescriptorEventPublisher::disable ( )

Definition at line 138 of file DescriptorEventPublisher.cpp.

                                           {
        for (auto& [fd, eventReceivers] : observedEventReceiverLists) {
            for (DescriptorEventReceiver* eventReceiver : eventReceivers) {
                eventReceiver->disable();
            }
        }
    }

◆ disable() [2/2]

void core::DescriptorEventPublisher::disable ( DescriptorEventReceiver * descriptorEventReceiver )

Definition at line 54 of file DescriptorEventPublisher.cpp.

                                                                                           {
        const int fd = descriptorEventReceiver->getRegisteredFd();
 
        dirtyEventReceiverLists[&observedEventReceiverLists[fd]].push_back(descriptorEventReceiver);
    }

References core::DescriptorEventReceiver::getRegisteredFd().

Here is the call graph for this function:

◆ enable()

void core::DescriptorEventPublisher::enable ( DescriptorEventReceiver * descriptorEventReceiver )

Definition at line 43 of file DescriptorEventPublisher.cpp.

                                                                                          {
        const int fd = descriptorEventReceiver->getRegisteredFd();
 
        observedEventReceiverLists[fd].push_front(descriptorEventReceiver);
        muxAdd(descriptorEventReceiver);
        if (descriptorEventReceiver->isSuspended()) {
            muxOff(descriptorEventReceiver);
        }
        descriptorEventReceiver->setEnabled(utils::Timeval::currentTime());
    }

References utils::Timeval::currentTime(), core::DescriptorEventReceiver::getRegisteredFd(), core::DescriptorEventReceiver::isSuspended(), muxAdd(), muxOff(), and core::DescriptorEventReceiver::setEnabled().

Here is the call graph for this function:

◆ getName()

const std::string & core::DescriptorEventPublisher::getName ( ) const

Definition at line 146 of file DescriptorEventPublisher.cpp.

                                                             {
        return name;
    }

References name.

◆ getNextTimeout()

utils::Timeval core::DescriptorEventPublisher::getNextTimeout ( const utils::Timeval & currentTime ) const

Definition at line 116 of file DescriptorEventPublisher.cpp.

                                                                                               {
        utils::Timeval nextTimeout = DescriptorEventReceiver::TIMEOUT::MAX;
 
        if (dirtyEventReceiverLists.empty()) {
            for (const auto& [fd, eventReceivers] : observedEventReceiverLists) {
                nextTimeout = std::min(eventReceivers.front()->getTimeout(currentTime), nextTimeout);
            }
        } else {
            nextTimeout = 0;
        }
 
        return nextTimeout;
    }

References core::DescriptorEventReceiver::TIMEOUT::MAX, and utils::Timeval::operator=().

Here is the call graph for this function:

◆ getObservedEventReceiverCount()

int core::DescriptorEventPublisher::getObservedEventReceiverCount ( ) const

Definition at line 102 of file DescriptorEventPublisher.cpp.

                                                                      {
        return static_cast<int>(observedEventReceiverLists.size());
    }

◆ maxFd()

int core::DescriptorEventPublisher::maxFd ( ) const

Definition at line 106 of file DescriptorEventPublisher.cpp.

                                              {
        int maxFd = -1;
 
        if (!observedEventReceiverLists.empty()) {
            maxFd = observedEventReceiverLists.rbegin()->first;
        }
 
        return maxFd;
    }

◆ muxAdd()

virtual void core::DescriptorEventPublisher::muxAdd ( DescriptorEventReceiver * descriptorEventReceiver )

privatepure virtual

Implemented in core::multiplexer::epoll::DescriptorEventPublisher, core::multiplexer::poll::DescriptorEventPublisher, and core::multiplexer::select::DescriptorEventPublisher.

Referenced by enable().

Here is the caller graph for this function:

◆ muxDel()

virtual void core::DescriptorEventPublisher::muxDel ( int fd )

privatepure virtual

Implemented in core::multiplexer::epoll::DescriptorEventPublisher, core::multiplexer::poll::DescriptorEventPublisher, and core::multiplexer::select::DescriptorEventPublisher.

◆ muxOff()

virtual void core::DescriptorEventPublisher::muxOff ( DescriptorEventReceiver * descriptorEventReceiver )

privatepure virtual

Implemented in core::multiplexer::epoll::DescriptorEventPublisher, core::multiplexer::poll::DescriptorEventPublisher, and core::multiplexer::select::DescriptorEventPublisher.

Referenced by enable(), and suspend().

Here is the caller graph for this function:

◆ muxOn()

virtual void core::DescriptorEventPublisher::muxOn ( DescriptorEventReceiver * descriptorEventReceiver )

privatepure virtual

Implemented in core::multiplexer::epoll::DescriptorEventPublisher, core::multiplexer::poll::DescriptorEventPublisher, and core::multiplexer::select::DescriptorEventPublisher.

Referenced by resume().

Here is the caller graph for this function:

◆ operator=()

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

delete

◆ releaseDisabledEvents()

void core::DescriptorEventPublisher::releaseDisabledEvents ( const utils::Timeval & currentTime )

Definition at line 74 of file DescriptorEventPublisher.cpp.

                                                                                        {
        for (auto& [dirtyDescriptEventReceiverList, disabledDescriptorEventReceivers] : dirtyEventReceiverLists) {
            for (DescriptorEventReceiver* disabledDescriptorEventReceiver : disabledDescriptorEventReceivers) {
                dirtyDescriptEventReceiverList->remove(disabledDescriptorEventReceiver);
 
                if (dirtyDescriptEventReceiverList->empty()) {
                    const int fd = disabledDescriptorEventReceiver->getRegisteredFd();
 
                    muxDel(fd);
                    observedEventReceiverLists.erase(fd);
                } else {
                    DescriptorEventReceiver* activeDescriptorEventReceiver = dirtyDescriptEventReceiverList->front();
 
                    activeDescriptorEventReceiver->triggered(currentTime);
                    if (!activeDescriptorEventReceiver->isSuspended()) {
                        muxOn(activeDescriptorEventReceiver);
                    } else {
                        muxOff(activeDescriptorEventReceiver);
                    }
                }
 
                disabledDescriptorEventReceiver->setDisabled();
            }
        }
 
        dirtyEventReceiverLists.clear();
    }

◆ resume()

void core::DescriptorEventPublisher::resume ( DescriptorEventReceiver * descriptorEventReceiver )

Definition at line 64 of file DescriptorEventPublisher.cpp.

                                                                                          {
        muxOn(descriptorEventReceiver);
    }

References muxOn().

Here is the call graph for this function:

◆ signal()

void core::DescriptorEventPublisher::signal ( int sigNum )

Definition at line 130 of file DescriptorEventPublisher.cpp.

                                                    {
        for (auto& [fd, eventReceivers] : observedEventReceiverLists) {
            for (DescriptorEventReceiver* eventReceiver : eventReceivers) {
                eventReceiver->onSignal(sigNum);
            }
        }
    }

◆ spanActiveEvents()

virtual void core::DescriptorEventPublisher::spanActiveEvents ( )

pure virtual

Implemented in core::multiplexer::epoll::DescriptorEventPublisher, core::multiplexer::poll::DescriptorEventPublisher, and core::multiplexer::select::DescriptorEventPublisher.

◆ suspend()

void core::DescriptorEventPublisher::suspend ( DescriptorEventReceiver * descriptorEventReceiver )

Definition at line 60 of file DescriptorEventPublisher.cpp.

                                                                                           {
        muxOff(descriptorEventReceiver);
    }

References muxOff().

Here is the call graph for this function:

Member Data Documentation

◆ dirtyEventReceiverLists

std::map<std::list<DescriptorEventReceiver*>*, std::list<DescriptorEventReceiver*> > core::DescriptorEventPublisher::dirtyEventReceiverLists

private

Definition at line 84 of file DescriptorEventPublisher.h.

◆ eventCounter

unsigned long core::DescriptorEventPublisher::eventCounter = 0

protected

Definition at line 75 of file DescriptorEventPublisher.h.

Referenced by core::multiplexer::epoll::DescriptorEventPublisher::spanActiveEvents().

◆ name

std::string core::DescriptorEventPublisher::name

private

Definition at line 83 of file DescriptorEventPublisher.h.

Referenced by DescriptorEventPublisher(), and getName().

◆ observedEventReceiverLists

std::map<int, std::list<DescriptorEventReceiver*> > core::DescriptorEventPublisher::observedEventReceiverLists

protected

Definition at line 74 of file DescriptorEventPublisher.h.

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

core/DescriptorEventPublisher.h
core/DescriptorEventPublisher.cpp

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ DescriptorEventPublisher() [1/3]

◆ DescriptorEventPublisher() [2/3]

◆ ~DescriptorEventPublisher()

◆ DescriptorEventPublisher() [3/3]

Member Function Documentation

◆ checkTimedOutEvents()

◆ disable() [1/2]

◆ disable() [2/2]

◆ enable()

◆ getName()

◆ getNextTimeout()

◆ getObservedEventReceiverCount()

◆ maxFd()

◆ muxAdd()

◆ muxDel()

◆ muxOff()

◆ muxOn()

◆ operator=()

◆ releaseDisabledEvents()

◆ resume()

◆ signal()

◆ spanActiveEvents()

◆ suspend()

Member Data Documentation

◆ dirtyEventReceiverLists

◆ eventCounter

◆ name

◆ observedEventReceiverLists