diff options
-rw-r--r-- | fs/btrfs/ctree.h | 3 | ||||
-rw-r--r-- | fs/btrfs/disk-io.c | 1 | ||||
-rw-r--r-- | fs/btrfs/qgroup.c | 33 |
3 files changed, 24 insertions, 13 deletions
diff --git a/fs/btrfs/ctree.h b/fs/btrfs/ctree.h index f9f512be9d41..df0463e2ab7f 100644 --- a/fs/btrfs/ctree.h +++ b/fs/btrfs/ctree.h | |||
@@ -1264,9 +1264,6 @@ struct btrfs_root { | |||
1264 | int send_in_progress; | 1264 | int send_in_progress; |
1265 | struct btrfs_subvolume_writers *subv_writers; | 1265 | struct btrfs_subvolume_writers *subv_writers; |
1266 | atomic_t will_be_snapshotted; | 1266 | atomic_t will_be_snapshotted; |
1267 | |||
1268 | /* For qgroup metadata space reserve */ | ||
1269 | atomic64_t qgroup_meta_rsv; | ||
1270 | }; | 1267 | }; |
1271 | 1268 | ||
1272 | struct btrfs_file_private { | 1269 | struct btrfs_file_private { |
diff --git a/fs/btrfs/disk-io.c b/fs/btrfs/disk-io.c index 38b387ae78f8..ad900f821f1e 100644 --- a/fs/btrfs/disk-io.c +++ b/fs/btrfs/disk-io.c | |||
@@ -1163,7 +1163,6 @@ static void __setup_root(struct btrfs_root *root, struct btrfs_fs_info *fs_info, | |||
1163 | atomic_set(&root->orphan_inodes, 0); | 1163 | atomic_set(&root->orphan_inodes, 0); |
1164 | refcount_set(&root->refs, 1); | 1164 | refcount_set(&root->refs, 1); |
1165 | atomic_set(&root->will_be_snapshotted, 0); | 1165 | atomic_set(&root->will_be_snapshotted, 0); |
1166 | atomic64_set(&root->qgroup_meta_rsv, 0); | ||
1167 | root->log_transid = 0; | 1166 | root->log_transid = 0; |
1168 | root->log_transid_committed = -1; | 1167 | root->log_transid_committed = -1; |
1169 | root->last_log_commit = 0; | 1168 | root->last_log_commit = 0; |
diff --git a/fs/btrfs/qgroup.c b/fs/btrfs/qgroup.c index 8831eaa14204..a7ca464cdbf7 100644 --- a/fs/btrfs/qgroup.c +++ b/fs/btrfs/qgroup.c | |||
@@ -2499,6 +2499,15 @@ out: | |||
2499 | return ret; | 2499 | return ret; |
2500 | } | 2500 | } |
2501 | 2501 | ||
2502 | /* | ||
2503 | * Free @num_bytes of reserved space with @type for qgroup. (Normally level 0 | ||
2504 | * qgroup). | ||
2505 | * | ||
2506 | * Will handle all higher level qgroup too. | ||
2507 | * | ||
2508 | * NOTE: If @num_bytes is (u64)-1, this means to free all bytes of this qgroup. | ||
2509 | * This special case is only used for META_PERTRANS type. | ||
2510 | */ | ||
2502 | void btrfs_qgroup_free_refroot(struct btrfs_fs_info *fs_info, | 2511 | void btrfs_qgroup_free_refroot(struct btrfs_fs_info *fs_info, |
2503 | u64 ref_root, u64 num_bytes, | 2512 | u64 ref_root, u64 num_bytes, |
2504 | enum btrfs_qgroup_rsv_type type) | 2513 | enum btrfs_qgroup_rsv_type type) |
@@ -2515,6 +2524,10 @@ void btrfs_qgroup_free_refroot(struct btrfs_fs_info *fs_info, | |||
2515 | if (num_bytes == 0) | 2524 | if (num_bytes == 0) |
2516 | return; | 2525 | return; |
2517 | 2526 | ||
2527 | if (num_bytes == (u64)-1 && type != BTRFS_QGROUP_RSV_META_PERTRANS) { | ||
2528 | WARN(1, "%s: Invalid type to free", __func__); | ||
2529 | return; | ||
2530 | } | ||
2518 | spin_lock(&fs_info->qgroup_lock); | 2531 | spin_lock(&fs_info->qgroup_lock); |
2519 | 2532 | ||
2520 | quota_root = fs_info->quota_root; | 2533 | quota_root = fs_info->quota_root; |
@@ -2525,6 +2538,13 @@ void btrfs_qgroup_free_refroot(struct btrfs_fs_info *fs_info, | |||
2525 | if (!qgroup) | 2538 | if (!qgroup) |
2526 | goto out; | 2539 | goto out; |
2527 | 2540 | ||
2541 | /* | ||
2542 | * We're freeing all pertrans rsv, get current value from level 0 | ||
2543 | * qgroup as real num_bytes to free. | ||
2544 | */ | ||
2545 | if (num_bytes == (u64)-1) | ||
2546 | num_bytes = qgroup->rsv.values[type]; | ||
2547 | |||
2528 | ulist_reinit(fs_info->qgroup_ulist); | 2548 | ulist_reinit(fs_info->qgroup_ulist); |
2529 | ret = ulist_add(fs_info->qgroup_ulist, qgroup->qgroupid, | 2549 | ret = ulist_add(fs_info->qgroup_ulist, qgroup->qgroupid, |
2530 | (uintptr_t)qgroup, GFP_ATOMIC); | 2550 | (uintptr_t)qgroup, GFP_ATOMIC); |
@@ -3082,24 +3102,21 @@ int __btrfs_qgroup_reserve_meta(struct btrfs_root *root, int num_bytes, | |||
3082 | ret = qgroup_reserve(root, num_bytes, enforce, type); | 3102 | ret = qgroup_reserve(root, num_bytes, enforce, type); |
3083 | if (ret < 0) | 3103 | if (ret < 0) |
3084 | return ret; | 3104 | return ret; |
3085 | atomic64_add(num_bytes, &root->qgroup_meta_rsv); | ||
3086 | return ret; | 3105 | return ret; |
3087 | } | 3106 | } |
3088 | 3107 | ||
3089 | void btrfs_qgroup_free_meta_all_pertrans(struct btrfs_root *root) | 3108 | void btrfs_qgroup_free_meta_all_pertrans(struct btrfs_root *root) |
3090 | { | 3109 | { |
3091 | struct btrfs_fs_info *fs_info = root->fs_info; | 3110 | struct btrfs_fs_info *fs_info = root->fs_info; |
3092 | u64 reserved; | ||
3093 | 3111 | ||
3094 | if (!test_bit(BTRFS_FS_QUOTA_ENABLED, &fs_info->flags) || | 3112 | if (!test_bit(BTRFS_FS_QUOTA_ENABLED, &fs_info->flags) || |
3095 | !is_fstree(root->objectid)) | 3113 | !is_fstree(root->objectid)) |
3096 | return; | 3114 | return; |
3097 | 3115 | ||
3098 | reserved = atomic64_xchg(&root->qgroup_meta_rsv, 0); | 3116 | /* TODO: Update trace point to handle such free */ |
3099 | if (reserved == 0) | 3117 | trace_qgroup_meta_reserve(root, 0); |
3100 | return; | 3118 | /* Special value -1 means to free all reserved space */ |
3101 | trace_qgroup_meta_reserve(root, -(s64)reserved); | 3119 | btrfs_qgroup_free_refroot(fs_info, root->objectid, (u64)-1, |
3102 | btrfs_qgroup_free_refroot(fs_info, root->objectid, reserved, | ||
3103 | BTRFS_QGROUP_RSV_META_PERTRANS); | 3120 | BTRFS_QGROUP_RSV_META_PERTRANS); |
3104 | } | 3121 | } |
3105 | 3122 | ||
@@ -3113,8 +3130,6 @@ void __btrfs_qgroup_free_meta(struct btrfs_root *root, int num_bytes, | |||
3113 | return; | 3130 | return; |
3114 | 3131 | ||
3115 | BUG_ON(num_bytes != round_down(num_bytes, fs_info->nodesize)); | 3132 | BUG_ON(num_bytes != round_down(num_bytes, fs_info->nodesize)); |
3116 | WARN_ON(atomic64_read(&root->qgroup_meta_rsv) < num_bytes); | ||
3117 | atomic64_sub(num_bytes, &root->qgroup_meta_rsv); | ||
3118 | trace_qgroup_meta_reserve(root, -(s64)num_bytes); | 3133 | trace_qgroup_meta_reserve(root, -(s64)num_bytes); |
3119 | btrfs_qgroup_free_refroot(fs_info, root->objectid, num_bytes, type); | 3134 | btrfs_qgroup_free_refroot(fs_info, root->objectid, num_bytes, type); |
3120 | } | 3135 | } |