diff options
author | NeilBrown <neilb@suse.de> | 2007-03-06 04:42:22 -0500 |
---|---|---|
committer | Linus Torvalds <torvalds@woody.linux-foundation.org> | 2007-03-06 12:30:26 -0500 |
commit | cda1fd4abd773216a888487af0170d0cc3d50454 (patch) | |
tree | aed6662bab1789a1698644f2e1d0db4255ecad67 /net/sunrpc/svc.c | |
parent | 5a05ed73e1abfd7e0e7d474817245861deaa18af (diff) |
[PATCH] knfsd: fix recently introduced problem with shutting down a busy NFS server
When the last thread of nfsd exits, it shuts down all related sockets. It
currently uses svc_close_socket to do this, but that only is immediately
effective if the socket is not SK_BUSY.
If the socket is busy - i.e. if a request has arrived that has not yet been
processes - svc_close_socket is not effective and the shutdown process spins.
So create a new svc_force_close_socket which removes the SK_BUSY flag is set
and then calls svc_close_socket.
Also change some open-codes loops in svc_destroy to use
list_for_each_entry_safe.
Signed-off-by: Neil Brown <neilb@suse.de>
Signed-off-by: Andrew Morton <akpm@linux-foundation.org>
Signed-off-by: Linus Torvalds <torvalds@linux-foundation.org>
Diffstat (limited to 'net/sunrpc/svc.c')
-rw-r--r-- | net/sunrpc/svc.c | 21 |
1 files changed, 9 insertions, 12 deletions
diff --git a/net/sunrpc/svc.c b/net/sunrpc/svc.c index 8353829bc5c6..f960b138236f 100644 --- a/net/sunrpc/svc.c +++ b/net/sunrpc/svc.c | |||
@@ -367,6 +367,7 @@ void | |||
367 | svc_destroy(struct svc_serv *serv) | 367 | svc_destroy(struct svc_serv *serv) |
368 | { | 368 | { |
369 | struct svc_sock *svsk; | 369 | struct svc_sock *svsk; |
370 | struct svc_sock *tmp; | ||
370 | 371 | ||
371 | dprintk("svc: svc_destroy(%s, %d)\n", | 372 | dprintk("svc: svc_destroy(%s, %d)\n", |
372 | serv->sv_program->pg_name, | 373 | serv->sv_program->pg_name, |
@@ -382,21 +383,17 @@ svc_destroy(struct svc_serv *serv) | |||
382 | 383 | ||
383 | del_timer_sync(&serv->sv_temptimer); | 384 | del_timer_sync(&serv->sv_temptimer); |
384 | 385 | ||
385 | while (!list_empty(&serv->sv_tempsocks)) { | 386 | list_for_each_entry_safe(svsk, tmp, &serv->sv_tempsocks, sk_list) |
386 | svsk = list_entry(serv->sv_tempsocks.next, | 387 | svc_force_close_socket(svsk); |
387 | struct svc_sock, | 388 | |
388 | sk_list); | ||
389 | svc_close_socket(svsk); | ||
390 | } | ||
391 | if (serv->sv_shutdown) | 389 | if (serv->sv_shutdown) |
392 | serv->sv_shutdown(serv); | 390 | serv->sv_shutdown(serv); |
393 | 391 | ||
394 | while (!list_empty(&serv->sv_permsocks)) { | 392 | list_for_each_entry_safe(svsk, tmp, &serv->sv_permsocks, sk_list) |
395 | svsk = list_entry(serv->sv_permsocks.next, | 393 | svc_force_close_socket(svsk); |
396 | struct svc_sock, | 394 | |
397 | sk_list); | 395 | BUG_ON(!list_empty(&serv->sv_permsocks)); |
398 | svc_close_socket(svsk); | 396 | BUG_ON(!list_empty(&serv->sv_tempsocks)); |
399 | } | ||
400 | 397 | ||
401 | cache_clean_deferred(serv); | 398 | cache_clean_deferred(serv); |
402 | 399 | ||