aboutsummaryrefslogtreecommitdiffstats
path: root/fs/nfsd
diff options
context:
space:
mode:
Diffstat (limited to 'fs/nfsd')
-rw-r--r--fs/nfsd/nfs3xdr.c59
-rw-r--r--fs/nfsd/nfs4callback.c89
-rw-r--r--fs/nfsd/nfs4idmap.c8
-rw-r--r--fs/nfsd/nfs4proc.c4
-rw-r--r--fs/nfsd/nfs4state.c200
-rw-r--r--fs/nfsd/nfs4xdr.c38
-rw-r--r--fs/nfsd/nfsctl.c7
-rw-r--r--fs/nfsd/nfssvc.c8
-rw-r--r--fs/nfsd/nfsxdr.c4
-rw-r--r--fs/nfsd/vfs.c43
10 files changed, 213 insertions, 247 deletions
diff --git a/fs/nfsd/nfs3xdr.c b/fs/nfsd/nfs3xdr.c
index 10f6e7dcf633..2d116d2298f8 100644
--- a/fs/nfsd/nfs3xdr.c
+++ b/fs/nfsd/nfs3xdr.c
@@ -174,9 +174,6 @@ static __be32 *
174encode_fattr3(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp, 174encode_fattr3(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp,
175 struct kstat *stat) 175 struct kstat *stat)
176{ 176{
177 struct dentry *dentry = fhp->fh_dentry;
178 struct timespec time;
179
180 *p++ = htonl(nfs3_ftypes[(stat->mode & S_IFMT) >> 12]); 177 *p++ = htonl(nfs3_ftypes[(stat->mode & S_IFMT) >> 12]);
181 *p++ = htonl((u32) stat->mode); 178 *p++ = htonl((u32) stat->mode);
182 *p++ = htonl((u32) stat->nlink); 179 *p++ = htonl((u32) stat->nlink);
@@ -191,10 +188,9 @@ encode_fattr3(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp,
191 *p++ = htonl((u32) MAJOR(stat->rdev)); 188 *p++ = htonl((u32) MAJOR(stat->rdev));
192 *p++ = htonl((u32) MINOR(stat->rdev)); 189 *p++ = htonl((u32) MINOR(stat->rdev));
193 p = encode_fsid(p, fhp); 190 p = encode_fsid(p, fhp);
194 p = xdr_encode_hyper(p, (u64) stat->ino); 191 p = xdr_encode_hyper(p, stat->ino);
195 p = encode_time3(p, &stat->atime); 192 p = encode_time3(p, &stat->atime);
196 lease_get_mtime(dentry->d_inode, &time); 193 p = encode_time3(p, &stat->mtime);
197 p = encode_time3(p, &time);
198 p = encode_time3(p, &stat->ctime); 194 p = encode_time3(p, &stat->ctime);
199 195
200 return p; 196 return p;
@@ -203,31 +199,9 @@ encode_fattr3(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp,
203static __be32 * 199static __be32 *
204encode_saved_post_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp) 200encode_saved_post_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
205{ 201{
206 struct inode *inode = fhp->fh_dentry->d_inode;
207
208 /* Attributes to follow */ 202 /* Attributes to follow */
209 *p++ = xdr_one; 203 *p++ = xdr_one;
210 204 return encode_fattr3(rqstp, p, fhp, &fhp->fh_post_attr);
211 *p++ = htonl(nfs3_ftypes[(fhp->fh_post_mode & S_IFMT) >> 12]);
212 *p++ = htonl((u32) fhp->fh_post_mode);
213 *p++ = htonl((u32) fhp->fh_post_nlink);
214 *p++ = htonl((u32) nfsd_ruid(rqstp, fhp->fh_post_uid));
215 *p++ = htonl((u32) nfsd_rgid(rqstp, fhp->fh_post_gid));
216 if (S_ISLNK(fhp->fh_post_mode) && fhp->fh_post_size > NFS3_MAXPATHLEN) {
217 p = xdr_encode_hyper(p, (u64) NFS3_MAXPATHLEN);
218 } else {
219 p = xdr_encode_hyper(p, (u64) fhp->fh_post_size);
220 }
221 p = xdr_encode_hyper(p, ((u64)fhp->fh_post_blocks) << 9);
222 *p++ = fhp->fh_post_rdev[0];
223 *p++ = fhp->fh_post_rdev[1];
224 p = encode_fsid(p, fhp);
225 p = xdr_encode_hyper(p, (u64) inode->i_ino);
226 p = encode_time3(p, &fhp->fh_post_atime);
227 p = encode_time3(p, &fhp->fh_post_mtime);
228 p = encode_time3(p, &fhp->fh_post_ctime);
229
230 return p;
231} 205}
232 206
233/* 207/*
@@ -246,6 +220,7 @@ encode_post_op_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
246 err = vfs_getattr(fhp->fh_export->ex_mnt, dentry, &stat); 220 err = vfs_getattr(fhp->fh_export->ex_mnt, dentry, &stat);
247 if (!err) { 221 if (!err) {
248 *p++ = xdr_one; /* attributes follow */ 222 *p++ = xdr_one; /* attributes follow */
223 lease_get_mtime(dentry->d_inode, &stat.mtime);
249 return encode_fattr3(rqstp, p, fhp, &stat); 224 return encode_fattr3(rqstp, p, fhp, &stat);
250 } 225 }
251 } 226 }
@@ -284,6 +259,23 @@ encode_wcc_data(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
284 return encode_post_op_attr(rqstp, p, fhp); 259 return encode_post_op_attr(rqstp, p, fhp);
285} 260}
286 261
262/*
263 * Fill in the post_op attr for the wcc data
264 */
265void fill_post_wcc(struct svc_fh *fhp)
266{
267 int err;
268
269 if (fhp->fh_post_saved)
270 printk("nfsd: inode locked twice during operation.\n");
271
272 err = vfs_getattr(fhp->fh_export->ex_mnt, fhp->fh_dentry,
273 &fhp->fh_post_attr);
274 if (err)
275 fhp->fh_post_saved = 0;
276 else
277 fhp->fh_post_saved = 1;
278}
287 279
288/* 280/*
289 * XDR decode functions 281 * XDR decode functions
@@ -643,8 +635,11 @@ int
643nfs3svc_encode_attrstat(struct svc_rqst *rqstp, __be32 *p, 635nfs3svc_encode_attrstat(struct svc_rqst *rqstp, __be32 *p,
644 struct nfsd3_attrstat *resp) 636 struct nfsd3_attrstat *resp)
645{ 637{
646 if (resp->status == 0) 638 if (resp->status == 0) {
639 lease_get_mtime(resp->fh.fh_dentry->d_inode,
640 &resp->stat.mtime);
647 p = encode_fattr3(rqstp, p, &resp->fh, &resp->stat); 641 p = encode_fattr3(rqstp, p, &resp->fh, &resp->stat);
642 }
648 return xdr_ressize_check(rqstp, p); 643 return xdr_ressize_check(rqstp, p);
649} 644}
650 645
@@ -802,7 +797,7 @@ nfs3svc_encode_readdirres(struct svc_rqst *rqstp, __be32 *p,
802 797
803static __be32 * 798static __be32 *
804encode_entry_baggage(struct nfsd3_readdirres *cd, __be32 *p, const char *name, 799encode_entry_baggage(struct nfsd3_readdirres *cd, __be32 *p, const char *name,
805 int namlen, ino_t ino) 800 int namlen, u64 ino)
806{ 801{
807 *p++ = xdr_one; /* mark entry present */ 802 *p++ = xdr_one; /* mark entry present */
808 p = xdr_encode_hyper(p, ino); /* file id */ 803 p = xdr_encode_hyper(p, ino); /* file id */
@@ -873,7 +868,7 @@ compose_entry_fh(struct nfsd3_readdirres *cd, struct svc_fh *fhp,
873#define NFS3_ENTRYPLUS_BAGGAGE (1 + 21 + 1 + (NFS3_FHSIZE >> 2)) 868#define NFS3_ENTRYPLUS_BAGGAGE (1 + 21 + 1 + (NFS3_FHSIZE >> 2))
874static int 869static int
875encode_entry(struct readdir_cd *ccd, const char *name, int namlen, 870encode_entry(struct readdir_cd *ccd, const char *name, int namlen,
876 loff_t offset, ino_t ino, unsigned int d_type, int plus) 871 loff_t offset, u64 ino, unsigned int d_type, int plus)
877{ 872{
878 struct nfsd3_readdirres *cd = container_of(ccd, struct nfsd3_readdirres, 873 struct nfsd3_readdirres *cd = container_of(ccd, struct nfsd3_readdirres,
879 common); 874 common);
diff --git a/fs/nfsd/nfs4callback.c b/fs/nfsd/nfs4callback.c
index 31d6633c7fe4..9d536a8cb379 100644
--- a/fs/nfsd/nfs4callback.c
+++ b/fs/nfsd/nfs4callback.c
@@ -39,6 +39,7 @@
39#include <linux/errno.h> 39#include <linux/errno.h>
40#include <linux/delay.h> 40#include <linux/delay.h>
41#include <linux/sched.h> 41#include <linux/sched.h>
42#include <linux/kthread.h>
42#include <linux/sunrpc/xdr.h> 43#include <linux/sunrpc/xdr.h>
43#include <linux/sunrpc/svc.h> 44#include <linux/sunrpc/svc.h>
44#include <linux/sunrpc/clnt.h> 45#include <linux/sunrpc/clnt.h>
@@ -343,26 +344,28 @@ static struct rpc_version * nfs_cb_version[] = {
343 &nfs_cb_version4, 344 &nfs_cb_version4,
344}; 345};
345 346
346/* 347/* Reference counting, callback cleanup, etc., all look racy as heck.
347 * Use the SETCLIENTID credential 348 * And why is cb_set an atomic? */
348 */ 349
349static struct rpc_cred * 350static int do_probe_callback(void *data)
350nfsd4_lookupcred(struct nfs4_client *clp, int taskflags)
351{ 351{
352 struct auth_cred acred; 352 struct nfs4_client *clp = data;
353 struct rpc_clnt *clnt = clp->cl_callback.cb_client; 353 struct nfs4_callback *cb = &clp->cl_callback;
354 struct rpc_cred *ret; 354 struct rpc_message msg = {
355 355 .rpc_proc = &nfs4_cb_procedures[NFSPROC4_CLNT_CB_NULL],
356 get_group_info(clp->cl_cred.cr_group_info); 356 .rpc_argp = clp,
357 acred.uid = clp->cl_cred.cr_uid; 357 };
358 acred.gid = clp->cl_cred.cr_gid; 358 int status;
359 acred.group_info = clp->cl_cred.cr_group_info; 359
360 360 status = rpc_call_sync(cb->cb_client, &msg, RPC_TASK_SOFT);
361 dprintk("NFSD: looking up %s cred\n", 361
362 clnt->cl_auth->au_ops->au_name); 362 if (status) {
363 ret = rpcauth_lookup_credcache(clnt->cl_auth, &acred, taskflags); 363 rpc_shutdown_client(cb->cb_client);
364 put_group_info(clp->cl_cred.cr_group_info); 364 cb->cb_client = NULL;
365 return ret; 365 } else
366 atomic_set(&cb->cb_set, 1);
367 put_nfs4_client(clp);
368 return 0;
366} 369}
367 370
368/* 371/*
@@ -390,11 +393,7 @@ nfsd4_probe_callback(struct nfs4_client *clp)
390 .authflavor = RPC_AUTH_UNIX, /* XXX: need AUTH_GSS... */ 393 .authflavor = RPC_AUTH_UNIX, /* XXX: need AUTH_GSS... */
391 .flags = (RPC_CLNT_CREATE_NOPING), 394 .flags = (RPC_CLNT_CREATE_NOPING),
392 }; 395 };
393 struct rpc_message msg = { 396 struct task_struct *t;
394 .rpc_proc = &nfs4_cb_procedures[NFSPROC4_CLNT_CB_NULL],
395 .rpc_argp = clp,
396 };
397 int status;
398 397
399 if (atomic_read(&cb->cb_set)) 398 if (atomic_read(&cb->cb_set))
400 return; 399 return;
@@ -426,16 +425,11 @@ nfsd4_probe_callback(struct nfs4_client *clp)
426 /* the task holds a reference to the nfs4_client struct */ 425 /* the task holds a reference to the nfs4_client struct */
427 atomic_inc(&clp->cl_count); 426 atomic_inc(&clp->cl_count);
428 427
429 msg.rpc_cred = nfsd4_lookupcred(clp,0); 428 t = kthread_run(do_probe_callback, clp, "nfs4_cb_probe");
430 if (IS_ERR(msg.rpc_cred))
431 goto out_release_clp;
432 status = rpc_call_async(cb->cb_client, &msg, RPC_TASK_ASYNC, &nfs4_cb_null_ops, NULL);
433 put_rpccred(msg.rpc_cred);
434 429
435 if (status != 0) { 430 if (IS_ERR(t))
436 dprintk("NFSD: asynchronous NFSPROC4_CB_NULL failed!\n");
437 goto out_release_clp; 431 goto out_release_clp;
438 } 432
439 return; 433 return;
440 434
441out_release_clp: 435out_release_clp:
@@ -447,30 +441,6 @@ out_err:
447 (int)clp->cl_name.len, clp->cl_name.data); 441 (int)clp->cl_name.len, clp->cl_name.data);
448} 442}
449 443
450static void
451nfs4_cb_null(struct rpc_task *task, void *dummy)
452{
453 struct nfs4_client *clp = (struct nfs4_client *)task->tk_msg.rpc_argp;
454 struct nfs4_callback *cb = &clp->cl_callback;
455 __be32 addr = htonl(cb->cb_addr);
456
457 dprintk("NFSD: nfs4_cb_null task->tk_status %d\n", task->tk_status);
458
459 if (task->tk_status < 0) {
460 dprintk("NFSD: callback establishment to client %.*s failed\n",
461 (int)clp->cl_name.len, clp->cl_name.data);
462 goto out;
463 }
464 atomic_set(&cb->cb_set, 1);
465 dprintk("NFSD: callback set to client %u.%u.%u.%u\n", NIPQUAD(addr));
466out:
467 put_nfs4_client(clp);
468}
469
470static const struct rpc_call_ops nfs4_cb_null_ops = {
471 .rpc_call_done = nfs4_cb_null,
472};
473
474/* 444/*
475 * called with dp->dl_count inc'ed. 445 * called with dp->dl_count inc'ed.
476 * nfs4_lock_state() may or may not have been called. 446 * nfs4_lock_state() may or may not have been called.
@@ -491,10 +461,6 @@ nfsd4_cb_recall(struct nfs4_delegation *dp)
491 if ((!atomic_read(&clp->cl_callback.cb_set)) || !clnt) 461 if ((!atomic_read(&clp->cl_callback.cb_set)) || !clnt)
492 return; 462 return;
493 463
494 msg.rpc_cred = nfsd4_lookupcred(clp, 0);
495 if (IS_ERR(msg.rpc_cred))
496 goto out;
497
498 cbr->cbr_trunc = 0; /* XXX need to implement truncate optimization */ 464 cbr->cbr_trunc = 0; /* XXX need to implement truncate optimization */
499 cbr->cbr_dp = dp; 465 cbr->cbr_dp = dp;
500 466
@@ -515,13 +481,12 @@ nfsd4_cb_recall(struct nfs4_delegation *dp)
515 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFT); 481 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFT);
516 } 482 }
517out_put_cred: 483out_put_cred:
518 put_rpccred(msg.rpc_cred);
519out:
520 if (status == -EIO) 484 if (status == -EIO)
521 atomic_set(&clp->cl_callback.cb_set, 0); 485 atomic_set(&clp->cl_callback.cb_set, 0);
522 /* Success or failure, now we're either waiting for lease expiration 486 /* Success or failure, now we're either waiting for lease expiration
523 * or deleg_return. */ 487 * or deleg_return. */
524 dprintk("NFSD: nfs4_cb_recall: dp %p dl_flock %p dl_count %d\n",dp, dp->dl_flock, atomic_read(&dp->dl_count)); 488 dprintk("NFSD: nfs4_cb_recall: dp %p dl_flock %p dl_count %d\n",dp, dp->dl_flock, atomic_read(&dp->dl_count));
489 put_nfs4_client(clp);
525 nfs4_put_delegation(dp); 490 nfs4_put_delegation(dp);
526 return; 491 return;
527} 492}
diff --git a/fs/nfsd/nfs4idmap.c b/fs/nfsd/nfs4idmap.c
index 2ccffde81b84..4c0c683ce07a 100644
--- a/fs/nfsd/nfs4idmap.c
+++ b/fs/nfsd/nfs4idmap.c
@@ -207,6 +207,7 @@ idtoname_parse(struct cache_detail *cd, char *buf, int buflen)
207{ 207{
208 struct ent ent, *res; 208 struct ent ent, *res;
209 char *buf1, *bp; 209 char *buf1, *bp;
210 int len;
210 int error = -EINVAL; 211 int error = -EINVAL;
211 212
212 if (buf[buflen - 1] != '\n') 213 if (buf[buflen - 1] != '\n')
@@ -248,10 +249,11 @@ idtoname_parse(struct cache_detail *cd, char *buf, int buflen)
248 goto out; 249 goto out;
249 250
250 /* Name */ 251 /* Name */
251 error = qword_get(&buf, buf1, PAGE_SIZE); 252 error = -EINVAL;
252 if (error == -EINVAL) 253 len = qword_get(&buf, buf1, PAGE_SIZE);
254 if (len < 0)
253 goto out; 255 goto out;
254 if (error == -ENOENT) 256 if (len == 0)
255 set_bit(CACHE_NEGATIVE, &ent.h.flags); 257 set_bit(CACHE_NEGATIVE, &ent.h.flags);
256 else { 258 else {
257 if (error >= IDMAP_NAMESZ) { 259 if (error >= IDMAP_NAMESZ) {
diff --git a/fs/nfsd/nfs4proc.c b/fs/nfsd/nfs4proc.c
index 29b7e63cb32c..18ead1790bb3 100644
--- a/fs/nfsd/nfs4proc.c
+++ b/fs/nfsd/nfs4proc.c
@@ -238,12 +238,12 @@ nfsd4_open(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
238 break; 238 break;
239 case NFS4_OPEN_CLAIM_DELEGATE_PREV: 239 case NFS4_OPEN_CLAIM_DELEGATE_PREV:
240 open->op_stateowner->so_confirmed = 1; 240 open->op_stateowner->so_confirmed = 1;
241 printk("NFSD: unsupported OPEN claim type %d\n", 241 dprintk("NFSD: unsupported OPEN claim type %d\n",
242 open->op_claim_type); 242 open->op_claim_type);
243 status = nfserr_notsupp; 243 status = nfserr_notsupp;
244 goto out; 244 goto out;
245 default: 245 default:
246 printk("NFSD: Invalid OPEN claim type %d\n", 246 dprintk("NFSD: Invalid OPEN claim type %d\n",
247 open->op_claim_type); 247 open->op_claim_type);
248 status = nfserr_inval; 248 status = nfserr_inval;
249 goto out; 249 goto out;
diff --git a/fs/nfsd/nfs4state.c b/fs/nfsd/nfs4state.c
index 3c028b9c6e0e..31673cd251c3 100644
--- a/fs/nfsd/nfs4state.c
+++ b/fs/nfsd/nfs4state.c
@@ -358,9 +358,22 @@ alloc_client(struct xdr_netobj name)
358 return clp; 358 return clp;
359} 359}
360 360
361static void
362shutdown_callback_client(struct nfs4_client *clp)
363{
364 struct rpc_clnt *clnt = clp->cl_callback.cb_client;
365
366 /* shutdown rpc client, ending any outstanding recall rpcs */
367 if (clnt) {
368 clp->cl_callback.cb_client = NULL;
369 rpc_shutdown_client(clnt);
370 }
371}
372
361static inline void 373static inline void
362free_client(struct nfs4_client *clp) 374free_client(struct nfs4_client *clp)
363{ 375{
376 shutdown_callback_client(clp);
364 if (clp->cl_cred.cr_group_info) 377 if (clp->cl_cred.cr_group_info)
365 put_group_info(clp->cl_cred.cr_group_info); 378 put_group_info(clp->cl_cred.cr_group_info);
366 kfree(clp->cl_name.data); 379 kfree(clp->cl_name.data);
@@ -375,18 +388,6 @@ put_nfs4_client(struct nfs4_client *clp)
375} 388}
376 389
377static void 390static void
378shutdown_callback_client(struct nfs4_client *clp)
379{
380 struct rpc_clnt *clnt = clp->cl_callback.cb_client;
381
382 /* shutdown rpc client, ending any outstanding recall rpcs */
383 if (clnt) {
384 clp->cl_callback.cb_client = NULL;
385 rpc_shutdown_client(clnt);
386 }
387}
388
389static void
390expire_client(struct nfs4_client *clp) 391expire_client(struct nfs4_client *clp)
391{ 392{
392 struct nfs4_stateowner *sop; 393 struct nfs4_stateowner *sop;
@@ -396,8 +397,6 @@ expire_client(struct nfs4_client *clp)
396 dprintk("NFSD: expire_client cl_count %d\n", 397 dprintk("NFSD: expire_client cl_count %d\n",
397 atomic_read(&clp->cl_count)); 398 atomic_read(&clp->cl_count));
398 399
399 shutdown_callback_client(clp);
400
401 INIT_LIST_HEAD(&reaplist); 400 INIT_LIST_HEAD(&reaplist);
402 spin_lock(&recall_lock); 401 spin_lock(&recall_lock);
403 while (!list_empty(&clp->cl_delegations)) { 402 while (!list_empty(&clp->cl_delegations)) {
@@ -462,26 +461,28 @@ copy_cred(struct svc_cred *target, struct svc_cred *source) {
462} 461}
463 462
464static inline int 463static inline int
465same_name(const char *n1, const char *n2) { 464same_name(const char *n1, const char *n2)
465{
466 return 0 == memcmp(n1, n2, HEXDIR_LEN); 466 return 0 == memcmp(n1, n2, HEXDIR_LEN);
467} 467}
468 468
469static int 469static int
470cmp_verf(nfs4_verifier *v1, nfs4_verifier *v2) { 470same_verf(nfs4_verifier *v1, nfs4_verifier *v2)
471 return(!memcmp(v1->data,v2->data,sizeof(v1->data))); 471{
472 return 0 == memcmp(v1->data, v2->data, sizeof(v1->data));
472} 473}
473 474
474static int 475static int
475cmp_clid(clientid_t * cl1, clientid_t * cl2) { 476same_clid(clientid_t *cl1, clientid_t *cl2)
476 return((cl1->cl_boot == cl2->cl_boot) && 477{
477 (cl1->cl_id == cl2->cl_id)); 478 return (cl1->cl_boot == cl2->cl_boot) && (cl1->cl_id == cl2->cl_id);
478} 479}
479 480
480/* XXX what about NGROUP */ 481/* XXX what about NGROUP */
481static int 482static int
482cmp_creds(struct svc_cred *cr1, struct svc_cred *cr2){ 483same_creds(struct svc_cred *cr1, struct svc_cred *cr2)
483 return(cr1->cr_uid == cr2->cr_uid); 484{
484 485 return cr1->cr_uid == cr2->cr_uid;
485} 486}
486 487
487static void 488static void
@@ -507,7 +508,7 @@ check_name(struct xdr_netobj name) {
507 if (name.len == 0) 508 if (name.len == 0)
508 return 0; 509 return 0;
509 if (name.len > NFS4_OPAQUE_LIMIT) { 510 if (name.len > NFS4_OPAQUE_LIMIT) {
510 printk("NFSD: check_name: name too long(%d)!\n", name.len); 511 dprintk("NFSD: check_name: name too long(%d)!\n", name.len);
511 return 0; 512 return 0;
512 } 513 }
513 return 1; 514 return 1;
@@ -546,7 +547,7 @@ find_confirmed_client(clientid_t *clid)
546 unsigned int idhashval = clientid_hashval(clid->cl_id); 547 unsigned int idhashval = clientid_hashval(clid->cl_id);
547 548
548 list_for_each_entry(clp, &conf_id_hashtbl[idhashval], cl_idhash) { 549 list_for_each_entry(clp, &conf_id_hashtbl[idhashval], cl_idhash) {
549 if (cmp_clid(&clp->cl_clientid, clid)) 550 if (same_clid(&clp->cl_clientid, clid))
550 return clp; 551 return clp;
551 } 552 }
552 return NULL; 553 return NULL;
@@ -559,7 +560,7 @@ find_unconfirmed_client(clientid_t *clid)
559 unsigned int idhashval = clientid_hashval(clid->cl_id); 560 unsigned int idhashval = clientid_hashval(clid->cl_id);
560 561
561 list_for_each_entry(clp, &unconf_id_hashtbl[idhashval], cl_idhash) { 562 list_for_each_entry(clp, &unconf_id_hashtbl[idhashval], cl_idhash) {
562 if (cmp_clid(&clp->cl_clientid, clid)) 563 if (same_clid(&clp->cl_clientid, clid))
563 return clp; 564 return clp;
564 } 565 }
565 return NULL; 566 return NULL;
@@ -753,7 +754,7 @@ nfsd4_setclientid(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
753 * or different ip_address 754 * or different ip_address
754 */ 755 */
755 status = nfserr_clid_inuse; 756 status = nfserr_clid_inuse;
756 if (!cmp_creds(&conf->cl_cred, &rqstp->rq_cred) 757 if (!same_creds(&conf->cl_cred, &rqstp->rq_cred)
757 || conf->cl_addr != sin->sin_addr.s_addr) { 758 || conf->cl_addr != sin->sin_addr.s_addr) {
758 dprintk("NFSD: setclientid: string in use by client" 759 dprintk("NFSD: setclientid: string in use by client"
759 "at %u.%u.%u.%u\n", NIPQUAD(conf->cl_addr)); 760 "at %u.%u.%u.%u\n", NIPQUAD(conf->cl_addr));
@@ -772,14 +773,8 @@ nfsd4_setclientid(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
772 new = create_client(clname, dname); 773 new = create_client(clname, dname);
773 if (new == NULL) 774 if (new == NULL)
774 goto out; 775 goto out;
775 copy_verf(new, &clverifier);
776 new->cl_addr = sin->sin_addr.s_addr;
777 copy_cred(&new->cl_cred,&rqstp->rq_cred);
778 gen_clid(new); 776 gen_clid(new);
779 gen_confirm(new); 777 } else if (same_verf(&conf->cl_verifier, &clverifier)) {
780 gen_callback(new, setclid);
781 add_to_unconfirmed(new, strhashval);
782 } else if (cmp_verf(&conf->cl_verifier, &clverifier)) {
783 /* 778 /*
784 * CASE 1: 779 * CASE 1:
785 * cl_name match, confirmed, principal match 780 * cl_name match, confirmed, principal match
@@ -804,13 +799,7 @@ nfsd4_setclientid(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
804 new = create_client(clname, dname); 799 new = create_client(clname, dname);
805 if (new == NULL) 800 if (new == NULL)
806 goto out; 801 goto out;
807 copy_verf(new,&conf->cl_verifier);
808 new->cl_addr = sin->sin_addr.s_addr;
809 copy_cred(&new->cl_cred,&rqstp->rq_cred);
810 copy_clid(new, conf); 802 copy_clid(new, conf);
811 gen_confirm(new);
812 gen_callback(new, setclid);
813 add_to_unconfirmed(new,strhashval);
814 } else if (!unconf) { 803 } else if (!unconf) {
815 /* 804 /*
816 * CASE 2: 805 * CASE 2:
@@ -823,14 +812,8 @@ nfsd4_setclientid(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
823 new = create_client(clname, dname); 812 new = create_client(clname, dname);
824 if (new == NULL) 813 if (new == NULL)
825 goto out; 814 goto out;
826 copy_verf(new,&clverifier);
827 new->cl_addr = sin->sin_addr.s_addr;
828 copy_cred(&new->cl_cred,&rqstp->rq_cred);
829 gen_clid(new); 815 gen_clid(new);
830 gen_confirm(new); 816 } else if (!same_verf(&conf->cl_confirm, &unconf->cl_confirm)) {
831 gen_callback(new, setclid);
832 add_to_unconfirmed(new, strhashval);
833 } else if (!cmp_verf(&conf->cl_confirm, &unconf->cl_confirm)) {
834 /* 817 /*
835 * CASE3: 818 * CASE3:
836 * confirmed found (name, principal match) 819 * confirmed found (name, principal match)
@@ -850,19 +833,19 @@ nfsd4_setclientid(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
850 new = create_client(clname, dname); 833 new = create_client(clname, dname);
851 if (new == NULL) 834 if (new == NULL)
852 goto out; 835 goto out;
853 copy_verf(new,&clverifier);
854 new->cl_addr = sin->sin_addr.s_addr;
855 copy_cred(&new->cl_cred,&rqstp->rq_cred);
856 gen_clid(new); 836 gen_clid(new);
857 gen_confirm(new);
858 gen_callback(new, setclid);
859 add_to_unconfirmed(new, strhashval);
860 } else { 837 } else {
861 /* No cases hit !!! */ 838 /* No cases hit !!! */
862 status = nfserr_inval; 839 status = nfserr_inval;
863 goto out; 840 goto out;
864 841
865 } 842 }
843 copy_verf(new, &clverifier);
844 new->cl_addr = sin->sin_addr.s_addr;
845 copy_cred(&new->cl_cred, &rqstp->rq_cred);
846 gen_confirm(new);
847 gen_callback(new, setclid);
848 add_to_unconfirmed(new, strhashval);
866 setclid->se_clientid.cl_boot = new->cl_clientid.cl_boot; 849 setclid->se_clientid.cl_boot = new->cl_clientid.cl_boot;
867 setclid->se_clientid.cl_id = new->cl_clientid.cl_id; 850 setclid->se_clientid.cl_id = new->cl_clientid.cl_id;
868 memcpy(setclid->se_confirm.data, new->cl_confirm.data, sizeof(setclid->se_confirm.data)); 851 memcpy(setclid->se_confirm.data, new->cl_confirm.data, sizeof(setclid->se_confirm.data));
@@ -910,16 +893,16 @@ nfsd4_setclientid_confirm(struct svc_rqst *rqstp,
910 goto out; 893 goto out;
911 894
912 if ((conf && unconf) && 895 if ((conf && unconf) &&
913 (cmp_verf(&unconf->cl_confirm, &confirm)) && 896 (same_verf(&unconf->cl_confirm, &confirm)) &&
914 (cmp_verf(&conf->cl_verifier, &unconf->cl_verifier)) && 897 (same_verf(&conf->cl_verifier, &unconf->cl_verifier)) &&
915 (same_name(conf->cl_recdir,unconf->cl_recdir)) && 898 (same_name(conf->cl_recdir,unconf->cl_recdir)) &&
916 (!cmp_verf(&conf->cl_confirm, &unconf->cl_confirm))) { 899 (!same_verf(&conf->cl_confirm, &unconf->cl_confirm))) {
917 /* CASE 1: 900 /* CASE 1:
918 * unconf record that matches input clientid and input confirm. 901 * unconf record that matches input clientid and input confirm.
919 * conf record that matches input clientid. 902 * conf record that matches input clientid.
920 * conf and unconf records match names, verifiers 903 * conf and unconf records match names, verifiers
921 */ 904 */
922 if (!cmp_creds(&conf->cl_cred, &unconf->cl_cred)) 905 if (!same_creds(&conf->cl_cred, &unconf->cl_cred))
923 status = nfserr_clid_inuse; 906 status = nfserr_clid_inuse;
924 else { 907 else {
925 /* XXX: We just turn off callbacks until we can handle 908 /* XXX: We just turn off callbacks until we can handle
@@ -933,7 +916,7 @@ nfsd4_setclientid_confirm(struct svc_rqst *rqstp,
933 } 916 }
934 } else if ((conf && !unconf) || 917 } else if ((conf && !unconf) ||
935 ((conf && unconf) && 918 ((conf && unconf) &&
936 (!cmp_verf(&conf->cl_verifier, &unconf->cl_verifier) || 919 (!same_verf(&conf->cl_verifier, &unconf->cl_verifier) ||
937 !same_name(conf->cl_recdir, unconf->cl_recdir)))) { 920 !same_name(conf->cl_recdir, unconf->cl_recdir)))) {
938 /* CASE 2: 921 /* CASE 2:
939 * conf record that matches input clientid. 922 * conf record that matches input clientid.
@@ -941,18 +924,18 @@ nfsd4_setclientid_confirm(struct svc_rqst *rqstp,
941 * unconf->cl_name or unconf->cl_verifier don't match the 924 * unconf->cl_name or unconf->cl_verifier don't match the
942 * conf record. 925 * conf record.
943 */ 926 */
944 if (!cmp_creds(&conf->cl_cred,&rqstp->rq_cred)) 927 if (!same_creds(&conf->cl_cred, &rqstp->rq_cred))
945 status = nfserr_clid_inuse; 928 status = nfserr_clid_inuse;
946 else 929 else
947 status = nfs_ok; 930 status = nfs_ok;
948 } else if (!conf && unconf 931 } else if (!conf && unconf
949 && cmp_verf(&unconf->cl_confirm, &confirm)) { 932 && same_verf(&unconf->cl_confirm, &confirm)) {
950 /* CASE 3: 933 /* CASE 3:
951 * conf record not found. 934 * conf record not found.
952 * unconf record found. 935 * unconf record found.
953 * unconf->cl_confirm matches input confirm 936 * unconf->cl_confirm matches input confirm
954 */ 937 */
955 if (!cmp_creds(&unconf->cl_cred, &rqstp->rq_cred)) { 938 if (!same_creds(&unconf->cl_cred, &rqstp->rq_cred)) {
956 status = nfserr_clid_inuse; 939 status = nfserr_clid_inuse;
957 } else { 940 } else {
958 unsigned int hash = 941 unsigned int hash =
@@ -967,8 +950,8 @@ nfsd4_setclientid_confirm(struct svc_rqst *rqstp,
967 conf = unconf; 950 conf = unconf;
968 status = nfs_ok; 951 status = nfs_ok;
969 } 952 }
970 } else if ((!conf || (conf && !cmp_verf(&conf->cl_confirm, &confirm))) 953 } else if ((!conf || (conf && !same_verf(&conf->cl_confirm, &confirm)))
971 && (!unconf || (unconf && !cmp_verf(&unconf->cl_confirm, 954 && (!unconf || (unconf && !same_verf(&unconf->cl_confirm,
972 &confirm)))) { 955 &confirm)))) {
973 /* CASE 4: 956 /* CASE 4:
974 * conf record not found, or if conf, conf->cl_confirm does not 957 * conf record not found, or if conf, conf->cl_confirm does not
@@ -1019,7 +1002,7 @@ nfsd4_free_slab(struct kmem_cache **slab)
1019 *slab = NULL; 1002 *slab = NULL;
1020} 1003}
1021 1004
1022static void 1005void
1023nfsd4_free_slabs(void) 1006nfsd4_free_slabs(void)
1024{ 1007{
1025 nfsd4_free_slab(&stateowner_slab); 1008 nfsd4_free_slab(&stateowner_slab);
@@ -1207,10 +1190,12 @@ move_to_close_lru(struct nfs4_stateowner *sop)
1207} 1190}
1208 1191
1209static int 1192static int
1210cmp_owner_str(struct nfs4_stateowner *sop, struct xdr_netobj *owner, clientid_t *clid) { 1193same_owner_str(struct nfs4_stateowner *sop, struct xdr_netobj *owner,
1211 return ((sop->so_owner.len == owner->len) && 1194 clientid_t *clid)
1212 !memcmp(sop->so_owner.data, owner->data, owner->len) && 1195{
1213 (sop->so_client->cl_clientid.cl_id == clid->cl_id)); 1196 return (sop->so_owner.len == owner->len) &&
1197 0 == memcmp(sop->so_owner.data, owner->data, owner->len) &&
1198 (sop->so_client->cl_clientid.cl_id == clid->cl_id);
1214} 1199}
1215 1200
1216static struct nfs4_stateowner * 1201static struct nfs4_stateowner *
@@ -1219,7 +1204,7 @@ find_openstateowner_str(unsigned int hashval, struct nfsd4_open *open)
1219 struct nfs4_stateowner *so = NULL; 1204 struct nfs4_stateowner *so = NULL;
1220 1205
1221 list_for_each_entry(so, &ownerstr_hashtbl[hashval], so_strhash) { 1206 list_for_each_entry(so, &ownerstr_hashtbl[hashval], so_strhash) {
1222 if (cmp_owner_str(so, &open->op_owner, &open->op_clientid)) 1207 if (same_owner_str(so, &open->op_owner, &open->op_clientid))
1223 return so; 1208 return so;
1224 } 1209 }
1225 return NULL; 1210 return NULL;
@@ -1360,6 +1345,7 @@ void nfsd_break_deleg_cb(struct file_lock *fl)
1360 * lock) we know the server hasn't removed the lease yet, we know 1345 * lock) we know the server hasn't removed the lease yet, we know
1361 * it's safe to take a reference: */ 1346 * it's safe to take a reference: */
1362 atomic_inc(&dp->dl_count); 1347 atomic_inc(&dp->dl_count);
1348 atomic_inc(&dp->dl_client->cl_count);
1363 1349
1364 spin_lock(&recall_lock); 1350 spin_lock(&recall_lock);
1365 list_add_tail(&dp->dl_recall_lru, &del_recall_lru); 1351 list_add_tail(&dp->dl_recall_lru, &del_recall_lru);
@@ -1368,8 +1354,12 @@ void nfsd_break_deleg_cb(struct file_lock *fl)
1368 /* only place dl_time is set. protected by lock_kernel*/ 1354 /* only place dl_time is set. protected by lock_kernel*/
1369 dp->dl_time = get_seconds(); 1355 dp->dl_time = get_seconds();
1370 1356
1371 /* XXX need to merge NFSD_LEASE_TIME with fs/locks.c:lease_break_time */ 1357 /*
1372 fl->fl_break_time = jiffies + NFSD_LEASE_TIME * HZ; 1358 * We don't want the locks code to timeout the lease for us;
1359 * we'll remove it ourself if the delegation isn't returned
1360 * in time.
1361 */
1362 fl->fl_break_time = 0;
1373 1363
1374 t = kthread_run(do_recall, dp, "%s", "nfs4_cb_recall"); 1364 t = kthread_run(do_recall, dp, "%s", "nfs4_cb_recall");
1375 if (IS_ERR(t)) { 1365 if (IS_ERR(t)) {
@@ -1378,6 +1368,7 @@ void nfsd_break_deleg_cb(struct file_lock *fl)
1378 printk(KERN_INFO "NFSD: Callback thread failed for " 1368 printk(KERN_INFO "NFSD: Callback thread failed for "
1379 "for client (clientid %08x/%08x)\n", 1369 "for client (clientid %08x/%08x)\n",
1380 clp->cl_clientid.cl_boot, clp->cl_clientid.cl_id); 1370 clp->cl_clientid.cl_boot, clp->cl_clientid.cl_id);
1371 put_nfs4_client(dp->dl_client);
1381 nfs4_put_delegation(dp); 1372 nfs4_put_delegation(dp);
1382 } 1373 }
1383} 1374}
@@ -1738,7 +1729,7 @@ out:
1738 if (open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS 1729 if (open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS
1739 && flag == NFS4_OPEN_DELEGATE_NONE 1730 && flag == NFS4_OPEN_DELEGATE_NONE
1740 && open->op_delegate_type != NFS4_OPEN_DELEGATE_NONE) 1731 && open->op_delegate_type != NFS4_OPEN_DELEGATE_NONE)
1741 printk("NFSD: WARNING: refusing delegation reclaim\n"); 1732 dprintk("NFSD: WARNING: refusing delegation reclaim\n");
1742 open->op_delegate_type = flag; 1733 open->op_delegate_type = flag;
1743} 1734}
1744 1735
@@ -2147,7 +2138,7 @@ nfs4_preprocess_seqid_op(struct svc_fh *current_fh, u32 seqid, stateid_t *statei
2147 *sopp = NULL; 2138 *sopp = NULL;
2148 2139
2149 if (ZERO_STATEID(stateid) || ONE_STATEID(stateid)) { 2140 if (ZERO_STATEID(stateid) || ONE_STATEID(stateid)) {
2150 printk("NFSD: preprocess_seqid_op: magic stateid!\n"); 2141 dprintk("NFSD: preprocess_seqid_op: magic stateid!\n");
2151 return nfserr_bad_stateid; 2142 return nfserr_bad_stateid;
2152 } 2143 }
2153 2144
@@ -2181,25 +2172,24 @@ nfs4_preprocess_seqid_op(struct svc_fh *current_fh, u32 seqid, stateid_t *statei
2181 lkflg = setlkflg(lock->lk_type); 2172 lkflg = setlkflg(lock->lk_type);
2182 2173
2183 if (lock->lk_is_new) { 2174 if (lock->lk_is_new) {
2184 if (!sop->so_is_open_owner) 2175 if (!sop->so_is_open_owner)
2185 return nfserr_bad_stateid; 2176 return nfserr_bad_stateid;
2186 if (!cmp_clid(&clp->cl_clientid, lockclid)) 2177 if (!same_clid(&clp->cl_clientid, lockclid))
2187 return nfserr_bad_stateid; 2178 return nfserr_bad_stateid;
2188 /* stp is the open stateid */ 2179 /* stp is the open stateid */
2189 status = nfs4_check_openmode(stp, lkflg); 2180 status = nfs4_check_openmode(stp, lkflg);
2190 if (status) 2181 if (status)
2191 return status; 2182 return status;
2192 } else { 2183 } else {
2193 /* stp is the lock stateid */ 2184 /* stp is the lock stateid */
2194 status = nfs4_check_openmode(stp->st_openstp, lkflg); 2185 status = nfs4_check_openmode(stp->st_openstp, lkflg);
2195 if (status) 2186 if (status)
2196 return status; 2187 return status;
2197 } 2188 }
2198
2199 } 2189 }
2200 2190
2201 if ((flags & CHECK_FH) && nfs4_check_fh(current_fh, stp)) { 2191 if ((flags & CHECK_FH) && nfs4_check_fh(current_fh, stp)) {
2202 printk("NFSD: preprocess_seqid_op: fh-stateid mismatch!\n"); 2192 dprintk("NFSD: preprocess_seqid_op: fh-stateid mismatch!\n");
2203 return nfserr_bad_stateid; 2193 return nfserr_bad_stateid;
2204 } 2194 }
2205 2195
@@ -2215,22 +2205,22 @@ nfs4_preprocess_seqid_op(struct svc_fh *current_fh, u32 seqid, stateid_t *statei
2215 goto check_replay; 2205 goto check_replay;
2216 2206
2217 if (sop->so_confirmed && flags & CONFIRM) { 2207 if (sop->so_confirmed && flags & CONFIRM) {
2218 printk("NFSD: preprocess_seqid_op: expected" 2208 dprintk("NFSD: preprocess_seqid_op: expected"
2219 " unconfirmed stateowner!\n"); 2209 " unconfirmed stateowner!\n");
2220 return nfserr_bad_stateid; 2210 return nfserr_bad_stateid;
2221 } 2211 }
2222 if (!sop->so_confirmed && !(flags & CONFIRM)) { 2212 if (!sop->so_confirmed && !(flags & CONFIRM)) {
2223 printk("NFSD: preprocess_seqid_op: stateowner not" 2213 dprintk("NFSD: preprocess_seqid_op: stateowner not"
2224 " confirmed yet!\n"); 2214 " confirmed yet!\n");
2225 return nfserr_bad_stateid; 2215 return nfserr_bad_stateid;
2226 } 2216 }
2227 if (stateid->si_generation > stp->st_stateid.si_generation) { 2217 if (stateid->si_generation > stp->st_stateid.si_generation) {
2228 printk("NFSD: preprocess_seqid_op: future stateid?!\n"); 2218 dprintk("NFSD: preprocess_seqid_op: future stateid?!\n");
2229 return nfserr_bad_stateid; 2219 return nfserr_bad_stateid;
2230 } 2220 }
2231 2221
2232 if (stateid->si_generation < stp->st_stateid.si_generation) { 2222 if (stateid->si_generation < stp->st_stateid.si_generation) {
2233 printk("NFSD: preprocess_seqid_op: old stateid!\n"); 2223 dprintk("NFSD: preprocess_seqid_op: old stateid!\n");
2234 return nfserr_old_stateid; 2224 return nfserr_old_stateid;
2235 } 2225 }
2236 renew_client(sop->so_client); 2226 renew_client(sop->so_client);
@@ -2242,7 +2232,7 @@ check_replay:
2242 /* indicate replay to calling function */ 2232 /* indicate replay to calling function */
2243 return nfserr_replay_me; 2233 return nfserr_replay_me;
2244 } 2234 }
2245 printk("NFSD: preprocess_seqid_op: bad seqid (expected %d, got %d)\n", 2235 dprintk("NFSD: preprocess_seqid_op: bad seqid (expected %d, got %d)\n",
2246 sop->so_seqid, seqid); 2236 sop->so_seqid, seqid);
2247 *sopp = NULL; 2237 *sopp = NULL;
2248 return nfserr_bad_seqid; 2238 return nfserr_bad_seqid;
@@ -2561,7 +2551,7 @@ find_lockstateowner_str(struct inode *inode, clientid_t *clid,
2561 struct nfs4_stateowner *op; 2551 struct nfs4_stateowner *op;
2562 2552
2563 list_for_each_entry(op, &lock_ownerstr_hashtbl[hashval], so_strhash) { 2553 list_for_each_entry(op, &lock_ownerstr_hashtbl[hashval], so_strhash) {
2564 if (cmp_owner_str(op, owner, clid)) 2554 if (same_owner_str(op, owner, clid))
2565 return op; 2555 return op;
2566 } 2556 }
2567 return NULL; 2557 return NULL;
@@ -2855,7 +2845,7 @@ nfsd4_lockt(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
2855 file_lock.fl_type = F_WRLCK; 2845 file_lock.fl_type = F_WRLCK;
2856 break; 2846 break;
2857 default: 2847 default:
2858 printk("NFSD: nfs4_lockt: bad lock type!\n"); 2848 dprintk("NFSD: nfs4_lockt: bad lock type!\n");
2859 status = nfserr_inval; 2849 status = nfserr_inval;
2860 goto out; 2850 goto out;
2861 } 2851 }
@@ -3025,7 +3015,7 @@ nfsd4_release_lockowner(struct svc_rqst *rqstp,
3025 INIT_LIST_HEAD(&matches); 3015 INIT_LIST_HEAD(&matches);
3026 for (i = 0; i < LOCK_HASH_SIZE; i++) { 3016 for (i = 0; i < LOCK_HASH_SIZE; i++) {
3027 list_for_each_entry(sop, &lock_ownerid_hashtbl[i], so_idhash) { 3017 list_for_each_entry(sop, &lock_ownerid_hashtbl[i], so_idhash) {
3028 if (!cmp_owner_str(sop, owner, clid)) 3018 if (!same_owner_str(sop, owner, clid))
3029 continue; 3019 continue;
3030 list_for_each_entry(stp, &sop->so_stateids, 3020 list_for_each_entry(stp, &sop->so_stateids,
3031 st_perstateowner) { 3021 st_perstateowner) {
@@ -3149,11 +3139,14 @@ nfs4_check_open_reclaim(clientid_t *clid)
3149 3139
3150/* initialization to perform at module load time: */ 3140/* initialization to perform at module load time: */
3151 3141
3152void 3142int
3153nfs4_state_init(void) 3143nfs4_state_init(void)
3154{ 3144{
3155 int i; 3145 int i, status;
3156 3146
3147 status = nfsd4_init_slabs();
3148 if (status)
3149 return status;
3157 for (i = 0; i < CLIENT_HASH_SIZE; i++) { 3150 for (i = 0; i < CLIENT_HASH_SIZE; i++) {
3158 INIT_LIST_HEAD(&conf_id_hashtbl[i]); 3151 INIT_LIST_HEAD(&conf_id_hashtbl[i]);
3159 INIT_LIST_HEAD(&conf_str_hashtbl[i]); 3152 INIT_LIST_HEAD(&conf_str_hashtbl[i]);
@@ -3182,6 +3175,7 @@ nfs4_state_init(void)
3182 for (i = 0; i < CLIENT_HASH_SIZE; i++) 3175 for (i = 0; i < CLIENT_HASH_SIZE; i++)
3183 INIT_LIST_HEAD(&reclaim_str_hashtbl[i]); 3176 INIT_LIST_HEAD(&reclaim_str_hashtbl[i]);
3184 reclaim_str_hashtbl_size = 0; 3177 reclaim_str_hashtbl_size = 0;
3178 return 0;
3185} 3179}
3186 3180
3187static void 3181static void
@@ -3242,20 +3236,15 @@ __nfs4_state_start(void)
3242 set_max_delegations(); 3236 set_max_delegations();
3243} 3237}
3244 3238
3245int 3239void
3246nfs4_state_start(void) 3240nfs4_state_start(void)
3247{ 3241{
3248 int status;
3249
3250 if (nfs4_init) 3242 if (nfs4_init)
3251 return 0; 3243 return;
3252 status = nfsd4_init_slabs();
3253 if (status)
3254 return status;
3255 nfsd4_load_reboot_recovery_data(); 3244 nfsd4_load_reboot_recovery_data();
3256 __nfs4_state_start(); 3245 __nfs4_state_start();
3257 nfs4_init = 1; 3246 nfs4_init = 1;
3258 return 0; 3247 return;
3259} 3248}
3260 3249
3261int 3250int
@@ -3313,7 +3302,6 @@ nfs4_state_shutdown(void)
3313 nfs4_lock_state(); 3302 nfs4_lock_state();
3314 nfs4_release_reclaim(); 3303 nfs4_release_reclaim();
3315 __nfs4_state_shutdown(); 3304 __nfs4_state_shutdown();
3316 nfsd4_free_slabs();
3317 nfs4_unlock_state(); 3305 nfs4_unlock_state();
3318} 3306}
3319 3307
diff --git a/fs/nfsd/nfs4xdr.c b/fs/nfsd/nfs4xdr.c
index 8ef0964179bc..57333944af7f 100644
--- a/fs/nfsd/nfs4xdr.c
+++ b/fs/nfsd/nfs4xdr.c
@@ -102,7 +102,8 @@ check_filename(char *str, int len, __be32 err)
102out: \ 102out: \
103 return status; \ 103 return status; \
104xdr_error: \ 104xdr_error: \
105 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \ 105 dprintk("NFSD: xdr error (%s:%d)\n", \
106 __FILE__, __LINE__); \
106 status = nfserr_bad_xdr; \ 107 status = nfserr_bad_xdr; \
107 goto out 108 goto out
108 109
@@ -124,7 +125,8 @@ xdr_error: \
124 if (!(x = (p==argp->tmp || p == argp->tmpp) ? \ 125 if (!(x = (p==argp->tmp || p == argp->tmpp) ? \
125 savemem(argp, p, nbytes) : \ 126 savemem(argp, p, nbytes) : \
126 (char *)p)) { \ 127 (char *)p)) { \
127 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \ 128 dprintk("NFSD: xdr error (%s:%d)\n", \
129 __FILE__, __LINE__); \
128 goto xdr_error; \ 130 goto xdr_error; \
129 } \ 131 } \
130 p += XDR_QUADLEN(nbytes); \ 132 p += XDR_QUADLEN(nbytes); \
@@ -140,7 +142,8 @@ xdr_error: \
140 p = argp->p; \ 142 p = argp->p; \
141 argp->p += XDR_QUADLEN(nbytes); \ 143 argp->p += XDR_QUADLEN(nbytes); \
142 } else if (!(p = read_buf(argp, nbytes))) { \ 144 } else if (!(p = read_buf(argp, nbytes))) { \
143 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \ 145 dprintk("NFSD: xdr error (%s:%d)\n", \
146 __FILE__, __LINE__); \
144 goto xdr_error; \ 147 goto xdr_error; \
145 } \ 148 } \
146} while (0) 149} while (0)
@@ -948,7 +951,8 @@ nfsd4_decode_write(struct nfsd4_compoundargs *argp, struct nfsd4_write *write)
948 */ 951 */
949 avail = (char*)argp->end - (char*)argp->p; 952 avail = (char*)argp->end - (char*)argp->p;
950 if (avail + argp->pagelen < write->wr_buflen) { 953 if (avail + argp->pagelen < write->wr_buflen) {
951 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); 954 dprintk("NFSD: xdr error (%s:%d)\n",
955 __FILE__, __LINE__);
952 goto xdr_error; 956 goto xdr_error;
953 } 957 }
954 argp->rqstp->rq_vec[0].iov_base = p; 958 argp->rqstp->rq_vec[0].iov_base = p;
@@ -1019,7 +1023,7 @@ nfsd4_decode_compound(struct nfsd4_compoundargs *argp)
1019 argp->ops = kmalloc(argp->opcnt * sizeof(*argp->ops), GFP_KERNEL); 1023 argp->ops = kmalloc(argp->opcnt * sizeof(*argp->ops), GFP_KERNEL);
1020 if (!argp->ops) { 1024 if (!argp->ops) {
1021 argp->ops = argp->iops; 1025 argp->ops = argp->iops;
1022 printk(KERN_INFO "nfsd: couldn't allocate room for COMPOUND\n"); 1026 dprintk("nfsd: couldn't allocate room for COMPOUND\n");
1023 goto xdr_error; 1027 goto xdr_error;
1024 } 1028 }
1025 } 1029 }
@@ -1326,7 +1330,7 @@ static char *nfsd4_path(struct svc_rqst *rqstp, struct svc_export *exp, __be32 *
1326 path = exp->ex_path; 1330 path = exp->ex_path;
1327 1331
1328 if (strncmp(path, rootpath, strlen(rootpath))) { 1332 if (strncmp(path, rootpath, strlen(rootpath))) {
1329 printk("nfsd: fs_locations failed;" 1333 dprintk("nfsd: fs_locations failed;"
1330 "%s is not contained in %s\n", path, rootpath); 1334 "%s is not contained in %s\n", path, rootpath);
1331 *stat = nfserr_notsupp; 1335 *stat = nfserr_notsupp;
1332 return NULL; 1336 return NULL;
@@ -1475,7 +1479,8 @@ nfsd4_encode_fattr(struct svc_fh *fhp, struct svc_export *exp,
1475 err = vfs_getattr(exp->ex_mnt, dentry, &stat); 1479 err = vfs_getattr(exp->ex_mnt, dentry, &stat);
1476 if (err) 1480 if (err)
1477 goto out_nfserr; 1481 goto out_nfserr;
1478 if ((bmval0 & (FATTR4_WORD0_FILES_FREE | FATTR4_WORD0_FILES_TOTAL)) || 1482 if ((bmval0 & (FATTR4_WORD0_FILES_FREE | FATTR4_WORD0_FILES_TOTAL |
1483 FATTR4_WORD0_MAXNAME)) ||
1479 (bmval1 & (FATTR4_WORD1_SPACE_AVAIL | FATTR4_WORD1_SPACE_FREE | 1484 (bmval1 & (FATTR4_WORD1_SPACE_AVAIL | FATTR4_WORD1_SPACE_FREE |
1480 FATTR4_WORD1_SPACE_TOTAL))) { 1485 FATTR4_WORD1_SPACE_TOTAL))) {
1481 err = vfs_statfs(dentry, &statfs); 1486 err = vfs_statfs(dentry, &statfs);
@@ -1679,7 +1684,7 @@ out_acl:
1679 if (bmval0 & FATTR4_WORD0_FILEID) { 1684 if (bmval0 & FATTR4_WORD0_FILEID) {
1680 if ((buflen -= 8) < 0) 1685 if ((buflen -= 8) < 0)
1681 goto out_resource; 1686 goto out_resource;
1682 WRITE64((u64) stat.ino); 1687 WRITE64(stat.ino);
1683 } 1688 }
1684 if (bmval0 & FATTR4_WORD0_FILES_AVAIL) { 1689 if (bmval0 & FATTR4_WORD0_FILES_AVAIL) {
1685 if ((buflen -= 8) < 0) 1690 if ((buflen -= 8) < 0)
@@ -1721,7 +1726,7 @@ out_acl:
1721 if (bmval0 & FATTR4_WORD0_MAXNAME) { 1726 if (bmval0 & FATTR4_WORD0_MAXNAME) {
1722 if ((buflen -= 4) < 0) 1727 if ((buflen -= 4) < 0)
1723 goto out_resource; 1728 goto out_resource;
1724 WRITE32(~(u32) 0); 1729 WRITE32(statfs.f_namelen);
1725 } 1730 }
1726 if (bmval0 & FATTR4_WORD0_MAXREAD) { 1731 if (bmval0 & FATTR4_WORD0_MAXREAD) {
1727 if ((buflen -= 8) < 0) 1732 if ((buflen -= 8) < 0)
@@ -1821,16 +1826,15 @@ out_acl:
1821 WRITE32(stat.mtime.tv_nsec); 1826 WRITE32(stat.mtime.tv_nsec);
1822 } 1827 }
1823 if (bmval1 & FATTR4_WORD1_MOUNTED_ON_FILEID) { 1828 if (bmval1 & FATTR4_WORD1_MOUNTED_ON_FILEID) {
1824 struct dentry *mnt_pnt, *mnt_root;
1825
1826 if ((buflen -= 8) < 0) 1829 if ((buflen -= 8) < 0)
1827 goto out_resource; 1830 goto out_resource;
1828 mnt_root = exp->ex_mnt->mnt_root; 1831 if (exp->ex_mnt->mnt_root->d_inode == dentry->d_inode) {
1829 if (mnt_root->d_inode == dentry->d_inode) { 1832 err = vfs_getattr(exp->ex_mnt->mnt_parent,
1830 mnt_pnt = exp->ex_mnt->mnt_mountpoint; 1833 exp->ex_mnt->mnt_mountpoint, &stat);
1831 WRITE64((u64) mnt_pnt->d_inode->i_ino); 1834 if (err)
1832 } else 1835 goto out_nfserr;
1833 WRITE64((u64) stat.ino); 1836 }
1837 WRITE64(stat.ino);
1834 } 1838 }
1835 *attrlenp = htonl((char *)p - (char *)attrlenp - 4); 1839 *attrlenp = htonl((char *)p - (char *)attrlenp - 4);
1836 *countp = p - buffer; 1840 *countp = p - buffer;
diff --git a/fs/nfsd/nfsctl.c b/fs/nfsd/nfsctl.c
index baac89d917ca..77dc9893b7ba 100644
--- a/fs/nfsd/nfsctl.c
+++ b/fs/nfsd/nfsctl.c
@@ -298,7 +298,7 @@ static ssize_t write_filehandle(struct file *file, char *buf, size_t size)
298 * qword quoting is used, so filehandle will be \x.... 298 * qword quoting is used, so filehandle will be \x....
299 */ 299 */
300 char *dname, *path; 300 char *dname, *path;
301 int maxsize; 301 int uninitialized_var(maxsize);
302 char *mesg = buf; 302 char *mesg = buf;
303 int len; 303 int len;
304 struct auth_domain *dom; 304 struct auth_domain *dom;
@@ -679,11 +679,13 @@ static int __init init_nfsd(void)
679 int retval; 679 int retval;
680 printk(KERN_INFO "Installing knfsd (copyright (C) 1996 okir@monad.swb.de).\n"); 680 printk(KERN_INFO "Installing knfsd (copyright (C) 1996 okir@monad.swb.de).\n");
681 681
682 retval = nfs4_state_init(); /* nfs4 locking state */
683 if (retval)
684 return retval;
682 nfsd_stat_init(); /* Statistics */ 685 nfsd_stat_init(); /* Statistics */
683 nfsd_cache_init(); /* RPC reply cache */ 686 nfsd_cache_init(); /* RPC reply cache */
684 nfsd_export_init(); /* Exports table */ 687 nfsd_export_init(); /* Exports table */
685 nfsd_lockd_init(); /* lockd->nfsd callbacks */ 688 nfsd_lockd_init(); /* lockd->nfsd callbacks */
686 nfs4_state_init(); /* NFSv4 locking state */
687 nfsd_idmap_init(); /* Name to ID mapping */ 689 nfsd_idmap_init(); /* Name to ID mapping */
688 if (proc_mkdir("fs/nfs", NULL)) { 690 if (proc_mkdir("fs/nfs", NULL)) {
689 struct proc_dir_entry *entry; 691 struct proc_dir_entry *entry;
@@ -712,6 +714,7 @@ static void __exit exit_nfsd(void)
712 nfsd_stat_shutdown(); 714 nfsd_stat_shutdown();
713 nfsd_lockd_shutdown(); 715 nfsd_lockd_shutdown();
714 nfsd_idmap_shutdown(); 716 nfsd_idmap_shutdown();
717 nfsd4_free_slabs();
715 unregister_filesystem(&nfsd_fs_type); 718 unregister_filesystem(&nfsd_fs_type);
716} 719}
717 720
diff --git a/fs/nfsd/nfssvc.c b/fs/nfsd/nfssvc.c
index a8c89ae4c743..1190aeaa92be 100644
--- a/fs/nfsd/nfssvc.c
+++ b/fs/nfsd/nfssvc.c
@@ -349,9 +349,7 @@ nfsd_svc(unsigned short port, int nrservs)
349 error = nfsd_racache_init(2*nrservs); 349 error = nfsd_racache_init(2*nrservs);
350 if (error<0) 350 if (error<0)
351 goto out; 351 goto out;
352 error = nfs4_state_start(); 352 nfs4_state_start();
353 if (error<0)
354 goto out;
355 353
356 nfsd_reset_versions(); 354 nfsd_reset_versions();
357 355
@@ -546,10 +544,8 @@ nfsd_dispatch(struct svc_rqst *rqstp, __be32 *statp)
546 /* Now call the procedure handler, and encode NFS status. */ 544 /* Now call the procedure handler, and encode NFS status. */
547 nfserr = proc->pc_func(rqstp, rqstp->rq_argp, rqstp->rq_resp); 545 nfserr = proc->pc_func(rqstp, rqstp->rq_argp, rqstp->rq_resp);
548 nfserr = map_new_errors(rqstp->rq_vers, nfserr); 546 nfserr = map_new_errors(rqstp->rq_vers, nfserr);
549 if (nfserr == nfserr_jukebox && rqstp->rq_vers == 2)
550 nfserr = nfserr_dropit;
551 if (nfserr == nfserr_dropit) { 547 if (nfserr == nfserr_dropit) {
552 dprintk("nfsd: Dropping request due to malloc failure!\n"); 548 dprintk("nfsd: Dropping request; may be revisited later\n");
553 nfsd_cache_update(rqstp, RC_NOCACHE, NULL); 549 nfsd_cache_update(rqstp, RC_NOCACHE, NULL);
554 return 0; 550 return 0;
555 } 551 }
diff --git a/fs/nfsd/nfsxdr.c b/fs/nfsd/nfsxdr.c
index cb3e7fadb772..986f9b32083c 100644
--- a/fs/nfsd/nfsxdr.c
+++ b/fs/nfsd/nfsxdr.c
@@ -523,6 +523,10 @@ nfssvc_encode_entry(void *ccdv, const char *name,
523 cd->common.err = nfserr_toosmall; 523 cd->common.err = nfserr_toosmall;
524 return -EINVAL; 524 return -EINVAL;
525 } 525 }
526 if (ino > ~((u32) 0)) {
527 cd->common.err = nfserr_fbig;
528 return -EINVAL;
529 }
526 *p++ = xdr_one; /* mark entry present */ 530 *p++ = xdr_one; /* mark entry present */
527 *p++ = htonl((u32) ino); /* file id */ 531 *p++ = htonl((u32) ino); /* file id */
528 p = xdr_encode_array(p, name, namlen);/* name length & name */ 532 p = xdr_encode_array(p, name, namlen);/* name length & name */
diff --git a/fs/nfsd/vfs.c b/fs/nfsd/vfs.c
index 085ded6f6d3a..2a8d665b134b 100644
--- a/fs/nfsd/vfs.c
+++ b/fs/nfsd/vfs.c
@@ -289,7 +289,8 @@ nfsd_setattr(struct svc_rqst *rqstp, struct svc_fh *fhp, struct iattr *iap,
289 if (!iap->ia_valid) 289 if (!iap->ia_valid)
290 goto out; 290 goto out;
291 291
292 /* NFSv2 does not differentiate between "set-[ac]time-to-now" 292 /*
293 * NFSv2 does not differentiate between "set-[ac]time-to-now"
293 * which only requires access, and "set-[ac]time-to-X" which 294 * which only requires access, and "set-[ac]time-to-X" which
294 * requires ownership. 295 * requires ownership.
295 * So if it looks like it might be "set both to the same time which 296 * So if it looks like it might be "set both to the same time which
@@ -302,25 +303,33 @@ nfsd_setattr(struct svc_rqst *rqstp, struct svc_fh *fhp, struct iattr *iap,
302 */ 303 */
303#define BOTH_TIME_SET (ATTR_ATIME_SET | ATTR_MTIME_SET) 304#define BOTH_TIME_SET (ATTR_ATIME_SET | ATTR_MTIME_SET)
304#define MAX_TOUCH_TIME_ERROR (30*60) 305#define MAX_TOUCH_TIME_ERROR (30*60)
305 if ((iap->ia_valid & BOTH_TIME_SET) == BOTH_TIME_SET 306 if ((iap->ia_valid & BOTH_TIME_SET) == BOTH_TIME_SET &&
306 && iap->ia_mtime.tv_sec == iap->ia_atime.tv_sec 307 iap->ia_mtime.tv_sec == iap->ia_atime.tv_sec) {
307 ) { 308 /*
308 /* Looks probable. Now just make sure time is in the right ballpark. 309 * Looks probable.
309 * Solaris, at least, doesn't seem to care what the time request is. 310 *
310 * We require it be within 30 minutes of now. 311 * Now just make sure time is in the right ballpark.
311 */ 312 * Solaris, at least, doesn't seem to care what the time
312 time_t delta = iap->ia_atime.tv_sec - get_seconds(); 313 * request is. We require it be within 30 minutes of now.
313 if (delta<0) delta = -delta;
314 if (delta < MAX_TOUCH_TIME_ERROR &&
315 inode_change_ok(inode, iap) != 0) {
316 /* turn off ATTR_[AM]TIME_SET but leave ATTR_[AM]TIME
317 * this will cause notify_change to set these times to "now"
318 */ 314 */
319 iap->ia_valid &= ~BOTH_TIME_SET; 315 time_t delta = iap->ia_atime.tv_sec - get_seconds();
320 } 316 if (delta < 0)
317 delta = -delta;
318 if (delta < MAX_TOUCH_TIME_ERROR &&
319 inode_change_ok(inode, iap) != 0) {
320 /*
321 * Turn off ATTR_[AM]TIME_SET but leave ATTR_[AM]TIME.
322 * This will cause notify_change to set these times
323 * to "now"
324 */
325 iap->ia_valid &= ~BOTH_TIME_SET;
326 }
321 } 327 }
322 328
323 /* The size case is special. It changes the file as well as the attributes. */ 329 /*
330 * The size case is special.
331 * It changes the file as well as the attributes.
332 */
324 if (iap->ia_valid & ATTR_SIZE) { 333 if (iap->ia_valid & ATTR_SIZE) {
325 if (iap->ia_size < inode->i_size) { 334 if (iap->ia_size < inode->i_size) {
326 err = nfsd_permission(rqstp, fhp->fh_export, dentry, MAY_TRUNC|MAY_OWNER_OVERRIDE); 335 err = nfsd_permission(rqstp, fhp->fh_export, dentry, MAY_TRUNC|MAY_OWNER_OVERRIDE);
generated by cgit v1.2.2 (git 2.25.0) at 2025-01-14 14:32:20 -0500