core::EventReceiver Class Reference

#include <EventReceiver.h>

Inheritance diagram for core::EventReceiver:

Collaboration diagram for core::EventReceiver:

Public Member Functions
	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 ()
virtual void	onEvent (const utils::Timeval &currentTime)=0
const std::string &	getName () const

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

Protected Member Functions
virtual	~EventReceiver ()=default

Private Attributes
Event	event

Detailed Description

Definition at line 61 of file EventReceiver.h.

Constructor & Destructor Documentation

EventReceiver() [1/3]

core::EventReceiver::EventReceiver

(

const std::string &

name

)

Definition at line 71 of file EventReceiver.cpp.

        : event(this, name) {
    }

References EventReceiver().

Referenced by EventReceiver().

Here is the call graph for this function:

Here is the caller graph for this function:

EventReceiver() [2/3]

core::EventReceiver::EventReceiver ( EventReceiver & )

delete

EventReceiver() [3/3]

core::EventReceiver::EventReceiver ( EventReceiver && )

delete

~EventReceiver()

virtual core::EventReceiver::~EventReceiver ( )

protectedvirtualdefault

Member Function Documentation

atNextTick()

void core::EventReceiver::atNextTick ( const std::function< void(void)> & callBack )

static

Definition at line 50 of file EventReceiver.cpp.

                                                                      {
        class NextTickEvent : public core::EventReceiver {
        public:
            explicit NextTickEvent(const std::function<void(void)>& callBack)
                : core::EventReceiver("RequestEvent")
                , callBack(callBack) {
            }
 
            void onEvent([[maybe_unused]] const utils::Timeval& currentTime) override {
                callBack();
 
                delete this;
            }
 
        private:
            std::function<void(void)> callBack;
        };
 
        (new NextTickEvent(callBack))->span();
    }

References span().

Here is the call graph for this function:

destruct()

void core::EventReceiver::destruct ( )

virtual

Reimplemented in core::socket::stream::SocketAcceptor< PhysicalSocketServerT, ConfigT, SocketConnectionT >, core::socket::stream::SocketAcceptor< PhysicalServerSocketT, ConfigT, core::socket::stream::legacy::SocketConnection >, core::socket::stream::SocketAcceptor< PhysicalSocketServerT, ConfigT, core::socket::stream::tls::SocketConnection >, core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, SocketConnectionT >, core::socket::stream::SocketConnector< PhysicalClientSocketT, ConfigT, core::socket::stream::legacy::SocketConnection >, core::socket::stream::SocketConnector< PhysicalSocketClientT, ConfigT, core::socket::stream::tls::SocketConnection >, and database::mariadb::MariaDBCommandStartEvent.

Definition at line 75 of file EventReceiver.cpp.

                                 {
        delete this;
    }

getName()

const std::string & core::EventReceiver::getName

(

)

const

Definition at line 87 of file EventReceiver.cpp.

                                                  {
        return event.getName();
    }

onEvent()

virtual void core::EventReceiver::onEvent ( const utils::Timeval & currentTime )

pure virtual

Implemented in apps::towercalculator::TowerCalculator, core::DescriptorEventReceiver, core::file::FileReader, core::TimerEventReceiver, database::mariadb::MariaDBCommandStartEvent, and iot::mqtt::OnReceivedFromPeerEvent.

Referenced by core::Event::dispatch().

Here is the caller graph for this function:

operator=() [1/2]

EventReceiver & core::EventReceiver::operator= ( EventReceiver && )

delete

operator=() [2/2]

EventReceiver & core::EventReceiver::operator= ( EventReceiver & )

delete

relax()

void core::EventReceiver::relax

(

)

Definition at line 83 of file EventReceiver.cpp.

                              {
        event.relax();
    }

span()

void core::EventReceiver::span

(

)

Definition at line 79 of file EventReceiver.cpp.

                             {
        event.span();
    }

Referenced by atNextTick(), apps::towercalculator::TowerCalculator::calculate(), core::socket::stream::SocketReader::doRead(), apps::towercalculator::TowerCalculator::onEvent(), and core::multiplexer::epoll::DescriptorEventPublisher::spanActiveEvents().

Here is the caller graph for this function:

Member Data Documentation

event

Event core::EventReceiver::event

private

Definition at line 87 of file EventReceiver.h.

---

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

• core/EventReceiver.h
• core/EventReceiver.cpp