diff options
author | Qu Wenruo <quwenruo@cn.fujitsu.com> | 2014-02-27 21:46:08 -0500 |
---|---|---|
committer | Josef Bacik <jbacik@fb.com> | 2014-03-10 15:17:07 -0400 |
commit | a8c93d4ef6f6727764a61a2ee1c1878a755637c5 (patch) | |
tree | 01979e4ce865b8a3bb0c498054800d7b73ab1e9e /fs/btrfs/volumes.c | |
parent | afe3d24267926eb78ba863016bdd65cfe718aef5 (diff) |
btrfs: Replace fs_info->submit_workers with btrfs_workqueue.
Much like the fs_info->workers, replace the fs_info->submit_workers
use the same btrfs_workqueue.
Signed-off-by: Qu Wenruo <quwenruo@cn.fujitsu.com>
Tested-by: David Sterba <dsterba@suse.cz>
Signed-off-by: Josef Bacik <jbacik@fb.com>
Diffstat (limited to 'fs/btrfs/volumes.c')
-rw-r--r-- | fs/btrfs/volumes.c | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/fs/btrfs/volumes.c b/fs/btrfs/volumes.c index 82a63b1a36ef..0066cff077ce 100644 --- a/fs/btrfs/volumes.c +++ b/fs/btrfs/volumes.c | |||
@@ -415,7 +415,8 @@ loop_lock: | |||
415 | device->running_pending = 1; | 415 | device->running_pending = 1; |
416 | 416 | ||
417 | spin_unlock(&device->io_lock); | 417 | spin_unlock(&device->io_lock); |
418 | btrfs_requeue_work(&device->work); | 418 | btrfs_queue_work(fs_info->submit_workers, |
419 | &device->work); | ||
419 | goto done; | 420 | goto done; |
420 | } | 421 | } |
421 | /* unplug every 64 requests just for good measure */ | 422 | /* unplug every 64 requests just for good measure */ |
@@ -439,7 +440,7 @@ done: | |||
439 | blk_finish_plug(&plug); | 440 | blk_finish_plug(&plug); |
440 | } | 441 | } |
441 | 442 | ||
442 | static void pending_bios_fn(struct btrfs_work *work) | 443 | static void pending_bios_fn(struct btrfs_work_struct *work) |
443 | { | 444 | { |
444 | struct btrfs_device *device; | 445 | struct btrfs_device *device; |
445 | 446 | ||
@@ -5379,8 +5380,8 @@ static noinline void btrfs_schedule_bio(struct btrfs_root *root, | |||
5379 | spin_unlock(&device->io_lock); | 5380 | spin_unlock(&device->io_lock); |
5380 | 5381 | ||
5381 | if (should_queue) | 5382 | if (should_queue) |
5382 | btrfs_queue_worker(&root->fs_info->submit_workers, | 5383 | btrfs_queue_work(root->fs_info->submit_workers, |
5383 | &device->work); | 5384 | &device->work); |
5384 | } | 5385 | } |
5385 | 5386 | ||
5386 | static int bio_size_ok(struct block_device *bdev, struct bio *bio, | 5387 | static int bio_size_ok(struct block_device *bdev, struct bio *bio, |
@@ -5668,7 +5669,7 @@ struct btrfs_device *btrfs_alloc_device(struct btrfs_fs_info *fs_info, | |||
5668 | else | 5669 | else |
5669 | generate_random_uuid(dev->uuid); | 5670 | generate_random_uuid(dev->uuid); |
5670 | 5671 | ||
5671 | dev->work.func = pending_bios_fn; | 5672 | btrfs_init_work(&dev->work, pending_bios_fn, NULL, NULL); |
5672 | 5673 | ||
5673 | return dev; | 5674 | return dev; |
5674 | } | 5675 | } |