aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStefan Bader <stefan.bader@canonical.com>2011-05-26 13:19:57 +0200
committerJohn Rigby <john.rigby@linaro.org>2012-06-25 12:17:00 -0600
commit20fc1804699b5675a1c1bb05e72e7ed9d41525b2 (patch)
tree3311f4b42a332f0307a3004c9fd317b01dab9959
parentdd9aed4be7b2e8b9ae7dc2f41f6024a30e763db9 (diff)
UBUNTU: SAUCE: Convert dm-raid45 to new block plugging
Plugging for IOs to block devices was changed to an explicit, per task base. This converts the module to the new framework, fixing the compile failure. Signed-off-by: Stefan Bader <stefan.bader@canonical.com> Signed-off-by: Leann Ogasawara <leann.ogasawara@canonical.com>
-rw-r--r--ubuntu/dm-raid4-5/dm-raid4-5.c19
1 files changed, 5 insertions, 14 deletions
diff --git a/ubuntu/dm-raid4-5/dm-raid4-5.c b/ubuntu/dm-raid4-5/dm-raid4-5.c
index 504aee38d03..fcc782c80fb 100644
--- a/ubuntu/dm-raid4-5/dm-raid4-5.c
+++ b/ubuntu/dm-raid4-5/dm-raid4-5.c
@@ -3275,18 +3275,6 @@ static void do_ios(struct raid_set *rs, struct bio_list *ios)
bio_list_merge_head(ios, &reject);
}
-/* Unplug: let any queued io role on the sets devices. */
-static void do_unplug(struct raid_set *rs)
-{
- struct raid_dev *dev = rs->dev + rs->set.raid_devs;
-
- while (dev-- > rs->dev) {
- /* Only call any device unplug function, if io got queued. */
- if (TestClearDevIoQueued(dev))
- blk_unplug(bdev_get_queue(dev->dev->bdev));
- }
-}
-
/* Send an event in case we're getting too busy. */
static void do_busy_event(struct raid_set *rs)
{
@@ -3326,6 +3314,7 @@ static void do_raid(struct work_struct *ws)
struct raid_set *rs = container_of(ws, struct raid_set,
io.dws_do_raid.work);
struct bio_list *ios = &rs->io.work, *ios_in = &rs->io.in;
+ struct blk_plug plug;
/*
* We always need to end io, so that ios can get errored in
@@ -3342,8 +3331,9 @@ static void do_raid(struct work_struct *ws)
do_sc_resize(rs);
/* Try to recover regions. */
+ blk_start_plug(&plug);
do_recovery(rs);
- do_unplug(rs); /* Unplug the sets device queues. */
+ blk_finish_plug(&plug); /* Unplug the queue */
/* Quickly grab all new ios queued and add them to the work list. */
mutex_lock(&rs->io.in_lock);
@@ -3351,11 +3341,12 @@ static void do_raid(struct work_struct *ws)
bio_list_init(ios_in);
mutex_unlock(&rs->io.in_lock);
+ blk_start_plug(&plug);
if (!bio_list_empty(ios))
do_ios(rs, ios); /* Got ios to work into the cache. */
do_flush(rs); /* Flush any stripes on io list. */
- do_unplug(rs); /* Unplug the sets device queues. */
+ blk_finish_plug(&plug); /* Unplug the queue */
do_busy_event(rs); /* Check if we got too busy. */
}