|
@@ -638,9 +638,6 @@ static void nlmsvc_grant_callback(struct rpc_task *task, void *data)
|
|
if (task->tk_status < 0) {
|
|
if (task->tk_status < 0) {
|
|
/* RPC error: Re-insert for retransmission */
|
|
/* RPC error: Re-insert for retransmission */
|
|
timeout = 10 * HZ;
|
|
timeout = 10 * HZ;
|
|
- } else if (block->b_done) {
|
|
|
|
- /* Block already removed, kill it for real */
|
|
|
|
- timeout = 0;
|
|
|
|
} else {
|
|
} else {
|
|
/* Call was successful, now wait for client callback */
|
|
/* Call was successful, now wait for client callback */
|
|
timeout = 60 * HZ;
|
|
timeout = 60 * HZ;
|
|
@@ -709,13 +706,10 @@ nlmsvc_retry_blocked(void)
|
|
break;
|
|
break;
|
|
if (time_after(block->b_when,jiffies))
|
|
if (time_after(block->b_when,jiffies))
|
|
break;
|
|
break;
|
|
- dprintk("nlmsvc_retry_blocked(%p, when=%ld, done=%d)\n",
|
|
|
|
- block, block->b_when, block->b_done);
|
|
|
|
|
|
+ dprintk("nlmsvc_retry_blocked(%p, when=%ld)\n",
|
|
|
|
+ block, block->b_when);
|
|
kref_get(&block->b_count);
|
|
kref_get(&block->b_count);
|
|
- if (block->b_done)
|
|
|
|
- nlmsvc_unlink_block(block);
|
|
|
|
- else
|
|
|
|
- nlmsvc_grant_blocked(block);
|
|
|
|
|
|
+ nlmsvc_grant_blocked(block);
|
|
nlmsvc_release_block(block);
|
|
nlmsvc_release_block(block);
|
|
}
|
|
}
|
|
|
|
|