MIRRORS/linux-yocto
1
0
Fork 0
mirror of git://git.yoctoproject.org/linux-yocto.git synced 2025-10-23 07:23:12 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

bcachefs: Use separate rhltable for bch2_inode_or_descendents_is_open()

Browse Source 
Signed-off-by: Kent Overstreet <kent.overstreet@linux.dev>
This commit is contained in:
Kent Overstreet 2024-11-24 20:15:30 -05:00
parent 375d21b76d
commit 525be09e63
3 changed files with 32 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
fs/bcachefs/bcachefs.h
View File

@ -1020,6 +1020,7 @@ struct bch_fs {
struct list_head vfs_inodes_list; struct list_head vfs_inodes_list;
struct mutex vfs_inodes_lock; struct mutex vfs_inodes_lock;
struct rhashtable vfs_inodes_table; struct rhashtable vfs_inodes_table;
struct rhltable vfs_inodes_by_inum_table;
/* VFS IO PATH - fs-io.c */ /* VFS IO PATH - fs-io.c */
struct bio_set writepage_bioset; struct bio_set writepage_bioset;

39
fs/bcachefs/fs.c
View File

@ -39,6 +39,7 @@
#include <linux/posix_acl.h> #include <linux/posix_acl.h>
#include <linux/random.h> #include <linux/random.h>
#include <linux/seq_file.h> #include <linux/seq_file.h>
#include <linux/siphash.h>
#include <linux/statfs.h> #include <linux/statfs.h>
#include <linux/string.h> #include <linux/string.h>
#include <linux/xattr.h> #include <linux/xattr.h>
@ -176,8 +177,9 @@ static bool subvol_inum_eq(subvol_inum a, subvol_inum b)
static u32 bch2_vfs_inode_hash_fn(const void *data, u32 len, u32 seed) static u32 bch2_vfs_inode_hash_fn(const void *data, u32 len, u32 seed)
{ {
const subvol_inum *inum = data; const subvol_inum *inum = data;
siphash_key_t k = { .key[0] = seed };
return jhash(&inum->inum, sizeof(inum->inum), seed); return siphash_2u64(inum->subvol, inum->inum, &k);
} }
static u32 bch2_vfs_inode_obj_hash_fn(const void *data, u32 len, u32 seed) static u32 bch2_vfs_inode_obj_hash_fn(const void *data, u32 len, u32 seed)
@ -206,11 +208,18 @@ static const struct rhashtable_params bch2_vfs_inodes_params = {
.automatic_shrinking = true, .automatic_shrinking = true,
}; };
static const struct rhashtable_params bch2_vfs_inodes_by_inum_params = {
.head_offset = offsetof(struct bch_inode_info, by_inum_hash),
.key_offset = offsetof(struct bch_inode_info, ei_inum.inum),
.key_len = sizeof(u64),
.automatic_shrinking = true,
};
int bch2_inode_or_descendents_is_open(struct btree_trans *trans, struct bpos p) int bch2_inode_or_descendents_is_open(struct btree_trans *trans, struct bpos p)
{ {
struct bch_fs *c = trans->c; struct bch_fs *c = trans->c;
struct rhashtable *ht = &c->vfs_inodes_table; struct rhltable *ht = &c->vfs_inodes_by_inum_table;
subvol_inum inum = (subvol_inum) { .inum = p.offset }; u64 inum = p.offset;
DARRAY(u32) subvols; DARRAY(u32) subvols;
int ret = 0; int ret = 0;
@ -235,15 +244,15 @@ restart_from_top:
struct rhash_lock_head __rcu *const *bkt; struct rhash_lock_head __rcu *const *bkt;
struct rhash_head *he; struct rhash_head *he;
unsigned int hash; unsigned int hash;
struct bucket_table *tbl = rht_dereference_rcu(ht->tbl, ht); struct bucket_table *tbl = rht_dereference_rcu(ht->ht.tbl, &ht->ht);
restart: restart:
hash = rht_key_hashfn(ht, tbl, &inum, bch2_vfs_inodes_params); hash = rht_key_hashfn(&ht->ht, tbl, &inum, bch2_vfs_inodes_by_inum_params);
bkt = rht_bucket(tbl, hash); bkt = rht_bucket(tbl, hash);
do { do {
struct bch_inode_info *inode; struct bch_inode_info *inode;
rht_for_each_entry_rcu_from(inode, he, rht_ptr_rcu(bkt), tbl, hash, hash) { rht_for_each_entry_rcu_from(inode, he, rht_ptr_rcu(bkt), tbl, hash, hash) {
if (inode->ei_inum.inum == inum.inum) { if (inode->ei_inum.inum == inum) {
ret = darray_push_gfp(&subvols, inode->ei_inum.subvol, ret = darray_push_gfp(&subvols, inode->ei_inum.subvol,
GFP_NOWAIT|__GFP_NOWARN); GFP_NOWAIT|__GFP_NOWARN);
if (ret) { if (ret) {
@ -264,7 +273,7 @@ restart:
/* Ensure we see any new tables. */ /* Ensure we see any new tables. */
smp_rmb(); smp_rmb();
tbl = rht_dereference_rcu(tbl->future_tbl, ht); tbl = rht_dereference_rcu(tbl->future_tbl, &ht->ht);
if (unlikely(tbl)) if (unlikely(tbl))
goto restart; goto restart;
rcu_read_unlock(); rcu_read_unlock();
@ -343,7 +352,11 @@ static void bch2_inode_hash_remove(struct bch_fs *c, struct bch_inode_info *inod
spin_unlock(&inode->v.i_lock); spin_unlock(&inode->v.i_lock);
if (remove) { if (remove) {
int ret = rhashtable_remove_fast(&c->vfs_inodes_table, int ret = rhltable_remove(&c->vfs_inodes_by_inum_table,
&inode->by_inum_hash, bch2_vfs_inodes_by_inum_params);
BUG_ON(ret);
ret = rhashtable_remove_fast(&c->vfs_inodes_table,
&inode->hash, bch2_vfs_inodes_params); &inode->hash, bch2_vfs_inodes_params);
BUG_ON(ret); BUG_ON(ret);
inode->v.i_hash.pprev = NULL; inode->v.i_hash.pprev = NULL;
@ -388,6 +401,11 @@ retry:
discard_new_inode(&inode->v); discard_new_inode(&inode->v);
return old; return old;
} else { } else {
int ret = rhltable_insert(&c->vfs_inodes_by_inum_table,
&inode->by_inum_hash,
bch2_vfs_inodes_by_inum_params);
BUG_ON(ret);
inode_fake_hash(&inode->v); inode_fake_hash(&inode->v);
inode_sb_list_add(&inode->v); inode_sb_list_add(&inode->v);
@ -2359,13 +2377,16 @@ static int bch2_init_fs_context(struct fs_context *fc)
void bch2_fs_vfs_exit(struct bch_fs *c) void bch2_fs_vfs_exit(struct bch_fs *c)
{ {
if (c->vfs_inodes_by_inum_table.ht.tbl)
rhltable_destroy(&c->vfs_inodes_by_inum_table);
if (c->vfs_inodes_table.tbl) if (c->vfs_inodes_table.tbl)
rhashtable_destroy(&c->vfs_inodes_table); rhashtable_destroy(&c->vfs_inodes_table);
} }
int bch2_fs_vfs_init(struct bch_fs *c) int bch2_fs_vfs_init(struct bch_fs *c)
{ {
return rhashtable_init(&c->vfs_inodes_table, &bch2_vfs_inodes_params); return rhashtable_init(&c->vfs_inodes_table, &bch2_vfs_inodes_params) ?:
rhltable_init(&c->vfs_inodes_by_inum_table, &bch2_vfs_inodes_by_inum_params);
} }
static struct file_system_type bcache_fs_type = { static struct file_system_type bcache_fs_type = {

1
fs/bcachefs/fs.h
View File

@ -14,6 +14,7 @@
struct bch_inode_info { struct bch_inode_info {
struct inode v; struct inode v;
struct rhash_head hash; struct rhash_head hash;
struct rhlist_head by_inum_hash;
subvol_inum ei_inum; subvol_inum ei_inum;
struct list_head ei_vfs_inode_list; struct list_head ei_vfs_inode_list;