Lines Matching defs:node

249 	struct llist_node *node = llist_del_all(&ctx->fallback_llist);
255 	llist_for_each_entry_safe(req, tmp, node, io_task_work.node)
1042 struct llist_node *io_handle_tw_list(struct llist_node *node,
1050 		struct llist_node *next = node->next;
1051 		struct io_kiocb *req = container_of(node, struct io_kiocb,
1052 						    io_task_work.node);
1063 		node = next;
1070 	} while (node && *count < max_entries);
1073 	return node;
1092 	struct llist_node *node = llist_del_all(&tctx->task_list);
1096 	while (node) {
1097 		req = container_of(node, struct io_kiocb, io_task_work.node);
1098 		node = node->next;
1108 		if (llist_add(&req->io_task_work.node, &last_ctx->fallback_llist))
1123 	struct llist_node *node;
1130 	node = llist_del_all(&tctx->task_list);
1131 	if (node) {
1132 		node = llist_reverse_order(node);
1133 		node = io_handle_tw_list(node, count, max_entries);
1141 	return node;
1181 							io_task_work.node);
1198 		req->io_task_work.node.next = head;
1200 			      &req->io_task_work.node));
1233 	if (!llist_add(&req->io_task_work.node, &tctx->task_list))
1269 	struct llist_node *node;
1271 	node = llist_del_all(&ctx->work_llist);
1272 	while (node) {
1273 		struct io_kiocb *req = container_of(node, struct io_kiocb,
1274 						    io_task_work.node);
1276 		node = node->next;
1296 	struct llist_node *node;
1309 	node = llist_reverse_order(io_llist_xchg(&ctx->work_llist, NULL));
1310 	while (node) {
1311 		struct llist_node *next = node->next;
1312 		struct io_kiocb *req = container_of(node, struct io_kiocb,
1313 						    io_task_work.node);
1318 		node = next;
1394 			       struct io_wq_work_node *node)
1398 		struct io_kiocb *req = container_of(node, struct io_kiocb,
1403 				node = req->comp_list.next;
1425 		node = req->comp_list.next;
1427 	} while (node);
1434 	struct io_wq_work_node *node;
1437 	__wq_list_for_each(node, &state->compl_reqs) {
1438 		struct io_kiocb *req = container_of(node, struct io_kiocb,
2871 	 * node. It'll be removed by the end of cancellation, just ignore it.
2893 	struct io_tctx_node *node;
2954 		node = list_first_entry(&ctx->tctx_list, struct io_tctx_node,
2958 		ret = task_work_add(node->task, &exit.task_work, TWA_SIGNAL);
3056 	struct io_tctx_node *node;
3061 	list_for_each_entry(node, &ctx->tctx_list, ctx_node) {
3062 		struct io_uring_task *tctx = node->task->io_uring;
3152 	struct io_tctx_node *node;
3178 			xa_for_each(&tctx->xa, index, node) {
3180 				if (node->ctx->sq_data)
3182 				loop |= io_uring_try_cancel_requests(node->ctx,
3200 		xa_for_each(&tctx->xa, index, node) {
3201 			if (!llist_empty(&node->ctx->work_llist)) {
3202 				WARN_ON_ONCE(node->ctx->submitter_task &&
3203 					     node->ctx->submitter_task != current);