diff options
-rw-r--r-- | fs/nfs/callback.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/fs/nfs/callback.c b/fs/nfs/callback.c index b8fb3a4ef649..351be9205bf8 100644 --- a/fs/nfs/callback.c +++ b/fs/nfs/callback.c | |||
@@ -128,22 +128,24 @@ nfs41_callback_svc(void *vrqstp) | |||
128 | if (try_to_freeze()) | 128 | if (try_to_freeze()) |
129 | continue; | 129 | continue; |
130 | 130 | ||
131 | prepare_to_wait(&serv->sv_cb_waitq, &wq, TASK_INTERRUPTIBLE); | 131 | prepare_to_wait(&serv->sv_cb_waitq, &wq, TASK_UNINTERRUPTIBLE); |
132 | spin_lock_bh(&serv->sv_cb_lock); | 132 | spin_lock_bh(&serv->sv_cb_lock); |
133 | if (!list_empty(&serv->sv_cb_list)) { | 133 | if (!list_empty(&serv->sv_cb_list)) { |
134 | req = list_first_entry(&serv->sv_cb_list, | 134 | req = list_first_entry(&serv->sv_cb_list, |
135 | struct rpc_rqst, rq_bc_list); | 135 | struct rpc_rqst, rq_bc_list); |
136 | list_del(&req->rq_bc_list); | 136 | list_del(&req->rq_bc_list); |
137 | spin_unlock_bh(&serv->sv_cb_lock); | 137 | spin_unlock_bh(&serv->sv_cb_lock); |
138 | finish_wait(&serv->sv_cb_waitq, &wq); | ||
138 | dprintk("Invoking bc_svc_process()\n"); | 139 | dprintk("Invoking bc_svc_process()\n"); |
139 | error = bc_svc_process(serv, req, rqstp); | 140 | error = bc_svc_process(serv, req, rqstp); |
140 | dprintk("bc_svc_process() returned w/ error code= %d\n", | 141 | dprintk("bc_svc_process() returned w/ error code= %d\n", |
141 | error); | 142 | error); |
142 | } else { | 143 | } else { |
143 | spin_unlock_bh(&serv->sv_cb_lock); | 144 | spin_unlock_bh(&serv->sv_cb_lock); |
144 | schedule(); | 145 | /* schedule_timeout to game the hung task watchdog */ |
146 | schedule_timeout(60 * HZ); | ||
147 | finish_wait(&serv->sv_cb_waitq, &wq); | ||
145 | } | 148 | } |
146 | finish_wait(&serv->sv_cb_waitq, &wq); | ||
147 | } | 149 | } |
148 | return 0; | 150 | return 0; |
149 | } | 151 | } |