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()333 if (WARN_ON_ONCE(ctx->submitter_task != current)) in __io_run_local_work()
229 } else if (ctx->submitter_task) { in io_lockdep_assert_cq_locked()237 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()753 if (ctx->submitter_task && ctx->submitter_task != current) in __io_uring_register()
641 WARN_ON_ONCE(node->ctx->submitter_task && in io_uring_cancel_generic()642 node->ctx->submitter_task != current); in io_uring_cancel_generic()
197 && ctx->submitter_task != current) in __io_uring_add_tctx_node_from_submit()
2184 if (ctx->submitter_task) in io_ring_ctx_free()2185 put_task_struct(ctx->submitter_task); in io_ring_ctx_free()2245 if (!ctx->submitter_task) in io_activate_pollwq()2253 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL)) in io_activate_pollwq()3072 ctx->submitter_task = get_task_struct(current); in io_uring_create()
1288 if (src_ctx->submitter_task && in io_register_clone_buffers()1289 src_ctx->submitter_task != current) { in io_register_clone_buffers()
301 struct task_struct *submitter_task; member