]> git.baikalelectronics.ru Git - kernel.git/commitdiff
io_uring: store timeout's sqe->off in proper place
authorPavel Begunkov <asml.silence@gmail.com>
Mon, 25 Nov 2019 20:14:38 +0000 (23:14 +0300)
committerJens Axboe <axboe@kernel.dk>
Tue, 26 Nov 2019 22:02:56 +0000 (15:02 -0700)
Timeouts' sequence offset (i.e. sqe->off) is stored in
req->submit.sequence under a false name. Keep it in timeout.data
instead. The unused space for sequence will be reclaimed in the
following patches.

Signed-off-by: Pavel Begunkov <asml.silence@gmail.com>
Signed-off-by: Jens Axboe <axboe@kernel.dk>
fs/io_uring.c

index 7412fdefa35a034dd3008fb0c9dd2b909758c0df..39409934e9e6a5005a826e63092cc98c7963a418 100644 (file)
@@ -309,6 +309,7 @@ struct io_timeout_data {
        struct hrtimer                  timer;
        struct timespec64               ts;
        enum hrtimer_mode               mode;
+       u32                             seq_offset;
 };
 
 struct io_timeout {
@@ -2473,8 +2474,7 @@ static int io_timeout(struct io_kiocb *req, const struct io_uring_sqe *sqe)
        }
 
        req->sequence = ctx->cached_sq_head + count - 1;
-       /* reuse it to store the count */
-       req->submit.sequence = count;
+       req->timeout.data->seq_offset = count;
 
        /*
         * Insertion sort, ensuring the first entry in the list is always
@@ -2485,6 +2485,7 @@ static int io_timeout(struct io_kiocb *req, const struct io_uring_sqe *sqe)
                struct io_kiocb *nxt = list_entry(entry, struct io_kiocb, list);
                unsigned nxt_sq_head;
                long long tmp, tmp_nxt;
+               u32 nxt_offset = nxt->timeout.data->seq_offset;
 
                if (nxt->flags & REQ_F_TIMEOUT_NOSEQ)
                        continue;
@@ -2494,8 +2495,8 @@ static int io_timeout(struct io_kiocb *req, const struct io_uring_sqe *sqe)
                 * long to store it.
                 */
                tmp = (long long)ctx->cached_sq_head + count - 1;
-               nxt_sq_head = nxt->sequence - nxt->submit.sequence + 1;
-               tmp_nxt = (long long)nxt_sq_head + nxt->submit.sequence - 1;
+               nxt_sq_head = nxt->sequence - nxt_offset + 1;
+               tmp_nxt = (long long)nxt_sq_head + nxt_offset - 1;
 
                /*
                 * cached_sq_head may overflow, and it will never overflow twice