diff options
| author | Jens Axboe <axboe@fb.com> | 2014-03-19 15:25:02 -0600 |
|---|---|---|
| committer | Jens Axboe <axboe@fb.com> | 2014-03-19 15:25:02 -0600 |
| commit | 5d12f905cc50c0810628d0deedd478ec2db48659 (patch) | |
| tree | d1cb703151748740c5fb550630710a4f253a7e49 /block/blk-mq.c | |
| parent | 95363efde193079541cb379eb47140e9c4d355d5 (diff) | |
| download | linux-stable-5d12f905cc50c0810628d0deedd478ec2db48659.tar.gz linux-stable-5d12f905cc50c0810628d0deedd478ec2db48659.tar.bz2 linux-stable-5d12f905cc50c0810628d0deedd478ec2db48659.zip | |
blk-mq: fix wrong usage of hctx->state vs hctx->flags
BLK_MQ_F_* flags are for hctx->flags, and are non-atomic and
set at registration time. BLK_MQ_S_* flags are dynamic and
atomic, and are accessed through hctx->state.
Some of the BLK_MQ_S_STOPPED uses were wrong. Additionally,
the header file should not use a bit shift for the _S_ flags,
as they are done through the set/test_bit functions.
Signed-off-by: Jens Axboe <axboe@fb.com>
Diffstat (limited to 'block/blk-mq.c')
| -rw-r--r-- | block/blk-mq.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/block/blk-mq.c b/block/blk-mq.c index 92284af4e0df..ed216f27e3b8 100644 --- a/block/blk-mq.c +++ b/block/blk-mq.c @@ -547,7 +547,7 @@ static void __blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx) LIST_HEAD(rq_list); int bit, queued; - if (unlikely(test_bit(BLK_MQ_S_STOPPED, &hctx->flags))) + if (unlikely(test_bit(BLK_MQ_S_STOPPED, &hctx->state))) return; hctx->run++; @@ -636,7 +636,7 @@ static void __blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx) void blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx, bool async) { - if (unlikely(test_bit(BLK_MQ_S_STOPPED, &hctx->flags))) + if (unlikely(test_bit(BLK_MQ_S_STOPPED, &hctx->state))) return; if (!async) @@ -656,7 +656,7 @@ void blk_mq_run_queues(struct request_queue *q, bool async) queue_for_each_hw_ctx(q, hctx, i) { if ((!blk_mq_hctx_has_pending(hctx) && list_empty_careful(&hctx->dispatch)) || - test_bit(BLK_MQ_S_STOPPED, &hctx->flags)) + test_bit(BLK_MQ_S_STOPPED, &hctx->state)) continue; blk_mq_run_hw_queue(hctx, async); |