|
@@ -963,14 +963,9 @@ void blk_mq_insert_request(struct request *rq, bool at_head, bool run_queue,
|
|
|
|
|
|
hctx = q->mq_ops->map_queue(q, ctx->cpu);
|
|
|
|
|
|
- if (rq->cmd_flags & (REQ_FLUSH | REQ_FUA) &&
|
|
|
- !(rq->cmd_flags & (REQ_FLUSH_SEQ))) {
|
|
|
- blk_insert_flush(rq);
|
|
|
- } else {
|
|
|
- spin_lock(&ctx->lock);
|
|
|
- __blk_mq_insert_request(hctx, rq, at_head);
|
|
|
- spin_unlock(&ctx->lock);
|
|
|
- }
|
|
|
+ spin_lock(&ctx->lock);
|
|
|
+ __blk_mq_insert_request(hctx, rq, at_head);
|
|
|
+ spin_unlock(&ctx->lock);
|
|
|
|
|
|
if (run_queue)
|
|
|
blk_mq_run_hw_queue(hctx, async);
|