core::multiplexer::epoll::EventMultiplexer Class Reference

#include <EventMultiplexer.h>

Inheritance diagram for core::multiplexer::epoll::EventMultiplexer:

Collaboration diagram for core::multiplexer::epoll::EventMultiplexer:

Public Member Functions
	EventMultiplexer ()
	~EventMultiplexer () override=default
Public Member Functions inherited from core::EventMultiplexer
	EventMultiplexer (DescriptorEventPublisher *readDescriptorEventPublisher, DescriptorEventPublisher *writeDescriptorEventPublisher, DescriptorEventPublisher *exceptionDescriptorEventPublisher)
	EventMultiplexer (const EventMultiplexer &)=delete
EventMultiplexer &	operator= (const EventMultiplexer &)=delete
DescriptorEventPublisher &	getDescriptorEventPublisher (DISP_TYPE dispType)
TimerEventPublisher &	getTimerEventPublisher ()
void	span (core::Event *event)
void	relax (core::Event *event)
void	signal (int sigNum)
void	terminate ()
void	clearEventQueue ()
TickStatus	tick (const utils::Timeval &tickTimeOut, const sigset_t &sigMask)

Private Member Functions
int	monitorDescriptors (utils::Timeval &tickTimeout, const sigset_t &sigMask) override
void	spanActiveEvents (int activeDescriptorCount) override

Private Attributes
int	epfd
int	epfds [3]
epoll_event	ePollEvents [3] {}

Additional Inherited Members
Public Types inherited from core::EventMultiplexer
enum	DISP_TYPE { RD = 0 , WR = 1 , EX = 2 }
Protected Member Functions inherited from core::EventMultiplexer
int	maxFd ()
Protected Attributes inherited from core::EventMultiplexer
std::array< DescriptorEventPublisher *, 3 >	descriptorEventPublishers

Detailed Description

Definition at line 33 of file EventMultiplexer.h.

Constructor & Destructor Documentation

EventMultiplexer()

core::multiplexer::epoll::EventMultiplexer::EventMultiplexer

(

)

Definition at line 41 of file EventMultiplexer.cpp.

        : core::EventMultiplexer(new core::multiplexer::epoll::DescriptorEventPublisher("READ", //
                                                                                        epfds[core::EventMultiplexer::DISP_TYPE::RD],
                                                                                        EPOLLIN,
                                                                                        EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR),
                                 new core::multiplexer::epoll::DescriptorEventPublisher("WRITE", //
                                                                                        epfds[core::EventMultiplexer::DISP_TYPE::WR],
                                                                                        EPOLLOUT,
                                                                                        EPOLLOUT),
                                 new core::multiplexer::epoll::DescriptorEventPublisher("EXCEPT", //
                                                                                        epfds[core::EventMultiplexer::DISP_TYPE::EX],
                                                                                        EPOLLPRI,
                                                                                        EPOLLPRI))
        , epfd(core::system::epoll_create1(EPOLL_CLOEXEC)) {
        epoll_event event{};
        event.events = EPOLLIN;
 
        event.data.ptr = descriptorEventPublishers[core::EventMultiplexer::DISP_TYPE::RD];
        core::system::epoll_ctl(epfd, EPOLL_CTL_ADD, epfds[core::EventMultiplexer::DISP_TYPE::RD], &event);
 
        event.data.ptr = descriptorEventPublishers[core::EventMultiplexer::DISP_TYPE::WR];
        core::system::epoll_ctl(epfd, EPOLL_CTL_ADD, epfds[core::EventMultiplexer::DISP_TYPE::WR], &event);
 
        event.data.ptr = descriptorEventPublishers[core::EventMultiplexer::DISP_TYPE::EX];
        core::system::epoll_ctl(epfd, EPOLL_CTL_ADD, epfds[core::EventMultiplexer::DISP_TYPE::EX], &event);
 
        LOG(DEBUG) << "Core::multiplexer: epoll";
    }

~EventMultiplexer()

core::multiplexer::epoll::EventMultiplexer::~EventMultiplexer ( )

overridevirtualdefault

Reimplemented from core::EventMultiplexer.

Member Function Documentation

monitorDescriptors()

int core::multiplexer::epoll::EventMultiplexer::monitorDescriptors ( utils::Timeval & tickTimeout, const sigset_t & sigMask )

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 70 of file EventMultiplexer.cpp.

                                                                                               {
        return core::system::epoll_pwait(epfd, ePollEvents, 3, tickTimeout.getMs(), &sigMask);
    }

spanActiveEvents()

void core::multiplexer::epoll::EventMultiplexer::spanActiveEvents ( int activeDescriptorCount )

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 74 of file EventMultiplexer.cpp.

                                                                     {
        for (int i = 0; i < activeDescriptorCount; i++) {
            if ((ePollEvents[i].events & EPOLLIN) != 0) {
                static_cast<core::DescriptorEventPublisher*>(ePollEvents[i].data.ptr)->spanActiveEvents();
            }
        }
    }

Member Data Documentation

epfd

int core::multiplexer::epoll::EventMultiplexer::epfd

private

Definition at line 42 of file EventMultiplexer.h.

epfds

int core::multiplexer::epoll::EventMultiplexer::epfds[3]

private

Definition at line 44 of file EventMultiplexer.h.

ePollEvents

epoll_event core::multiplexer::epoll::EventMultiplexer::ePollEvents[3] {}

private

Definition at line 45 of file EventMultiplexer.h.

{};

---

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

• core/multiplexer/epoll/EventMultiplexer.h
• core/multiplexer/epoll/EventMultiplexer.cpp