提交 31e50229 编写于 作者: L Liu Bo 提交者: Chris Mason

Btrfs: put raid properties into global table

Raid properties can be shared among raid calculation code, we can put
them into a global table to keep it simple.
Signed-off-by: NLiu Bo <bo.li.liu@oracle.com>
Signed-off-by: NChris Mason <chris.mason@fusionio.com>
上级 4ded4f63
...@@ -3077,6 +3077,7 @@ int btrfs_trim_fs(struct btrfs_root *root, struct fstrim_range *range); ...@@ -3077,6 +3077,7 @@ int btrfs_trim_fs(struct btrfs_root *root, struct fstrim_range *range);
int btrfs_init_space_info(struct btrfs_fs_info *fs_info); int btrfs_init_space_info(struct btrfs_fs_info *fs_info);
int btrfs_delayed_refs_qgroup_accounting(struct btrfs_trans_handle *trans, int btrfs_delayed_refs_qgroup_accounting(struct btrfs_trans_handle *trans,
struct btrfs_fs_info *fs_info); struct btrfs_fs_info *fs_info);
int __get_raid_index(u64 flags);
/* ctree.c */ /* ctree.c */
int btrfs_bin_search(struct extent_buffer *eb, struct btrfs_key *key, int btrfs_bin_search(struct extent_buffer *eb, struct btrfs_key *key,
int level, int *slot); int level, int *slot);
......
...@@ -5479,7 +5479,7 @@ wait_block_group_cache_done(struct btrfs_block_group_cache *cache) ...@@ -5479,7 +5479,7 @@ wait_block_group_cache_done(struct btrfs_block_group_cache *cache)
return 0; return 0;
} }
static int __get_block_group_index(u64 flags) int __get_raid_index(u64 flags)
{ {
int index; int index;
...@@ -5499,7 +5499,7 @@ static int __get_block_group_index(u64 flags) ...@@ -5499,7 +5499,7 @@ static int __get_block_group_index(u64 flags)
static int get_block_group_index(struct btrfs_block_group_cache *cache) static int get_block_group_index(struct btrfs_block_group_cache *cache)
{ {
return __get_block_group_index(cache->flags); return __get_raid_index(cache->flags);
} }
enum btrfs_loop_type { enum btrfs_loop_type {
...@@ -7441,7 +7441,7 @@ int btrfs_can_relocate(struct btrfs_root *root, u64 bytenr) ...@@ -7441,7 +7441,7 @@ int btrfs_can_relocate(struct btrfs_root *root, u64 bytenr)
*/ */
target = get_restripe_target(root->fs_info, block_group->flags); target = get_restripe_target(root->fs_info, block_group->flags);
if (target) { if (target) {
index = __get_block_group_index(extended_to_chunk(target)); index = __get_raid_index(extended_to_chunk(target));
} else { } else {
/* /*
* this is just a balance, so if we were marked as full * this is just a balance, so if we were marked as full
......
...@@ -3491,6 +3491,14 @@ static int btrfs_cmp_device_info(const void *a, const void *b) ...@@ -3491,6 +3491,14 @@ static int btrfs_cmp_device_info(const void *a, const void *b)
return 0; return 0;
} }
struct btrfs_raid_attr btrfs_raid_array[BTRFS_NR_RAID_TYPES] = {
{ 2, 1, 0, 4, 2, 2 /* raid10 */ },
{ 1, 1, 2, 2, 2, 2 /* raid1 */ },
{ 1, 2, 1, 1, 1, 2 /* dup */ },
{ 1, 1, 0, 2, 1, 1 /* raid0 */ },
{ 1, 1, 0, 1, 1, 1 /* single */ },
};
static int __btrfs_alloc_chunk(struct btrfs_trans_handle *trans, static int __btrfs_alloc_chunk(struct btrfs_trans_handle *trans,
struct btrfs_root *extent_root, struct btrfs_root *extent_root,
struct map_lookup **map_ret, struct map_lookup **map_ret,
...@@ -3520,43 +3528,21 @@ static int __btrfs_alloc_chunk(struct btrfs_trans_handle *trans, ...@@ -3520,43 +3528,21 @@ static int __btrfs_alloc_chunk(struct btrfs_trans_handle *trans,
int ndevs; int ndevs;
int i; int i;
int j; int j;
int index;
BUG_ON(!alloc_profile_is_valid(type, 0)); BUG_ON(!alloc_profile_is_valid(type, 0));
if (list_empty(&fs_devices->alloc_list)) if (list_empty(&fs_devices->alloc_list))
return -ENOSPC; return -ENOSPC;
sub_stripes = 1; index = __get_raid_index(type);
dev_stripes = 1;
devs_increment = 1;
ncopies = 1;
devs_max = 0; /* 0 == as many as possible */
devs_min = 1;
/* sub_stripes = btrfs_raid_array[index].sub_stripes;
* define the properties of each RAID type. dev_stripes = btrfs_raid_array[index].dev_stripes;
* FIXME: move this to a global table and use it in all RAID devs_max = btrfs_raid_array[index].devs_max;
* calculation code devs_min = btrfs_raid_array[index].devs_min;
*/ devs_increment = btrfs_raid_array[index].devs_increment;
if (type & (BTRFS_BLOCK_GROUP_DUP)) { ncopies = btrfs_raid_array[index].ncopies;
dev_stripes = 2;
ncopies = 2;
devs_max = 1;
} else if (type & (BTRFS_BLOCK_GROUP_RAID0)) {
devs_min = 2;
} else if (type & (BTRFS_BLOCK_GROUP_RAID1)) {
devs_increment = 2;
ncopies = 2;
devs_max = 2;
devs_min = 2;
} else if (type & (BTRFS_BLOCK_GROUP_RAID10)) {
sub_stripes = 2;
devs_increment = 2;
ncopies = 2;
devs_min = 4;
} else {
devs_max = 1;
}
if (type & BTRFS_BLOCK_GROUP_DATA) { if (type & BTRFS_BLOCK_GROUP_DATA) {
max_stripe_size = 1024 * 1024 * 1024; max_stripe_size = 1024 * 1024 * 1024;
......
...@@ -180,6 +180,15 @@ struct btrfs_device_info { ...@@ -180,6 +180,15 @@ struct btrfs_device_info {
u64 total_avail; u64 total_avail;
}; };
struct btrfs_raid_attr {
int sub_stripes; /* sub_stripes info for map */
int dev_stripes; /* stripes per dev */
int devs_max; /* max devs to use */
int devs_min; /* min devs needed */
int devs_increment; /* ndevs has to be a multiple of this */
int ncopies; /* how many copies to data has */
};
struct map_lookup { struct map_lookup {
u64 type; u64 type;
int io_align; int io_align;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册