static void io_uring_cancel_task_requests(struct io_ring_ctx *ctx,
					  struct files_struct *files)
{
	struct task_struct *task = current;

	if (ctx->flags & IORING_SETUP_SQPOLL)
		task = ctx->sqo_thread;

	io_cqring_overflow_flush(ctx, true, task, files);

	while (__io_uring_cancel_task_requests(ctx, task, files)) {
		io_run_task_work();
		cond_resched();
	}
}
static void io_uring_cancel_task_requests(struct io_ring_ctx *ctx,
					  struct files_struct *files)
{
	struct task_struct *task = current;

	if (ctx->flags & IORING_SETUP_SQPOLL)
		task = ctx->sqo_thread;

	io_cqring_overflow_flush(ctx, true, task, files);

	while (__io_uring_cancel_task_requests(ctx, task, files)) {
		io_run_task_work();
		cond_resched();
	}
}