Searched refs:node (Results 1 – 3 of 3) sorted by relevance
| /io_uring/ |
| D | io-wq.c | 94 int node; member
471 struct io_wq_work_node *node, *prev; in io_get_next_work() local
476 wq_list_for_each(node, prev, &acct->work_list) { in io_get_next_work()
479 work = container_of(node, struct io_wq_work, list); in io_get_next_work()
483 wq_list_del(&acct->work_list, node, prev); in io_get_next_work()
500 node = &tail->list; in io_get_next_work()
764 tsk = create_io_thread(io_wqe_worker, worker, wqe->node); in create_worker_cont()
812 worker = kzalloc_node(sizeof(*worker), GFP_KERNEL, wqe->node); in create_io_worker()
831 tsk = create_io_thread(io_wqe_worker, worker, wqe->node); in create_io_worker()
1026 struct io_wq_work_node *node, *prev; in io_acct_cancel_pending_work() local
[all …]
|
| D | io-wq.h | 43 static inline void wq_list_add_after(struct io_wq_work_node *node, in wq_list_add_after() argument
49 pos->next = node; in wq_list_add_after()
50 node->next = next; in wq_list_add_after()
52 list->last = node; in wq_list_add_after()
55 static inline void wq_list_add_tail(struct io_wq_work_node *node, in wq_list_add_tail() argument
58 node->next = NULL; in wq_list_add_tail()
60 list->last = node; in wq_list_add_tail()
61 WRITE_ONCE(list->first, node); in wq_list_add_tail()
63 list->last->next = node; in wq_list_add_tail()
64 list->last = node; in wq_list_add_tail()
[all …]
|
| D | io_uring.c | 238 struct list_head node; member
824 struct io_wq_work_node node; member
1297 struct llist_node *node = llist_del_all(&ctx->fallback_llist); in io_fallback_req_func() local
1302 llist_for_each_entry_safe(req, tmp, node, io_task_work.fallback_node) in io_fallback_req_func()
2199 struct io_wq_work_node *node; in tctx_task_work() local
2205 node = tctx->task_list.first; in tctx_task_work()
2207 if (!node) in tctx_task_work()
2210 if (!node) in tctx_task_work()
2214 struct io_wq_work_node *next = node->next; in tctx_task_work()
2215 struct io_kiocb *req = container_of(node, struct io_kiocb, in tctx_task_work()
[all …]
|