Mercurial > hg > nginx
comparison src/event/ngx_event_timer.h @ 50:b288069a8696
nginx-0.0.1-2003-01-23-21:47:54 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Thu, 23 Jan 2003 18:47:54 +0000 |
parents | |
children | a6afbb8a2ada |
comparison
equal
deleted
inserted
replaced
49:c091d5b853c8 | 50:b288069a8696 |
---|---|
1 #ifndef _NGX_EVENT_TIMER_H_INCLUDED_ | |
2 #define _NGX_EVENT_TIMER_H_INCLUDED_ | |
3 | |
4 | |
5 #include <ngx_config.h> | |
6 | |
7 #include <ngx_log.h> | |
8 #include <ngx_connection.h> | |
9 #include <ngx_event.h> | |
10 | |
11 | |
12 int ngx_event_init_timer(ngx_log_t *log); | |
13 void ngx_event_add_timer(ngx_event_t *ev, ngx_msec_t timer); | |
14 | |
15 extern ngx_event_t *ngx_timer_queue; | |
16 extern int ngx_timer_hash_size; | |
17 | |
18 | |
19 ngx_inline static int ngx_event_get_timer() | |
20 { | |
21 int i; | |
22 ngx_msec_t timer; | |
23 | |
24 timer = NGX_MAX_MSEC; | |
25 | |
26 for (i = 0; i < ngx_timer_hash_size; i++) { | |
27 if (ngx_timer_queue[i].timer_next != &ngx_timer_queue[i]) { | |
28 if (timer > ngx_timer_queue[i].timer_next->timer_delta) { | |
29 timer = ngx_timer_queue[i].timer_next->timer_delta; | |
30 } | |
31 } | |
32 } | |
33 | |
34 if (timer == NGX_MAX_MSEC) { | |
35 return 0; | |
36 } else { | |
37 return timer; | |
38 } | |
39 } | |
40 | |
41 | |
42 ngx_inline static void ngx_event_del_timer(ngx_event_t *ev) | |
43 { | |
44 #if (NGX_DEBUG_EVENT) | |
45 /* STUB - we can not cast (ngx_connection_t *) here */ | |
46 ngx_log_debug(ev->log, "del timer: %d" _ *(int *)(ev->data)); | |
47 #endif | |
48 | |
49 if (ev->timer_prev) { | |
50 ev->timer_prev->timer_next = ev->timer_next; | |
51 } | |
52 | |
53 if (ev->timer_next) { | |
54 ev->timer_next->timer_delta += ev->timer_delta; | |
55 ev->timer_next->timer_prev = ev->timer_prev; | |
56 ev->timer_next = NULL; | |
57 } | |
58 | |
59 if (ev->timer_prev) { | |
60 ev->timer_prev = NULL; | |
61 } | |
62 } | |
63 | |
64 | |
65 #endif _NGX_EVENT_TIMER_H_INCLUDED_ |