core::eventreceiver::ConnectEventReceiver Class Reference

#include <ConnectEventReceiver.h>

Inheritance diagram for core::eventreceiver::ConnectEventReceiver:

Collaboration diagram for core::eventreceiver::ConnectEventReceiver:

Protected Member Functions
	ConnectEventReceiver (const std::string &name, const utils::Timeval &timeout)
virtual void	connectTimeout ()
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	connectEvent ()=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 ConnectEventReceiver.h.

Constructor & Destructor Documentation

ConnectEventReceiver()

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

protected

Definition at line 31 of file ConnectEventReceiver.cpp.

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

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

Here is the call graph for this function:

Member Function Documentation

connectEvent()

virtual void core::eventreceiver::ConnectEventReceiver::connectEvent ( )

privatepure virtual

Implemented in core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, SocketConnectionT >, core::socket::stream::SocketConnector< PhysicalClientSocketT, ConfigT, core::socket::stream::legacy::SocketConnection >, and core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, core::socket::stream::tls::SocketConnection >.

Referenced by dispatchEvent().

Here is the caller graph for this function:

connectTimeout()

void core::eventreceiver::ConnectEventReceiver::connectTimeout ( )

protectedvirtual

Reimplemented in core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, SocketConnectionT >, core::socket::stream::SocketConnector< PhysicalClientSocketT, ConfigT, core::socket::stream::legacy::SocketConnection >, and core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, core::socket::stream::tls::SocketConnection >.

Definition at line 38 of file ConnectEventReceiver.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:

dispatchEvent()

void core::eventreceiver::ConnectEventReceiver::dispatchEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 42 of file ConnectEventReceiver.cpp.

                                             {
        connectEvent();
    }

References connectEvent().

Here is the call graph for this function:

signalEvent()

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

overrideprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 50 of file ConnectEventReceiver.cpp.

                                                                      {
        disable();
    }

References core::DescriptorEventReceiver::disable().

Here is the call graph for this function:

timeoutEvent()

void core::eventreceiver::ConnectEventReceiver::timeoutEvent ( )

finalprivatevirtual

Implements core::DescriptorEventReceiver.

Definition at line 46 of file ConnectEventReceiver.cpp.

                                            {
        connectTimeout();
    }

References connectTimeout().

Here is the call graph for this function:

---

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

• core/eventreceiver/ConnectEventReceiver.h
• core/eventreceiver/ConnectEventReceiver.cpp