]> www.infradead.org Git - users/hch/misc.git/commitdiff
io_uring: remove task ref helpers
authorJens Axboe <axboe@kernel.dk>
Sun, 3 Nov 2024 03:26:16 +0000 (21:26 -0600)
committerJens Axboe <axboe@kernel.dk>
Wed, 6 Nov 2024 20:55:38 +0000 (13:55 -0700)
They are only used right where they are defined, just open-code them
inside io_put_task().

Signed-off-by: Jens Axboe <axboe@kernel.dk>
io_uring/io_uring.c

index 4a2282c8546420c219ef86252232086539fdc48a..43afd9da7d0742c3e0bf2d4c30aa871c5986e036 100644 (file)
@@ -677,30 +677,19 @@ static void io_cqring_do_overflow_flush(struct io_ring_ctx *ctx)
        mutex_unlock(&ctx->uring_lock);
 }
 
-/* can be called by any task */
-static void io_put_task_remote(struct task_struct *task)
-{
-       struct io_uring_task *tctx = task->io_uring;
-
-       percpu_counter_sub(&tctx->inflight, 1);
-       if (unlikely(atomic_read(&tctx->in_cancel)))
-               wake_up(&tctx->wait);
-       put_task_struct(task);
-}
-
-/* used by a task to put its own references */
-static void io_put_task_local(struct task_struct *task)
-{
-       task->io_uring->cached_refs++;
-}
-
 /* must to be called somewhat shortly after putting a request */
 static inline void io_put_task(struct task_struct *task)
 {
-       if (likely(task == current))
-               io_put_task_local(task);
-       else
-               io_put_task_remote(task);
+       struct io_uring_task *tctx = task->io_uring;
+
+       if (likely(task == current)) {
+               tctx->cached_refs++;
+       } else {
+               percpu_counter_sub(&tctx->inflight, 1);
+               if (unlikely(atomic_read(&tctx->in_cancel)))
+                       wake_up(&tctx->wait);
+               put_task_struct(task);
+       }
 }
 
 void io_task_refs_refill(struct io_uring_task *tctx)