Home
last modified time | relevance | path

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

/linux-6.3-rc2/io_uring/
A Dio_uring.h87 } else if (ctx->submitter_task->flags & PF_EXITING) { \
90 lockdep_assert(current == ctx->submitter_task); \
370 return likely(ctx->submitter_task == current); in io_allowed_defer_tw_run()
376 ctx->submitter_task == current); in io_allowed_run_tw()
A Dmsg_ring.c73 return current != target_ctx->submitter_task; in io_msg_need_remote()
80 struct task_struct *task = READ_ONCE(ctx->submitter_task); in io_msg_exec_remote()
86 if (task_work_add(ctx->submitter_task, &msg->tw, TWA_SIGNAL)) in io_msg_exec_remote()
A Dio_uring.c1305 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE); in io_req_local_work_add()
1354 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work()
2796 if (ctx->submitter_task) in io_ring_ctx_free()
2797 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()
2863 if (!ctx->submitter_task) in io_activate_pollwq()
2871 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()
3797 WRITE_ONCE(ctx->submitter_task, get_task_struct(current)); in io_uring_create()
3990 if (ctx->flags & IORING_SETUP_SINGLE_ISSUER && !ctx->submitter_task) { in io_register_enable_rings()
3991 WRITE_ONCE(ctx->submitter_task, get_task_struct(current)); in io_register_enable_rings()
4151 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
A Dtctx.c141 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
A Drsrc.c256 if (ctx->submitter_task) { in io_rsrc_node_ref_zero()
257 if (!task_work_add(ctx->submitter_task, &ctx->rsrc_put_tw, in io_rsrc_node_ref_zero()
/linux-6.3-rc2/include/linux/
A Dio_uring_types.h213 struct task_struct *submitter_task; member

Completed in 22 milliseconds