Mercurial > hg > nginx-quic
diff src/event/modules/ngx_kqueue_module.c @ 26:53cb81681040
nginx-0.0.1-2002-12-15-09:25:09 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Sun, 15 Dec 2002 06:25:09 +0000 |
parents | 72ad26c77d2d |
children | d45effe5854c |
line wrap: on
line diff
--- a/src/event/modules/ngx_kqueue_module.c +++ b/src/event/modules/ngx_kqueue_module.c @@ -16,12 +16,14 @@ #endif - +/* should be per-thread */ static int kq; static struct kevent *change_list, *event_list; static int nchanges, nevents; static ngx_event_t timer_queue; +/* */ + int ngx_kqueue_init(int max_connections, ngx_log_t *log) { @@ -53,6 +55,7 @@ int ngx_kqueue_init(int max_connections, return NGX_OK; } + int ngx_kqueue_add_event(ngx_event_t *ev, int event, u_int flags) { ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0; @@ -60,22 +63,33 @@ int ngx_kqueue_add_event(ngx_event_t *ev return ngx_kqueue_set_event(ev, event, EV_ADD | flags); } -int ngx_kqueue_del_event(ngx_event_t *ev, int event) + +int ngx_kqueue_del_event(ngx_event_t *ev, int event, u_int flags) { ngx_event_t *e; - if (ev->index <= nchanges && change_list[ev->index].udata == ev) { - change_list[ev->index] = change_list[nchanges]; - e = (ngx_event_t *) change_list[ev->index].udata; - e->index = ev->index; - nchanges--; + if (ev->index < nchanges && change_list[ev->index].udata == ev) { + + ngx_connection_t *cn = (ngx_connection_t *) ev->data; + ngx_log_debug(ev->log, "kqueue del event: %d: ft:%d" _ + cn->fd _ event); + + if (ev->index < --nchanges) { + e = (ngx_event_t *) change_list[nchanges].udata; + change_list[ev->index] = change_list[nchanges]; + e->index = ev->index; + } return NGX_OK; } + if (flags & NGX_CLOSE_EVENT) + return NGX_OK; + return ngx_kqueue_set_event(ev, event, EV_DELETE); } + int ngx_kqueue_set_event(ngx_event_t *ev, int filter, u_int flags) { struct timespec ts = { 0, 0 }; @@ -110,13 +124,18 @@ int ngx_kqueue_set_event(ngx_event_t *ev return NGX_OK; } + int ngx_kqueue_process_events(ngx_log_t *log) { int events, i; - u_int timer = 0, delta = 0; + u_int timer, delta; ngx_event_t *ev; struct timeval tv; - struct timespec ts, *tp = NULL; + struct timespec ts, *tp; + + timer = 0; + delta = 0; + tp = NULL; if (timer_queue.timer_next != &timer_queue) { timer = timer_queue.timer_next->timer_delta; @@ -212,6 +231,7 @@ int ngx_kqueue_process_events(ngx_log_t return NGX_OK; } + void ngx_kqueue_add_timer(ngx_event_t *ev, ngx_msec_t timer) { ngx_event_t *e;