7 #if defined HAVE_STDINT_H
9 #elif defined HAVE_INTTYPES_H
10 # include <inttypes.h>
13 #include <sys/types.h>
15 /* select event-system */
17 #if defined(HAVE_EPOLL_CTL) && defined(HAVE_SYS_EPOLL_H)
18 # define USE_LINUX_EPOLL
19 struct epoll_event
; /* declaration */
22 /* MacOS 10.3.x has poll.h under /usr/include/, all other unixes
23 * under /usr/include/sys/ */
24 #if defined HAVE_POLL && (defined(HAVE_SYS_POLL_H) || defined(HAVE_POLL_H))
26 struct pollfd
; /* declaration */
29 #if defined HAVE_SELECT
31 # include <winsock2.h>
34 # ifdef HAVE_SYS_SELECT_H
35 # include <sys/select.h>
39 #if defined HAVE_SYS_DEVPOLL_H && defined(__sun)
40 # define USE_SOLARIS_DEVPOLL
41 struct pollfd
; /* declaration */
44 #if defined HAVE_PORT_H && defined HAVE_PORT_CREATE && defined(__sun)
45 # define USE_SOLARIS_PORT
49 #if defined HAVE_SYS_EVENT_H && defined HAVE_KQUEUE
50 # define USE_FREEBSD_KQUEUE
51 struct kevent
; /* declaration */
54 #if defined HAVE_LIBEV
56 struct ev_loop
; /* declaration */
59 struct server
; /* declaration */
61 typedef handler_t (*fdevent_handler
)(struct server
*srv
, void *ctx
, int revents
);
63 /* these are the POLL* values from <bits/poll.h> (linux poll)
66 #define FDEVENT_IN BV(0)
67 #define FDEVENT_PRI BV(1)
68 #define FDEVENT_OUT BV(2)
69 #define FDEVENT_ERR BV(3)
70 #define FDEVENT_HUP BV(4)
71 #define FDEVENT_NVAL BV(5)
73 #define FDEVENT_STREAM_REQUEST BV(0)
74 #define FDEVENT_STREAM_REQUEST_BUFMIN BV(1)
75 #define FDEVENT_STREAM_REQUEST_POLLIN BV(15)
77 #define FDEVENT_STREAM_RESPONSE BV(0)
78 #define FDEVENT_STREAM_RESPONSE_BUFMIN BV(1)
80 typedef enum { FD_EVENT_TYPE_UNSET
= -1,
81 FD_EVENT_TYPE_CONNECTION
,
82 FD_EVENT_TYPE_FCGI_CONNECTION
,
83 FD_EVENT_TYPE_DIRWATCH
,
84 FD_EVENT_TYPE_CGI_CONNECTION
87 typedef enum { FDEVENT_HANDLER_UNSET
,
88 FDEVENT_HANDLER_SELECT
,
90 FDEVENT_HANDLER_LINUX_SYSEPOLL
,
91 FDEVENT_HANDLER_SOLARIS_DEVPOLL
,
92 FDEVENT_HANDLER_SOLARIS_PORT
,
93 FDEVENT_HANDLER_FREEBSD_KQUEUE
,
98 typedef struct _fdnode
{
99 fdevent_handler handler
;
107 * array of unused fd's
119 * fd-event handler for select(), poll() and rt-signals on Linux 2.4
122 typedef struct fdevents
{
124 fdevent_handler_t type
;
130 #ifdef USE_LINUX_EPOLL
132 struct epoll_event
*epoll_events
;
135 struct pollfd
*pollfds
;
147 fd_set select_set_read
;
148 fd_set select_set_write
;
149 fd_set select_set_error
;
153 #ifdef USE_SOLARIS_DEVPOLL
155 struct pollfd
*devpollfds
;
157 #ifdef USE_SOLARIS_PORT
158 port_event_t
*port_events
;
160 #ifdef USE_FREEBSD_KQUEUE
162 struct kevent
*kq_results
;
164 #ifdef USE_SOLARIS_PORT
168 struct ev_loop
*libev_loop
;
170 int (*reset
)(struct fdevents
*ev
);
171 void (*free
)(struct fdevents
*ev
);
173 int (*event_set
)(struct fdevents
*ev
, int fde_ndx
, int fd
, int events
);
174 int (*event_del
)(struct fdevents
*ev
, int fde_ndx
, int fd
);
175 int (*event_get_revent
)(struct fdevents
*ev
, size_t ndx
);
176 int (*event_get_fd
)(struct fdevents
*ev
, size_t ndx
);
178 int (*event_next_fdndx
)(struct fdevents
*ev
, int ndx
);
180 int (*poll
)(struct fdevents
*ev
, int timeout_ms
);
183 fdevents
*fdevent_init(struct server
*srv
, size_t maxfds
, int type
);
184 int fdevent_reset(fdevents
*ev
); /* "init" after fork() */
185 void fdevent_free(fdevents
*ev
);
187 #define fdevent_event_get_interest(ev, fd) \
188 ((fd) >= 0 ? (ev)->fdarray[(fd)]->events : 0)
189 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 */
190 void fdevent_event_add(fdevents
*ev
, int *fde_ndx
, int fd
, int event
); /* events can be FDEVENT_IN or FDEVENT_OUT */
191 void fdevent_event_clr(fdevents
*ev
, int *fde_ndx
, int fd
, int event
); /* events can be FDEVENT_IN or FDEVENT_OUT */
192 void fdevent_event_del(fdevents
*ev
, int *fde_ndx
, int fd
);
193 int fdevent_event_get_revent(fdevents
*ev
, size_t ndx
);
194 int fdevent_event_get_fd(fdevents
*ev
, size_t ndx
);
195 fdevent_handler
fdevent_get_handler(fdevents
*ev
, int fd
);
196 void * fdevent_get_context(fdevents
*ev
, int fd
);
198 int fdevent_event_next_fdndx(fdevents
*ev
, int ndx
);
200 int fdevent_poll(fdevents
*ev
, int timeout_ms
);
202 int fdevent_register(fdevents
*ev
, int fd
, fdevent_handler handler
, void *ctx
);
203 int fdevent_unregister(fdevents
*ev
, int fd
);
204 void fdevent_sched_close(fdevents
*ev
, int fd
, int issock
);
205 void fdevent_sched_run(struct server
*srv
, fdevents
*ev
);
207 void fdevent_setfd_cloexec(int fd
);
208 void fdevent_clrfd_cloexec(int fd
);
209 int fdevent_fcntl_set_nb(fdevents
*ev
, int fd
);
210 int fdevent_fcntl_set_nb_cloexec(fdevents
*ev
, int fd
);
211 int fdevent_fcntl_set_nb_cloexec_sock(fdevents
*ev
, int fd
);
212 int fdevent_socket_cloexec(int domain
, int type
, int protocol
);
213 int fdevent_socket_nb_cloexec(int domain
, int type
, int protocol
);
214 int fdevent_open_cloexec(const char *pathname
, int flags
, mode_t mode
);
217 int fdevent_accept_listenfd(int listenfd
, struct sockaddr
*addr
, size_t *addrlen
);
219 int fdevent_open_devnull(void);
220 int fdevent_open_dirname(char *path
);
221 int fdevent_set_stdin_stdout_stderr(int fdin
, int fdout
, int fderr
);
222 pid_t
fdevent_fork_execve(const char *name
, char *argv
[], char *envp
[], int fdin
, int fdout
, int fderr
, int dfd
);
223 int fdevent_open_logger(const char *logger
);
224 int fdevent_cycle_logger(const char *logger
, int *curfd
);
225 int fdevent_reaped_logger_pipe(pid_t pid
);
226 int fdevent_waitpid_logger_pipe_pid(pid_t pid
, time_t ts
);
227 void fdevent_restart_logger_pipes(time_t ts
);
228 void fdevent_close_logger_pipes(void);
229 void fdevent_breakagelog_logger_pipe(int fd
);
230 void fdevent_clr_logger_pipe_pids(void);
232 int fdevent_select_init(fdevents
*ev
);
233 int fdevent_poll_init(fdevents
*ev
);
234 int fdevent_linux_sysepoll_init(fdevents
*ev
);
235 int fdevent_solaris_devpoll_init(fdevents
*ev
);
236 int fdevent_solaris_port_init(fdevents
*ev
);
237 int fdevent_freebsd_kqueue_init(fdevents
*ev
);
238 int fdevent_libev_init(fdevents
*ev
);
240 int fdevent_ioctl_fionread (int fd
, int fdfmt
, int *toread
);
242 int fdevent_connect_status(int fd
);
244 /* fd must be TCP socket (AF_INET, AF_INET6), end-of-stream recv() 0 bytes */
245 int fdevent_is_tcp_half_closed(int fd
);
246 int fdevent_set_tcp_nodelay (const int fd
, const int opt
);
248 int fdevent_set_so_reuseaddr (const int fd
, const int opt
);