mirror of
https://github.com/FEX-Emu/linux.git
synced 2024-12-18 06:50:08 +00:00
nfsd4: simplify idr allocation
We don't really need to preallocate at all; just allocate and initialize everything at once, but leave the sc_type field initially 0 to prevent finding the stateid till it's fully initialized. Signed-off-by: J. Bruce Fields <bfields@redhat.com>
This commit is contained in:
parent
2d32b29a1c
commit
3abdb60712
@ -261,33 +261,46 @@ static inline int get_new_stid(struct nfs4_stid *stid)
|
|||||||
return new_stid;
|
return new_stid;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void init_stid(struct nfs4_stid *stid, struct nfs4_client *cl, unsigned char type)
|
static struct nfs4_stid *nfs4_alloc_stid(struct nfs4_client *cl, struct
|
||||||
{
|
kmem_cache *slab)
|
||||||
stateid_t *s = &stid->sc_stateid;
|
|
||||||
int new_id;
|
|
||||||
|
|
||||||
stid->sc_type = type;
|
|
||||||
stid->sc_client = cl;
|
|
||||||
s->si_opaque.so_clid = cl->cl_clientid;
|
|
||||||
new_id = get_new_stid(stid);
|
|
||||||
s->si_opaque.so_id = (u32)new_id;
|
|
||||||
/* Will be incremented before return to client: */
|
|
||||||
s->si_generation = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
static struct nfs4_stid *nfs4_alloc_stid(struct nfs4_client *cl, struct kmem_cache *slab)
|
|
||||||
{
|
{
|
||||||
struct idr *stateids = &cl->cl_stateids;
|
struct idr *stateids = &cl->cl_stateids;
|
||||||
|
static int min_stateid = 0;
|
||||||
|
struct nfs4_stid *stid;
|
||||||
|
int new_id;
|
||||||
|
|
||||||
|
stid = kmem_cache_alloc(slab, GFP_KERNEL);
|
||||||
|
if (!stid)
|
||||||
|
return NULL;
|
||||||
|
|
||||||
if (!idr_pre_get(stateids, GFP_KERNEL))
|
if (!idr_pre_get(stateids, GFP_KERNEL))
|
||||||
return NULL;
|
goto out_free;
|
||||||
|
if (idr_get_new_above(stateids, stid, min_stateid, &new_id))
|
||||||
|
goto out_free;
|
||||||
|
stid->sc_client = cl;
|
||||||
|
stid->sc_type = 0;
|
||||||
|
stid->sc_stateid.si_opaque.so_id = new_id;
|
||||||
|
stid->sc_stateid.si_opaque.so_clid = cl->cl_clientid;
|
||||||
|
/* Will be incremented before return to client: */
|
||||||
|
stid->sc_stateid.si_generation = 0;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Note: if we fail here (or any time between now and the time
|
* It shouldn't be a problem to reuse an opaque stateid value.
|
||||||
* we actually get the new idr), we won't need to undo the idr
|
* I don't think it is for 4.1. But with 4.0 I worry that, for
|
||||||
* preallocation, since the idr code caps the number of
|
* example, a stray write retransmission could be accepted by
|
||||||
* preallocated entries.
|
* the server when it should have been rejected. Therefore,
|
||||||
|
* adopt a trick from the sctp code to attempt to maximize the
|
||||||
|
* amount of time until an id is reused, by ensuring they always
|
||||||
|
* "increase" (mod INT_MAX):
|
||||||
*/
|
*/
|
||||||
return kmem_cache_alloc(slab, GFP_KERNEL);
|
|
||||||
|
min_stateid = new_id+1;
|
||||||
|
if (min_stateid == INT_MAX)
|
||||||
|
min_stateid = 0;
|
||||||
|
return stid;
|
||||||
|
out_free:
|
||||||
|
kfree(stid);
|
||||||
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
static struct nfs4_ol_stateid * nfs4_alloc_stateid(struct nfs4_client *clp)
|
static struct nfs4_ol_stateid * nfs4_alloc_stateid(struct nfs4_client *clp)
|
||||||
@ -316,7 +329,7 @@ alloc_init_deleg(struct nfs4_client *clp, struct nfs4_ol_stateid *stp, struct sv
|
|||||||
dp = delegstateid(nfs4_alloc_stid(clp, deleg_slab));
|
dp = delegstateid(nfs4_alloc_stid(clp, deleg_slab));
|
||||||
if (dp == NULL)
|
if (dp == NULL)
|
||||||
return dp;
|
return dp;
|
||||||
init_stid(&dp->dl_stid, clp, NFS4_DELEG_STID);
|
dp->dl_stid.sc_type = NFS4_DELEG_STID;
|
||||||
/*
|
/*
|
||||||
* delegation seqid's are never incremented. The 4.1 special
|
* delegation seqid's are never incremented. The 4.1 special
|
||||||
* meaning of seqid 0 isn't meaningful, really, but let's avoid
|
* meaning of seqid 0 isn't meaningful, really, but let's avoid
|
||||||
@ -337,13 +350,21 @@ alloc_init_deleg(struct nfs4_client *clp, struct nfs4_ol_stateid *stp, struct sv
|
|||||||
return dp;
|
return dp;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void free_stid(struct nfs4_stid *s, struct kmem_cache *slab)
|
||||||
|
{
|
||||||
|
struct idr *stateids = &s->sc_client->cl_stateids;
|
||||||
|
|
||||||
|
idr_remove(stateids, s->sc_stateid.si_opaque.so_id);
|
||||||
|
kmem_cache_free(slab, s);
|
||||||
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
nfs4_put_delegation(struct nfs4_delegation *dp)
|
nfs4_put_delegation(struct nfs4_delegation *dp)
|
||||||
{
|
{
|
||||||
if (atomic_dec_and_test(&dp->dl_count)) {
|
if (atomic_dec_and_test(&dp->dl_count)) {
|
||||||
dprintk("NFSD: freeing dp %p\n",dp);
|
dprintk("NFSD: freeing dp %p\n",dp);
|
||||||
put_nfs4_file(dp->dl_file);
|
put_nfs4_file(dp->dl_file);
|
||||||
kmem_cache_free(deleg_slab, dp);
|
free_stid(&dp->dl_stid, deleg_slab);
|
||||||
num_delegations--;
|
num_delegations--;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -360,9 +381,7 @@ static void nfs4_put_deleg_lease(struct nfs4_file *fp)
|
|||||||
|
|
||||||
static void unhash_stid(struct nfs4_stid *s)
|
static void unhash_stid(struct nfs4_stid *s)
|
||||||
{
|
{
|
||||||
struct idr *stateids = &s->sc_client->cl_stateids;
|
s->sc_type = 0;
|
||||||
|
|
||||||
idr_remove(stateids, s->sc_stateid.si_opaque.so_id);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Called under the state lock. */
|
/* Called under the state lock. */
|
||||||
@ -519,7 +538,7 @@ static void close_generic_stateid(struct nfs4_ol_stateid *stp)
|
|||||||
|
|
||||||
static void free_generic_stateid(struct nfs4_ol_stateid *stp)
|
static void free_generic_stateid(struct nfs4_ol_stateid *stp)
|
||||||
{
|
{
|
||||||
kmem_cache_free(stateid_slab, stp);
|
free_stid(&stp->st_stid, stateid_slab);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void release_lock_stateid(struct nfs4_ol_stateid *stp)
|
static void release_lock_stateid(struct nfs4_ol_stateid *stp)
|
||||||
@ -1260,7 +1279,12 @@ static void gen_confirm(struct nfs4_client *clp)
|
|||||||
|
|
||||||
static struct nfs4_stid *find_stateid(struct nfs4_client *cl, stateid_t *t)
|
static struct nfs4_stid *find_stateid(struct nfs4_client *cl, stateid_t *t)
|
||||||
{
|
{
|
||||||
return idr_find(&cl->cl_stateids, t->si_opaque.so_id);
|
struct nfs4_stid *ret;
|
||||||
|
|
||||||
|
ret = idr_find(&cl->cl_stateids, t->si_opaque.so_id);
|
||||||
|
if (!ret || !ret->sc_type)
|
||||||
|
return NULL;
|
||||||
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
static struct nfs4_stid *find_stateid_by_type(struct nfs4_client *cl, stateid_t *t, char typemask)
|
static struct nfs4_stid *find_stateid_by_type(struct nfs4_client *cl, stateid_t *t, char typemask)
|
||||||
@ -2446,9 +2470,8 @@ alloc_init_open_stateowner(unsigned int strhashval, struct nfs4_client *clp, str
|
|||||||
|
|
||||||
static void init_open_stateid(struct nfs4_ol_stateid *stp, struct nfs4_file *fp, struct nfsd4_open *open) {
|
static void init_open_stateid(struct nfs4_ol_stateid *stp, struct nfs4_file *fp, struct nfsd4_open *open) {
|
||||||
struct nfs4_openowner *oo = open->op_openowner;
|
struct nfs4_openowner *oo = open->op_openowner;
|
||||||
struct nfs4_client *clp = oo->oo_owner.so_client;
|
|
||||||
|
|
||||||
init_stid(&stp->st_stid, clp, NFS4_OPEN_STID);
|
stp->st_stid.sc_type = NFS4_OPEN_STID;
|
||||||
INIT_LIST_HEAD(&stp->st_lockowners);
|
INIT_LIST_HEAD(&stp->st_lockowners);
|
||||||
list_add(&stp->st_perstateowner, &oo->oo_owner.so_stateids);
|
list_add(&stp->st_perstateowner, &oo->oo_owner.so_stateids);
|
||||||
list_add(&stp->st_perfile, &fp->fi_stateids);
|
list_add(&stp->st_perfile, &fp->fi_stateids);
|
||||||
@ -4034,7 +4057,7 @@ alloc_init_lock_stateid(struct nfs4_lockowner *lo, struct nfs4_file *fp, struct
|
|||||||
stp = nfs4_alloc_stateid(clp);
|
stp = nfs4_alloc_stateid(clp);
|
||||||
if (stp == NULL)
|
if (stp == NULL)
|
||||||
return NULL;
|
return NULL;
|
||||||
init_stid(&stp->st_stid, clp, NFS4_LOCK_STID);
|
stp->st_stid.sc_type = NFS4_LOCK_STID;
|
||||||
list_add(&stp->st_perfile, &fp->fi_stateids);
|
list_add(&stp->st_perfile, &fp->fi_stateids);
|
||||||
list_add(&stp->st_perstateowner, &lo->lo_owner.so_stateids);
|
list_add(&stp->st_perstateowner, &lo->lo_owner.so_stateids);
|
||||||
stp->st_stateowner = &lo->lo_owner;
|
stp->st_stateowner = &lo->lo_owner;
|
||||||
|
Loading…
Reference in New Issue
Block a user