diff options
Diffstat (limited to 'net/sunrpc')
-rw-r--r-- | net/sunrpc/clnt.c | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/net/sunrpc/clnt.c b/net/sunrpc/clnt.c index de8bbfcd5030..8b78177e7575 100644 --- a/net/sunrpc/clnt.c +++ b/net/sunrpc/clnt.c | |||
@@ -144,6 +144,7 @@ static struct rpc_clnt * rpc_new_client(struct rpc_xprt *xprt, char *servname, s | |||
144 | err = -ENOMEM; | 144 | err = -ENOMEM; |
145 | if (clnt->cl_metrics == NULL) | 145 | if (clnt->cl_metrics == NULL) |
146 | goto out_no_stats; | 146 | goto out_no_stats; |
147 | clnt->cl_program = program; | ||
147 | 148 | ||
148 | if (!xprt_bound(clnt->cl_xprt)) | 149 | if (!xprt_bound(clnt->cl_xprt)) |
149 | clnt->cl_autobind = 1; | 150 | clnt->cl_autobind = 1; |
@@ -257,6 +258,7 @@ struct rpc_clnt * | |||
257 | rpc_clone_client(struct rpc_clnt *clnt) | 258 | rpc_clone_client(struct rpc_clnt *clnt) |
258 | { | 259 | { |
259 | struct rpc_clnt *new; | 260 | struct rpc_clnt *new; |
261 | int err = -ENOMEM; | ||
260 | 262 | ||
261 | new = kmemdup(clnt, sizeof(*new), GFP_KERNEL); | 263 | new = kmemdup(clnt, sizeof(*new), GFP_KERNEL); |
262 | if (!new) | 264 | if (!new) |
@@ -266,6 +268,9 @@ rpc_clone_client(struct rpc_clnt *clnt) | |||
266 | new->cl_metrics = rpc_alloc_iostats(clnt); | 268 | new->cl_metrics = rpc_alloc_iostats(clnt); |
267 | if (new->cl_metrics == NULL) | 269 | if (new->cl_metrics == NULL) |
268 | goto out_no_stats; | 270 | goto out_no_stats; |
271 | err = rpc_setup_pipedir(new, clnt->cl_program->pipe_dir_name); | ||
272 | if (err != 0) | ||
273 | goto out_no_path; | ||
269 | new->cl_parent = clnt; | 274 | new->cl_parent = clnt; |
270 | atomic_inc(&clnt->cl_count); | 275 | atomic_inc(&clnt->cl_count); |
271 | new->cl_xprt = xprt_get(clnt->cl_xprt); | 276 | new->cl_xprt = xprt_get(clnt->cl_xprt); |
@@ -273,17 +278,17 @@ rpc_clone_client(struct rpc_clnt *clnt) | |||
273 | new->cl_autobind = 0; | 278 | new->cl_autobind = 0; |
274 | new->cl_oneshot = 0; | 279 | new->cl_oneshot = 0; |
275 | new->cl_dead = 0; | 280 | new->cl_dead = 0; |
276 | if (!IS_ERR(new->cl_dentry)) | ||
277 | dget(new->cl_dentry); | ||
278 | rpc_init_rtt(&new->cl_rtt_default, clnt->cl_xprt->timeout.to_initval); | 281 | rpc_init_rtt(&new->cl_rtt_default, clnt->cl_xprt->timeout.to_initval); |
279 | if (new->cl_auth) | 282 | if (new->cl_auth) |
280 | atomic_inc(&new->cl_auth->au_count); | 283 | atomic_inc(&new->cl_auth->au_count); |
281 | return new; | 284 | return new; |
285 | out_no_path: | ||
286 | rpc_free_iostats(new->cl_metrics); | ||
282 | out_no_stats: | 287 | out_no_stats: |
283 | kfree(new); | 288 | kfree(new); |
284 | out_no_clnt: | 289 | out_no_clnt: |
285 | printk(KERN_INFO "RPC: out of memory in %s\n", __FUNCTION__); | 290 | dprintk("RPC: %s returned error %d\n", __FUNCTION__, err); |
286 | return ERR_PTR(-ENOMEM); | 291 | return ERR_PTR(err); |
287 | } | 292 | } |
288 | 293 | ||
289 | /* | 294 | /* |
@@ -336,16 +341,14 @@ rpc_destroy_client(struct rpc_clnt *clnt) | |||
336 | rpcauth_destroy(clnt->cl_auth); | 341 | rpcauth_destroy(clnt->cl_auth); |
337 | clnt->cl_auth = NULL; | 342 | clnt->cl_auth = NULL; |
338 | } | 343 | } |
339 | if (clnt->cl_parent != clnt) { | ||
340 | if (!IS_ERR(clnt->cl_dentry)) | ||
341 | dput(clnt->cl_dentry); | ||
342 | rpc_destroy_client(clnt->cl_parent); | ||
343 | goto out_free; | ||
344 | } | ||
345 | if (!IS_ERR(clnt->cl_dentry)) { | 344 | if (!IS_ERR(clnt->cl_dentry)) { |
346 | rpc_rmdir(clnt->cl_dentry); | 345 | rpc_rmdir(clnt->cl_dentry); |
347 | rpc_put_mount(); | 346 | rpc_put_mount(); |
348 | } | 347 | } |
348 | if (clnt->cl_parent != clnt) { | ||
349 | rpc_destroy_client(clnt->cl_parent); | ||
350 | goto out_free; | ||
351 | } | ||
349 | if (clnt->cl_server != clnt->cl_inline_name) | 352 | if (clnt->cl_server != clnt->cl_inline_name) |
350 | kfree(clnt->cl_server); | 353 | kfree(clnt->cl_server); |
351 | out_free: | 354 | out_free: |