Lines Matching refs:delayed_root
206 struct btrfs_delayed_root *delayed_root) in btrfs_first_delayed_node() argument
211 spin_lock(&delayed_root->lock); in btrfs_first_delayed_node()
212 if (list_empty(&delayed_root->node_list)) in btrfs_first_delayed_node()
215 p = delayed_root->node_list.next; in btrfs_first_delayed_node()
219 spin_unlock(&delayed_root->lock); in btrfs_first_delayed_node()
227 struct btrfs_delayed_root *delayed_root; in btrfs_next_delayed_node() local
231 delayed_root = node->root->fs_info->delayed_root; in btrfs_next_delayed_node()
232 spin_lock(&delayed_root->lock); in btrfs_next_delayed_node()
235 if (list_empty(&delayed_root->node_list)) in btrfs_next_delayed_node()
237 p = delayed_root->node_list.next; in btrfs_next_delayed_node()
238 } else if (list_is_last(&node->n_list, &delayed_root->node_list)) in btrfs_next_delayed_node()
246 spin_unlock(&delayed_root->lock); in btrfs_next_delayed_node()
255 struct btrfs_delayed_root *delayed_root; in __btrfs_release_delayed_node() local
260 delayed_root = delayed_node->root->fs_info->delayed_root; in __btrfs_release_delayed_node()
264 btrfs_queue_delayed_node(delayed_root, delayed_node, mod); in __btrfs_release_delayed_node()
266 btrfs_dequeue_delayed_node(delayed_root, delayed_node); in __btrfs_release_delayed_node()
291 struct btrfs_delayed_root *delayed_root) in btrfs_first_prepared_delayed_node() argument
296 spin_lock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
297 if (list_empty(&delayed_root->prepare_list)) in btrfs_first_prepared_delayed_node()
300 p = delayed_root->prepare_list.next; in btrfs_first_prepared_delayed_node()
305 spin_unlock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
446 atomic_inc(&delayed_node->root->fs_info->delayed_root->items); in __btrfs_add_delayed_item()
464 static void finish_one_item(struct btrfs_delayed_root *delayed_root) in finish_one_item() argument
466 int seq = atomic_inc_return(&delayed_root->items_seq); in finish_one_item()
469 if ((atomic_dec_return(&delayed_root->items) < in finish_one_item()
471 cond_wake_up_nomb(&delayed_root->wait); in finish_one_item()
477 struct btrfs_delayed_root *delayed_root; in __btrfs_remove_delayed_item() local
482 delayed_root = delayed_item->delayed_node->root->fs_info->delayed_root; in __btrfs_remove_delayed_item()
484 BUG_ON(!delayed_root); in __btrfs_remove_delayed_item()
496 finish_one_item(delayed_root); in __btrfs_remove_delayed_item()
900 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_inode() local
908 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_inode()
909 finish_one_item(delayed_root); in btrfs_release_delayed_inode()
917 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_iref() local
922 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_iref()
923 finish_one_item(delayed_root); in btrfs_release_delayed_iref()
1062 struct btrfs_delayed_root *delayed_root; in __btrfs_run_delayed_items() local
1079 delayed_root = fs_info->delayed_root; in __btrfs_run_delayed_items()
1081 curr_node = btrfs_first_delayed_node(delayed_root); in __btrfs_run_delayed_items()
1219 struct btrfs_delayed_root *delayed_root; member
1227 struct btrfs_delayed_root *delayed_root; in btrfs_async_run_delayed_root() local
1236 delayed_root = async_work->delayed_root; in btrfs_async_run_delayed_root()
1243 if (atomic_read(&delayed_root->items) < in btrfs_async_run_delayed_root()
1247 delayed_node = btrfs_first_prepared_delayed_node(delayed_root); in btrfs_async_run_delayed_root()
1279 wake_up(&delayed_root->wait); in btrfs_async_run_delayed_root()
1284 static int btrfs_wq_run_delayed_node(struct btrfs_delayed_root *delayed_root, in btrfs_wq_run_delayed_node() argument
1293 async_work->delayed_root = delayed_root; in btrfs_wq_run_delayed_node()
1304 WARN_ON(btrfs_first_delayed_node(fs_info->delayed_root)); in btrfs_assert_delayed_root_empty()
1307 static int could_end_wait(struct btrfs_delayed_root *delayed_root, int seq) in could_end_wait() argument
1309 int val = atomic_read(&delayed_root->items_seq); in could_end_wait()
1314 if (atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) in could_end_wait()
1322 struct btrfs_delayed_root *delayed_root = fs_info->delayed_root; in btrfs_balance_delayed_items() local
1324 if ((atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) || in btrfs_balance_delayed_items()
1328 if (atomic_read(&delayed_root->items) >= BTRFS_DELAYED_WRITEBACK) { in btrfs_balance_delayed_items()
1332 seq = atomic_read(&delayed_root->items_seq); in btrfs_balance_delayed_items()
1334 ret = btrfs_wq_run_delayed_node(delayed_root, fs_info, 0); in btrfs_balance_delayed_items()
1338 wait_event_interruptible(delayed_root->wait, in btrfs_balance_delayed_items()
1339 could_end_wait(delayed_root, seq)); in btrfs_balance_delayed_items()
1343 btrfs_wq_run_delayed_node(delayed_root, fs_info, BTRFS_DELAYED_BATCH); in btrfs_balance_delayed_items()
1772 atomic_inc(&root->fs_info->delayed_root->items); in btrfs_delayed_update_inode()
1816 atomic_inc(&fs_info->delayed_root->items); in btrfs_delayed_delete_inode_ref()
1907 curr_node = btrfs_first_delayed_node(fs_info->delayed_root); in btrfs_destroy_delayed_inodes()