btrfs: reserve correct number of items for inode creation

The various inode creation code paths do not account for the compression
property, POSIX ACLs, or the parent inode item when starting a
transaction. Fix it by refactoring all of these code paths to use a new
function, btrfs_new_inode_prepare(), which computes the correct number
of items. To do so, it needs to know whether POSIX ACLs will be created,
so move the ACL creation into that function. To reduce the number of
arguments that need to be passed around for inode creation, define
struct btrfs_new_inode_args containing all of the relevant information.

btrfs_new_inode_prepare() will also be a good place to set up the
fscrypt context and encrypted filename in the future.

Reviewed-by: Sweet Tea Dorminy <sweettea-kernel@dorminy.me>
Signed-off-by: Omar Sandoval <osandov@fb.com>
Signed-off-by: David Sterba <dsterba@suse.com>
This commit is contained in:
Omar Sandoval 2022-03-14 18:12:34 -07:00 committed by David Sterba
parent 5f465bf1f1
commit 3538d68dbd
4 changed files with 273 additions and 134 deletions

View File

@ -55,8 +55,8 @@ struct posix_acl *btrfs_get_acl(struct inode *inode, int type, bool rcu)
return acl; return acl;
} }
static int __btrfs_set_acl(struct btrfs_trans_handle *trans, int __btrfs_set_acl(struct btrfs_trans_handle *trans, struct inode *inode,
struct inode *inode, struct posix_acl *acl, int type) struct posix_acl *acl, int type)
{ {
int ret, size = 0; int ret, size = 0;
const char *name; const char *name;
@ -127,35 +127,3 @@ int btrfs_set_acl(struct user_namespace *mnt_userns, struct inode *inode,
inode->i_mode = old_mode; inode->i_mode = old_mode;
return ret; return ret;
} }
int btrfs_init_acl(struct btrfs_trans_handle *trans,
struct inode *inode, struct inode *dir)
{
struct posix_acl *default_acl, *acl;
int ret = 0;
/* this happens with subvols */
if (!dir)
return 0;
ret = posix_acl_create(dir, &inode->i_mode, &default_acl, &acl);
if (ret)
return ret;
if (default_acl) {
ret = __btrfs_set_acl(trans, inode, default_acl,
ACL_TYPE_DEFAULT);
posix_acl_release(default_acl);
}
if (acl) {
if (!ret)
ret = __btrfs_set_acl(trans, inode, acl,
ACL_TYPE_ACCESS);
posix_acl_release(acl);
}
if (!default_acl && !acl)
cache_no_acl(inode);
return ret;
}

View File

@ -3284,11 +3284,32 @@ int btrfs_start_delalloc_roots(struct btrfs_fs_info *fs_info, long nr,
int btrfs_set_extent_delalloc(struct btrfs_inode *inode, u64 start, u64 end, int btrfs_set_extent_delalloc(struct btrfs_inode *inode, u64 start, u64 end,
unsigned int extra_bits, unsigned int extra_bits,
struct extent_state **cached_state); struct extent_state **cached_state);
struct btrfs_new_inode_args {
/* Input */
struct inode *dir;
struct dentry *dentry;
struct inode *inode;
bool orphan;
bool subvol;
/*
* Output from btrfs_new_inode_prepare(), input to
* btrfs_create_new_inode().
*/
struct posix_acl *default_acl;
struct posix_acl *acl;
};
int btrfs_new_inode_prepare(struct btrfs_new_inode_args *args,
unsigned int *trans_num_items);
int btrfs_create_new_inode(struct btrfs_trans_handle *trans,
struct btrfs_new_inode_args *args,
u64 *index);
void btrfs_new_inode_args_destroy(struct btrfs_new_inode_args *args);
struct inode *btrfs_new_subvol_inode(struct user_namespace *mnt_userns, struct inode *btrfs_new_subvol_inode(struct user_namespace *mnt_userns,
struct inode *dir); struct inode *dir);
int btrfs_create_subvol_root(struct btrfs_trans_handle *trans, int btrfs_create_subvol_root(struct btrfs_trans_handle *trans,
struct btrfs_root *parent_root, struct btrfs_root *parent_root,
struct inode *inode); struct btrfs_new_inode_args *args);
void btrfs_set_delalloc_extent(struct inode *inode, struct extent_state *state, void btrfs_set_delalloc_extent(struct inode *inode, struct extent_state *state,
unsigned *bits); unsigned *bits);
void btrfs_clear_delalloc_extent(struct inode *inode, void btrfs_clear_delalloc_extent(struct inode *inode,
@ -3846,15 +3867,16 @@ static inline int __btrfs_fs_compat_ro(struct btrfs_fs_info *fs_info, u64 flag)
struct posix_acl *btrfs_get_acl(struct inode *inode, int type, bool rcu); struct posix_acl *btrfs_get_acl(struct inode *inode, int type, bool rcu);
int btrfs_set_acl(struct user_namespace *mnt_userns, struct inode *inode, int btrfs_set_acl(struct user_namespace *mnt_userns, struct inode *inode,
struct posix_acl *acl, int type); struct posix_acl *acl, int type);
int btrfs_init_acl(struct btrfs_trans_handle *trans, int __btrfs_set_acl(struct btrfs_trans_handle *trans, struct inode *inode,
struct inode *inode, struct inode *dir); struct posix_acl *acl, int type);
#else #else
#define btrfs_get_acl NULL #define btrfs_get_acl NULL
#define btrfs_set_acl NULL #define btrfs_set_acl NULL
static inline int btrfs_init_acl(struct btrfs_trans_handle *trans, static inline int __btrfs_set_acl(struct btrfs_trans_handle *trans,
struct inode *inode, struct inode *dir) struct inode *inode, struct posix_acl *acl,
int type)
{ {
return 0; return -EOPNOTSUPP;
} }
#endif #endif

View File

@ -222,16 +222,26 @@ static inline void btrfs_cleanup_ordered_extents(struct btrfs_inode *inode,
static int btrfs_dirty_inode(struct inode *inode); static int btrfs_dirty_inode(struct inode *inode);
static int btrfs_init_inode_security(struct btrfs_trans_handle *trans, static int btrfs_init_inode_security(struct btrfs_trans_handle *trans,
struct inode *inode, struct inode *dir, struct btrfs_new_inode_args *args)
const struct qstr *qstr)
{ {
int err; int err;
err = btrfs_init_acl(trans, inode, dir); if (args->default_acl) {
if (!err) err = __btrfs_set_acl(trans, args->inode, args->default_acl,
err = btrfs_xattr_security_init(trans, inode, dir, qstr); ACL_TYPE_DEFAULT);
if (err)
return err; return err;
} }
if (args->acl) {
err = __btrfs_set_acl(trans, args->inode, args->acl, ACL_TYPE_ACCESS);
if (err)
return err;
}
if (!args->default_acl && !args->acl)
cache_no_acl(args->inode);
return btrfs_xattr_security_init(trans, args->inode, args->dir,
&args->dentry->d_name);
}
/* /*
* this does all the hard work for inserting an inline extent into * this does all the hard work for inserting an inline extent into
@ -6038,6 +6048,54 @@ static int btrfs_insert_inode_locked(struct inode *inode)
btrfs_find_actor, &args); btrfs_find_actor, &args);
} }
int btrfs_new_inode_prepare(struct btrfs_new_inode_args *args,
unsigned int *trans_num_items)
{
struct inode *dir = args->dir;
struct inode *inode = args->inode;
int ret;
ret = posix_acl_create(dir, &inode->i_mode, &args->default_acl, &args->acl);
if (ret)
return ret;
/* 1 to add inode item */
*trans_num_items = 1;
/* 1 to add compression property */
if (BTRFS_I(dir)->prop_compress)
(*trans_num_items)++;
/* 1 to add default ACL xattr */
if (args->default_acl)
(*trans_num_items)++;
/* 1 to add access ACL xattr */
if (args->acl)
(*trans_num_items)++;
#ifdef CONFIG_SECURITY
/* 1 to add LSM xattr */
if (dir->i_security)
(*trans_num_items)++;
#endif
if (args->orphan) {
/* 1 to add orphan item */
(*trans_num_items)++;
} else {
/*
* 1 to add inode ref
* 1 to add dir item
* 1 to add dir index
* 1 to update parent inode item
*/
*trans_num_items += 4;
}
return 0;
}
void btrfs_new_inode_args_destroy(struct btrfs_new_inode_args *args)
{
posix_acl_release(args->acl);
posix_acl_release(args->default_acl);
}
/* /*
* Inherit flags from the parent inode. * Inherit flags from the parent inode.
* *
@ -6069,12 +6127,16 @@ static void btrfs_inherit_iflags(struct inode *inode, struct inode *dir)
btrfs_sync_inode_flags_to_i_flags(inode); btrfs_sync_inode_flags_to_i_flags(inode);
} }
static int btrfs_new_inode(struct btrfs_trans_handle *trans, int btrfs_create_new_inode(struct btrfs_trans_handle *trans,
struct btrfs_root *root, struct inode *inode, struct btrfs_new_inode_args *args,
struct inode *dir, const char *name, int name_len,
u64 *index) u64 *index)
{ {
struct btrfs_fs_info *fs_info = root->fs_info; struct inode *dir = args->subvol ? NULL : args->dir;
struct inode *inode = args->inode;
const char *name;
int name_len;
struct btrfs_fs_info *fs_info = btrfs_sb(inode->i_sb);
struct btrfs_root *root;
struct btrfs_inode_item *inode_item; struct btrfs_inode_item *inode_item;
struct btrfs_key *location; struct btrfs_key *location;
struct btrfs_path *path; struct btrfs_path *path;
@ -6086,6 +6148,17 @@ static int btrfs_new_inode(struct btrfs_trans_handle *trans,
unsigned long ptr; unsigned long ptr;
int ret; int ret;
if (args->subvol) {
name = "..";
name_len = 2;
} else if (args->orphan) {
name = NULL;
name_len = 0;
} else {
name = args->dentry->d_name.name;
name_len = args->dentry->d_name.len;
}
path = btrfs_alloc_path(); path = btrfs_alloc_path();
if (!path) if (!path)
return -ENOMEM; return -ENOMEM;
@ -6097,6 +6170,10 @@ static int btrfs_new_inode(struct btrfs_trans_handle *trans,
if (!name) if (!name)
set_nlink(inode, 0); set_nlink(inode, 0);
if (!args->subvol)
BTRFS_I(inode)->root = btrfs_grab_root(BTRFS_I(dir)->root);
root = BTRFS_I(inode)->root;
ret = btrfs_get_free_objectid(root, &objectid); ret = btrfs_get_free_objectid(root, &objectid);
if (ret) { if (ret) {
btrfs_free_path(path); btrfs_free_path(path);
@ -6122,8 +6199,6 @@ static int btrfs_new_inode(struct btrfs_trans_handle *trans,
*/ */
BTRFS_I(inode)->index_cnt = 2; BTRFS_I(inode)->index_cnt = 2;
BTRFS_I(inode)->dir_index = *index; BTRFS_I(inode)->dir_index = *index;
if (!BTRFS_I(inode)->root)
BTRFS_I(inode)->root = btrfs_grab_root(root);
BTRFS_I(inode)->generation = trans->transid; BTRFS_I(inode)->generation = trans->transid;
inode->i_generation = BTRFS_I(inode)->generation; inode->i_generation = BTRFS_I(inode)->generation;
@ -6331,30 +6406,37 @@ static int btrfs_create_common(struct inode *dir, struct dentry *dentry,
{ {
struct btrfs_fs_info *fs_info = btrfs_sb(dir->i_sb); struct btrfs_fs_info *fs_info = btrfs_sb(dir->i_sb);
struct btrfs_root *root = BTRFS_I(dir)->root; struct btrfs_root *root = BTRFS_I(dir)->root;
struct btrfs_new_inode_args new_inode_args = {
.dir = dir,
.dentry = dentry,
.inode = inode,
};
unsigned int trans_num_items;
struct btrfs_trans_handle *trans; struct btrfs_trans_handle *trans;
int err; int err;
u64 index = 0; u64 index = 0;
/* err = btrfs_new_inode_prepare(&new_inode_args, &trans_num_items);
* 2 for inode item and ref if (err) {
* 2 for dir items
* 1 for xattr if selinux is on
*/
trans = btrfs_start_transaction(root, 5);
if (IS_ERR(trans)) {
iput(inode); iput(inode);
return PTR_ERR(trans); return err;
} }
err = btrfs_new_inode(trans, root, inode, dir, dentry->d_name.name, trans = btrfs_start_transaction(root, trans_num_items);
dentry->d_name.len, &index); if (IS_ERR(trans)) {
iput(inode);
err = PTR_ERR(trans);
goto out_new_inode_args;
}
err = btrfs_create_new_inode(trans, &new_inode_args, &index);
if (err) { if (err) {
iput(inode); iput(inode);
inode = NULL; inode = NULL;
goto out_unlock; goto out_unlock;
} }
err = btrfs_init_inode_security(trans, inode, dir, &dentry->d_name); err = btrfs_init_inode_security(trans, &new_inode_args);
if (err) if (err)
goto out_unlock; goto out_unlock;
@ -6376,6 +6458,8 @@ out_unlock:
discard_new_inode(inode); discard_new_inode(inode);
} }
btrfs_btree_balance_dirty(fs_info); btrfs_btree_balance_dirty(fs_info);
out_new_inode_args:
btrfs_new_inode_args_destroy(&new_inode_args);
return err; return err;
} }
@ -8653,13 +8737,14 @@ struct inode *btrfs_new_subvol_inode(struct user_namespace *mnt_userns,
*/ */
int btrfs_create_subvol_root(struct btrfs_trans_handle *trans, int btrfs_create_subvol_root(struct btrfs_trans_handle *trans,
struct btrfs_root *parent_root, struct btrfs_root *parent_root,
struct inode *inode) struct btrfs_new_inode_args *args)
{ {
struct inode *inode = args->inode;
struct btrfs_root *new_root = BTRFS_I(inode)->root; struct btrfs_root *new_root = BTRFS_I(inode)->root;
int err; int err;
u64 index = 0; u64 index = 0;
err = btrfs_new_inode(trans, new_root, inode, NULL, "..", 2, &index); err = btrfs_create_new_inode(trans, args, &index);
if (err) if (err)
return err; return err;
@ -9164,22 +9249,22 @@ static struct inode *new_whiteout_inode(struct user_namespace *mnt_userns,
} }
static int btrfs_whiteout_for_rename(struct btrfs_trans_handle *trans, static int btrfs_whiteout_for_rename(struct btrfs_trans_handle *trans,
struct btrfs_root *root, struct btrfs_new_inode_args *args)
struct inode *inode, struct inode *dir,
struct dentry *dentry)
{ {
struct inode *inode = args->inode;
struct inode *dir = args->dir;
struct btrfs_root *root = BTRFS_I(dir)->root;
struct dentry *dentry = args->dentry;
int ret; int ret;
u64 index; u64 index;
ret = btrfs_new_inode(trans, root, inode, dir, dentry->d_name.name, ret = btrfs_create_new_inode(trans, args, &index);
dentry->d_name.len, &index);
if (ret) { if (ret) {
iput(inode); iput(inode);
return ret; return ret;
} }
ret = btrfs_init_inode_security(trans, inode, dir, ret = btrfs_init_inode_security(trans, args);
&dentry->d_name);
if (ret) if (ret)
goto out; goto out;
@ -9204,7 +9289,10 @@ static int btrfs_rename(struct user_namespace *mnt_userns,
unsigned int flags) unsigned int flags)
{ {
struct btrfs_fs_info *fs_info = btrfs_sb(old_dir->i_sb); struct btrfs_fs_info *fs_info = btrfs_sb(old_dir->i_sb);
struct inode *whiteout_inode; struct btrfs_new_inode_args whiteout_args = {
.dir = old_dir,
.dentry = old_dentry,
};
struct btrfs_trans_handle *trans; struct btrfs_trans_handle *trans;
unsigned int trans_num_items; unsigned int trans_num_items;
struct btrfs_root *root = BTRFS_I(old_dir)->root; struct btrfs_root *root = BTRFS_I(old_dir)->root;
@ -9260,9 +9348,15 @@ static int btrfs_rename(struct user_namespace *mnt_userns,
filemap_flush(old_inode->i_mapping); filemap_flush(old_inode->i_mapping);
if (flags & RENAME_WHITEOUT) { if (flags & RENAME_WHITEOUT) {
whiteout_inode = new_whiteout_inode(mnt_userns, old_dir); whiteout_args.inode = new_whiteout_inode(mnt_userns, old_dir);
if (!whiteout_inode) if (!whiteout_args.inode)
return -ENOMEM; return -ENOMEM;
ret = btrfs_new_inode_prepare(&whiteout_args, &trans_num_items);
if (ret)
goto out_whiteout_inode;
} else {
/* 1 to update the old parent inode. */
trans_num_items = 1;
} }
if (old_ino == BTRFS_FIRST_FREE_OBJECTID) { if (old_ino == BTRFS_FIRST_FREE_OBJECTID) {
@ -9274,24 +9368,23 @@ static int btrfs_rename(struct user_namespace *mnt_userns,
* 1 to add new root ref * 1 to add new root ref
* 1 to add new root backref * 1 to add new root backref
*/ */
trans_num_items = 4; trans_num_items += 4;
} else { } else {
/* /*
* 1 to update inode * 1 to update inode
* 1 to remove old inode ref * 1 to remove old inode ref
* 1 to add new inode ref * 1 to add new inode ref
*/ */
trans_num_items = 3; trans_num_items += 3;
} }
/* /*
* 1 to remove old dir item * 1 to remove old dir item
* 1 to remove old dir index * 1 to remove old dir index
* 1 to update old parent inode
* 1 to add new dir item * 1 to add new dir item
* 1 to add new dir index * 1 to add new dir index
* 1 to update new parent inode (if it's not the same as the old parent)
*/ */
trans_num_items += 6; trans_num_items += 4;
/* 1 to update new parent inode if it's not the same as the old parent */
if (new_dir != old_dir) if (new_dir != old_dir)
trans_num_items++; trans_num_items++;
if (new_inode) { if (new_inode) {
@ -9304,8 +9397,6 @@ static int btrfs_rename(struct user_namespace *mnt_userns,
*/ */
trans_num_items += 5; trans_num_items += 5;
} }
if (flags & RENAME_WHITEOUT)
trans_num_items += 5;
trans = btrfs_start_transaction(root, trans_num_items); trans = btrfs_start_transaction(root, trans_num_items);
if (IS_ERR(trans)) { if (IS_ERR(trans)) {
ret = PTR_ERR(trans); ret = PTR_ERR(trans);
@ -9401,9 +9492,8 @@ static int btrfs_rename(struct user_namespace *mnt_userns,
rename_ctx.index, new_dentry->d_parent); rename_ctx.index, new_dentry->d_parent);
if (flags & RENAME_WHITEOUT) { if (flags & RENAME_WHITEOUT) {
ret = btrfs_whiteout_for_rename(trans, root, whiteout_inode, ret = btrfs_whiteout_for_rename(trans, &whiteout_args);
old_dir, old_dentry); whiteout_args.inode = NULL;
whiteout_inode = NULL;
if (ret) { if (ret) {
btrfs_abort_transaction(trans, ret); btrfs_abort_transaction(trans, ret);
goto out_fail; goto out_fail;
@ -9416,7 +9506,10 @@ out_notrans:
if (old_ino == BTRFS_FIRST_FREE_OBJECTID) if (old_ino == BTRFS_FIRST_FREE_OBJECTID)
up_read(&fs_info->subvol_sem); up_read(&fs_info->subvol_sem);
if (flags & RENAME_WHITEOUT) if (flags & RENAME_WHITEOUT)
iput(whiteout_inode); btrfs_new_inode_args_destroy(&whiteout_args);
out_whiteout_inode:
if (flags & RENAME_WHITEOUT)
iput(whiteout_args.inode);
return ret; return ret;
} }
@ -9636,6 +9729,11 @@ static int btrfs_symlink(struct user_namespace *mnt_userns, struct inode *dir,
struct btrfs_path *path; struct btrfs_path *path;
struct btrfs_key key; struct btrfs_key key;
struct inode *inode; struct inode *inode;
struct btrfs_new_inode_args new_inode_args = {
.dir = dir,
.dentry = dentry,
};
unsigned int trans_num_items;
int err; int err;
u64 index = 0; u64 index = 0;
int name_len; int name_len;
@ -9656,28 +9754,30 @@ static int btrfs_symlink(struct user_namespace *mnt_userns, struct inode *dir,
inode_nohighmem(inode); inode_nohighmem(inode);
inode->i_mapping->a_ops = &btrfs_aops; inode->i_mapping->a_ops = &btrfs_aops;
/* new_inode_args.inode = inode;
* 2 items for inode item and ref err = btrfs_new_inode_prepare(&new_inode_args, &trans_num_items);
* 2 items for dir items if (err) {
* 1 item for updating parent inode item iput(inode);
* 1 item for the inline extent item return err;
* 1 item for xattr if selinux is on }
*/ /* 1 additional item for the inline extent */
trans = btrfs_start_transaction(root, 7); trans_num_items++;
trans = btrfs_start_transaction(root, trans_num_items);
if (IS_ERR(trans)) { if (IS_ERR(trans)) {
iput(inode); iput(inode);
return PTR_ERR(trans); err = PTR_ERR(trans);
goto out_new_inode_args;
} }
err = btrfs_new_inode(trans, root, inode, dir, dentry->d_name.name, err = btrfs_create_new_inode(trans, &new_inode_args, &index);
dentry->d_name.len, &index);
if (err) { if (err) {
iput(inode); iput(inode);
inode = NULL; inode = NULL;
goto out_unlock; goto out_unlock;
} }
err = btrfs_init_inode_security(trans, inode, dir, &dentry->d_name); err = btrfs_init_inode_security(trans, &new_inode_args);
if (err) if (err)
goto out_unlock; goto out_unlock;
@ -9736,6 +9836,8 @@ out_unlock:
discard_new_inode(inode); discard_new_inode(inode);
} }
btrfs_btree_balance_dirty(fs_info); btrfs_btree_balance_dirty(fs_info);
out_new_inode_args:
btrfs_new_inode_args_destroy(&new_inode_args);
return err; return err;
} }
@ -9987,6 +10089,12 @@ static int btrfs_tmpfile(struct user_namespace *mnt_userns, struct inode *dir,
struct btrfs_trans_handle *trans; struct btrfs_trans_handle *trans;
struct btrfs_root *root = BTRFS_I(dir)->root; struct btrfs_root *root = BTRFS_I(dir)->root;
struct inode *inode; struct inode *inode;
struct btrfs_new_inode_args new_inode_args = {
.dir = dir,
.dentry = dentry,
.orphan = true,
};
unsigned int trans_num_items;
u64 index; u64 index;
int ret; int ret;
@ -9998,23 +10106,28 @@ static int btrfs_tmpfile(struct user_namespace *mnt_userns, struct inode *dir,
inode->i_op = &btrfs_file_inode_operations; inode->i_op = &btrfs_file_inode_operations;
inode->i_mapping->a_ops = &btrfs_aops; inode->i_mapping->a_ops = &btrfs_aops;
/* new_inode_args.inode = inode;
* 5 units required for adding orphan entry ret = btrfs_new_inode_prepare(&new_inode_args, &trans_num_items);
*/ if (ret) {
trans = btrfs_start_transaction(root, 5);
if (IS_ERR(trans)) {
iput(inode); iput(inode);
return PTR_ERR(trans); return ret;
} }
ret = btrfs_new_inode(trans, root, inode, dir, NULL, 0, &index); trans = btrfs_start_transaction(root, trans_num_items);
if (IS_ERR(trans)) {
iput(inode);
ret = PTR_ERR(trans);
goto out_new_inode_args;
}
ret = btrfs_create_new_inode(trans, &new_inode_args, &index);
if (ret) { if (ret) {
iput(inode); iput(inode);
inode = NULL; inode = NULL;
goto out; goto out;
} }
ret = btrfs_init_inode_security(trans, inode, dir, NULL); ret = btrfs_init_inode_security(trans, &new_inode_args);
if (ret) if (ret)
goto out; goto out;
@ -10026,9 +10139,9 @@ static int btrfs_tmpfile(struct user_namespace *mnt_userns, struct inode *dir,
goto out; goto out;
/* /*
* We set number of links to 0 in btrfs_new_inode(), and here we set * We set number of links to 0 in btrfs_create_new_inode(), and here we
* it to 1 because d_tmpfile() will issue a warning if the count is 0, * set it to 1 because d_tmpfile() will issue a warning if the count is
* through: * 0, through:
* *
* d_tmpfile() -> inode_dec_link_count() -> drop_nlink() * d_tmpfile() -> inode_dec_link_count() -> drop_nlink()
*/ */
@ -10041,6 +10154,8 @@ out:
if (ret && inode) if (ret && inode)
discard_new_inode(inode); discard_new_inode(inode);
btrfs_btree_balance_dirty(fs_info); btrfs_btree_balance_dirty(fs_info);
out_new_inode_args:
btrfs_new_inode_args_destroy(&new_inode_args);
return ret; return ret;
} }

View File

@ -544,6 +544,33 @@ int __pure btrfs_is_empty_uuid(u8 *uuid)
return 1; return 1;
} }
/*
* Calculate the number of transaction items to reserve for creating a subvolume
* or snapshot, not including the inode, directory entries, or parent directory.
*/
static unsigned int create_subvol_num_items(struct btrfs_qgroup_inherit *inherit)
{
/*
* 1 to add root block
* 1 to add root item
* 1 to add root ref
* 1 to add root backref
* 1 to add UUID item
* 1 to add qgroup info
* 1 to add qgroup limit
*
* Ideally the last two would only be accounted if qgroups are enabled,
* but that can change between now and the time we would insert them.
*/
unsigned int num_items = 7;
if (inherit) {
/* 2 to add qgroup relations for each inherited qgroup */
num_items += 2 * inherit->num_qgroups;
}
return num_items;
}
static noinline int create_subvol(struct user_namespace *mnt_userns, static noinline int create_subvol(struct user_namespace *mnt_userns,
struct inode *dir, struct dentry *dentry, struct inode *dir, struct dentry *dentry,
struct btrfs_qgroup_inherit *inherit) struct btrfs_qgroup_inherit *inherit)
@ -560,7 +587,12 @@ static noinline int create_subvol(struct user_namespace *mnt_userns,
struct btrfs_root *new_root; struct btrfs_root *new_root;
struct btrfs_block_rsv block_rsv; struct btrfs_block_rsv block_rsv;
struct timespec64 cur_time = current_time(dir); struct timespec64 cur_time = current_time(dir);
struct inode *inode; struct btrfs_new_inode_args new_inode_args = {
.dir = dir,
.dentry = dentry,
.subvol = true,
};
unsigned int trans_num_items;
int ret; int ret;
dev_t anon_dev; dev_t anon_dev;
u64 objectid; u64 objectid;
@ -587,26 +619,27 @@ static noinline int create_subvol(struct user_namespace *mnt_userns,
if (ret < 0) if (ret < 0)
goto out_root_item; goto out_root_item;
inode = btrfs_new_subvol_inode(mnt_userns, dir); new_inode_args.inode = btrfs_new_subvol_inode(mnt_userns, dir);
if (!inode) { if (!new_inode_args.inode) {
ret = -ENOMEM; ret = -ENOMEM;
goto out_anon_dev; goto out_anon_dev;
} }
ret = btrfs_new_inode_prepare(&new_inode_args, &trans_num_items);
btrfs_init_block_rsv(&block_rsv, BTRFS_BLOCK_RSV_TEMP);
/*
* The same as the snapshot creation, please see the comment
* of create_snapshot().
*/
ret = btrfs_subvolume_reserve_metadata(root, &block_rsv, 8, false);
if (ret) if (ret)
goto out_inode; goto out_inode;
trans_num_items += create_subvol_num_items(inherit);
btrfs_init_block_rsv(&block_rsv, BTRFS_BLOCK_RSV_TEMP);
ret = btrfs_subvolume_reserve_metadata(root, &block_rsv,
trans_num_items, false);
if (ret)
goto out_new_inode_args;
trans = btrfs_start_transaction(root, 0); trans = btrfs_start_transaction(root, 0);
if (IS_ERR(trans)) { if (IS_ERR(trans)) {
ret = PTR_ERR(trans); ret = PTR_ERR(trans);
btrfs_subvolume_release_metadata(root, &block_rsv); btrfs_subvolume_release_metadata(root, &block_rsv);
goto out_inode; goto out_new_inode_args;
} }
trans->block_rsv = &block_rsv; trans->block_rsv = &block_rsv;
trans->bytes_reserved = block_rsv.size; trans->bytes_reserved = block_rsv.size;
@ -689,8 +722,8 @@ static noinline int create_subvol(struct user_namespace *mnt_userns,
} }
/* anon_dev is owned by new_root now. */ /* anon_dev is owned by new_root now. */
anon_dev = 0; anon_dev = 0;
BTRFS_I(inode)->root = new_root; BTRFS_I(new_inode_args.inode)->root = new_root;
/* ... and new_root is owned by inode now. */ /* ... and new_root is owned by new_inode_args.inode now. */
ret = btrfs_record_root_in_trans(trans, new_root); ret = btrfs_record_root_in_trans(trans, new_root);
if (ret) { if (ret) {
@ -698,7 +731,7 @@ static noinline int create_subvol(struct user_namespace *mnt_userns,
goto out; goto out;
} }
ret = btrfs_create_subvol_root(trans, root, inode); ret = btrfs_create_subvol_root(trans, root, &new_inode_args);
if (ret) { if (ret) {
/* We potentially lose an unused inode item here */ /* We potentially lose an unused inode item here */
btrfs_abort_transaction(trans, ret); btrfs_abort_transaction(trans, ret);
@ -751,11 +784,13 @@ out:
ret = btrfs_commit_transaction(trans); ret = btrfs_commit_transaction(trans);
if (!ret) { if (!ret) {
d_instantiate(dentry, inode); d_instantiate(dentry, new_inode_args.inode);
inode = NULL; new_inode_args.inode = NULL;
} }
out_new_inode_args:
btrfs_new_inode_args_destroy(&new_inode_args);
out_inode: out_inode:
iput(inode); iput(new_inode_args.inode);
out_anon_dev: out_anon_dev:
if (anon_dev) if (anon_dev)
free_anon_bdev(anon_dev); free_anon_bdev(anon_dev);
@ -771,6 +806,7 @@ static int create_snapshot(struct btrfs_root *root, struct inode *dir,
struct btrfs_fs_info *fs_info = btrfs_sb(dir->i_sb); struct btrfs_fs_info *fs_info = btrfs_sb(dir->i_sb);
struct inode *inode; struct inode *inode;
struct btrfs_pending_snapshot *pending_snapshot; struct btrfs_pending_snapshot *pending_snapshot;
unsigned int trans_num_items;
struct btrfs_trans_handle *trans; struct btrfs_trans_handle *trans;
int ret; int ret;
@ -808,16 +844,14 @@ static int create_snapshot(struct btrfs_root *root, struct inode *dir,
btrfs_init_block_rsv(&pending_snapshot->block_rsv, btrfs_init_block_rsv(&pending_snapshot->block_rsv,
BTRFS_BLOCK_RSV_TEMP); BTRFS_BLOCK_RSV_TEMP);
/* /*
* 1 - parent dir inode * 1 to add dir item
* 2 - dir entries * 1 to add dir index
* 1 - root item * 1 to update parent inode item
* 2 - root ref/backref
* 1 - root of snapshot
* 1 - UUID item
*/ */
trans_num_items = create_subvol_num_items(inherit) + 3;
ret = btrfs_subvolume_reserve_metadata(BTRFS_I(dir)->root, ret = btrfs_subvolume_reserve_metadata(BTRFS_I(dir)->root,
&pending_snapshot->block_rsv, 8, &pending_snapshot->block_rsv,
false); trans_num_items, false);
if (ret) if (ret)
goto free_pending; goto free_pending;