Lines Matching refs:delayed_root
42 void btrfs_init_delayed_root(struct btrfs_delayed_root *delayed_root) in btrfs_init_delayed_root() argument
44 atomic_set(&delayed_root->items, 0); in btrfs_init_delayed_root()
45 atomic_set(&delayed_root->items_seq, 0); in btrfs_init_delayed_root()
46 delayed_root->nodes = 0; in btrfs_init_delayed_root()
47 spin_lock_init(&delayed_root->lock); in btrfs_init_delayed_root()
48 init_waitqueue_head(&delayed_root->wait); in btrfs_init_delayed_root()
49 INIT_LIST_HEAD(&delayed_root->node_list); in btrfs_init_delayed_root()
50 INIT_LIST_HEAD(&delayed_root->prepare_list); in btrfs_init_delayed_root()
212 struct btrfs_delayed_root *delayed_root) in btrfs_first_delayed_node() argument
217 spin_lock(&delayed_root->lock); in btrfs_first_delayed_node()
218 if (list_empty(&delayed_root->node_list)) in btrfs_first_delayed_node()
221 p = delayed_root->node_list.next; in btrfs_first_delayed_node()
225 spin_unlock(&delayed_root->lock); in btrfs_first_delayed_node()
233 struct btrfs_delayed_root *delayed_root; in btrfs_next_delayed_node() local
237 delayed_root = node->root->fs_info->delayed_root; in btrfs_next_delayed_node()
238 spin_lock(&delayed_root->lock); in btrfs_next_delayed_node()
241 if (list_empty(&delayed_root->node_list)) in btrfs_next_delayed_node()
243 p = delayed_root->node_list.next; in btrfs_next_delayed_node()
244 } else if (list_is_last(&node->n_list, &delayed_root->node_list)) in btrfs_next_delayed_node()
252 spin_unlock(&delayed_root->lock); in btrfs_next_delayed_node()
261 struct btrfs_delayed_root *delayed_root; in __btrfs_release_delayed_node() local
266 delayed_root = delayed_node->root->fs_info->delayed_root; in __btrfs_release_delayed_node()
270 btrfs_queue_delayed_node(delayed_root, delayed_node, mod); in __btrfs_release_delayed_node()
272 btrfs_dequeue_delayed_node(delayed_root, delayed_node); in __btrfs_release_delayed_node()
294 struct btrfs_delayed_root *delayed_root) in btrfs_first_prepared_delayed_node() argument
299 spin_lock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
300 if (list_empty(&delayed_root->prepare_list)) in btrfs_first_prepared_delayed_node()
303 p = delayed_root->prepare_list.next; in btrfs_first_prepared_delayed_node()
308 spin_unlock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
409 atomic_inc(&delayed_node->root->fs_info->delayed_root->items); in __btrfs_add_delayed_item()
413 static void finish_one_item(struct btrfs_delayed_root *delayed_root) in finish_one_item() argument
415 int seq = atomic_inc_return(&delayed_root->items_seq); in finish_one_item()
418 if ((atomic_dec_return(&delayed_root->items) < in finish_one_item()
420 cond_wake_up_nomb(&delayed_root->wait); in finish_one_item()
427 struct btrfs_delayed_root *delayed_root; in __btrfs_remove_delayed_item() local
436 delayed_root = delayed_node->root->fs_info->delayed_root; in __btrfs_remove_delayed_item()
447 finish_one_item(delayed_root); in __btrfs_remove_delayed_item()
982 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_inode() local
990 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_inode()
991 finish_one_item(delayed_root); in btrfs_release_delayed_inode()
999 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_iref() local
1004 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_iref()
1005 finish_one_item(delayed_root); in btrfs_release_delayed_iref()
1150 struct btrfs_delayed_root *delayed_root; in __btrfs_run_delayed_items() local
1167 delayed_root = fs_info->delayed_root; in __btrfs_run_delayed_items()
1169 curr_node = btrfs_first_delayed_node(delayed_root); in __btrfs_run_delayed_items()
1320 struct btrfs_delayed_root *delayed_root; member
1328 struct btrfs_delayed_root *delayed_root; in btrfs_async_run_delayed_root() local
1337 delayed_root = async_work->delayed_root; in btrfs_async_run_delayed_root()
1344 if (atomic_read(&delayed_root->items) < in btrfs_async_run_delayed_root()
1348 delayed_node = btrfs_first_prepared_delayed_node(delayed_root); in btrfs_async_run_delayed_root()
1380 wake_up(&delayed_root->wait); in btrfs_async_run_delayed_root()
1385 static int btrfs_wq_run_delayed_node(struct btrfs_delayed_root *delayed_root, in btrfs_wq_run_delayed_node() argument
1394 async_work->delayed_root = delayed_root; in btrfs_wq_run_delayed_node()
1404 WARN_ON(btrfs_first_delayed_node(fs_info->delayed_root)); in btrfs_assert_delayed_root_empty()
1407 static int could_end_wait(struct btrfs_delayed_root *delayed_root, int seq) in could_end_wait() argument
1409 int val = atomic_read(&delayed_root->items_seq); in could_end_wait()
1414 if (atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) in could_end_wait()
1422 struct btrfs_delayed_root *delayed_root = fs_info->delayed_root; in btrfs_balance_delayed_items() local
1424 if ((atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) || in btrfs_balance_delayed_items()
1428 if (atomic_read(&delayed_root->items) >= BTRFS_DELAYED_WRITEBACK) { in btrfs_balance_delayed_items()
1432 seq = atomic_read(&delayed_root->items_seq); in btrfs_balance_delayed_items()
1434 ret = btrfs_wq_run_delayed_node(delayed_root, fs_info, 0); in btrfs_balance_delayed_items()
1438 wait_event_interruptible(delayed_root->wait, in btrfs_balance_delayed_items()
1439 could_end_wait(delayed_root, seq)); in btrfs_balance_delayed_items()
1443 btrfs_wq_run_delayed_node(delayed_root, fs_info, BTRFS_DELAYED_BATCH); in btrfs_balance_delayed_items()
1950 atomic_inc(&root->fs_info->delayed_root->items); in btrfs_delayed_update_inode()
1994 atomic_inc(&fs_info->delayed_root->items); in btrfs_delayed_delete_inode_ref()
2092 curr_node = btrfs_first_delayed_node(fs_info->delayed_root); in btrfs_destroy_delayed_inodes()