Mercurial > hg > nginx
view src/event/ngx_event_timer.c @ 269:f082cb6bcdd7
nginx-0.0.2-2004-02-25-18:46:57 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 25 Feb 2004 15:46:57 +0000 |
parents | 5238e93961a1 |
children | 7bb9562216ce |
line wrap: on
line source
#include <ngx_config.h> #include <ngx_core.h> #include <ngx_event.h> /* * TODO: in multithreaded enviroment all timer operations must be * protected by the single mutex */ #if (NGX_THREADS) static ngx_mutex_t *ngx_event_timer_mutex; #endif ngx_rbtree_t *ngx_event_timer_rbtree; ngx_rbtree_t ngx_event_timer_sentinel; void ngx_event_timer_init(void) { if (ngx_event_timer_rbtree) { return; } ngx_event_timer_rbtree = &ngx_event_timer_sentinel; } ngx_msec_t ngx_event_find_timer(void) { ngx_rbtree_t *node; if (ngx_event_timer_rbtree == &ngx_event_timer_sentinel) { return 0; } node = ngx_rbtree_min(ngx_event_timer_rbtree, &ngx_event_timer_sentinel); return (ngx_msec_t) (node->key * NGX_TIMER_RESOLUTION - ngx_elapsed_msec / NGX_TIMER_RESOLUTION * NGX_TIMER_RESOLUTION); #if 0 (node->key * NGX_TIMER_RESOLUTION - ngx_elapsed_msec); #endif } void ngx_event_expire_timers(ngx_msec_t timer) { ngx_event_t *ev; ngx_rbtree_t *node; for ( ;; ) { if (ngx_event_timer_rbtree == &ngx_event_timer_sentinel) { break; } node = ngx_rbtree_min(ngx_event_timer_rbtree, &ngx_event_timer_sentinel); if ((ngx_msec_t) node->key <= (ngx_msec_t) (ngx_old_elapsed_msec + timer) / NGX_TIMER_RESOLUTION) { ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, rbtree_key)); ngx_del_timer(ev); if (ev->delayed) { ev->delayed = 0; if (ev->ready == 0) { continue; } } else { ev->timedout = 1; } ev->event_handler(ev); continue; } break; } }