eventloop.hh

Go to the documentation of this file.

#ifndef SPONGE_LIBSPONGE_EVENTLOOP_HH
#define SPONGE_LIBSPONGE_EVENTLOOP_HH
 
#include "file_descriptor.hh"
 
#include <cstdlib>
#include <functional>
#include <list>
#include <poll.h>
 
class EventLoop {
  public:
    enum class Direction : short {
        In = POLLIN,   
        Out = POLLOUT  
    };
 
  private:
    using CallbackT = std::function<void(void)>;  
    using InterestT = std::function<bool(void)>;  
 
    class Rule {
      public:
        FileDescriptor fd;    
        Direction direction;  
        CallbackT callback;   
        InterestT interest;   
        CallbackT cancel;     
 
        unsigned int service_count() const;
    };
 
    std::list<Rule> _rules{};  
 
  public:
    enum class Result {
        Success,  
        Timeout,  
        Exit  
    };
 
    void add_rule(const FileDescriptor &fd,
                  const Direction direction,
                  const CallbackT &callback,
                  const InterestT &interest = [] { return true; },
                  const CallbackT &cancel = [] {});
 
    Result wait_next_event(const int timeout_ms);
};
 
using Direction = EventLoop::Direction;
 
 
#endif  // SPONGE_LIBSPONGE_EVENTLOOP_HH