diff options
author | Linus Torvalds <torvalds@linux-foundation.org> | 2008-07-21 00:21:46 -0400 |
---|---|---|
committer | Linus Torvalds <torvalds@linux-foundation.org> | 2008-07-21 00:21:46 -0400 |
commit | 14b395e35d1afdd8019d11b92e28041fad591b71 (patch) | |
tree | cff7ba9bed7a38300b19a5bacc632979d64fd9c8 /fs/lockd/svclock.c | |
parent | 734b397cd14f3340394a8dd3266bec97d01f034b (diff) | |
parent | 5108b27651727b5aba0826e8fd7be71b42428701 (diff) |
Merge branch 'for-2.6.27' of git://linux-nfs.org/~bfields/linux
* 'for-2.6.27' of git://linux-nfs.org/~bfields/linux: (51 commits)
nfsd: nfs4xdr.c do-while is not a compound statement
nfsd: Use C99 initializers in fs/nfsd/nfs4xdr.c
lockd: Pass "struct sockaddr *" to new failover-by-IP function
lockd: get host reference in nlmsvc_create_block() instead of callers
lockd: minor svclock.c style fixes
lockd: eliminate duplicate nlmsvc_lookup_host call from nlmsvc_lock
lockd: eliminate duplicate nlmsvc_lookup_host call from nlmsvc_testlock
lockd: nlm_release_host() checks for NULL, caller needn't
file lock: reorder struct file_lock to save space on 64 bit builds
nfsd: take file and mnt write in nfs4_upgrade_open
nfsd: document open share bit tracking
nfsd: tabulate nfs4 xdr encoding functions
nfsd: dprint operation names
svcrdma: Change WR context get/put to use the kmem cache
svcrdma: Create a kmem cache for the WR contexts
svcrdma: Add flush_scheduled_work to module exit function
svcrdma: Limit ORD based on client's advertised IRD
svcrdma: Remove unused wait q from svcrdma_xprt structure
svcrdma: Remove unneeded spin locks from __svc_rdma_free
svcrdma: Add dma map count and WARN_ON
...
Diffstat (limited to 'fs/lockd/svclock.c')
-rw-r--r-- | fs/lockd/svclock.c | 33 |
1 files changed, 10 insertions, 23 deletions
diff --git a/fs/lockd/svclock.c b/fs/lockd/svclock.c index 56a08ab9a4cb..821b9acdfb66 100644 --- a/fs/lockd/svclock.c +++ b/fs/lockd/svclock.c | |||
@@ -129,9 +129,9 @@ nlmsvc_lookup_block(struct nlm_file *file, struct nlm_lock *lock) | |||
129 | 129 | ||
130 | static inline int nlm_cookie_match(struct nlm_cookie *a, struct nlm_cookie *b) | 130 | static inline int nlm_cookie_match(struct nlm_cookie *a, struct nlm_cookie *b) |
131 | { | 131 | { |
132 | if(a->len != b->len) | 132 | if (a->len != b->len) |
133 | return 0; | 133 | return 0; |
134 | if(memcmp(a->data,b->data,a->len)) | 134 | if (memcmp(a->data, b->data, a->len)) |
135 | return 0; | 135 | return 0; |
136 | return 1; | 136 | return 1; |
137 | } | 137 | } |
@@ -180,6 +180,7 @@ nlmsvc_create_block(struct svc_rqst *rqstp, struct nlm_host *host, | |||
180 | struct nlm_block *block; | 180 | struct nlm_block *block; |
181 | struct nlm_rqst *call = NULL; | 181 | struct nlm_rqst *call = NULL; |
182 | 182 | ||
183 | nlm_get_host(host); | ||
183 | call = nlm_alloc_call(host); | 184 | call = nlm_alloc_call(host); |
184 | if (call == NULL) | 185 | if (call == NULL) |
185 | return NULL; | 186 | return NULL; |
@@ -358,10 +359,10 @@ nlmsvc_defer_lock_rqst(struct svc_rqst *rqstp, struct nlm_block *block) | |||
358 | */ | 359 | */ |
359 | __be32 | 360 | __be32 |
360 | nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, | 361 | nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, |
361 | struct nlm_lock *lock, int wait, struct nlm_cookie *cookie) | 362 | struct nlm_host *host, struct nlm_lock *lock, int wait, |
363 | struct nlm_cookie *cookie) | ||
362 | { | 364 | { |
363 | struct nlm_block *block = NULL; | 365 | struct nlm_block *block = NULL; |
364 | struct nlm_host *host; | ||
365 | int error; | 366 | int error; |
366 | __be32 ret; | 367 | __be32 ret; |
367 | 368 | ||
@@ -373,11 +374,6 @@ nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, | |||
373 | (long long)lock->fl.fl_end, | 374 | (long long)lock->fl.fl_end, |
374 | wait); | 375 | wait); |
375 | 376 | ||
376 | /* Create host handle for callback */ | ||
377 | host = nlmsvc_lookup_host(rqstp, lock->caller, lock->len); | ||
378 | if (host == NULL) | ||
379 | return nlm_lck_denied_nolocks; | ||
380 | |||
381 | /* Lock file against concurrent access */ | 377 | /* Lock file against concurrent access */ |
382 | mutex_lock(&file->f_mutex); | 378 | mutex_lock(&file->f_mutex); |
383 | /* Get existing block (in case client is busy-waiting) | 379 | /* Get existing block (in case client is busy-waiting) |
@@ -385,8 +381,7 @@ nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, | |||
385 | */ | 381 | */ |
386 | block = nlmsvc_lookup_block(file, lock); | 382 | block = nlmsvc_lookup_block(file, lock); |
387 | if (block == NULL) { | 383 | if (block == NULL) { |
388 | block = nlmsvc_create_block(rqstp, nlm_get_host(host), file, | 384 | block = nlmsvc_create_block(rqstp, host, file, lock, cookie); |
389 | lock, cookie); | ||
390 | ret = nlm_lck_denied_nolocks; | 385 | ret = nlm_lck_denied_nolocks; |
391 | if (block == NULL) | 386 | if (block == NULL) |
392 | goto out; | 387 | goto out; |
@@ -417,7 +412,7 @@ nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, | |||
417 | lock->fl.fl_flags &= ~FL_SLEEP; | 412 | lock->fl.fl_flags &= ~FL_SLEEP; |
418 | 413 | ||
419 | dprintk("lockd: vfs_lock_file returned %d\n", error); | 414 | dprintk("lockd: vfs_lock_file returned %d\n", error); |
420 | switch(error) { | 415 | switch (error) { |
421 | case 0: | 416 | case 0: |
422 | ret = nlm_granted; | 417 | ret = nlm_granted; |
423 | goto out; | 418 | goto out; |
@@ -450,7 +445,6 @@ nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file, | |||
450 | out: | 445 | out: |
451 | mutex_unlock(&file->f_mutex); | 446 | mutex_unlock(&file->f_mutex); |
452 | nlmsvc_release_block(block); | 447 | nlmsvc_release_block(block); |
453 | nlm_release_host(host); | ||
454 | dprintk("lockd: nlmsvc_lock returned %u\n", ret); | 448 | dprintk("lockd: nlmsvc_lock returned %u\n", ret); |
455 | return ret; | 449 | return ret; |
456 | } | 450 | } |
@@ -460,8 +454,8 @@ out: | |||
460 | */ | 454 | */ |
461 | __be32 | 455 | __be32 |
462 | nlmsvc_testlock(struct svc_rqst *rqstp, struct nlm_file *file, | 456 | nlmsvc_testlock(struct svc_rqst *rqstp, struct nlm_file *file, |
463 | struct nlm_lock *lock, struct nlm_lock *conflock, | 457 | struct nlm_host *host, struct nlm_lock *lock, |
464 | struct nlm_cookie *cookie) | 458 | struct nlm_lock *conflock, struct nlm_cookie *cookie) |
465 | { | 459 | { |
466 | struct nlm_block *block = NULL; | 460 | struct nlm_block *block = NULL; |
467 | int error; | 461 | int error; |
@@ -479,16 +473,9 @@ nlmsvc_testlock(struct svc_rqst *rqstp, struct nlm_file *file, | |||
479 | 473 | ||
480 | if (block == NULL) { | 474 | if (block == NULL) { |
481 | struct file_lock *conf = kzalloc(sizeof(*conf), GFP_KERNEL); | 475 | struct file_lock *conf = kzalloc(sizeof(*conf), GFP_KERNEL); |
482 | struct nlm_host *host; | ||
483 | 476 | ||
484 | if (conf == NULL) | 477 | if (conf == NULL) |
485 | return nlm_granted; | 478 | return nlm_granted; |
486 | /* Create host handle for callback */ | ||
487 | host = nlmsvc_lookup_host(rqstp, lock->caller, lock->len); | ||
488 | if (host == NULL) { | ||
489 | kfree(conf); | ||
490 | return nlm_lck_denied_nolocks; | ||
491 | } | ||
492 | block = nlmsvc_create_block(rqstp, host, file, lock, cookie); | 479 | block = nlmsvc_create_block(rqstp, host, file, lock, cookie); |
493 | if (block == NULL) { | 480 | if (block == NULL) { |
494 | kfree(conf); | 481 | kfree(conf); |
@@ -897,7 +884,7 @@ nlmsvc_retry_blocked(void) | |||
897 | 884 | ||
898 | if (block->b_when == NLM_NEVER) | 885 | if (block->b_when == NLM_NEVER) |
899 | break; | 886 | break; |
900 | if (time_after(block->b_when,jiffies)) { | 887 | if (time_after(block->b_when, jiffies)) { |
901 | timeout = block->b_when - jiffies; | 888 | timeout = block->b_when - jiffies; |
902 | break; | 889 | break; |
903 | } | 890 | } |