nginx/src/event/ngx_event_timer.c

108 lines
2.2 KiB
C
Raw Normal View History

2003-01-22 01:36:01 +08:00
2003-01-24 02:47:54 +08:00
#include <ngx_config.h>
2003-01-22 01:36:01 +08:00
2003-01-24 02:47:54 +08:00
#include <ngx_core.h>
#include <ngx_log.h>
#include <ngx_alloc.h>
#include <ngx_connection.h>
#include <ngx_event.h>
#include <ngx_event_timer.h>
/* STUB */
#define NGX_TIMER_HASH_SIZE 5
ngx_event_t *ngx_timer_queue;
int ngx_timer_hash_size;
int ngx_event_init_timer(ngx_log_t *log)
{
int i;
ngx_timer_hash_size = NGX_TIMER_HASH_SIZE;
ngx_test_null(ngx_timer_queue,
ngx_alloc(ngx_timer_hash_size * sizeof(ngx_event_t), log),
NGX_ERROR);
for (i = 0; i < ngx_timer_hash_size; i++) {
ngx_timer_queue[i].timer_prev = &ngx_timer_queue[i];
ngx_timer_queue[i].timer_next = &ngx_timer_queue[i];
}
return NGX_OK;
}
void ngx_event_add_timer(ngx_event_t *ev, ngx_msec_t timer)
2003-01-22 01:36:01 +08:00
{
2003-01-24 02:47:54 +08:00
int n;
2003-01-22 01:36:01 +08:00
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;
}
n = timer % ngx_timer_hash_size;
2003-01-24 14:20:47 +08:00
#if (NGX_DEBUG_EVENT)
ngx_log_debug(ev->log, "timer slot: %d" _ n);
#endif
2003-01-22 01:36:01 +08:00
2003-01-24 02:47:54 +08:00
for (e = ngx_timer_queue[n].timer_next;
e != &ngx_timer_queue[n] && timer > e->timer_delta;
2003-01-22 01:36:01 +08:00
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;
}
2003-01-24 14:20:47 +08:00
void ngx_event_expire_timers(ngx_msec_t timer)
{
int i;
ngx_msec_t delta;
ngx_event_t *ev;
for (i = 0; i < ngx_timer_hash_size; i++) {
delta = timer;
for ( ;; ) {
ev = ngx_timer_queue[i].timer_next;
if (ev == &ngx_timer_queue[i]) {
break;
}
if (ev->timer_delta > delta) {
ev->timer_delta -= delta;
break;
}
delta -= ev->timer_delta;
ngx_del_timer(ev);
ev->timedout = 1;
if (ev->event_handler(ev) == NGX_ERROR) {
ev->close_handler(ev);
}
}
}
}