diff options
-rw-r--r-- | fs/btrfs/inode.c | 20 |
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 | } |
7374 | out: | 7372 | out: |
7375 | if (wakeup) | 7373 | if (wakeup) |