Lines Matching refs:node
68 list_node_t node; member
127 static inline async_wait_t* node_to_wait(list_node_t* node) { in node_to_wait() argument
128 return FROM_NODE(async_wait_t, node); in node_to_wait()
135 static inline async_task_t* node_to_task(list_node_t* node) { in node_to_task() argument
136 return FROM_NODE(async_task_t, node); in node_to_task()
143 static inline async_exception_t* node_to_exception(list_node_t* node) { in node_to_exception() argument
144 return FROM_NODE(async_exception_t, node); in node_to_exception()
210 list_node_t* node; in async_loop_shutdown() local
211 while ((node = list_remove_head(&loop->wait_list))) { in async_loop_shutdown()
212 async_wait_t* wait = node_to_wait(node); in async_loop_shutdown()
215 while ((node = list_remove_head(&loop->due_list))) { in async_loop_shutdown()
216 async_task_t* task = node_to_task(node); in async_loop_shutdown()
219 while ((node = list_remove_head(&loop->task_list))) { in async_loop_shutdown()
220 async_task_t* task = node_to_task(node); in async_loop_shutdown()
223 while ((node = list_remove_head(&loop->exception_list))) { in async_loop_shutdown()
224 async_exception_t* exception = node_to_exception(node); in async_loop_shutdown()
350 list_node_t* node; in async_loop_dispatch_tasks() local
354 list_for_every(&loop->task_list, node) { in async_loop_dispatch_tasks()
355 if (node_to_task(node)->deadline > due_time) in async_loop_dispatch_tasks()
357 tail = node; in async_loop_dispatch_tasks()
373 while ((node = list_remove_head(&loop->due_list))) { in async_loop_dispatch_tasks()
377 async_task_t* task = node_to_task(node); in async_loop_dispatch_tasks()
520 list_node_t* node = wait_to_node(wait); in async_loop_cancel_wait() local
521 if (!list_in_list(node)) { in async_loop_cancel_wait()
532 list_delete(node); in async_loop_cancel_wait()
576 list_node_t* node = task_to_node(task); in async_loop_cancel_task() local
577 if (!list_in_list(node)) { in async_loop_cancel_task()
585 node->prev == &loop->task_list && in async_loop_cancel_task()
586 node->next != &loop->task_list && in async_loop_cancel_task()
587 node_to_task(node->next)->deadline > task->deadline; in async_loop_cancel_task()
588 list_delete(node); in async_loop_cancel_task()
672 list_node_t* node = exception_to_node(exception); in async_loop_unbind_exception_port() local
673 if (!list_in_list(node)) { in async_loop_unbind_exception_port()
683 list_delete(node); in async_loop_unbind_exception_port()
709 list_node_t* node; in async_loop_insert_task_locked() local
710 for (node = loop->task_list.prev; node != &loop->task_list; node = node->prev) { in async_loop_insert_task_locked()
711 if (task->deadline >= node_to_task(node)->deadline) in async_loop_insert_task_locked()
714 list_add_after(node, task_to_node(task)); in async_loop_insert_task_locked()
772 list_add_tail(&loop->thread_list, &rec->node); in async_loop_start_thread()