Searched refs:sqd (Results 1 – 6 of 6) sorted by relevance
77 kfree(sqd); in io_put_sq_data()95 if (sqd) { in io_sq_thread_finish()119 if (!sqd) in io_attach_sq_data()125 return sqd; in io_attach_sq_data()138 return sqd; in io_get_sq_data()142 return sqd; in io_get_sq_data()145 sqd = kzalloc(sizeof(*sqd), GFP_KERNEL); in io_get_sq_data()146 if (!sqd) in io_get_sq_data()155 return sqd; in io_get_sq_data()211 wait_event(sqd->wait, !atomic_read(&sqd->park_pending)); in io_sqd_handle_event()[all …]
26 void io_sq_thread_stop(struct io_sq_data *sqd);27 void io_sq_thread_park(struct io_sq_data *sqd);28 void io_sq_thread_unpark(struct io_sq_data *sqd);29 void io_put_sq_data(struct io_sq_data *sqd);
274 sqd = ctx->sq_data; in io_register_iowq_max_workers()275 if (sqd) { in io_register_iowq_max_workers()283 mutex_lock(&sqd->lock); in io_register_iowq_max_workers()285 if (sqd->thread) in io_register_iowq_max_workers()307 if (sqd) { in io_register_iowq_max_workers()309 mutex_unlock(&sqd->lock); in io_register_iowq_max_workers()310 io_put_sq_data(sqd); in io_register_iowq_max_workers()318 if (sqd) in io_register_iowq_max_workers()334 if (sqd) { in io_register_iowq_max_workers()336 mutex_unlock(&sqd->lock); in io_register_iowq_max_workers()[all …]
2900 struct io_sq_data *sqd = ctx->sq_data; in io_ring_exit_work() local2903 io_sq_thread_park(sqd); in io_ring_exit_work()2904 tsk = sqd->thread; in io_ring_exit_work()2908 io_sq_thread_unpark(sqd); in io_ring_exit_work()3132 __cold void io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd) in io_uring_cancel_generic() argument3141 WARN_ON_ONCE(sqd && sqd->thread != current); in io_uring_cancel_generic()3161 if (!sqd) { in io_uring_cancel_generic()3172 list_for_each_entry(ctx, &sqd->ctx_list, sqd_list) in io_uring_cancel_generic()
100 __cold void io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd);
1231 ed35 sqd RXE_FRRD