kqueue.hpp

#ifndef kqueue_hpp
#define kqueue_hpp

#include "file_descriptor.h"
#include "timer.h"

#include <functional>
#include <cstdint>
#include <sys/event.h>
#include <list>

namespace sysapi
{
    struct epoll;
    struct epoll_registration;
    
    struct epoll
    {
        typedef std::function<void ()> action_t;
        epoll();
        epoll(epoll const&) = delete;
        epoll(epoll&&);
        
        epoll& operator=(epoll);
        
        void swap(epoll& other);
        
        void run();
        timer& get_timer();
        
    private:
        void add(int fd, int16_t event, epoll_registration*);
        void modify(int fd, int16_t event, epoll_registration*);
        void remove(int fd, int16_t event);
        
        int run_timers_calculate_timeout();
        
    private:
        file_descriptor fd_;
        timer timer_;
        std::list<std::pair<int, int16_t>> deleted_events;
        
        friend struct epoll_registration;
    };
    
    struct epoll_registration
    {
        typedef std::function<void (struct kevent)> callback_t;
        
        epoll_registration();
        epoll_registration(epoll&, int fd, std::list<int16_t> events, callback_t callback);
        epoll_registration(epoll_registration const&) = delete;
        epoll_registration(epoll_registration&&);
        ~epoll_registration();
        
        epoll_registration& operator=(epoll_registration);
        
        void modify(std::list<int16_t> new_events);
        
        void swap(epoll_registration& other);
        
        void clear();
        epoll& get_epoll() const;
        
    private:
        void update();
        
    private:
        epoll* ep;
        int fd;
        std::list<int16_t> events;
        callback_t callback;
        
        friend struct epoll;
    };
}

using sysapi::epoll;
using sysapi::epoll_registration;

#endif