Proxmox-Port/linux-loongson
1
0
Fork 0
mirror of https://git.kernel.org/pub/scm/linux/kernel/git/chenhuacai/linux-loongson synced 2025-09-04 02:13:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

nfsd: allow passing in array of thread counts via netlink

Browse Source 
Now that nfsd_svc can handle an array of thread counts, fix up the
netlink threads interface to construct one from the netlink call
and pass it through so we can start a pooled server the same way we
would start a normal one.

Note that any unspecified values in the array are considered zeroes,
so it's possible to shut down a pooled server by passing in a short
array that has only zeros, or even an empty array.

Signed-off-by: Jeff Layton <jlayton@kernel.org>
Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
This commit is contained in:
Jeff Layton 2024-06-13 14:34:32 -04:00 committed by Chuck Lever
parent b4d8f22891
commit 7f5c330b26
2 changed files with 31 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
fs/nfsd/nfsctl.c
View File

@ -1645,7 +1645,7 @@ int nfsd_nl_rpc_status_get_dumpit(struct sk_buff *skb,
*/ */
int nfsd_nl_threads_set_doit(struct sk_buff *skb, struct genl_info *info) int nfsd_nl_threads_set_doit(struct sk_buff *skb, struct genl_info *info)
{ {
int nthreads = 0, count = 0, nrpools, ret = -EOPNOTSUPP, rem; int *nthreads, count = 0, nrpools, i, ret = -EOPNOTSUPP, rem;
struct net *net = genl_info_net(info); struct net *net = genl_info_net(info);
struct nfsd_net *nn = net_generic(net, nfsd_net_id); struct nfsd_net *nn = net_generic(net, nfsd_net_id);
const struct nlattr *attr; const struct nlattr *attr;
@ -1662,15 +1662,22 @@ int nfsd_nl_threads_set_doit(struct sk_buff *skb, struct genl_info *info)
mutex_lock(&nfsd_mutex); mutex_lock(&nfsd_mutex);
nrpools = nfsd_nrpools(net); nrpools = max(count, nfsd_nrpools(net));
if (nrpools && count > nrpools) nthreads = kcalloc(nrpools, sizeof(int), GFP_KERNEL);
count = nrpools; if (!nthreads) {
ret = -ENOMEM;
/* XXX: make this handle non-global pool-modes */
if (count > 1)
goto out_unlock; goto out_unlock;
}
i = 0;
nlmsg_for_each_attr(attr, info->nlhdr, GENL_HDRLEN, rem) {
if (nla_type(attr) == NFSD_A_SERVER_THREADS) {
nthreads[i++] = nla_get_u32(attr);
if (i >= nrpools)
break;
}
}
nthreads = nla_get_u32(info->attrs[NFSD_A_SERVER_THREADS]);
if (info->attrs[NFSD_A_SERVER_GRACETIME] || if (info->attrs[NFSD_A_SERVER_GRACETIME] ||
info->attrs[NFSD_A_SERVER_LEASETIME] || info->attrs[NFSD_A_SERVER_LEASETIME] ||
info->attrs[NFSD_A_SERVER_SCOPE]) { info->attrs[NFSD_A_SERVER_SCOPE]) {
@ -1704,12 +1711,13 @@ int nfsd_nl_threads_set_doit(struct sk_buff *skb, struct genl_info *info)
scope = nla_data(attr); scope = nla_data(attr);
} }
ret = nfsd_svc(1, &nthreads, net, get_current_cred(), scope); ret = nfsd_svc(nrpools, nthreads, net, get_current_cred(), scope);
if (ret > 0)
ret = 0;
out_unlock: out_unlock:
mutex_unlock(&nfsd_mutex); mutex_unlock(&nfsd_mutex);
kfree(nthreads);
return ret == nthreads ? 0 : ret; return ret;
} }
/** /**

12
fs/nfsd/nfssvc.c
View File

@ -769,8 +769,18 @@ int nfsd_set_nrthreads(int n, int *nthreads, struct net *net)
&nn->nfsd_serv->sv_pools[i], &nn->nfsd_serv->sv_pools[i],
nthreads[i]); nthreads[i]);
if (err) if (err)
break; goto out;
} }
/* Anything undefined in array is considered to be 0 */
for (i = n; i < nn->nfsd_serv->sv_nrpools; ++i) {
err = svc_set_num_threads(nn->nfsd_serv,
&nn->nfsd_serv->sv_pools[i],
0);
if (err)
goto out;
}
out:
return err; return err;
} }