diff options
author | Trond Myklebust <trondmy@gmail.com> | 2019-04-07 13:58:44 -0400 |
---|---|---|
committer | Anna Schumaker <Anna.Schumaker@Netapp.com> | 2019-04-25 14:18:12 -0400 |
commit | ae67bd3821bb0a54d97e7883d211196637d487a9 (patch) | |
tree | 351a54fd10a71f6c76d5e8d8a8ce323c9252192e /fs/nfsd | |
parent | 085b7755808aa11f78ab9377257e1dad2e6fa4bb (diff) |
SUNRPC: Fix up task signalling
The RPC_TASK_KILLED flag should really not be set from another context
because it can clobber data in the struct task when task->tk_flags is
changed non-atomically.
Let's therefore swap out RPC_TASK_KILLED with an atomic flag, and add
a function to set that flag and safely wake up the task.
Signed-off-by: Trond Myklebust <trond.myklebust@hammerspace.com>
Signed-off-by: Anna Schumaker <Anna.Schumaker@Netapp.com>
Diffstat (limited to 'fs/nfsd')
-rw-r--r-- | fs/nfsd/nfs4callback.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/fs/nfsd/nfs4callback.c b/fs/nfsd/nfs4callback.c index d219159b98af..f7494be8dbe2 100644 --- a/fs/nfsd/nfs4callback.c +++ b/fs/nfsd/nfs4callback.c | |||
@@ -1032,7 +1032,7 @@ static bool nfsd4_cb_sequence_done(struct rpc_task *task, struct nfsd4_callback | |||
1032 | * the submission code will error out, so we don't need to | 1032 | * the submission code will error out, so we don't need to |
1033 | * handle that case here. | 1033 | * handle that case here. |
1034 | */ | 1034 | */ |
1035 | if (task->tk_flags & RPC_TASK_KILLED) | 1035 | if (RPC_SIGNALLED(task)) |
1036 | goto need_restart; | 1036 | goto need_restart; |
1037 | 1037 | ||
1038 | return true; | 1038 | return true; |
@@ -1081,7 +1081,7 @@ static bool nfsd4_cb_sequence_done(struct rpc_task *task, struct nfsd4_callback | |||
1081 | dprintk("%s: freed slot, new seqid=%d\n", __func__, | 1081 | dprintk("%s: freed slot, new seqid=%d\n", __func__, |
1082 | clp->cl_cb_session->se_cb_seq_nr); | 1082 | clp->cl_cb_session->se_cb_seq_nr); |
1083 | 1083 | ||
1084 | if (task->tk_flags & RPC_TASK_KILLED) | 1084 | if (RPC_SIGNALLED(task)) |
1085 | goto need_restart; | 1085 | goto need_restart; |
1086 | out: | 1086 | out: |
1087 | return ret; | 1087 | return ret; |