提交 07b92c22 编写于 作者: O Olga Kornievskaia 提交者: Greg Kroah-Hartman

NFSv4.2 copy do not allocate memory under the lock

[ Upstream commit 99f2c55591fb5c1b536263970d98c2ebc2089906 ]

Bruce pointed out that we shouldn't allocate memory while holding
a lock in the nfs4_callback_offload() and handle_async_copy()
that deal with a racing CB_OFFLOAD and reply to COPY case.
Signed-off-by: NOlga Kornievskaia <kolga@netapp.com>
Signed-off-by: NTrond Myklebust <trond.myklebust@hammerspace.com>
Signed-off-by: NSasha Levin <sashal@kernel.org>
上级 d1862827
...@@ -686,20 +686,24 @@ __be32 nfs4_callback_offload(void *data, void *dummy, ...@@ -686,20 +686,24 @@ __be32 nfs4_callback_offload(void *data, void *dummy,
{ {
struct cb_offloadargs *args = data; struct cb_offloadargs *args = data;
struct nfs_server *server; struct nfs_server *server;
struct nfs4_copy_state *copy; struct nfs4_copy_state *copy, *tmp_copy;
bool found = false; bool found = false;
copy = kzalloc(sizeof(struct nfs4_copy_state), GFP_NOFS);
if (!copy)
return htonl(NFS4ERR_SERVERFAULT);
spin_lock(&cps->clp->cl_lock); spin_lock(&cps->clp->cl_lock);
rcu_read_lock(); rcu_read_lock();
list_for_each_entry_rcu(server, &cps->clp->cl_superblocks, list_for_each_entry_rcu(server, &cps->clp->cl_superblocks,
client_link) { client_link) {
list_for_each_entry(copy, &server->ss_copies, copies) { list_for_each_entry(tmp_copy, &server->ss_copies, copies) {
if (memcmp(args->coa_stateid.other, if (memcmp(args->coa_stateid.other,
copy->stateid.other, tmp_copy->stateid.other,
sizeof(args->coa_stateid.other))) sizeof(args->coa_stateid.other)))
continue; continue;
nfs4_copy_cb_args(copy, args); nfs4_copy_cb_args(tmp_copy, args);
complete(&copy->completion); complete(&tmp_copy->completion);
found = true; found = true;
goto out; goto out;
} }
...@@ -707,15 +711,11 @@ __be32 nfs4_callback_offload(void *data, void *dummy, ...@@ -707,15 +711,11 @@ __be32 nfs4_callback_offload(void *data, void *dummy,
out: out:
rcu_read_unlock(); rcu_read_unlock();
if (!found) { if (!found) {
copy = kzalloc(sizeof(struct nfs4_copy_state), GFP_NOFS);
if (!copy) {
spin_unlock(&cps->clp->cl_lock);
return htonl(NFS4ERR_SERVERFAULT);
}
memcpy(&copy->stateid, &args->coa_stateid, NFS4_STATEID_SIZE); memcpy(&copy->stateid, &args->coa_stateid, NFS4_STATEID_SIZE);
nfs4_copy_cb_args(copy, args); nfs4_copy_cb_args(copy, args);
list_add_tail(&copy->copies, &cps->clp->pending_cb_stateids); list_add_tail(&copy->copies, &cps->clp->pending_cb_stateids);
} } else
kfree(copy);
spin_unlock(&cps->clp->cl_lock); spin_unlock(&cps->clp->cl_lock);
return 0; return 0;
......
...@@ -137,31 +137,32 @@ static int handle_async_copy(struct nfs42_copy_res *res, ...@@ -137,31 +137,32 @@ static int handle_async_copy(struct nfs42_copy_res *res,
struct file *dst, struct file *dst,
nfs4_stateid *src_stateid) nfs4_stateid *src_stateid)
{ {
struct nfs4_copy_state *copy; struct nfs4_copy_state *copy, *tmp_copy;
int status = NFS4_OK; int status = NFS4_OK;
bool found_pending = false; bool found_pending = false;
struct nfs_open_context *ctx = nfs_file_open_context(dst); struct nfs_open_context *ctx = nfs_file_open_context(dst);
copy = kzalloc(sizeof(struct nfs4_copy_state), GFP_NOFS);
if (!copy)
return -ENOMEM;
spin_lock(&server->nfs_client->cl_lock); spin_lock(&server->nfs_client->cl_lock);
list_for_each_entry(copy, &server->nfs_client->pending_cb_stateids, list_for_each_entry(tmp_copy, &server->nfs_client->pending_cb_stateids,
copies) { copies) {
if (memcmp(&res->write_res.stateid, &copy->stateid, if (memcmp(&res->write_res.stateid, &tmp_copy->stateid,
NFS4_STATEID_SIZE)) NFS4_STATEID_SIZE))
continue; continue;
found_pending = true; found_pending = true;
list_del(&copy->copies); list_del(&tmp_copy->copies);
break; break;
} }
if (found_pending) { if (found_pending) {
spin_unlock(&server->nfs_client->cl_lock); spin_unlock(&server->nfs_client->cl_lock);
kfree(copy);
copy = tmp_copy;
goto out; goto out;
} }
copy = kzalloc(sizeof(struct nfs4_copy_state), GFP_NOFS);
if (!copy) {
spin_unlock(&server->nfs_client->cl_lock);
return -ENOMEM;
}
memcpy(&copy->stateid, &res->write_res.stateid, NFS4_STATEID_SIZE); memcpy(&copy->stateid, &res->write_res.stateid, NFS4_STATEID_SIZE);
init_completion(&copy->completion); init_completion(&copy->completion);
copy->parent_state = ctx->state; copy->parent_state = ctx->state;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册