Searched refs:timer (Results 1 - 25 of 26) sorted by relevance

12

/tldk/app/nginx/src/event/
H A Dngx_event_timer.h35 "event timer del: %d: %M",
36 ngx_event_ident(ev->data), ev->timer.key);
38 ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer);
41 ev->timer.left = NULL;
42 ev->timer.right = NULL;
43 ev->timer.parent = NULL;
51 ngx_event_add_timer(ngx_event_t *ev, ngx_msec_t timer) argument
56 key = ngx_current_msec + timer;
61 * Use a previous timer value if difference between it and a new
66 diff = (ngx_msec_int_t) (key - ev->timer
[all...]
H A Dngx_event_timer.c17 * the event timer rbtree may contain the duplicate keys, however,
19 * a minimum timer value only
35 ngx_msec_int_t timer; local
47 timer = (ngx_msec_int_t) (node->key - ngx_current_msec);
49 return (ngx_msec_t) (timer > 0 ? timer : 0);
76 ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer));
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);
[all...]
H A Dngx_event.h121 ngx_rbtree_node_t timer; member in struct:ngx_event_s
189 ngx_int_t (*process_events)(ngx_cycle_t *cycle, ngx_msec_t timer,
192 ngx_int_t (*init)(ngx_cycle_t *cycle, ngx_msec_t timer);
265 * The event module handles periodic or absolute timer event by itself:
H A Dngx_event.c197 ngx_msec_t timer, delta; local
200 timer = NGX_TIMER_INFINITE;
204 timer = ngx_event_find_timer();
211 if (timer == NGX_TIMER_INFINITE || timer > 500) {
212 timer = 500;
231 if (timer == NGX_TIMER_INFINITE
232 || timer > ngx_accept_mutex_delay)
234 timer = ngx_accept_mutex_delay;
242 (void) ngx_process_events(cycle, timer, flag
[all...]
/tldk/lib/libtle_l4p/
H A Dtcp_timer.h41 if (s->timer.handle != NULL) {
43 tle_timer_stop(tw, s->timer.handle);
44 s->timer.handle = NULL;
53 if (s->timer.handle == NULL) {
55 s->timer.handle = tle_timer_start(tw, s, s->tcb.snd.rto);
66 s->timer.handle = tle_timer_start(tw, s, s->tcb.snd.rto);
71 * reset number of retransmissions and restart RTO timer.
H A Dtcp_stream.h108 } timer; member in struct:tle_tcp_stream
178 struct tle_timer_wheel *tmr; /* timer wheel */
/tldk/app/nginx/src/event/modules/
H A Dngx_iocp_module.c14 static ngx_int_t ngx_iocp_init(ngx_cycle_t *cycle, ngx_msec_t timer);
20 static ngx_int_t ngx_iocp_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
109 ngx_iocp_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
132 if (timer == 0) {
137 * The waitable timer could not be used, because
143 msec = timer;
161 ngx_msec_t timer = *(ngx_msec_t *) data; local
167 Sleep(timer);
171 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ngx_cycle->log, 0, "timer");
235 ngx_int_t ngx_iocp_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, argument
[all...]
H A Dngx_eventport_module.c55 struct timespec it_interval;/* timer period */
56 struct timespec it_value; /* timer expiration */
137 static ngx_int_t ngx_eventport_init(ngx_cycle_t *cycle, ngx_msec_t timer);
145 ngx_msec_t timer, ngx_uint_t flags);
209 ngx_eventport_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
245 if (timer) {
261 its.it_interval.tv_sec = timer / 1000;
262 its.it_interval.tv_nsec = (timer % 1000) * 1000000;
263 its.it_value.tv_sec = timer / 1000;
264 its.it_value.tv_nsec = (timer
436 ngx_eventport_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags) argument
[all...]
H A Dngx_win32_select_module.c13 static ngx_int_t ngx_select_init(ngx_cycle_t *cycle, ngx_msec_t timer);
19 static ngx_int_t ngx_select_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
76 ngx_select_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
218 ngx_select_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, argument
240 if (timer == NGX_TIMER_INFINITE) {
244 tv.tv_sec = (long) (timer / 1000);
245 tv.tv_usec = (long) ((timer % 1000) * 1000);
250 "select timer: %M", timer);
266 ngx_msleep(timer);
[all...]
H A Dngx_select_module.c13 static ngx_int_t ngx_select_init(ngx_cycle_t *cycle, ngx_msec_t timer);
19 static ngx_int_t ngx_select_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
75 ngx_select_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
211 ngx_select_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, argument
248 if (timer == NGX_TIMER_INFINITE) {
252 tv.tv_sec = (long) (timer / 1000);
253 tv.tv_usec = (long) ((timer % 1000) * 1000);
258 "select timer: %M", timer);
300 if (timer !
[all...]
H A Dngx_poll_module.c13 static ngx_int_t ngx_poll_init(ngx_cycle_t *cycle, ngx_msec_t timer);
19 static ngx_int_t ngx_poll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
68 ngx_poll_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
239 ngx_poll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags) argument
260 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "poll timer: %M", timer);
262 ready = poll(event_list, (u_int) nevents, (int) timer);
292 if (timer != NGX_TIMER_INFINITE) {
H A Dngx_kqueue_module.c19 static ngx_int_t ngx_kqueue_init(ngx_cycle_t *cycle, ngx_msec_t timer);
33 static ngx_int_t ngx_kqueue_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
117 ngx_kqueue_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
188 if (timer) {
193 kev.data = timer;
498 ngx_kqueue_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, argument
512 if (timer == NGX_TIMER_INFINITE) {
517 ts.tv_sec = timer / 1000;
518 ts.tv_nsec = (timer % 1000) * 1000000;
534 "kevent timer
[all...]
H A Dngx_devpoll_module.c38 static ngx_int_t ngx_devpoll_init(ngx_cycle_t *cycle, ngx_msec_t timer);
47 ngx_msec_t timer, ngx_uint_t flags);
118 ngx_devpoll_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
340 ngx_devpoll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, argument
358 "devpoll timer: %M", timer);
373 dvp.dp_timeout = timer;
401 if (timer != NGX_TIMER_INFINITE) {
H A Dngx_epoll_module.c104 static ngx_int_t ngx_epoll_init(ngx_cycle_t *cycle, ngx_msec_t timer);
123 static ngx_int_t ngx_epoll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
323 ngx_epoll_init(ngx_cycle_t *cycle, ngx_msec_t timer) argument
784 ngx_epoll_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags) argument
798 "epoll timer: %M", timer);
800 events = epoll_wait(ep, event_list, (int) nevents, timer);
827 if (timer != NGX_TIMER_INFINITE) {
/tldk/test/
H A DMakefile27 DIRS-y += timer
/tldk/lib/libtle_timer/
H A DMakefile34 SRCS-y += timer.c
H A Dtle_timer.h43 * @brief timer definitions
63 /** initialize a timer wheel */
67 /** free a timer wheel */
71 /** start a timer */
75 /** stop a timer */
77 tle_timer_stop(struct tle_timer_wheel *tw, void *timer);
79 /** run the timer wheel. Call in every tick_size cycles
H A Dtimer.c50 void *obj; /** object for which timer is created */
54 /** Slow ring only, saved when timer added to ring */
78 struct tle_timer_wheel_args prm; /** timer wheel configuration params */
145 /** create the tle timer wheel */
160 /* at least one timer has to be created */
203 /** free the tle timer wheel */
210 /** start a timer */
256 /* Return the user timer-cancellation handle */
267 /* Give the user a handle to cancel the timer */
271 /** stop a timer */
272 tle_timer_stop(struct tle_timer_wheel *tw, void *timer) argument
[all...]
/tldk/app/nginx/src/tldk/
H A Dtldk_event.c133 tldk_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags) argument
143 FE_TRACE("%s(cycle=%p,timer=%lu,flags=%#lx);\n",
144 __func__, cycle, timer, flags);
149 tme = (timer == NGX_TIMER_INFINITE) ? timer :
150 timer * (rte_get_tsc_hz() + MS_PER_S - 1) / MS_PER_S;
210 tldk_init_events(ngx_cycle_t *cycle, ngx_msec_t timer) argument
212 FE_TRACE("%s(cycle=%p,timer=%lu);\n",
213 __func__, cycle, timer);
/tldk/app/nginx/src/http/
H A Dngx_http_request_body.c588 ngx_msec_t timer; local
604 timer = (ngx_msec_t) r->lingering_time - (ngx_msec_t) ngx_time();
606 if ((ngx_msec_int_t) timer <= 0) {
614 timer = 0;
640 if (timer) {
644 timer *= 1000;
646 if (timer > clcf->lingering_timeout) {
647 timer = clcf->lingering_timeout;
650 ngx_add_timer(rev, timer);
H A Dngx_http_file_cache.c404 ngx_msec_t now, timer; local
417 timer = c->node->lock_time - now;
419 if (!c->node->updating || (ngx_msec_int_t) timer <= 0) {
450 timer = c->wait_time - now;
452 ngx_add_timer(&c->wait_event, (timer > 500) ? 500 : timer);
484 ngx_msec_t now, timer; local
489 timer = c->wait_time - now;
491 if ((ngx_msec_int_t) timer <= 0) {
503 timer
[all...]
H A Dngx_http_request.c3255 ngx_msec_t timer; local
3272 timer = (ngx_msec_t) r->lingering_time - (ngx_msec_t) ngx_time();
3273 if ((ngx_msec_int_t) timer <= 0) {
3297 timer *= 1000;
3299 if (timer > clcf->lingering_timeout) {
3300 timer = clcf->lingering_timeout;
3303 ngx_add_timer(rev, timer);
/tldk/app/nginx/src/os/win32/
H A Dngx_process_cycle.c68 ngx_msec_t timer; local
122 timer = 0;
134 if (timer) {
135 timeout = timer > ngx_current_msec ? timer - ngx_current_msec : 0;
154 if (timer == 0) {
155 timer = ngx_current_msec + 5000;
/tldk/app/nginx/src/core/
H A Dngx_resolver.c1437 time_t timer, atimer, stimer, ntimer; local
1472 timer = ntimer;
1474 if (timer == 0) {
1475 timer = atimer;
1478 timer = ngx_min(timer, atimer);
1481 if (timer == 0) {
1482 timer = stimer;
1485 timer = ngx_min(timer, stime
[all...]
/tldk/app/nginx/src/mail/
H A Dngx_mail_auth_http_module.c467 time_t timer; local
721 timer = ctx->sleep;
725 if (timer == 0) {
731 ngx_add_timer(s->connection->read, (ngx_msec_t) (timer * 1000));
739 timer = ctx->sleep;
743 if (timer == 0) {
748 ngx_add_timer(s->connection->read, (ngx_msec_t) (timer * 1000));

Completed in 22 milliseconds

12