ioevent

   1 #ifndef _IOEVENT__HPP_
   2 #define _IOEVENT__HPP_
   3
   4 /// \file ioevent
   5 /// \brief Inline I/O event watcher classes
   6 /// Copying: http://en.wikipedia.org/wiki/Copyright-free
   7 /// Intended for public-domain wherever possible:
   8 /// http://en.wikipedia.org/wiki/Public_domain
   9
  10 /// \author Chris Brody mailto:chris.brody@gmail.com
  11
  12 /// May be used with http://libev.schmorp.de/ or
  13 /// http://monkey.org/~provos/libevent/
  14
  15 #include <sys/types.h>
  16 #include <event.h>
  17
  18 /// I/O event callback type
  19 /// @see http://monkey.org/~provos/libevent/
  20 typedef void cbtype (int, short, void *);
  21
  22 /// Macro - reference to an I/O event loop
  23 #define IOLOOP event_base *
  24
  25 /// Construct new I/O event loop
  26 inline IOLOOP
  27 ioloop_new()
  28 {
  29         return (IOLOOP)::event_init();
  30 }
  31
  32 /// Dispatch incoming I/O events & timers
  33 /// (event loop with no special flags)
  34 /// @param l Reference to I/O event loop
  35 inline void
  36 ioloop_dispatch(IOLOOP l)
  37 {
  38         ::event_base_loop(l, 0);
  39 }
  40
  41 /// Event loop - dispatch incoming I/O events & timers
  42 /// @param l Reference to I/O event loop
  43 /// @param flags Desired EV flags for event loop
  44 inline void
  45 ioloop_loop(IOLOOP l, int flags)
  46 {
  47         ::event_base_loop(l, flags);
  48 }
  49
  50 /// Base I/O watcher class
  51 struct iowatcher : public event
  52 {
  53         void set (IOLOOP l)
  54         {
  55                 ::event_base_set(l, this);
  56         }
  57
  58         void set (int s, short ev)
  59         {
  60                 ::event_set(this, s, (ev & (EV_READ | EV_WRITE)) ? (ev | EV_PERSIST) : ev, ev_callback, ev_arg);
  61         }
  62
  63         void start()
  64         {
  65                 ::event_add(this, NULL);
  66         }
  67
  68         void stop()
  69         {
  70                 ::event_del(this);
  71         }
  72
  73 protected:
  74         iowatcher(int s, short ev, cbtype cb, void * v = 0)
  75         {
  76                 ::event_set(this, s, (ev & (EV_READ | EV_WRITE)) ? (ev | EV_PERSIST) : ev, cb, v);
  77         }
  78
  79         iowatcher(cbtype cb, void * v = 0)
  80         {
  81                 ::event_set(this, -1, 0, cb, v);
  82         }
  83
  84 //private:
  85         iowatcher() { }
  86 };
  87
  88 /// I/O event watcher
  89 struct ioevent : public iowatcher
  90 {
  91         ioevent(int s, short ev, cbtype cb, void * v = 0) : iowatcher(s, ev, cb, v) { }
  92
  93         ioevent(cbtype cb, void * v = 0) : iowatcher(cb, v) { }
  94
  95 private:
  96         ioevent() { }
  97 };
  98
  99 /// I/O timer watcher
 100 struct itimer : public iowatcher
 101 {
 102         itimer(cbtype cb, void * v = 0) : iowatcher(cb, v) { }
 103
 104         void start(int ts)
 105         {
 106                 struct timeval tv;
 107
 108                 tv.tv_sec = ts;
 109                 tv.tv_usec = 0;
 110
 111                 ::event_add(this, &tv);
 112         }
 113
 114 private:
 115         itimer() { }
 116 };
 117
 118 #endif