^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) /* SPDX-License-Identifier: GPL-2.0 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * Copyright (C) 2011 Fujitsu. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) * Written by Miao Xie <miaox@cn.fujitsu.com>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) #ifndef BTRFS_DELAYED_INODE_H
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) #define BTRFS_DELAYED_INODE_H
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #include <linux/rbtree.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/spinlock.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/mutex.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/list.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/wait.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <linux/atomic.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) #include <linux/refcount.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include "ctree.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) /* types of the delayed item */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) #define BTRFS_DELAYED_INSERTION_ITEM 1
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) #define BTRFS_DELAYED_DELETION_ITEM 2
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) struct btrfs_delayed_root {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) spinlock_t lock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) struct list_head node_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) * Used for delayed nodes which is waiting to be dealt with by the
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) * worker. If the delayed node is inserted into the work queue, we
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) * drop it from this list.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) struct list_head prepare_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) atomic_t items; /* for delayed items */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) atomic_t items_seq; /* for delayed items */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) int nodes; /* for delayed nodes */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) wait_queue_head_t wait;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) #define BTRFS_DELAYED_NODE_IN_LIST 0
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) #define BTRFS_DELAYED_NODE_INODE_DIRTY 1
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) #define BTRFS_DELAYED_NODE_DEL_IREF 2
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) struct btrfs_delayed_node {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) u64 inode_id;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) u64 bytes_reserved;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) struct btrfs_root *root;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) /* Used to add the node into the delayed root's node list. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47) struct list_head n_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) * Used to add the node into the prepare list, the nodes in this list
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) * is waiting to be dealt with by the async worker.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) struct list_head p_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) struct rb_root_cached ins_root;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) struct rb_root_cached del_root;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) struct mutex mutex;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) struct btrfs_inode_item inode_item;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) refcount_t refs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) u64 index_cnt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) int count;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) struct btrfs_delayed_item {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) struct rb_node rb_node;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) struct btrfs_key key;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) struct list_head tree_list; /* used for batch insert/delete items */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) struct list_head readdir_list; /* used for readdir items */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) u64 bytes_reserved;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) struct btrfs_delayed_node *delayed_node;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) refcount_t refs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) int ins_or_del;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) u32 data_len;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) char data[];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) static inline void btrfs_init_delayed_root(
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) struct btrfs_delayed_root *delayed_root)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) atomic_set(&delayed_root->items, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) atomic_set(&delayed_root->items_seq, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) delayed_root->nodes = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) spin_lock_init(&delayed_root->lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) init_waitqueue_head(&delayed_root->wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) INIT_LIST_HEAD(&delayed_root->node_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) INIT_LIST_HEAD(&delayed_root->prepare_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) int btrfs_insert_delayed_dir_index(struct btrfs_trans_handle *trans,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) const char *name, int name_len,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) struct btrfs_inode *dir,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) struct btrfs_disk_key *disk_key, u8 type,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) u64 index);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) int btrfs_delete_delayed_dir_index(struct btrfs_trans_handle *trans,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) struct btrfs_inode *dir, u64 index);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) int btrfs_inode_delayed_dir_index_count(struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) int btrfs_run_delayed_items(struct btrfs_trans_handle *trans);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) int btrfs_run_delayed_items_nr(struct btrfs_trans_handle *trans, int nr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) void btrfs_balance_delayed_items(struct btrfs_fs_info *fs_info);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) int btrfs_commit_inode_delayed_items(struct btrfs_trans_handle *trans,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) /* Used for evicting the inode. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) void btrfs_remove_delayed_node(struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) void btrfs_kill_delayed_inode_items(struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) int btrfs_commit_inode_delayed_inode(struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) int btrfs_delayed_update_inode(struct btrfs_trans_handle *trans,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) struct btrfs_root *root, struct inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) int btrfs_fill_inode(struct inode *inode, u32 *rdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) int btrfs_delayed_delete_inode_ref(struct btrfs_inode *inode);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) /* Used for drop dead root */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) void btrfs_kill_all_delayed_nodes(struct btrfs_root *root);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) /* Used for clean the transaction */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) void btrfs_destroy_delayed_inodes(struct btrfs_fs_info *fs_info);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) /* Used for readdir() */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) bool btrfs_readdir_get_delayed_items(struct inode *inode,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) struct list_head *ins_list,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) struct list_head *del_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) void btrfs_readdir_put_delayed_items(struct inode *inode,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) struct list_head *ins_list,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) struct list_head *del_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) int btrfs_should_delete_dir_index(struct list_head *del_list,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) u64 index);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) int btrfs_readdir_delayed_dir_index(struct dir_context *ctx,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) struct list_head *ins_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) /* for init */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) int __init btrfs_delayed_inode_init(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) void __cold btrfs_delayed_inode_exit(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) /* for debugging */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) void btrfs_assert_delayed_root_empty(struct btrfs_fs_info *fs_info);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) #endif