Lines Matching refs:sq_data
310 struct io_sq_data *sq_data; /* if using sq thread polling */ member
1470 if (ctx->sq_data && req->task == ctx->sq_data->thread) in io_task_match()
1582 if (ctx->sq_data && waitqueue_active(&ctx->sq_data->wait)) in io_cqring_ev_posted()
1583 wake_up(&ctx->sq_data->wait); in io_cqring_ev_posted()
2674 wq_has_sleeper(&ctx->sq_data->wait)) in io_iopoll_req_issued()
2675 wake_up(&ctx->sq_data->wait); in io_iopoll_req_issued()
6663 struct io_sq_data *sqd = ctx->sq_data; in __io_sq_thread()
7032 sqd = ctx_attach->sq_data; in io_attach_sq_data()
7083 struct io_sq_data *sqd = ctx->sq_data; in io_sq_thread_stop()
7109 ctx->sq_data = NULL; in io_sq_thread_stop()
7795 ctx->sq_data = sqd; in io_sq_offload_create()
7851 struct io_sq_data *sqd = ctx->sq_data; in io_sq_offload_start()
8659 if ((ctx->flags & IORING_SETUP_SQPOLL) && ctx->sq_data) { in io_uring_cancel_task_requests()
8660 task = ctx->sq_data->thread; in io_uring_cancel_task_requests()
8662 io_sq_thread_park(ctx->sq_data); in io_uring_cancel_task_requests()
8677 if ((ctx->flags & IORING_SETUP_SQPOLL) && ctx->sq_data) { in io_uring_cancel_task_requests()
8685 io_sq_thread_unpark(ctx->sq_data); in io_uring_cancel_task_requests()
8975 wake_up(&ctx->sq_data->wait); in SYSCALL_DEFINE6()
9064 sq = ctx->sq_data; in __io_uring_show_fdinfo()