Commit 72ac3c0d authored by Josef Bacik's avatar Josef Bacik

Btrfs: convert the inode bit field to use the actual bit operations

Miao pointed this out while I was working on an orphan problem that messing
with a bitfield where different ranges are protected by different locks
doesn't work out right.  Turns out we've been doing this forever where we
have different parts of the bit field protected by either no lock at all or
different locks which could cause all sorts of weird problems including the
issue I was hitting.  So instead make a runtime_flags thing that we use the
normal bit operations on that are all atomic so we can keep having our
no/different locking for the different flags and then make force_compress
it's own thing so it can be treated normally.  Thanks,
Signed-off-by: default avatarJosef Bacik <josef@redhat.com>
parent cd023e7b
...@@ -24,6 +24,19 @@ ...@@ -24,6 +24,19 @@
#include "ordered-data.h" #include "ordered-data.h"
#include "delayed-inode.h" #include "delayed-inode.h"
/*
* ordered_data_close is set by truncate when a file that used
* to have good data has been truncated to zero. When it is set
* the btrfs file release call will add this inode to the
* ordered operations list so that we make sure to flush out any
* new data the application may have written before commit.
*/
#define BTRFS_INODE_ORDERED_DATA_CLOSE 0
#define BTRFS_INODE_ORPHAN_META_RESERVED 1
#define BTRFS_INODE_DUMMY 2
#define BTRFS_INODE_IN_DEFRAG 3
#define BTRFS_INODE_DELALLOC_META_RESERVED 4
/* in memory btrfs inode */ /* in memory btrfs inode */
struct btrfs_inode { struct btrfs_inode {
/* which subvolume this inode belongs to */ /* which subvolume this inode belongs to */
...@@ -78,6 +91,8 @@ struct btrfs_inode { ...@@ -78,6 +91,8 @@ struct btrfs_inode {
/* the space_info for where this inode's data allocations are done */ /* the space_info for where this inode's data allocations are done */
struct btrfs_space_info *space_info; struct btrfs_space_info *space_info;
unsigned long runtime_flags;
/* full 64 bit generation number, struct vfs_inode doesn't have a big /* full 64 bit generation number, struct vfs_inode doesn't have a big
* enough field for this. * enough field for this.
*/ */
...@@ -141,23 +156,10 @@ struct btrfs_inode { ...@@ -141,23 +156,10 @@ struct btrfs_inode {
unsigned outstanding_extents; unsigned outstanding_extents;
unsigned reserved_extents; unsigned reserved_extents;
/*
* ordered_data_close is set by truncate when a file that used
* to have good data has been truncated to zero. When it is set
* the btrfs file release call will add this inode to the
* ordered operations list so that we make sure to flush out any
* new data the application may have written before commit.
*/
unsigned ordered_data_close:1;
unsigned orphan_meta_reserved:1;
unsigned dummy_inode:1;
unsigned in_defrag:1;
unsigned delalloc_meta_reserved:1;
/* /*
* always compress this one file * always compress this one file
*/ */
unsigned force_compress:4; unsigned force_compress;
struct btrfs_delayed_node *delayed_node; struct btrfs_delayed_node *delayed_node;
......
...@@ -669,8 +669,8 @@ static int btrfs_delayed_inode_reserve_metadata( ...@@ -669,8 +669,8 @@ static int btrfs_delayed_inode_reserve_metadata(
return ret; return ret;
} else if (src_rsv == &root->fs_info->delalloc_block_rsv) { } else if (src_rsv == &root->fs_info->delalloc_block_rsv) {
spin_lock(&BTRFS_I(inode)->lock); spin_lock(&BTRFS_I(inode)->lock);
if (BTRFS_I(inode)->delalloc_meta_reserved) { if (test_and_clear_bit(BTRFS_INODE_DELALLOC_META_RESERVED,
BTRFS_I(inode)->delalloc_meta_reserved = 0; &BTRFS_I(inode)->runtime_flags)) {
spin_unlock(&BTRFS_I(inode)->lock); spin_unlock(&BTRFS_I(inode)->lock);
release = true; release = true;
goto migrate; goto migrate;
......
...@@ -2001,7 +2001,8 @@ int open_ctree(struct super_block *sb, ...@@ -2001,7 +2001,8 @@ int open_ctree(struct super_block *sb,
BTRFS_I(fs_info->btree_inode)->root = tree_root; BTRFS_I(fs_info->btree_inode)->root = tree_root;
memset(&BTRFS_I(fs_info->btree_inode)->location, 0, memset(&BTRFS_I(fs_info->btree_inode)->location, 0,
sizeof(struct btrfs_key)); sizeof(struct btrfs_key));
BTRFS_I(fs_info->btree_inode)->dummy_inode = 1; set_bit(BTRFS_INODE_DUMMY,
&BTRFS_I(fs_info->btree_inode)->runtime_flags);
insert_inode_hash(fs_info->btree_inode); insert_inode_hash(fs_info->btree_inode);
spin_lock_init(&fs_info->block_group_cache_lock); spin_lock_init(&fs_info->block_group_cache_lock);
......
...@@ -4355,10 +4355,9 @@ static unsigned drop_outstanding_extent(struct inode *inode) ...@@ -4355,10 +4355,9 @@ static unsigned drop_outstanding_extent(struct inode *inode)
BTRFS_I(inode)->outstanding_extents--; BTRFS_I(inode)->outstanding_extents--;
if (BTRFS_I(inode)->outstanding_extents == 0 && if (BTRFS_I(inode)->outstanding_extents == 0 &&
BTRFS_I(inode)->delalloc_meta_reserved) { test_and_clear_bit(BTRFS_INODE_DELALLOC_META_RESERVED,
&BTRFS_I(inode)->runtime_flags))
drop_inode_space = 1; drop_inode_space = 1;
BTRFS_I(inode)->delalloc_meta_reserved = 0;
}
/* /*
* If we have more or the same amount of outsanding extents than we have * If we have more or the same amount of outsanding extents than we have
...@@ -4465,7 +4464,8 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -4465,7 +4464,8 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
* Add an item to reserve for updating the inode when we complete the * Add an item to reserve for updating the inode when we complete the
* delalloc io. * delalloc io.
*/ */
if (!BTRFS_I(inode)->delalloc_meta_reserved) { if (!test_bit(BTRFS_INODE_DELALLOC_META_RESERVED,
&BTRFS_I(inode)->runtime_flags)) {
nr_extents++; nr_extents++;
extra_reserve = 1; extra_reserve = 1;
} }
...@@ -4511,7 +4511,8 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes) ...@@ -4511,7 +4511,8 @@ int btrfs_delalloc_reserve_metadata(struct inode *inode, u64 num_bytes)
spin_lock(&BTRFS_I(inode)->lock); spin_lock(&BTRFS_I(inode)->lock);
if (extra_reserve) { if (extra_reserve) {
BTRFS_I(inode)->delalloc_meta_reserved = 1; set_bit(BTRFS_INODE_DELALLOC_META_RESERVED,
&BTRFS_I(inode)->runtime_flags);
nr_extents--; nr_extents--;
} }
BTRFS_I(inode)->reserved_extents += nr_extents; BTRFS_I(inode)->reserved_extents += nr_extents;
......
...@@ -103,7 +103,7 @@ static void __btrfs_add_inode_defrag(struct inode *inode, ...@@ -103,7 +103,7 @@ static void __btrfs_add_inode_defrag(struct inode *inode,
goto exists; goto exists;
} }
} }
BTRFS_I(inode)->in_defrag = 1; set_bit(BTRFS_INODE_IN_DEFRAG, &BTRFS_I(inode)->runtime_flags);
rb_link_node(&defrag->rb_node, parent, p); rb_link_node(&defrag->rb_node, parent, p);
rb_insert_color(&defrag->rb_node, &root->fs_info->defrag_inodes); rb_insert_color(&defrag->rb_node, &root->fs_info->defrag_inodes);
return; return;
...@@ -131,7 +131,7 @@ int btrfs_add_inode_defrag(struct btrfs_trans_handle *trans, ...@@ -131,7 +131,7 @@ int btrfs_add_inode_defrag(struct btrfs_trans_handle *trans,
if (btrfs_fs_closing(root->fs_info)) if (btrfs_fs_closing(root->fs_info))
return 0; return 0;
if (BTRFS_I(inode)->in_defrag) if (test_bit(BTRFS_INODE_IN_DEFRAG, &BTRFS_I(inode)->runtime_flags))
return 0; return 0;
if (trans) if (trans)
...@@ -148,7 +148,7 @@ int btrfs_add_inode_defrag(struct btrfs_trans_handle *trans, ...@@ -148,7 +148,7 @@ int btrfs_add_inode_defrag(struct btrfs_trans_handle *trans,
defrag->root = root->root_key.objectid; defrag->root = root->root_key.objectid;
spin_lock(&root->fs_info->defrag_inodes_lock); spin_lock(&root->fs_info->defrag_inodes_lock);
if (!BTRFS_I(inode)->in_defrag) if (!test_bit(BTRFS_INODE_IN_DEFRAG, &BTRFS_I(inode)->runtime_flags))
__btrfs_add_inode_defrag(inode, defrag); __btrfs_add_inode_defrag(inode, defrag);
else else
kfree(defrag); kfree(defrag);
...@@ -252,7 +252,7 @@ int btrfs_run_defrag_inodes(struct btrfs_fs_info *fs_info) ...@@ -252,7 +252,7 @@ int btrfs_run_defrag_inodes(struct btrfs_fs_info *fs_info)
goto next; goto next;
/* do a chunk of defrag */ /* do a chunk of defrag */
BTRFS_I(inode)->in_defrag = 0; clear_bit(BTRFS_INODE_IN_DEFRAG, &BTRFS_I(inode)->runtime_flags);
range.start = defrag->last_offset; range.start = defrag->last_offset;
num_defrag = btrfs_defrag_file(inode, NULL, &range, defrag->transid, num_defrag = btrfs_defrag_file(inode, NULL, &range, defrag->transid,
defrag_batch); defrag_batch);
...@@ -1465,8 +1465,8 @@ int btrfs_release_file(struct inode *inode, struct file *filp) ...@@ -1465,8 +1465,8 @@ int btrfs_release_file(struct inode *inode, struct file *filp)
* flush down new bytes that may have been written if the * flush down new bytes that may have been written if the
* application were using truncate to replace a file in place. * application were using truncate to replace a file in place.
*/ */
if (BTRFS_I(inode)->ordered_data_close) { if (test_and_clear_bit(BTRFS_INODE_ORDERED_DATA_CLOSE,
BTRFS_I(inode)->ordered_data_close = 0; &BTRFS_I(inode)->runtime_flags)) {
btrfs_add_ordered_operation(NULL, BTRFS_I(inode)->root, inode); btrfs_add_ordered_operation(NULL, BTRFS_I(inode)->root, inode);
if (inode->i_size > BTRFS_ORDERED_OPERATIONS_FLUSH_LIMIT) if (inode->i_size > BTRFS_ORDERED_OPERATIONS_FLUSH_LIMIT)
filemap_flush(inode->i_mapping); filemap_flush(inode->i_mapping);
......
...@@ -2182,10 +2182,9 @@ int btrfs_orphan_add(struct btrfs_trans_handle *trans, struct inode *inode) ...@@ -2182,10 +2182,9 @@ int btrfs_orphan_add(struct btrfs_trans_handle *trans, struct inode *inode)
insert = 1; insert = 1;
} }
if (!BTRFS_I(inode)->orphan_meta_reserved) { if (!test_and_set_bit(BTRFS_INODE_ORPHAN_META_RESERVED,
BTRFS_I(inode)->orphan_meta_reserved = 1; &BTRFS_I(inode)->runtime_flags))
reserve = 1; reserve = 1;
}
spin_unlock(&root->orphan_lock); spin_unlock(&root->orphan_lock);
/* grab metadata reservation from transaction handle */ /* grab metadata reservation from transaction handle */
...@@ -2233,10 +2232,9 @@ int btrfs_orphan_del(struct btrfs_trans_handle *trans, struct inode *inode) ...@@ -2233,10 +2232,9 @@ int btrfs_orphan_del(struct btrfs_trans_handle *trans, struct inode *inode)
delete_item = 1; delete_item = 1;
} }
if (BTRFS_I(inode)->orphan_meta_reserved) { if (test_and_clear_bit(BTRFS_INODE_ORPHAN_META_RESERVED,
BTRFS_I(inode)->orphan_meta_reserved = 0; &BTRFS_I(inode)->runtime_flags))
release_rsv = 1; release_rsv = 1;
}
spin_unlock(&root->orphan_lock); spin_unlock(&root->orphan_lock);
if (trans && delete_item) { if (trans && delete_item) {
...@@ -3642,7 +3640,8 @@ static int btrfs_setsize(struct inode *inode, loff_t newsize) ...@@ -3642,7 +3640,8 @@ static int btrfs_setsize(struct inode *inode, loff_t newsize)
* any new writes get down to disk quickly. * any new writes get down to disk quickly.
*/ */
if (newsize == 0) if (newsize == 0)
BTRFS_I(inode)->ordered_data_close = 1; set_bit(BTRFS_INODE_ORDERED_DATA_CLOSE,
&BTRFS_I(inode)->runtime_flags);
/* we don't support swapfiles, so vmtruncate shouldn't fail */ /* we don't support swapfiles, so vmtruncate shouldn't fail */
truncate_setsize(inode, newsize); truncate_setsize(inode, newsize);
...@@ -4102,7 +4101,7 @@ static struct inode *new_simple_dir(struct super_block *s, ...@@ -4102,7 +4101,7 @@ static struct inode *new_simple_dir(struct super_block *s,
BTRFS_I(inode)->root = root; BTRFS_I(inode)->root = root;
memcpy(&BTRFS_I(inode)->location, key, sizeof(*key)); memcpy(&BTRFS_I(inode)->location, key, sizeof(*key));
BTRFS_I(inode)->dummy_inode = 1; set_bit(BTRFS_INODE_DUMMY, &BTRFS_I(inode)->runtime_flags);
inode->i_ino = BTRFS_EMPTY_SUBVOL_DIR_OBJECTID; inode->i_ino = BTRFS_EMPTY_SUBVOL_DIR_OBJECTID;
inode->i_op = &btrfs_dir_ro_inode_operations; inode->i_op = &btrfs_dir_ro_inode_operations;
...@@ -4406,7 +4405,7 @@ int btrfs_write_inode(struct inode *inode, struct writeback_control *wbc) ...@@ -4406,7 +4405,7 @@ int btrfs_write_inode(struct inode *inode, struct writeback_control *wbc)
int ret = 0; int ret = 0;
bool nolock = false; bool nolock = false;
if (BTRFS_I(inode)->dummy_inode) if (test_bit(BTRFS_INODE_DUMMY, &BTRFS_I(inode)->runtime_flags))
return 0; return 0;
if (btrfs_fs_closing(root->fs_info) && btrfs_is_free_space_inode(root, inode)) if (btrfs_fs_closing(root->fs_info) && btrfs_is_free_space_inode(root, inode))
...@@ -4439,7 +4438,7 @@ int btrfs_dirty_inode(struct inode *inode) ...@@ -4439,7 +4438,7 @@ int btrfs_dirty_inode(struct inode *inode)
struct btrfs_trans_handle *trans; struct btrfs_trans_handle *trans;
int ret; int ret;
if (BTRFS_I(inode)->dummy_inode) if (test_bit(BTRFS_INODE_DUMMY, &BTRFS_I(inode)->runtime_flags))
return 0; return 0;
trans = btrfs_join_transaction(root); trans = btrfs_join_transaction(root);
...@@ -6752,7 +6751,8 @@ static int btrfs_truncate(struct inode *inode) ...@@ -6752,7 +6751,8 @@ static int btrfs_truncate(struct inode *inode)
* using truncate to replace the contents of the file will * using truncate to replace the contents of the file will
* end up with a zero length file after a crash. * end up with a zero length file after a crash.
*/ */
if (inode->i_size == 0 && BTRFS_I(inode)->ordered_data_close) if (inode->i_size == 0 && test_bit(BTRFS_INODE_ORDERED_DATA_CLOSE,
&BTRFS_I(inode)->runtime_flags))
btrfs_add_ordered_operation(trans, root, inode); btrfs_add_ordered_operation(trans, root, inode);
while (1) { while (1) {
...@@ -6889,11 +6889,7 @@ struct inode *btrfs_alloc_inode(struct super_block *sb) ...@@ -6889,11 +6889,7 @@ struct inode *btrfs_alloc_inode(struct super_block *sb)
ei->outstanding_extents = 0; ei->outstanding_extents = 0;
ei->reserved_extents = 0; ei->reserved_extents = 0;
ei->ordered_data_close = 0; ei->runtime_flags = 0;
ei->orphan_meta_reserved = 0;
ei->dummy_inode = 0;
ei->in_defrag = 0;
ei->delalloc_meta_reserved = 0;
ei->force_compress = BTRFS_COMPRESS_NONE; ei->force_compress = BTRFS_COMPRESS_NONE;
ei->delayed_node = NULL; ei->delayed_node = NULL;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment