#include <ReadEventReceiver.h>

Inheritance diagram for core::eventreceiver::ReadEventReceiver:

Collaboration diagram for core::eventreceiver::ReadEventReceiver:

Protected Member Functions
	ReadEventReceiver (const std::string &name, const utils::Timeval &timeout)

virtual void	readTimeout ()

Protected Member Functions inherited from core::DescriptorEventReceiver
bool	enable (int fd)

void	disable ()

void	suspend ()

void	resume ()

Protected Member Functions inherited from core::Observer
void	observed ()

void	unObserved ()

virtual void	unobservedEvent ()=0

	Observer ()=default

	Observer (Observer &)=delete

	Observer (Observer &&)=delete

virtual	~Observer ()

Protected Member Functions inherited from core::EventReceiver
virtual	~EventReceiver ()=default

	EventReceiver (const std::string &name)

	EventReceiver (EventReceiver &)=delete

	EventReceiver (EventReceiver &&)=delete

EventReceiver &	operator= (EventReceiver &)=delete

EventReceiver &	operator= (EventReceiver &&)=delete

virtual void	destruct ()

void	span ()

void	relax ()

const std::string &	getName () const

Private Member Functions
virtual void	readEvent ()=0

void	dispatchEvent () final

void	timeoutEvent () final

void	signalEvent (int signum) override

Additional Inherited Members
Public Member Functions inherited from core::DescriptorEventReceiver
	DescriptorEventReceiver (const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE)

int	getRegisteredFd () const

bool	isEnabled () const

bool	isSuspended () const

void	setTimeout (const utils::Timeval &timeout)

utils::Timeval	getTimeout (const utils::Timeval &currentTime) const

void	checkTimeout (const utils::Timeval &currentTime)

Public Member Functions inherited from core::EventReceiver
	EventReceiver (const std::string &name)

	EventReceiver (EventReceiver &)=delete

	EventReceiver (EventReceiver &&)=delete

EventReceiver &	operator= (EventReceiver &)=delete

EventReceiver &	operator= (EventReceiver &&)=delete

virtual void	destruct ()

void	span ()

void	relax ()

const std::string &	getName () const

Static Public Member Functions inherited from core::EventReceiver
static void	atNextTick (const std::function< void(void)> &callBack)

Static Protected Member Functions inherited from core::EventReceiver
static void	atNextTick (const std::function< void(void)> &callBack)

Detailed Description

Definition at line 35 of file ReadEventReceiver.h.

Constructor & Destructor Documentation

◆ ReadEventReceiver()

core::eventreceiver::ReadEventReceiver::ReadEventReceiver	(	const std::string &	name,
		const utils::Timeval &	timeout )

protected

Definition at line 31 of file ReadEventReceiver.cpp.

        : core::DescriptorEventReceiver(
              name + " Read",
              core::EventLoop::instance().getEventMultiplexer().getDescriptorEventPublisher(core::EventMultiplexer::DISP_TYPE::RD),
              timeout) {
    }

References core::EventMultiplexer::getDescriptorEventPublisher(), core::EventLoop::getEventMultiplexer(), core::EventLoop::instance(), and core::EventMultiplexer::RD.

Referenced by core::socket::stream::SocketReader::SocketReader().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

◆ dispatchEvent()

void core::eventreceiver::ReadEventReceiver::dispatchEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 42 of file ReadEventReceiver.cpp.

                                          {
        readEvent();
    }

References readEvent().

Here is the call graph for this function:

◆ readEvent()

virtual void core::eventreceiver::ReadEventReceiver::readEvent ( )

privatepure virtual

Implemented in apps::towercalculator::KeyboardReader, core::pipe::PipeSink, core::socket::stream::SocketReader, core::socket::stream::tls::TLSHandshake, core::socket::stream::tls::TLSShutdown, and database::mariadb::MariaDBConnection.

Referenced by dispatchEvent().

Here is the caller graph for this function:

◆ readTimeout()

void core::eventreceiver::ReadEventReceiver::readTimeout ( )

protectedvirtual

Reimplemented in core::socket::stream::tls::TLSHandshake, core::socket::stream::tls::TLSShutdown, and database::mariadb::MariaDBConnection.

Definition at line 38 of file ReadEventReceiver.cpp.

                                        {
        disable();
    }

References core::DescriptorEventReceiver::disable().

Referenced by timeoutEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ signalEvent()

void core::eventreceiver::ReadEventReceiver::signalEvent ( int signum )

overrideprivatevirtual

Implements core::DescriptorEventReceiver.

Reimplemented in core::socket::stream::SocketReader, core::socket::stream::tls::TLSHandshake, and core::socket::stream::tls::TLSShutdown.

Definition at line 50 of file ReadEventReceiver.cpp.

                                                                   {
        disable();
    }

References core::DescriptorEventReceiver::disable().

Here is the call graph for this function:

◆ timeoutEvent()

void core::eventreceiver::ReadEventReceiver::timeoutEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 46 of file ReadEventReceiver.cpp.

                                         {
        readTimeout();
    }

References readTimeout().

Here is the call graph for this function:

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

core/eventreceiver/ReadEventReceiver.h
core/eventreceiver/ReadEventReceiver.cpp

Protected Member Functions

Private Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ ReadEventReceiver()

Member Function Documentation

◆ dispatchEvent()

◆ readEvent()

◆ readTimeout()

◆ signalEvent()

◆ timeoutEvent()