Commit a534dbe9 authored by Richard Kennedy's avatar Richard Kennedy Committed by Jens Axboe

block: ensure jiffies wrap is handled correctly in blk_rq_timed_out_timer

blk_rq_timed_out_timer() relied on blk_add_timer() never returning a
timer value of zero, but commit 7838c15b
removed the code that bumped this value when it was zero.
Therefore when jiffies is near wrap we could get unlucky & not set the
timeout value correctly.

This patch uses a flag to indicate that the timeout value was set and so
handles jiffies wrap correctly, and it keeps all the logic in one
function so should be easier to maintain in the future.
Signed-off-by: default avatarRichard Kennedy <richard@rsk.demon.co.uk>
Cc: stable@kernel.org
Signed-off-by: default avatarJens Axboe <jens.axboe@oracle.com>
parent 05ce7bfe
...@@ -109,6 +109,7 @@ void blk_rq_timed_out_timer(unsigned long data) ...@@ -109,6 +109,7 @@ void blk_rq_timed_out_timer(unsigned long data)
struct request_queue *q = (struct request_queue *) data; struct request_queue *q = (struct request_queue *) data;
unsigned long flags, next = 0; unsigned long flags, next = 0;
struct request *rq, *tmp; struct request *rq, *tmp;
int next_set = 0;
spin_lock_irqsave(q->queue_lock, flags); spin_lock_irqsave(q->queue_lock, flags);
...@@ -122,16 +123,13 @@ void blk_rq_timed_out_timer(unsigned long data) ...@@ -122,16 +123,13 @@ void blk_rq_timed_out_timer(unsigned long data)
if (blk_mark_rq_complete(rq)) if (blk_mark_rq_complete(rq))
continue; continue;
blk_rq_timed_out(rq); blk_rq_timed_out(rq);
} else if (!next || time_after(next, rq->deadline)) } else if (!next_set || time_after(next, rq->deadline)) {
next = rq->deadline; next = rq->deadline;
next_set = 1;
}
} }
/* if (next_set)
* next can never be 0 here with the list non-empty, since we always
* bump ->deadline to 1 so we can detect if the timer was ever added
* or not. See comment in blk_add_timer()
*/
if (next)
mod_timer(&q->timeout, round_jiffies_up(next)); mod_timer(&q->timeout, round_jiffies_up(next));
spin_unlock_irqrestore(q->queue_lock, flags); spin_unlock_irqrestore(q->queue_lock, flags);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment