Skip to content

Commit 49cacf0

Browse files
hailan94kawasaki
authored andcommitted
block/blk-rq-qos: cleanup rq_qos_add()
Now that there is no caller of rq_qos_add(), remove it, and also rename rq_qos_add_frozen() back to rq_qos_add(). Signed-off-by: Yu Kuai <yukuai@fnnas.com> Reviewed-by: Nilay Shroff <nilay@linux.ibm.com>
1 parent 6033021 commit 49cacf0

File tree

5 files changed

+6
-39
lines changed

5 files changed

+6
-39
lines changed

block/blk-iocost.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2925,7 +2925,7 @@ static int blk_iocost_init(struct gendisk *disk)
29252925
* called before policy activation completion, can't assume that the
29262926
* target bio has an iocg associated and need to test for NULL iocg.
29272927
*/
2928-
ret = rq_qos_add_frozen(&ioc->rqos, disk, RQ_QOS_COST, &ioc_rqos_ops);
2928+
ret = rq_qos_add(&ioc->rqos, disk, RQ_QOS_COST, &ioc_rqos_ops);
29292929
if (ret)
29302930
goto err_free_ioc;
29312931

block/blk-iolatency.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -764,8 +764,8 @@ static int blk_iolatency_init(struct gendisk *disk)
764764
if (!blkiolat)
765765
return -ENOMEM;
766766

767-
ret = rq_qos_add_frozen(&blkiolat->rqos, disk, RQ_QOS_LATENCY,
768-
&blkcg_iolatency_ops);
767+
ret = rq_qos_add(&blkiolat->rqos, disk, RQ_QOS_LATENCY,
768+
&blkcg_iolatency_ops);
769769
if (ret)
770770
goto err_free;
771771
ret = blkcg_activate_policy(disk, &blkcg_policy_iolatency);

block/blk-rq-qos.c

Lines changed: 2 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -322,8 +322,8 @@ void rq_qos_exit(struct request_queue *q)
322322
mutex_unlock(&q->rq_qos_mutex);
323323
}
324324

325-
int rq_qos_add_frozen(struct rq_qos *rqos, struct gendisk *disk,
326-
enum rq_qos_id id, const struct rq_qos_ops *ops)
325+
int rq_qos_add(struct rq_qos *rqos, struct gendisk *disk, enum rq_qos_id id,
326+
const struct rq_qos_ops *ops)
327327
{
328328
struct request_queue *q = disk->queue;
329329

@@ -343,37 +343,6 @@ int rq_qos_add_frozen(struct rq_qos *rqos, struct gendisk *disk,
343343
return 0;
344344
}
345345

346-
int rq_qos_add(struct rq_qos *rqos, struct gendisk *disk, enum rq_qos_id id,
347-
const struct rq_qos_ops *ops)
348-
{
349-
struct request_queue *q = disk->queue;
350-
unsigned int memflags;
351-
352-
lockdep_assert_held(&q->rq_qos_mutex);
353-
354-
rqos->disk = disk;
355-
rqos->id = id;
356-
rqos->ops = ops;
357-
358-
/*
359-
* No IO can be in-flight when adding rqos, so freeze queue, which
360-
* is fine since we only support rq_qos for blk-mq queue.
361-
*/
362-
memflags = blk_mq_freeze_queue(q);
363-
364-
if (rq_qos_id(q, rqos->id))
365-
goto ebusy;
366-
rqos->next = q->rq_qos;
367-
q->rq_qos = rqos;
368-
blk_queue_flag_set(QUEUE_FLAG_QOS_ENABLED, q);
369-
370-
blk_mq_unfreeze_queue(q, memflags);
371-
return 0;
372-
ebusy:
373-
blk_mq_unfreeze_queue(q, memflags);
374-
return -EBUSY;
375-
}
376-
377346
void rq_qos_del(struct rq_qos *rqos)
378347
{
379348
struct request_queue *q = rqos->disk->queue;

block/blk-rq-qos.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,8 +87,6 @@ static inline void rq_wait_init(struct rq_wait *rq_wait)
8787

8888
int rq_qos_add(struct rq_qos *rqos, struct gendisk *disk, enum rq_qos_id id,
8989
const struct rq_qos_ops *ops);
90-
int rq_qos_add_frozen(struct rq_qos *rqos, struct gendisk *disk,
91-
enum rq_qos_id id, const struct rq_qos_ops *ops);
9290
void rq_qos_del(struct rq_qos *rqos);
9391

9492
typedef bool (acquire_inflight_cb_t)(struct rq_wait *rqw, void *private_data);

block/blk-wbt.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -966,7 +966,7 @@ static int wbt_init(struct gendisk *disk, struct rq_wb *rwb)
966966
* Assign rwb and add the stats callback.
967967
*/
968968
mutex_lock(&q->rq_qos_mutex);
969-
ret = rq_qos_add_frozen(&rwb->rqos, disk, RQ_QOS_WBT, &wbt_rqos_ops);
969+
ret = rq_qos_add(&rwb->rqos, disk, RQ_QOS_WBT, &wbt_rqos_ops);
970970
mutex_unlock(&q->rq_qos_mutex);
971971
if (ret)
972972
return ret;

0 commit comments

Comments
 (0)