android/android_kernel_asus_sm8350
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

NFSv4.1: FREE_STATEID can be asynchronous

Browse Source 
Nothing should need to be serialised with FREE_STATEID on the client,
so let's make the RPC call always asynchronous. Also constify the
stateid argument.

Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
Tested-by: Oleg Drokin <green@linuxhacker.ru>
Signed-off-by: Anna Schumaker <Anna.Schumaker@Netapp.com>
This commit is contained in:
Trond Myklebust
2016-09-22 13:39:04 -04:00
committed by Anna Schumaker
parent c5896fc862
commit f0b0bf8826
1 changed files with 12 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
fs/nfs/nfs4proc.c
View File

@ -99,8 +99,8 @@ static int nfs4_do_setattr(struct inode *inode, struct rpc_cred *cred,
#ifdef CONFIG_NFS_V4_1 #ifdef CONFIG_NFS_V4_1
static int nfs41_test_stateid(struct nfs_server *, nfs4_stateid *, static int nfs41_test_stateid(struct nfs_server *, nfs4_stateid *,
struct rpc_cred *); struct rpc_cred *);
static int nfs41_free_stateid(struct nfs_server *, nfs4_stateid *, static int nfs41_free_stateid(struct nfs_server *, const nfs4_stateid *,
struct rpc_cred *); struct rpc_cred *, bool);
#endif #endif
#ifdef CONFIG_NFS_V4_SECURITY_LABEL #ifdef CONFIG_NFS_V4_SECURITY_LABEL
@ -2443,7 +2443,7 @@ static int nfs41_test_and_free_expired_stateid(struct nfs_server *server,
} }
out_free: out_free:
/* Ack the revoked state to the server */ /* Ack the revoked state to the server */
nfs41_free_stateid(server, stateid, cred); nfs41_free_stateid(server, stateid, cred, true);
return -NFS4ERR_EXPIRED; return -NFS4ERR_EXPIRED;
} }
@ -8921,7 +8921,7 @@ static const struct rpc_call_ops nfs41_free_stateid_ops = {
}; };
static struct rpc_task *_nfs41_free_stateid(struct nfs_server *server, static struct rpc_task *_nfs41_free_stateid(struct nfs_server *server,
nfs4_stateid *stateid, const nfs4_stateid *stateid,
struct rpc_cred *cred, struct rpc_cred *cred,
bool privileged) bool privileged)
{ {
@ -8964,38 +8964,31 @@ static struct rpc_task *_nfs41_free_stateid(struct nfs_server *server,
* @server: server / transport on which to perform the operation * @server: server / transport on which to perform the operation
* @stateid: state ID to release * @stateid: state ID to release
* @cred: credential * @cred: credential
* @is_recovery: set to true if this call needs to be privileged
* *
* Returns NFS_OK if the server freed "stateid". Otherwise a * Note: this function is always asynchronous.
* negative NFS4ERR value is returned.
*/ */
static int nfs41_free_stateid(struct nfs_server *server, static int nfs41_free_stateid(struct nfs_server *server,
nfs4_stateid *stateid, const nfs4_stateid *stateid,
struct rpc_cred *cred) struct rpc_cred *cred,
bool is_recovery)
{ {
struct rpc_task *task; struct rpc_task *task;
int ret;
task = _nfs41_free_stateid(server, stateid, cred, true); task = _nfs41_free_stateid(server, stateid, cred, is_recovery);
if (IS_ERR(task)) if (IS_ERR(task))
return PTR_ERR(task); return PTR_ERR(task);
ret = rpc_wait_for_completion_task(task);
if (!ret)
ret = task->tk_status;
rpc_put_task(task); rpc_put_task(task);
return ret; return 0;
} }
static void static void
nfs41_free_lock_state(struct nfs_server *server, struct nfs4_lock_state *lsp) nfs41_free_lock_state(struct nfs_server *server, struct nfs4_lock_state *lsp)
{ {
struct rpc_task *task;
struct rpc_cred *cred = lsp->ls_state->owner->so_cred; struct rpc_cred *cred = lsp->ls_state->owner->so_cred;
task = _nfs41_free_stateid(server, &lsp->ls_stateid, cred, false); nfs41_free_stateid(server, &lsp->ls_stateid, cred, false);
nfs4_free_lock_state(server, lsp); nfs4_free_lock_state(server, lsp);
if (IS_ERR(task))
return;
rpc_put_task(task);
} }
static bool nfs41_match_stateid(const nfs4_stateid *s1, static bool nfs41_match_stateid(const nfs4_stateid *s1,