lighttpd中采取了類似于OO中面向?qū)ο蟮姆绞椒庋b了各種平臺(tái)對(duì)網(wǎng)絡(luò)IO的事件處理,這其中包括:
OS Method Config Value
all select select
Unix poll poll
Linux 2.4+ rt-signals linux-rtsig
Linux 2.6+ epoll linux-sysepoll
Solaris /dev/poll solaris-devpoll
FreeBSD, ... kqueue freebsd-kqueue
NetBSD kqueue kqueue
所有的網(wǎng)絡(luò)IO事件都要滿足這個(gè)數(shù)據(jù)結(jié)構(gòu)的要求, 這個(gè)名為fdevents的結(jié)構(gòu)體可以看成是OO中虛擬基類, 而每種具體的實(shí)現(xiàn)則可以看成是
繼承并且實(shí)現(xiàn)了該虛擬基類中純虛函數(shù)的派生類:
typedef struct fdevents {
fdevent_handler_t type;
fdnode **fdarray;
size_t maxfds;
#ifdef USE_LINUX_SIGIO
int in_sigio;
int signum;
sigset_t sigset;
siginfo_t siginfo;
bitset *sigbset;
#endif
#ifdef USE_LINUX_EPOLL
int epoll_fd;
struct epoll_event *epoll_events;
#endif
#ifdef USE_POLL
struct pollfd *pollfds;
size_t size;
size_t used;
buffer_int unused;
#endif
#ifdef USE_SELECT
fd_set select_read;
fd_set select_write;
fd_set select_error;
fd_set select_set_read;
fd_set select_set_write;
fd_set select_set_error;
int select_max_fd;
#endif
#ifdef USE_SOLARIS_DEVPOLL
int devpoll_fd;
struct pollfd *devpollfds;
#endif
#ifdef USE_FREEBSD_KQUEUE
int kq_fd;
struct kevent *kq_results;
bitset *kq_bevents;
#endif
#ifdef USE_SOLARIS_PORT
int port_fd;
#endif
int (*reset)(struct fdevents *ev);
void (*free)(struct fdevents *ev);
int (*event_add)(struct fdevents *ev, int fde_ndx, int fd, int events);
int (*event_del)(struct fdevents *ev, int fde_ndx, int fd);
int (*event_get_revent)(struct fdevents *ev, size_t ndx);
int (*event_get_fd)(struct fdevents *ev, size_t ndx);
int (*event_next_fdndx)(struct fdevents *ev, int ndx);
int (*poll)(struct fdevents *ev, int timeout_ms);
int (*fcntl_set)(struct fdevents *ev, int fd);
} fdevents;
該結(jié)構(gòu)體中包含了一些公有的參數(shù), 也就是類似OO中虛擬基類中的成員變量, 無論是哪個(gè)派生類繼承之后都會(huì)有這部分的成員,
如最前面的幾個(gè)成員:
fdevent_handler_t type;
fdnode **fdarray;
size_t maxfds;
其中type是如下類型的枚舉:
typedef enum
{
FDEVENT_HANDLER_UNSET,
FDEVENT_HANDLER_SELECT,
FDEVENT_HANDLER_POLL,
FDEVENT_HANDLER_LINUX_RTSIG,
FDEVENT_HANDLER_LINUX_SYSEPOLL,
FDEVENT_HANDLER_SOLARIS_DEVPOLL,
FDEVENT_HANDLER_FREEBSD_KQUEUE,
FDEVENT_HANDLER_SOLARIS_PORT
} fdevent_handler_t;
, 其實(shí)也就是各個(gè)不同IO事件類型.
fdarray是一個(gè)存放fdnode *類型的數(shù)組:
typedef struct _fdnode {
fdevent_handler handler;
void *ctx;
int fd;
struct _fdnode *prev, *next;
} fdnode;
這個(gè)結(jié)構(gòu)體中, handler是一個(gè)回調(diào)函數(shù), 在事件觸發(fā)時(shí)進(jìn)行回調(diào)(后面我們會(huì)講到), ctx是一個(gè)context, 根據(jù)不同的fd進(jìn)行區(qū)分.
fd就不必多說了, 是socket fd, 可能是服務(wù)器監(jiān)聽所有的fd, 也可能是accept之后與client相關(guān)的fd.再后面的兩個(gè)參數(shù), 將這個(gè)結(jié)構(gòu)體
變?yōu)榱艘粋€(gè)鏈表中的一個(gè)節(jié)點(diǎn).
maxfds, 這個(gè)成員用于存放可以處理的最大數(shù)量.
除了這些公有成員外, 根據(jù)編譯時(shí)的預(yù)編譯宏, 該結(jié)構(gòu)體還有其它的成員, 這些成員就相當(dāng)于OO中具體每個(gè)派生類自己私有的成員.
在這個(gè)結(jié)構(gòu)體的最后, 是一組函數(shù)指針, 也就是OO中的純虛函數(shù), 每個(gè)派生類都要根據(jù)這些接口自己進(jìn)行實(shí)現(xiàn),我分別給加上了一些簡單的注釋:
// 重置某個(gè)fdevents
int (*reset)(struct fdevents *ev);
// 釋放fdevents指針
void (*free)(struct fdevents *ev);
// 向fdevents中添加一個(gè)fd, events表示這個(gè)fd對(duì)哪些事件感興趣
int (*event_add)(struct fdevents *ev, int fde_ndx, int fd, int events);
// 向fdevents中刪除一個(gè)fd
int (*event_del)(struct fdevents *ev, int fde_ndx, int fd);
// 根據(jù)fd在fdevents中的fdarray中的index, 獲取該fd目前對(duì)哪些事件感興趣
int (*event_get_revent)(struct fdevents *ev, size_t ndx);
// 根據(jù)fd在fdevents中的fdarray中的index, 獲取要進(jìn)行處理的fd
int (*event_get_fd)(struct fdevents *ev, size_t ndx);
// 獲取下一個(gè)需要進(jìn)行處理的fd在fdarray中的index
int (*event_next_fdndx)(struct fdevents *ev, int ndx);
// 輪詢, timeout_ms是超時(shí)參數(shù), 單位是微秒
int (*poll)(struct fdevents *ev, int timeout_ms);
// 這個(gè)接口一般都沒有實(shí)現(xiàn), 為NULL
int (*fcntl_set)(struct fdevents *ev, int fd);
在上面的函數(shù)中, 參數(shù)int events的值為以下幾種:
#define BV(x) (1 << x)
#define FDEVENT_IN BV(0)
#define FDEVENT_PRI BV(1)
#define FDEVENT_OUT BV(2)
#define FDEVENT_ERR BV(3)
#define FDEVENT_HUP BV(4)
#define FDEVENT_NVAL BV(5)
從這里可以看到, 具體判斷某個(gè)事件是否發(fā)生, 需要采用的掩碼操作進(jìn)行判斷, 而不是一般的比較操作, 如:
if (events & FDEVENT_IN) 而不是 if (events == FDEVENT_IN)
因此, 一個(gè)fd, 當(dāng)前所關(guān)注的事件類型可以不止一個(gè)而是有多個(gè).
了解了這個(gè)結(jié)構(gòu)體之后, 也就了解了lighttpd中每種網(wǎng)絡(luò)IO事件必須處理的事件類型及它們對(duì)外的接口.下一節(jié)開始講解在lighttpd中是如何使用這個(gè)事件處理器的.