• Home
  • Raw
  • Download

Lines Matching refs:work

897 	struct io_wq_work		work;  member
1110 static void io_rsrc_put_work(struct work_struct *work);
1293 static void io_fallback_req_func(struct work_struct *work) in io_fallback_req_func() argument
1295 struct io_ring_ctx *ctx = container_of(work, struct io_ring_ctx, in io_fallback_req_func()
1296 fallback_work.work); in io_fallback_req_func()
1452 req->work.list.next = NULL; in io_prep_async_work()
1453 req->work.flags = 0; in io_prep_async_work()
1455 req->work.flags |= IO_WQ_WORK_CONCURRENT; in io_prep_async_work()
1459 io_wq_hash_work(&req->work, file_inode(req->file)); in io_prep_async_work()
1462 req->work.flags |= IO_WQ_WORK_UNBOUND; in io_prep_async_work()
1506 req->work.flags |= IO_WQ_WORK_CANCEL; in io_queue_async_work()
1508 trace_io_uring_queue_async_work(ctx, io_wq_is_hashed(&req->work), req, in io_queue_async_work()
1509 &req->work, req->flags); in io_queue_async_work()
1510 io_wq_enqueue(tctx->io_wq, &req->work); in io_queue_async_work()
6359 static bool io_cancel_cb(struct io_wq_work *work, void *data) in io_cancel_cb() argument
6361 struct io_kiocb *req = container_of(work, struct io_kiocb, work); in io_cancel_cb()
6881 static struct io_wq_work *io_wq_free_work(struct io_wq_work *work) in io_wq_free_work() argument
6883 struct io_kiocb *req = container_of(work, struct io_kiocb, work); in io_wq_free_work()
6886 return req ? &req->work : NULL; in io_wq_free_work()
6889 static void io_wq_submit_work(struct io_wq_work *work) in io_wq_submit_work() argument
6891 struct io_kiocb *req = container_of(work, struct io_kiocb, work); in io_wq_submit_work()
6906 if (work->flags & IO_WQ_WORK_CANCEL) in io_wq_submit_work()
8368 static void io_rsrc_put_work(struct work_struct *work) in io_rsrc_put_work() argument
8373 ctx = container_of(work, struct io_ring_ctx, rsrc_put_work.work); in io_rsrc_put_work()
9489 struct io_tctx_exit *work; in io_tctx_exit_cb() local
9491 work = container_of(cb, struct io_tctx_exit, task_work); in io_tctx_exit_cb()
9499 io_uring_del_tctx_node((unsigned long)work->ctx); in io_tctx_exit_cb()
9500 complete(&work->completion); in io_tctx_exit_cb()
9503 static bool io_cancel_ctx_cb(struct io_wq_work *work, void *data) in io_cancel_ctx_cb() argument
9505 struct io_kiocb *req = container_of(work, struct io_kiocb, work); in io_cancel_ctx_cb()
9510 static void io_ring_exit_work(struct work_struct *work) in io_ring_exit_work() argument
9512 struct io_ring_ctx *ctx = container_of(work, struct io_ring_ctx, exit_work); in io_ring_exit_work()
9665 static bool io_cancel_task_cb(struct io_wq_work *work, void *data) in io_cancel_task_cb() argument
9667 struct io_kiocb *req = container_of(work, struct io_kiocb, work); in io_cancel_task_cb()