Lines Matching refs:timers

31 nxt_timers_init(nxt_timers_t *timers, nxt_uint_t mchanges)  in nxt_timers_init()  argument
33 nxt_rbtree_init(&timers->tree, nxt_timer_rbtree_compare); in nxt_timers_init()
39 timers->mchanges = mchanges; in nxt_timers_init()
41 timers->changes = nxt_malloc(sizeof(nxt_timer_change_t) * mchanges); in nxt_timers_init()
43 if (nxt_fast_path(timers->changes != NULL)) { in nxt_timers_init()
76 time = engine->timers.now + timeout; in nxt_timer_add()
129 nxt_timers_t *timers; in nxt_timer_change() local
132 timers = &engine->timers; in nxt_timer_change()
140 if (timers->nchanges >= timers->mchanges) { in nxt_timer_change()
144 timers->nchanges++; in nxt_timer_change()
145 timer->change = timers->nchanges; in nxt_timer_change()
151 ch = &timers->changes[timer->change - 1]; in nxt_timer_change()
163 nxt_timers_t *timers; in nxt_timer_changes_commit() local
166 timers = &engine->timers; in nxt_timer_changes_commit()
168 nxt_debug(&engine->task, "timers changes: %ui", timers->nchanges); in nxt_timer_changes_commit()
170 ch = timers->changes; in nxt_timer_changes_commit()
171 end = ch + timers->nchanges; in nxt_timer_changes_commit()
201 nxt_rbtree_delete(&timers->tree, &timer->node); in nxt_timer_changes_commit()
218 nxt_rbtree_insert(&timers->tree, &timer->node); in nxt_timer_changes_commit()
224 timers->nchanges = 0; in nxt_timer_changes_commit()
234 nxt_timers_t *timers; in nxt_timer_find() local
238 timers = &engine->timers; in nxt_timer_find()
240 if (timers->nchanges != 0) { in nxt_timer_find()
244 tree = &timers->tree; in nxt_timer_find()
262 timers->minimum = time - timer->bias; in nxt_timer_find()
265 time, timer->bias, timers->now); in nxt_timer_find()
267 delta = nxt_msec_diff(time, timers->now); in nxt_timer_find()
274 timers->minimum = timers->now + 24 * 60 * 60 * 1000; in nxt_timer_find()
284 nxt_timers_t *timers; in nxt_timer_expire() local
288 timers = &engine->timers; in nxt_timer_expire()
289 timers->now = now; in nxt_timer_expire()
292 timers->minimum, now); in nxt_timer_expire()
295 if (nxt_msec_diff(timers->minimum , now) > 0) { in nxt_timer_expire()
299 tree = &timers->tree; in nxt_timer_expire()