Searched refs:submitter_task (Results 1 – 6 of 6) sorted by relevance
126 } else if (ctx->submitter_task) { in io_lockdep_assert_cq_locked()133 if (ctx->submitter_task->flags & PF_EXITING) in io_lockdep_assert_cq_locked()136 lockdep_assert(current == ctx->submitter_task); in io_lockdep_assert_cq_locked()415 return likely(ctx->submitter_task == current); in io_allowed_defer_tw_run()421 ctx->submitter_task == current); in io_allowed_run_tw()
180 if (ctx->flags & IORING_SETUP_SINGLE_ISSUER && !ctx->submitter_task) { in io_register_enable_rings()181 WRITE_ONCE(ctx->submitter_task, get_task_struct(current)); in io_register_enable_rings()377 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
92 req->task = READ_ONCE(ctx->submitter_task); in io_msg_remote_post()236 struct task_struct *task = READ_ONCE(ctx->submitter_task); in io_msg_fd_remote()
1226 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE); in io_req_local_work_add()1305 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work()2753 if (ctx->submitter_task) in io_ring_ctx_free()2754 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()2807 if (!ctx->submitter_task) in io_activate_pollwq()2815 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()3203 WARN_ON_ONCE(node->ctx->submitter_task && in io_uring_cancel_generic()3204 node->ctx->submitter_task != current); in io_uring_cancel_generic()3682 WRITE_ONCE(ctx->submitter_task, get_task_struct(current)); in io_uring_create()
141 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
238 struct task_struct *submitter_task; member