sunrpc: pass in the sv_stats struct through svc_create_pooled
authorJosef Bacik <josef@toxicpanda.com>
Fri, 26 Jan 2024 15:39:42 +0000 (10:39 -0500)
committerChuck Lever <chuck.lever@oracle.com>
Fri, 1 Mar 2024 14:12:08 +0000 (09:12 -0500)
Since only one service actually reports the rpc stats there's not much
of a reason to have a pointer to it in the svc_program struct.  Adjust
the svc_create_pooled function to take the sv_stats as an argument and
pass the struct through there as desired instead of getting it from the
svc_program->pg_stats.

Signed-off-by: Josef Bacik <josef@toxicpanda.com>
Reviewed-by: Jeff Layton <jlayton@kernel.org>
Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
fs/nfsd/nfssvc.c
include/linux/sunrpc/svc.h
net/sunrpc/svc.c

index a0b117107e8605ee67d0bc017de5ba8f0288343c..d640f893021a717bb7ca5f08ed5b8c4ebbf8bd40 100644 (file)
@@ -661,7 +661,8 @@ int nfsd_create_serv(struct net *net)
        if (nfsd_max_blksize == 0)
                nfsd_max_blksize = nfsd_get_default_max_blksize();
        nfsd_reset_versions(nn);
-       serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize, nfsd);
+       serv = svc_create_pooled(&nfsd_program, &nfsd_svcstats,
+                                nfsd_max_blksize, nfsd);
        if (serv == NULL)
                return -ENOMEM;
 
index 67cf1c9efd809b17243d64453cff4dc8f624b14f..91a653eb3a5073044394d3865b9203ca5e3f09b0 100644 (file)
@@ -411,7 +411,9 @@ bool                   svc_rqst_replace_page(struct svc_rqst *rqstp,
 void              svc_rqst_release_pages(struct svc_rqst *rqstp);
 void              svc_rqst_free(struct svc_rqst *);
 void              svc_exit_thread(struct svc_rqst *);
-struct svc_serv *  svc_create_pooled(struct svc_program *, unsigned int,
+struct svc_serv *  svc_create_pooled(struct svc_program *prog,
+                                    struct svc_stat *stats,
+                                    unsigned int bufsize,
                                     int (*threadfn)(void *data));
 int               svc_set_num_threads(struct svc_serv *, struct svc_pool *, int);
 int               svc_pool_stats_open(struct svc_info *si, struct file *file);
index 62afc3dbc837174e583a295749eeb851a3706684..1ce6a3b7175caff4b540d303e322e7c57795f056 100644 (file)
@@ -451,8 +451,8 @@ __svc_init_bc(struct svc_serv *serv)
  * Create an RPC service
  */
 static struct svc_serv *
-__svc_create(struct svc_program *prog, unsigned int bufsize, int npools,
-            int (*threadfn)(void *data))
+__svc_create(struct svc_program *prog, struct svc_stat *stats,
+            unsigned int bufsize, int npools, int (*threadfn)(void *data))
 {
        struct svc_serv *serv;
        unsigned int vers;
@@ -463,7 +463,7 @@ __svc_create(struct svc_program *prog, unsigned int bufsize, int npools,
                return NULL;
        serv->sv_name      = prog->pg_name;
        serv->sv_program   = prog;
-       serv->sv_stats     = prog->pg_stats;
+       serv->sv_stats     = stats;
        if (bufsize > RPCSVC_MAXPAYLOAD)
                bufsize = RPCSVC_MAXPAYLOAD;
        serv->sv_max_payload = bufsize? bufsize : 4096;
@@ -529,26 +529,28 @@ __svc_create(struct svc_program *prog, unsigned int bufsize, int npools,
 struct svc_serv *svc_create(struct svc_program *prog, unsigned int bufsize,
                            int (*threadfn)(void *data))
 {
-       return __svc_create(prog, bufsize, 1, threadfn);
+       return __svc_create(prog, NULL, bufsize, 1, threadfn);
 }
 EXPORT_SYMBOL_GPL(svc_create);
 
 /**
  * svc_create_pooled - Create an RPC service with pooled threads
  * @prog: the RPC program the new service will handle
+ * @stats: the stats struct if desired
  * @bufsize: maximum message size for @prog
  * @threadfn: a function to service RPC requests for @prog
  *
  * Returns an instantiated struct svc_serv object or NULL.
  */
 struct svc_serv *svc_create_pooled(struct svc_program *prog,
+                                  struct svc_stat *stats,
                                   unsigned int bufsize,
                                   int (*threadfn)(void *data))
 {
        struct svc_serv *serv;
        unsigned int npools = svc_pool_map_get();
 
-       serv = __svc_create(prog, bufsize, npools, threadfn);
+       serv = __svc_create(prog, stats, bufsize, npools, threadfn);
        if (!serv)
                goto out_err;
        return serv;