Mercurial > hg > nginx

comparison src/event/modules/ngx_kqueue_module.c @ 38:2ffaa35fba42

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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;