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

/linux-master/io_uring/
H A Dio_uring.h133 } else if (ctx->submitter_task) {
135 * ->submitter_task may be NULL and we can still post a CQE,
140 if (ctx->submitter_task->flags & PF_EXITING)
143 lockdep_assert(current == ctx->submitter_task);
414 return likely(ctx->submitter_task == current);
420 ctx->submitter_task == current);
H A Dmsg_ring.c73 return current != target_ctx->submitter_task;
80 struct task_struct *task = READ_ONCE(ctx->submitter_task);
86 if (task_work_add(ctx->submitter_task, &msg->tw, TWA_SIGNAL))
H A Dregister.c235 if (ctx->flags & IORING_SETUP_SINGLE_ISSUER && !ctx->submitter_task) {
236 WRITE_ONCE(ctx->submitter_task, get_task_struct(current));
239 * submitter_task is set.
404 if (ctx->submitter_task && ctx->submitter_task != current)
H A Dtctx.c141 && ctx->submitter_task != current)
H A Dio_uring.c1027 if (ctx->task_complete && ctx->submitter_task != current) {
1358 wake_up_state(ctx->submitter_task, TASK_INTERRUPTIBLE);
1432 if (WARN_ON_ONCE(ctx->submitter_task != current))
2908 if (ctx->submitter_task)
2909 put_task_struct(ctx->submitter_task);
2963 if (!ctx->submitter_task)
2966 * with ->submitter_task only the submitter task completes requests, we
2971 if (task_work_add(ctx->submitter_task, &ctx->poll_wq_task_work, TWA_SIGNAL))
3394 WARN_ON_ONCE(node->ctx->submitter_task &&
3395 node->ctx->submitter_task !
[all...]
/linux-master/include/linux/
H A Dio_uring_types.h246 struct task_struct *submitter_task; member in struct:io_ring_ctx::__anon47

Completed in 301 milliseconds