diff options
-rw-r--r-- | fs/btrfs/btrfs_inode.h | 2 | ||||
-rw-r--r-- | fs/btrfs/ctree.h | 19 | ||||
-rw-r--r-- | fs/btrfs/extent-tree.c | 361 | ||||
-rw-r--r-- | fs/btrfs/extent_io.c | 63 | ||||
-rw-r--r-- | fs/btrfs/extent_io.h | 8 | ||||
-rw-r--r-- | fs/btrfs/file.c | 27 | ||||
-rw-r--r-- | fs/btrfs/inode.c | 131 | ||||
-rw-r--r-- | fs/btrfs/ioctl.c | 29 | ||||
-rw-r--r-- | fs/btrfs/ordered-data.c | 7 |
9 files changed, 232 insertions, 415 deletions
diff --git a/fs/btrfs/btrfs_inode.h b/fs/btrfs/btrfs_inode.h index 7a4dee199832..40510d9351f5 100644 --- a/fs/btrfs/btrfs_inode.h +++ b/fs/btrfs/btrfs_inode.h | |||
@@ -137,8 +137,8 @@ struct btrfs_inode { | |||
137 | * of extent items we've reserved metadata for. | 137 | * of extent items we've reserved metadata for. |
138 | */ | 138 | */ |
139 | spinlock_t accounting_lock; | 139 | spinlock_t accounting_lock; |
140 | atomic_t outstanding_extents; | ||
140 | int reserved_extents; | 141 | int reserved_extents; |
141 | int outstanding_extents; | ||
142 | 142 | ||
143 | /* | 143 | /* |
144 | * ordered_data_close is set by truncate when a file that used | 144 | * ordered_data_close is set by truncate when a file that used |
diff --git a/fs/btrfs/ctree.h b/fs/btrfs/ctree.h index e0aa9fb563e2..d4744192eada 100644 --- a/fs/btrfs/ctree.h +++ b/fs/btrfs/ctree.h | |||
@@ -2079,19 +2079,8 @@ int btrfs_remove_block_group(struct btrfs_trans_handle *trans, | |||
2079 | u64 btrfs_reduce_alloc_profile(struct btrfs_root *root, u64 flags); | 2079 | u64 btrfs_reduce_alloc_profile(struct btrfs_root *root, u64 flags); |
2080 | void btrfs_set_inode_space_info(struct btrfs_root *root, struct inode *ionde); | 2080 | void btrfs_set_inode_space_info(struct btrfs_root *root, struct inode *ionde); |
2081 | void btrfs_clear_space_info_full(struct btrfs_fs_info *info); | 2081 | void btrfs_clear_space_info_full(struct btrfs_fs_info *info); |
2082 | 2082 | int btrfs_check_data_free_space(struct inode *inode, u64 bytes); | |
2083 | int btrfs_unreserve_metadata_for_delalloc(struct btrfs_root *root, | 2083 | void btrfs_free_reserved_data_space(struct inode *inode, u64 bytes); |
2084 | struct inode *inode, int num_items); | ||
2085 | int btrfs_reserve_metadata_for_delalloc(struct btrfs_root *root, | ||
2086 | struct inode *inode, int num_items); | ||
2087 | int btrfs_check_data_free_space(struct btrfs_root *root, struct inode *inode, | ||
2088 | u64 bytes); | ||
2089 | void btrfs_free_reserved_data_space(struct btrfs_root *root, | ||
2090 | struct inode *inode, u64 bytes); | ||
2091 | void btrfs_delalloc_reserve_space(struct btrfs_root *root, struct inode *inode, | ||
2092 | u64 bytes); | ||
2093 | void btrfs_delalloc_free_space(struct btrfs_root *root, struct inode *inode, | ||
2094 | u64 bytes); | ||
2095 | int btrfs_trans_reserve_metadata(struct btrfs_trans_handle *trans, | 2084 | int btrfs_trans_reserve_metadata(struct btrfs_trans_handle *trans, |
2096 | struct btrfs_root *root, | 2085 | struct btrfs_root *root, |
2097 | int num_items, int *retries); | 2086 | int num_items, int *retries); |
@@ -2099,6 +2088,10 @@ void btrfs_trans_release_metadata(struct btrfs_trans_handle *trans, | |||
2099 | struct btrfs_root *root); | 2088 | struct btrfs_root *root); |
2100 | int btrfs_snap_reserve_metadata(struct btrfs_trans_handle *trans, | 2089 | int btrfs_snap_reserve_metadata(struct btrfs_trans_handle *trans, |
2101 | struct btrfs_pending_snapshot *pending); | 2090 | struct btrfs_pending_snapshot *pending); |
2091 | int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes); | ||
2092 | void btrfs_delalloc_release_metadata(struct inode *inode, u64 num_bytes); | ||
2093 | int btrfs_delalloc_reserve_space(struct inode *inode, u64 num_bytes); | ||
2094 | void btrfs_delalloc_release_space(struct inode *inode, u64 num_bytes); | ||
2102 | void btrfs_init_block_rsv(struct btrfs_block_rsv *rsv); | 2095 | void btrfs_init_block_rsv(struct btrfs_block_rsv *rsv); |
2103 | struct btrfs_block_rsv *btrfs_alloc_block_rsv(struct btrfs_root *root); | 2096 | struct btrfs_block_rsv *btrfs_alloc_block_rsv(struct btrfs_root *root); |
2104 | void btrfs_free_block_rsv(struct btrfs_root *root, | 2097 | void btrfs_free_block_rsv(struct btrfs_root *root, |
diff --git a/fs/btrfs/extent-tree.c b/fs/btrfs/extent-tree.c index 657df6e002d3..b1822e752b4a 100644 --- a/fs/btrfs/extent-tree.c +++ b/fs/btrfs/extent-tree.c | |||
@@ -64,12 +64,6 @@ static int find_next_key(struct btrfs_path *path, int level, | |||
64 | struct btrfs_key *key); | 64 | struct btrfs_key *key); |
65 | static void dump_space_info(struct btrfs_space_info *info, u64 bytes, | 65 | static void dump_space_info(struct btrfs_space_info *info, u64 bytes, |
66 | int dump_block_groups); | 66 | int dump_block_groups); |
67 | static int maybe_allocate_chunk(struct btrfs_trans_handle *trans, | ||
68 | struct btrfs_root *root, | ||
69 | struct btrfs_space_info *sinfo, u64 num_bytes); | ||
70 | static int shrink_delalloc(struct btrfs_trans_handle *trans, | ||
71 | struct btrfs_root *root, | ||
72 | struct btrfs_space_info *sinfo, u64 to_reclaim); | ||
73 | 67 | ||
74 | static noinline int | 68 | static noinline int |
75 | block_group_cache_done(struct btrfs_block_group_cache *cache) | 69 | block_group_cache_done(struct btrfs_block_group_cache *cache) |
@@ -2880,189 +2874,14 @@ void btrfs_set_inode_space_info(struct btrfs_root *root, struct inode *inode) | |||
2880 | BTRFS_BLOCK_GROUP_DATA); | 2874 | BTRFS_BLOCK_GROUP_DATA); |
2881 | } | 2875 | } |
2882 | 2876 | ||
2883 | static u64 calculate_bytes_needed(struct btrfs_root *root, int num_items) | ||
2884 | { | ||
2885 | u64 num_bytes; | ||
2886 | int level; | ||
2887 | |||
2888 | level = BTRFS_MAX_LEVEL - 2; | ||
2889 | /* | ||
2890 | * NOTE: these calculations are absolutely the worst possible case. | ||
2891 | * This assumes that _every_ item we insert will require a new leaf, and | ||
2892 | * that the tree has grown to its maximum level size. | ||
2893 | */ | ||
2894 | |||
2895 | /* | ||
2896 | * for every item we insert we could insert both an extent item and a | ||
2897 | * extent ref item. Then for ever item we insert, we will need to cow | ||
2898 | * both the original leaf, plus the leaf to the left and right of it. | ||
2899 | * | ||
2900 | * Unless we are talking about the extent root, then we just want the | ||
2901 | * number of items * 2, since we just need the extent item plus its ref. | ||
2902 | */ | ||
2903 | if (root == root->fs_info->extent_root) | ||
2904 | num_bytes = num_items * 2; | ||
2905 | else | ||
2906 | num_bytes = (num_items + (2 * num_items)) * 3; | ||
2907 | |||
2908 | /* | ||
2909 | * num_bytes is total number of leaves we could need times the leaf | ||
2910 | * size, and then for every leaf we could end up cow'ing 2 nodes per | ||
2911 | * level, down to the leaf level. | ||
2912 | */ | ||
2913 | num_bytes = (num_bytes * root->leafsize) + | ||
2914 | (num_bytes * (level * 2)) * root->nodesize; | ||
2915 | |||
2916 | return num_bytes; | ||
2917 | } | ||
2918 | |||
2919 | /* | ||
2920 | * Unreserve metadata space for delalloc. If we have less reserved credits than | ||
2921 | * we have extents, this function does nothing. | ||
2922 | */ | ||
2923 | int btrfs_unreserve_metadata_for_delalloc(struct btrfs_root *root, | ||
2924 | struct inode *inode, int num_items) | ||
2925 | { | ||
2926 | struct btrfs_fs_info *info = root->fs_info; | ||
2927 | struct btrfs_space_info *meta_sinfo; | ||
2928 | u64 num_bytes; | ||
2929 | u64 alloc_target; | ||
2930 | bool bug = false; | ||
2931 | |||
2932 | /* get the space info for where the metadata will live */ | ||
2933 | alloc_target = btrfs_get_alloc_profile(root, 0); | ||
2934 | meta_sinfo = __find_space_info(info, alloc_target); | ||
2935 | |||
2936 | num_bytes = calculate_bytes_needed(root->fs_info->extent_root, | ||
2937 | num_items); | ||
2938 | |||
2939 | spin_lock(&meta_sinfo->lock); | ||
2940 | spin_lock(&BTRFS_I(inode)->accounting_lock); | ||
2941 | if (BTRFS_I(inode)->reserved_extents <= | ||
2942 | BTRFS_I(inode)->outstanding_extents) { | ||
2943 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
2944 | spin_unlock(&meta_sinfo->lock); | ||
2945 | return 0; | ||
2946 | } | ||
2947 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
2948 | |||
2949 | BTRFS_I(inode)->reserved_extents -= num_items; | ||
2950 | BUG_ON(BTRFS_I(inode)->reserved_extents < 0); | ||
2951 | |||
2952 | if (meta_sinfo->bytes_delalloc < num_bytes) { | ||
2953 | bug = true; | ||
2954 | meta_sinfo->bytes_delalloc = 0; | ||
2955 | } else { | ||
2956 | meta_sinfo->bytes_delalloc -= num_bytes; | ||
2957 | } | ||
2958 | spin_unlock(&meta_sinfo->lock); | ||
2959 | |||
2960 | BUG_ON(bug); | ||
2961 | |||
2962 | return 0; | ||
2963 | } | ||
2964 | |||
2965 | static void check_force_delalloc(struct btrfs_space_info *meta_sinfo) | ||
2966 | { | ||
2967 | u64 thresh; | ||
2968 | |||
2969 | thresh = meta_sinfo->bytes_used + meta_sinfo->bytes_reserved + | ||
2970 | meta_sinfo->bytes_pinned + meta_sinfo->bytes_readonly + | ||
2971 | meta_sinfo->bytes_super + meta_sinfo->bytes_root + | ||
2972 | meta_sinfo->bytes_may_use; | ||
2973 | |||
2974 | thresh = meta_sinfo->total_bytes - thresh; | ||
2975 | thresh *= 80; | ||
2976 | do_div(thresh, 100); | ||
2977 | if (thresh <= meta_sinfo->bytes_delalloc) | ||
2978 | meta_sinfo->force_delalloc = 1; | ||
2979 | else | ||
2980 | meta_sinfo->force_delalloc = 0; | ||
2981 | } | ||
2982 | |||
2983 | /* | ||
2984 | * Reserve metadata space for delalloc. | ||
2985 | */ | ||
2986 | int btrfs_reserve_metadata_for_delalloc(struct btrfs_root *root, | ||
2987 | struct inode *inode, int num_items) | ||
2988 | { | ||
2989 | struct btrfs_fs_info *info = root->fs_info; | ||
2990 | struct btrfs_space_info *meta_sinfo; | ||
2991 | u64 num_bytes; | ||
2992 | u64 used; | ||
2993 | u64 alloc_target; | ||
2994 | int flushed = 0; | ||
2995 | int force_delalloc; | ||
2996 | |||
2997 | /* get the space info for where the metadata will live */ | ||
2998 | alloc_target = btrfs_get_alloc_profile(root, 0); | ||
2999 | meta_sinfo = __find_space_info(info, alloc_target); | ||
3000 | |||
3001 | num_bytes = calculate_bytes_needed(root->fs_info->extent_root, | ||
3002 | num_items); | ||
3003 | again: | ||
3004 | spin_lock(&meta_sinfo->lock); | ||
3005 | |||
3006 | force_delalloc = meta_sinfo->force_delalloc; | ||
3007 | |||
3008 | if (unlikely(!meta_sinfo->bytes_root)) | ||
3009 | meta_sinfo->bytes_root = calculate_bytes_needed(root, 6); | ||
3010 | |||
3011 | if (!flushed) | ||
3012 | meta_sinfo->bytes_delalloc += num_bytes; | ||
3013 | |||
3014 | used = meta_sinfo->bytes_used + meta_sinfo->bytes_reserved + | ||
3015 | meta_sinfo->bytes_pinned + meta_sinfo->bytes_readonly + | ||
3016 | meta_sinfo->bytes_super + meta_sinfo->bytes_root + | ||
3017 | meta_sinfo->bytes_may_use + meta_sinfo->bytes_delalloc; | ||
3018 | |||
3019 | if (used > meta_sinfo->total_bytes) { | ||
3020 | flushed++; | ||
3021 | |||
3022 | if (flushed == 1) { | ||
3023 | if (maybe_allocate_chunk(NULL, root, meta_sinfo, | ||
3024 | num_bytes)) | ||
3025 | goto again; | ||
3026 | flushed++; | ||
3027 | } else { | ||
3028 | spin_unlock(&meta_sinfo->lock); | ||
3029 | } | ||
3030 | |||
3031 | if (flushed == 2) { | ||
3032 | filemap_flush(inode->i_mapping); | ||
3033 | goto again; | ||
3034 | } else if (flushed == 3) { | ||
3035 | shrink_delalloc(NULL, root, meta_sinfo, num_bytes); | ||
3036 | goto again; | ||
3037 | } | ||
3038 | spin_lock(&meta_sinfo->lock); | ||
3039 | meta_sinfo->bytes_delalloc -= num_bytes; | ||
3040 | spin_unlock(&meta_sinfo->lock); | ||
3041 | printk(KERN_ERR "enospc, has %d, reserved %d\n", | ||
3042 | BTRFS_I(inode)->outstanding_extents, | ||
3043 | BTRFS_I(inode)->reserved_extents); | ||
3044 | dump_space_info(meta_sinfo, 0, 0); | ||
3045 | return -ENOSPC; | ||
3046 | } | ||
3047 | |||
3048 | BTRFS_I(inode)->reserved_extents += num_items; | ||
3049 | check_force_delalloc(meta_sinfo); | ||
3050 | spin_unlock(&meta_sinfo->lock); | ||
3051 | |||
3052 | if (!flushed && force_delalloc) | ||
3053 | filemap_flush(inode->i_mapping); | ||
3054 | |||
3055 | return 0; | ||
3056 | } | ||
3057 | |||
3058 | /* | 2877 | /* |
3059 | * This will check the space that the inode allocates from to make sure we have | 2878 | * This will check the space that the inode allocates from to make sure we have |
3060 | * enough space for bytes. | 2879 | * enough space for bytes. |
3061 | */ | 2880 | */ |
3062 | int btrfs_check_data_free_space(struct btrfs_root *root, struct inode *inode, | 2881 | int btrfs_check_data_free_space(struct inode *inode, u64 bytes) |
3063 | u64 bytes) | ||
3064 | { | 2882 | { |
3065 | struct btrfs_space_info *data_sinfo; | 2883 | struct btrfs_space_info *data_sinfo; |
2884 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
3066 | u64 used; | 2885 | u64 used; |
3067 | int ret = 0, committed = 0; | 2886 | int ret = 0, committed = 0; |
3068 | 2887 | ||
@@ -3147,12 +2966,13 @@ alloc: | |||
3147 | } | 2966 | } |
3148 | 2967 | ||
3149 | /* | 2968 | /* |
3150 | * if there was an error for whatever reason after calling | 2969 | * called when we are clearing an delalloc extent from the |
3151 | * btrfs_check_data_free_space, call this so we can cleanup the counters. | 2970 | * inode's io_tree or there was an error for whatever reason |
2971 | * after calling btrfs_check_data_free_space | ||
3152 | */ | 2972 | */ |
3153 | void btrfs_free_reserved_data_space(struct btrfs_root *root, | 2973 | void btrfs_free_reserved_data_space(struct inode *inode, u64 bytes) |
3154 | struct inode *inode, u64 bytes) | ||
3155 | { | 2974 | { |
2975 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
3156 | struct btrfs_space_info *data_sinfo; | 2976 | struct btrfs_space_info *data_sinfo; |
3157 | 2977 | ||
3158 | /* make sure bytes are sectorsize aligned */ | 2978 | /* make sure bytes are sectorsize aligned */ |
@@ -3165,48 +2985,6 @@ void btrfs_free_reserved_data_space(struct btrfs_root *root, | |||
3165 | spin_unlock(&data_sinfo->lock); | 2985 | spin_unlock(&data_sinfo->lock); |
3166 | } | 2986 | } |
3167 | 2987 | ||
3168 | /* called when we are adding a delalloc extent to the inode's io_tree */ | ||
3169 | void btrfs_delalloc_reserve_space(struct btrfs_root *root, struct inode *inode, | ||
3170 | u64 bytes) | ||
3171 | { | ||
3172 | struct btrfs_space_info *data_sinfo; | ||
3173 | |||
3174 | /* get the space info for where this inode will be storing its data */ | ||
3175 | data_sinfo = BTRFS_I(inode)->space_info; | ||
3176 | |||
3177 | /* make sure we have enough space to handle the data first */ | ||
3178 | spin_lock(&data_sinfo->lock); | ||
3179 | data_sinfo->bytes_delalloc += bytes; | ||
3180 | |||
3181 | /* | ||
3182 | * we are adding a delalloc extent without calling | ||
3183 | * btrfs_check_data_free_space first. This happens on a weird | ||
3184 | * writepage condition, but shouldn't hurt our accounting | ||
3185 | */ | ||
3186 | if (unlikely(bytes > BTRFS_I(inode)->reserved_bytes)) { | ||
3187 | data_sinfo->bytes_may_use -= BTRFS_I(inode)->reserved_bytes; | ||
3188 | BTRFS_I(inode)->reserved_bytes = 0; | ||
3189 | } else { | ||
3190 | data_sinfo->bytes_may_use -= bytes; | ||
3191 | BTRFS_I(inode)->reserved_bytes -= bytes; | ||
3192 | } | ||
3193 | |||
3194 | spin_unlock(&data_sinfo->lock); | ||
3195 | } | ||
3196 | |||
3197 | /* called when we are clearing an delalloc extent from the inode's io_tree */ | ||
3198 | void btrfs_delalloc_free_space(struct btrfs_root *root, struct inode *inode, | ||
3199 | u64 bytes) | ||
3200 | { | ||
3201 | struct btrfs_space_info *info; | ||
3202 | |||
3203 | info = BTRFS_I(inode)->space_info; | ||
3204 | |||
3205 | spin_lock(&info->lock); | ||
3206 | info->bytes_delalloc -= bytes; | ||
3207 | spin_unlock(&info->lock); | ||
3208 | } | ||
3209 | |||
3210 | static void force_metadata_allocation(struct btrfs_fs_info *info) | 2988 | static void force_metadata_allocation(struct btrfs_fs_info *info) |
3211 | { | 2989 | { |
3212 | struct list_head *head = &info->space_info; | 2990 | struct list_head *head = &info->space_info; |
@@ -3331,18 +3109,19 @@ static int maybe_allocate_chunk(struct btrfs_trans_handle *trans, | |||
3331 | * shrink metadata reservation for delalloc | 3109 | * shrink metadata reservation for delalloc |
3332 | */ | 3110 | */ |
3333 | static int shrink_delalloc(struct btrfs_trans_handle *trans, | 3111 | static int shrink_delalloc(struct btrfs_trans_handle *trans, |
3334 | struct btrfs_root *root, | 3112 | struct btrfs_root *root, u64 to_reclaim) |
3335 | struct btrfs_space_info *sinfo, u64 to_reclaim) | ||
3336 | { | 3113 | { |
3114 | struct btrfs_block_rsv *block_rsv; | ||
3337 | u64 reserved; | 3115 | u64 reserved; |
3338 | u64 max_reclaim; | 3116 | u64 max_reclaim; |
3339 | u64 reclaimed = 0; | 3117 | u64 reclaimed = 0; |
3340 | int pause = 1; | 3118 | int pause = 1; |
3341 | int ret; | 3119 | int ret; |
3342 | 3120 | ||
3343 | spin_lock(&sinfo->lock); | 3121 | block_rsv = &root->fs_info->delalloc_block_rsv; |
3344 | reserved = sinfo->bytes_delalloc; | 3122 | spin_lock(&block_rsv->lock); |
3345 | spin_unlock(&sinfo->lock); | 3123 | reserved = block_rsv->reserved; |
3124 | spin_unlock(&block_rsv->lock); | ||
3346 | 3125 | ||
3347 | if (reserved == 0) | 3126 | if (reserved == 0) |
3348 | return 0; | 3127 | return 0; |
@@ -3361,11 +3140,11 @@ static int shrink_delalloc(struct btrfs_trans_handle *trans, | |||
3361 | pause = 1; | 3140 | pause = 1; |
3362 | } | 3141 | } |
3363 | 3142 | ||
3364 | spin_lock(&sinfo->lock); | 3143 | spin_lock(&block_rsv->lock); |
3365 | if (reserved > sinfo->bytes_delalloc) | 3144 | if (reserved > block_rsv->reserved) |
3366 | reclaimed = reserved - sinfo->bytes_delalloc; | 3145 | reclaimed = reserved - block_rsv->reserved; |
3367 | reserved = sinfo->bytes_delalloc; | 3146 | reserved = block_rsv->reserved; |
3368 | spin_unlock(&sinfo->lock); | 3147 | spin_unlock(&block_rsv->lock); |
3369 | 3148 | ||
3370 | if (reserved == 0 || reclaimed >= max_reclaim) | 3149 | if (reserved == 0 || reclaimed >= max_reclaim) |
3371 | break; | 3150 | break; |
@@ -3394,7 +3173,7 @@ static int should_retry_reserve(struct btrfs_trans_handle *trans, | |||
3394 | if (trans && trans->transaction->in_commit) | 3173 | if (trans && trans->transaction->in_commit) |
3395 | return -ENOSPC; | 3174 | return -ENOSPC; |
3396 | 3175 | ||
3397 | ret = shrink_delalloc(trans, root, space_info, num_bytes); | 3176 | ret = shrink_delalloc(trans, root, num_bytes); |
3398 | if (ret) | 3177 | if (ret) |
3399 | return ret; | 3178 | return ret; |
3400 | 3179 | ||
@@ -3754,6 +3533,108 @@ int btrfs_snap_reserve_metadata(struct btrfs_trans_handle *trans, | |||
3754 | return block_rsv_migrate_bytes(src_rsv, dst_rsv, num_bytes); | 3533 | return block_rsv_migrate_bytes(src_rsv, dst_rsv, num_bytes); |
3755 | } | 3534 | } |
3756 | 3535 | ||
3536 | static u64 calc_csum_metadata_size(struct inode *inode, u64 num_bytes) | ||
3537 | { | ||
3538 | return num_bytes >>= 3; | ||
3539 | } | ||
3540 | |||
3541 | int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) | ||
3542 | { | ||
3543 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
3544 | struct btrfs_block_rsv *block_rsv = &root->fs_info->delalloc_block_rsv; | ||
3545 | u64 to_reserve; | ||
3546 | int nr_extents; | ||
3547 | int retries = 0; | ||
3548 | int ret; | ||
3549 | |||
3550 | if (btrfs_transaction_in_commit(root->fs_info)) | ||
3551 | schedule_timeout(1); | ||
3552 | |||
3553 | num_bytes = ALIGN(num_bytes, root->sectorsize); | ||
3554 | again: | ||
3555 | spin_lock(&BTRFS_I(inode)->accounting_lock); | ||
3556 | nr_extents = atomic_read(&BTRFS_I(inode)->outstanding_extents) + 1; | ||
3557 | if (nr_extents > BTRFS_I(inode)->reserved_extents) { | ||
3558 | nr_extents -= BTRFS_I(inode)->reserved_extents; | ||
3559 | to_reserve = calc_trans_metadata_size(root, nr_extents); | ||
3560 | } else { | ||
3561 | nr_extents = 0; | ||
3562 | to_reserve = 0; | ||
3563 | } | ||
3564 | |||
3565 | to_reserve += calc_csum_metadata_size(inode, num_bytes); | ||
3566 | ret = reserve_metadata_bytes(block_rsv, to_reserve); | ||
3567 | if (ret) { | ||
3568 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
3569 | ret = should_retry_reserve(NULL, root, block_rsv, to_reserve, | ||
3570 | &retries); | ||
3571 | if (ret > 0) | ||
3572 | goto again; | ||
3573 | return ret; | ||
3574 | } | ||
3575 | |||
3576 | BTRFS_I(inode)->reserved_extents += nr_extents; | ||
3577 | atomic_inc(&BTRFS_I(inode)->outstanding_extents); | ||
3578 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
3579 | |||
3580 | block_rsv_add_bytes(block_rsv, to_reserve, 1); | ||
3581 | |||
3582 | if (block_rsv->size > 512 * 1024 * 1024) | ||
3583 | shrink_delalloc(NULL, root, to_reserve); | ||
3584 | |||
3585 | return 0; | ||
3586 | } | ||
3587 | |||
3588 | void btrfs_delalloc_release_metadata(struct inode *inode, u64 num_bytes) | ||
3589 | { | ||
3590 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
3591 | u64 to_free; | ||
3592 | int nr_extents; | ||
3593 | |||
3594 | num_bytes = ALIGN(num_bytes, root->sectorsize); | ||
3595 | atomic_dec(&BTRFS_I(inode)->outstanding_extents); | ||
3596 | |||
3597 | spin_lock(&BTRFS_I(inode)->accounting_lock); | ||
3598 | nr_extents = atomic_read(&BTRFS_I(inode)->outstanding_extents); | ||
3599 | if (nr_extents < BTRFS_I(inode)->reserved_extents) { | ||
3600 | nr_extents = BTRFS_I(inode)->reserved_extents - nr_extents; | ||
3601 | BTRFS_I(inode)->reserved_extents -= nr_extents; | ||
3602 | } else { | ||
3603 | nr_extents = 0; | ||
3604 | } | ||
3605 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
3606 | |||
3607 | to_free = calc_csum_metadata_size(inode, num_bytes); | ||
3608 | if (nr_extents > 0) | ||
3609 | to_free += calc_trans_metadata_size(root, nr_extents); | ||
3610 | |||
3611 | btrfs_block_rsv_release(root, &root->fs_info->delalloc_block_rsv, | ||
3612 | to_free); | ||
3613 | } | ||
3614 | |||
3615 | int btrfs_delalloc_reserve_space(struct inode *inode, u64 num_bytes) | ||
3616 | { | ||
3617 | int ret; | ||
3618 | |||
3619 | ret = btrfs_check_data_free_space(inode, num_bytes); | ||
3620 | if (ret) | ||
3621 | return ret; | ||
3622 | |||
3623 | ret = btrfs_delalloc_reserve_metadata(inode, num_bytes); | ||
3624 | if (ret) { | ||
3625 | btrfs_free_reserved_data_space(inode, num_bytes); | ||
3626 | return ret; | ||
3627 | } | ||
3628 | |||
3629 | return 0; | ||
3630 | } | ||
3631 | |||
3632 | void btrfs_delalloc_release_space(struct inode *inode, u64 num_bytes) | ||
3633 | { | ||
3634 | btrfs_delalloc_release_metadata(inode, num_bytes); | ||
3635 | btrfs_free_reserved_data_space(inode, num_bytes); | ||
3636 | } | ||
3637 | |||
3757 | static int update_block_group(struct btrfs_trans_handle *trans, | 3638 | static int update_block_group(struct btrfs_trans_handle *trans, |
3758 | struct btrfs_root *root, | 3639 | struct btrfs_root *root, |
3759 | u64 bytenr, u64 num_bytes, int alloc) | 3640 | u64 bytenr, u64 num_bytes, int alloc) |
diff --git a/fs/btrfs/extent_io.c b/fs/btrfs/extent_io.c index d2d03684fab2..1a57c17d4029 100644 --- a/fs/btrfs/extent_io.c +++ b/fs/btrfs/extent_io.c | |||
@@ -335,21 +335,18 @@ static int merge_state(struct extent_io_tree *tree, | |||
335 | } | 335 | } |
336 | 336 | ||
337 | static int set_state_cb(struct extent_io_tree *tree, | 337 | static int set_state_cb(struct extent_io_tree *tree, |
338 | struct extent_state *state, | 338 | struct extent_state *state, int *bits) |
339 | unsigned long bits) | ||
340 | { | 339 | { |
341 | if (tree->ops && tree->ops->set_bit_hook) { | 340 | if (tree->ops && tree->ops->set_bit_hook) { |
342 | return tree->ops->set_bit_hook(tree->mapping->host, | 341 | return tree->ops->set_bit_hook(tree->mapping->host, |
343 | state->start, state->end, | 342 | state, bits); |
344 | state->state, bits); | ||
345 | } | 343 | } |
346 | 344 | ||
347 | return 0; | 345 | return 0; |
348 | } | 346 | } |
349 | 347 | ||
350 | static void clear_state_cb(struct extent_io_tree *tree, | 348 | static void clear_state_cb(struct extent_io_tree *tree, |
351 | struct extent_state *state, | 349 | struct extent_state *state, int *bits) |
352 | unsigned long bits) | ||
353 | { | 350 | { |
354 | if (tree->ops && tree->ops->clear_bit_hook) | 351 | if (tree->ops && tree->ops->clear_bit_hook) |
355 | tree->ops->clear_bit_hook(tree->mapping->host, state, bits); | 352 | tree->ops->clear_bit_hook(tree->mapping->host, state, bits); |
@@ -367,9 +364,10 @@ static void clear_state_cb(struct extent_io_tree *tree, | |||
367 | */ | 364 | */ |
368 | static int insert_state(struct extent_io_tree *tree, | 365 | static int insert_state(struct extent_io_tree *tree, |
369 | struct extent_state *state, u64 start, u64 end, | 366 | struct extent_state *state, u64 start, u64 end, |
370 | int bits) | 367 | int *bits) |
371 | { | 368 | { |
372 | struct rb_node *node; | 369 | struct rb_node *node; |
370 | int bits_to_set = *bits & ~EXTENT_CTLBITS; | ||
373 | int ret; | 371 | int ret; |
374 | 372 | ||
375 | if (end < start) { | 373 | if (end < start) { |
@@ -384,9 +382,9 @@ static int insert_state(struct extent_io_tree *tree, | |||
384 | if (ret) | 382 | if (ret) |
385 | return ret; | 383 | return ret; |
386 | 384 | ||
387 | if (bits & EXTENT_DIRTY) | 385 | if (bits_to_set & EXTENT_DIRTY) |
388 | tree->dirty_bytes += end - start + 1; | 386 | tree->dirty_bytes += end - start + 1; |
389 | state->state |= bits; | 387 | state->state |= bits_to_set; |
390 | node = tree_insert(&tree->state, end, &state->rb_node); | 388 | node = tree_insert(&tree->state, end, &state->rb_node); |
391 | if (node) { | 389 | if (node) { |
392 | struct extent_state *found; | 390 | struct extent_state *found; |
@@ -456,13 +454,13 @@ static int split_state(struct extent_io_tree *tree, struct extent_state *orig, | |||
456 | * struct is freed and removed from the tree | 454 | * struct is freed and removed from the tree |
457 | */ | 455 | */ |
458 | static int clear_state_bit(struct extent_io_tree *tree, | 456 | static int clear_state_bit(struct extent_io_tree *tree, |
459 | struct extent_state *state, int bits, int wake, | 457 | struct extent_state *state, |
460 | int delete) | 458 | int *bits, int wake) |
461 | { | 459 | { |
462 | int bits_to_clear = bits & ~EXTENT_DO_ACCOUNTING; | 460 | int bits_to_clear = *bits & ~EXTENT_CTLBITS; |
463 | int ret = state->state & bits_to_clear; | 461 | int ret = state->state & bits_to_clear; |
464 | 462 | ||
465 | if ((bits & EXTENT_DIRTY) && (state->state & EXTENT_DIRTY)) { | 463 | if ((bits_to_clear & EXTENT_DIRTY) && (state->state & EXTENT_DIRTY)) { |
466 | u64 range = state->end - state->start + 1; | 464 | u64 range = state->end - state->start + 1; |
467 | WARN_ON(range > tree->dirty_bytes); | 465 | WARN_ON(range > tree->dirty_bytes); |
468 | tree->dirty_bytes -= range; | 466 | tree->dirty_bytes -= range; |
@@ -471,9 +469,8 @@ static int clear_state_bit(struct extent_io_tree *tree, | |||
471 | state->state &= ~bits_to_clear; | 469 | state->state &= ~bits_to_clear; |
472 | if (wake) | 470 | if (wake) |
473 | wake_up(&state->wq); | 471 | wake_up(&state->wq); |
474 | if (delete || state->state == 0) { | 472 | if (state->state == 0) { |
475 | if (state->tree) { | 473 | if (state->tree) { |
476 | clear_state_cb(tree, state, state->state); | ||
477 | rb_erase(&state->rb_node, &tree->state); | 474 | rb_erase(&state->rb_node, &tree->state); |
478 | state->tree = NULL; | 475 | state->tree = NULL; |
479 | free_extent_state(state); | 476 | free_extent_state(state); |
@@ -514,6 +511,10 @@ int clear_extent_bit(struct extent_io_tree *tree, u64 start, u64 end, | |||
514 | int set = 0; | 511 | int set = 0; |
515 | int clear = 0; | 512 | int clear = 0; |
516 | 513 | ||
514 | if (delete) | ||
515 | bits |= ~EXTENT_CTLBITS; | ||
516 | bits |= EXTENT_FIRST_DELALLOC; | ||
517 | |||
517 | if (bits & (EXTENT_IOBITS | EXTENT_BOUNDARY)) | 518 | if (bits & (EXTENT_IOBITS | EXTENT_BOUNDARY)) |
518 | clear = 1; | 519 | clear = 1; |
519 | again: | 520 | again: |
@@ -580,8 +581,7 @@ hit_next: | |||
580 | if (err) | 581 | if (err) |
581 | goto out; | 582 | goto out; |
582 | if (state->end <= end) { | 583 | if (state->end <= end) { |
583 | set |= clear_state_bit(tree, state, bits, wake, | 584 | set |= clear_state_bit(tree, state, &bits, wake); |
584 | delete); | ||
585 | if (last_end == (u64)-1) | 585 | if (last_end == (u64)-1) |
586 | goto out; | 586 | goto out; |
587 | start = last_end + 1; | 587 | start = last_end + 1; |
@@ -602,7 +602,7 @@ hit_next: | |||
602 | if (wake) | 602 | if (wake) |
603 | wake_up(&state->wq); | 603 | wake_up(&state->wq); |
604 | 604 | ||
605 | set |= clear_state_bit(tree, prealloc, bits, wake, delete); | 605 | set |= clear_state_bit(tree, prealloc, &bits, wake); |
606 | 606 | ||
607 | prealloc = NULL; | 607 | prealloc = NULL; |
608 | goto out; | 608 | goto out; |
@@ -613,7 +613,7 @@ hit_next: | |||
613 | else | 613 | else |
614 | next_node = NULL; | 614 | next_node = NULL; |
615 | 615 | ||
616 | set |= clear_state_bit(tree, state, bits, wake, delete); | 616 | set |= clear_state_bit(tree, state, &bits, wake); |
617 | if (last_end == (u64)-1) | 617 | if (last_end == (u64)-1) |
618 | goto out; | 618 | goto out; |
619 | start = last_end + 1; | 619 | start = last_end + 1; |
@@ -706,19 +706,19 @@ out: | |||
706 | 706 | ||
707 | static int set_state_bits(struct extent_io_tree *tree, | 707 | static int set_state_bits(struct extent_io_tree *tree, |
708 | struct extent_state *state, | 708 | struct extent_state *state, |
709 | int bits) | 709 | int *bits) |
710 | { | 710 | { |
711 | int ret; | 711 | int ret; |
712 | int bits_to_set = *bits & ~EXTENT_CTLBITS; | ||
712 | 713 | ||
713 | ret = set_state_cb(tree, state, bits); | 714 | ret = set_state_cb(tree, state, bits); |
714 | if (ret) | 715 | if (ret) |
715 | return ret; | 716 | return ret; |
716 | 717 | if ((bits_to_set & EXTENT_DIRTY) && !(state->state & EXTENT_DIRTY)) { | |
717 | if ((bits & EXTENT_DIRTY) && !(state->state & EXTENT_DIRTY)) { | ||
718 | u64 range = state->end - state->start + 1; | 718 | u64 range = state->end - state->start + 1; |
719 | tree->dirty_bytes += range; | 719 | tree->dirty_bytes += range; |
720 | } | 720 | } |
721 | state->state |= bits; | 721 | state->state |= bits_to_set; |
722 | 722 | ||
723 | return 0; | 723 | return 0; |
724 | } | 724 | } |
@@ -757,6 +757,7 @@ static int set_extent_bit(struct extent_io_tree *tree, u64 start, u64 end, | |||
757 | u64 last_start; | 757 | u64 last_start; |
758 | u64 last_end; | 758 | u64 last_end; |
759 | 759 | ||
760 | bits |= EXTENT_FIRST_DELALLOC; | ||
760 | again: | 761 | again: |
761 | if (!prealloc && (mask & __GFP_WAIT)) { | 762 | if (!prealloc && (mask & __GFP_WAIT)) { |
762 | prealloc = alloc_extent_state(mask); | 763 | prealloc = alloc_extent_state(mask); |
@@ -778,7 +779,7 @@ again: | |||
778 | */ | 779 | */ |
779 | node = tree_search(tree, start); | 780 | node = tree_search(tree, start); |
780 | if (!node) { | 781 | if (!node) { |
781 | err = insert_state(tree, prealloc, start, end, bits); | 782 | err = insert_state(tree, prealloc, start, end, &bits); |
782 | prealloc = NULL; | 783 | prealloc = NULL; |
783 | BUG_ON(err == -EEXIST); | 784 | BUG_ON(err == -EEXIST); |
784 | goto out; | 785 | goto out; |
@@ -802,7 +803,7 @@ hit_next: | |||
802 | goto out; | 803 | goto out; |
803 | } | 804 | } |
804 | 805 | ||
805 | err = set_state_bits(tree, state, bits); | 806 | err = set_state_bits(tree, state, &bits); |
806 | if (err) | 807 | if (err) |
807 | goto out; | 808 | goto out; |
808 | 809 | ||
@@ -852,7 +853,7 @@ hit_next: | |||
852 | if (err) | 853 | if (err) |
853 | goto out; | 854 | goto out; |
854 | if (state->end <= end) { | 855 | if (state->end <= end) { |
855 | err = set_state_bits(tree, state, bits); | 856 | err = set_state_bits(tree, state, &bits); |
856 | if (err) | 857 | if (err) |
857 | goto out; | 858 | goto out; |
858 | cache_state(state, cached_state); | 859 | cache_state(state, cached_state); |
@@ -877,7 +878,7 @@ hit_next: | |||
877 | else | 878 | else |
878 | this_end = last_start - 1; | 879 | this_end = last_start - 1; |
879 | err = insert_state(tree, prealloc, start, this_end, | 880 | err = insert_state(tree, prealloc, start, this_end, |
880 | bits); | 881 | &bits); |
881 | BUG_ON(err == -EEXIST); | 882 | BUG_ON(err == -EEXIST); |
882 | if (err) { | 883 | if (err) { |
883 | prealloc = NULL; | 884 | prealloc = NULL; |
@@ -903,7 +904,7 @@ hit_next: | |||
903 | err = split_state(tree, state, prealloc, end + 1); | 904 | err = split_state(tree, state, prealloc, end + 1); |
904 | BUG_ON(err == -EEXIST); | 905 | BUG_ON(err == -EEXIST); |
905 | 906 | ||
906 | err = set_state_bits(tree, prealloc, bits); | 907 | err = set_state_bits(tree, prealloc, &bits); |
907 | if (err) { | 908 | if (err) { |
908 | prealloc = NULL; | 909 | prealloc = NULL; |
909 | goto out; | 910 | goto out; |
@@ -966,8 +967,7 @@ int clear_extent_dirty(struct extent_io_tree *tree, u64 start, u64 end, | |||
966 | { | 967 | { |
967 | return clear_extent_bit(tree, start, end, | 968 | return clear_extent_bit(tree, start, end, |
968 | EXTENT_DIRTY | EXTENT_DELALLOC | | 969 | EXTENT_DIRTY | EXTENT_DELALLOC | |
969 | EXTENT_DO_ACCOUNTING, 0, 0, | 970 | EXTENT_DO_ACCOUNTING, 0, 0, NULL, mask); |
970 | NULL, mask); | ||
971 | } | 971 | } |
972 | 972 | ||
973 | int set_extent_new(struct extent_io_tree *tree, u64 start, u64 end, | 973 | int set_extent_new(struct extent_io_tree *tree, u64 start, u64 end, |
@@ -1435,9 +1435,6 @@ int extent_clear_unlock_delalloc(struct inode *inode, | |||
1435 | if (op & EXTENT_CLEAR_DELALLOC) | 1435 | if (op & EXTENT_CLEAR_DELALLOC) |
1436 | clear_bits |= EXTENT_DELALLOC; | 1436 | clear_bits |= EXTENT_DELALLOC; |
1437 | 1437 | ||
1438 | if (op & EXTENT_CLEAR_ACCOUNTING) | ||
1439 | clear_bits |= EXTENT_DO_ACCOUNTING; | ||
1440 | |||
1441 | clear_extent_bit(tree, start, end, clear_bits, 1, 0, NULL, GFP_NOFS); | 1438 | clear_extent_bit(tree, start, end, clear_bits, 1, 0, NULL, GFP_NOFS); |
1442 | if (!(op & (EXTENT_CLEAR_UNLOCK_PAGE | EXTENT_CLEAR_DIRTY | | 1439 | if (!(op & (EXTENT_CLEAR_UNLOCK_PAGE | EXTENT_CLEAR_DIRTY | |
1443 | EXTENT_SET_WRITEBACK | EXTENT_END_WRITEBACK | | 1440 | EXTENT_SET_WRITEBACK | EXTENT_END_WRITEBACK | |
diff --git a/fs/btrfs/extent_io.h b/fs/btrfs/extent_io.h index bbab4813646f..86f10dc791d9 100644 --- a/fs/btrfs/extent_io.h +++ b/fs/btrfs/extent_io.h | |||
@@ -16,7 +16,9 @@ | |||
16 | #define EXTENT_BOUNDARY (1 << 9) | 16 | #define EXTENT_BOUNDARY (1 << 9) |
17 | #define EXTENT_NODATASUM (1 << 10) | 17 | #define EXTENT_NODATASUM (1 << 10) |
18 | #define EXTENT_DO_ACCOUNTING (1 << 11) | 18 | #define EXTENT_DO_ACCOUNTING (1 << 11) |
19 | #define EXTENT_FIRST_DELALLOC (1 << 12) | ||
19 | #define EXTENT_IOBITS (EXTENT_LOCKED | EXTENT_WRITEBACK) | 20 | #define EXTENT_IOBITS (EXTENT_LOCKED | EXTENT_WRITEBACK) |
21 | #define EXTENT_CTLBITS (EXTENT_DO_ACCOUNTING | EXTENT_FIRST_DELALLOC) | ||
20 | 22 | ||
21 | /* flags for bio submission */ | 23 | /* flags for bio submission */ |
22 | #define EXTENT_BIO_COMPRESSED 1 | 24 | #define EXTENT_BIO_COMPRESSED 1 |
@@ -69,10 +71,10 @@ struct extent_io_ops { | |||
69 | struct extent_state *state); | 71 | struct extent_state *state); |
70 | int (*writepage_end_io_hook)(struct page *page, u64 start, u64 end, | 72 | int (*writepage_end_io_hook)(struct page *page, u64 start, u64 end, |
71 | struct extent_state *state, int uptodate); | 73 | struct extent_state *state, int uptodate); |
72 | int (*set_bit_hook)(struct inode *inode, u64 start, u64 end, | 74 | int (*set_bit_hook)(struct inode *inode, struct extent_state *state, |
73 | unsigned long old, unsigned long bits); | 75 | int *bits); |
74 | int (*clear_bit_hook)(struct inode *inode, struct extent_state *state, | 76 | int (*clear_bit_hook)(struct inode *inode, struct extent_state *state, |
75 | unsigned long bits); | 77 | int *bits); |
76 | int (*merge_extent_hook)(struct inode *inode, | 78 | int (*merge_extent_hook)(struct inode *inode, |
77 | struct extent_state *new, | 79 | struct extent_state *new, |
78 | struct extent_state *other); | 80 | struct extent_state *other); |
diff --git a/fs/btrfs/file.c b/fs/btrfs/file.c index 41e09e24e295..6d8f817eadb5 100644 --- a/fs/btrfs/file.c +++ b/fs/btrfs/file.c | |||
@@ -852,13 +852,6 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
852 | 852 | ||
853 | vfs_check_frozen(inode->i_sb, SB_FREEZE_WRITE); | 853 | vfs_check_frozen(inode->i_sb, SB_FREEZE_WRITE); |
854 | 854 | ||
855 | /* do the reserve before the mutex lock in case we have to do some | ||
856 | * flushing. We wouldn't deadlock, but this is more polite. | ||
857 | */ | ||
858 | err = btrfs_reserve_metadata_for_delalloc(root, inode, 1); | ||
859 | if (err) | ||
860 | goto out_nolock; | ||
861 | |||
862 | mutex_lock(&inode->i_mutex); | 855 | mutex_lock(&inode->i_mutex); |
863 | 856 | ||
864 | current->backing_dev_info = inode->i_mapping->backing_dev_info; | 857 | current->backing_dev_info = inode->i_mapping->backing_dev_info; |
@@ -921,7 +914,7 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
921 | WARN_ON(num_pages > nrptrs); | 914 | WARN_ON(num_pages > nrptrs); |
922 | memset(pages, 0, sizeof(struct page *) * nrptrs); | 915 | memset(pages, 0, sizeof(struct page *) * nrptrs); |
923 | 916 | ||
924 | ret = btrfs_check_data_free_space(root, inode, write_bytes); | 917 | ret = btrfs_delalloc_reserve_space(inode, write_bytes); |
925 | if (ret) | 918 | if (ret) |
926 | goto out; | 919 | goto out; |
927 | 920 | ||
@@ -929,26 +922,20 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
929 | pos, first_index, last_index, | 922 | pos, first_index, last_index, |
930 | write_bytes); | 923 | write_bytes); |
931 | if (ret) { | 924 | if (ret) { |
932 | btrfs_free_reserved_data_space(root, inode, | 925 | btrfs_delalloc_release_space(inode, write_bytes); |
933 | write_bytes); | ||
934 | goto out; | 926 | goto out; |
935 | } | 927 | } |
936 | 928 | ||
937 | ret = btrfs_copy_from_user(pos, num_pages, | 929 | ret = btrfs_copy_from_user(pos, num_pages, |
938 | write_bytes, pages, buf); | 930 | write_bytes, pages, buf); |
939 | if (ret) { | 931 | if (ret == 0) { |
940 | btrfs_free_reserved_data_space(root, inode, | 932 | dirty_and_release_pages(NULL, root, file, pages, |
941 | write_bytes); | 933 | num_pages, pos, write_bytes); |
942 | btrfs_drop_pages(pages, num_pages); | ||
943 | goto out; | ||
944 | } | 934 | } |
945 | 935 | ||
946 | ret = dirty_and_release_pages(NULL, root, file, pages, | ||
947 | num_pages, pos, write_bytes); | ||
948 | btrfs_drop_pages(pages, num_pages); | 936 | btrfs_drop_pages(pages, num_pages); |
949 | if (ret) { | 937 | if (ret) { |
950 | btrfs_free_reserved_data_space(root, inode, | 938 | btrfs_delalloc_release_space(inode, write_bytes); |
951 | write_bytes); | ||
952 | goto out; | 939 | goto out; |
953 | } | 940 | } |
954 | 941 | ||
@@ -975,9 +962,7 @@ out: | |||
975 | mutex_unlock(&inode->i_mutex); | 962 | mutex_unlock(&inode->i_mutex); |
976 | if (ret) | 963 | if (ret) |
977 | err = ret; | 964 | err = ret; |
978 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
979 | 965 | ||
980 | out_nolock: | ||
981 | kfree(pages); | 966 | kfree(pages); |
982 | if (pinned[0]) | 967 | if (pinned[0]) |
983 | page_cache_release(pinned[0]); | 968 | page_cache_release(pinned[0]); |
diff --git a/fs/btrfs/inode.c b/fs/btrfs/inode.c index c4b0fd12df68..6e54665d37f7 100644 --- a/fs/btrfs/inode.c +++ b/fs/btrfs/inode.c | |||
@@ -252,6 +252,7 @@ static noinline int cow_file_range_inline(struct btrfs_trans_handle *trans, | |||
252 | inline_len, compressed_size, | 252 | inline_len, compressed_size, |
253 | compressed_pages); | 253 | compressed_pages); |
254 | BUG_ON(ret); | 254 | BUG_ON(ret); |
255 | btrfs_delalloc_release_metadata(inode, end + 1 - start); | ||
255 | btrfs_drop_extent_cache(inode, start, aligned_end - 1, 0); | 256 | btrfs_drop_extent_cache(inode, start, aligned_end - 1, 0); |
256 | return 0; | 257 | return 0; |
257 | } | 258 | } |
@@ -414,6 +415,7 @@ again: | |||
414 | trans = btrfs_join_transaction(root, 1); | 415 | trans = btrfs_join_transaction(root, 1); |
415 | BUG_ON(!trans); | 416 | BUG_ON(!trans); |
416 | btrfs_set_trans_block_group(trans, inode); | 417 | btrfs_set_trans_block_group(trans, inode); |
418 | trans->block_rsv = &root->fs_info->delalloc_block_rsv; | ||
417 | 419 | ||
418 | /* lets try to make an inline extent */ | 420 | /* lets try to make an inline extent */ |
419 | if (ret || total_in < (actual_end - start)) { | 421 | if (ret || total_in < (actual_end - start)) { |
@@ -439,7 +441,6 @@ again: | |||
439 | start, end, NULL, | 441 | start, end, NULL, |
440 | EXTENT_CLEAR_UNLOCK_PAGE | EXTENT_CLEAR_DIRTY | | 442 | EXTENT_CLEAR_UNLOCK_PAGE | EXTENT_CLEAR_DIRTY | |
441 | EXTENT_CLEAR_DELALLOC | | 443 | EXTENT_CLEAR_DELALLOC | |
442 | EXTENT_CLEAR_ACCOUNTING | | ||
443 | EXTENT_SET_WRITEBACK | EXTENT_END_WRITEBACK); | 444 | EXTENT_SET_WRITEBACK | EXTENT_END_WRITEBACK); |
444 | 445 | ||
445 | btrfs_end_transaction(trans, root); | 446 | btrfs_end_transaction(trans, root); |
@@ -734,6 +735,7 @@ static noinline int cow_file_range(struct inode *inode, | |||
734 | trans = btrfs_join_transaction(root, 1); | 735 | trans = btrfs_join_transaction(root, 1); |
735 | BUG_ON(!trans); | 736 | BUG_ON(!trans); |
736 | btrfs_set_trans_block_group(trans, inode); | 737 | btrfs_set_trans_block_group(trans, inode); |
738 | trans->block_rsv = &root->fs_info->delalloc_block_rsv; | ||
737 | 739 | ||
738 | actual_end = min_t(u64, isize, end + 1); | 740 | actual_end = min_t(u64, isize, end + 1); |
739 | 741 | ||
@@ -753,7 +755,6 @@ static noinline int cow_file_range(struct inode *inode, | |||
753 | EXTENT_CLEAR_UNLOCK_PAGE | | 755 | EXTENT_CLEAR_UNLOCK_PAGE | |
754 | EXTENT_CLEAR_UNLOCK | | 756 | EXTENT_CLEAR_UNLOCK | |
755 | EXTENT_CLEAR_DELALLOC | | 757 | EXTENT_CLEAR_DELALLOC | |
756 | EXTENT_CLEAR_ACCOUNTING | | ||
757 | EXTENT_CLEAR_DIRTY | | 758 | EXTENT_CLEAR_DIRTY | |
758 | EXTENT_SET_WRITEBACK | | 759 | EXTENT_SET_WRITEBACK | |
759 | EXTENT_END_WRITEBACK); | 760 | EXTENT_END_WRITEBACK); |
@@ -1226,15 +1227,13 @@ static int run_delalloc_range(struct inode *inode, struct page *locked_page, | |||
1226 | } | 1227 | } |
1227 | 1228 | ||
1228 | static int btrfs_split_extent_hook(struct inode *inode, | 1229 | static int btrfs_split_extent_hook(struct inode *inode, |
1229 | struct extent_state *orig, u64 split) | 1230 | struct extent_state *orig, u64 split) |
1230 | { | 1231 | { |
1232 | /* not delalloc, ignore it */ | ||
1231 | if (!(orig->state & EXTENT_DELALLOC)) | 1233 | if (!(orig->state & EXTENT_DELALLOC)) |
1232 | return 0; | 1234 | return 0; |
1233 | 1235 | ||
1234 | spin_lock(&BTRFS_I(inode)->accounting_lock); | 1236 | atomic_inc(&BTRFS_I(inode)->outstanding_extents); |
1235 | BTRFS_I(inode)->outstanding_extents++; | ||
1236 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
1237 | |||
1238 | return 0; | 1237 | return 0; |
1239 | } | 1238 | } |
1240 | 1239 | ||
@@ -1252,10 +1251,7 @@ static int btrfs_merge_extent_hook(struct inode *inode, | |||
1252 | if (!(other->state & EXTENT_DELALLOC)) | 1251 | if (!(other->state & EXTENT_DELALLOC)) |
1253 | return 0; | 1252 | return 0; |
1254 | 1253 | ||
1255 | spin_lock(&BTRFS_I(inode)->accounting_lock); | 1254 | atomic_dec(&BTRFS_I(inode)->outstanding_extents); |
1256 | BTRFS_I(inode)->outstanding_extents--; | ||
1257 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
1258 | |||
1259 | return 0; | 1255 | return 0; |
1260 | } | 1256 | } |
1261 | 1257 | ||
@@ -1264,8 +1260,8 @@ static int btrfs_merge_extent_hook(struct inode *inode, | |||
1264 | * bytes in this file, and to maintain the list of inodes that | 1260 | * bytes in this file, and to maintain the list of inodes that |
1265 | * have pending delalloc work to be done. | 1261 | * have pending delalloc work to be done. |
1266 | */ | 1262 | */ |
1267 | static int btrfs_set_bit_hook(struct inode *inode, u64 start, u64 end, | 1263 | static int btrfs_set_bit_hook(struct inode *inode, |
1268 | unsigned long old, unsigned long bits) | 1264 | struct extent_state *state, int *bits) |
1269 | { | 1265 | { |
1270 | 1266 | ||
1271 | /* | 1267 | /* |
@@ -1273,17 +1269,18 @@ static int btrfs_set_bit_hook(struct inode *inode, u64 start, u64 end, | |||
1273 | * but in this case, we are only testeing for the DELALLOC | 1269 | * but in this case, we are only testeing for the DELALLOC |
1274 | * bit, which is only set or cleared with irqs on | 1270 | * bit, which is only set or cleared with irqs on |
1275 | */ | 1271 | */ |
1276 | if (!(old & EXTENT_DELALLOC) && (bits & EXTENT_DELALLOC)) { | 1272 | if (!(state->state & EXTENT_DELALLOC) && (*bits & EXTENT_DELALLOC)) { |
1277 | struct btrfs_root *root = BTRFS_I(inode)->root; | 1273 | struct btrfs_root *root = BTRFS_I(inode)->root; |
1274 | u64 len = state->end + 1 - state->start; | ||
1278 | 1275 | ||
1279 | spin_lock(&BTRFS_I(inode)->accounting_lock); | 1276 | if (*bits & EXTENT_FIRST_DELALLOC) |
1280 | BTRFS_I(inode)->outstanding_extents++; | 1277 | *bits &= ~EXTENT_FIRST_DELALLOC; |
1281 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | 1278 | else |
1282 | btrfs_delalloc_reserve_space(root, inode, end - start + 1); | 1279 | atomic_inc(&BTRFS_I(inode)->outstanding_extents); |
1283 | 1280 | ||
1284 | spin_lock(&root->fs_info->delalloc_lock); | 1281 | spin_lock(&root->fs_info->delalloc_lock); |
1285 | BTRFS_I(inode)->delalloc_bytes += end - start + 1; | 1282 | BTRFS_I(inode)->delalloc_bytes += len; |
1286 | root->fs_info->delalloc_bytes += end - start + 1; | 1283 | root->fs_info->delalloc_bytes += len; |
1287 | if (list_empty(&BTRFS_I(inode)->delalloc_inodes)) { | 1284 | if (list_empty(&BTRFS_I(inode)->delalloc_inodes)) { |
1288 | list_add_tail(&BTRFS_I(inode)->delalloc_inodes, | 1285 | list_add_tail(&BTRFS_I(inode)->delalloc_inodes, |
1289 | &root->fs_info->delalloc_inodes); | 1286 | &root->fs_info->delalloc_inodes); |
@@ -1297,45 +1294,32 @@ static int btrfs_set_bit_hook(struct inode *inode, u64 start, u64 end, | |||
1297 | * extent_io.c clear_bit_hook, see set_bit_hook for why | 1294 | * extent_io.c clear_bit_hook, see set_bit_hook for why |
1298 | */ | 1295 | */ |
1299 | static int btrfs_clear_bit_hook(struct inode *inode, | 1296 | static int btrfs_clear_bit_hook(struct inode *inode, |
1300 | struct extent_state *state, unsigned long bits) | 1297 | struct extent_state *state, int *bits) |
1301 | { | 1298 | { |
1302 | /* | 1299 | /* |
1303 | * set_bit and clear bit hooks normally require _irqsave/restore | 1300 | * set_bit and clear bit hooks normally require _irqsave/restore |
1304 | * but in this case, we are only testeing for the DELALLOC | 1301 | * but in this case, we are only testeing for the DELALLOC |
1305 | * bit, which is only set or cleared with irqs on | 1302 | * bit, which is only set or cleared with irqs on |
1306 | */ | 1303 | */ |
1307 | if ((state->state & EXTENT_DELALLOC) && (bits & EXTENT_DELALLOC)) { | 1304 | if ((state->state & EXTENT_DELALLOC) && (*bits & EXTENT_DELALLOC)) { |
1308 | struct btrfs_root *root = BTRFS_I(inode)->root; | 1305 | struct btrfs_root *root = BTRFS_I(inode)->root; |
1306 | u64 len = state->end + 1 - state->start; | ||
1309 | 1307 | ||
1310 | if (bits & EXTENT_DO_ACCOUNTING) { | 1308 | if (*bits & EXTENT_FIRST_DELALLOC) |
1311 | spin_lock(&BTRFS_I(inode)->accounting_lock); | 1309 | *bits &= ~EXTENT_FIRST_DELALLOC; |
1312 | WARN_ON(!BTRFS_I(inode)->outstanding_extents); | 1310 | else if (!(*bits & EXTENT_DO_ACCOUNTING)) |
1313 | BTRFS_I(inode)->outstanding_extents--; | 1311 | atomic_dec(&BTRFS_I(inode)->outstanding_extents); |
1314 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | 1312 | |
1315 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | 1313 | if (*bits & EXTENT_DO_ACCOUNTING) |
1316 | } | 1314 | btrfs_delalloc_release_metadata(inode, len); |
1315 | |||
1316 | if (root->root_key.objectid != BTRFS_DATA_RELOC_TREE_OBJECTID) | ||
1317 | btrfs_free_reserved_data_space(inode, len); | ||
1317 | 1318 | ||
1318 | spin_lock(&root->fs_info->delalloc_lock); | 1319 | spin_lock(&root->fs_info->delalloc_lock); |
1319 | if (state->end - state->start + 1 > | 1320 | root->fs_info->delalloc_bytes -= len; |
1320 | root->fs_info->delalloc_bytes) { | 1321 | BTRFS_I(inode)->delalloc_bytes -= len; |
1321 | printk(KERN_INFO "btrfs warning: delalloc account " | 1322 | |
1322 | "%llu %llu\n", | ||
1323 | (unsigned long long) | ||
1324 | state->end - state->start + 1, | ||
1325 | (unsigned long long) | ||
1326 | root->fs_info->delalloc_bytes); | ||
1327 | btrfs_delalloc_free_space(root, inode, (u64)-1); | ||
1328 | root->fs_info->delalloc_bytes = 0; | ||
1329 | BTRFS_I(inode)->delalloc_bytes = 0; | ||
1330 | } else { | ||
1331 | btrfs_delalloc_free_space(root, inode, | ||
1332 | state->end - | ||
1333 | state->start + 1); | ||
1334 | root->fs_info->delalloc_bytes -= state->end - | ||
1335 | state->start + 1; | ||
1336 | BTRFS_I(inode)->delalloc_bytes -= state->end - | ||
1337 | state->start + 1; | ||
1338 | } | ||
1339 | if (BTRFS_I(inode)->delalloc_bytes == 0 && | 1323 | if (BTRFS_I(inode)->delalloc_bytes == 0 && |
1340 | !list_empty(&BTRFS_I(inode)->delalloc_inodes)) { | 1324 | !list_empty(&BTRFS_I(inode)->delalloc_inodes)) { |
1341 | list_del_init(&BTRFS_I(inode)->delalloc_inodes); | 1325 | list_del_init(&BTRFS_I(inode)->delalloc_inodes); |
@@ -1520,6 +1504,7 @@ again: | |||
1520 | goto again; | 1504 | goto again; |
1521 | } | 1505 | } |
1522 | 1506 | ||
1507 | BUG(); | ||
1523 | btrfs_set_extent_delalloc(inode, page_start, page_end, &cached_state); | 1508 | btrfs_set_extent_delalloc(inode, page_start, page_end, &cached_state); |
1524 | ClearPageChecked(page); | 1509 | ClearPageChecked(page); |
1525 | out: | 1510 | out: |
@@ -1650,7 +1635,7 @@ static int insert_reserved_file_extent(struct btrfs_trans_handle *trans, | |||
1650 | static int btrfs_finish_ordered_io(struct inode *inode, u64 start, u64 end) | 1635 | static int btrfs_finish_ordered_io(struct inode *inode, u64 start, u64 end) |
1651 | { | 1636 | { |
1652 | struct btrfs_root *root = BTRFS_I(inode)->root; | 1637 | struct btrfs_root *root = BTRFS_I(inode)->root; |
1653 | struct btrfs_trans_handle *trans; | 1638 | struct btrfs_trans_handle *trans = NULL; |
1654 | struct btrfs_ordered_extent *ordered_extent = NULL; | 1639 | struct btrfs_ordered_extent *ordered_extent = NULL; |
1655 | struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree; | 1640 | struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree; |
1656 | struct extent_state *cached_state = NULL; | 1641 | struct extent_state *cached_state = NULL; |
@@ -1668,9 +1653,10 @@ static int btrfs_finish_ordered_io(struct inode *inode, u64 start, u64 end) | |||
1668 | ret = btrfs_ordered_update_i_size(inode, 0, ordered_extent); | 1653 | ret = btrfs_ordered_update_i_size(inode, 0, ordered_extent); |
1669 | if (!ret) { | 1654 | if (!ret) { |
1670 | trans = btrfs_join_transaction(root, 1); | 1655 | trans = btrfs_join_transaction(root, 1); |
1656 | btrfs_set_trans_block_group(trans, inode); | ||
1657 | trans->block_rsv = &root->fs_info->delalloc_block_rsv; | ||
1671 | ret = btrfs_update_inode(trans, root, inode); | 1658 | ret = btrfs_update_inode(trans, root, inode); |
1672 | BUG_ON(ret); | 1659 | BUG_ON(ret); |
1673 | btrfs_end_transaction(trans, root); | ||
1674 | } | 1660 | } |
1675 | goto out; | 1661 | goto out; |
1676 | } | 1662 | } |
@@ -1680,6 +1666,8 @@ static int btrfs_finish_ordered_io(struct inode *inode, u64 start, u64 end) | |||
1680 | 0, &cached_state, GFP_NOFS); | 1666 | 0, &cached_state, GFP_NOFS); |
1681 | 1667 | ||
1682 | trans = btrfs_join_transaction(root, 1); | 1668 | trans = btrfs_join_transaction(root, 1); |
1669 | btrfs_set_trans_block_group(trans, inode); | ||
1670 | trans->block_rsv = &root->fs_info->delalloc_block_rsv; | ||
1683 | 1671 | ||
1684 | if (test_bit(BTRFS_ORDERED_COMPRESSED, &ordered_extent->flags)) | 1672 | if (test_bit(BTRFS_ORDERED_COMPRESSED, &ordered_extent->flags)) |
1685 | compressed = 1; | 1673 | compressed = 1; |
@@ -1711,12 +1699,13 @@ static int btrfs_finish_ordered_io(struct inode *inode, u64 start, u64 end) | |||
1711 | add_pending_csums(trans, inode, ordered_extent->file_offset, | 1699 | add_pending_csums(trans, inode, ordered_extent->file_offset, |
1712 | &ordered_extent->list); | 1700 | &ordered_extent->list); |
1713 | 1701 | ||
1714 | /* this also removes the ordered extent from the tree */ | ||
1715 | btrfs_ordered_update_i_size(inode, 0, ordered_extent); | 1702 | btrfs_ordered_update_i_size(inode, 0, ordered_extent); |
1716 | ret = btrfs_update_inode(trans, root, inode); | 1703 | ret = btrfs_update_inode(trans, root, inode); |
1717 | BUG_ON(ret); | 1704 | BUG_ON(ret); |
1718 | btrfs_end_transaction(trans, root); | ||
1719 | out: | 1705 | out: |
1706 | btrfs_delalloc_release_metadata(inode, ordered_extent->len); | ||
1707 | if (trans) | ||
1708 | btrfs_end_transaction(trans, root); | ||
1720 | /* once for us */ | 1709 | /* once for us */ |
1721 | btrfs_put_ordered_extent(ordered_extent); | 1710 | btrfs_put_ordered_extent(ordered_extent); |
1722 | /* once for the tree */ | 1711 | /* once for the tree */ |
@@ -3219,11 +3208,7 @@ static int btrfs_truncate_page(struct address_space *mapping, loff_t from) | |||
3219 | 3208 | ||
3220 | if ((offset & (blocksize - 1)) == 0) | 3209 | if ((offset & (blocksize - 1)) == 0) |
3221 | goto out; | 3210 | goto out; |
3222 | ret = btrfs_check_data_free_space(root, inode, PAGE_CACHE_SIZE); | 3211 | ret = btrfs_delalloc_reserve_space(inode, PAGE_CACHE_SIZE); |
3223 | if (ret) | ||
3224 | goto out; | ||
3225 | |||
3226 | ret = btrfs_reserve_metadata_for_delalloc(root, inode, 1); | ||
3227 | if (ret) | 3212 | if (ret) |
3228 | goto out; | 3213 | goto out; |
3229 | 3214 | ||
@@ -3231,8 +3216,7 @@ static int btrfs_truncate_page(struct address_space *mapping, loff_t from) | |||
3231 | again: | 3216 | again: |
3232 | page = grab_cache_page(mapping, index); | 3217 | page = grab_cache_page(mapping, index); |
3233 | if (!page) { | 3218 | if (!page) { |
3234 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | 3219 | btrfs_delalloc_release_space(inode, PAGE_CACHE_SIZE); |
3235 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
3236 | goto out; | 3220 | goto out; |
3237 | } | 3221 | } |
3238 | 3222 | ||
@@ -3295,8 +3279,7 @@ again: | |||
3295 | 3279 | ||
3296 | out_unlock: | 3280 | out_unlock: |
3297 | if (ret) | 3281 | if (ret) |
3298 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | 3282 | btrfs_delalloc_release_space(inode, PAGE_CACHE_SIZE); |
3299 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
3300 | unlock_page(page); | 3283 | unlock_page(page); |
3301 | page_cache_release(page); | 3284 | page_cache_release(page); |
3302 | out: | 3285 | out: |
@@ -4878,6 +4861,7 @@ again: | |||
4878 | } | 4861 | } |
4879 | flush_dcache_page(page); | 4862 | flush_dcache_page(page); |
4880 | } else if (create && PageUptodate(page)) { | 4863 | } else if (create && PageUptodate(page)) { |
4864 | WARN_ON(1); | ||
4881 | if (!trans) { | 4865 | if (!trans) { |
4882 | kunmap(page); | 4866 | kunmap(page); |
4883 | free_extent_map(em); | 4867 | free_extent_map(em); |
@@ -5142,7 +5126,7 @@ int btrfs_page_mkwrite(struct vm_area_struct *vma, struct vm_fault *vmf) | |||
5142 | u64 page_start; | 5126 | u64 page_start; |
5143 | u64 page_end; | 5127 | u64 page_end; |
5144 | 5128 | ||
5145 | ret = btrfs_check_data_free_space(root, inode, PAGE_CACHE_SIZE); | 5129 | ret = btrfs_delalloc_reserve_space(inode, PAGE_CACHE_SIZE); |
5146 | if (ret) { | 5130 | if (ret) { |
5147 | if (ret == -ENOMEM) | 5131 | if (ret == -ENOMEM) |
5148 | ret = VM_FAULT_OOM; | 5132 | ret = VM_FAULT_OOM; |
@@ -5151,13 +5135,6 @@ int btrfs_page_mkwrite(struct vm_area_struct *vma, struct vm_fault *vmf) | |||
5151 | goto out; | 5135 | goto out; |
5152 | } | 5136 | } |
5153 | 5137 | ||
5154 | ret = btrfs_reserve_metadata_for_delalloc(root, inode, 1); | ||
5155 | if (ret) { | ||
5156 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | ||
5157 | ret = VM_FAULT_SIGBUS; | ||
5158 | goto out; | ||
5159 | } | ||
5160 | |||
5161 | ret = VM_FAULT_NOPAGE; /* make the VM retry the fault */ | 5138 | ret = VM_FAULT_NOPAGE; /* make the VM retry the fault */ |
5162 | again: | 5139 | again: |
5163 | lock_page(page); | 5140 | lock_page(page); |
@@ -5167,7 +5144,6 @@ again: | |||
5167 | 5144 | ||
5168 | if ((page->mapping != inode->i_mapping) || | 5145 | if ((page->mapping != inode->i_mapping) || |
5169 | (page_start >= size)) { | 5146 | (page_start >= size)) { |
5170 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | ||
5171 | /* page got truncated out from underneath us */ | 5147 | /* page got truncated out from underneath us */ |
5172 | goto out_unlock; | 5148 | goto out_unlock; |
5173 | } | 5149 | } |
@@ -5208,7 +5184,6 @@ again: | |||
5208 | unlock_extent_cached(io_tree, page_start, page_end, | 5184 | unlock_extent_cached(io_tree, page_start, page_end, |
5209 | &cached_state, GFP_NOFS); | 5185 | &cached_state, GFP_NOFS); |
5210 | ret = VM_FAULT_SIGBUS; | 5186 | ret = VM_FAULT_SIGBUS; |
5211 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | ||
5212 | goto out_unlock; | 5187 | goto out_unlock; |
5213 | } | 5188 | } |
5214 | ret = 0; | 5189 | ret = 0; |
@@ -5235,10 +5210,10 @@ again: | |||
5235 | unlock_extent_cached(io_tree, page_start, page_end, &cached_state, GFP_NOFS); | 5210 | unlock_extent_cached(io_tree, page_start, page_end, &cached_state, GFP_NOFS); |
5236 | 5211 | ||
5237 | out_unlock: | 5212 | out_unlock: |
5238 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
5239 | if (!ret) | 5213 | if (!ret) |
5240 | return VM_FAULT_LOCKED; | 5214 | return VM_FAULT_LOCKED; |
5241 | unlock_page(page); | 5215 | unlock_page(page); |
5216 | btrfs_delalloc_release_space(inode, PAGE_CACHE_SIZE); | ||
5242 | out: | 5217 | out: |
5243 | return ret; | 5218 | return ret; |
5244 | } | 5219 | } |
@@ -5383,7 +5358,7 @@ struct inode *btrfs_alloc_inode(struct super_block *sb) | |||
5383 | ei->last_unlink_trans = 0; | 5358 | ei->last_unlink_trans = 0; |
5384 | 5359 | ||
5385 | spin_lock_init(&ei->accounting_lock); | 5360 | spin_lock_init(&ei->accounting_lock); |
5386 | ei->outstanding_extents = 0; | 5361 | atomic_set(&ei->outstanding_extents, 0); |
5387 | ei->reserved_extents = 0; | 5362 | ei->reserved_extents = 0; |
5388 | 5363 | ||
5389 | ei->ordered_data_close = 0; | 5364 | ei->ordered_data_close = 0; |
@@ -5411,6 +5386,8 @@ void btrfs_destroy_inode(struct inode *inode) | |||
5411 | 5386 | ||
5412 | WARN_ON(!list_empty(&inode->i_dentry)); | 5387 | WARN_ON(!list_empty(&inode->i_dentry)); |
5413 | WARN_ON(inode->i_data.nrpages); | 5388 | WARN_ON(inode->i_data.nrpages); |
5389 | WARN_ON(atomic_read(&BTRFS_I(inode)->outstanding_extents)); | ||
5390 | WARN_ON(BTRFS_I(inode)->reserved_extents); | ||
5414 | 5391 | ||
5415 | /* | 5392 | /* |
5416 | * This can happen where we create an inode, but somebody else also | 5393 | * This can happen where we create an inode, but somebody else also |
@@ -5970,8 +5947,7 @@ static long btrfs_fallocate(struct inode *inode, int mode, | |||
5970 | goto out; | 5947 | goto out; |
5971 | } | 5948 | } |
5972 | 5949 | ||
5973 | ret = btrfs_check_data_free_space(BTRFS_I(inode)->root, inode, | 5950 | ret = btrfs_check_data_free_space(inode, alloc_end - alloc_start); |
5974 | alloc_end - alloc_start); | ||
5975 | if (ret) | 5951 | if (ret) |
5976 | goto out; | 5952 | goto out; |
5977 | 5953 | ||
@@ -6037,8 +6013,7 @@ static long btrfs_fallocate(struct inode *inode, int mode, | |||
6037 | unlock_extent_cached(&BTRFS_I(inode)->io_tree, alloc_start, locked_end, | 6013 | unlock_extent_cached(&BTRFS_I(inode)->io_tree, alloc_start, locked_end, |
6038 | &cached_state, GFP_NOFS); | 6014 | &cached_state, GFP_NOFS); |
6039 | 6015 | ||
6040 | btrfs_free_reserved_data_space(BTRFS_I(inode)->root, inode, | 6016 | btrfs_free_reserved_data_space(inode, alloc_end - alloc_start); |
6041 | alloc_end - alloc_start); | ||
6042 | out: | 6017 | out: |
6043 | mutex_unlock(&inode->i_mutex); | 6018 | mutex_unlock(&inode->i_mutex); |
6044 | return ret; | 6019 | return ret; |
diff --git a/fs/btrfs/ioctl.c b/fs/btrfs/ioctl.c index 3066da468c6d..6a706e691377 100644 --- a/fs/btrfs/ioctl.c +++ b/fs/btrfs/ioctl.c | |||
@@ -587,19 +587,9 @@ static int btrfs_defrag_file(struct file *file, | |||
587 | if (range->flags & BTRFS_DEFRAG_RANGE_COMPRESS) | 587 | if (range->flags & BTRFS_DEFRAG_RANGE_COMPRESS) |
588 | BTRFS_I(inode)->force_compress = 1; | 588 | BTRFS_I(inode)->force_compress = 1; |
589 | 589 | ||
590 | ret = btrfs_check_data_free_space(root, inode, PAGE_CACHE_SIZE); | 590 | ret = btrfs_delalloc_reserve_space(inode, PAGE_CACHE_SIZE); |
591 | if (ret) { | 591 | if (ret) |
592 | ret = -ENOSPC; | 592 | goto err_unlock; |
593 | break; | ||
594 | } | ||
595 | |||
596 | ret = btrfs_reserve_metadata_for_delalloc(root, inode, 1); | ||
597 | if (ret) { | ||
598 | btrfs_free_reserved_data_space(root, inode, | ||
599 | PAGE_CACHE_SIZE); | ||
600 | ret = -ENOSPC; | ||
601 | break; | ||
602 | } | ||
603 | again: | 593 | again: |
604 | if (inode->i_size == 0 || | 594 | if (inode->i_size == 0 || |
605 | i > ((inode->i_size - 1) >> PAGE_CACHE_SHIFT)) { | 595 | i > ((inode->i_size - 1) >> PAGE_CACHE_SHIFT)) { |
@@ -608,8 +598,10 @@ again: | |||
608 | } | 598 | } |
609 | 599 | ||
610 | page = grab_cache_page(inode->i_mapping, i); | 600 | page = grab_cache_page(inode->i_mapping, i); |
611 | if (!page) | 601 | if (!page) { |
602 | ret = -ENOMEM; | ||
612 | goto err_reservations; | 603 | goto err_reservations; |
604 | } | ||
613 | 605 | ||
614 | if (!PageUptodate(page)) { | 606 | if (!PageUptodate(page)) { |
615 | btrfs_readpage(NULL, page); | 607 | btrfs_readpage(NULL, page); |
@@ -617,6 +609,7 @@ again: | |||
617 | if (!PageUptodate(page)) { | 609 | if (!PageUptodate(page)) { |
618 | unlock_page(page); | 610 | unlock_page(page); |
619 | page_cache_release(page); | 611 | page_cache_release(page); |
612 | ret = -EIO; | ||
620 | goto err_reservations; | 613 | goto err_reservations; |
621 | } | 614 | } |
622 | } | 615 | } |
@@ -630,8 +623,7 @@ again: | |||
630 | wait_on_page_writeback(page); | 623 | wait_on_page_writeback(page); |
631 | 624 | ||
632 | if (PageDirty(page)) { | 625 | if (PageDirty(page)) { |
633 | btrfs_free_reserved_data_space(root, inode, | 626 | btrfs_delalloc_release_space(inode, PAGE_CACHE_SIZE); |
634 | PAGE_CACHE_SIZE); | ||
635 | goto loop_unlock; | 627 | goto loop_unlock; |
636 | } | 628 | } |
637 | 629 | ||
@@ -669,7 +661,6 @@ loop_unlock: | |||
669 | page_cache_release(page); | 661 | page_cache_release(page); |
670 | mutex_unlock(&inode->i_mutex); | 662 | mutex_unlock(&inode->i_mutex); |
671 | 663 | ||
672 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
673 | balance_dirty_pages_ratelimited_nr(inode->i_mapping, 1); | 664 | balance_dirty_pages_ratelimited_nr(inode->i_mapping, 1); |
674 | i++; | 665 | i++; |
675 | } | 666 | } |
@@ -699,9 +690,9 @@ loop_unlock: | |||
699 | return 0; | 690 | return 0; |
700 | 691 | ||
701 | err_reservations: | 692 | err_reservations: |
693 | btrfs_delalloc_release_space(inode, PAGE_CACHE_SIZE); | ||
694 | err_unlock: | ||
702 | mutex_unlock(&inode->i_mutex); | 695 | mutex_unlock(&inode->i_mutex); |
703 | btrfs_free_reserved_data_space(root, inode, PAGE_CACHE_SIZE); | ||
704 | btrfs_unreserve_metadata_for_delalloc(root, inode, 1); | ||
705 | return ret; | 696 | return ret; |
706 | } | 697 | } |
707 | 698 | ||
diff --git a/fs/btrfs/ordered-data.c b/fs/btrfs/ordered-data.c index a127c0ebb2dc..c9f1020572f2 100644 --- a/fs/btrfs/ordered-data.c +++ b/fs/btrfs/ordered-data.c | |||
@@ -311,13 +311,6 @@ static int __btrfs_remove_ordered_extent(struct inode *inode, | |||
311 | tree->last = NULL; | 311 | tree->last = NULL; |
312 | set_bit(BTRFS_ORDERED_COMPLETE, &entry->flags); | 312 | set_bit(BTRFS_ORDERED_COMPLETE, &entry->flags); |
313 | 313 | ||
314 | spin_lock(&BTRFS_I(inode)->accounting_lock); | ||
315 | WARN_ON(!BTRFS_I(inode)->outstanding_extents); | ||
316 | BTRFS_I(inode)->outstanding_extents--; | ||
317 | spin_unlock(&BTRFS_I(inode)->accounting_lock); | ||
318 | btrfs_unreserve_metadata_for_delalloc(BTRFS_I(inode)->root, | ||
319 | inode, 1); | ||
320 | |||
321 | spin_lock(&root->fs_info->ordered_extent_lock); | 314 | spin_lock(&root->fs_info->ordered_extent_lock); |
322 | list_del_init(&entry->root_extent_list); | 315 | list_del_init(&entry->root_extent_list); |
323 | 316 | ||