diff options
Diffstat (limited to 'net/sunrpc/svc_xprt.c')
-rw-r--r-- | net/sunrpc/svc_xprt.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/net/sunrpc/svc_xprt.c b/net/sunrpc/svc_xprt.c index cbc084939dd8..8ff6840866fa 100644 --- a/net/sunrpc/svc_xprt.c +++ b/net/sunrpc/svc_xprt.c | |||
@@ -651,6 +651,11 @@ int svc_recv(struct svc_rqst *rqstp, long timeout) | |||
651 | if (signalled() || kthread_should_stop()) | 651 | if (signalled() || kthread_should_stop()) |
652 | return -EINTR; | 652 | return -EINTR; |
653 | 653 | ||
654 | /* Normally we will wait up to 5 seconds for any required | ||
655 | * cache information to be provided. | ||
656 | */ | ||
657 | rqstp->rq_chandle.thread_wait = 5*HZ; | ||
658 | |||
654 | spin_lock_bh(&pool->sp_lock); | 659 | spin_lock_bh(&pool->sp_lock); |
655 | xprt = svc_xprt_dequeue(pool); | 660 | xprt = svc_xprt_dequeue(pool); |
656 | if (xprt) { | 661 | if (xprt) { |
@@ -658,6 +663,12 @@ int svc_recv(struct svc_rqst *rqstp, long timeout) | |||
658 | svc_xprt_get(xprt); | 663 | svc_xprt_get(xprt); |
659 | rqstp->rq_reserved = serv->sv_max_mesg; | 664 | rqstp->rq_reserved = serv->sv_max_mesg; |
660 | atomic_add(rqstp->rq_reserved, &xprt->xpt_reserved); | 665 | atomic_add(rqstp->rq_reserved, &xprt->xpt_reserved); |
666 | |||
667 | /* As there is a shortage of threads and this request | ||
668 | * had to be queue, don't allow the thread to wait so | ||
669 | * long for cache updates. | ||
670 | */ | ||
671 | rqstp->rq_chandle.thread_wait = 1*HZ; | ||
661 | } else { | 672 | } else { |
662 | /* No data pending. Go to sleep */ | 673 | /* No data pending. Go to sleep */ |
663 | svc_thread_enqueue(pool, rqstp); | 674 | svc_thread_enqueue(pool, rqstp); |