Lines Matching refs:delayed_root
204 struct btrfs_delayed_root *delayed_root) in btrfs_first_delayed_node() argument
209 spin_lock(&delayed_root->lock); in btrfs_first_delayed_node()
210 if (list_empty(&delayed_root->node_list)) in btrfs_first_delayed_node()
213 p = delayed_root->node_list.next; in btrfs_first_delayed_node()
217 spin_unlock(&delayed_root->lock); in btrfs_first_delayed_node()
225 struct btrfs_delayed_root *delayed_root; in btrfs_next_delayed_node() local
229 delayed_root = node->root->fs_info->delayed_root; in btrfs_next_delayed_node()
230 spin_lock(&delayed_root->lock); in btrfs_next_delayed_node()
233 if (list_empty(&delayed_root->node_list)) in btrfs_next_delayed_node()
235 p = delayed_root->node_list.next; in btrfs_next_delayed_node()
236 } else if (list_is_last(&node->n_list, &delayed_root->node_list)) in btrfs_next_delayed_node()
244 spin_unlock(&delayed_root->lock); in btrfs_next_delayed_node()
253 struct btrfs_delayed_root *delayed_root; in __btrfs_release_delayed_node() local
258 delayed_root = delayed_node->root->fs_info->delayed_root; in __btrfs_release_delayed_node()
262 btrfs_queue_delayed_node(delayed_root, delayed_node, mod); in __btrfs_release_delayed_node()
264 btrfs_dequeue_delayed_node(delayed_root, delayed_node); in __btrfs_release_delayed_node()
289 struct btrfs_delayed_root *delayed_root) in btrfs_first_prepared_delayed_node() argument
294 spin_lock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
295 if (list_empty(&delayed_root->prepare_list)) in btrfs_first_prepared_delayed_node()
298 p = delayed_root->prepare_list.next; in btrfs_first_prepared_delayed_node()
303 spin_unlock(&delayed_root->lock); in btrfs_first_prepared_delayed_node()
441 atomic_inc(&delayed_node->root->fs_info->delayed_root->items); in __btrfs_add_delayed_item()
459 static void finish_one_item(struct btrfs_delayed_root *delayed_root) in finish_one_item() argument
461 int seq = atomic_inc_return(&delayed_root->items_seq); in finish_one_item()
464 if ((atomic_dec_return(&delayed_root->items) < in finish_one_item()
466 cond_wake_up_nomb(&delayed_root->wait); in finish_one_item()
472 struct btrfs_delayed_root *delayed_root; in __btrfs_remove_delayed_item() local
474 delayed_root = delayed_item->delayed_node->root->fs_info->delayed_root; in __btrfs_remove_delayed_item()
476 BUG_ON(!delayed_root); in __btrfs_remove_delayed_item()
488 finish_one_item(delayed_root); in __btrfs_remove_delayed_item()
977 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_inode() local
985 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_inode()
986 finish_one_item(delayed_root); in btrfs_release_delayed_inode()
992 struct btrfs_delayed_root *delayed_root; in btrfs_release_delayed_iref() local
998 delayed_root = delayed_node->root->fs_info->delayed_root; in btrfs_release_delayed_iref()
999 finish_one_item(delayed_root); in btrfs_release_delayed_iref()
1131 struct btrfs_delayed_root *delayed_root; in __btrfs_run_delayed_items() local
1149 delayed_root = fs_info->delayed_root; in __btrfs_run_delayed_items()
1151 curr_node = btrfs_first_delayed_node(delayed_root); in __btrfs_run_delayed_items()
1291 struct btrfs_delayed_root *delayed_root; member
1299 struct btrfs_delayed_root *delayed_root; in btrfs_async_run_delayed_root() local
1308 delayed_root = async_work->delayed_root; in btrfs_async_run_delayed_root()
1315 if (atomic_read(&delayed_root->items) < in btrfs_async_run_delayed_root()
1319 delayed_node = btrfs_first_prepared_delayed_node(delayed_root); in btrfs_async_run_delayed_root()
1352 wake_up(&delayed_root->wait); in btrfs_async_run_delayed_root()
1357 static int btrfs_wq_run_delayed_node(struct btrfs_delayed_root *delayed_root, in btrfs_wq_run_delayed_node() argument
1366 async_work->delayed_root = delayed_root; in btrfs_wq_run_delayed_node()
1377 WARN_ON(btrfs_first_delayed_node(fs_info->delayed_root)); in btrfs_assert_delayed_root_empty()
1380 static int could_end_wait(struct btrfs_delayed_root *delayed_root, int seq) in could_end_wait() argument
1382 int val = atomic_read(&delayed_root->items_seq); in could_end_wait()
1387 if (atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) in could_end_wait()
1395 struct btrfs_delayed_root *delayed_root = fs_info->delayed_root; in btrfs_balance_delayed_items() local
1397 if ((atomic_read(&delayed_root->items) < BTRFS_DELAYED_BACKGROUND) || in btrfs_balance_delayed_items()
1401 if (atomic_read(&delayed_root->items) >= BTRFS_DELAYED_WRITEBACK) { in btrfs_balance_delayed_items()
1405 seq = atomic_read(&delayed_root->items_seq); in btrfs_balance_delayed_items()
1407 ret = btrfs_wq_run_delayed_node(delayed_root, fs_info, 0); in btrfs_balance_delayed_items()
1411 wait_event_interruptible(delayed_root->wait, in btrfs_balance_delayed_items()
1412 could_end_wait(delayed_root, seq)); in btrfs_balance_delayed_items()
1416 btrfs_wq_run_delayed_node(delayed_root, fs_info, BTRFS_DELAYED_BATCH); in btrfs_balance_delayed_items()
1829 atomic_inc(&root->fs_info->delayed_root->items); in btrfs_delayed_update_inode()
1873 atomic_inc(&fs_info->delayed_root->items); in btrfs_delayed_delete_inode_ref()
1958 curr_node = btrfs_first_delayed_node(fs_info->delayed_root); in btrfs_destroy_delayed_inodes()