core::multiplexer::poll::EventMultiplexer Class Reference

#include <EventMultiplexer.h>

Inheritance diagram for core::multiplexer::poll::EventMultiplexer:

Collaboration diagram for core::multiplexer::poll::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
PollFdsManager	pollFdsManager

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 179 of file EventMultiplexer.h.

Constructor & Destructor Documentation

EventMultiplexer()

core::multiplexer::poll::EventMultiplexer::EventMultiplexer

(

)

Definition at line 153 of file EventMultiplexer.cpp.

        : core::EventMultiplexer(new core::multiplexer::poll::DescriptorEventPublisher("READ", //
                                                                                       pollFdsManager,
                                                                                       POLLIN,
                                                                                       POLLIN | POLLHUP | POLLRDHUP | POLLERR),
                                 new core::multiplexer::poll::DescriptorEventPublisher("WRITE", //
                                                                                       pollFdsManager,
                                                                                       POLLOUT,
                                                                                       POLLOUT),
                                 new core::multiplexer::poll::DescriptorEventPublisher("EXCEPT", //
                                                                                       pollFdsManager,
                                                                                       POLLPRI,
                                                                                       POLLPRI)) {
        LOG(DEBUG) << "Core::multiplexer: poll";
    }

References logger::DEBUG, EventMultiplexer(), and logger::LogMessage::LogMessage().

Referenced by EventMultiplexer().

Here is the call graph for this function:

Here is the caller graph for this function:

~EventMultiplexer()

core::multiplexer::poll::EventMultiplexer::~EventMultiplexer ( )

overridevirtualdefault

Reimplemented from core::EventMultiplexer.

Member Function Documentation

monitorDescriptors()

int core::multiplexer::poll::EventMultiplexer::monitorDescriptors ( utils::Timeval & tickTimeOut, const sigset_t & sigMask )

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 169 of file EventMultiplexer.cpp.

                                                                                               {
        const timespec timeSpec = tickTimeOut.getTimespec();
 
        return core::system::ppoll(pollFdsManager.getEvents(), pollFdsManager.getCurrentSize(), &timeSpec, &sigMask);
    }

References utils::Timeval::getTimespec().

Here is the call graph for this function:

spanActiveEvents()

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

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 175 of file EventMultiplexer.cpp.

                                                                     {
        if (activeDescriptorCount > 0) {
            for (core::DescriptorEventPublisher* const descriptorEventPublisher : descriptorEventPublishers) {
                descriptorEventPublisher->spanActiveEvents();
            }
        }
    }

Member Data Documentation

pollFdsManager

PollFdsManager core::multiplexer::poll::EventMultiplexer::pollFdsManager

private

Definition at line 188 of file EventMultiplexer.h.

---

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

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