core::multiplexer::poll::DescriptorEventPublisher Class Reference

#include <DescriptorEventPublisher.h>

Inheritance diagram for core::multiplexer::poll::DescriptorEventPublisher:

Collaboration diagram for core::multiplexer::poll::DescriptorEventPublisher:

Public Member Functions
	DescriptorEventPublisher (const std::string &name, core::multiplexer::poll::PollFdsManager &pollFds, short events, short 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
core::multiplexer::poll::PollFdsManager &	pollFds
short	events
short	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 37 of file DescriptorEventPublisher.h.

Constructor & Destructor Documentation

DescriptorEventPublisher()

core::multiplexer::poll::DescriptorEventPublisher::DescriptorEventPublisher	(	const std::string &	name,
		core::multiplexer::poll::PollFdsManager &	pollFds,
		short	events,
		short	revents )

Definition at line 36 of file DescriptorEventPublisher.cpp.

        : core::DescriptorEventPublisher(name)
        , pollFds(pollFds)
        , events(events)
        , revents(revents) {
    }

References events, pollFds, and revents.

Member Function Documentation

muxAdd()

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

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 43 of file DescriptorEventPublisher.cpp.

                                                                                    {
        pollFds.muxAdd(eventReceiver, events);
    }

References events, core::multiplexer::poll::PollFdsManager::muxAdd(), and pollFds.

Here is the call graph for this function:

muxDel()

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

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 47 of file DescriptorEventPublisher.cpp.

                                                {
        pollFds.muxDel(fd, events);
    }

References events, core::multiplexer::poll::PollFdsManager::muxDel(), and pollFds.

Here is the call graph for this function:

muxOff()

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

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 55 of file DescriptorEventPublisher.cpp.

                                                                                    {
        pollFds.muxOff(eventReceiver, events);
    }

References events, core::multiplexer::poll::PollFdsManager::muxOff(), and pollFds.

Here is the call graph for this function:

muxOn()

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

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 51 of file DescriptorEventPublisher.cpp.

                                                                                   {
        pollFds.muxOn(eventReceiver, events);
    }

References events, core::multiplexer::poll::PollFdsManager::muxOn(), and pollFds.

Here is the call graph for this function:

spanActiveEvents()

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

overrideprivatevirtual

Implements core::DescriptorEventPublisher.

Definition at line 59 of file DescriptorEventPublisher.cpp.

                                                    {
        pollfd* pollfds = pollFds.getEvents();
 
        const std::unordered_map<int, PollFdsManager::PollFdIndex>& pollFdsIndices = pollFds.getPollFdIndices();
 
        for (auto& [fd, eventReceivers] : observedEventReceiverLists) {
            const pollfd& pollFd = pollfds[pollFdsIndices.find(fd)->second.index];
 
            if ((pollFd.events & events) != 0 && (pollFd.revents & revents) != 0) {
                core::DescriptorEventReceiver* eventReceiver = eventReceivers.front();
                eventCounter++;
                eventReceiver->span();
            }
        }
    }

Member Data Documentation

events

short core::multiplexer::poll::DescriptorEventPublisher::events

private

Definition at line 50 of file DescriptorEventPublisher.h.

Referenced by DescriptorEventPublisher(), muxAdd(), muxDel(), muxOff(), and muxOn().

pollFds

core::multiplexer::poll::PollFdsManager& core::multiplexer::poll::DescriptorEventPublisher::pollFds

private

Definition at line 49 of file DescriptorEventPublisher.h.

Referenced by DescriptorEventPublisher(), muxAdd(), muxDel(), muxOff(), and muxOn().

revents

short core::multiplexer::poll::DescriptorEventPublisher::revents

private

Definition at line 51 of file DescriptorEventPublisher.h.

Referenced by DescriptorEventPublisher().

---

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

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