aboutsummaryrefslogtreecommitdiffstats
path: root/net/sunrpc/svc_xprt.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/sunrpc/svc_xprt.c')
-rw-r--r--net/sunrpc/svc_xprt.c11
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);