[<prev] [next>] [thread-next>] [day] [month] [year] [list]
Message-Id: <20250623122226.3720564-1-suhui@nfschina.com>
Date: Mon, 23 Jun 2025 20:22:27 +0800
From: Su Hui <suhui@...china.com>
To: chuck.lever@...cle.com,
jlayton@...nel.org,
neil@...wn.name,
okorniev@...hat.com,
Dai.Ngo@...cle.com,
tom@...pey.com
Cc: Su Hui <suhui@...china.com>,
linux-nfs@...r.kernel.org,
linux-kernel@...r.kernel.org,
kernel-janitors@...r.kernel.org
Subject: [PATCH] nfsd: Using guard() to simplify nfsd_cache_lookup()
Using guard() to replace *unlock* label. guard() makes lock/unlock code
more clear. Change the order of the code to let all lock code in the
same scope. No functional changes.
Signed-off-by: Su Hui <suhui@...china.com>
---
fs/nfsd/nfscache.c | 99 ++++++++++++++++++++++------------------------
1 file changed, 48 insertions(+), 51 deletions(-)
diff --git a/fs/nfsd/nfscache.c b/fs/nfsd/nfscache.c
index ba9d326b3de6..2d92adf3e6b0 100644
--- a/fs/nfsd/nfscache.c
+++ b/fs/nfsd/nfscache.c
@@ -489,7 +489,7 @@ int nfsd_cache_lookup(struct svc_rqst *rqstp, unsigned int start,
if (type == RC_NOCACHE) {
nfsd_stats_rc_nocache_inc(nn);
- goto out;
+ return rtn;
}
csum = nfsd_cache_csum(&rqstp->rq_arg, start, len);
@@ -500,64 +500,61 @@ int nfsd_cache_lookup(struct svc_rqst *rqstp, unsigned int start,
*/
rp = nfsd_cacherep_alloc(rqstp, csum, nn);
if (!rp)
- goto out;
+ return rtn;
b = nfsd_cache_bucket_find(rqstp->rq_xid, nn);
- spin_lock(&b->cache_lock);
- found = nfsd_cache_insert(b, rp, nn);
- if (found != rp)
- goto found_entry;
- *cacherep = rp;
- rp->c_state = RC_INPROG;
- nfsd_prune_bucket_locked(nn, b, 3, &dispose);
- spin_unlock(&b->cache_lock);
+ scoped_guard(spinlock, &b->cache_lock) {
+ found = nfsd_cache_insert(b, rp, nn);
+ if (found == rp) {
+ *cacherep = rp;
+ rp->c_state = RC_INPROG;
+ nfsd_prune_bucket_locked(nn, b, 3, &dispose);
+ goto out;
+ }
+ /* We found a matching entry which is either in progress or done. */
+ nfsd_reply_cache_free_locked(NULL, rp, nn);
+ nfsd_stats_rc_hits_inc(nn);
+ rtn = RC_DROPIT;
+ rp = found;
+
+ /* Request being processed */
+ if (rp->c_state == RC_INPROG)
+ goto out_trace;
+
+ /* From the hall of fame of impractical attacks:
+ * Is this a user who tries to snoop on the cache?
+ */
+ rtn = RC_DOIT;
+ if (!test_bit(RQ_SECURE, &rqstp->rq_flags) && rp->c_secure)
+ goto out_trace;
+ /* Compose RPC reply header */
+ switch (rp->c_type) {
+ case RC_NOCACHE:
+ break;
+ case RC_REPLSTAT:
+ xdr_stream_encode_be32(&rqstp->rq_res_stream, rp->c_replstat);
+ rtn = RC_REPLY;
+ break;
+ case RC_REPLBUFF:
+ if (!nfsd_cache_append(rqstp, &rp->c_replvec))
+ return rtn; /* should not happen */
+ rtn = RC_REPLY;
+ break;
+ default:
+ WARN_ONCE(1, "nfsd: bad repcache type %d\n", rp->c_type);
+ }
+
+out_trace:
+ trace_nfsd_drc_found(nn, rqstp, rtn);
+ return rtn;
+ }
+out:
nfsd_cacherep_dispose(&dispose);
nfsd_stats_rc_misses_inc(nn);
atomic_inc(&nn->num_drc_entries);
nfsd_stats_drc_mem_usage_add(nn, sizeof(*rp));
- goto out;
-
-found_entry:
- /* We found a matching entry which is either in progress or done. */
- nfsd_reply_cache_free_locked(NULL, rp, nn);
- nfsd_stats_rc_hits_inc(nn);
- rtn = RC_DROPIT;
- rp = found;
-
- /* Request being processed */
- if (rp->c_state == RC_INPROG)
- goto out_trace;
-
- /* From the hall of fame of impractical attacks:
- * Is this a user who tries to snoop on the cache? */
- rtn = RC_DOIT;
- if (!test_bit(RQ_SECURE, &rqstp->rq_flags) && rp->c_secure)
- goto out_trace;
-
- /* Compose RPC reply header */
- switch (rp->c_type) {
- case RC_NOCACHE:
- break;
- case RC_REPLSTAT:
- xdr_stream_encode_be32(&rqstp->rq_res_stream, rp->c_replstat);
- rtn = RC_REPLY;
- break;
- case RC_REPLBUFF:
- if (!nfsd_cache_append(rqstp, &rp->c_replvec))
- goto out_unlock; /* should not happen */
- rtn = RC_REPLY;
- break;
- default:
- WARN_ONCE(1, "nfsd: bad repcache type %d\n", rp->c_type);
- }
-
-out_trace:
- trace_nfsd_drc_found(nn, rqstp, rtn);
-out_unlock:
- spin_unlock(&b->cache_lock);
-out:
return rtn;
}
--
2.30.2
Powered by blists - more mailing lists