aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fs/btrfs/ctree.h3
-rw-r--r--fs/btrfs/disk-io.c1
-rw-r--r--fs/btrfs/qgroup.c33
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
1272struct btrfs_file_private { 1269struct 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 */
2502void btrfs_qgroup_free_refroot(struct btrfs_fs_info *fs_info, 2511void 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
3089void btrfs_qgroup_free_meta_all_pertrans(struct btrfs_root *root) 3108void 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}