Commit 6d5fcb5a authored by Trond Myklebust's avatar Trond Myklebust

SUNRPC: Remove BKL around the RPC socket operations etc.

All internal RPC client operations should no longer depend on the BKL,
however lockd and NFS callbacks may still require it.
Signed-off-by: default avatarTrond Myklebust <Trond.Myklebust@netapp.com>
parent bbd5a1f9
...@@ -27,6 +27,7 @@ ...@@ -27,6 +27,7 @@
#include <linux/types.h> #include <linux/types.h>
#include <linux/mm.h> #include <linux/mm.h>
#include <linux/slab.h> #include <linux/slab.h>
#include <linux/smp_lock.h>
#include <linux/utsname.h> #include <linux/utsname.h>
#include <linux/workqueue.h> #include <linux/workqueue.h>
...@@ -823,8 +824,10 @@ call_encode(struct rpc_task *task) ...@@ -823,8 +824,10 @@ call_encode(struct rpc_task *task)
if (encode == NULL) if (encode == NULL)
return; return;
lock_kernel();
task->tk_status = rpcauth_wrap_req(task, encode, req, p, task->tk_status = rpcauth_wrap_req(task, encode, req, p,
task->tk_msg.rpc_argp); task->tk_msg.rpc_argp);
unlock_kernel();
if (task->tk_status == -ENOMEM) { if (task->tk_status == -ENOMEM) {
/* XXX: Is this sane? */ /* XXX: Is this sane? */
rpc_delay(task, 3*HZ); rpc_delay(task, 3*HZ);
...@@ -1155,9 +1158,12 @@ call_decode(struct rpc_task *task) ...@@ -1155,9 +1158,12 @@ call_decode(struct rpc_task *task)
task->tk_action = rpc_exit_task; task->tk_action = rpc_exit_task;
if (decode) if (decode) {
lock_kernel();
task->tk_status = rpcauth_unwrap_resp(task, decode, req, p, task->tk_status = rpcauth_unwrap_resp(task, decode, req, p,
task->tk_msg.rpc_resp); task->tk_msg.rpc_resp);
unlock_kernel();
}
dprintk("RPC: %4d call_decode result %d\n", task->tk_pid, dprintk("RPC: %4d call_decode result %d\n", task->tk_pid,
task->tk_status); task->tk_status);
return; return;
......
...@@ -588,7 +588,9 @@ void rpc_delay(struct rpc_task *task, unsigned long delay) ...@@ -588,7 +588,9 @@ void rpc_delay(struct rpc_task *task, unsigned long delay)
*/ */
static void rpc_prepare_task(struct rpc_task *task) static void rpc_prepare_task(struct rpc_task *task)
{ {
lock_kernel();
task->tk_ops->rpc_call_prepare(task, task->tk_calldata); task->tk_ops->rpc_call_prepare(task, task->tk_calldata);
unlock_kernel();
} }
/* /*
...@@ -598,7 +600,9 @@ void rpc_exit_task(struct rpc_task *task) ...@@ -598,7 +600,9 @@ void rpc_exit_task(struct rpc_task *task)
{ {
task->tk_action = NULL; task->tk_action = NULL;
if (task->tk_ops->rpc_call_done != NULL) { if (task->tk_ops->rpc_call_done != NULL) {
lock_kernel();
task->tk_ops->rpc_call_done(task, task->tk_calldata); task->tk_ops->rpc_call_done(task, task->tk_calldata);
unlock_kernel();
if (task->tk_action != NULL) { if (task->tk_action != NULL) {
WARN_ON(RPC_ASSASSINATED(task)); WARN_ON(RPC_ASSASSINATED(task));
/* Always release the RPC slot and buffer memory */ /* Always release the RPC slot and buffer memory */
...@@ -651,9 +655,7 @@ static int __rpc_execute(struct rpc_task *task) ...@@ -651,9 +655,7 @@ static int __rpc_execute(struct rpc_task *task)
*/ */
save_callback=task->tk_callback; save_callback=task->tk_callback;
task->tk_callback=NULL; task->tk_callback=NULL;
lock_kernel();
save_callback(task); save_callback(task);
unlock_kernel();
} }
/* /*
...@@ -664,9 +666,7 @@ static int __rpc_execute(struct rpc_task *task) ...@@ -664,9 +666,7 @@ static int __rpc_execute(struct rpc_task *task)
if (!RPC_IS_QUEUED(task)) { if (!RPC_IS_QUEUED(task)) {
if (task->tk_action == NULL) if (task->tk_action == NULL)
break; break;
lock_kernel();
task->tk_action(task); task->tk_action(task);
unlock_kernel();
} }
/* /*
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment