Commit 9f3db423 authored by Nikolay Borisov's avatar Nikolay Borisov Committed by David Sterba

btrfs: Make btrfs_delalloc_reserve_metadata take btrfs_inode

Signed-off-by: default avatarNikolay Borisov <nborisov@suse.com>
Signed-off-by: default avatarDavid Sterba <dsterba@suse.com>
parent 703b391a
...@@ -2703,7 +2703,7 @@ int btrfs_subvolume_reserve_metadata(struct btrfs_root *root, ...@@ -2703,7 +2703,7 @@ int btrfs_subvolume_reserve_metadata(struct btrfs_root *root,
u64 *qgroup_reserved, bool use_global_rsv); u64 *qgroup_reserved, bool use_global_rsv);
void btrfs_subvolume_release_metadata(struct btrfs_fs_info *fs_info, void btrfs_subvolume_release_metadata(struct btrfs_fs_info *fs_info,
struct btrfs_block_rsv *rsv); struct btrfs_block_rsv *rsv);
int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes); int btrfs_delalloc_reserve_metadata(struct btrfs_inode *inode, u64 num_bytes);
void btrfs_delalloc_release_metadata(struct inode *inode, u64 num_bytes); void btrfs_delalloc_release_metadata(struct inode *inode, u64 num_bytes);
int btrfs_delalloc_reserve_space(struct inode *inode, u64 start, u64 len); int btrfs_delalloc_reserve_space(struct inode *inode, u64 start, u64 len);
void btrfs_delalloc_release_space(struct inode *inode, u64 start, u64 len); void btrfs_delalloc_release_space(struct inode *inode, u64 start, u64 len);
......
...@@ -5920,10 +5920,10 @@ static u64 calc_csum_metadata_size(struct btrfs_inode *inode, u64 num_bytes, ...@@ -5920,10 +5920,10 @@ static u64 calc_csum_metadata_size(struct btrfs_inode *inode, u64 num_bytes,
return btrfs_calc_trans_metadata_size(fs_info, old_csums - num_csums); return btrfs_calc_trans_metadata_size(fs_info, old_csums - num_csums);
} }
int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) int btrfs_delalloc_reserve_metadata(struct btrfs_inode *inode, u64 num_bytes)
{ {
struct btrfs_fs_info *fs_info = btrfs_sb(inode->i_sb); struct btrfs_fs_info *fs_info = btrfs_sb(inode->vfs_inode.i_sb);
struct btrfs_root *root = BTRFS_I(inode)->root; struct btrfs_root *root = inode->root;
struct btrfs_block_rsv *block_rsv = &fs_info->delalloc_block_rsv; struct btrfs_block_rsv *block_rsv = &fs_info->delalloc_block_rsv;
u64 to_reserve = 0; u64 to_reserve = 0;
u64 csum_bytes; u64 csum_bytes;
...@@ -5943,7 +5943,7 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -5943,7 +5943,7 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
* If we have a transaction open (can happen if we call truncate_block * If we have a transaction open (can happen if we call truncate_block
* from truncate), then we need FLUSH_LIMIT so we don't deadlock. * from truncate), then we need FLUSH_LIMIT so we don't deadlock.
*/ */
if (btrfs_is_free_space_inode(BTRFS_I(inode))) { if (btrfs_is_free_space_inode(inode)) {
flush = BTRFS_RESERVE_NO_FLUSH; flush = BTRFS_RESERVE_NO_FLUSH;
delalloc_lock = false; delalloc_lock = false;
} else if (current->journal_info) { } else if (current->journal_info) {
...@@ -5955,25 +5955,24 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -5955,25 +5955,24 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
schedule_timeout(1); schedule_timeout(1);
if (delalloc_lock) if (delalloc_lock)
mutex_lock(&BTRFS_I(inode)->delalloc_mutex); mutex_lock(&inode->delalloc_mutex);
num_bytes = ALIGN(num_bytes, fs_info->sectorsize); num_bytes = ALIGN(num_bytes, fs_info->sectorsize);
spin_lock(&BTRFS_I(inode)->lock); spin_lock(&inode->lock);
nr_extents = count_max_extents(num_bytes); nr_extents = count_max_extents(num_bytes);
BTRFS_I(inode)->outstanding_extents += nr_extents; inode->outstanding_extents += nr_extents;
nr_extents = 0; nr_extents = 0;
if (BTRFS_I(inode)->outstanding_extents > if (inode->outstanding_extents > inode->reserved_extents)
BTRFS_I(inode)->reserved_extents) nr_extents += inode->outstanding_extents -
nr_extents += BTRFS_I(inode)->outstanding_extents - inode->reserved_extents;
BTRFS_I(inode)->reserved_extents;
/* We always want to reserve a slot for updating the inode. */ /* We always want to reserve a slot for updating the inode. */
to_reserve = btrfs_calc_trans_metadata_size(fs_info, nr_extents + 1); to_reserve = btrfs_calc_trans_metadata_size(fs_info, nr_extents + 1);
to_reserve += calc_csum_metadata_size(BTRFS_I(inode), num_bytes, 1); to_reserve += calc_csum_metadata_size(inode, num_bytes, 1);
csum_bytes = BTRFS_I(inode)->csum_bytes; csum_bytes = inode->csum_bytes;
spin_unlock(&BTRFS_I(inode)->lock); spin_unlock(&inode->lock);
if (test_bit(BTRFS_FS_QUOTA_ENABLED, &fs_info->flags)) { if (test_bit(BTRFS_FS_QUOTA_ENABLED, &fs_info->flags)) {
ret = btrfs_qgroup_reserve_meta(root, ret = btrfs_qgroup_reserve_meta(root,
...@@ -5989,38 +5988,38 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -5989,38 +5988,38 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
goto out_fail; goto out_fail;
} }
spin_lock(&BTRFS_I(inode)->lock); spin_lock(&inode->lock);
if (test_and_set_bit(BTRFS_INODE_DELALLOC_META_RESERVED, if (test_and_set_bit(BTRFS_INODE_DELALLOC_META_RESERVED,
&BTRFS_I(inode)->runtime_flags)) { &inode->runtime_flags)) {
to_reserve -= btrfs_calc_trans_metadata_size(fs_info, 1); to_reserve -= btrfs_calc_trans_metadata_size(fs_info, 1);
release_extra = true; release_extra = true;
} }
BTRFS_I(inode)->reserved_extents += nr_extents; inode->reserved_extents += nr_extents;
spin_unlock(&BTRFS_I(inode)->lock); spin_unlock(&inode->lock);
if (delalloc_lock) if (delalloc_lock)
mutex_unlock(&BTRFS_I(inode)->delalloc_mutex); mutex_unlock(&inode->delalloc_mutex);
if (to_reserve) if (to_reserve)
trace_btrfs_space_reservation(fs_info, "delalloc", trace_btrfs_space_reservation(fs_info, "delalloc",
btrfs_ino(BTRFS_I(inode)), to_reserve, 1); btrfs_ino(inode), to_reserve, 1);
if (release_extra) if (release_extra)
btrfs_block_rsv_release(fs_info, block_rsv, btrfs_block_rsv_release(fs_info, block_rsv,
btrfs_calc_trans_metadata_size(fs_info, 1)); btrfs_calc_trans_metadata_size(fs_info, 1));
return 0; return 0;
out_fail: out_fail:
spin_lock(&BTRFS_I(inode)->lock); spin_lock(&inode->lock);
dropped = drop_outstanding_extent(BTRFS_I(inode), num_bytes); dropped = drop_outstanding_extent(inode, num_bytes);
/* /*
* If the inodes csum_bytes is the same as the original * If the inodes csum_bytes is the same as the original
* csum_bytes then we know we haven't raced with any free()ers * csum_bytes then we know we haven't raced with any free()ers
* so we can just reduce our inodes csum bytes and carry on. * so we can just reduce our inodes csum bytes and carry on.
*/ */
if (BTRFS_I(inode)->csum_bytes == csum_bytes) { if (inode->csum_bytes == csum_bytes) {
calc_csum_metadata_size(BTRFS_I(inode), num_bytes, 0); calc_csum_metadata_size(inode, num_bytes, 0);
} else { } else {
u64 orig_csum_bytes = BTRFS_I(inode)->csum_bytes; u64 orig_csum_bytes = inode->csum_bytes;
u64 bytes; u64 bytes;
/* /*
...@@ -6031,9 +6030,9 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -6031,9 +6030,9 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
* number of bytes that were freed while we were trying our * number of bytes that were freed while we were trying our
* reservation. * reservation.
*/ */
bytes = csum_bytes - BTRFS_I(inode)->csum_bytes; bytes = csum_bytes - inode->csum_bytes;
BTRFS_I(inode)->csum_bytes = csum_bytes; inode->csum_bytes = csum_bytes;
to_free = calc_csum_metadata_size(BTRFS_I(inode), bytes, 0); to_free = calc_csum_metadata_size(inode, bytes, 0);
/* /*
...@@ -6041,9 +6040,9 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -6041,9 +6040,9 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
* been making this reservation and our ->csum_bytes were not * been making this reservation and our ->csum_bytes were not
* artificially inflated. * artificially inflated.
*/ */
BTRFS_I(inode)->csum_bytes = csum_bytes - num_bytes; inode->csum_bytes = csum_bytes - num_bytes;
bytes = csum_bytes - orig_csum_bytes; bytes = csum_bytes - orig_csum_bytes;
bytes = calc_csum_metadata_size(BTRFS_I(inode), bytes, 0); bytes = calc_csum_metadata_size(inode, bytes, 0);
/* /*
* Now reset ->csum_bytes to what it should be. If bytes is * Now reset ->csum_bytes to what it should be. If bytes is
...@@ -6053,23 +6052,23 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -6053,23 +6052,23 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
* need to do anything, the other free-ers did the correct * need to do anything, the other free-ers did the correct
* thing. * thing.
*/ */
BTRFS_I(inode)->csum_bytes = orig_csum_bytes - num_bytes; inode->csum_bytes = orig_csum_bytes - num_bytes;
if (bytes > to_free) if (bytes > to_free)
to_free = bytes - to_free; to_free = bytes - to_free;
else else
to_free = 0; to_free = 0;
} }
spin_unlock(&BTRFS_I(inode)->lock); spin_unlock(&inode->lock);
if (dropped) if (dropped)
to_free += btrfs_calc_trans_metadata_size(fs_info, dropped); to_free += btrfs_calc_trans_metadata_size(fs_info, dropped);
if (to_free) { if (to_free) {
btrfs_block_rsv_release(fs_info, block_rsv, to_free); btrfs_block_rsv_release(fs_info, block_rsv, to_free);
trace_btrfs_space_reservation(fs_info, "delalloc", trace_btrfs_space_reservation(fs_info, "delalloc",
btrfs_ino(BTRFS_I(inode)), to_free, 0); btrfs_ino(inode), to_free, 0);
} }
if (delalloc_lock) if (delalloc_lock)
mutex_unlock(&BTRFS_I(inode)->delalloc_mutex); mutex_unlock(&inode->delalloc_mutex);
return ret; return ret;
} }
...@@ -6137,7 +6136,7 @@ int btrfs_delalloc_reserve_space(struct inode *inode, u64 start, u64 len) ...@@ -6137,7 +6136,7 @@ int btrfs_delalloc_reserve_space(struct inode *inode, u64 start, u64 len)
ret = btrfs_check_data_free_space(inode, start, len); ret = btrfs_check_data_free_space(inode, start, len);
if (ret < 0) if (ret < 0)
return ret; return ret;
ret = btrfs_delalloc_reserve_metadata(inode, len); ret = btrfs_delalloc_reserve_metadata(BTRFS_I(inode), len);
if (ret < 0) if (ret < 0)
btrfs_free_reserved_data_space(inode, start, len); btrfs_free_reserved_data_space(inode, start, len);
return ret; return ret;
......
...@@ -1599,7 +1599,8 @@ static noinline ssize_t __btrfs_buffered_write(struct file *file, ...@@ -1599,7 +1599,8 @@ static noinline ssize_t __btrfs_buffered_write(struct file *file,
} }
} }
ret = btrfs_delalloc_reserve_metadata(inode, reserve_bytes); ret = btrfs_delalloc_reserve_metadata(BTRFS_I(inode),
reserve_bytes);
if (ret) { if (ret) {
if (!only_release_metadata) if (!only_release_metadata)
btrfs_free_reserved_data_space(inode, pos, btrfs_free_reserved_data_space(inode, pos,
......
...@@ -3203,7 +3203,8 @@ static int relocate_file_extent_cluster(struct inode *inode, ...@@ -3203,7 +3203,8 @@ static int relocate_file_extent_cluster(struct inode *inode,
index = (cluster->start - offset) >> PAGE_SHIFT; index = (cluster->start - offset) >> PAGE_SHIFT;
last_index = (cluster->end - offset) >> PAGE_SHIFT; last_index = (cluster->end - offset) >> PAGE_SHIFT;
while (index <= last_index) { while (index <= last_index) {
ret = btrfs_delalloc_reserve_metadata(inode, PAGE_SIZE); ret = btrfs_delalloc_reserve_metadata(BTRFS_I(inode),
PAGE_SIZE);
if (ret) if (ret)
goto out; goto out;
......
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