diff options
| author | Jens Axboe <axboe@kernel.dk> | 2025-05-23 06:04:29 -0600 |
|---|---|---|
| committer | Jens Axboe <axboe@kernel.dk> | 2025-05-23 06:14:04 -0600 |
| commit | e37dfc0530815ead6e8ddab2a4ccce3be31af954 (patch) | |
| tree | e5e023f57c1575943480a7bce8ee37ae24d36919 | |
| parent | 28be240c763a44932bfe573f09e145d182e52609 (diff) | |
| download | ipsec-e37dfc0530815ead6e8ddab2a4ccce3be31af954.tar.gz | |
io_uring/io-wq: move hash helpers to the top
Just in preparation for using them higher up in the function, move
these generic helpers.
Signed-off-by: Jens Axboe <axboe@kernel.dk>
| -rw-r--r-- | io_uring/io-wq.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/io_uring/io-wq.c b/io_uring/io-wq.c index d52069b1177b0a..d36d0bd9847de8 100644 --- a/io_uring/io-wq.c +++ b/io_uring/io-wq.c @@ -150,6 +150,16 @@ static bool io_acct_cancel_pending_work(struct io_wq *wq, static void create_worker_cb(struct callback_head *cb); static void io_wq_cancel_tw_create(struct io_wq *wq); +static inline unsigned int __io_get_work_hash(unsigned int work_flags) +{ + return work_flags >> IO_WQ_HASH_SHIFT; +} + +static inline unsigned int io_get_work_hash(struct io_wq_work *work) +{ + return __io_get_work_hash(atomic_read(&work->flags)); +} + static bool io_worker_get(struct io_worker *worker) { return refcount_inc_not_zero(&worker->ref); @@ -454,16 +464,6 @@ static void __io_worker_idle(struct io_wq_acct *acct, struct io_worker *worker) } } -static inline unsigned int __io_get_work_hash(unsigned int work_flags) -{ - return work_flags >> IO_WQ_HASH_SHIFT; -} - -static inline unsigned int io_get_work_hash(struct io_wq_work *work) -{ - return __io_get_work_hash(atomic_read(&work->flags)); -} - static bool io_wait_on_hash(struct io_wq *wq, unsigned int hash) { bool ret = false; |