Lines Matching refs:delayed_root
195 struct btrfs_delayed_root *delayed_root) in btrfs_first_delayed_node() argument
200 spin_lock(&delayed_root->lock); in btrfs_first_delayed_node()
201 if (list_empty(&delayed_root->node_list)) in btrfs_first_delayed_node()
204 p = delayed_root->node_list.next; in btrfs_first_delayed_node()
208 spin_unlock(&delayed_root->lock); in btrfs_first_delayed_node()
216 struct btrfs_delayed_root *delayed_root; in btrfs_next_delayed_node() local
220 delayed_root = node->root->fs_info->delayed_root; in btrfs_next_delayed_node()
221 spin_lock(&delayed_root->lock); in btrfs_next_delayed_node()
224 if (list_empty(&delayed_root->node_list)) in btrfs_next_delayed_node()
226 p = delayed_root->node_list.next; in btrfs_next_delayed_node()
227 } else if (list_is_last(&node->n_list, &delayed_root->node_list)) in btrfs_next_delayed_node()
235 spin_unlock(&delayed_root->lock); in btrfs_next_delayed_node()
244 struct btrfs_delayed_root *delayed_root; in __btrfs_release_delayed_node() local
249 delayed_root = delayed_node->root->fs_info->delayed_root; in __btrfs_release_delayed_node()
253 btrfs_queue_delayed_node(delayed_root, delayed_node, mod); in __btrfs_release_delayed_node()
255 btrfs_dequeue_delayed_node(delayed_root, delayed_node); in __btrfs_release_delayed_node()
280 struct btrfs_delayed_root *delayed_root) in btrfs_first_prepared_delayed_node() argument
285 spin_lock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
286 if (list_empty(&delayed_root->prepare_list)) in btrfs_first_prepared_delayed_node()
289 p = delayed_root->prepare_list.next; in btrfs_first_prepared_delayed_node()
294 spin_unlock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
394 atomic_inc(&delayed_node->root->fs_info->delayed_root->items); in __btrfs_add_delayed_item()
398 static void finish_one_item(struct btrfs_delayed_root *delayed_root) in finish_one_item() argument
400 int seq = atomic_inc_return(&delayed_root->items_seq); in finish_one_item()
403 if ((atomic_dec_return(&delayed_root->items) < in finish_one_item()
405 cond_wake_up_nomb(&delayed_root->wait); in finish_one_item()
411 struct btrfs_delayed_root *delayed_root; in __btrfs_remove_delayed_item() local
417 delayed_root = delayed_item->delayed_node->root->fs_info->delayed_root; in __btrfs_remove_delayed_item()
419 BUG_ON(!delayed_root); in __btrfs_remove_delayed_item()
430 finish_one_item(delayed_root); in __btrfs_remove_delayed_item()
965 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_inode() local
973 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_inode()
974 finish_one_item(delayed_root); in btrfs_release_delayed_inode()
982 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_iref() local
987 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_iref()
988 finish_one_item(delayed_root); in btrfs_release_delayed_iref()
1127 struct btrfs_delayed_root *delayed_root; in __btrfs_run_delayed_items() local
1144 delayed_root = fs_info->delayed_root; in __btrfs_run_delayed_items()
1146 curr_node = btrfs_first_delayed_node(delayed_root); in __btrfs_run_delayed_items()
1284 struct btrfs_delayed_root *delayed_root; member
1292 struct btrfs_delayed_root *delayed_root; in btrfs_async_run_delayed_root() local
1301 delayed_root = async_work->delayed_root; in btrfs_async_run_delayed_root()
1308 if (atomic_read(&delayed_root->items) < in btrfs_async_run_delayed_root()
1312 delayed_node = btrfs_first_prepared_delayed_node(delayed_root); in btrfs_async_run_delayed_root()
1344 wake_up(&delayed_root->wait); in btrfs_async_run_delayed_root()
1349 static int btrfs_wq_run_delayed_node(struct btrfs_delayed_root *delayed_root, in btrfs_wq_run_delayed_node() argument
1358 async_work->delayed_root = delayed_root; in btrfs_wq_run_delayed_node()
1369 WARN_ON(btrfs_first_delayed_node(fs_info->delayed_root)); in btrfs_assert_delayed_root_empty()
1372 static int could_end_wait(struct btrfs_delayed_root *delayed_root, int seq) in could_end_wait() argument
1374 int val = atomic_read(&delayed_root->items_seq); in could_end_wait()
1379 if (atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) in could_end_wait()
1387 struct btrfs_delayed_root *delayed_root = fs_info->delayed_root; in btrfs_balance_delayed_items() local
1389 if ((atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) || in btrfs_balance_delayed_items()
1393 if (atomic_read(&delayed_root->items) >= BTRFS_DELAYED_WRITEBACK) { in btrfs_balance_delayed_items()
1397 seq = atomic_read(&delayed_root->items_seq); in btrfs_balance_delayed_items()
1399 ret = btrfs_wq_run_delayed_node(delayed_root, fs_info, 0); in btrfs_balance_delayed_items()
1403 wait_event_interruptible(delayed_root->wait, in btrfs_balance_delayed_items()
1404 could_end_wait(delayed_root, seq)); in btrfs_balance_delayed_items()
1408 btrfs_wq_run_delayed_node(delayed_root, fs_info, BTRFS_DELAYED_BATCH); in btrfs_balance_delayed_items()
1900 atomic_inc(&root->fs_info->delayed_root->items); in btrfs_delayed_update_inode()
1944 atomic_inc(&fs_info->delayed_root->items); in btrfs_delayed_delete_inode_ref()
2040 curr_node = btrfs_first_delayed_node(fs_info->delayed_root); in btrfs_destroy_delayed_inodes()