Commit 6143c23c authored by Naohiro Aota's avatar Naohiro Aota Committed by David Sterba

btrfs: zoned: implement cloning for zoned device-replace

This is 2/4 patch to implement device replace for zoned filesystems.

In zoned mode, a block group must be either copied (from the source
device to the target device) or cloned (to both devices).

Implement the cloning part. If a block group targeted by an IO is marked
to copy, we should not clone the IO to the destination device, because
the block group is eventually copied by the replace process.

This commit also handles cloning of device reset.
Reviewed-by: default avatarJosef Bacik <josef@toxicpanda.com>
Signed-off-by: default avatarNaohiro Aota <naohiro.aota@wdc.com>
Signed-off-by: default avatarDavid Sterba <dsterba@suse.com>
parent 78ce9fc2
...@@ -35,6 +35,7 @@ ...@@ -35,6 +35,7 @@
#include "discard.h" #include "discard.h"
#include "rcu-string.h" #include "rcu-string.h"
#include "zoned.h" #include "zoned.h"
#include "dev-replace.h"
#undef SCRAMBLE_DELAYED_REFS #undef SCRAMBLE_DELAYED_REFS
...@@ -1265,6 +1266,46 @@ static int btrfs_issue_discard(struct block_device *bdev, u64 start, u64 len, ...@@ -1265,6 +1266,46 @@ static int btrfs_issue_discard(struct block_device *bdev, u64 start, u64 len,
return ret; return ret;
} }
static int do_discard_extent(struct btrfs_bio_stripe *stripe, u64 *bytes)
{
struct btrfs_device *dev = stripe->dev;
struct btrfs_fs_info *fs_info = dev->fs_info;
struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;
u64 phys = stripe->physical;
u64 len = stripe->length;
u64 discarded = 0;
int ret = 0;
/* Zone reset on a zoned filesystem */
if (btrfs_can_zone_reset(dev, phys, len)) {
u64 src_disc;
ret = btrfs_reset_device_zone(dev, phys, len, &discarded);
if (ret)
goto out;
if (!btrfs_dev_replace_is_ongoing(dev_replace) ||
dev != dev_replace->srcdev)
goto out;
src_disc = discarded;
/* Send to replace target as well */
ret = btrfs_reset_device_zone(dev_replace->tgtdev, phys, len,
&discarded);
discarded += src_disc;
} else if (blk_queue_discard(bdev_get_queue(stripe->dev->bdev))) {
ret = btrfs_issue_discard(dev->bdev, phys, len, &discarded);
} else {
ret = 0;
*bytes = 0;
}
out:
*bytes = discarded;
return ret;
}
int btrfs_discard_extent(struct btrfs_fs_info *fs_info, u64 bytenr, int btrfs_discard_extent(struct btrfs_fs_info *fs_info, u64 bytenr,
u64 num_bytes, u64 *actual_bytes) u64 num_bytes, u64 *actual_bytes)
{ {
...@@ -1298,28 +1339,14 @@ int btrfs_discard_extent(struct btrfs_fs_info *fs_info, u64 bytenr, ...@@ -1298,28 +1339,14 @@ int btrfs_discard_extent(struct btrfs_fs_info *fs_info, u64 bytenr,
stripe = bbio->stripes; stripe = bbio->stripes;
for (i = 0; i < bbio->num_stripes; i++, stripe++) { for (i = 0; i < bbio->num_stripes; i++, stripe++) {
struct btrfs_device *dev = stripe->dev;
u64 physical = stripe->physical;
u64 length = stripe->length;
u64 bytes; u64 bytes;
struct request_queue *req_q;
if (!stripe->dev->bdev) { if (!stripe->dev->bdev) {
ASSERT(btrfs_test_opt(fs_info, DEGRADED)); ASSERT(btrfs_test_opt(fs_info, DEGRADED));
continue; continue;
} }
req_q = bdev_get_queue(stripe->dev->bdev); ret = do_discard_extent(stripe, &bytes);
/* Zone reset on zoned filesystems */
if (btrfs_can_zone_reset(dev, physical, length))
ret = btrfs_reset_device_zone(dev, physical,
length, &bytes);
else if (blk_queue_discard(req_q))
ret = btrfs_issue_discard(dev->bdev, physical,
length, &bytes);
else
continue;
if (!ret) { if (!ret) {
discarded_bytes += bytes; discarded_bytes += bytes;
} else if (ret != -EOPNOTSUPP) { } else if (ret != -EOPNOTSUPP) {
......
...@@ -5973,9 +5973,29 @@ static int get_extra_mirror_from_replace(struct btrfs_fs_info *fs_info, ...@@ -5973,9 +5973,29 @@ static int get_extra_mirror_from_replace(struct btrfs_fs_info *fs_info,
return ret; return ret;
} }
static bool is_block_group_to_copy(struct btrfs_fs_info *fs_info, u64 logical)
{
struct btrfs_block_group *cache;
bool ret;
/* Non-ZONED mode does not use "to_copy" flag */
if (!btrfs_is_zoned(fs_info))
return false;
cache = btrfs_lookup_block_group(fs_info, logical);
spin_lock(&cache->lock);
ret = cache->to_copy;
spin_unlock(&cache->lock);
btrfs_put_block_group(cache);
return ret;
}
static void handle_ops_on_dev_replace(enum btrfs_map_op op, static void handle_ops_on_dev_replace(enum btrfs_map_op op,
struct btrfs_bio **bbio_ret, struct btrfs_bio **bbio_ret,
struct btrfs_dev_replace *dev_replace, struct btrfs_dev_replace *dev_replace,
u64 logical,
int *num_stripes_ret, int *max_errors_ret) int *num_stripes_ret, int *max_errors_ret)
{ {
struct btrfs_bio *bbio = *bbio_ret; struct btrfs_bio *bbio = *bbio_ret;
...@@ -5988,6 +6008,13 @@ static void handle_ops_on_dev_replace(enum btrfs_map_op op, ...@@ -5988,6 +6008,13 @@ static void handle_ops_on_dev_replace(enum btrfs_map_op op,
if (op == BTRFS_MAP_WRITE) { if (op == BTRFS_MAP_WRITE) {
int index_where_to_add; int index_where_to_add;
/*
* A block group which have "to_copy" set will eventually
* copied by dev-replace process. We can avoid cloning IO here.
*/
if (is_block_group_to_copy(dev_replace->srcdev->fs_info, logical))
return;
/* /*
* duplicate the write operations while the dev replace * duplicate the write operations while the dev replace
* procedure is running. Since the copying of the old disk to * procedure is running. Since the copying of the old disk to
...@@ -6376,8 +6403,8 @@ static int __btrfs_map_block(struct btrfs_fs_info *fs_info, ...@@ -6376,8 +6403,8 @@ static int __btrfs_map_block(struct btrfs_fs_info *fs_info,
if (dev_replace_is_ongoing && dev_replace->tgtdev != NULL && if (dev_replace_is_ongoing && dev_replace->tgtdev != NULL &&
need_full_stripe(op)) { need_full_stripe(op)) {
handle_ops_on_dev_replace(op, &bbio, dev_replace, &num_stripes, handle_ops_on_dev_replace(op, &bbio, dev_replace, logical,
&max_errors); &num_stripes, &max_errors);
} }
*bbio_ret = bbio; *bbio_ret = bbio;
......
...@@ -11,6 +11,7 @@ ...@@ -11,6 +11,7 @@
#include "disk-io.h" #include "disk-io.h"
#include "block-group.h" #include "block-group.h"
#include "transaction.h" #include "transaction.h"
#include "dev-replace.h"
/* Maximum number of zones to report per blkdev_report_zones() call */ /* Maximum number of zones to report per blkdev_report_zones() call */
#define BTRFS_REPORT_NR_ZONES 4096 #define BTRFS_REPORT_NR_ZONES 4096
...@@ -1036,6 +1037,8 @@ int btrfs_load_block_group_zone_info(struct btrfs_block_group *cache, bool new) ...@@ -1036,6 +1037,8 @@ int btrfs_load_block_group_zone_info(struct btrfs_block_group *cache, bool new)
for (i = 0; i < map->num_stripes; i++) { for (i = 0; i < map->num_stripes; i++) {
bool is_sequential; bool is_sequential;
struct blk_zone zone; struct blk_zone zone;
struct btrfs_dev_replace *dev_replace = &fs_info->dev_replace;
int dev_replace_is_ongoing = 0;
device = map->stripes[i].dev; device = map->stripes[i].dev;
physical = map->stripes[i].physical; physical = map->stripes[i].physical;
...@@ -1062,6 +1065,12 @@ int btrfs_load_block_group_zone_info(struct btrfs_block_group *cache, bool new) ...@@ -1062,6 +1065,12 @@ int btrfs_load_block_group_zone_info(struct btrfs_block_group *cache, bool new)
*/ */
btrfs_dev_clear_zone_empty(device, physical); btrfs_dev_clear_zone_empty(device, physical);
down_read(&dev_replace->rwsem);
dev_replace_is_ongoing = btrfs_dev_replace_is_ongoing(dev_replace);
if (dev_replace_is_ongoing && dev_replace->tgtdev != NULL)
btrfs_dev_clear_zone_empty(dev_replace->tgtdev, physical);
up_read(&dev_replace->rwsem);
/* /*
* The group is mapped to a sequential zone. Get the zone write * The group is mapped to a sequential zone. Get the zone write
* pointer to determine the allocation offset within the zone. * pointer to determine the allocation offset within the zone.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment