Commit 1885b24d authored by Jens Axboe's avatar Jens Axboe
Browse files

blk-mq: Add helper to abort requeued requests 



Adds a helper function a driver can use to abort requeued requests in
case any are pending when h/w queues are being removed.

Signed-off-by: default avatarJens Axboe <axboe@fb.com>
parent c68ed59f

block/blk-mq.c

+20 −0
Original line number Diff line number Diff line
@@ -539,6 +539,26 @@ void blk_mq_kick_requeue_list(struct request_queue *q) 
}

EXPORT_SYMBOL(blk_mq_kick_requeue_list);



void blk_mq_abort_requeue_list(struct request_queue *q)

{

	unsigned long flags;

	LIST_HEAD(rq_list);



	spin_lock_irqsave(&q->requeue_lock, flags);

	list_splice_init(&q->requeue_list, &rq_list);

	spin_unlock_irqrestore(&q->requeue_lock, flags);



	while (!list_empty(&rq_list)) {

		struct request *rq;



		rq = list_first_entry(&rq_list, struct request, queuelist);

		list_del_init(&rq->queuelist);

		rq->errors = -EIO;

		blk_mq_end_request(rq, rq->errors);

	}

}

EXPORT_SYMBOL(blk_mq_abort_requeue_list);



static inline bool is_flush_request(struct request *rq,

		struct blk_flush_queue *fq, unsigned int tag)

{

include/linux/blk-mq.h

+1 −0
Original line number Diff line number Diff line
@@ -203,6 +203,7 @@ void blk_mq_requeue_request(struct request *rq); 
void blk_mq_add_to_requeue_list(struct request *rq, bool at_head);

void blk_mq_cancel_requeue_work(struct request_queue *q);

void blk_mq_kick_requeue_list(struct request_queue *q);

void blk_mq_abort_requeue_list(struct request_queue *q);

void blk_mq_complete_request(struct request *rq);



void blk_mq_stop_hw_queue(struct blk_mq_hw_ctx *hctx);