diff options
author | Chris Mason <chris.mason@oracle.com> | 2007-12-21 16:27:21 -0500 |
---|---|---|
committer | Chris Mason <chris.mason@oracle.com> | 2008-09-25 11:03:58 -0400 |
commit | 1832a6d5ee3b1af61001cadba9e10da9e91af4a4 (patch) | |
tree | 3a6dcb2a186c3623b0355b7e45d1b94ecae5e54d /fs | |
parent | 01f466580502c57001bf80fff709479fdb9e87a5 (diff) |
Btrfs: Implement basic support for -ENOSPC
This is intended to prevent accidentally filling the drive. A determined
user can still make things oops.
It includes some accounting of the current bytes under delayed allocation,
but this will change as things get optimized
Signed-off-by: Chris Mason <chris.mason@oracle.com>
Diffstat (limited to 'fs')
-rw-r--r-- | fs/btrfs/ctree.h | 4 | ||||
-rw-r--r-- | fs/btrfs/disk-io.c | 5 | ||||
-rw-r--r-- | fs/btrfs/extent_map.c | 20 | ||||
-rw-r--r-- | fs/btrfs/extent_map.h | 3 | ||||
-rw-r--r-- | fs/btrfs/file.c | 28 | ||||
-rw-r--r-- | fs/btrfs/inode.c | 161 |
6 files changed, 193 insertions, 28 deletions
diff --git a/fs/btrfs/ctree.h b/fs/btrfs/ctree.h index 2559f5d5d00a..10129cc6656f 100644 --- a/fs/btrfs/ctree.h +++ b/fs/btrfs/ctree.h | |||
@@ -346,6 +346,8 @@ struct btrfs_fs_info { | |||
346 | int closing; | 346 | int closing; |
347 | 347 | ||
348 | u64 total_pinned; | 348 | u64 total_pinned; |
349 | spinlock_t delalloc_lock; | ||
350 | u64 delalloc_bytes; | ||
349 | }; | 351 | }; |
350 | /* | 352 | /* |
351 | * in ram representation of the tree. extent_root is used for all allocations | 353 | * in ram representation of the tree. extent_root is used for all allocations |
@@ -1115,6 +1117,8 @@ int btrfs_csum_truncate(struct btrfs_trans_handle *trans, | |||
1115 | struct btrfs_root *root, struct btrfs_path *path, | 1117 | struct btrfs_root *root, struct btrfs_path *path, |
1116 | u64 isize); | 1118 | u64 isize); |
1117 | /* inode.c */ | 1119 | /* inode.c */ |
1120 | int btrfs_check_free_space(struct btrfs_root *root, u64 num_required, | ||
1121 | int for_del); | ||
1118 | int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page); | 1122 | int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page); |
1119 | int btrfs_readpage(struct file *file, struct page *page); | 1123 | int btrfs_readpage(struct file *file, struct page *page); |
1120 | void btrfs_delete_inode(struct inode *inode); | 1124 | void btrfs_delete_inode(struct inode *inode); |
diff --git a/fs/btrfs/disk-io.c b/fs/btrfs/disk-io.c index ebb2db624fdd..eebb4fb65c61 100644 --- a/fs/btrfs/disk-io.c +++ b/fs/btrfs/disk-io.c | |||
@@ -223,7 +223,8 @@ static int btree_writepages(struct address_space *mapping, | |||
223 | } else { | 223 | } else { |
224 | thresh = 8 * 1024 * 1024; | 224 | thresh = 8 * 1024 * 1024; |
225 | } | 225 | } |
226 | num_dirty = count_range_bits(tree, &start, thresh, EXTENT_DIRTY); | 226 | num_dirty = count_range_bits(tree, &start, (u64)-1, |
227 | thresh, EXTENT_DIRTY); | ||
227 | if (num_dirty < thresh) { | 228 | if (num_dirty < thresh) { |
228 | return 0; | 229 | return 0; |
229 | } | 230 | } |
@@ -559,6 +560,7 @@ struct btrfs_root *open_ctree(struct super_block *sb) | |||
559 | INIT_LIST_HEAD(&fs_info->dead_roots); | 560 | INIT_LIST_HEAD(&fs_info->dead_roots); |
560 | INIT_LIST_HEAD(&fs_info->hashers); | 561 | INIT_LIST_HEAD(&fs_info->hashers); |
561 | spin_lock_init(&fs_info->hash_lock); | 562 | spin_lock_init(&fs_info->hash_lock); |
563 | spin_lock_init(&fs_info->delalloc_lock); | ||
562 | 564 | ||
563 | memset(&fs_info->super_kobj, 0, sizeof(fs_info->super_kobj)); | 565 | memset(&fs_info->super_kobj, 0, sizeof(fs_info->super_kobj)); |
564 | init_completion(&fs_info->kobj_unregister); | 566 | init_completion(&fs_info->kobj_unregister); |
@@ -570,6 +572,7 @@ struct btrfs_root *open_ctree(struct super_block *sb) | |||
570 | fs_info->sb = sb; | 572 | fs_info->sb = sb; |
571 | fs_info->mount_opt = 0; | 573 | fs_info->mount_opt = 0; |
572 | fs_info->max_extent = (u64)-1; | 574 | fs_info->max_extent = (u64)-1; |
575 | fs_info->delalloc_bytes = 0; | ||
573 | fs_info->btree_inode = new_inode(sb); | 576 | fs_info->btree_inode = new_inode(sb); |
574 | fs_info->btree_inode->i_ino = 1; | 577 | fs_info->btree_inode->i_ino = 1; |
575 | fs_info->btree_inode->i_nlink = 1; | 578 | fs_info->btree_inode->i_nlink = 1; |
diff --git a/fs/btrfs/extent_map.c b/fs/btrfs/extent_map.c index a0dff34dd437..2b92f1070274 100644 --- a/fs/btrfs/extent_map.c +++ b/fs/btrfs/extent_map.c | |||
@@ -1131,7 +1131,8 @@ out: | |||
1131 | } | 1131 | } |
1132 | 1132 | ||
1133 | u64 count_range_bits(struct extent_map_tree *tree, | 1133 | u64 count_range_bits(struct extent_map_tree *tree, |
1134 | u64 *start, u64 max_bytes, unsigned long bits) | 1134 | u64 *start, u64 search_end, u64 max_bytes, |
1135 | unsigned long bits) | ||
1135 | { | 1136 | { |
1136 | struct rb_node *node; | 1137 | struct rb_node *node; |
1137 | struct extent_state *state; | 1138 | struct extent_state *state; |
@@ -1139,9 +1140,14 @@ u64 count_range_bits(struct extent_map_tree *tree, | |||
1139 | u64 total_bytes = 0; | 1140 | u64 total_bytes = 0; |
1140 | int found = 0; | 1141 | int found = 0; |
1141 | 1142 | ||
1143 | if (search_end <= cur_start) { | ||
1144 | printk("search_end %Lu start %Lu\n", search_end, cur_start); | ||
1145 | WARN_ON(1); | ||
1146 | return 0; | ||
1147 | } | ||
1148 | |||
1142 | write_lock_irq(&tree->lock); | 1149 | write_lock_irq(&tree->lock); |
1143 | if (bits == EXTENT_DIRTY) { | 1150 | if (cur_start == 0 && bits == EXTENT_DIRTY) { |
1144 | *start = 0; | ||
1145 | total_bytes = tree->dirty_bytes; | 1151 | total_bytes = tree->dirty_bytes; |
1146 | goto out; | 1152 | goto out; |
1147 | } | 1153 | } |
@@ -1156,8 +1162,11 @@ u64 count_range_bits(struct extent_map_tree *tree, | |||
1156 | 1162 | ||
1157 | while(1) { | 1163 | while(1) { |
1158 | state = rb_entry(node, struct extent_state, rb_node); | 1164 | state = rb_entry(node, struct extent_state, rb_node); |
1159 | if ((state->state & bits)) { | 1165 | if (state->start > search_end) |
1160 | total_bytes += state->end - state->start + 1; | 1166 | break; |
1167 | if (state->end >= cur_start && (state->state & bits)) { | ||
1168 | total_bytes += min(search_end, state->end) + 1 - | ||
1169 | max(cur_start, state->start); | ||
1161 | if (total_bytes >= max_bytes) | 1170 | if (total_bytes >= max_bytes) |
1162 | break; | 1171 | break; |
1163 | if (!found) { | 1172 | if (!found) { |
@@ -1173,7 +1182,6 @@ out: | |||
1173 | write_unlock_irq(&tree->lock); | 1182 | write_unlock_irq(&tree->lock); |
1174 | return total_bytes; | 1183 | return total_bytes; |
1175 | } | 1184 | } |
1176 | |||
1177 | /* | 1185 | /* |
1178 | * helper function to lock both pages and extents in the tree. | 1186 | * helper function to lock both pages and extents in the tree. |
1179 | * pages must be locked first. | 1187 | * pages must be locked first. |
diff --git a/fs/btrfs/extent_map.h b/fs/btrfs/extent_map.h index 6e572d3e8924..ea60f5447b5b 100644 --- a/fs/btrfs/extent_map.h +++ b/fs/btrfs/extent_map.h | |||
@@ -115,7 +115,8 @@ int __init extent_map_init(void); | |||
115 | void extent_map_exit(void); | 115 | void extent_map_exit(void); |
116 | 116 | ||
117 | u64 count_range_bits(struct extent_map_tree *tree, | 117 | u64 count_range_bits(struct extent_map_tree *tree, |
118 | u64 *start, u64 max_bytes, unsigned long bits); | 118 | u64 *start, u64 search_end, |
119 | u64 max_bytes, unsigned long bits); | ||
119 | 120 | ||
120 | int test_range_bit(struct extent_map_tree *tree, u64 start, u64 end, | 121 | int test_range_bit(struct extent_map_tree *tree, u64 start, u64 end, |
121 | int bits, int filled); | 122 | int bits, int filled); |
diff --git a/fs/btrfs/file.c b/fs/btrfs/file.c index 461b09663fed..71dc2d33b6c6 100644 --- a/fs/btrfs/file.c +++ b/fs/btrfs/file.c | |||
@@ -307,6 +307,7 @@ static int dirty_and_release_pages(struct btrfs_trans_handle *trans, | |||
307 | inline_size > 32768 || | 307 | inline_size > 32768 || |
308 | inline_size >= BTRFS_MAX_INLINE_DATA_SIZE(root)) { | 308 | inline_size >= BTRFS_MAX_INLINE_DATA_SIZE(root)) { |
309 | u64 last_end; | 309 | u64 last_end; |
310 | u64 existing_delalloc = 0; | ||
310 | 311 | ||
311 | for (i = 0; i < num_pages; i++) { | 312 | for (i = 0; i < num_pages; i++) { |
312 | struct page *p = pages[i]; | 313 | struct page *p = pages[i]; |
@@ -316,8 +317,19 @@ static int dirty_and_release_pages(struct btrfs_trans_handle *trans, | |||
316 | last_end = (u64)(pages[num_pages -1]->index) << | 317 | last_end = (u64)(pages[num_pages -1]->index) << |
317 | PAGE_CACHE_SHIFT; | 318 | PAGE_CACHE_SHIFT; |
318 | last_end += PAGE_CACHE_SIZE - 1; | 319 | last_end += PAGE_CACHE_SIZE - 1; |
320 | if (start_pos < isize) { | ||
321 | u64 delalloc_start = start_pos; | ||
322 | existing_delalloc = count_range_bits(em_tree, | ||
323 | &delalloc_start, | ||
324 | end_of_last_block, (u64)-1, | ||
325 | EXTENT_DELALLOC); | ||
326 | } | ||
319 | set_extent_delalloc(em_tree, start_pos, end_of_last_block, | 327 | set_extent_delalloc(em_tree, start_pos, end_of_last_block, |
320 | GFP_NOFS); | 328 | GFP_NOFS); |
329 | spin_lock(&root->fs_info->delalloc_lock); | ||
330 | root->fs_info->delalloc_bytes += (end_of_last_block + 1 - | ||
331 | start_pos) - existing_delalloc; | ||
332 | spin_unlock(&root->fs_info->delalloc_lock); | ||
321 | } else { | 333 | } else { |
322 | u64 aligned_end; | 334 | u64 aligned_end; |
323 | /* step one, delete the existing extents in this range */ | 335 | /* step one, delete the existing extents in this range */ |
@@ -708,12 +720,12 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
708 | current->backing_dev_info = inode->i_mapping->backing_dev_info; | 720 | current->backing_dev_info = inode->i_mapping->backing_dev_info; |
709 | err = generic_write_checks(file, &pos, &count, S_ISBLK(inode->i_mode)); | 721 | err = generic_write_checks(file, &pos, &count, S_ISBLK(inode->i_mode)); |
710 | if (err) | 722 | if (err) |
711 | goto out; | 723 | goto out_nolock; |
712 | if (count == 0) | 724 | if (count == 0) |
713 | goto out; | 725 | goto out_nolock; |
714 | err = remove_suid(fdentry(file)); | 726 | err = remove_suid(fdentry(file)); |
715 | if (err) | 727 | if (err) |
716 | goto out; | 728 | goto out_nolock; |
717 | file_update_time(file); | 729 | file_update_time(file); |
718 | 730 | ||
719 | pages = kmalloc(nrptrs * sizeof(struct page *), GFP_KERNEL); | 731 | pages = kmalloc(nrptrs * sizeof(struct page *), GFP_KERNEL); |
@@ -758,6 +770,13 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
758 | 770 | ||
759 | WARN_ON(num_pages > nrptrs); | 771 | WARN_ON(num_pages > nrptrs); |
760 | memset(pages, 0, sizeof(pages)); | 772 | memset(pages, 0, sizeof(pages)); |
773 | |||
774 | mutex_lock(&root->fs_info->fs_mutex); | ||
775 | ret = btrfs_check_free_space(root, write_bytes, 0); | ||
776 | mutex_unlock(&root->fs_info->fs_mutex); | ||
777 | if (ret) | ||
778 | goto out; | ||
779 | |||
761 | ret = prepare_pages(root, file, pages, num_pages, | 780 | ret = prepare_pages(root, file, pages, num_pages, |
762 | pos, first_index, last_index, | 781 | pos, first_index, last_index, |
763 | write_bytes); | 782 | write_bytes); |
@@ -787,8 +806,9 @@ static ssize_t btrfs_file_write(struct file *file, const char __user *buf, | |||
787 | btrfs_btree_balance_dirty(root, 1); | 806 | btrfs_btree_balance_dirty(root, 1); |
788 | cond_resched(); | 807 | cond_resched(); |
789 | } | 808 | } |
790 | mutex_unlock(&inode->i_mutex); | ||
791 | out: | 809 | out: |
810 | mutex_unlock(&inode->i_mutex); | ||
811 | out_nolock: | ||
792 | kfree(pages); | 812 | kfree(pages); |
793 | if (pinned[0]) | 813 | if (pinned[0]) |
794 | page_cache_release(pinned[0]); | 814 | page_cache_release(pinned[0]); |
diff --git a/fs/btrfs/inode.c b/fs/btrfs/inode.c index 1c61c85dc3d8..a9f5d6d417f0 100644 --- a/fs/btrfs/inode.c +++ b/fs/btrfs/inode.c | |||
@@ -72,6 +72,26 @@ static unsigned char btrfs_type_by_mode[S_IFMT >> S_SHIFT] = { | |||
72 | [S_IFLNK >> S_SHIFT] = BTRFS_FT_SYMLINK, | 72 | [S_IFLNK >> S_SHIFT] = BTRFS_FT_SYMLINK, |
73 | }; | 73 | }; |
74 | 74 | ||
75 | int btrfs_check_free_space(struct btrfs_root *root, u64 num_required, | ||
76 | int for_del) | ||
77 | { | ||
78 | u64 total = btrfs_super_total_bytes(&root->fs_info->super_copy); | ||
79 | u64 used = btrfs_super_bytes_used(&root->fs_info->super_copy); | ||
80 | u64 thresh; | ||
81 | int ret = 0; | ||
82 | |||
83 | if (for_del) | ||
84 | thresh = (total * 90) / 100; | ||
85 | else | ||
86 | thresh = (total * 85) / 100; | ||
87 | |||
88 | spin_lock(&root->fs_info->delalloc_lock); | ||
89 | if (used + root->fs_info->delalloc_bytes + num_required > thresh) | ||
90 | ret = -ENOSPC; | ||
91 | spin_unlock(&root->fs_info->delalloc_lock); | ||
92 | return ret; | ||
93 | } | ||
94 | |||
75 | static int cow_file_range(struct inode *inode, u64 start, u64 end) | 95 | static int cow_file_range(struct inode *inode, u64 start, u64 end) |
76 | { | 96 | { |
77 | struct btrfs_root *root = BTRFS_I(inode)->root; | 97 | struct btrfs_root *root = BTRFS_I(inode)->root; |
@@ -124,6 +144,7 @@ static int run_delalloc_nocow(struct inode *inode, u64 start, u64 end) | |||
124 | u64 extent_end; | 144 | u64 extent_end; |
125 | u64 bytenr; | 145 | u64 bytenr; |
126 | u64 cow_end; | 146 | u64 cow_end; |
147 | u64 loops = 0; | ||
127 | struct btrfs_root *root = BTRFS_I(inode)->root; | 148 | struct btrfs_root *root = BTRFS_I(inode)->root; |
128 | struct extent_buffer *leaf; | 149 | struct extent_buffer *leaf; |
129 | int found_type; | 150 | int found_type; |
@@ -169,6 +190,9 @@ again: | |||
169 | btrfs_file_extent_num_bytes(leaf, item); | 190 | btrfs_file_extent_num_bytes(leaf, item); |
170 | err = 0; | 191 | err = 0; |
171 | 192 | ||
193 | if (loops && start != extent_start) | ||
194 | goto not_found; | ||
195 | |||
172 | if (start < extent_start || start >= extent_end) | 196 | if (start < extent_start || start >= extent_end) |
173 | goto not_found; | 197 | goto not_found; |
174 | 198 | ||
@@ -191,6 +215,7 @@ loop: | |||
191 | return 0; | 215 | return 0; |
192 | } | 216 | } |
193 | btrfs_release_path(root, path); | 217 | btrfs_release_path(root, path); |
218 | loops++; | ||
194 | goto again; | 219 | goto again; |
195 | 220 | ||
196 | not_found: | 221 | not_found: |
@@ -202,6 +227,7 @@ not_found: | |||
202 | static int run_delalloc_range(struct inode *inode, u64 start, u64 end) | 227 | static int run_delalloc_range(struct inode *inode, u64 start, u64 end) |
203 | { | 228 | { |
204 | struct btrfs_root *root = BTRFS_I(inode)->root; | 229 | struct btrfs_root *root = BTRFS_I(inode)->root; |
230 | u64 num_bytes; | ||
205 | int ret; | 231 | int ret; |
206 | 232 | ||
207 | mutex_lock(&root->fs_info->fs_mutex); | 233 | mutex_lock(&root->fs_info->fs_mutex); |
@@ -209,6 +235,17 @@ static int run_delalloc_range(struct inode *inode, u64 start, u64 end) | |||
209 | ret = run_delalloc_nocow(inode, start, end); | 235 | ret = run_delalloc_nocow(inode, start, end); |
210 | else | 236 | else |
211 | ret = cow_file_range(inode, start, end); | 237 | ret = cow_file_range(inode, start, end); |
238 | |||
239 | spin_lock(&root->fs_info->delalloc_lock); | ||
240 | num_bytes = end + 1 - start; | ||
241 | if (root->fs_info->delalloc_bytes < num_bytes) { | ||
242 | printk("delalloc accounting error total %llu sub %llu\n", | ||
243 | root->fs_info->delalloc_bytes, num_bytes); | ||
244 | } else { | ||
245 | root->fs_info->delalloc_bytes -= num_bytes; | ||
246 | } | ||
247 | spin_unlock(&root->fs_info->delalloc_lock); | ||
248 | |||
212 | mutex_unlock(&root->fs_info->fs_mutex); | 249 | mutex_unlock(&root->fs_info->fs_mutex); |
213 | return ret; | 250 | return ret; |
214 | } | 251 | } |
@@ -547,10 +584,15 @@ static int btrfs_unlink(struct inode *dir, struct dentry *dentry) | |||
547 | struct btrfs_root *root; | 584 | struct btrfs_root *root; |
548 | struct btrfs_trans_handle *trans; | 585 | struct btrfs_trans_handle *trans; |
549 | int ret; | 586 | int ret; |
550 | unsigned long nr; | 587 | unsigned long nr = 0; |
551 | 588 | ||
552 | root = BTRFS_I(dir)->root; | 589 | root = BTRFS_I(dir)->root; |
553 | mutex_lock(&root->fs_info->fs_mutex); | 590 | mutex_lock(&root->fs_info->fs_mutex); |
591 | |||
592 | ret = btrfs_check_free_space(root, 1, 1); | ||
593 | if (ret) | ||
594 | goto fail; | ||
595 | |||
554 | trans = btrfs_start_transaction(root, 1); | 596 | trans = btrfs_start_transaction(root, 1); |
555 | 597 | ||
556 | btrfs_set_trans_block_group(trans, dir); | 598 | btrfs_set_trans_block_group(trans, dir); |
@@ -558,25 +600,29 @@ static int btrfs_unlink(struct inode *dir, struct dentry *dentry) | |||
558 | nr = trans->blocks_used; | 600 | nr = trans->blocks_used; |
559 | 601 | ||
560 | btrfs_end_transaction(trans, root); | 602 | btrfs_end_transaction(trans, root); |
603 | fail: | ||
561 | mutex_unlock(&root->fs_info->fs_mutex); | 604 | mutex_unlock(&root->fs_info->fs_mutex); |
562 | btrfs_btree_balance_dirty(root, nr); | 605 | btrfs_btree_balance_dirty(root, nr); |
563 | |||
564 | return ret; | 606 | return ret; |
565 | } | 607 | } |
566 | 608 | ||
567 | static int btrfs_rmdir(struct inode *dir, struct dentry *dentry) | 609 | static int btrfs_rmdir(struct inode *dir, struct dentry *dentry) |
568 | { | 610 | { |
569 | struct inode *inode = dentry->d_inode; | 611 | struct inode *inode = dentry->d_inode; |
570 | int err; | 612 | int err = 0; |
571 | int ret; | 613 | int ret; |
572 | struct btrfs_root *root = BTRFS_I(dir)->root; | 614 | struct btrfs_root *root = BTRFS_I(dir)->root; |
573 | struct btrfs_trans_handle *trans; | 615 | struct btrfs_trans_handle *trans; |
574 | unsigned long nr; | 616 | unsigned long nr = 0; |
575 | 617 | ||
576 | if (inode->i_size > BTRFS_EMPTY_DIR_SIZE) | 618 | if (inode->i_size > BTRFS_EMPTY_DIR_SIZE) |
577 | return -ENOTEMPTY; | 619 | return -ENOTEMPTY; |
578 | 620 | ||
579 | mutex_lock(&root->fs_info->fs_mutex); | 621 | mutex_lock(&root->fs_info->fs_mutex); |
622 | ret = btrfs_check_free_space(root, 1, 1); | ||
623 | if (ret) | ||
624 | goto fail; | ||
625 | |||
580 | trans = btrfs_start_transaction(root, 1); | 626 | trans = btrfs_start_transaction(root, 1); |
581 | btrfs_set_trans_block_group(trans, dir); | 627 | btrfs_set_trans_block_group(trans, dir); |
582 | 628 | ||
@@ -588,6 +634,7 @@ static int btrfs_rmdir(struct inode *dir, struct dentry *dentry) | |||
588 | 634 | ||
589 | nr = trans->blocks_used; | 635 | nr = trans->blocks_used; |
590 | ret = btrfs_end_transaction(trans, root); | 636 | ret = btrfs_end_transaction(trans, root); |
637 | fail: | ||
591 | mutex_unlock(&root->fs_info->fs_mutex); | 638 | mutex_unlock(&root->fs_info->fs_mutex); |
592 | btrfs_btree_balance_dirty(root, nr); | 639 | btrfs_btree_balance_dirty(root, nr); |
593 | 640 | ||
@@ -792,17 +839,29 @@ static int btrfs_cow_one_page(struct inode *inode, struct page *page, | |||
792 | size_t zero_start) | 839 | size_t zero_start) |
793 | { | 840 | { |
794 | char *kaddr; | 841 | char *kaddr; |
795 | int ret = 0; | ||
796 | struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree; | 842 | struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree; |
843 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
797 | u64 page_start = (u64)page->index << PAGE_CACHE_SHIFT; | 844 | u64 page_start = (u64)page->index << PAGE_CACHE_SHIFT; |
798 | u64 page_end = page_start + PAGE_CACHE_SIZE - 1; | 845 | u64 page_end = page_start + PAGE_CACHE_SIZE - 1; |
846 | u64 existing_delalloc; | ||
847 | u64 delalloc_start; | ||
848 | int ret = 0; | ||
799 | 849 | ||
800 | WARN_ON(!PageLocked(page)); | 850 | WARN_ON(!PageLocked(page)); |
801 | set_page_extent_mapped(page); | 851 | set_page_extent_mapped(page); |
802 | 852 | ||
803 | lock_extent(em_tree, page_start, page_end, GFP_NOFS); | 853 | lock_extent(em_tree, page_start, page_end, GFP_NOFS); |
854 | delalloc_start = page_start; | ||
855 | existing_delalloc = count_range_bits(&BTRFS_I(inode)->extent_tree, | ||
856 | &delalloc_start, page_end, | ||
857 | PAGE_CACHE_SIZE, EXTENT_DELALLOC); | ||
804 | set_extent_delalloc(&BTRFS_I(inode)->extent_tree, page_start, | 858 | set_extent_delalloc(&BTRFS_I(inode)->extent_tree, page_start, |
805 | page_end, GFP_NOFS); | 859 | page_end, GFP_NOFS); |
860 | |||
861 | spin_lock(&root->fs_info->delalloc_lock); | ||
862 | root->fs_info->delalloc_bytes += PAGE_CACHE_SIZE - existing_delalloc; | ||
863 | spin_unlock(&root->fs_info->delalloc_lock); | ||
864 | |||
806 | if (zero_start != PAGE_CACHE_SIZE) { | 865 | if (zero_start != PAGE_CACHE_SIZE) { |
807 | kaddr = kmap(page); | 866 | kaddr = kmap(page); |
808 | memset(kaddr + zero_start, 0, PAGE_CACHE_SIZE - zero_start); | 867 | memset(kaddr + zero_start, 0, PAGE_CACHE_SIZE - zero_start); |
@@ -881,6 +940,12 @@ static int btrfs_setattr(struct dentry *dentry, struct iattr *attr) | |||
881 | if (attr->ia_size <= pos) | 940 | if (attr->ia_size <= pos) |
882 | goto out; | 941 | goto out; |
883 | 942 | ||
943 | mutex_lock(&root->fs_info->fs_mutex); | ||
944 | err = btrfs_check_free_space(root, 1, 0); | ||
945 | mutex_unlock(&root->fs_info->fs_mutex); | ||
946 | if (err) | ||
947 | goto fail; | ||
948 | |||
884 | btrfs_truncate_page(inode->i_mapping, inode->i_size); | 949 | btrfs_truncate_page(inode->i_mapping, inode->i_size); |
885 | 950 | ||
886 | lock_extent(em_tree, pos, block_end, GFP_NOFS); | 951 | lock_extent(em_tree, pos, block_end, GFP_NOFS); |
@@ -906,7 +971,7 @@ static int btrfs_setattr(struct dentry *dentry, struct iattr *attr) | |||
906 | } | 971 | } |
907 | out: | 972 | out: |
908 | err = inode_setattr(inode, attr); | 973 | err = inode_setattr(inode, attr); |
909 | 974 | fail: | |
910 | return err; | 975 | return err; |
911 | } | 976 | } |
912 | void btrfs_delete_inode(struct inode *inode) | 977 | void btrfs_delete_inode(struct inode *inode) |
@@ -1440,16 +1505,20 @@ static int btrfs_mknod(struct inode *dir, struct dentry *dentry, | |||
1440 | { | 1505 | { |
1441 | struct btrfs_trans_handle *trans; | 1506 | struct btrfs_trans_handle *trans; |
1442 | struct btrfs_root *root = BTRFS_I(dir)->root; | 1507 | struct btrfs_root *root = BTRFS_I(dir)->root; |
1443 | struct inode *inode; | 1508 | struct inode *inode = NULL; |
1444 | int err; | 1509 | int err; |
1445 | int drop_inode = 0; | 1510 | int drop_inode = 0; |
1446 | u64 objectid; | 1511 | u64 objectid; |
1447 | unsigned long nr; | 1512 | unsigned long nr = 0; |
1448 | 1513 | ||
1449 | if (!new_valid_dev(rdev)) | 1514 | if (!new_valid_dev(rdev)) |
1450 | return -EINVAL; | 1515 | return -EINVAL; |
1451 | 1516 | ||
1452 | mutex_lock(&root->fs_info->fs_mutex); | 1517 | mutex_lock(&root->fs_info->fs_mutex); |
1518 | err = btrfs_check_free_space(root, 1, 0); | ||
1519 | if (err) | ||
1520 | goto fail; | ||
1521 | |||
1453 | trans = btrfs_start_transaction(root, 1); | 1522 | trans = btrfs_start_transaction(root, 1); |
1454 | btrfs_set_trans_block_group(trans, dir); | 1523 | btrfs_set_trans_block_group(trans, dir); |
1455 | 1524 | ||
@@ -1480,6 +1549,7 @@ static int btrfs_mknod(struct inode *dir, struct dentry *dentry, | |||
1480 | out_unlock: | 1549 | out_unlock: |
1481 | nr = trans->blocks_used; | 1550 | nr = trans->blocks_used; |
1482 | btrfs_end_transaction(trans, root); | 1551 | btrfs_end_transaction(trans, root); |
1552 | fail: | ||
1483 | mutex_unlock(&root->fs_info->fs_mutex); | 1553 | mutex_unlock(&root->fs_info->fs_mutex); |
1484 | 1554 | ||
1485 | if (drop_inode) { | 1555 | if (drop_inode) { |
@@ -1495,13 +1565,16 @@ static int btrfs_create(struct inode *dir, struct dentry *dentry, | |||
1495 | { | 1565 | { |
1496 | struct btrfs_trans_handle *trans; | 1566 | struct btrfs_trans_handle *trans; |
1497 | struct btrfs_root *root = BTRFS_I(dir)->root; | 1567 | struct btrfs_root *root = BTRFS_I(dir)->root; |
1498 | struct inode *inode; | 1568 | struct inode *inode = NULL; |
1499 | int err; | 1569 | int err; |
1500 | int drop_inode = 0; | 1570 | int drop_inode = 0; |
1501 | unsigned long nr; | 1571 | unsigned long nr = 0; |
1502 | u64 objectid; | 1572 | u64 objectid; |
1503 | 1573 | ||
1504 | mutex_lock(&root->fs_info->fs_mutex); | 1574 | mutex_lock(&root->fs_info->fs_mutex); |
1575 | err = btrfs_check_free_space(root, 1, 0); | ||
1576 | if (err) | ||
1577 | goto fail; | ||
1505 | trans = btrfs_start_transaction(root, 1); | 1578 | trans = btrfs_start_transaction(root, 1); |
1506 | btrfs_set_trans_block_group(trans, dir); | 1579 | btrfs_set_trans_block_group(trans, dir); |
1507 | 1580 | ||
@@ -1535,6 +1608,7 @@ static int btrfs_create(struct inode *dir, struct dentry *dentry, | |||
1535 | out_unlock: | 1608 | out_unlock: |
1536 | nr = trans->blocks_used; | 1609 | nr = trans->blocks_used; |
1537 | btrfs_end_transaction(trans, root); | 1610 | btrfs_end_transaction(trans, root); |
1611 | fail: | ||
1538 | mutex_unlock(&root->fs_info->fs_mutex); | 1612 | mutex_unlock(&root->fs_info->fs_mutex); |
1539 | 1613 | ||
1540 | if (drop_inode) { | 1614 | if (drop_inode) { |
@@ -1551,7 +1625,7 @@ static int btrfs_link(struct dentry *old_dentry, struct inode *dir, | |||
1551 | struct btrfs_trans_handle *trans; | 1625 | struct btrfs_trans_handle *trans; |
1552 | struct btrfs_root *root = BTRFS_I(dir)->root; | 1626 | struct btrfs_root *root = BTRFS_I(dir)->root; |
1553 | struct inode *inode = old_dentry->d_inode; | 1627 | struct inode *inode = old_dentry->d_inode; |
1554 | unsigned long nr; | 1628 | unsigned long nr = 0; |
1555 | int err; | 1629 | int err; |
1556 | int drop_inode = 0; | 1630 | int drop_inode = 0; |
1557 | 1631 | ||
@@ -1564,6 +1638,9 @@ static int btrfs_link(struct dentry *old_dentry, struct inode *dir, | |||
1564 | inc_nlink(inode); | 1638 | inc_nlink(inode); |
1565 | #endif | 1639 | #endif |
1566 | mutex_lock(&root->fs_info->fs_mutex); | 1640 | mutex_lock(&root->fs_info->fs_mutex); |
1641 | err = btrfs_check_free_space(root, 1, 0); | ||
1642 | if (err) | ||
1643 | goto fail; | ||
1567 | trans = btrfs_start_transaction(root, 1); | 1644 | trans = btrfs_start_transaction(root, 1); |
1568 | 1645 | ||
1569 | btrfs_set_trans_block_group(trans, dir); | 1646 | btrfs_set_trans_block_group(trans, dir); |
@@ -1582,6 +1659,7 @@ static int btrfs_link(struct dentry *old_dentry, struct inode *dir, | |||
1582 | 1659 | ||
1583 | nr = trans->blocks_used; | 1660 | nr = trans->blocks_used; |
1584 | btrfs_end_transaction(trans, root); | 1661 | btrfs_end_transaction(trans, root); |
1662 | fail: | ||
1585 | mutex_unlock(&root->fs_info->fs_mutex); | 1663 | mutex_unlock(&root->fs_info->fs_mutex); |
1586 | 1664 | ||
1587 | if (drop_inode) { | 1665 | if (drop_inode) { |
@@ -1603,6 +1681,10 @@ static int btrfs_mkdir(struct inode *dir, struct dentry *dentry, int mode) | |||
1603 | unsigned long nr = 1; | 1681 | unsigned long nr = 1; |
1604 | 1682 | ||
1605 | mutex_lock(&root->fs_info->fs_mutex); | 1683 | mutex_lock(&root->fs_info->fs_mutex); |
1684 | err = btrfs_check_free_space(root, 1, 0); | ||
1685 | if (err) | ||
1686 | goto out_unlock; | ||
1687 | |||
1606 | trans = btrfs_start_transaction(root, 1); | 1688 | trans = btrfs_start_transaction(root, 1); |
1607 | btrfs_set_trans_block_group(trans, dir); | 1689 | btrfs_set_trans_block_group(trans, dir); |
1608 | 1690 | ||
@@ -1869,6 +1951,15 @@ static sector_t btrfs_bmap(struct address_space *mapping, sector_t iblock) | |||
1869 | static int btrfs_prepare_write(struct file *file, struct page *page, | 1951 | static int btrfs_prepare_write(struct file *file, struct page *page, |
1870 | unsigned from, unsigned to) | 1952 | unsigned from, unsigned to) |
1871 | { | 1953 | { |
1954 | struct btrfs_root *root = BTRFS_I(page->mapping->host)->root; | ||
1955 | int err; | ||
1956 | |||
1957 | mutex_lock(&root->fs_info->fs_mutex); | ||
1958 | err = btrfs_check_free_space(root, PAGE_CACHE_SIZE, 0); | ||
1959 | mutex_lock(&root->fs_info->fs_mutex); | ||
1960 | if (err) | ||
1961 | return -ENOSPC; | ||
1962 | |||
1872 | return extent_prepare_write(&BTRFS_I(page->mapping->host)->extent_tree, | 1963 | return extent_prepare_write(&BTRFS_I(page->mapping->host)->extent_tree, |
1873 | page->mapping->host, page, from, to, | 1964 | page->mapping->host, page, from, to, |
1874 | btrfs_get_extent); | 1965 | btrfs_get_extent); |
@@ -1880,6 +1971,7 @@ int btrfs_readpage(struct file *file, struct page *page) | |||
1880 | tree = &BTRFS_I(page->mapping->host)->extent_tree; | 1971 | tree = &BTRFS_I(page->mapping->host)->extent_tree; |
1881 | return extent_read_full_page(tree, page, btrfs_get_extent); | 1972 | return extent_read_full_page(tree, page, btrfs_get_extent); |
1882 | } | 1973 | } |
1974 | |||
1883 | static int btrfs_writepage(struct page *page, struct writeback_control *wbc) | 1975 | static int btrfs_writepage(struct page *page, struct writeback_control *wbc) |
1884 | { | 1976 | { |
1885 | struct extent_map_tree *tree; | 1977 | struct extent_map_tree *tree; |
@@ -1954,11 +2046,20 @@ static void btrfs_invalidatepage(struct page *page, unsigned long offset) | |||
1954 | int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page) | 2046 | int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page) |
1955 | { | 2047 | { |
1956 | struct inode *inode = fdentry(vma->vm_file)->d_inode; | 2048 | struct inode *inode = fdentry(vma->vm_file)->d_inode; |
2049 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
1957 | unsigned long end; | 2050 | unsigned long end; |
1958 | loff_t size; | 2051 | loff_t size; |
1959 | int ret = -EINVAL; | 2052 | int ret; |
1960 | u64 page_start; | 2053 | u64 page_start; |
1961 | 2054 | ||
2055 | mutex_lock(&root->fs_info->fs_mutex); | ||
2056 | ret = btrfs_check_free_space(root, PAGE_CACHE_SIZE, 0); | ||
2057 | mutex_lock(&root->fs_info->fs_mutex); | ||
2058 | if (ret) | ||
2059 | goto out; | ||
2060 | |||
2061 | ret = -EINVAL; | ||
2062 | |||
1962 | down_read(&BTRFS_I(inode)->root->snap_sem); | 2063 | down_read(&BTRFS_I(inode)->root->snap_sem); |
1963 | lock_page(page); | 2064 | lock_page(page); |
1964 | wait_on_page_writeback(page); | 2065 | wait_on_page_writeback(page); |
@@ -1982,6 +2083,7 @@ int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page) | |||
1982 | out_unlock: | 2083 | out_unlock: |
1983 | up_read(&BTRFS_I(inode)->root->snap_sem); | 2084 | up_read(&BTRFS_I(inode)->root->snap_sem); |
1984 | unlock_page(page); | 2085 | unlock_page(page); |
2086 | out: | ||
1985 | return ret; | 2087 | return ret; |
1986 | } | 2088 | } |
1987 | 2089 | ||
@@ -2046,6 +2148,10 @@ static int create_subvol(struct btrfs_root *root, char *name, int namelen) | |||
2046 | unsigned long nr = 1; | 2148 | unsigned long nr = 1; |
2047 | 2149 | ||
2048 | mutex_lock(&root->fs_info->fs_mutex); | 2150 | mutex_lock(&root->fs_info->fs_mutex); |
2151 | ret = btrfs_check_free_space(root, 1, 0); | ||
2152 | if (ret) | ||
2153 | goto fail_commit; | ||
2154 | |||
2049 | trans = btrfs_start_transaction(root, 1); | 2155 | trans = btrfs_start_transaction(root, 1); |
2050 | BUG_ON(!trans); | 2156 | BUG_ON(!trans); |
2051 | 2157 | ||
@@ -2162,7 +2268,7 @@ static int create_snapshot(struct btrfs_root *root, char *name, int namelen) | |||
2162 | int ret; | 2268 | int ret; |
2163 | int err; | 2269 | int err; |
2164 | u64 objectid; | 2270 | u64 objectid; |
2165 | unsigned long nr; | 2271 | unsigned long nr = 0; |
2166 | 2272 | ||
2167 | if (!root->ref_cows) | 2273 | if (!root->ref_cows) |
2168 | return -EINVAL; | 2274 | return -EINVAL; |
@@ -2172,6 +2278,10 @@ static int create_snapshot(struct btrfs_root *root, char *name, int namelen) | |||
2172 | thaw_bdev(root->fs_info->sb->s_bdev, root->fs_info->sb); | 2278 | thaw_bdev(root->fs_info->sb->s_bdev, root->fs_info->sb); |
2173 | 2279 | ||
2174 | mutex_lock(&root->fs_info->fs_mutex); | 2280 | mutex_lock(&root->fs_info->fs_mutex); |
2281 | ret = btrfs_check_free_space(root, 1, 0); | ||
2282 | if (ret) | ||
2283 | goto fail_unlock; | ||
2284 | |||
2175 | trans = btrfs_start_transaction(root, 1); | 2285 | trans = btrfs_start_transaction(root, 1); |
2176 | BUG_ON(!trans); | 2286 | BUG_ON(!trans); |
2177 | 2287 | ||
@@ -2229,7 +2339,7 @@ fail: | |||
2229 | 2339 | ||
2230 | if (err && !ret) | 2340 | if (err && !ret) |
2231 | ret = err; | 2341 | ret = err; |
2232 | 2342 | fail_unlock: | |
2233 | mutex_unlock(&root->fs_info->fs_mutex); | 2343 | mutex_unlock(&root->fs_info->fs_mutex); |
2234 | up_write(&root->snap_sem); | 2344 | up_write(&root->snap_sem); |
2235 | btrfs_btree_balance_dirty(root, nr); | 2345 | btrfs_btree_balance_dirty(root, nr); |
@@ -2255,6 +2365,7 @@ static unsigned long force_ra(struct address_space *mapping, | |||
2255 | 2365 | ||
2256 | int btrfs_defrag_file(struct file *file) { | 2366 | int btrfs_defrag_file(struct file *file) { |
2257 | struct inode *inode = fdentry(file)->d_inode; | 2367 | struct inode *inode = fdentry(file)->d_inode; |
2368 | struct btrfs_root *root = BTRFS_I(inode)->root; | ||
2258 | struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree; | 2369 | struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree; |
2259 | struct page *page; | 2370 | struct page *page; |
2260 | unsigned long last_index; | 2371 | unsigned long last_index; |
@@ -2262,6 +2373,13 @@ int btrfs_defrag_file(struct file *file) { | |||
2262 | u64 page_start; | 2373 | u64 page_start; |
2263 | u64 page_end; | 2374 | u64 page_end; |
2264 | unsigned long i; | 2375 | unsigned long i; |
2376 | int ret; | ||
2377 | |||
2378 | mutex_lock(&root->fs_info->fs_mutex); | ||
2379 | ret = btrfs_check_free_space(root, inode->i_size, 0); | ||
2380 | mutex_unlock(&root->fs_info->fs_mutex); | ||
2381 | if (ret) | ||
2382 | return -ENOSPC; | ||
2265 | 2383 | ||
2266 | mutex_lock(&inode->i_mutex); | 2384 | mutex_lock(&inode->i_mutex); |
2267 | last_index = inode->i_size >> PAGE_CACHE_SHIFT; | 2385 | last_index = inode->i_size >> PAGE_CACHE_SHIFT; |
@@ -2522,6 +2640,10 @@ static int btrfs_rename(struct inode * old_dir, struct dentry *old_dentry, | |||
2522 | } | 2640 | } |
2523 | 2641 | ||
2524 | mutex_lock(&root->fs_info->fs_mutex); | 2642 | mutex_lock(&root->fs_info->fs_mutex); |
2643 | ret = btrfs_check_free_space(root, 1, 0); | ||
2644 | if (ret) | ||
2645 | goto out_unlock; | ||
2646 | |||
2525 | trans = btrfs_start_transaction(root, 1); | 2647 | trans = btrfs_start_transaction(root, 1); |
2526 | 2648 | ||
2527 | btrfs_set_trans_block_group(trans, new_dir); | 2649 | btrfs_set_trans_block_group(trans, new_dir); |
@@ -2553,6 +2675,7 @@ static int btrfs_rename(struct inode * old_dir, struct dentry *old_dentry, | |||
2553 | out_fail: | 2675 | out_fail: |
2554 | btrfs_free_path(path); | 2676 | btrfs_free_path(path); |
2555 | btrfs_end_transaction(trans, root); | 2677 | btrfs_end_transaction(trans, root); |
2678 | out_unlock: | ||
2556 | mutex_unlock(&root->fs_info->fs_mutex); | 2679 | mutex_unlock(&root->fs_info->fs_mutex); |
2557 | return ret; | 2680 | return ret; |
2558 | } | 2681 | } |
@@ -2564,7 +2687,7 @@ static int btrfs_symlink(struct inode *dir, struct dentry *dentry, | |||
2564 | struct btrfs_root *root = BTRFS_I(dir)->root; | 2687 | struct btrfs_root *root = BTRFS_I(dir)->root; |
2565 | struct btrfs_path *path; | 2688 | struct btrfs_path *path; |
2566 | struct btrfs_key key; | 2689 | struct btrfs_key key; |
2567 | struct inode *inode; | 2690 | struct inode *inode = NULL; |
2568 | int err; | 2691 | int err; |
2569 | int drop_inode = 0; | 2692 | int drop_inode = 0; |
2570 | u64 objectid; | 2693 | u64 objectid; |
@@ -2573,12 +2696,17 @@ static int btrfs_symlink(struct inode *dir, struct dentry *dentry, | |||
2573 | unsigned long ptr; | 2696 | unsigned long ptr; |
2574 | struct btrfs_file_extent_item *ei; | 2697 | struct btrfs_file_extent_item *ei; |
2575 | struct extent_buffer *leaf; | 2698 | struct extent_buffer *leaf; |
2576 | unsigned long nr; | 2699 | unsigned long nr = 0; |
2577 | 2700 | ||
2578 | name_len = strlen(symname) + 1; | 2701 | name_len = strlen(symname) + 1; |
2579 | if (name_len > BTRFS_MAX_INLINE_DATA_SIZE(root)) | 2702 | if (name_len > BTRFS_MAX_INLINE_DATA_SIZE(root)) |
2580 | return -ENAMETOOLONG; | 2703 | return -ENAMETOOLONG; |
2704 | |||
2581 | mutex_lock(&root->fs_info->fs_mutex); | 2705 | mutex_lock(&root->fs_info->fs_mutex); |
2706 | err = btrfs_check_free_space(root, 1, 0); | ||
2707 | if (err) | ||
2708 | goto out_fail; | ||
2709 | |||
2582 | trans = btrfs_start_transaction(root, 1); | 2710 | trans = btrfs_start_transaction(root, 1); |
2583 | btrfs_set_trans_block_group(trans, dir); | 2711 | btrfs_set_trans_block_group(trans, dir); |
2584 | 2712 | ||
@@ -2645,6 +2773,7 @@ static int btrfs_symlink(struct inode *dir, struct dentry *dentry, | |||
2645 | out_unlock: | 2773 | out_unlock: |
2646 | nr = trans->blocks_used; | 2774 | nr = trans->blocks_used; |
2647 | btrfs_end_transaction(trans, root); | 2775 | btrfs_end_transaction(trans, root); |
2776 | out_fail: | ||
2648 | mutex_unlock(&root->fs_info->fs_mutex); | 2777 | mutex_unlock(&root->fs_info->fs_mutex); |
2649 | if (drop_inode) { | 2778 | if (drop_inode) { |
2650 | inode_dec_link_count(inode); | 2779 | inode_dec_link_count(inode); |