core::multiplexer::epoll::DescriptorEventPublisher Class Reference

#include <DescriptorEventPublisher.h>

Inheritance diagram for core::multiplexer::epoll::DescriptorEventPublisher:

Collaboration diagram for core::multiplexer::epoll::DescriptorEventPublisher:

Classes
class	EPollEvents

Public Member Functions
	DescriptorEventPublisher (const std::string &name, int &epfd, uint32_t events, uint32_t revents)
Public Member Functions inherited from core::DescriptorEventPublisher
	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)
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

Private Member Functions
void	muxAdd (core::DescriptorEventReceiver *eventReceiver) override
void	muxDel (int fd) override
void	muxOn (core::DescriptorEventReceiver *eventReceiver) override
void	muxOff (core::DescriptorEventReceiver *eventReceiver) override
void	spanActiveEvents () override

Private Attributes
EPollEvents	ePollEvents
uint32_t	revents

Additional Inherited Members
Protected Member Functions inherited from core::DescriptorEventPublisher
	DescriptorEventPublisher (std::string name)
Protected Attributes inherited from core::DescriptorEventPublisher
std::map< int, std::list< DescriptorEventReceiver * > >	observedEventReceiverLists
unsigned long	eventCounter = 0

Detailed Description

Definition at line 41 of file DescriptorEventPublisher.h.

Constructor & Destructor Documentation

DescriptorEventPublisher()

core::multiplexer::epoll::DescriptorEventPublisher::DescriptorEventPublisher	(	const std::string &	name,
		int &	epfd,
		uint32_t	events,
		uint32_t	revents )

Definition at line 101 of file DescriptorEventPublisher.cpp.

        : core::DescriptorEventPublisher(name)
        , ePollEvents(epfd, events)
        , revents(revents) {
    }

References DescriptorEventPublisher(), and revents.

Referenced by DescriptorEventPublisher().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

muxAdd()

void core::multiplexer::epoll::DescriptorEventPublisher::muxAdd ( core::DescriptorEventReceiver * eventReceiver )

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 107 of file DescriptorEventPublisher.cpp.

                                                                                    {
        ePollEvents.muxAdd(eventReceiver);
    }

muxDel()

void core::multiplexer::epoll::DescriptorEventPublisher::muxDel ( int fd )

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 111 of file DescriptorEventPublisher.cpp.

                                                {
        ePollEvents.muxDel(fd);
    }

muxOff()

void core::multiplexer::epoll::DescriptorEventPublisher::muxOff ( core::DescriptorEventReceiver * eventReceiver )

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 119 of file DescriptorEventPublisher.cpp.

                                                                                    {
        ePollEvents.muxOff(eventReceiver);
    }

muxOn()

void core::multiplexer::epoll::DescriptorEventPublisher::muxOn ( core::DescriptorEventReceiver * eventReceiver )

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 115 of file DescriptorEventPublisher.cpp.

                                                                                   {
        ePollEvents.muxOn(eventReceiver);
    }

spanActiveEvents()

void core::multiplexer::epoll::DescriptorEventPublisher::spanActiveEvents ( )

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 123 of file DescriptorEventPublisher.cpp.

                                                    {
        const int count = core::system::epoll_wait(ePollEvents.getEPFd(), ePollEvents.getEvents(), ePollEvents.getInterestCount(), 0);
 
        for (int i = 0; i < count; i++) {
            const epoll_event& ev = ePollEvents.getEvents()[i];
            core::DescriptorEventReceiver* eventReceiver = static_cast<core::DescriptorEventReceiver*>(ev.data.ptr);
            if (eventReceiver != nullptr && (ev.events & revents) != 0) {
                eventCounter++;
                eventReceiver->span();
            }
        }
    }

References core::DescriptorEventPublisher::eventCounter, revents, and core::EventReceiver::span().

Here is the call graph for this function:

Member Data Documentation

ePollEvents

EPollEvents core::multiplexer::epoll::DescriptorEventPublisher::ePollEvents

private

Definition at line 80 of file DescriptorEventPublisher.h.

revents

uint32_t core::multiplexer::epoll::DescriptorEventPublisher::revents

private

Definition at line 81 of file DescriptorEventPublisher.h.

Referenced by DescriptorEventPublisher(), and spanActiveEvents().

---

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

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