Btrfs: collect only the necessary ordered extents on ranged fsync
authorFilipe Manana <fdmanana@suse.com>
Thu, 13 Nov 2014 17:00:35 +0000 (17:00 +0000)
committerChris Mason <clm@fb.com>
Fri, 21 Nov 2014 19:59:56 +0000 (11:59 -0800)
Instead of collecting all ordered extents from the inode's ordered tree
and then wait for all of them to complete, just collect the ones that
overlap the fsync range.

Signed-off-by: Filipe Manana <fdmanana@suse.com>
Signed-off-by: Chris Mason <clm@fb.com>
fs/btrfs/ordered-data.c
fs/btrfs/ordered-data.h
fs/btrfs/tree-log.c

index 9c28eb4da4dd0451dd985a8a98eb0b1507091e34..534544e08f769486a97c3c7f3719bed982500783 100644 (file)
@@ -432,21 +432,31 @@ out:
 
 /* Needs to either be called under a log transaction or the log_mutex */
 void btrfs_get_logged_extents(struct inode *inode,
-                             struct list_head *logged_list)
+                             struct list_head *logged_list,
+                             const loff_t start,
+                             const loff_t end)
 {
        struct btrfs_ordered_inode_tree *tree;
        struct btrfs_ordered_extent *ordered;
        struct rb_node *n;
+       struct rb_node *prev;
 
        tree = &BTRFS_I(inode)->ordered_tree;
        spin_lock_irq(&tree->lock);
-       for (n = rb_first(&tree->tree); n; n = rb_next(n)) {
+       n = __tree_search(&tree->tree, end, &prev);
+       if (!n)
+               n = prev;
+       for (; n; n = rb_prev(n)) {
                ordered = rb_entry(n, struct btrfs_ordered_extent, rb_node);
+               if (ordered->file_offset > end)
+                       continue;
+               if (entry_end(ordered) <= start)
+                       break;
                if (!list_empty(&ordered->log_list))
                        continue;
                if (test_bit(BTRFS_ORDERED_LOGGED, &ordered->flags))
                        continue;
-               list_add_tail(&ordered->log_list, logged_list);
+               list_add(&ordered->log_list, logged_list);
                atomic_inc(&ordered->refs);
        }
        spin_unlock_irq(&tree->lock);
index 0124bffc775fd5e5aad8a750f2e9094ff904b27c..e96cd4ccd805d9220b997518e7b7e9d85ef890d4 100644 (file)
@@ -198,7 +198,9 @@ int btrfs_find_ordered_sum(struct inode *inode, u64 offset, u64 disk_bytenr,
 int btrfs_wait_ordered_extents(struct btrfs_root *root, int nr);
 void btrfs_wait_ordered_roots(struct btrfs_fs_info *fs_info, int nr);
 void btrfs_get_logged_extents(struct inode *inode,
-                             struct list_head *logged_list);
+                             struct list_head *logged_list,
+                             const loff_t start,
+                             const loff_t end);
 void btrfs_put_logged_extents(struct list_head *logged_list);
 void btrfs_submit_logged_extents(struct list_head *logged_list,
                                 struct btrfs_root *log);
index afe483cb27b02fd41eb607934105be6204ee7cf5..3883d0febd820201ed7abb239a680569aa5cbd25 100644 (file)
@@ -3972,7 +3972,7 @@ static int btrfs_log_inode(struct btrfs_trans_handle *trans,
 
        mutex_lock(&BTRFS_I(inode)->log_mutex);
 
-       btrfs_get_logged_extents(inode, &logged_list);
+       btrfs_get_logged_extents(inode, &logged_list, start, end);
 
        /*
         * a brute force approach to making sure we get the most uptodate