Rework btrfs_drop_inode to avoid scheduling
authorChris Mason <chris.mason@oracle.com>
Tue, 15 Jan 2008 13:40:48 +0000 (08:40 -0500)
committerChris Mason <chris.mason@oracle.com>
Thu, 25 Sep 2008 15:03:59 +0000 (11:03 -0400)
Signed-off-by: Chris Mason <chris.mason@oracle.com>
fs/btrfs/ctree.h
fs/btrfs/disk-io.c
fs/btrfs/inode.c
fs/btrfs/ordered-data.c
fs/btrfs/ordered-data.h
fs/btrfs/transaction.c

index a2c2d6d82c5eb017a3887402cab4bf5586da9ff5..1e19f2d86334c673bd60df793b4e4708d87c671d 100644 (file)
@@ -349,6 +349,7 @@ struct btrfs_fs_info {
 
        u64 total_pinned;
        spinlock_t delalloc_lock;
+       spinlock_t new_trans_lock;
        u64 delalloc_bytes;
 };
 /*
index 87daed632f370d31142b7e4ec8644e476db76ba7..cd29922d40738845915202e051bce0496d103a55 100644 (file)
@@ -639,6 +639,7 @@ struct btrfs_root *open_ctree(struct super_block *sb)
        INIT_LIST_HEAD(&fs_info->hashers);
        spin_lock_init(&fs_info->hash_lock);
        spin_lock_init(&fs_info->delalloc_lock);
+       spin_lock_init(&fs_info->new_trans_lock);
 
        memset(&fs_info->super_kobj, 0, sizeof(fs_info->super_kobj));
        init_completion(&fs_info->kobj_unregister);
index e53d2033164614c72942e8bbd1fd76abc1996060..008e3445748ef95b3d7d42da3d7ce815f005553c 100644 (file)
@@ -993,20 +993,13 @@ fail:
 
 void btrfs_drop_inode(struct inode *inode)
 {
-       struct btrfs_trans_handle *trans;
-       struct btrfs_root *root = BTRFS_I(inode)->root;
-
-       if (!BTRFS_I(inode)->ordered_trans) {
+       if (!BTRFS_I(inode)->ordered_trans || inode->i_nlink) {
                generic_drop_inode(inode);
                return;
        }
-       /* nasty, but it prevents a deadlock with data=ordered by preventing
-        * a commit until after this inode is done
-        */
-       trans = btrfs_start_transaction(root, 1);
+       /* FIXME, make sure this delete actually ends up in the transaction */
+       btrfs_del_ordered_inode(inode);
        generic_drop_inode(inode);
-       /* note, the inode is now untouchable */
-       btrfs_end_transaction(trans, root);
 }
 
 void btrfs_delete_inode(struct inode *inode)
index 411aba84d305466a0f3ae62b774c7a487f05f9e3..b56011baa17cc88d6ec8784bdb46644112b7de98 100644 (file)
@@ -219,3 +219,39 @@ int btrfs_find_del_first_ordered_inode(struct btrfs_ordered_inode_tree *tree,
        kfree(entry);
        return 1;
 }
+
+static int __btrfs_del_ordered_inode(struct btrfs_ordered_inode_tree *tree,
+                                    u64 root_objectid, u64 objectid)
+{
+       struct tree_entry *entry;
+       struct rb_node *node;
+       struct rb_node *prev;
+
+       write_lock(&tree->lock);
+       node = __tree_search(&tree->tree, root_objectid, objectid, &prev);
+       if (!node) {
+               write_unlock(&tree->lock);
+               return 0;
+       }
+       rb_erase(node, &tree->tree);
+       write_unlock(&tree->lock);
+       entry = rb_entry(node, struct tree_entry, rb_node);
+       kfree(entry);
+       return 1;
+}
+
+int btrfs_del_ordered_inode(struct inode *inode)
+{
+       struct btrfs_root *root = BTRFS_I(inode)->root;
+       u64 root_objectid = root->root_key.objectid;
+
+       spin_lock(&root->fs_info->new_trans_lock);
+       if (root->fs_info->running_transaction) {
+               struct btrfs_ordered_inode_tree *tree;
+               tree = &root->fs_info->running_transaction->ordered_inode_tree;
+               __btrfs_del_ordered_inode(tree, root_objectid, inode->i_ino);
+       }
+       spin_unlock(&root->fs_info->new_trans_lock);
+       return 0;
+}
+
index aaf9eb142719828d45ea8adf5757d88571293526..26b26212865b0a3b5cdc5d20ebc969e77077c6f8 100644 (file)
@@ -36,4 +36,5 @@ int btrfs_find_del_first_ordered_inode(struct btrfs_ordered_inode_tree *tree,
                                       u64 *root_objectid, u64 *objectid);
 int btrfs_find_first_ordered_inode(struct btrfs_ordered_inode_tree *tree,
                                       u64 *root_objectid, u64 *objectid);
+int btrfs_del_ordered_inode(struct inode *inode);
 #endif
index 614903f5c88444f9faaf1d13b086d384646b3e0e..a3205808ab2b9851c0cdd0007ded8caaaa13040b 100644 (file)
@@ -699,7 +699,9 @@ int btrfs_commit_transaction(struct btrfs_trans_handle *trans,
        BUG_ON(ret);
 
        cur_trans = root->fs_info->running_transaction;
+       spin_lock(&root->fs_info->new_trans_lock);
        root->fs_info->running_transaction = NULL;
+       spin_unlock(&root->fs_info->new_trans_lock);
        btrfs_set_super_generation(&root->fs_info->super_copy,
                                   cur_trans->transid);
        btrfs_set_super_root(&root->fs_info->super_copy,