Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 1 | /* |
| 2 | include/proto/fd.h |
| 3 | File descriptors states. |
| 4 | |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 5 | Copyright (C) 2000-2007 Willy Tarreau - w@1wt.eu |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 6 | |
| 7 | This library is free software; you can redistribute it and/or |
| 8 | modify it under the terms of the GNU Lesser General Public |
| 9 | License as published by the Free Software Foundation, version 2.1 |
| 10 | exclusively. |
| 11 | |
| 12 | This library is distributed in the hope that it will be useful, |
| 13 | but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 14 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
| 15 | Lesser General Public License for more details. |
| 16 | |
| 17 | You should have received a copy of the GNU Lesser General Public |
| 18 | License along with this library; if not, write to the Free Software |
| 19 | Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
| 20 | */ |
| 21 | |
| 22 | #ifndef _PROTO_FD_H |
| 23 | #define _PROTO_FD_H |
| 24 | |
Willy Tarreau | 2ff7622 | 2007-04-09 19:29:56 +0200 | [diff] [blame] | 25 | #include <stdio.h> |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 26 | #include <sys/time.h> |
| 27 | #include <sys/types.h> |
| 28 | #include <unistd.h> |
| 29 | |
Willy Tarreau | e3ba5f0 | 2006-06-29 18:54:54 +0200 | [diff] [blame] | 30 | #include <common/config.h> |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 31 | #include <types/fd.h> |
| 32 | |
| 33 | /* Deletes an FD from the fdsets, and recomputes the maxfd limit. |
| 34 | * The file descriptor is also closed. |
| 35 | */ |
| 36 | void fd_delete(int fd); |
| 37 | |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 38 | /* disable the specified poller */ |
| 39 | void disable_poller(const char *poller_name); |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 40 | |
Willy Tarreau | 2a42950 | 2006-10-15 14:52:29 +0200 | [diff] [blame] | 41 | /* |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 42 | * Initialize the pollers till the best one is found. |
| 43 | * If none works, returns 0, otherwise 1. |
Willy Tarreau | ef1d1f8 | 2007-04-16 00:25:25 +0200 | [diff] [blame] | 44 | * The pollers register themselves just before main() is called. |
Willy Tarreau | 2a42950 | 2006-10-15 14:52:29 +0200 | [diff] [blame] | 45 | */ |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 46 | int init_pollers(); |
Willy Tarreau | 2a42950 | 2006-10-15 14:52:29 +0200 | [diff] [blame] | 47 | |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 48 | /* |
Willy Tarreau | 2ff7622 | 2007-04-09 19:29:56 +0200 | [diff] [blame] | 49 | * Some pollers may lose their connection after a fork(). It may be necessary |
| 50 | * to create initialize part of them again. Returns 0 in case of failure, |
| 51 | * otherwise 1. The fork() function may be NULL if unused. In case of error, |
| 52 | * the the current poller is destroyed and the caller is responsible for trying |
| 53 | * another one by calling init_pollers() again. |
| 54 | */ |
| 55 | int fork_poller(); |
| 56 | |
| 57 | /* |
| 58 | * Lists the known pollers on <out>. |
| 59 | * Should be performed only before initialization. |
| 60 | */ |
| 61 | int list_pollers(FILE *out); |
| 62 | |
| 63 | /* |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 64 | * Runs the polling loop |
| 65 | */ |
| 66 | void run_poller(); |
Willy Tarreau | 2a42950 | 2006-10-15 14:52:29 +0200 | [diff] [blame] | 67 | |
Willy Tarreau | f161a34 | 2007-04-08 16:59:42 +0200 | [diff] [blame] | 68 | #define EV_FD_SET(fd, ev) (cur_poller.set((fd), (ev))) |
| 69 | #define EV_FD_CLR(fd, ev) (cur_poller.clr((fd), (ev))) |
Willy Tarreau | 63455a9 | 2007-04-09 15:34:49 +0200 | [diff] [blame] | 70 | #define EV_FD_ISSET(fd, ev) (cur_poller.is_set((fd), (ev))) |
Willy Tarreau | f161a34 | 2007-04-08 16:59:42 +0200 | [diff] [blame] | 71 | #define EV_FD_COND_S(fd, ev) (cur_poller.cond_s((fd), (ev))) |
| 72 | #define EV_FD_COND_C(fd, ev) (cur_poller.cond_c((fd), (ev))) |
Willy Tarreau | 4f60f16 | 2007-04-08 16:39:58 +0200 | [diff] [blame] | 73 | #define EV_FD_REM(fd) (cur_poller.rem(fd)) |
| 74 | #define EV_FD_CLO(fd) (cur_poller.clo(fd)) |
Willy Tarreau | 2a42950 | 2006-10-15 14:52:29 +0200 | [diff] [blame] | 75 | |
| 76 | |
Willy Tarreau | d6f087e | 2008-01-18 17:20:13 +0100 | [diff] [blame] | 77 | /* Prepares <fd> for being polled */ |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 78 | static inline void fd_insert(int fd) |
| 79 | { |
Willy Tarreau | d6f087e | 2008-01-18 17:20:13 +0100 | [diff] [blame] | 80 | fdtab[fd].ev = 0; |
Willy Tarreau | baaee00 | 2006-06-26 02:48:02 +0200 | [diff] [blame] | 81 | if (fd + 1 > maxfd) |
| 82 | maxfd = fd + 1; |
| 83 | } |
| 84 | |
| 85 | |
| 86 | #endif /* _PROTO_FD_H */ |
| 87 | |
| 88 | /* |
| 89 | * Local variables: |
| 90 | * c-indent-level: 8 |
| 91 | * c-basic-offset: 8 |
| 92 | * End: |
| 93 | */ |