Mercurial > hg > nginx-quic
diff src/event/modules/ngx_select_module.c @ 53:d1e42f1b8fd4
nginx-0.0.1-2003-01-27-00:08:14 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Sun, 26 Jan 2003 21:08:14 +0000 |
parents | b288069a8696 |
children | e8cdc2989cee |
line wrap: on
line diff
--- a/src/event/modules/ngx_select_module.c +++ b/src/event/modules/ngx_select_module.c @@ -23,11 +23,11 @@ static int max_write; static int max_fd; #endif -static u_int nevents; +static int nevents; static ngx_event_t **event_index; static ngx_event_t **ready_index; -static ngx_event_t timer_queue; +static ngx_event_t *timer_queue; /* */ int ngx_select_init(int max_connections, ngx_log_t *log) @@ -57,12 +57,14 @@ int ngx_select_init(int max_connections, nevents = 0; - timer_queue.timer_prev = &timer_queue; - timer_queue.timer_next = &timer_queue; + timer_queue = ngx_event_init_timer(log); + if (timer_queue == NULL) { + return NGX_ERROR; + } ngx_event_actions.add = ngx_select_add_event; ngx_event_actions.del = ngx_select_del_event; - ngx_event_actions.timer = ngx_select_add_timer; + ngx_event_actions.timer = ngx_event_add_timer; ngx_event_actions.process = ngx_select_process_events; #if (WIN32) @@ -176,7 +178,8 @@ int ngx_select_del_event(ngx_event_t *ev int ngx_select_process_events(ngx_log_t *log) { int ready, found, nready; - u_int i, timer, delta; + u_int i; + ngx_msec_t timer, delta; ngx_event_t *ev; ngx_connection_t *c; struct timeval tv, *tp; @@ -184,12 +187,12 @@ int ngx_select_process_events(ngx_log_t work_read_fd_set = master_read_fd_set; work_write_fd_set = master_write_fd_set; - if (timer_queue.timer_next != &timer_queue) { - timer = timer_queue.timer_next->timer_delta; + timer = ngx_event_find_timer(); + + if (timer) { tv.tv_sec = timer / 1000; tv.tv_usec = (timer % 1000) * 1000; tp = &tv; - delta = ngx_msec(); } else { @@ -309,58 +312,9 @@ int ngx_select_process_events(ngx_log_t ngx_log_error(NGX_LOG_ALERT, log, 0, "select ready != events"); } - if (timer && timer_queue.timer_next != &timer_queue) { - if (delta >= timer_queue.timer_next->timer_delta) { - for ( ;; ) { - ev = timer_queue.timer_next; - - if (ev == &timer_queue || delta < ev->timer_delta) { - break; - } - - delta -= ev->timer_delta; - - ngx_del_timer(ev); - ev->timedout = 1; - if (ev->event_handler(ev) == NGX_ERROR) { - ev->close_handler(ev); - } - } - - } else { - timer_queue.timer_next->timer_delta -= delta; - } + if (timer) { + ngx_event_expire_timers(delta); } return NGX_OK; } - -void ngx_select_add_timer(ngx_event_t *ev, ngx_msec_t timer) -{ - ngx_event_t *e; - -#if (NGX_DEBUG_EVENT) - ngx_connection_t *c = (ngx_connection_t *) ev->data; - ngx_log_debug(ev->log, "set timer: %d:%d" _ c->fd _ timer); -#endif - - if (ev->timer_next || ev->timer_prev) { - ngx_log_error(NGX_LOG_ALERT, ev->log, 0, "timer already set"); - return; - } - - for (e = timer_queue.timer_next; - e != &timer_queue && timer > e->timer_delta; - e = e->timer_next) - { - timer -= e->timer_delta; - } - - ev->timer_delta = timer; - - ev->timer_next = e; - ev->timer_prev = e->timer_prev; - - e->timer_prev->timer_next = ev; - e->timer_prev = ev; -}