diff options
author | NeilBrown <neilb@suse.de> | 2006-10-03 04:15:53 -0400 |
---|---|---|
committer | Linus Torvalds <torvalds@g5.osdl.org> | 2006-10-03 11:04:18 -0400 |
commit | 26be34dc3a46be983352dd89683db374b0cb73fa (patch) | |
tree | 296ed9d019ac56d4a6ea0909f1cf11bdfd08a3e5 /drivers/md/linear.c | |
parent | c04be0aa82ff535e3676ab3e573957bdeef41879 (diff) |
[PATCH] md: define backing_dev_info.congested_fn for raid0 and linear
Each backing_dev needs to be able to report whether it is congested, either by
modulating BDI_*_congested in ->state, or by defining a ->congested_fn.
md/raid did neither of these. This patch add a congested_fn which simply
checks all component devices to see if they are congested.
Signed-off-by: Neil Brown <neilb@suse.de>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
Diffstat (limited to 'drivers/md/linear.c')
-rw-r--r-- | drivers/md/linear.c | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/drivers/md/linear.c b/drivers/md/linear.c index b99c19c7eb22..c625ddb8833d 100644 --- a/drivers/md/linear.c +++ b/drivers/md/linear.c | |||
@@ -111,6 +111,19 @@ static int linear_issue_flush(request_queue_t *q, struct gendisk *disk, | |||
111 | return ret; | 111 | return ret; |
112 | } | 112 | } |
113 | 113 | ||
114 | static int linear_congested(void *data, int bits) | ||
115 | { | ||
116 | mddev_t *mddev = data; | ||
117 | linear_conf_t *conf = mddev_to_conf(mddev); | ||
118 | int i, ret = 0; | ||
119 | |||
120 | for (i = 0; i < mddev->raid_disks && !ret ; i++) { | ||
121 | request_queue_t *q = bdev_get_queue(conf->disks[i].rdev->bdev); | ||
122 | ret |= bdi_congested(&q->backing_dev_info, bits); | ||
123 | } | ||
124 | return ret; | ||
125 | } | ||
126 | |||
114 | static linear_conf_t *linear_conf(mddev_t *mddev, int raid_disks) | 127 | static linear_conf_t *linear_conf(mddev_t *mddev, int raid_disks) |
115 | { | 128 | { |
116 | linear_conf_t *conf; | 129 | linear_conf_t *conf; |
@@ -269,6 +282,8 @@ static int linear_run (mddev_t *mddev) | |||
269 | blk_queue_merge_bvec(mddev->queue, linear_mergeable_bvec); | 282 | blk_queue_merge_bvec(mddev->queue, linear_mergeable_bvec); |
270 | mddev->queue->unplug_fn = linear_unplug; | 283 | mddev->queue->unplug_fn = linear_unplug; |
271 | mddev->queue->issue_flush_fn = linear_issue_flush; | 284 | mddev->queue->issue_flush_fn = linear_issue_flush; |
285 | mddev->queue->backing_dev_info.congested_fn = linear_congested; | ||
286 | mddev->queue->backing_dev_info.congested_data = mddev; | ||
272 | return 0; | 287 | return 0; |
273 | } | 288 | } |
274 | 289 | ||