diff options
Diffstat (limited to 'net/sunrpc/clnt.c')
-rw-r--r-- | net/sunrpc/clnt.c | 13 |
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 | ||
504 | static inline void rpc_task_sigmask(struct rpc_task *task, sigset_t *oldset) | 504 | static 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 | ||
509 | static inline void rpc_restore_sigmask(sigset_t *oldset) | 509 | static 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; |
555 | out: | 557 | out: |
556 | rpc_restore_sigmask(&oldset); | ||
557 | return ret; | 558 | return ret; |
558 | } | 559 | } |
559 | EXPORT_SYMBOL_GPL(rpc_run_task); | 560 | EXPORT_SYMBOL_GPL(rpc_run_task); |