Mercurial > hg > nginx
comparison src/event/modules/ngx_kqueue_module.c @ 38:2ffaa35fba42
nginx-0.0.1-2002-12-24-10:09:57 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Tue, 24 Dec 2002 07:09:57 +0000 |
parents | c14d7232b11f |
children | 83fa61cd3d2f |
comparison
equal
deleted
inserted
replaced
37:9fe40e51d4a3 | 38:2ffaa35fba42 |
---|---|
59 | 59 |
60 int ngx_kqueue_add_event(ngx_event_t *ev, int event, u_int flags) | 60 int ngx_kqueue_add_event(ngx_event_t *ev, int event, u_int flags) |
61 { | 61 { |
62 ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0; | 62 ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0; |
63 | 63 |
64 #if 1 | |
65 if (nchanges > 0 | 64 if (nchanges > 0 |
66 && ev->index < nchanges | 65 && ev->index < nchanges |
67 && change_list[ev->index].udata == ev) | 66 && change_list[ev->index].udata == ev) |
68 { | 67 { |
69 /* DEBUG */ | 68 /* DEBUG */ |
73 change_list[ev->index].filter = event; | 72 change_list[ev->index].filter = event; |
74 change_list[ev->index].flags = flags; | 73 change_list[ev->index].flags = flags; |
75 | 74 |
76 return NGX_OK; | 75 return NGX_OK; |
77 } | 76 } |
78 #endif | |
79 | 77 |
80 return ngx_kqueue_set_event(ev, event, EV_ADD | flags); | 78 return ngx_kqueue_set_event(ev, event, EV_ADD | flags); |
81 } | 79 } |
82 | 80 |
83 | 81 |
138 change_list[nchanges].flags = flags; | 136 change_list[nchanges].flags = flags; |
139 change_list[nchanges].fflags = 0; | 137 change_list[nchanges].fflags = 0; |
140 change_list[nchanges].data = 0; | 138 change_list[nchanges].data = 0; |
141 change_list[nchanges].udata = ev; | 139 change_list[nchanges].udata = ev; |
142 | 140 |
143 #if 0 | 141 ev->index = nchanges; |
144 if (flags == EV_ADD) | |
145 #endif | |
146 ev->index = nchanges; | |
147 | 142 |
148 nchanges++; | 143 nchanges++; |
149 | 144 |
150 return NGX_OK; | 145 return NGX_OK; |
151 } | 146 } |
262 | 257 |
263 void ngx_kqueue_add_timer(ngx_event_t *ev, ngx_msec_t timer) | 258 void ngx_kqueue_add_timer(ngx_event_t *ev, ngx_msec_t timer) |
264 { | 259 { |
265 ngx_event_t *e; | 260 ngx_event_t *e; |
266 | 261 |
267 ngx_log_debug(ev->log, "set timer: %d" _ timer); | 262 #if (NGX_DEBUG) |
268 | 263 ngx_connection_t *c = (ngx_connection_t *) ev->data; |
264 ngx_log_debug(ev->log, "set timer: %d:%d" _ c->fd _ timer); | |
265 #endif | |
269 ngx_assert((!ev->timer_next && !ev->timer_prev), return, ev->log, | 266 ngx_assert((!ev->timer_next && !ev->timer_prev), return, ev->log, |
270 "timer already set"); | 267 "timer already set"); |
271 | 268 |
272 for (e = timer_queue.timer_next; | 269 for (e = timer_queue.timer_next; |
273 e != &timer_queue && timer > e->timer_delta; | 270 e != &timer_queue && timer > e->timer_delta; |