svc: don't hold reference for poolstats, only mutex.
A future patch will remove refcounting on svc_serv as it is of little use. It is currently used to keep the svc around while the pool_stats file is open. Change this to get the pointer, protected by the mutex, only in seq_start, and the release the mutex in seq_stop. This means that if the nfsd server is stopped and restarted while the pool_stats file it open, then some pool stats info could be from the first instance and some from the second. This might appear odd, but is unlikely to be a problem in practice. Signed-off-by: NeilBrown <neilb@suse.de> Reviewed-by: Jeff Layton <jlayton@kernel.org> Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
This commit is contained in:
parent
05a4b58301
commit
7b207ccd98
@ -123,7 +123,9 @@ struct nfsd_net {
|
|||||||
u32 clientid_counter;
|
u32 clientid_counter;
|
||||||
u32 clverifier_counter;
|
u32 clverifier_counter;
|
||||||
|
|
||||||
struct svc_serv *nfsd_serv;
|
struct svc_info nfsd_info;
|
||||||
|
#define nfsd_serv nfsd_info.serv
|
||||||
|
|
||||||
/* When a listening socket is added to nfsd, keep_active is set
|
/* When a listening socket is added to nfsd, keep_active is set
|
||||||
* and this justifies a reference on nfsd_serv. This stops
|
* and this justifies a reference on nfsd_serv. This stops
|
||||||
* nfsd_serv from being freed. When the number of threads is
|
* nfsd_serv from being freed. When the number of threads is
|
||||||
|
@ -183,7 +183,7 @@ static const struct file_operations pool_stats_operations = {
|
|||||||
.open = nfsd_pool_stats_open,
|
.open = nfsd_pool_stats_open,
|
||||||
.read = seq_read,
|
.read = seq_read,
|
||||||
.llseek = seq_lseek,
|
.llseek = seq_lseek,
|
||||||
.release = nfsd_pool_stats_release,
|
.release = seq_release,
|
||||||
};
|
};
|
||||||
|
|
||||||
DEFINE_SHOW_ATTRIBUTE(nfsd_reply_cache_stats);
|
DEFINE_SHOW_ATTRIBUTE(nfsd_reply_cache_stats);
|
||||||
|
@ -684,6 +684,7 @@ int nfsd_create_serv(struct net *net)
|
|||||||
return error;
|
return error;
|
||||||
}
|
}
|
||||||
spin_lock(&nfsd_notifier_lock);
|
spin_lock(&nfsd_notifier_lock);
|
||||||
|
nn->nfsd_info.mutex = &nfsd_mutex;
|
||||||
nn->nfsd_serv = serv;
|
nn->nfsd_serv = serv;
|
||||||
spin_unlock(&nfsd_notifier_lock);
|
spin_unlock(&nfsd_notifier_lock);
|
||||||
|
|
||||||
@ -1082,28 +1083,7 @@ bool nfssvc_encode_voidres(struct svc_rqst *rqstp, struct xdr_stream *xdr)
|
|||||||
|
|
||||||
int nfsd_pool_stats_open(struct inode *inode, struct file *file)
|
int nfsd_pool_stats_open(struct inode *inode, struct file *file)
|
||||||
{
|
{
|
||||||
int ret;
|
|
||||||
struct nfsd_net *nn = net_generic(inode->i_sb->s_fs_info, nfsd_net_id);
|
struct nfsd_net *nn = net_generic(inode->i_sb->s_fs_info, nfsd_net_id);
|
||||||
|
|
||||||
mutex_lock(&nfsd_mutex);
|
return svc_pool_stats_open(&nn->nfsd_info, file);
|
||||||
if (nn->nfsd_serv == NULL) {
|
|
||||||
mutex_unlock(&nfsd_mutex);
|
|
||||||
return -ENODEV;
|
|
||||||
}
|
|
||||||
svc_get(nn->nfsd_serv);
|
|
||||||
ret = svc_pool_stats_open(nn->nfsd_serv, file);
|
|
||||||
mutex_unlock(&nfsd_mutex);
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
|
|
||||||
int nfsd_pool_stats_release(struct inode *inode, struct file *file)
|
|
||||||
{
|
|
||||||
struct seq_file *seq = file->private_data;
|
|
||||||
struct svc_serv *serv = seq->private;
|
|
||||||
int ret = seq_release(inode, file);
|
|
||||||
|
|
||||||
mutex_lock(&nfsd_mutex);
|
|
||||||
svc_put(serv);
|
|
||||||
mutex_unlock(&nfsd_mutex);
|
|
||||||
return ret;
|
|
||||||
}
|
}
|
||||||
|
@ -97,6 +97,12 @@ struct svc_serv {
|
|||||||
#endif /* CONFIG_SUNRPC_BACKCHANNEL */
|
#endif /* CONFIG_SUNRPC_BACKCHANNEL */
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/* This is used by pool_stats to find and lock an svc */
|
||||||
|
struct svc_info {
|
||||||
|
struct svc_serv *serv;
|
||||||
|
struct mutex *mutex;
|
||||||
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* svc_get() - increment reference count on a SUNRPC serv
|
* svc_get() - increment reference count on a SUNRPC serv
|
||||||
* @serv: the svc_serv to have count incremented
|
* @serv: the svc_serv to have count incremented
|
||||||
@ -431,7 +437,7 @@ 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,
|
||||||
int (*threadfn)(void *data));
|
int (*threadfn)(void *data));
|
||||||
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_info *si, struct file *file);
|
||||||
void svc_process(struct svc_rqst *rqstp);
|
void svc_process(struct svc_rqst *rqstp);
|
||||||
void svc_process_bc(struct rpc_rqst *req, struct svc_rqst *rqstp);
|
void svc_process_bc(struct rpc_rqst *req, struct svc_rqst *rqstp);
|
||||||
int svc_register(const struct svc_serv *, struct net *, const int,
|
int svc_register(const struct svc_serv *, struct net *, const int,
|
||||||
|
@ -1362,29 +1362,36 @@ int svc_xprt_names(struct svc_serv *serv, char *buf, const int buflen)
|
|||||||
}
|
}
|
||||||
EXPORT_SYMBOL_GPL(svc_xprt_names);
|
EXPORT_SYMBOL_GPL(svc_xprt_names);
|
||||||
|
|
||||||
|
|
||||||
/*----------------------------------------------------------------------------*/
|
/*----------------------------------------------------------------------------*/
|
||||||
|
|
||||||
static void *svc_pool_stats_start(struct seq_file *m, loff_t *pos)
|
static void *svc_pool_stats_start(struct seq_file *m, loff_t *pos)
|
||||||
{
|
{
|
||||||
unsigned int pidx = (unsigned int)*pos;
|
unsigned int pidx = (unsigned int)*pos;
|
||||||
struct svc_serv *serv = m->private;
|
struct svc_info *si = m->private;
|
||||||
|
|
||||||
dprintk("svc_pool_stats_start, *pidx=%u\n", pidx);
|
dprintk("svc_pool_stats_start, *pidx=%u\n", pidx);
|
||||||
|
|
||||||
|
mutex_lock(si->mutex);
|
||||||
|
|
||||||
if (!pidx)
|
if (!pidx)
|
||||||
return SEQ_START_TOKEN;
|
return SEQ_START_TOKEN;
|
||||||
return (pidx > serv->sv_nrpools ? NULL : &serv->sv_pools[pidx-1]);
|
if (!si->serv)
|
||||||
|
return NULL;
|
||||||
|
return pidx > si->serv->sv_nrpools ? NULL
|
||||||
|
: &si->serv->sv_pools[pidx - 1];
|
||||||
}
|
}
|
||||||
|
|
||||||
static void *svc_pool_stats_next(struct seq_file *m, void *p, loff_t *pos)
|
static void *svc_pool_stats_next(struct seq_file *m, void *p, loff_t *pos)
|
||||||
{
|
{
|
||||||
struct svc_pool *pool = p;
|
struct svc_pool *pool = p;
|
||||||
struct svc_serv *serv = m->private;
|
struct svc_info *si = m->private;
|
||||||
|
struct svc_serv *serv = si->serv;
|
||||||
|
|
||||||
dprintk("svc_pool_stats_next, *pos=%llu\n", *pos);
|
dprintk("svc_pool_stats_next, *pos=%llu\n", *pos);
|
||||||
|
|
||||||
if (p == SEQ_START_TOKEN) {
|
if (!serv) {
|
||||||
|
pool = NULL;
|
||||||
|
} else if (p == SEQ_START_TOKEN) {
|
||||||
pool = &serv->sv_pools[0];
|
pool = &serv->sv_pools[0];
|
||||||
} else {
|
} else {
|
||||||
unsigned int pidx = (pool - &serv->sv_pools[0]);
|
unsigned int pidx = (pool - &serv->sv_pools[0]);
|
||||||
@ -1399,6 +1406,9 @@ static void *svc_pool_stats_next(struct seq_file *m, void *p, loff_t *pos)
|
|||||||
|
|
||||||
static void svc_pool_stats_stop(struct seq_file *m, void *p)
|
static void svc_pool_stats_stop(struct seq_file *m, void *p)
|
||||||
{
|
{
|
||||||
|
struct svc_info *si = m->private;
|
||||||
|
|
||||||
|
mutex_unlock(si->mutex);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int svc_pool_stats_show(struct seq_file *m, void *p)
|
static int svc_pool_stats_show(struct seq_file *m, void *p)
|
||||||
@ -1426,14 +1436,18 @@ static const struct seq_operations svc_pool_stats_seq_ops = {
|
|||||||
.show = svc_pool_stats_show,
|
.show = svc_pool_stats_show,
|
||||||
};
|
};
|
||||||
|
|
||||||
int svc_pool_stats_open(struct svc_serv *serv, struct file *file)
|
int svc_pool_stats_open(struct svc_info *info, struct file *file)
|
||||||
{
|
{
|
||||||
|
struct seq_file *seq;
|
||||||
int err;
|
int err;
|
||||||
|
|
||||||
err = seq_open(file, &svc_pool_stats_seq_ops);
|
err = seq_open(file, &svc_pool_stats_seq_ops);
|
||||||
if (!err)
|
if (err)
|
||||||
((struct seq_file *) file->private_data)->private = serv;
|
return err;
|
||||||
return err;
|
seq = file->private_data;
|
||||||
|
seq->private = info;
|
||||||
|
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
EXPORT_SYMBOL(svc_pool_stats_open);
|
EXPORT_SYMBOL(svc_pool_stats_open);
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user