core::multiplexer::poll::PollFdsManager Class Reference

#include <EventMultiplexer.h>

Collaboration diagram for core::multiplexer::poll::PollFdsManager:

Classes
struct	PollFdIndex

Public Member Functions
	PollFdsManager ()
void	muxAdd (core::DescriptorEventReceiver *eventReceiver, short event)
void	muxDel (int fd, short event)
void	muxOn (const core::DescriptorEventReceiver *eventReceiver, short event)
void	muxOff (const DescriptorEventReceiver *eventReceiver, short event)
pollfd *	getEvents ()
const std::unordered_map< int, PollFdIndex > &	getPollFdIndices () const
nfds_t	getCurrentSize () const

Private Member Functions
void	compress ()

Private Attributes
nfds_t	nextIndex = 0
std::vector< pollfd >	pollfds
std::unordered_map< int, PollFdIndex >	pollFdIndices

Detailed Description

Definition at line 40 of file EventMultiplexer.h.

Constructor & Destructor Documentation

PollFdsManager()

core::multiplexer::poll::PollFdsManager::PollFdsManager ( )

explicit

Definition at line 46 of file EventMultiplexer.cpp.

                                   {
        pollfds.resize(1, {-1, 0, 0});
        pollFdIndices.reserve(1);
    }

Member Function Documentation

compress()

void core::multiplexer::poll::PollFdsManager::compress ( )

private

Definition at line 102 of file EventMultiplexer.cpp.

                                  {
        (void) std::remove_if(pollfds.begin(), pollfds.end(), [](const pollfd& pollFd) -> bool {
            return pollFd.fd < 0;
        });
 
        pollfds.resize(pollFdIndices.size() + 1, {-1, 0, 0});
 
        pollFdIndices.reserve(pollFdIndices.size() + 1);
 
        for (uint32_t i = 0; i < pollFdIndices.size(); i++) {
            pollFdIndices[pollfds[i].fd].index = i;
        }
 
        nextIndex = pollFdIndices.size();
    }

getCurrentSize()

nfds_t core::multiplexer::poll::PollFdsManager::getCurrentSize

(

)

const

Definition at line 126 of file EventMultiplexer.cpp.

                                                {
        return nextIndex;
    }

getEvents()

pollfd * core::multiplexer::poll::PollFdsManager::getEvents

(

)

Definition at line 118 of file EventMultiplexer.cpp.

                                      {
        return pollfds.data();
    }

getPollFdIndices()

const std::unordered_map< int, PollFdsManager::PollFdIndex > & core::multiplexer::poll::PollFdsManager::getPollFdIndices

(

)

const

Definition at line 122 of file EventMultiplexer.cpp.

                                                                                                   {
        return pollFdIndices;
    }

muxAdd()

void core::multiplexer::poll::PollFdsManager::muxAdd	(	core::DescriptorEventReceiver *	eventReceiver,
		short	event )

Definition at line 51 of file EventMultiplexer.cpp.

                                                                                       {
        const int fd = eventReceiver->getRegisteredFd();
 
        if (!pollFdIndices.contains(fd)) {
            pollfds[nextIndex].events = event;
            pollfds[nextIndex].fd = fd;
 
            pollFdIndices[fd].index = nextIndex;
            pollFdIndices[fd].events = event;
 
            ++nextIndex;
 
            if (nextIndex == pollfds.size()) {
                pollfds.resize(pollfds.size() * 2, {-1, 0, 0});
                pollFdIndices.reserve(pollfds.size());
            }
        } else {
            PollFdIndex& pollFdIndex = pollFdIndices[fd];
 
            pollfds[pollFdIndex.index].events |= event;
            pollFdIndex.events |= event;
        }
    }

Referenced by core::multiplexer::poll::DescriptorEventPublisher::muxAdd().

Here is the caller graph for this function:

muxDel()

void core::multiplexer::poll::PollFdsManager::muxDel	(	int	fd,
		short	event )

Definition at line 75 of file EventMultiplexer.cpp.

                                                   {
        const std::unordered_map<int, PollFdIndex>::iterator itPollFdIndex = pollFdIndices.find(fd);
 
        PollFdIndex& pollFdIndex = itPollFdIndex->second;
 
        pollfds[pollFdIndex.index].events &= static_cast<short>(~event); // tilde promotes to int
        pollFdIndex.events &= static_cast<short>(~event);                // tilde promotes to int
 
        if (pollFdIndex.events == 0) {
            pollfds[pollFdIndex.index].fd = -1; // Compress will keep track of that descriptor
            pollFdIndices.erase(fd);
 
            if (pollfds.size() > (pollFdIndices.size() * 2) + 1) {
                compress();
            }
        }
    }

Referenced by core::multiplexer::poll::DescriptorEventPublisher::muxDel().

Here is the caller graph for this function:

muxOff()

void core::multiplexer::poll::PollFdsManager::muxOff	(	const DescriptorEventReceiver *	eventReceiver,
		short	event )

Definition at line 97 of file EventMultiplexer.cpp.

                                                                                         {
        pollfds[pollFdIndices.find(eventReceiver->getRegisteredFd())->second.index].events &=
            static_cast<short>(~event); // Tilde promotes to int
    }

Referenced by core::multiplexer::poll::DescriptorEventPublisher::muxOff().

Here is the caller graph for this function:

muxOn()

void core::multiplexer::poll::PollFdsManager::muxOn	(	const core::DescriptorEventReceiver *	eventReceiver,
		short	event )

Definition at line 93 of file EventMultiplexer.cpp.

                                                                                        {
        pollfds[pollFdIndices.find(eventReceiver->getRegisteredFd())->second.index].events |= event;
    }

Referenced by core::multiplexer::poll::DescriptorEventPublisher::muxOn().

Here is the caller graph for this function:

Member Data Documentation

nextIndex

nfds_t core::multiplexer::poll::PollFdsManager::nextIndex = 0

private

Definition at line 61 of file EventMultiplexer.h.

pollFdIndices

std::unordered_map<int, PollFdIndex> core::multiplexer::poll::PollFdsManager::pollFdIndices

private

Definition at line 65 of file EventMultiplexer.h.

pollfds

std::vector<pollfd> core::multiplexer::poll::PollFdsManager::pollfds

private

Definition at line 64 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