Lines Matching refs:node
50 struct io_tctx_node *node; in __io_uring_free() local
59 xa_for_each(&tctx->xa, index, node) { in __io_uring_free()
109 struct io_tctx_node *node; in __io_uring_add_tctx_node() local
128 node = kmalloc(sizeof(*node), GFP_KERNEL); in __io_uring_add_tctx_node()
129 if (!node) in __io_uring_add_tctx_node()
131 node->ctx = ctx; in __io_uring_add_tctx_node()
132 node->task = current; in __io_uring_add_tctx_node()
135 node, GFP_KERNEL)); in __io_uring_add_tctx_node()
137 kfree(node); in __io_uring_add_tctx_node()
142 list_add(&node->ctx_node, &ctx->tctx_list); in __io_uring_add_tctx_node()
170 struct io_tctx_node *node; in io_uring_del_tctx_node() local
174 node = xa_erase(&tctx->xa, index); in io_uring_del_tctx_node()
175 if (!node) in io_uring_del_tctx_node()
178 WARN_ON_ONCE(current != node->task); in io_uring_del_tctx_node()
179 WARN_ON_ONCE(list_empty(&node->ctx_node)); in io_uring_del_tctx_node()
181 mutex_lock(&node->ctx->uring_lock); in io_uring_del_tctx_node()
182 list_del(&node->ctx_node); in io_uring_del_tctx_node()
183 mutex_unlock(&node->ctx->uring_lock); in io_uring_del_tctx_node()
185 if (tctx->last == node->ctx) in io_uring_del_tctx_node()
187 kfree(node); in io_uring_del_tctx_node()
193 struct io_tctx_node *node; in io_uring_clean_tctx() local
196 xa_for_each(&tctx->xa, index, node) { in io_uring_clean_tctx()