From: Benny Halevy <bhalevy@panasas.com>
To: "J. Bruce Fields" <bfields@redhat.com>
Cc: linux-nfs@vger.kernel.org, "J. Bruce Fields" <bfields@citi.umich.edu>
Subject: Re: [PATCH 11/16] nfsd4: keep per-session list of connections
Date: Thu, 30 Sep 2010 23:21:50 +0200 [thread overview]
Message-ID: <4CA4FF6E.3030907@panasas.com> (raw)
In-Reply-To: <1285863553-8945-12-git-send-email-bfields@redhat.com>
On 2010-09-30 18:19, J. Bruce Fields wrote:
> From: J. Bruce Fields <bfields@citi.umich.edu>
>
> The spec requires us in various places to keep track of the connections
> associated with each session.
>
> Signed-off-by: J. Bruce Fields <bfields@citi.umich.edu>
> ---
> fs/nfsd/nfs4state.c | 69 +++++++++++++++++++++++++++++++++++++++-----------
> fs/nfsd/state.h | 8 ++++++
> include/linux/nfs4.h | 3 ++
> 3 files changed, 65 insertions(+), 15 deletions(-)
>
> diff --git a/fs/nfsd/nfs4state.c b/fs/nfsd/nfs4state.c
> index f86476c..c7c1a7a 100644
> --- a/fs/nfsd/nfs4state.c
> +++ b/fs/nfsd/nfs4state.c
> @@ -625,11 +625,58 @@ static void init_forechannel_attrs(struct nfsd4_channel_attrs *new, struct nfsd4
> new->maxops = min_t(u32, req->maxops, NFSD_MAX_OPS_PER_COMPOUND);
> }
>
> +static __be32 nfsd4_new_conn(struct svc_rqst *rqstp, struct nfsd4_session *ses)
> +{
> + struct nfs4_client *clp = ses->se_client;
> + struct nfsd4_conn *conn;
> +
> + conn = kmalloc(sizeof(struct nfsd4_conn), GFP_KERNEL);
> + if (!conn)
> + return nfserr_jukebox;
> + conn->cn_flags = NFS4_CDFC4_FORE;
> + svc_xprt_get(rqstp->rq_xprt);
> + conn->cn_xprt = rqstp->rq_xprt;
> +
> + spin_lock(&clp->cl_lock);
> + list_add(&conn->cn_persession, &ses->se_conns);
> + spin_unlock(&clp->cl_lock);
> +
> + return nfs_ok;
> +}
> +
> +static void free_conn(struct nfsd4_conn *c)
> +{
> + svc_xprt_put(c->cn_xprt);
> + kfree(c);
> +}
> +
> +void free_session(struct kref *kref)
> +{
> + struct nfsd4_session *ses;
> + int mem;
> +
> + ses = container_of(kref, struct nfsd4_session, se_ref);
> + while (!list_empty(&ses->se_conns)) {
> + struct nfsd4_conn *c;
> + c = list_first_entry(&ses->se_conns, struct nfsd4_conn, cn_persession);
> + list_del(&c->cn_persession);
> + free_conn(c);
> + }
> + spin_lock(&nfsd_drc_lock);
> + mem = ses->se_fchannel.maxreqs * slot_bytes(&ses->se_fchannel);
> + nfsd_drc_mem_used -= mem;
> + spin_unlock(&nfsd_drc_lock);
> + free_session_slots(ses);
> + kfree(ses);
> +}
> +
> +
> static __be32 alloc_init_session(struct svc_rqst *rqstp, struct nfs4_client *clp, struct nfsd4_create_session *cses)
> {
> struct nfsd4_session *new;
> struct nfsd4_channel_attrs *fchan = &cses->fore_channel;
> int numslots, slotsize;
> + int status;
> int idx;
>
> /*
> @@ -654,6 +701,8 @@ static __be32 alloc_init_session(struct svc_rqst *rqstp, struct nfs4_client *clp
> memcpy(clp->cl_sessionid.data, new->se_sessionid.data,
> NFS4_MAX_SESSIONID_LEN);
>
> + INIT_LIST_HEAD(&new->se_conns);
> +
> new->se_flags = cses->flags;
> kref_init(&new->se_ref);
> idx = hash_sessionid(&new->se_sessionid);
> @@ -662,6 +711,11 @@ static __be32 alloc_init_session(struct svc_rqst *rqstp, struct nfs4_client *clp
> list_add(&new->se_perclnt, &clp->cl_sessions);
> spin_unlock(&client_lock);
>
> + status = nfsd4_new_conn(rqstp, new);
> + if (status) {
> + free_session(&new->se_ref);
> + return nfserr_jukebox;
why not return status?
> + }
> return nfs_ok;
> }
>
> @@ -694,21 +748,6 @@ unhash_session(struct nfsd4_session *ses)
> list_del(&ses->se_perclnt);
> }
>
> -void
> -free_session(struct kref *kref)
> -{
> - struct nfsd4_session *ses;
> - int mem;
> -
> - ses = container_of(kref, struct nfsd4_session, se_ref);
> - spin_lock(&nfsd_drc_lock);
> - mem = ses->se_fchannel.maxreqs * slot_bytes(&ses->se_fchannel);
> - nfsd_drc_mem_used -= mem;
> - spin_unlock(&nfsd_drc_lock);
> - free_session_slots(ses);
> - kfree(ses);
> -}
> -
> /* must be called under the client_lock */
> static inline void
> renew_client_locked(struct nfs4_client *clp)
> diff --git a/fs/nfsd/state.h b/fs/nfsd/state.h
> index 58bc2a6..29413c2 100644
> --- a/fs/nfsd/state.h
> +++ b/fs/nfsd/state.h
> @@ -152,6 +152,13 @@ struct nfsd4_clid_slot {
> struct nfsd4_create_session sl_cr_ses;
> };
>
> +struct nfsd4_conn {
> + struct list_head cn_persession;
> + struct svc_xprt *cn_xprt;
> +/* CDFC4_FORE, CDFC4_BACK: */
> + unsigned char cn_flags;
> +};
> +
> struct nfsd4_session {
> struct kref se_ref;
> struct list_head se_hash; /* hash by sessionid */
> @@ -161,6 +168,7 @@ struct nfsd4_session {
> struct nfs4_sessionid se_sessionid;
> struct nfsd4_channel_attrs se_fchannel;
> struct nfsd4_channel_attrs se_bchannel;
> + struct list_head se_conns;
> struct nfsd4_slot *se_slots[]; /* forward channel slots */
> };
>
> diff --git a/include/linux/nfs4.h b/include/linux/nfs4.h
> index 07e40c6..79b15fb 100644
> --- a/include/linux/nfs4.h
> +++ b/include/linux/nfs4.h
> @@ -61,6 +61,9 @@
> #define NFS4_SHARE_SIGNAL_DELEG_WHEN_RESRC_AVAIL 0x10000
> #define NFS4_SHARE_PUSH_DELEG_WHEN_UNCONTENDED 0x20000
>
> +#define NFS4_CDFC4_FORE 0x1
> +#define NFS4_CDFC4_BACK 0x2
> +
nit: I think that defining flags shifted bits is clearer, e.g.:
enum nfsd4_channel_dir {
NFS4_CDFC4_FORE = 1 << 0,
NFS4_CDFC4_BACK = 1 << 1,
};
Benny
> #define NFS4_SET_TO_SERVER_TIME 0
> #define NFS4_SET_TO_CLIENT_TIME 1
>
next prev parent reply other threads:[~2010-09-30 21:21 UTC|newest]
Thread overview: 21+ messages / expand[flat|nested] mbox.gz Atom feed top
2010-09-30 16:18 4.1 patches J. Bruce Fields
2010-09-30 16:18 ` [PATCH 01/16] nfsd4: minor variable renaming (cb -> conn) J. Bruce Fields
2010-09-30 16:18 ` [PATCH 02/16] nfsd4: combine nfs4_rpc_args and nfsd4_cb_sequence J. Bruce Fields
2010-09-30 16:19 ` [PATCH 03/16] nfsd4: rename nfs4_rpc_args->nfsd4_cb_args J. Bruce Fields
2010-09-30 16:19 ` [PATCH 04/16] nfsd4: generic callback code J. Bruce Fields
2010-09-30 16:19 ` [PATCH 05/16] nfsd4: use generic callback code in null case J. Bruce Fields
2010-09-30 16:19 ` [PATCH 06/16] nfsd4: remove separate cb_args struct J. Bruce Fields
2010-09-30 16:19 ` [PATCH 07/16] nfsd4: Move callback setup to callback queue J. Bruce Fields
2010-09-30 16:19 ` [PATCH 08/16] nfsd4: fix alloc_init_session BUILD_BUG_ON() J. Bruce Fields
2010-09-30 16:19 ` [PATCH 09/16] nfsd4: fix alloc_init_session return type J. Bruce Fields
2010-09-30 16:19 ` [PATCH 10/16] nfsd4: clean up session allocation J. Bruce Fields
2010-09-30 16:19 ` [PATCH 11/16] nfsd4: keep per-session list of connections J. Bruce Fields
2010-09-30 21:21 ` Benny Halevy [this message]
2010-09-30 21:38 ` J. Bruce Fields
2010-09-30 16:19 ` [PATCH 12/16] nfsd: provide callbacks on svc_xprt deletion J. Bruce Fields
2010-09-30 16:19 ` [PATCH 13/16] nfsd4: use callbacks on svc_xprt_deletion J. Bruce Fields
2010-09-30 16:19 ` [PATCH 14/16] nfsd4: refactor connection allocation J. Bruce Fields
2010-09-30 16:19 ` [PATCH 15/16] nfsd4: add new connections to session J. Bruce Fields
2010-09-30 21:33 ` Benny Halevy
2010-09-30 21:57 ` J. Bruce Fields
2010-09-30 16:19 ` [PATCH 16/16] nfsd4: enforce DESTROY_SESSION connection requirement J. Bruce Fields
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=4CA4FF6E.3030907@panasas.com \
--to=bhalevy@panasas.com \
--cc=bfields@citi.umich.edu \
--cc=bfields@redhat.com \
--cc=linux-nfs@vger.kernel.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox