* [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops
@ 2015-06-08 5:26 Shirley Ma
2015-06-08 11:42 ` Jeff Layton
0 siblings, 1 reply; 4+ messages in thread
From: Shirley Ma @ 2015-06-08 5:26 UTC (permalink / raw)
To: J. Bruce Fields, Jeff Layton; +Cc: Linux NFS Mailing List
sunrpc: move sv_module parm into sv_ops
...not technically an operation, but it's more convenient and cleaner
to pass the module pointer in this struct.
Author: Jeff Layton <jlayton@primarydata.com>
Signed-off-by: Shirley Ma <shirley.ma@oracle.com>
Tested-by: Shirley Ma <shirley.ma@oracle.com>
---
diff --git a/fs/nfsd/nfssvc.c b/fs/nfsd/nfssvc.c
index bd03968..17ceaad 100644
--- a/fs/nfsd/nfssvc.c
+++ b/fs/nfsd/nfssvc.c
@@ -394,6 +394,7 @@ static int nfsd_get_default_max_blksize(void)
static struct svc_serv_ops nfsd_sv_ops = {
.svo_shutdown = nfsd_last_thread,
.svo_function = nfsd,
+ .svo_module = THIS_MODULE,
};
int nfsd_create_serv(struct net *net)
@@ -410,7 +411,7 @@ int nfsd_create_serv(struct net *net)
nfsd_max_blksize = nfsd_get_default_max_blksize();
nfsd_reset_versions();
nn->nfsd_serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize,
- &nfsd_sv_ops, THIS_MODULE);
+ &nfsd_sv_ops);
if (nn->nfsd_serv == NULL)
return -ENOMEM;
diff --git a/include/linux/sunrpc/svc.h b/include/linux/sunrpc/svc.h
index 68103a6..2ec741a 100644
--- a/include/linux/sunrpc/svc.h
+++ b/include/linux/sunrpc/svc.h
@@ -54,7 +54,12 @@ struct svc_serv;
struct svc_serv_ops {
/* Callback to use when last thread exits. */
void (*svo_shutdown)(struct svc_serv *, struct net *);
+
+ /* function for service threads to run */
int (*svo_function)(void *);
+
+ /* optional module to count when adding threads (pooled svcs only) */
+ struct module *svo_module;
};
/*
@@ -89,8 +94,6 @@ struct svc_serv {
unsigned int sv_nrpools; /* number of thread pools */
struct svc_pool * sv_pools; /* array of thread pools */
struct svc_serv_ops * sv_ops; /* server operations */
- struct module * sv_module; /* optional module to count when
- * adding threads */
#if defined(CONFIG_SUNRPC_BACKCHANNEL)
struct list_head sv_cb_list; /* queue for callback requests
* that arrive over the same
@@ -430,7 +433,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv,
struct svc_pool *pool, int node);
void svc_exit_thread(struct svc_rqst *);
struct svc_serv * svc_create_pooled(struct svc_program *, unsigned int,
- struct svc_serv_ops *, struct module *);
+ struct svc_serv_ops *);
int svc_set_num_threads(struct svc_serv *, struct svc_pool *, int);
int svc_pool_stats_open(struct svc_serv *serv, struct file *file);
void svc_destroy(struct svc_serv *);
diff --git a/net/sunrpc/svc.c b/net/sunrpc/svc.c
index 25d7b92..5ae9d63 100644
--- a/net/sunrpc/svc.c
+++ b/net/sunrpc/svc.c
@@ -494,7 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create);
struct svc_serv *
svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
- struct svc_serv_ops *ops, struct module *mod)
+ struct svc_serv_ops *ops)
{
struct svc_serv *serv;
unsigned int npools = svc_pool_map_get();
@@ -502,8 +502,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
serv = __svc_create(prog, bufsize, npools, ops);
if (!serv)
goto out_err;
-
- serv->sv_module = mod;
return serv;
out_err:
svc_pool_map_put();
@@ -737,12 +735,12 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs)
break;
}
- __module_get(serv->sv_module);
+ __module_get(serv->sv_ops->svo_module);
task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp,
node, "%s", serv->sv_name);
if (IS_ERR(task)) {
error = PTR_ERR(task);
- module_put(serv->sv_module);
+ module_put(serv->sv_ops->svo_module);
svc_exit_thread(rqstp);
break;
}
^ permalink raw reply related [flat|nested] 4+ messages in thread* Re: [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops
2015-06-08 5:26 [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops Shirley Ma
@ 2015-06-08 11:42 ` Jeff Layton
2015-06-08 15:54 ` Shirley Ma
0 siblings, 1 reply; 4+ messages in thread
From: Jeff Layton @ 2015-06-08 11:42 UTC (permalink / raw)
To: Shirley Ma; +Cc: J. Bruce Fields, Jeff Layton, Linux NFS Mailing List
On Sun, 07 Jun 2015 22:26:02 -0700
Shirley Ma <shirley.ma@oracle.com> wrote:
> sunrpc: move sv_module parm into sv_ops
>
> ...not technically an operation, but it's more convenient and cleaner
> to pass the module pointer in this struct.
>
> Author: Jeff Layton <jlayton@primarydata.com>
> Signed-off-by: Shirley Ma <shirley.ma@oracle.com>
> Tested-by: Shirley Ma <shirley.ma@oracle.com>
> ---
> diff --git a/fs/nfsd/nfssvc.c b/fs/nfsd/nfssvc.c
> index bd03968..17ceaad 100644
> --- a/fs/nfsd/nfssvc.c
> +++ b/fs/nfsd/nfssvc.c
> @@ -394,6 +394,7 @@ static int nfsd_get_default_max_blksize(void)
> static struct svc_serv_ops nfsd_sv_ops = {
> .svo_shutdown = nfsd_last_thread,
> .svo_function = nfsd,
> + .svo_module = THIS_MODULE,
> };
>
> int nfsd_create_serv(struct net *net)
> @@ -410,7 +411,7 @@ int nfsd_create_serv(struct net *net)
> nfsd_max_blksize = nfsd_get_default_max_blksize();
> nfsd_reset_versions();
> nn->nfsd_serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize,
> - &nfsd_sv_ops, THIS_MODULE);
> + &nfsd_sv_ops);
> if (nn->nfsd_serv == NULL)
> return -ENOMEM;
>
> diff --git a/include/linux/sunrpc/svc.h b/include/linux/sunrpc/svc.h
> index 68103a6..2ec741a 100644
> --- a/include/linux/sunrpc/svc.h
> +++ b/include/linux/sunrpc/svc.h
> @@ -54,7 +54,12 @@ struct svc_serv;
> struct svc_serv_ops {
> /* Callback to use when last thread exits. */
> void (*svo_shutdown)(struct svc_serv *, struct net *);
> +
> + /* function for service threads to run */
> int (*svo_function)(void *);
> +
> + /* optional module to count when adding threads (pooled svcs only) */
> + struct module *svo_module;
> };
>
> /*
> @@ -89,8 +94,6 @@ struct svc_serv {
> unsigned int sv_nrpools; /* number of thread pools */
> struct svc_pool * sv_pools; /* array of thread pools */
> struct svc_serv_ops * sv_ops; /* server operations */
> - struct module * sv_module; /* optional module to count when
> - * adding threads */
> #if defined(CONFIG_SUNRPC_BACKCHANNEL)
> struct list_head sv_cb_list; /* queue for callback requests
> * that arrive over the same
> @@ -430,7 +433,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv,
> struct svc_pool *pool, int node);
> void svc_exit_thread(struct svc_rqst *);
> struct svc_serv * svc_create_pooled(struct svc_program *, unsigned int,
> - struct svc_serv_ops *, struct module *);
> + struct svc_serv_ops *);
> int svc_set_num_threads(struct svc_serv *, struct svc_pool *, int);
> int svc_pool_stats_open(struct svc_serv *serv, struct file *file);
> void svc_destroy(struct svc_serv *);
> diff --git a/net/sunrpc/svc.c b/net/sunrpc/svc.c
> index 25d7b92..5ae9d63 100644
> --- a/net/sunrpc/svc.c
> +++ b/net/sunrpc/svc.c
> @@ -494,7 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create);
>
> struct svc_serv *
> svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
> - struct svc_serv_ops *ops, struct module *mod)
> + struct svc_serv_ops *ops)
> {
> struct svc_serv *serv;
> unsigned int npools = svc_pool_map_get();
> @@ -502,8 +502,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
> serv = __svc_create(prog, bufsize, npools, ops);
> if (!serv)
> goto out_err;
> -
> - serv->sv_module = mod;
> return serv;
> out_err:
> svc_pool_map_put();
> @@ -737,12 +735,12 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs)
> break;
> }
>
> - __module_get(serv->sv_module);
> + __module_get(serv->sv_ops->svo_module);
> task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp,
> node, "%s", serv->sv_name);
> if (IS_ERR(task)) {
> error = PTR_ERR(task);
> - module_put(serv->sv_module);
> + module_put(serv->sv_ops->svo_module);
> svc_exit_thread(rqstp);
> break;
> }
Hmmm...there are two patch #2's in this series and one looks like a dup
of #3? It'd be good to clean that up and resend eventually once
everyone has commented...
Anyway, ACK from me on merging this part of the work. It's unlikely to
hurt anything performance-wise, and having an ops container for the serv
makes a lot of sense, IMO.
--
Jeff Layton <jeff.layton@primarydata.com>
^ permalink raw reply [flat|nested] 4+ messages in thread* Re: [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops
2015-06-08 11:42 ` Jeff Layton
@ 2015-06-08 15:54 ` Shirley Ma
0 siblings, 0 replies; 4+ messages in thread
From: Shirley Ma @ 2015-06-08 15:54 UTC (permalink / raw)
To: Jeff Layton; +Cc: J. Bruce Fields, Jeff Layton, Linux NFS Mailing List
Oops, I made a mistake. Yes, I will resend them.
Thanks
Shirley
On 06/08/2015 04:42 AM, Jeff Layton wrote:
> On Sun, 07 Jun 2015 22:26:02 -0700
> Shirley Ma <shirley.ma@oracle.com> wrote:
>
>> sunrpc: move sv_module parm into sv_ops
>>
>> ...not technically an operation, but it's more convenient and cleaner
>> to pass the module pointer in this struct.
>>
>> Author: Jeff Layton <jlayton@primarydata.com>
>> Signed-off-by: Shirley Ma <shirley.ma@oracle.com>
>> Tested-by: Shirley Ma <shirley.ma@oracle.com>
>> ---
>> diff --git a/fs/nfsd/nfssvc.c b/fs/nfsd/nfssvc.c
>> index bd03968..17ceaad 100644
>> --- a/fs/nfsd/nfssvc.c
>> +++ b/fs/nfsd/nfssvc.c
>> @@ -394,6 +394,7 @@ static int nfsd_get_default_max_blksize(void)
>> static struct svc_serv_ops nfsd_sv_ops = {
>> .svo_shutdown = nfsd_last_thread,
>> .svo_function = nfsd,
>> + .svo_module = THIS_MODULE,
>> };
>>
>> int nfsd_create_serv(struct net *net)
>> @@ -410,7 +411,7 @@ int nfsd_create_serv(struct net *net)
>> nfsd_max_blksize = nfsd_get_default_max_blksize();
>> nfsd_reset_versions();
>> nn->nfsd_serv = svc_create_pooled(&nfsd_program, nfsd_max_blksize,
>> - &nfsd_sv_ops, THIS_MODULE);
>> + &nfsd_sv_ops);
>> if (nn->nfsd_serv == NULL)
>> return -ENOMEM;
>>
>> diff --git a/include/linux/sunrpc/svc.h b/include/linux/sunrpc/svc.h
>> index 68103a6..2ec741a 100644
>> --- a/include/linux/sunrpc/svc.h
>> +++ b/include/linux/sunrpc/svc.h
>> @@ -54,7 +54,12 @@ struct svc_serv;
>> struct svc_serv_ops {
>> /* Callback to use when last thread exits. */
>> void (*svo_shutdown)(struct svc_serv *, struct net *);
>> +
>> + /* function for service threads to run */
>> int (*svo_function)(void *);
>> +
>> + /* optional module to count when adding threads (pooled svcs only) */
>> + struct module *svo_module;
>> };
>>
>> /*
>> @@ -89,8 +94,6 @@ struct svc_serv {
>> unsigned int sv_nrpools; /* number of thread pools */
>> struct svc_pool * sv_pools; /* array of thread pools */
>> struct svc_serv_ops * sv_ops; /* server operations */
>> - struct module * sv_module; /* optional module to count when
>> - * adding threads */
>> #if defined(CONFIG_SUNRPC_BACKCHANNEL)
>> struct list_head sv_cb_list; /* queue for callback requests
>> * that arrive over the same
>> @@ -430,7 +433,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv,
>> struct svc_pool *pool, int node);
>> void svc_exit_thread(struct svc_rqst *);
>> struct svc_serv * svc_create_pooled(struct svc_program *, unsigned int,
>> - struct svc_serv_ops *, struct module *);
>> + struct svc_serv_ops *);
>> int svc_set_num_threads(struct svc_serv *, struct svc_pool *, int);
>> int svc_pool_stats_open(struct svc_serv *serv, struct file *file);
>> void svc_destroy(struct svc_serv *);
>> diff --git a/net/sunrpc/svc.c b/net/sunrpc/svc.c
>> index 25d7b92..5ae9d63 100644
>> --- a/net/sunrpc/svc.c
>> +++ b/net/sunrpc/svc.c
>> @@ -494,7 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create);
>>
>> struct svc_serv *
>> svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
>> - struct svc_serv_ops *ops, struct module *mod)
>> + struct svc_serv_ops *ops)
>> {
>> struct svc_serv *serv;
>> unsigned int npools = svc_pool_map_get();
>> @@ -502,8 +502,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
>> serv = __svc_create(prog, bufsize, npools, ops);
>> if (!serv)
>> goto out_err;
>> -
>> - serv->sv_module = mod;
>> return serv;
>> out_err:
>> svc_pool_map_put();
>> @@ -737,12 +735,12 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs)
>> break;
>> }
>>
>> - __module_get(serv->sv_module);
>> + __module_get(serv->sv_ops->svo_module);
>> task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp,
>> node, "%s", serv->sv_name);
>> if (IS_ERR(task)) {
>> error = PTR_ERR(task);
>> - module_put(serv->sv_module);
>> + module_put(serv->sv_ops->svo_module);
>> svc_exit_thread(rqstp);
>> break;
>> }
>
> Hmmm...there are two patch #2's in this series and one looks like a dup
> of #3? It'd be good to clean that up and resend eventually once
> everyone has commented...
>
> Anyway, ACK from me on merging this part of the work. It's unlikely to
> hurt anything performance-wise, and having an ops container for the serv
> makes a lot of sense, IMO.
>
^ permalink raw reply [flat|nested] 4+ messages in thread
* [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops
@ 2015-06-08 5:22 Shirley Ma
0 siblings, 0 replies; 4+ messages in thread
From: Shirley Ma @ 2015-06-08 5:22 UTC (permalink / raw)
To: J. Bruce Fields, Jeff Layton; +Cc: Linux NFS Mailing List
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.
Author: Jeff Layton <jlayton@primarydata.com>
Signed-off-by: Shirley Ma <shirley.ma@oracle.com>
Tested-by: Shirley Ma <shirley.ma@oracle.com>
---
diff --git a/fs/nfsd/nfssvc.c b/fs/nfsd/nfssvc.c
index 7311677..bd03968 100644
--- a/fs/nfsd/nfssvc.c
+++ b/fs/nfsd/nfssvc.c
@@ -393,6 +393,7 @@ static int nfsd_get_default_max_blksize(void)
static struct svc_serv_ops nfsd_sv_ops = {
.svo_shutdown = nfsd_last_thread,
+ .svo_function = nfsd,
};
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_reset_versions();
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)
return -ENOMEM;
diff --git a/include/linux/sunrpc/svc.h b/include/linux/sunrpc/svc.h
index 3d651be..68103a6 100644
--- a/include/linux/sunrpc/svc.h
+++ b/include/linux/sunrpc/svc.h
@@ -19,11 +19,6 @@
#include <linux/wait.h>
#include <linux/mm.h>
-/*
- * This is the RPC server thread function prototype
- */
-typedef int (*svc_thread_fn)(void *);
-
/* statistics for svc_pool structures */
struct svc_pool_stats {
atomic_long_t packets;
@@ -58,7 +53,8 @@ struct svc_serv;
struct svc_serv_ops {
/* 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 {
struct svc_serv_ops * sv_ops; /* server operations */
struct module * sv_module; /* optional module to count when
* adding threads */
- svc_thread_fn sv_function; /* main function for threads */
#if defined(CONFIG_SUNRPC_BACKCHANNEL)
struct list_head sv_cb_list; /* queue for callback requests
* that arrive over the same
@@ -435,7 +430,7 @@ struct svc_rqst *svc_prepare_thread(struct svc_serv *serv,
struct svc_pool *pool, int node);
void svc_exit_thread(struct svc_rqst *);
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_pool_stats_open(struct svc_serv *serv, struct file *file);
void svc_destroy(struct svc_serv *);
diff --git a/net/sunrpc/svc.c b/net/sunrpc/svc.c
index bb44682..25d7b92 100644
--- a/net/sunrpc/svc.c
+++ b/net/sunrpc/svc.c
@@ -34,7 +34,7 @@
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.
@@ -494,8 +494,7 @@ EXPORT_SYMBOL_GPL(svc_create);
struct svc_serv *
svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
- struct svc_serv_ops *ops, svc_thread_fn func,
- struct module *mod)
+ struct svc_serv_ops *ops, struct module *mod)
{
struct svc_serv *serv;
unsigned int npools = svc_pool_map_get();
@@ -504,7 +503,6 @@ svc_create_pooled(struct svc_program *prog, unsigned int bufsize,
if (!serv)
goto out_err;
- serv->sv_function = func;
serv->sv_module = mod;
return serv;
out_err:
@@ -740,7 +738,7 @@ svc_set_num_threads(struct svc_serv *serv, struct svc_pool *pool, int nrservs)
}
__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);
if (IS_ERR(task)) {
error = PTR_ERR(task);
^ permalink raw reply related [flat|nested] 4+ messages in thread
end of thread, other threads:[~2015-06-08 15:54 UTC | newest]
Thread overview: 4+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2015-06-08 5:26 [RFC PATCH V3 2/7] nfsd/sunrpc: move sv_function into sv_ops Shirley Ma
2015-06-08 11:42 ` Jeff Layton
2015-06-08 15:54 ` Shirley Ma
-- strict thread matches above, loose matches on Subject: below --
2015-06-08 5:22 Shirley Ma
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.