src/fdevent.h

   1 #ifndef _FDEVENT_H_
   2 #define _FDEVENT_H_
   3 #include "first.h"
   4
   5 #include "settings.h"
   6
   7 #if defined HAVE_STDINT_H
   8 # include <stdint.h>
   9 #elif defined HAVE_INTTYPES_H
  10 # include <inttypes.h>
  11 #endif
  12
  13 #include <sys/types.h>
  14
  15 /* select event-system */
  16
  17 #if defined(HAVE_EPOLL_CTL) && defined(HAVE_SYS_EPOLL_H)
  18 # define USE_LINUX_EPOLL
  19 #endif
  20
  21 /* MacOS 10.3.x has poll.h under /usr/include/, all other unixes
  22  * under /usr/include/sys/ */
  23 #if defined HAVE_POLL && (defined(HAVE_SYS_POLL_H) || defined(HAVE_POLL_H))
  24 # define USE_POLL
  25 #endif
  26
  27 #if defined HAVE_SELECT
  28 # ifdef __WIN32
  29 #  include <winsock2.h>
  30 # endif
  31 # define USE_SELECT
  32 # ifdef HAVE_SYS_SELECT_H
  33 #  include <sys/select.h>
  34 # endif
  35 #endif
  36
  37 #if defined HAVE_SYS_DEVPOLL_H && defined(__sun)
  38 # define USE_SOLARIS_DEVPOLL
  39 #endif
  40
  41 #if defined HAVE_PORT_H && defined HAVE_PORT_CREATE && defined(__sun)
  42 # define USE_SOLARIS_PORT
  43 # include <port.h>
  44 #endif
  45
  46 #if defined HAVE_SYS_EVENT_H && defined HAVE_KQUEUE
  47 # define USE_FREEBSD_KQUEUE
  48 #endif
  49
  50 #if defined HAVE_LIBEV
  51 # define USE_LIBEV
  52 #endif
  53
  54 struct server;
  55
  56 typedef handler_t (*fdevent_handler)(struct server *srv, void *ctx, int revents);
  57
  58 /* these are the POLL* values from <bits/poll.h> (linux poll)
  59  */
  60
  61 #define FDEVENT_IN     BV(0)
  62 #define FDEVENT_PRI    BV(1)
  63 #define FDEVENT_OUT    BV(2)
  64 #define FDEVENT_ERR    BV(3)
  65 #define FDEVENT_HUP    BV(4)
  66 #define FDEVENT_NVAL   BV(5)
  67
  68 typedef enum { FD_EVENT_TYPE_UNSET = -1,
  69                 FD_EVENT_TYPE_CONNECTION,
  70                 FD_EVENT_TYPE_FCGI_CONNECTION,
  71                 FD_EVENT_TYPE_DIRWATCH,
  72                 FD_EVENT_TYPE_CGI_CONNECTION
  73 } fd_event_t;
  74
  75 typedef enum { FDEVENT_HANDLER_UNSET,
  76                 FDEVENT_HANDLER_SELECT,
  77                 FDEVENT_HANDLER_POLL,
  78                 FDEVENT_HANDLER_LINUX_SYSEPOLL,
  79                 FDEVENT_HANDLER_SOLARIS_DEVPOLL,
  80                 FDEVENT_HANDLER_SOLARIS_PORT,
  81                 FDEVENT_HANDLER_FREEBSD_KQUEUE,
  82                 FDEVENT_HANDLER_LIBEV
  83 } fdevent_handler_t;
  84
  85
  86 typedef struct _fdnode {
  87         fdevent_handler handler;
  88         void *ctx;
  89         void *handler_ctx;
  90         int fd;
  91         int events;
  92 } fdnode;
  93
  94 /**
  95  * array of unused fd's
  96  *
  97  */
  98
  99 typedef struct {
 100         int *ptr;
 101
 102         size_t used;
 103         size_t size;
 104 } buffer_int;
 105
 106 /**
 107  * fd-event handler for select(), poll() and rt-signals on Linux 2.4
 108  *
 109  */
 110 typedef struct fdevents {
 111         struct server *srv;
 112         fdevent_handler_t type;
 113
 114         fdnode **fdarray;
 115         size_t maxfds;
 116
 117 #ifdef USE_LINUX_EPOLL
 118         int epoll_fd;
 119         struct epoll_event *epoll_events;
 120 #endif
 121 #ifdef USE_POLL
 122         struct pollfd *pollfds;
 123
 124         size_t size;
 125         size_t used;
 126
 127         buffer_int unused;
 128 #endif
 129 #ifdef USE_SELECT
 130         fd_set select_read;
 131         fd_set select_write;
 132         fd_set select_error;
 133
 134         fd_set select_set_read;
 135         fd_set select_set_write;
 136         fd_set select_set_error;
 137
 138         int select_max_fd;
 139 #endif
 140 #ifdef USE_SOLARIS_DEVPOLL
 141         int devpoll_fd;
 142         struct pollfd *devpollfds;
 143 #endif
 144 #ifdef USE_SOLARIS_PORT
 145         port_event_t *port_events;
 146 #endif
 147 #ifdef USE_FREEBSD_KQUEUE
 148         int kq_fd;
 149         struct kevent *kq_results;
 150 #endif
 151 #ifdef USE_SOLARIS_PORT
 152         int port_fd;
 153 #endif
 154 #ifdef USE_LIBEV
 155         struct ev_loop *libev_loop;
 156 #endif
 157         int (*reset)(struct fdevents *ev);
 158         void (*free)(struct fdevents *ev);
 159
 160         int (*event_set)(struct fdevents *ev, int fde_ndx, int fd, int events);
 161         int (*event_del)(struct fdevents *ev, int fde_ndx, int fd);
 162         int (*event_get_revent)(struct fdevents *ev, size_t ndx);
 163         int (*event_get_fd)(struct fdevents *ev, size_t ndx);
 164
 165         int (*event_next_fdndx)(struct fdevents *ev, int ndx);
 166
 167         int (*poll)(struct fdevents *ev, int timeout_ms);
 168
 169         int (*fcntl_set)(struct fdevents *ev, int fd);
 170 } fdevents;
 171
 172 fdevents *fdevent_init(struct server *srv, size_t maxfds, fdevent_handler_t type);
 173 int fdevent_reset(fdevents *ev); /* "init" after fork() */
 174 void fdevent_free(fdevents *ev);
 175
 176 void fdevent_event_set(fdevents *ev, int *fde_ndx, int fd, int events); /* events can be FDEVENT_IN, FDEVENT_OUT or FDEVENT_IN | FDEVENT_OUT */
 177 void fdevent_event_del(fdevents *ev, int *fde_ndx, int fd);
 178 int fdevent_event_get_revent(fdevents *ev, size_t ndx);
 179 int fdevent_event_get_fd(fdevents *ev, size_t ndx);
 180 fdevent_handler fdevent_get_handler(fdevents *ev, int fd);
 181 void * fdevent_get_context(fdevents *ev, int fd);
 182
 183 int fdevent_event_next_fdndx(fdevents *ev, int ndx);
 184
 185 int fdevent_poll(fdevents *ev, int timeout_ms);
 186
 187 int fdevent_register(fdevents *ev, int fd, fdevent_handler handler, void *ctx);
 188 int fdevent_unregister(fdevents *ev, int fd);
 189
 190 void fd_close_on_exec(int fd);
 191 int fdevent_fcntl_set(fdevents *ev, int fd);
 192
 193 int fdevent_select_init(fdevents *ev);
 194 int fdevent_poll_init(fdevents *ev);
 195 int fdevent_linux_sysepoll_init(fdevents *ev);
 196 int fdevent_solaris_devpoll_init(fdevents *ev);
 197 int fdevent_solaris_port_init(fdevents *ev);
 198 int fdevent_freebsd_kqueue_init(fdevents *ev);
 199 int fdevent_libev_init(fdevents *ev);
 200
 201 #endif