Searched refs:submitter_task (Results 1 – 8 of 8) sorted by relevance
236 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE); in io_req_local_work_add()323 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work()
216 } else if (ctx->submitter_task) { in io_lockdep_assert_cq_locked()224 lockdep_assert(current == ctx->submitter_task); in io_lockdep_assert_cq_locked()
275 ctx->submitter_task = get_task_struct(current); in io_register_enable_rings()725 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
634 WARN_ON_ONCE(node->ctx->submitter_task && in io_uring_cancel_generic()635 node->ctx->submitter_task != current); in io_uring_cancel_generic()
167 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
2165 if (ctx->submitter_task) in io_ring_ctx_free()2166 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()2226 if (!ctx->submitter_task) in io_activate_pollwq()2234 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()3023 ctx->submitter_task = get_task_struct(current); in io_uring_create()
1281 if (src_ctx->submitter_task && in io_register_clone_buffers()1282 src_ctx->submitter_task != current) { in io_register_clone_buffers()
290 struct task_struct *submitter_task; member