]> pilppa.com Git - linux-2.6-omap-h63xx.git/commitdiff
NFSv4: Clean up nfs4_call_async()
authorTrond Myklebust <Trond.Myklebust@netapp.com>
Tue, 12 Jun 2007 03:05:07 +0000 (23:05 -0400)
committerTrond Myklebust <Trond.Myklebust@netapp.com>
Wed, 11 Jul 2007 03:40:24 +0000 (23:40 -0400)
Use rpc_run_task() instead of doing it ourselves.

Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
fs/nfs/nfs4proc.c
fs/nfs/nfs4state.c
net/sunrpc/sunrpc_syms.c

index 8feaf232f2e4c9dba8bd63181914a94afcbda3f0..3cc75445a68de627c3def7ed4cc2b1e16db34eda 100644 (file)
@@ -295,18 +295,6 @@ static void nfs4_opendata_free(struct nfs4_opendata *p)
        }
 }
 
-/* Helper for asynchronous RPC calls */
-static int nfs4_call_async(struct rpc_clnt *clnt,
-               const struct rpc_call_ops *tk_ops, void *calldata)
-{
-       struct rpc_task *task;
-
-       if (!(task = rpc_new_task(clnt, RPC_TASK_ASYNC, tk_ops, calldata)))
-               return -ENOMEM;
-       rpc_execute(task);
-       return 0;
-}
-
 static int nfs4_wait_for_completion_rpc_task(struct rpc_task *task)
 {
        sigset_t oldset;
@@ -1218,6 +1206,8 @@ int nfs4_do_close(struct path *path, struct nfs4_state *state)
 {
        struct nfs_server *server = NFS_SERVER(state->inode);
        struct nfs4_closedata *calldata;
+       struct nfs4_state_owner *sp = state->owner;
+       struct rpc_task *task;
        int status = -ENOMEM;
 
        calldata = kmalloc(sizeof(*calldata), GFP_KERNEL);
@@ -1237,14 +1227,16 @@ int nfs4_do_close(struct path *path, struct nfs4_state *state)
        calldata->path.mnt = mntget(path->mnt);
        calldata->path.dentry = dget(path->dentry);
 
-       status = nfs4_call_async(server->client, &nfs4_close_ops, calldata);
-       if (status == 0)
-               goto out;
-
-       nfs_free_seqid(calldata->arg.seqid);
+       task = rpc_run_task(server->client, RPC_TASK_ASYNC, &nfs4_close_ops, calldata);
+       if (IS_ERR(task))
+               return PTR_ERR(task);
+       rpc_put_task(task);
+       return 0;
 out_free_calldata:
        kfree(calldata);
 out:
+       nfs4_put_open_state(state);
+       nfs4_put_state_owner(sp);
        return status;
 }
 
index a85138ef67ade73587000105f01f73bf3694d458..5d7ffbfc3483085930dd69de4f90c4d0a9bae6f7 100644 (file)
@@ -375,10 +375,11 @@ void nfs4_close_state(struct path *path, struct nfs4_state *state, mode_t mode)
        spin_unlock(&inode->i_lock);
        spin_unlock(&owner->so_lock);
 
-       if (oldstate != newstate && nfs4_do_close(path, state) == 0)
-               return;
-       nfs4_put_open_state(state);
-       nfs4_put_state_owner(owner);
+       if (oldstate == newstate) {
+               nfs4_put_open_state(state);
+               nfs4_put_state_owner(owner);
+       } else
+               nfs4_do_close(path, state);
 }
 
 /*
index 73075dec83c07e4d73503156ca22668519cdfcf5..c46d31ca307b93defb087094dcc2893bd20e6efa 100644 (file)
@@ -30,7 +30,6 @@ EXPORT_SYMBOL(rpc_wake_up_next);
 EXPORT_SYMBOL(rpc_wake_up_task);
 EXPORT_SYMBOL(rpciod_down);
 EXPORT_SYMBOL(rpciod_up);
-EXPORT_SYMBOL(rpc_new_task);
 EXPORT_SYMBOL(rpc_wake_up_status);
 
 /* RPC client functions */