On Fri, Dec 02, 2016 at 08:15:16PM -0700, Jens Axboe wrote:
> For MQ devices, we have to use other functions to run the queue.
> No functional changes in this patch, just a prep patch for
> support legacy schedulers on blk-mq.
> 
> Signed-off-by: Jens Axboe <[email protected]>
> ---
>  block/cfq-iosched.c | 22 +++++++++++++++++++---
>  1 file changed, 19 insertions(+), 3 deletions(-)
> 
> diff --git a/block/cfq-iosched.c b/block/cfq-iosched.c
> index c73a6fcaeb9d..d6d454a72bd4 100644
> --- a/block/cfq-iosched.c
> +++ b/block/cfq-iosched.c
> @@ -919,8 +919,14 @@ static inline struct cfq_data *cic_to_cfqd(struct 
> cfq_io_cq *cic)
>  static inline void cfq_schedule_dispatch(struct cfq_data *cfqd)
>  {
>       if (cfqd->busy_queues) {
> +             struct request_queue *q = cfqd->queue;
> +
>               cfq_log(cfqd, "schedule dispatch");
> -             kblockd_schedule_work(&cfqd->unplug_work);
> +
> +             if (q->mq_ops)

You've introduced blk_use_mq_path() in patch 1, so why don't you use it here
as well?

> +                     blk_mq_run_hw_queues(q, true);
> +             else
> +                     kblockd_schedule_work(&cfqd->unplug_work);
>       }
>  }
>  
> @@ -4086,6 +4092,16 @@ static void cfq_preempt_queue(struct cfq_data *cfqd, 
> struct cfq_queue *cfqq)
>       cfq_mark_cfqq_slice_new(cfqq);
>  }
>  
> +static void cfq_run_queue(struct cfq_data *cfqd)
> +{
> +     struct request_queue *q = cfqd->queue;
> +
> +     if (q->mq_ops)

Ditto.

> +             blk_mq_run_hw_queues(q, true);
> +     else
> +             __blk_run_queue(q);
> +}
> +
>  /*
>   * Called when a new fs request (rq) is added (to cfqq). Check if there's
>   * something we should do about it
> @@ -4122,7 +4138,7 @@ cfq_rq_enqueued(struct cfq_data *cfqd, struct cfq_queue 
> *cfqq,
>                           cfqd->busy_queues > 1) {
>                               cfq_del_timer(cfqd, cfqq);
>                               cfq_clear_cfqq_wait_request(cfqq);
> -                             __blk_run_queue(cfqd->queue);
> +                             cfq_run_queue(cfqd);
>                       } else {
>                               cfqg_stats_update_idle_time(cfqq->cfqg);
>                               cfq_mark_cfqq_must_dispatch(cfqq);
> @@ -4136,7 +4152,7 @@ cfq_rq_enqueued(struct cfq_data *cfqd, struct cfq_queue 
> *cfqq,
>                * this new queue is RT and the current one is BE
>                */
>               cfq_preempt_queue(cfqd, cfqq);
> -             __blk_run_queue(cfqd->queue);
> +             cfq_run_queue(cfqd);
>       }
>  }
>  
> -- 
> 2.7.4
> 
> --
> To unsubscribe from this list: send the line "unsubscribe linux-block" in
> the body of a message to [email protected]
> More majordomo info at  http://vger.kernel.org/majordomo-info.html

-- 
Johannes Thumshirn                                          Storage
[email protected]                                +49 911 74053 689
SUSE LINUX GmbH, Maxfeldstr. 5, 90409 Nürnberg
GF: Felix Imendörffer, Jane Smithard, Graham Norton
HRB 21284 (AG Nürnberg)
Key fingerprint = EC38 9CAB C2C4 F25D 8600 D0D0 0393 969D 2D76 0850
--
To unsubscribe from this list: send the line "unsubscribe linux-block" in
the body of a message to [email protected]
More majordomo info at  http://vger.kernel.org/majordomo-info.html

Reply via email to