aboutsummaryrefslogtreecommitdiffstats
path: root/net/sunrpc/clnt.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/sunrpc/clnt.c')
-rw-r--r--net/sunrpc/clnt.c13
1 files changed, 7 insertions, 6 deletions
diff --git a/net/sunrpc/clnt.c b/net/sunrpc/clnt.c
index 9aad45946d32..aefe3ae218f7 100644
--- a/net/sunrpc/clnt.c
+++ b/net/sunrpc/clnt.c
@@ -501,12 +501,12 @@ static void rpc_save_sigmask(sigset_t *oldset, int intr)
501 sigprocmask(SIG_BLOCK, &sigmask, oldset); 501 sigprocmask(SIG_BLOCK, &sigmask, oldset);
502} 502}
503 503
504static inline void rpc_task_sigmask(struct rpc_task *task, sigset_t *oldset) 504static void rpc_task_sigmask(struct rpc_task *task, sigset_t *oldset)
505{ 505{
506 rpc_save_sigmask(oldset, !RPC_TASK_UNINTERRUPTIBLE(task)); 506 rpc_save_sigmask(oldset, !RPC_TASK_UNINTERRUPTIBLE(task));
507} 507}
508 508
509static inline void rpc_restore_sigmask(sigset_t *oldset) 509static void rpc_restore_sigmask(sigset_t *oldset)
510{ 510{
511 sigprocmask(SIG_SETMASK, oldset, NULL); 511 sigprocmask(SIG_SETMASK, oldset, NULL);
512} 512}
@@ -536,11 +536,10 @@ struct rpc_task *rpc_run_task(const struct rpc_task_setup *task_setup_data)
536 if (task == NULL) { 536 if (task == NULL) {
537 rpc_release_calldata(task_setup_data->callback_ops, 537 rpc_release_calldata(task_setup_data->callback_ops,
538 task_setup_data->callback_data); 538 task_setup_data->callback_data);
539 return ERR_PTR(-ENOMEM); 539 ret = ERR_PTR(-ENOMEM);
540 goto out;
540 } 541 }
541 542
542 /* Mask signals on synchronous RPC calls and RPCSEC_GSS upcalls */
543 rpc_task_sigmask(task, &oldset);
544 if (task_setup_data->rpc_message != NULL) { 543 if (task_setup_data->rpc_message != NULL) {
545 rpc_call_setup(task, task_setup_data->rpc_message, 0); 544 rpc_call_setup(task, task_setup_data->rpc_message, 0);
546 if (task->tk_status != 0) { 545 if (task->tk_status != 0) {
@@ -550,10 +549,12 @@ struct rpc_task *rpc_run_task(const struct rpc_task_setup *task_setup_data)
550 } 549 }
551 } 550 }
552 atomic_inc(&task->tk_count); 551 atomic_inc(&task->tk_count);
552 /* Mask signals on synchronous RPC calls and RPCSEC_GSS upcalls */
553 rpc_task_sigmask(task, &oldset);
553 rpc_execute(task); 554 rpc_execute(task);
555 rpc_restore_sigmask(&oldset);
554 ret = task; 556 ret = task;
555out: 557out:
556 rpc_restore_sigmask(&oldset);
557 return ret; 558 return ret;
558} 559}
559EXPORT_SYMBOL_GPL(rpc_run_task); 560EXPORT_SYMBOL_GPL(rpc_run_task);