aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fs/btrfs/inode.c20
1 files changed, 9 insertions, 11 deletions
diff --git a/fs/btrfs/inode.c b/fs/btrfs/inode.c
index 4d0aec0cf5d8..40d49da5e846 100644
--- a/fs/btrfs/inode.c
+++ b/fs/btrfs/inode.c
@@ -6708,12 +6708,9 @@ static int btrfs_get_blocks_direct(struct inode *inode, sector_t iblock,
6708 int unlock_bits = EXTENT_LOCKED; 6708 int unlock_bits = EXTENT_LOCKED;
6709 int ret = 0; 6709 int ret = 0;
6710 6710
6711 if (create) { 6711 if (create)
6712 spin_lock(&BTRFS_I(inode)->lock);
6713 BTRFS_I(inode)->outstanding_extents++;
6714 spin_unlock(&BTRFS_I(inode)->lock);
6715 unlock_bits |= EXTENT_DELALLOC | EXTENT_DIRTY; 6712 unlock_bits |= EXTENT_DELALLOC | EXTENT_DIRTY;
6716 } else 6713 else
6717 len = min_t(u64, len, root->sectorsize); 6714 len = min_t(u64, len, root->sectorsize);
6718 6715
6719 lockstart = start; 6716 lockstart = start;
@@ -6855,6 +6852,10 @@ unlock:
6855 if (start + len > i_size_read(inode)) 6852 if (start + len > i_size_read(inode))
6856 i_size_write(inode, start + len); 6853 i_size_write(inode, start + len);
6857 6854
6855 spin_lock(&BTRFS_I(inode)->lock);
6856 BTRFS_I(inode)->outstanding_extents++;
6857 spin_unlock(&BTRFS_I(inode)->lock);
6858
6858 ret = set_extent_bit(&BTRFS_I(inode)->io_tree, lockstart, 6859 ret = set_extent_bit(&BTRFS_I(inode)->io_tree, lockstart,
6859 lockstart + len - 1, EXTENT_DELALLOC, NULL, 6860 lockstart + len - 1, EXTENT_DELALLOC, NULL,
6860 &cached_state, GFP_NOFS); 6861 &cached_state, GFP_NOFS);
@@ -7362,14 +7363,11 @@ static ssize_t btrfs_direct_IO(int rw, struct kiocb *iocb,
7362 if (rw & WRITE) { 7363 if (rw & WRITE) {
7363 if (ret < 0 && ret != -EIOCBQUEUED) 7364 if (ret < 0 && ret != -EIOCBQUEUED)
7364 btrfs_delalloc_release_space(inode, count); 7365 btrfs_delalloc_release_space(inode, count);
7365 else if (ret > 0 && (size_t)ret < count) { 7366 else if (ret >= 0 && (size_t)ret < count)
7366 spin_lock(&BTRFS_I(inode)->lock);
7367 BTRFS_I(inode)->outstanding_extents++;
7368 spin_unlock(&BTRFS_I(inode)->lock);
7369 btrfs_delalloc_release_space(inode, 7367 btrfs_delalloc_release_space(inode,
7370 count - (size_t)ret); 7368 count - (size_t)ret);
7371 } 7369 else
7372 btrfs_delalloc_release_metadata(inode, 0); 7370 btrfs_delalloc_release_metadata(inode, 0);
7373 } 7371 }
7374out: 7372out:
7375 if (wakeup) 7373 if (wakeup)