Lines Matching refs:node
65 iu_timer_node_t *node, *next_node; in iu_tq_destroy() local
67 for (node = tq->iutq_head; node != NULL; node = next_node) { in iu_tq_destroy()
68 next_node = node->iutn_next; in iu_tq_destroy()
69 destroy_timer(tq, node); in iu_tq_destroy()
85 insert_timer(iu_tq_t *tq, iu_timer_node_t *node, uint64_t msec) in insert_timer() argument
98 node->iutn_abs_timeout = gethrtime() + MSEC2NSEC(msec); in insert_timer()
101 tq->iutq_head->iutn_abs_timeout < node->iutn_abs_timeout) in insert_timer()
105 node->iutn_abs_timeout) in insert_timer()
108 node->iutn_next = after ? after->iutn_next : tq->iutq_head; in insert_timer()
109 node->iutn_prev = after; in insert_timer()
111 tq->iutq_head = node; in insert_timer()
113 after->iutn_next = node; in insert_timer()
115 if (node->iutn_next != NULL) in insert_timer()
116 node->iutn_next->iutn_prev = node; in insert_timer()
128 remove_timer(iu_tq_t *tq, iu_timer_node_t *node) in remove_timer() argument
130 if (node->iutn_next != NULL) in remove_timer()
131 node->iutn_next->iutn_prev = node->iutn_prev; in remove_timer()
132 if (node->iutn_prev != NULL) in remove_timer()
133 node->iutn_prev->iutn_next = node->iutn_next; in remove_timer()
135 tq->iutq_head = node->iutn_next; in remove_timer()
147 destroy_timer(iu_tq_t *tq, iu_timer_node_t *node) in destroy_timer() argument
149 release_timer_id(tq, node->iutn_timer_id); in destroy_timer()
157 node->iutn_pending_delete++; in destroy_timer()
158 node->iutn_next = pending_delete_chain; in destroy_timer()
159 pending_delete_chain = node; in destroy_timer()
161 free(node); in destroy_timer()
196 iu_timer_node_t *node = calloc(1, sizeof (iu_timer_node_t)); in iu_schedule_timer_ms() local
198 if (node == NULL) in iu_schedule_timer_ms()
201 node->iutn_callback = callback; in iu_schedule_timer_ms()
202 node->iutn_arg = arg; in iu_schedule_timer_ms()
203 node->iutn_timer_id = get_timer_id(tq); in iu_schedule_timer_ms()
204 if (node->iutn_timer_id == -1) { in iu_schedule_timer_ms()
205 free(node); in iu_schedule_timer_ms()
209 insert_timer(tq, node, ms); in iu_schedule_timer_ms()
211 return (node->iutn_timer_id); in iu_schedule_timer_ms()
227 iu_timer_node_t *node; in iu_cancel_timer() local
232 for (node = tq->iutq_head; node != NULL; node = node->iutn_next) { in iu_cancel_timer()
233 if (node->iutn_timer_id == timer_id) { in iu_cancel_timer()
235 *arg = node->iutn_arg; in iu_cancel_timer()
236 remove_timer(tq, node); in iu_cancel_timer()
237 destroy_timer(tq, node); in iu_cancel_timer()
256 iu_timer_node_t *node; in iu_adjust_timer() local
261 for (node = tq->iutq_head; node != NULL; node = node->iutn_next) { in iu_adjust_timer()
262 if (node->iutn_timer_id == timer_id) { in iu_adjust_timer()
263 remove_timer(tq, node); in iu_adjust_timer()
264 insert_timer(tq, node, sec * MILLISEC); in iu_adjust_timer()
317 iu_timer_node_t *node, *next_node; in iu_expire_timers() local
336 for (node = tq->iutq_head; node != NULL; node = node->iutn_next) in iu_expire_timers()
337 node->iutn_expire_next = node->iutn_next; in iu_expire_timers()
339 for (node = tq->iutq_head; node != NULL; in iu_expire_timers()
340 node = node->iutn_expire_next) { in iu_expire_timers()
349 if (node->iutn_abs_timeout - current_time > 1000000) in iu_expire_timers()
360 if (node->iutn_pending_delete) in iu_expire_timers()
370 remove_timer(tq, node); in iu_expire_timers()
371 destroy_timer(tq, node); in iu_expire_timers()
372 node->iutn_callback(tq, node->iutn_arg); in iu_expire_timers()
383 for (node = pending_delete_chain; node != NULL; node = next_node) { in iu_expire_timers()
384 next_node = node->iutn_next; in iu_expire_timers()
385 free(node); in iu_expire_timers()