core::eventreceiver::WriteEventReceiver Class Reference

#include <WriteEventReceiver.h>

Inheritance diagram for core::eventreceiver::WriteEventReceiver:

Collaboration diagram for core::eventreceiver::WriteEventReceiver:

Protected Member Functions
	WriteEventReceiver (const std::string &name, const utils::Timeval &timeout)
virtual void	writeTimeout ()
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	writeEvent ()=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 57 of file WriteEventReceiver.h.

Constructor & Destructor Documentation

WriteEventReceiver()

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

protected

Definition at line 53 of file WriteEventReceiver.cpp.

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

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

Referenced by core::pipe::PipeSource::PipeSource(), core::socket::stream::SocketWriter::SocketWriter(), core::socket::stream::tls::TLSHandshake::TLSHandshake(), and core::socket::stream::tls::TLSShutdown::TLSShutdown().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

dispatchEvent()

void core::eventreceiver::WriteEventReceiver::dispatchEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 64 of file WriteEventReceiver.cpp.

                                           {
        writeEvent();
    }

References writeEvent().

Here is the call graph for this function:

signalEvent()

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

overrideprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 72 of file WriteEventReceiver.cpp.

                                                                    {
        disable();
    }

References core::DescriptorEventReceiver::disable().

Here is the call graph for this function:

timeoutEvent()

void core::eventreceiver::WriteEventReceiver::timeoutEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 68 of file WriteEventReceiver.cpp.

                                          {
        writeTimeout();
    }

References writeTimeout().

Here is the call graph for this function:

writeEvent()

virtual void core::eventreceiver::WriteEventReceiver::writeEvent ( )

privatepure virtual

Implemented in core::socket::stream::SocketWriter, core::socket::stream::tls::TLSHandshake, core::socket::stream::tls::TLSShutdown, core::pipe::PipeSource, and database::mariadb::MariaDBConnection.

Referenced by dispatchEvent().

Here is the caller graph for this function:

writeTimeout()

void core::eventreceiver::WriteEventReceiver::writeTimeout ( )

protectedvirtual

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

Definition at line 60 of file WriteEventReceiver.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:

---

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

• core/eventreceiver/WriteEventReceiver.h
• core/eventreceiver/WriteEventReceiver.cpp