nfsd: make NFSv4 lease time per net
Lease time is a part of NFSv4 state engine, which is constructed per network namespace. Signed-off-by: Stanislav Kinsbursky <skinsbursky@parallels.com> Signed-off-by: J. Bruce Fields <bfields@redhat.com>
This commit is contained in:
parent
864aee5c6f
commit
3d7337115d
|
@ -87,6 +87,8 @@ struct nfsd_net {
|
||||||
|
|
||||||
struct file *rec_file;
|
struct file *rec_file;
|
||||||
bool in_grace;
|
bool in_grace;
|
||||||
|
|
||||||
|
time_t nfsd4_lease;
|
||||||
};
|
};
|
||||||
|
|
||||||
extern int nfsd_net_id;
|
extern int nfsd_net_id;
|
||||||
|
|
|
@ -36,6 +36,7 @@
|
||||||
#include <linux/slab.h>
|
#include <linux/slab.h>
|
||||||
#include "nfsd.h"
|
#include "nfsd.h"
|
||||||
#include "state.h"
|
#include "state.h"
|
||||||
|
#include "netns.h"
|
||||||
|
|
||||||
#define NFSDDBG_FACILITY NFSDDBG_PROC
|
#define NFSDDBG_FACILITY NFSDDBG_PROC
|
||||||
|
|
||||||
|
@ -625,9 +626,10 @@ static const struct rpc_program cb_program = {
|
||||||
.pipe_dir_name = "nfsd4_cb",
|
.pipe_dir_name = "nfsd4_cb",
|
||||||
};
|
};
|
||||||
|
|
||||||
static int max_cb_time(void)
|
static int max_cb_time(struct net *net)
|
||||||
{
|
{
|
||||||
return max(nfsd4_lease/10, (time_t)1) * HZ;
|
struct nfsd_net *nn = net_generic(net, nfsd_net_id);
|
||||||
|
return max(nn->nfsd4_lease/10, (time_t)1) * HZ;
|
||||||
}
|
}
|
||||||
|
|
||||||
static struct rpc_cred *callback_cred;
|
static struct rpc_cred *callback_cred;
|
||||||
|
@ -659,7 +661,7 @@ static struct rpc_cred *get_backchannel_cred(struct nfs4_client *clp, struct rpc
|
||||||
static int setup_callback_client(struct nfs4_client *clp, struct nfs4_cb_conn *conn, struct nfsd4_session *ses)
|
static int setup_callback_client(struct nfs4_client *clp, struct nfs4_cb_conn *conn, struct nfsd4_session *ses)
|
||||||
{
|
{
|
||||||
struct rpc_timeout timeparms = {
|
struct rpc_timeout timeparms = {
|
||||||
.to_initval = max_cb_time(),
|
.to_initval = max_cb_time(clp->net),
|
||||||
.to_retries = 0,
|
.to_retries = 0,
|
||||||
};
|
};
|
||||||
struct rpc_create_args args = {
|
struct rpc_create_args args = {
|
||||||
|
|
|
@ -51,7 +51,6 @@
|
||||||
#define NFSDDBG_FACILITY NFSDDBG_PROC
|
#define NFSDDBG_FACILITY NFSDDBG_PROC
|
||||||
|
|
||||||
/* Globals */
|
/* Globals */
|
||||||
time_t nfsd4_lease = 90; /* default lease time */
|
|
||||||
time_t nfsd4_grace = 90;
|
time_t nfsd4_grace = 90;
|
||||||
|
|
||||||
#define all_ones {{~0,~0},~0}
|
#define all_ones {{~0,~0},~0}
|
||||||
|
@ -3184,7 +3183,7 @@ nfsd4_end_grace(struct nfsd_net *nn)
|
||||||
* to see the (possibly new, possibly shorter) lease time, we
|
* to see the (possibly new, possibly shorter) lease time, we
|
||||||
* can safely set the next grace time to the current lease time:
|
* can safely set the next grace time to the current lease time:
|
||||||
*/
|
*/
|
||||||
nfsd4_grace = nfsd4_lease;
|
nfsd4_grace = nn->nfsd4_lease;
|
||||||
}
|
}
|
||||||
|
|
||||||
static time_t
|
static time_t
|
||||||
|
@ -3194,9 +3193,9 @@ nfs4_laundromat(struct nfsd_net *nn)
|
||||||
struct nfs4_openowner *oo;
|
struct nfs4_openowner *oo;
|
||||||
struct nfs4_delegation *dp;
|
struct nfs4_delegation *dp;
|
||||||
struct list_head *pos, *next, reaplist;
|
struct list_head *pos, *next, reaplist;
|
||||||
time_t cutoff = get_seconds() - nfsd4_lease;
|
time_t cutoff = get_seconds() - nn->nfsd4_lease;
|
||||||
time_t t, clientid_val = nfsd4_lease;
|
time_t t, clientid_val = nn->nfsd4_lease;
|
||||||
time_t u, test_val = nfsd4_lease;
|
time_t u, test_val = nn->nfsd4_lease;
|
||||||
|
|
||||||
nfs4_lock_state();
|
nfs4_lock_state();
|
||||||
|
|
||||||
|
@ -3245,7 +3244,7 @@ nfs4_laundromat(struct nfsd_net *nn)
|
||||||
dp = list_entry (pos, struct nfs4_delegation, dl_recall_lru);
|
dp = list_entry (pos, struct nfs4_delegation, dl_recall_lru);
|
||||||
unhash_delegation(dp);
|
unhash_delegation(dp);
|
||||||
}
|
}
|
||||||
test_val = nfsd4_lease;
|
test_val = nn->nfsd4_lease;
|
||||||
list_for_each_safe(pos, next, &nn->close_lru) {
|
list_for_each_safe(pos, next, &nn->close_lru) {
|
||||||
oo = container_of(pos, struct nfs4_openowner, oo_close_lru);
|
oo = container_of(pos, struct nfs4_openowner, oo_close_lru);
|
||||||
if (time_after((unsigned long)oo->oo_time, (unsigned long)cutoff)) {
|
if (time_after((unsigned long)oo->oo_time, (unsigned long)cutoff)) {
|
||||||
|
|
|
@ -53,6 +53,7 @@
|
||||||
#include "vfs.h"
|
#include "vfs.h"
|
||||||
#include "state.h"
|
#include "state.h"
|
||||||
#include "cache.h"
|
#include "cache.h"
|
||||||
|
#include "netns.h"
|
||||||
|
|
||||||
#define NFSDDBG_FACILITY NFSDDBG_XDR
|
#define NFSDDBG_FACILITY NFSDDBG_XDR
|
||||||
|
|
||||||
|
@ -2052,6 +2053,7 @@ nfsd4_encode_fattr(struct svc_fh *fhp, struct svc_export *exp,
|
||||||
.mnt = exp->ex_path.mnt,
|
.mnt = exp->ex_path.mnt,
|
||||||
.dentry = dentry,
|
.dentry = dentry,
|
||||||
};
|
};
|
||||||
|
struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
|
||||||
|
|
||||||
BUG_ON(bmval1 & NFSD_WRITEONLY_ATTRS_WORD1);
|
BUG_ON(bmval1 & NFSD_WRITEONLY_ATTRS_WORD1);
|
||||||
BUG_ON(bmval0 & ~nfsd_suppattrs0(minorversion));
|
BUG_ON(bmval0 & ~nfsd_suppattrs0(minorversion));
|
||||||
|
@ -2212,7 +2214,7 @@ nfsd4_encode_fattr(struct svc_fh *fhp, struct svc_export *exp,
|
||||||
if (bmval0 & FATTR4_WORD0_LEASE_TIME) {
|
if (bmval0 & FATTR4_WORD0_LEASE_TIME) {
|
||||||
if ((buflen -= 4) < 0)
|
if ((buflen -= 4) < 0)
|
||||||
goto out_resource;
|
goto out_resource;
|
||||||
WRITE32(nfsd4_lease);
|
WRITE32(nn->nfsd4_lease);
|
||||||
}
|
}
|
||||||
if (bmval0 & FATTR4_WORD0_RDATTR_ERROR) {
|
if (bmval0 & FATTR4_WORD0_RDATTR_ERROR) {
|
||||||
if ((buflen -= 4) < 0)
|
if ((buflen -= 4) < 0)
|
||||||
|
|
|
@ -909,7 +909,8 @@ static ssize_t nfsd4_write_time(struct file *file, char *buf, size_t size, time_
|
||||||
*/
|
*/
|
||||||
static ssize_t write_leasetime(struct file *file, char *buf, size_t size)
|
static ssize_t write_leasetime(struct file *file, char *buf, size_t size)
|
||||||
{
|
{
|
||||||
return nfsd4_write_time(file, buf, size, &nfsd4_lease);
|
struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
|
||||||
|
return nfsd4_write_time(file, buf, size, &nn->nfsd4_lease);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -1060,6 +1061,7 @@ int nfsd_net_id;
|
||||||
static __net_init int nfsd_init_net(struct net *net)
|
static __net_init int nfsd_init_net(struct net *net)
|
||||||
{
|
{
|
||||||
int retval;
|
int retval;
|
||||||
|
struct nfsd_net *nn = net_generic(net, nfsd_net_id);
|
||||||
|
|
||||||
retval = nfsd_export_init(net);
|
retval = nfsd_export_init(net);
|
||||||
if (retval)
|
if (retval)
|
||||||
|
@ -1067,6 +1069,7 @@ static __net_init int nfsd_init_net(struct net *net)
|
||||||
retval = nfsd_idmap_init(net);
|
retval = nfsd_idmap_init(net);
|
||||||
if (retval)
|
if (retval)
|
||||||
goto out_idmap_error;
|
goto out_idmap_error;
|
||||||
|
nn->nfsd4_lease = 90; /* default lease time */
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
out_idmap_error:
|
out_idmap_error:
|
||||||
|
|
|
@ -276,7 +276,6 @@ extern struct timeval nfssvc_boot;
|
||||||
|
|
||||||
#ifdef CONFIG_NFSD_V4
|
#ifdef CONFIG_NFSD_V4
|
||||||
|
|
||||||
extern time_t nfsd4_lease;
|
|
||||||
extern time_t nfsd4_grace;
|
extern time_t nfsd4_grace;
|
||||||
|
|
||||||
/* before processing a COMPOUND operation, we have to check that there
|
/* before processing a COMPOUND operation, we have to check that there
|
||||||
|
|
Loading…
Reference in New Issue