Lines Matching refs:locked
810 typedef void (*io_req_tw_func_t)(struct io_kiocb *req, bool *locked);
1132 static inline void io_tw_lock(struct io_ring_ctx *ctx, bool *locked) in io_tw_lock() argument
1134 if (!*locked) { in io_tw_lock()
1136 *locked = true; in io_tw_lock()
1292 bool locked = false; in io_fallback_req_func() local
1296 req->io_task_work.func(req, &locked); in io_fallback_req_func()
1298 if (locked) { in io_fallback_req_func()
1476 static void io_queue_async_work(struct io_kiocb *req, bool *locked) in io_queue_async_work() argument
1483 locked = NULL; in io_queue_async_work()
2171 static void ctx_flush_and_put(struct io_ring_ctx *ctx, bool *locked) in ctx_flush_and_put() argument
2175 if (*locked) { in ctx_flush_and_put()
2179 *locked = false; in ctx_flush_and_put()
2186 bool locked = false; in tctx_task_work() local
2194 if (!tctx->task_list.first && locked && ctx->submit_state.compl_nr) in tctx_task_work()
2212 ctx_flush_and_put(ctx, &locked); in tctx_task_work()
2215 locked = mutex_trylock(&ctx->uring_lock); in tctx_task_work()
2218 req->io_task_work.func(req, &locked); in tctx_task_work()
2221 ctx_flush_and_put(ctx, &locked); in tctx_task_work()
2228 ctx_flush_and_put(ctx, &locked); in tctx_task_work()
2284 static void io_req_task_cancel(struct io_kiocb *req, bool *locked) in io_req_task_cancel() argument
2289 io_tw_lock(ctx, locked); in io_req_task_cancel()
2293 static void io_req_task_submit(struct io_kiocb *req, bool *locked) in io_req_task_submit() argument
2297 io_tw_lock(ctx, locked); in io_req_task_submit()
2338 static void io_free_req_work(struct io_kiocb *req, bool *locked) in io_free_req_work() argument
2794 static void io_req_task_complete(struct io_kiocb *req, bool *locked) in io_req_task_complete() argument
2799 if (*locked) { in io_req_task_complete()
2812 static void io_req_rw_complete(struct io_kiocb *req, bool *locked) in io_req_rw_complete() argument
2815 io_req_task_complete(req, locked); in io_req_rw_complete()
5697 static void io_poll_task_func(struct io_kiocb *req, bool *locked) in io_poll_task_func() argument
5720 static void io_apoll_task_func(struct io_kiocb *req, bool *locked) in io_apoll_task_func() argument
5729 io_tw_lock(req->ctx, locked); in io_apoll_task_func()
5736 io_req_task_submit(req, locked); in io_apoll_task_func()
6195 static void io_req_task_timeout(struct io_kiocb *req, bool *locked) in io_req_task_timeout() argument
7173 static void io_req_task_link_timeout(struct io_kiocb *req, bool *locked) in io_req_task_link_timeout() argument