Searched refs:submitter_task (Results 1 – 7 of 7) sorted by relevance
205 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE); in io_req_local_work_add()316 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work()
231 } else if (ctx->submitter_task) { in io_lockdep_assert_cq_locked()239 lockdep_assert(current == ctx->submitter_task); in io_lockdep_assert_cq_locked()
283 ctx->submitter_task = get_task_struct(current); in io_register_enable_rings()766 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
245 struct task_struct *task = ctx->submitter_task; in io_msg_fd_remote()
203 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
2174 if (ctx->submitter_task) in io_ring_ctx_free()2175 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()2236 if (!ctx->submitter_task) in io_activate_pollwq()2244 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()3063 ctx->submitter_task = get_task_struct(current); in io_uring_create()
339 struct task_struct *submitter_task; member