blk-mq: don't time out requests again that are in the timeout handler
We can currently call the timeout handler again on a request that has
already been handed over to the timeout handler. Prevent that with a new
flag.
Fixes: 12f5b931
("blk-mq: Remove generation seqeunce")
Reported-by: Andrew Randrianasulu <randrianasulu@gmail.com>
Tested-by: Andrew Randrianasulu <randrianasulu@gmail.com>
Signed-off-by: Christoph Hellwig <hch@lst.de>
Signed-off-by: Jens Axboe <axboe@kernel.dk>
This commit is contained in:
parent
a347c7ad8e
commit
da66126739
2 changed files with 7 additions and 0 deletions
|
@ -671,6 +671,7 @@ static void __blk_mq_requeue_request(struct request *rq)
|
||||||
|
|
||||||
if (blk_mq_request_started(rq)) {
|
if (blk_mq_request_started(rq)) {
|
||||||
WRITE_ONCE(rq->state, MQ_RQ_IDLE);
|
WRITE_ONCE(rq->state, MQ_RQ_IDLE);
|
||||||
|
rq->rq_flags &= ~RQF_TIMED_OUT;
|
||||||
if (q->dma_drain_size && blk_rq_bytes(rq))
|
if (q->dma_drain_size && blk_rq_bytes(rq))
|
||||||
rq->nr_phys_segments--;
|
rq->nr_phys_segments--;
|
||||||
}
|
}
|
||||||
|
@ -770,6 +771,7 @@ EXPORT_SYMBOL(blk_mq_tag_to_rq);
|
||||||
|
|
||||||
static void blk_mq_rq_timed_out(struct request *req, bool reserved)
|
static void blk_mq_rq_timed_out(struct request *req, bool reserved)
|
||||||
{
|
{
|
||||||
|
req->rq_flags |= RQF_TIMED_OUT;
|
||||||
if (req->q->mq_ops->timeout) {
|
if (req->q->mq_ops->timeout) {
|
||||||
enum blk_eh_timer_return ret;
|
enum blk_eh_timer_return ret;
|
||||||
|
|
||||||
|
@ -779,6 +781,7 @@ static void blk_mq_rq_timed_out(struct request *req, bool reserved)
|
||||||
WARN_ON_ONCE(ret != BLK_EH_RESET_TIMER);
|
WARN_ON_ONCE(ret != BLK_EH_RESET_TIMER);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
req->rq_flags &= ~RQF_TIMED_OUT;
|
||||||
blk_add_timer(req);
|
blk_add_timer(req);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -788,6 +791,8 @@ static bool blk_mq_req_expired(struct request *rq, unsigned long *next)
|
||||||
|
|
||||||
if (blk_mq_rq_state(rq) != MQ_RQ_IN_FLIGHT)
|
if (blk_mq_rq_state(rq) != MQ_RQ_IN_FLIGHT)
|
||||||
return false;
|
return false;
|
||||||
|
if (rq->rq_flags & RQF_TIMED_OUT)
|
||||||
|
return false;
|
||||||
|
|
||||||
deadline = blk_rq_deadline(rq);
|
deadline = blk_rq_deadline(rq);
|
||||||
if (time_after_eq(jiffies, deadline))
|
if (time_after_eq(jiffies, deadline))
|
||||||
|
|
|
@ -127,6 +127,8 @@ typedef __u32 __bitwise req_flags_t;
|
||||||
#define RQF_ZONE_WRITE_LOCKED ((__force req_flags_t)(1 << 19))
|
#define RQF_ZONE_WRITE_LOCKED ((__force req_flags_t)(1 << 19))
|
||||||
/* already slept for hybrid poll */
|
/* already slept for hybrid poll */
|
||||||
#define RQF_MQ_POLL_SLEPT ((__force req_flags_t)(1 << 20))
|
#define RQF_MQ_POLL_SLEPT ((__force req_flags_t)(1 << 20))
|
||||||
|
/* ->timeout has been called, don't expire again */
|
||||||
|
#define RQF_TIMED_OUT ((__force req_flags_t)(1 << 21))
|
||||||
|
|
||||||
/* flags that prevent us from merging requests: */
|
/* flags that prevent us from merging requests: */
|
||||||
#define RQF_NOMERGE_FLAGS \
|
#define RQF_NOMERGE_FLAGS \
|
||||||
|
|
Loading…
Reference in a new issue