diff options
author | Jens Axboe <jens.axboe@oracle.com> | 2008-07-28 07:08:45 -0400 |
---|---|---|
committer | Jens Axboe <jens.axboe@oracle.com> | 2008-10-09 02:56:09 -0400 |
commit | 18887ad910e56066233a07fd3cfb2fa11338b782 (patch) | |
tree | a8d14ba47f15c58e36b26c82fa4ae4ad7526c80a /block/blk-core.c | |
parent | b646fc59b332ef307895558c9cd1359dc2d25813 (diff) |
block: make kblockd_schedule_work() take the queue as parameter
Preparatory patch for checking queuing affinity.
Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
Diffstat (limited to 'block/blk-core.c')
-rw-r--r-- | block/blk-core.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/block/blk-core.c b/block/blk-core.c index 527b3382a610..9c6f818d0c33 100644 --- a/block/blk-core.c +++ b/block/blk-core.c | |||
@@ -305,7 +305,7 @@ void blk_unplug_timeout(unsigned long data) | |||
305 | blk_add_trace_pdu_int(q, BLK_TA_UNPLUG_TIMER, NULL, | 305 | blk_add_trace_pdu_int(q, BLK_TA_UNPLUG_TIMER, NULL, |
306 | q->rq.count[READ] + q->rq.count[WRITE]); | 306 | q->rq.count[READ] + q->rq.count[WRITE]); |
307 | 307 | ||
308 | kblockd_schedule_work(&q->unplug_work); | 308 | kblockd_schedule_work(q, &q->unplug_work); |
309 | } | 309 | } |
310 | 310 | ||
311 | void blk_unplug(struct request_queue *q) | 311 | void blk_unplug(struct request_queue *q) |
@@ -346,7 +346,7 @@ void blk_start_queue(struct request_queue *q) | |||
346 | queue_flag_clear(QUEUE_FLAG_REENTER, q); | 346 | queue_flag_clear(QUEUE_FLAG_REENTER, q); |
347 | } else { | 347 | } else { |
348 | blk_plug_device(q); | 348 | blk_plug_device(q); |
349 | kblockd_schedule_work(&q->unplug_work); | 349 | kblockd_schedule_work(q, &q->unplug_work); |
350 | } | 350 | } |
351 | } | 351 | } |
352 | EXPORT_SYMBOL(blk_start_queue); | 352 | EXPORT_SYMBOL(blk_start_queue); |
@@ -411,7 +411,7 @@ void __blk_run_queue(struct request_queue *q) | |||
411 | queue_flag_clear(QUEUE_FLAG_REENTER, q); | 411 | queue_flag_clear(QUEUE_FLAG_REENTER, q); |
412 | } else { | 412 | } else { |
413 | blk_plug_device(q); | 413 | blk_plug_device(q); |
414 | kblockd_schedule_work(&q->unplug_work); | 414 | kblockd_schedule_work(q, &q->unplug_work); |
415 | } | 415 | } |
416 | } | 416 | } |
417 | } | 417 | } |
@@ -1959,7 +1959,7 @@ void blk_rq_bio_prep(struct request_queue *q, struct request *rq, | |||
1959 | rq->rq_disk = bio->bi_bdev->bd_disk; | 1959 | rq->rq_disk = bio->bi_bdev->bd_disk; |
1960 | } | 1960 | } |
1961 | 1961 | ||
1962 | int kblockd_schedule_work(struct work_struct *work) | 1962 | int kblockd_schedule_work(struct request_queue *q, struct work_struct *work) |
1963 | { | 1963 | { |
1964 | return queue_work(kblockd_workqueue, work); | 1964 | return queue_work(kblockd_workqueue, work); |
1965 | } | 1965 | } |