One Level Up Top Level

src/event/ngx_event_timer.c - nginx-1.7.10

Global variables defined

Functions defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #include <ngx_config.h>
  9. #include <ngx_core.h>
  10. #include <ngx_event.h>


  13. ‌ngx_rbtree_t              ngx_event_timer_rbtree;
  14. ‌static ngx_rbtree_node_t  ngx_event_timer_sentinel;

  16. /*
  17. * the event timer rbtree may contain the duplicate keys, however,
  18. * it should not be a problem, because we use the rbtree to find
  19. * a minimum timer value only
  20. */

  22. ngx_int_t
  23. ‌ngx_event_timer_init(ngx_log_t *log)
  24. {
  25.     ngx_rbtree_init(&ngx_event_timer_rbtree, &ngx_event_timer_sentinel,
  26.                     ngx_rbtree_insert_timer_value);

  28.     return NGX_OK;
  29. }


  32. ngx_msec_t
  33. ‌ngx_event_find_timer(void)
  34. {
  35.     ngx_msec_int_t      timer;
  36.     ngx_rbtree_node_t  *node, *root, *sentinel;

  38.     if (ngx_event_timer_rbtree.root == &ngx_event_timer_sentinel) {
  39.         return NGX_TIMER_INFINITE;
  40.     }

  42.     root = ngx_event_timer_rbtree.root;
  43.     sentinel = ngx_event_timer_rbtree.sentinel;

  45.     node = ngx_rbtree_min(root, sentinel);

  47.     timer = (ngx_msec_int_t) (node->key - ngx_current_msec);

  49.     return (ngx_msec_t) (timer > 0 ? timer : 0);
  50. }


  53. void
  54. ‌ngx_event_expire_timers(void)
  55. {
  56.     ngx_event_t        *ev;
  57.     ngx_rbtree_node_t  *node, *root, *sentinel;

  59.     sentinel = ngx_event_timer_rbtree.sentinel;

  61.     for ( ;; ) {
  62.         root = ngx_event_timer_rbtree.root;

  64.         if (root == sentinel) {
  65.             return;
  66.         }

  68.         node = ngx_rbtree_min(root, sentinel);

  70.         /* node->key > ngx_current_time */

  72.         if ((ngx_msec_int_t) (node->key - ngx_current_msec) > 0) {
  73.             return;
  74.         }

  76.         ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer));

  78.         ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
  79.                        "event timer del: %d: %M",
  80.                        ngx_event_ident(ev->data), ev->timer.key);

  82.         ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer);

  84. #if (NGX_DEBUG)
  85.         ev->timer.left = NULL;
  86.         ev->timer.right = NULL;
  87.         ev->timer.parent = NULL;
  88. #endif

  90.         ev->timer_set = 0;

  92.         ev->timedout = 1;

  94.         ev->handler(ev);
  95.     }
  96. }


  99. void
  100. ‌ngx_event_cancel_timers(void)
  101. {
  102.     ngx_event_t        *ev;
  103.     ngx_rbtree_node_t  *node, *root, *sentinel;

  105.     sentinel = ngx_event_timer_rbtree.sentinel;

  107.     for ( ;; ) {
  108.         root = ngx_event_timer_rbtree.root;

  110.         if (root == sentinel) {
  111.             return;
  112.         }

  114.         node = ngx_rbtree_min(root, sentinel);

  116.         ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer));

  118.         if (!ev->cancelable) {
  119.             return;
  120.         }

  122.         ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
  123.                        "event timer cancel: %d: %M",
  124.                        ngx_event_ident(ev->data), ev->timer.key);

  126.         ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer);

  128. #if (NGX_DEBUG)
  129.         ev->timer.left = NULL;
  130.         ev->timer.right = NULL;
  131.         ev->timer.parent = NULL;
  132. #endif

  134.         ev->timer_set = 0;

  136.         ev->handler(ev);
  137.     }
  138. }

One Level Up Top Level