Commit 9b531137 authored by Stanislav Kinsbursky's avatar Stanislav Kinsbursky Committed by J. Bruce Fields

nfsd: make ownerstr_hashtbl allocated per net

This hash holds open owner state and closely associated with nfs4_clients
info, which are network namespace aware. So let's make it allocated per
network namespace too.

Note: this hash can be allocated in per-net operations. But it looks
better to allocate it on nfsd state start and thus don't waste resources
if server is not running.
Signed-off-by: default avatarStanislav Kinsbursky <skinsbursky@parallels.com>
Signed-off-by: default avatarJ. Bruce Fields <bfields@redhat.com>
parent a99454aa
...@@ -60,6 +60,7 @@ struct nfsd_net { ...@@ -60,6 +60,7 @@ struct nfsd_net {
struct rb_root conf_name_tree; struct rb_root conf_name_tree;
struct list_head *unconf_id_hashtbl; struct list_head *unconf_id_hashtbl;
struct rb_root unconf_name_tree; struct rb_root unconf_name_tree;
struct list_head *ownerstr_hashtbl;
}; };
extern int nfsd_net_id; extern int nfsd_net_id;
......
...@@ -176,8 +176,6 @@ static unsigned int ownerstr_hashval(u32 clientid, struct xdr_netobj *ownername) ...@@ -176,8 +176,6 @@ static unsigned int ownerstr_hashval(u32 clientid, struct xdr_netobj *ownername)
return ret & OWNER_HASH_MASK; return ret & OWNER_HASH_MASK;
} }
static struct list_head ownerstr_hashtbl[OWNER_HASH_SIZE];
/* hash table for nfs4_file */ /* hash table for nfs4_file */
#define FILE_HASH_BITS 8 #define FILE_HASH_BITS 8
#define FILE_HASH_SIZE (1 << FILE_HASH_BITS) #define FILE_HASH_SIZE (1 << FILE_HASH_BITS)
...@@ -2428,7 +2426,9 @@ static inline void *alloc_stateowner(struct kmem_cache *slab, struct xdr_netobj ...@@ -2428,7 +2426,9 @@ static inline void *alloc_stateowner(struct kmem_cache *slab, struct xdr_netobj
static void hash_openowner(struct nfs4_openowner *oo, struct nfs4_client *clp, unsigned int strhashval) static void hash_openowner(struct nfs4_openowner *oo, struct nfs4_client *clp, unsigned int strhashval)
{ {
list_add(&oo->oo_owner.so_strhash, &ownerstr_hashtbl[strhashval]); struct nfsd_net *nn = net_generic(clp->net, nfsd_net_id);
list_add(&oo->oo_owner.so_strhash, &nn->ownerstr_hashtbl[strhashval]);
list_add(&oo->oo_perclient, &clp->cl_openowners); list_add(&oo->oo_perclient, &clp->cl_openowners);
} }
...@@ -2486,13 +2486,14 @@ same_owner_str(struct nfs4_stateowner *sop, struct xdr_netobj *owner, ...@@ -2486,13 +2486,14 @@ same_owner_str(struct nfs4_stateowner *sop, struct xdr_netobj *owner,
} }
static struct nfs4_openowner * static struct nfs4_openowner *
find_openstateowner_str(unsigned int hashval, struct nfsd4_open *open, bool sessions) find_openstateowner_str(unsigned int hashval, struct nfsd4_open *open,
bool sessions, struct nfsd_net *nn)
{ {
struct nfs4_stateowner *so; struct nfs4_stateowner *so;
struct nfs4_openowner *oo; struct nfs4_openowner *oo;
struct nfs4_client *clp; struct nfs4_client *clp;
list_for_each_entry(so, &ownerstr_hashtbl[hashval], so_strhash) { list_for_each_entry(so, &nn->ownerstr_hashtbl[hashval], so_strhash) {
if (!so->so_is_open_owner) if (!so->so_is_open_owner)
continue; continue;
if (same_owner_str(so, &open->op_owner, &open->op_clientid)) { if (same_owner_str(so, &open->op_owner, &open->op_clientid)) {
...@@ -2648,7 +2649,7 @@ nfsd4_process_open1(struct nfsd4_compound_state *cstate, ...@@ -2648,7 +2649,7 @@ nfsd4_process_open1(struct nfsd4_compound_state *cstate,
return nfserr_jukebox; return nfserr_jukebox;
strhashval = ownerstr_hashval(clientid->cl_id, &open->op_owner); strhashval = ownerstr_hashval(clientid->cl_id, &open->op_owner);
oo = find_openstateowner_str(strhashval, open, cstate->minorversion); oo = find_openstateowner_str(strhashval, open, cstate->minorversion, nn);
open->op_openowner = oo; open->op_openowner = oo;
if (!oo) { if (!oo) {
clp = find_confirmed_client(clientid, cstate->minorversion, clp = find_confirmed_client(clientid, cstate->minorversion,
...@@ -3976,8 +3977,9 @@ static void hash_lockowner(struct nfs4_lockowner *lo, unsigned int strhashval, s ...@@ -3976,8 +3977,9 @@ static void hash_lockowner(struct nfs4_lockowner *lo, unsigned int strhashval, s
struct inode *inode = open_stp->st_file->fi_inode; struct inode *inode = open_stp->st_file->fi_inode;
unsigned int inohash = lockowner_ino_hashval(inode, unsigned int inohash = lockowner_ino_hashval(inode,
clp->cl_clientid.cl_id, &lo->lo_owner.so_owner); clp->cl_clientid.cl_id, &lo->lo_owner.so_owner);
struct nfsd_net *nn = net_generic(clp->net, nfsd_net_id);
list_add(&lo->lo_owner.so_strhash, &ownerstr_hashtbl[strhashval]); list_add(&lo->lo_owner.so_strhash, &nn->ownerstr_hashtbl[strhashval]);
list_add(&lo->lo_owner_ino_hash, &lockowner_ino_hashtbl[inohash]); list_add(&lo->lo_owner_ino_hash, &lockowner_ino_hashtbl[inohash]);
list_add(&lo->lo_perstateid, &open_stp->st_lockowners); list_add(&lo->lo_perstateid, &open_stp->st_lockowners);
} }
...@@ -4458,7 +4460,7 @@ nfsd4_release_lockowner(struct svc_rqst *rqstp, ...@@ -4458,7 +4460,7 @@ nfsd4_release_lockowner(struct svc_rqst *rqstp,
status = nfserr_locks_held; status = nfserr_locks_held;
INIT_LIST_HEAD(&matches); INIT_LIST_HEAD(&matches);
list_for_each_entry(sop, &ownerstr_hashtbl[hashval], so_strhash) { list_for_each_entry(sop, &nn->ownerstr_hashtbl[hashval], so_strhash) {
if (sop->so_is_open_owner) if (sop->so_is_open_owner)
continue; continue;
if (!same_owner_str(sop, owner, clid)) if (!same_owner_str(sop, owner, clid))
...@@ -4614,13 +4616,14 @@ static void release_openowner_sop(struct nfs4_stateowner *sop) ...@@ -4614,13 +4616,14 @@ static void release_openowner_sop(struct nfs4_stateowner *sop)
} }
static int nfsd_release_n_owners(u64 num, bool is_open_owner, static int nfsd_release_n_owners(u64 num, bool is_open_owner,
void (*release_sop)(struct nfs4_stateowner *)) void (*release_sop)(struct nfs4_stateowner *),
struct nfsd_net *nn)
{ {
int i, count = 0; int i, count = 0;
struct nfs4_stateowner *sop, *next; struct nfs4_stateowner *sop, *next;
for (i = 0; i < OWNER_HASH_SIZE; i++) { for (i = 0; i < OWNER_HASH_SIZE; i++) {
list_for_each_entry_safe(sop, next, &ownerstr_hashtbl[i], so_strhash) { list_for_each_entry_safe(sop, next, &nn->ownerstr_hashtbl[i], so_strhash) {
if (sop->so_is_open_owner != is_open_owner) if (sop->so_is_open_owner != is_open_owner)
continue; continue;
release_sop(sop); release_sop(sop);
...@@ -4634,9 +4637,10 @@ static int nfsd_release_n_owners(u64 num, bool is_open_owner, ...@@ -4634,9 +4637,10 @@ static int nfsd_release_n_owners(u64 num, bool is_open_owner,
void nfsd_forget_locks(u64 num) void nfsd_forget_locks(u64 num)
{ {
int count; int count;
struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
nfs4_lock_state(); nfs4_lock_state();
count = nfsd_release_n_owners(num, false, release_lockowner_sop); count = nfsd_release_n_owners(num, false, release_lockowner_sop, nn);
nfs4_unlock_state(); nfs4_unlock_state();
printk(KERN_INFO "NFSD: Forgot %d locks", count); printk(KERN_INFO "NFSD: Forgot %d locks", count);
...@@ -4645,9 +4649,10 @@ void nfsd_forget_locks(u64 num) ...@@ -4645,9 +4649,10 @@ void nfsd_forget_locks(u64 num)
void nfsd_forget_openowners(u64 num) void nfsd_forget_openowners(u64 num)
{ {
int count; int count;
struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
nfs4_lock_state(); nfs4_lock_state();
count = nfsd_release_n_owners(num, true, release_openowner_sop); count = nfsd_release_n_owners(num, true, release_openowner_sop, nn);
nfs4_unlock_state(); nfs4_unlock_state();
printk(KERN_INFO "NFSD: Forgot %d open owners", count); printk(KERN_INFO "NFSD: Forgot %d open owners", count);
...@@ -4721,9 +4726,6 @@ nfs4_state_init(void) ...@@ -4721,9 +4726,6 @@ nfs4_state_init(void)
for (i = 0; i < FILE_HASH_SIZE; i++) { for (i = 0; i < FILE_HASH_SIZE; i++) {
INIT_LIST_HEAD(&file_hashtbl[i]); INIT_LIST_HEAD(&file_hashtbl[i]);
} }
for (i = 0; i < OWNER_HASH_SIZE; i++) {
INIT_LIST_HEAD(&ownerstr_hashtbl[i]);
}
for (i = 0; i < LOCKOWNER_INO_HASH_SIZE; i++) for (i = 0; i < LOCKOWNER_INO_HASH_SIZE; i++)
INIT_LIST_HEAD(&lockowner_ino_hashtbl[i]); INIT_LIST_HEAD(&lockowner_ino_hashtbl[i]);
INIT_LIST_HEAD(&close_lru); INIT_LIST_HEAD(&close_lru);
...@@ -4765,16 +4767,24 @@ static int nfs4_state_start_net(struct net *net) ...@@ -4765,16 +4767,24 @@ static int nfs4_state_start_net(struct net *net)
CLIENT_HASH_SIZE, GFP_KERNEL); CLIENT_HASH_SIZE, GFP_KERNEL);
if (!nn->unconf_id_hashtbl) if (!nn->unconf_id_hashtbl)
goto err_unconf_id; goto err_unconf_id;
nn->ownerstr_hashtbl = kmalloc(sizeof(struct list_head) *
OWNER_HASH_SIZE, GFP_KERNEL);
if (!nn->ownerstr_hashtbl)
goto err_ownerstr;
for (i = 0; i < CLIENT_HASH_SIZE; i++) { for (i = 0; i < CLIENT_HASH_SIZE; i++) {
INIT_LIST_HEAD(&nn->conf_id_hashtbl[i]); INIT_LIST_HEAD(&nn->conf_id_hashtbl[i]);
INIT_LIST_HEAD(&nn->unconf_id_hashtbl[i]); INIT_LIST_HEAD(&nn->unconf_id_hashtbl[i]);
} }
for (i = 0; i < OWNER_HASH_SIZE; i++)
INIT_LIST_HEAD(&nn->ownerstr_hashtbl[i]);
nn->conf_name_tree = RB_ROOT; nn->conf_name_tree = RB_ROOT;
nn->unconf_name_tree = RB_ROOT; nn->unconf_name_tree = RB_ROOT;
return 0; return 0;
err_ownerstr:
kfree(nn->unconf_id_hashtbl);
err_unconf_id: err_unconf_id:
kfree(nn->conf_id_hashtbl); kfree(nn->conf_id_hashtbl);
err: err:
...@@ -4805,6 +4815,7 @@ __nfs4_state_shutdown_net(struct net *net) ...@@ -4805,6 +4815,7 @@ __nfs4_state_shutdown_net(struct net *net)
destroy_client(clp); destroy_client(clp);
} }
kfree(nn->ownerstr_hashtbl);
kfree(nn->unconf_id_hashtbl); kfree(nn->unconf_id_hashtbl);
kfree(nn->conf_id_hashtbl); kfree(nn->conf_id_hashtbl);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment