core::multiplexer::select::EventMultiplexer Class Reference

#include <EventMultiplexer.h>

Inheritance diagram for core::multiplexer::select::EventMultiplexer:

Collaboration diagram for core::multiplexer::select::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
FdSet	fdSets [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 56 of file EventMultiplexer.h.

Constructor & Destructor Documentation

EventMultiplexer()

core::multiplexer::select::EventMultiplexer::EventMultiplexer

(

)

Definition at line 63 of file EventMultiplexer.cpp.

        : core::EventMultiplexer(new core::multiplexer::select::DescriptorEventPublisher("READ", //
                                                                                         fdSets[core::EventMultiplexer::DISP_TYPE::RD]),
                                 new core::multiplexer::select::DescriptorEventPublisher("WRITE", //
                                                                                         fdSets[core::EventMultiplexer::DISP_TYPE::WR]),
                                 new core::multiplexer::select::DescriptorEventPublisher("EXCEPT", //
                                                                                         fdSets[core::EventMultiplexer::DISP_TYPE::EX])) {
        LOG(DEBUG) << "Core::multiplexer: select";
    }

References core::multiplexer::select::DescriptorEventPublisher::DescriptorEventPublisher(), core::EventMultiplexer::EventMultiplexer(), core::EventMultiplexer::EX, fdSets, core::EventMultiplexer::RD, and core::EventMultiplexer::WR.

Here is the call graph for this function:

~EventMultiplexer()

core::multiplexer::select::EventMultiplexer::~EventMultiplexer ( )

overridevirtualdefault

Reimplemented from core::EventMultiplexer.

Member Function Documentation

monitorDescriptors()

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

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 73 of file EventMultiplexer.cpp.

                                                                                               {
        const timespec timeSpec = tickTimeOut.getTimespec();
 
        return core::system::pselect(maxFd() + 1,
                                     &fdSets[core::EventMultiplexer::DISP_TYPE::RD].get(),
                                     &fdSets[core::EventMultiplexer::DISP_TYPE::WR].get(),
                                     &fdSets[core::EventMultiplexer::DISP_TYPE::EX].get(),
                                     &timeSpec,
                                     &sigMask);
    }

References core::EventMultiplexer::EX, fdSets, core::multiplexer::select::FdSet::get(), utils::Timeval::getTimespec(), core::EventMultiplexer::maxFd(), core::system::pselect(), core::EventMultiplexer::RD, and core::EventMultiplexer::WR.

Here is the call graph for this function:

spanActiveEvents()

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

overrideprivatevirtual

Implements core::EventMultiplexer.

Definition at line 84 of file EventMultiplexer.cpp.

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

References core::EventMultiplexer::descriptorEventPublishers, and core::DescriptorEventPublisher::spanActiveEvents().

Here is the call graph for this function:

Member Data Documentation

fdSets

FdSet core::multiplexer::select::EventMultiplexer::fdSets[3]

private

Definition at line 65 of file EventMultiplexer.h.

Referenced by EventMultiplexer(), and monitorDescriptors().

---

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

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