reactor.hpp

Go to the documentation of this file.

 
#ifndef __JOIN_REACTOR_HPP__
#define __JOIN_REACTOR_HPP__
 
// libjoin.
#include <join/condition.hpp>
 
// C++.
#include <thread>
#include <vector>
 
// C.
#include <sys/epoll.h>
 
namespace join
{
    class EventHandler
    {
    public:
        EventHandler () = default;
 
        virtual ~EventHandler () = default;
 
        virtual int handle () const noexcept = 0;
 
    protected:
        virtual void onReceive ()
        {
            // do nothing.
        }
 
        virtual void onClose ()
        {
            // do nothing.
        }
 
        virtual void onError ()
        {
            // do nothing.
        }
 
        friend class Reactor;
    };
 
    class Reactor
    {
    public:
        Reactor ();
 
        Reactor (const Reactor& other) = delete;
 
        Reactor (Reactor&& other) = delete;
 
        Reactor& operator= (const Reactor& other) = delete;
 
        Reactor& operator= (Reactor&& other) = delete;
 
        ~Reactor ();
 
        int addHandler (EventHandler* handler);
 
        int delHandler (EventHandler* handler);
 
        static Reactor* instance ();
 
    protected:
        void dispatch ();
 
        int _eventfd = -1;
 
        int _epoll = -1;
 
        std::thread::id _threadId;
 
        RecursiveMutex _mutex;
 
        Condition _threadStatus;
 
        bool _running = false;
 
        int _num = 0;
    };
}
 
#endif