Mercurial > hg > nginx
diff src/event/ngx_event_timer.c @ 5896:3efdd7788bb0
Events: introduced cancelable timers.
author | Valentin Bartenev <vbart@nginx.com> |
---|---|
date | Wed, 13 Aug 2014 22:45:04 +0400 |
parents | 0f53e5fb7205 |
children | 3069dd358ba2 |
line wrap: on
line diff
--- a/src/event/ngx_event_timer.c Mon Aug 25 13:37:06 2014 +0400 +++ b/src/event/ngx_event_timer.c Wed Aug 13 22:45:04 2014 +0400 @@ -94,3 +94,45 @@ ev->handler(ev); } } + + +void +ngx_event_cancel_timers(void) +{ + ngx_event_t *ev; + ngx_rbtree_node_t *node, *root, *sentinel; + + sentinel = ngx_event_timer_rbtree.sentinel; + + for ( ;; ) { + root = ngx_event_timer_rbtree.root; + + if (root == sentinel) { + return; + } + + node = ngx_rbtree_min(root, sentinel); + + ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer)); + + if (!ev->cancelable) { + return; + } + + ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, + "event timer cancel: %d: %M", + ngx_event_ident(ev->data), ev->timer.key); + + ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer); + +#if (NGX_DEBUG) + ev->timer.left = NULL; + ev->timer.right = NULL; + ev->timer.parent = NULL; +#endif + + ev->timer_set = 0; + + ev->handler(ev); + } +}