Commit c369014f authored by Jeff Layton's avatar Jeff Layton Committed by J. Bruce Fields

nfsd/sunrpc: move sv_function into sv_ops

Since we now have a container for holding svc_serv operations, move the
sv_function into it as well.
Signed-off-by: default avatarShirley Ma <shirley.ma@oracle.com>
Acked-by: default avatarJeff Layton <jlayton@primarydata.com>
Tested-by: default avatarShirley Ma <shirley.ma@oracle.com>
Signed-off-by: default avatarJ. Bruce Fields <bfields@redhat.com>
parent ea126e74
...@@ -393,6 +393,7 @@ static int nfsd_get_default_max_blksize(void) ...@@ -393,6 +393,7 @@ static int nfsd_get_default_max_blksize(void)
static struct svc_serv_ops nfsd_sv_ops = { static struct svc_serv_ops nfsd_sv_ops = {
.svo_shutdown = nfsd_last_thread, .svo_shutdown = nfsd_last_thread,
.svo_function = nfsd,
}; };
int nfsd_create_serv(struct net *net) int nfsd_create_serv(struct net *net)
...@@ -409,7 +410,7 @@ int nfsd_create_serv(struct net *net) ...@@ -409,7 +410,7 @@ int nfsd_create_serv(struct net *net)
nfsd_max_blksize = nfsd_get_default_max_blksize(); nfsd_max_blksize = nfsd_get_default_max_blksize();
nfsd_reset_versions(); nfsd_reset_versions();
nn->nfsd_serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize, nn->nfsd_serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize,
&nfsd_sv_ops, nfsd, THIS_MODULE); &nfsd_sv_ops, THIS_MODULE);
if (nn->nfsd_serv == NULL) if (nn->nfsd_serv == NULL)
return -ENOMEM; return -ENOMEM;
......
...@@ -19,11 +19,6 @@ ...@@ -19,11 +19,6 @@
#include <linux/wait.h> #include <linux/wait.h>
#include <linux/mm.h> #include <linux/mm.h>
/*
* This is the RPC server thread function prototype
*/
typedef int (*svc_thread_fn)(void *);
/* statistics for svc_pool structures */ /* statistics for svc_pool structures */
struct svc_pool_stats { struct svc_pool_stats {
atomic_long_t packets; atomic_long_t packets;
...@@ -58,7 +53,8 @@ struct svc_serv; ...@@ -58,7 +53,8 @@ struct svc_serv;
struct svc_serv_ops { struct svc_serv_ops {
/* Callback to use when last thread exits. */ /* Callback to use when last thread exits. */
void (*svo_shutdown)(struct svc_serv *serv, struct net *net); void (*svo_shutdown)(struct svc_serv *, struct net *);
int (*svo_function)(void *);
}; };
/* /*
...@@ -95,7 +91,6 @@ struct svc_serv { ...@@ -95,7 +91,6 @@ struct svc_serv {
struct svc_serv_ops *sv_ops; /* server operations */ struct svc_serv_ops *sv_ops; /* server operations */
struct module * sv_module; /* optional module to count when struct module * sv_module; /* optional module to count when
* adding threads */ * adding threads */
svc_thread_fn sv_function; /* main function for threads */
#if defined(CONFIG_SUNRPC_BACKCHANNEL) #if defined(CONFIG_SUNRPC_BACKCHANNEL)
struct list_head sv_cb_list; /* queue for callback requests struct list_head sv_cb_list; /* queue for callback requests
* that arrive over the same * that arrive over the same
...@@ -435,7 +430,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv, ...@@ -435,7 +430,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv,
struct svc_pool *pool, int node); struct svc_pool *pool, int node);
void svc_exit_thread(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 *, unsigned int,
struct svc_serv_ops *, svc_thread_fn, struct module *); struct svc_serv_ops *, struct module *);
int svc_set_num_threads(struct svc_serv *, struct svc_pool *, int); int svc_set_num_threads(struct svc_serv *, struct svc_pool *, int);
int svc_pool_stats_open(struct svc_serv *serv, struct file *file); int svc_pool_stats_open(struct svc_serv *serv, struct file *file);
void svc_destroy(struct svc_serv *); void svc_destroy(struct svc_serv *);
......
...@@ -34,7 +34,7 @@ ...@@ -34,7 +34,7 @@
static void svc_unregister(const struct svc_serv *serv, struct net *net); static void svc_unregister(const struct svc_serv *serv, struct net *net);
#define svc_serv_is_pooled(serv) ((serv)->sv_function) #define svc_serv_is_pooled(serv) ((serv)->sv_ops->svo_function)
/* /*
* Mode for mapping cpus to pools. * Mode for mapping cpus to pools.
...@@ -494,8 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create); ...@@ -494,8 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create);
struct svc_serv * struct svc_serv *
svc_create_pooled(struct svc_program *prog, unsigned int bufsize, svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
struct svc_serv_ops *ops, svc_thread_fn func, struct svc_serv_ops *ops, struct module *mod)
struct module *mod)
{ {
struct svc_serv *serv; struct svc_serv *serv;
unsigned int npools = svc_pool_map_get(); unsigned int npools = svc_pool_map_get();
...@@ -504,7 +503,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize, ...@@ -504,7 +503,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
if (!serv) if (!serv)
goto out_err; goto out_err;
serv->sv_function = func;
serv->sv_module = mod; serv->sv_module = mod;
return serv; return serv;
out_err: out_err:
...@@ -740,7 +738,7 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs) ...@@ -740,7 +738,7 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs)
} }
__module_get(serv->sv_module); __module_get(serv->sv_module);
task = kthread_create_on_node(serv->sv_function, rqstp, task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp,
node, "%s", serv->sv_name); node, "%s", serv->sv_name);
if (IS_ERR(task)) { if (IS_ERR(task)) {
error = PTR_ERR(task); error = PTR_ERR(task);
......
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