Home
last modified time | relevance | path

Searched refs:submitter_task (Results 1 – 8 of 8) sorted by relevance

/linux/io_uring/
H A Dtw.c201 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE); in io_req_local_work_add()
313 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work_loop()
H A Dio_uring.h230 } else if (ctx->submitter_task) { in io_lockdep_assert_cq_locked()
232 * ->submitter_task may be NULL and we can still post a CQE, in io_lockdep_assert_cq_locked()
238 lockdep_assert(current == ctx->submitter_task); in io_lockdep_assert_cq_locked()
H A Dregister.c283 ctx->submitter_task = get_task_struct(current); in io_register_enable_rings()
753 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
H A Dcancel.c639 WARN_ON_ONCE(node->ctx->submitter_task && in io_uring_cancel_generic()
640 node->ctx->submitter_task != current); in io_uring_cancel_generic()
H A Dtctx.c198 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
H A Dio_uring.c2180 if (ctx->submitter_task) in io_ring_ctx_free()
2181 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()
2242 if (!ctx->submitter_task) in io_activate_pollwq()
2245 * with ->submitter_task only the submitter task completes requests, we in io_activate_pollwq()
2250 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()
2612 * Keep IORING_SETUP_R_DISABLED check before submitter_task load in SYSCALL_DEFINE6()
3067 ctx->submitter_task = get_task_struct(current); in io_uring_create()
H A Drsrc.c1433 if (src_ctx->submitter_task && in iov_kern_bvec_size()
1434 src_ctx->submitter_task != current) { in iov_kern_bvec_size()
/linux/include/linux/
H A Dio_uring_types.h325 struct task_struct *submitter_task;
301 struct task_struct *submitter_task; global() member