78 static int	rpc_ping(struct rpc_clnt *clnt);
81 static void rpc_register_client(struct rpc_clnt *clnt)  in rpc_register_client()  argument
83 	struct net *net = rpc_net_ns(clnt);  in rpc_register_client()
87 	list_add(&clnt->cl_clients, &sn->all_clients);  in rpc_register_client()
91 static void rpc_unregister_client(struct rpc_clnt *clnt)  in rpc_unregister_client()  argument
93 	struct net *net = rpc_net_ns(clnt);  in rpc_unregister_client()
97 	list_del(&clnt->cl_clients);  in rpc_unregister_client()
101 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)  in __rpc_clnt_remove_pipedir()  argument
103 	rpc_remove_client_dir(clnt);  in __rpc_clnt_remove_pipedir()
106 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)  in rpc_clnt_remove_pipedir()  argument
108 	struct net *net = rpc_net_ns(clnt);  in rpc_clnt_remove_pipedir()
113 		__rpc_clnt_remove_pipedir(clnt);  in rpc_clnt_remove_pipedir()
119 				    struct rpc_clnt *clnt)  in rpc_setup_pipedir_sb()  argument
122 	const char *dir_name = clnt->cl_program->pipe_dir_name;  in rpc_setup_pipedir_sb()
134 		dentry = rpc_create_client_dir(dir, name, clnt);  in rpc_setup_pipedir_sb()
149 rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt)  in rpc_setup_pipedir()  argument
153 	if (clnt->cl_program->pipe_dir_name != NULL) {  in rpc_setup_pipedir()
154 		dentry = rpc_setup_pipedir_sb(pipefs_sb, clnt);  in rpc_setup_pipedir()
161 static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event)  in rpc_clnt_skip_event()  argument
163 	if (clnt->cl_program->pipe_dir_name == NULL)  in rpc_clnt_skip_event()
168 		if (clnt->cl_pipedir_objects.pdh_dentry != NULL)  in rpc_clnt_skip_event()
170 		if (refcount_read(&clnt->cl_count) == 0)  in rpc_clnt_skip_event()
174 		if (clnt->cl_pipedir_objects.pdh_dentry == NULL)  in rpc_clnt_skip_event()
181 static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event,  in __rpc_clnt_handle_event()  argument
188 		dentry = rpc_setup_pipedir_sb(sb, clnt);  in __rpc_clnt_handle_event()
195 		__rpc_clnt_remove_pipedir(clnt);  in __rpc_clnt_handle_event()
204 static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event,  in __rpc_pipefs_event()  argument
209 	for (;; clnt = clnt->cl_parent) {  in __rpc_pipefs_event()
210 		if (!rpc_clnt_skip_event(clnt, event))  in __rpc_pipefs_event()
211 			error = __rpc_clnt_handle_event(clnt, event, sb);  in __rpc_pipefs_event()
212 		if (error || clnt == clnt->cl_parent)  in __rpc_pipefs_event()
221 	struct rpc_clnt *clnt;  in rpc_get_client_for_event()  local
224 	list_for_each_entry(clnt, &sn->all_clients, cl_clients) {  in rpc_get_client_for_event()
225 		if (rpc_clnt_skip_event(clnt, event))  in rpc_get_client_for_event()
228 		return clnt;  in rpc_get_client_for_event()
238 	struct rpc_clnt *clnt;  in rpc_pipefs_event()  local
241 	while ((clnt = rpc_get_client_for_event(sb->s_fs_info, event))) {  in rpc_pipefs_event()
242 		error = __rpc_pipefs_event(clnt, event, sb);  in rpc_pipefs_event()
264 static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt,  in rpc_clnt_set_transport()  argument
270 	spin_lock(&clnt->cl_lock);  in rpc_clnt_set_transport()
271 	old = rcu_dereference_protected(clnt->cl_xprt,  in rpc_clnt_set_transport()
272 			lockdep_is_held(&clnt->cl_lock));  in rpc_clnt_set_transport()
275 		clnt->cl_autobind = 1;  in rpc_clnt_set_transport()
277 	clnt->cl_timeout = timeout;  in rpc_clnt_set_transport()
278 	rcu_assign_pointer(clnt->cl_xprt, xprt);  in rpc_clnt_set_transport()
279 	spin_unlock(&clnt->cl_lock);  in rpc_clnt_set_transport()
284 static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename)  in rpc_clnt_set_nodename()  argument
286 	clnt->cl_nodelen = strlcpy(clnt->cl_nodename,  in rpc_clnt_set_nodename()
287 			nodename, sizeof(clnt->cl_nodename));  in rpc_clnt_set_nodename()
290 static int rpc_client_register(struct rpc_clnt *clnt,  in rpc_client_register()  argument
299 	struct net *net = rpc_net_ns(clnt);  in rpc_client_register()
303 	rpc_clnt_debugfs_register(clnt);  in rpc_client_register()
307 		err = rpc_setup_pipedir(pipefs_sb, clnt);  in rpc_client_register()
312 	rpc_register_client(clnt);  in rpc_client_register()
316 	auth = rpcauth_create(&auth_args, clnt);  in rpc_client_register()
326 	rpc_unregister_client(clnt);  in rpc_client_register()
327 	__rpc_clnt_remove_pipedir(clnt);  in rpc_client_register()
331 	rpc_sysfs_client_destroy(clnt);  in rpc_client_register()
332 	rpc_clnt_debugfs_unregister(clnt);  in rpc_client_register()
343 static int rpc_alloc_clid(struct rpc_clnt *clnt)  in rpc_alloc_clid()  argument
350 	clnt->cl_clid = clid;  in rpc_alloc_clid()
354 static void rpc_free_clid(struct rpc_clnt *clnt)  in rpc_free_clid()  argument
356 	ida_simple_remove(&rpc_clids, clnt->cl_clid);  in rpc_free_clid()
366 	struct rpc_clnt *clnt = NULL;  in rpc_new_client()  local
383 	clnt = kzalloc(sizeof(*clnt), GFP_KERNEL);  in rpc_new_client()
384 	if (!clnt)  in rpc_new_client()
386 	clnt->cl_parent = parent ? : clnt;  in rpc_new_client()
388 	err = rpc_alloc_clid(clnt);  in rpc_new_client()
392 	clnt->cl_cred	  = get_cred(args->cred);  in rpc_new_client()
393 	clnt->cl_procinfo = version->procs;  in rpc_new_client()
394 	clnt->cl_maxproc  = version->nrprocs;  in rpc_new_client()
395 	clnt->cl_prog     = args->prognumber ? : program->number;  in rpc_new_client()
396 	clnt->cl_vers     = version->number;  in rpc_new_client()
397 	clnt->cl_stats    = program->stats;  in rpc_new_client()
398 	clnt->cl_metrics  = rpc_alloc_iostats(clnt);  in rpc_new_client()
399 	rpc_init_pipe_dir_head(&clnt->cl_pipedir_objects);  in rpc_new_client()
401 	if (clnt->cl_metrics == NULL)  in rpc_new_client()
403 	clnt->cl_program  = program;  in rpc_new_client()
404 	INIT_LIST_HEAD(&clnt->cl_tasks);  in rpc_new_client()
405 	spin_lock_init(&clnt->cl_lock);  in rpc_new_client()
409 		memcpy(&clnt->cl_timeout_default, args->timeout,  in rpc_new_client()
410 				sizeof(clnt->cl_timeout_default));  in rpc_new_client()
411 		timeout = &clnt->cl_timeout_default;  in rpc_new_client()
414 	rpc_clnt_set_transport(clnt, xprt, timeout);  in rpc_new_client()
416 	xprt_iter_init(&clnt->cl_xpi, xps);  in rpc_new_client()
419 	clnt->cl_rtt = &clnt->cl_rtt_default;  in rpc_new_client()
420 	rpc_init_rtt(&clnt->cl_rtt_default, clnt->cl_timeout->to_initval);  in rpc_new_client()
422 	refcount_set(&clnt->cl_count, 1);  in rpc_new_client()
427 	rpc_clnt_set_nodename(clnt, nodename);  in rpc_new_client()
429 	rpc_sysfs_client_setup(clnt, xps, rpc_net_ns(clnt));  in rpc_new_client()
430 	err = rpc_client_register(clnt, args->authflavor, args->client_name);  in rpc_new_client()
436 	trace_rpc_clnt_new(clnt, xprt, program->name, args->servername);  in rpc_new_client()
437 	return clnt;  in rpc_new_client()
440 	rpc_free_iostats(clnt->cl_metrics);  in rpc_new_client()
442 	put_cred(clnt->cl_cred);  in rpc_new_client()
443 	rpc_free_clid(clnt);  in rpc_new_client()
445 	kfree(clnt);  in rpc_new_client()
458 	struct rpc_clnt *clnt = NULL;  in rpc_create_xprt()  local
476 	clnt = rpc_new_client(args, xps, xprt, NULL);  in rpc_create_xprt()
477 	if (IS_ERR(clnt))  in rpc_create_xprt()
478 		return clnt;  in rpc_create_xprt()
481 		int err = rpc_ping(clnt);  in rpc_create_xprt()
483 			rpc_shutdown_client(clnt);  in rpc_create_xprt()
488 	clnt->cl_softrtry = 1;  in rpc_create_xprt()
490 		clnt->cl_softrtry = 0;  in rpc_create_xprt()
492 			clnt->cl_softerr = 1;  in rpc_create_xprt()
496 		clnt->cl_autobind = 1;  in rpc_create_xprt()
498 		clnt->cl_noretranstimeo = 1;  in rpc_create_xprt()
500 		clnt->cl_discrtry = 1;  in rpc_create_xprt()
502 		clnt->cl_chatty = 1;  in rpc_create_xprt()
504 	return clnt;  in rpc_create_xprt()
530 	struct rpc_clnt *clnt;  in rpc_create()  local
597 	clnt = rpc_create_xprt(args, xprt);  in rpc_create()
598 	if (IS_ERR(clnt) || args->nconnect <= 1)  in rpc_create()
599 		return clnt;  in rpc_create()
602 		if (rpc_clnt_add_xprt(clnt, &xprtargs, NULL, NULL) < 0)  in rpc_create()
605 	return clnt;  in rpc_create()
615 					   struct rpc_clnt *clnt)  in __rpc_clone_client()  argument
624 	xprt = xprt_get(rcu_dereference(clnt->cl_xprt));  in __rpc_clone_client()
625 	xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));  in __rpc_clone_client()
633 	args->nodename = clnt->cl_nodename;  in __rpc_clone_client()
635 	new = rpc_new_client(args, xps, xprt, clnt);  in __rpc_clone_client()
641 	new->cl_softrtry = clnt->cl_softrtry;  in __rpc_clone_client()
642 	new->cl_softerr = clnt->cl_softerr;  in __rpc_clone_client()
643 	new->cl_noretranstimeo = clnt->cl_noretranstimeo;  in __rpc_clone_client()
644 	new->cl_discrtry = clnt->cl_discrtry;  in __rpc_clone_client()
645 	new->cl_chatty = clnt->cl_chatty;  in __rpc_clone_client()
646 	new->cl_principal = clnt->cl_principal;  in __rpc_clone_client()
650 	trace_rpc_clnt_clone_err(clnt, err);  in __rpc_clone_client()
661 struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt)  in rpc_clone_client()  argument
664 		.program	= clnt->cl_program,  in rpc_clone_client()
665 		.prognumber	= clnt->cl_prog,  in rpc_clone_client()
666 		.version	= clnt->cl_vers,  in rpc_clone_client()
667 		.authflavor	= clnt->cl_auth->au_flavor,  in rpc_clone_client()
668 		.cred		= clnt->cl_cred,  in rpc_clone_client()
670 	return __rpc_clone_client(&args, clnt);  in rpc_clone_client()
683 rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor)  in rpc_clone_client_set_auth()  argument
686 		.program	= clnt->cl_program,  in rpc_clone_client_set_auth()
687 		.prognumber	= clnt->cl_prog,  in rpc_clone_client_set_auth()
688 		.version	= clnt->cl_vers,  in rpc_clone_client_set_auth()
690 		.cred		= clnt->cl_cred,  in rpc_clone_client_set_auth()
692 	return __rpc_clone_client(&args, clnt);  in rpc_clone_client_set_auth()
711 int rpc_switch_client_transport(struct rpc_clnt *clnt,  in rpc_switch_client_transport()  argument
732 	pseudoflavor = clnt->cl_auth->au_flavor;  in rpc_switch_client_transport()
734 	old_timeo = clnt->cl_timeout;  in rpc_switch_client_transport()
735 	old = rpc_clnt_set_transport(clnt, xprt, timeout);  in rpc_switch_client_transport()
736 	oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps);  in rpc_switch_client_transport()
738 	rpc_unregister_client(clnt);  in rpc_switch_client_transport()
739 	__rpc_clnt_remove_pipedir(clnt);  in rpc_switch_client_transport()
740 	rpc_sysfs_client_destroy(clnt);  in rpc_switch_client_transport()
741 	rpc_clnt_debugfs_unregister(clnt);  in rpc_switch_client_transport()
748 	parent = clnt->cl_parent;  in rpc_switch_client_transport()
749 	clnt->cl_parent = clnt;  in rpc_switch_client_transport()
756 	err = rpc_client_register(clnt, pseudoflavor, NULL);  in rpc_switch_client_transport()
761 	if (parent != clnt)  in rpc_switch_client_transport()
765 	trace_rpc_clnt_replace_xprt(clnt);  in rpc_switch_client_transport()
769 	xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps);  in rpc_switch_client_transport()
770 	rpc_clnt_set_transport(clnt, old, old_timeo);  in rpc_switch_client_transport()
771 	clnt->cl_parent = parent;  in rpc_switch_client_transport()
772 	rpc_client_register(clnt, pseudoflavor, NULL);  in rpc_switch_client_transport()
775 	trace_rpc_clnt_replace_xprt_err(clnt);  in rpc_switch_client_transport()
781 int rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi)  in rpc_clnt_xprt_iter_init()  argument
786 	xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));  in rpc_clnt_xprt_iter_init()
806 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,  in rpc_clnt_iterate_for_each_xprt()  argument
813 	ret = rpc_clnt_xprt_iter_init(clnt, &xpi);  in rpc_clnt_iterate_for_each_xprt()
821 		ret = fn(clnt, xprt, data);  in rpc_clnt_iterate_for_each_xprt()
835 void rpc_killall_tasks(struct rpc_clnt *clnt)  in rpc_killall_tasks()  argument
840 	if (list_empty(&clnt->cl_tasks))  in rpc_killall_tasks()
846 	trace_rpc_clnt_killall(clnt);  in rpc_killall_tasks()
847 	spin_lock(&clnt->cl_lock);  in rpc_killall_tasks()
848 	list_for_each_entry(rovr, &clnt->cl_tasks, tk_task)  in rpc_killall_tasks()
850 	spin_unlock(&clnt->cl_lock);  in rpc_killall_tasks()
858 void rpc_shutdown_client(struct rpc_clnt *clnt)  in rpc_shutdown_client()  argument
862 	trace_rpc_clnt_shutdown(clnt);  in rpc_shutdown_client()
864 	while (!list_empty(&clnt->cl_tasks)) {  in rpc_shutdown_client()
865 		rpc_killall_tasks(clnt);  in rpc_shutdown_client()
867 			list_empty(&clnt->cl_tasks), 1*HZ);  in rpc_shutdown_client()
870 	rpc_release_client(clnt);  in rpc_shutdown_client()
879 	struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work);  in rpc_free_client_work()  local
881 	trace_rpc_clnt_free(clnt);  in rpc_free_client_work()
887 	rpc_sysfs_client_destroy(clnt);  in rpc_free_client_work()
888 	rpc_clnt_debugfs_unregister(clnt);  in rpc_free_client_work()
889 	rpc_free_clid(clnt);  in rpc_free_client_work()
890 	rpc_clnt_remove_pipedir(clnt);  in rpc_free_client_work()
891 	xprt_put(rcu_dereference_raw(clnt->cl_xprt));  in rpc_free_client_work()
893 	kfree(clnt);  in rpc_free_client_work()
897 rpc_free_client(struct rpc_clnt *clnt)  in rpc_free_client()  argument
901 	trace_rpc_clnt_release(clnt);  in rpc_free_client()
902 	if (clnt->cl_parent != clnt)  in rpc_free_client()
903 		parent = clnt->cl_parent;  in rpc_free_client()
904 	rpc_unregister_client(clnt);  in rpc_free_client()
905 	rpc_free_iostats(clnt->cl_metrics);  in rpc_free_client()
906 	clnt->cl_metrics = NULL;  in rpc_free_client()
907 	xprt_iter_destroy(&clnt->cl_xpi);  in rpc_free_client()
908 	put_cred(clnt->cl_cred);  in rpc_free_client()
910 	INIT_WORK(&clnt->cl_work, rpc_free_client_work);  in rpc_free_client()
911 	schedule_work(&clnt->cl_work);  in rpc_free_client()
919 rpc_free_auth(struct rpc_clnt *clnt)  in rpc_free_auth()  argument
926 	if (clnt->cl_auth != NULL) {  in rpc_free_auth()
927 		rpcauth_release(clnt->cl_auth);  in rpc_free_auth()
928 		clnt->cl_auth = NULL;  in rpc_free_auth()
930 	if (refcount_dec_and_test(&clnt->cl_count))  in rpc_free_auth()
931 		return rpc_free_client(clnt);  in rpc_free_auth()
939 rpc_release_client(struct rpc_clnt *clnt)  in rpc_release_client()  argument
942 		if (list_empty(&clnt->cl_tasks))  in rpc_release_client()
944 		if (refcount_dec_not_one(&clnt->cl_count))  in rpc_release_client()
946 		clnt = rpc_free_auth(clnt);  in rpc_release_client()
947 	} while (clnt != NULL);  in rpc_release_client()
972 	struct rpc_clnt *clnt;  in rpc_bind_new_program()  local
975 	clnt = __rpc_clone_client(&args, old);  in rpc_bind_new_program()
976 	if (IS_ERR(clnt))  in rpc_bind_new_program()
978 	err = rpc_ping(clnt);  in rpc_bind_new_program()
980 		rpc_shutdown_client(clnt);  in rpc_bind_new_program()
981 		clnt = ERR_PTR(err);  in rpc_bind_new_program()
984 	return clnt;  in rpc_bind_new_program()
989 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)  in rpc_task_get_xprt()  argument
996 	xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);  in rpc_task_get_xprt()
1005 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)  in rpc_task_release_xprt()  argument
1011 	xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);  in rpc_task_release_xprt()
1034 	struct rpc_clnt *clnt = task->tk_client;  in rpc_task_release_client()  local
1037 	if (clnt != NULL) {  in rpc_task_release_client()
1039 		spin_lock(&clnt->cl_lock);  in rpc_task_release_client()
1041 		spin_unlock(&clnt->cl_lock);  in rpc_task_release_client()
1044 		rpc_release_client(clnt);  in rpc_task_release_client()
1049 rpc_task_get_first_xprt(struct rpc_clnt *clnt)  in rpc_task_get_first_xprt()  argument
1054 	xprt = xprt_get(rcu_dereference(clnt->cl_xprt));  in rpc_task_get_first_xprt()
1056 	return rpc_task_get_xprt(clnt, xprt);  in rpc_task_get_first_xprt()
1060 rpc_task_get_next_xprt(struct rpc_clnt *clnt)  in rpc_task_get_next_xprt()  argument
1062 	return rpc_task_get_xprt(clnt, xprt_iter_get_next(&clnt->cl_xpi));  in rpc_task_get_next_xprt()
1066 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_transport()  argument
1071 		task->tk_xprt = rpc_task_get_first_xprt(clnt);  in rpc_task_set_transport()
1073 		task->tk_xprt = rpc_task_get_next_xprt(clnt);  in rpc_task_set_transport()
1077 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_client()  argument
1080 	if (clnt != NULL) {  in rpc_task_set_client()
1081 		rpc_task_set_transport(task, clnt);  in rpc_task_set_client()
1082 		task->tk_client = clnt;  in rpc_task_set_client()
1083 		refcount_inc(&clnt->cl_count);  in rpc_task_set_client()
1084 		if (clnt->cl_softrtry)  in rpc_task_set_client()
1086 		if (clnt->cl_softerr)  in rpc_task_set_client()
1088 		if (clnt->cl_noretranstimeo)  in rpc_task_set_client()
1090 		if (atomic_read(&clnt->cl_swapper))  in rpc_task_set_client()
1093 		spin_lock(&clnt->cl_lock);  in rpc_task_set_client()
1094 		list_add_tail(&task->tk_task, &clnt->cl_tasks);  in rpc_task_set_client()
1095 		spin_unlock(&clnt->cl_lock);  in rpc_task_set_client()
1155 int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags)  in rpc_call_sync()  argument
1159 		.rpc_client = clnt,  in rpc_call_sync()
1191 rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags,  in rpc_call_async()  argument
1196 		.rpc_client = clnt,  in rpc_call_async()
1280 size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize)  in rpc_peeraddr()  argument
1286 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_peeraddr()
1307 const char *rpc_peeraddr2str(struct rpc_clnt *clnt,  in rpc_peeraddr2str()  argument
1312 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_peeraddr2str()
1445 int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen)  in rpc_localaddr()  argument
1455 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_localaddr()
1472 rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize)  in rpc_setbufsize()  argument
1477 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_setbufsize()
1489 struct net *rpc_net_ns(struct rpc_clnt *clnt)  in rpc_net_ns()  argument
1494 	ret = rcu_dereference(clnt->cl_xprt)->xprt_net;  in rpc_net_ns()
1509 size_t rpc_max_payload(struct rpc_clnt *clnt)  in rpc_max_payload()  argument
1514 	ret = rcu_dereference(clnt->cl_xprt)->max_payload;  in rpc_max_payload()
1524 size_t rpc_max_bc_payload(struct rpc_clnt *clnt)  in rpc_max_bc_payload()  argument
1530 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_max_bc_payload()
1537 unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt)  in rpc_num_bc_slots()  argument
1543 	xprt = rcu_dereference(clnt->cl_xprt);  in rpc_num_bc_slots()
1555 void rpc_force_rebind(struct rpc_clnt *clnt)  in rpc_force_rebind()  argument
1557 	if (clnt->cl_autobind) {  in rpc_force_rebind()
1559 		xprt_clear_bound(rcu_dereference(clnt->cl_xprt));  in rpc_force_rebind()
1635 	struct rpc_clnt	*clnt = task->tk_client;  in call_start()  local
1641 	if (clnt->cl_program->version[clnt->cl_vers])  in call_start()
1642 		clnt->cl_program->version[clnt->cl_vers]->counts[idx]++;  in call_start()
1643 	clnt->cl_stats->rpccnt++;  in call_start()
1645 	rpc_task_set_transport(task, clnt);  in call_start()
2059 	struct rpc_clnt *clnt = task->tk_client;  in call_connect_status()  local
2070 		clnt->cl_stats->netreconn++;  in call_connect_status()
2084 		if (clnt->cl_autobind) {  in call_connect_status()
2085 			rpc_force_rebind(clnt);  in call_connect_status()
2114 			xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));  in call_connect_status()
2326 	struct rpc_clnt	*clnt = task->tk_client;  in call_status()  local
2360 		rpc_force_rebind(clnt);  in call_status()
2372 		if (clnt->cl_chatty)  in call_status()
2374 			       clnt->cl_program->name, -status);  in call_status()
2397 	struct rpc_clnt	*clnt = task->tk_client;  in rpc_check_timeout()  local
2425 		if (clnt->cl_chatty) {  in rpc_check_timeout()
2428 				clnt->cl_program->name,  in rpc_check_timeout()
2440 		if (clnt->cl_chatty) {  in rpc_check_timeout()
2443 				clnt->cl_program->name,  in rpc_check_timeout()
2447 	rpc_force_rebind(clnt);  in rpc_check_timeout()
2461 	struct rpc_clnt	*clnt = task->tk_client;  in call_decode()  local
2472 		if (clnt->cl_chatty) {  in call_decode()
2474 				clnt->cl_program->name,  in call_decode()
2529 	struct rpc_clnt *clnt = task->tk_client;  in rpc_encode_header()  local
2541 	*p++ = cpu_to_be32(clnt->cl_prog);  in rpc_encode_header()
2542 	*p++ = cpu_to_be32(clnt->cl_vers);  in rpc_encode_header()
2558 	struct rpc_clnt *clnt = task->tk_client;  in rpc_decode_header()  local
2611 	clnt->cl_stats->rpcgarbage++;  in rpc_decode_header()
2708 struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt,  in rpc_call_null_helper()  argument
2716 		.rpc_client = clnt,  in rpc_call_null_helper()
2729 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags)  in rpc_call_null()  argument
2731 	return rpc_call_null_helper(clnt, NULL, cred, flags, NULL, NULL);  in rpc_call_null()
2735 static int rpc_ping(struct rpc_clnt *clnt)  in rpc_ping()  argument
2740 	task = rpc_call_null_helper(clnt, NULL, NULL, 0, NULL, NULL);  in rpc_ping()
2783 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,  in rpc_clnt_test_and_add_xprt()  argument
2790 	if (xps->xps_nunique_destaddr_xprts + 1 > clnt->cl_max_connect) {  in rpc_clnt_test_and_add_xprt()
2793 			"transport to server: %s\n", clnt->cl_max_connect,  in rpc_clnt_test_and_add_xprt()
2794 			rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR));  in rpc_clnt_test_and_add_xprt()
2809 	task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC,  in rpc_clnt_test_and_add_xprt()
2836 int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt,  in rpc_clnt_setup_test_and_add_xprt()  argument
2852 	task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL);  in rpc_clnt_setup_test_and_add_xprt()
2864 	xtest->add_xprt_test(clnt, xprt, xtest->data);  in rpc_clnt_setup_test_and_add_xprt()
2893 int rpc_clnt_add_xprt(struct rpc_clnt *clnt,  in rpc_clnt_add_xprt()  argument
2909 	xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));  in rpc_clnt_add_xprt()
2910 	xprt = xprt_iter_xprt(&clnt->cl_xpi);  in rpc_clnt_add_xprt()
2936 		ret = setup(clnt, xps, xprt, data);  in rpc_clnt_add_xprt()
2955 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt,  in rpc_xprt_set_connect_timeout()  argument
2969 rpc_set_connect_timeout(struct rpc_clnt *clnt,  in rpc_set_connect_timeout()  argument
2977 	rpc_clnt_iterate_for_each_xprt(clnt,  in rpc_set_connect_timeout()
2983 void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt)  in rpc_clnt_xprt_switch_put()  argument
2986 	xprt_switch_put(rcu_dereference(clnt->cl_xpi.xpi_xpswitch));  in rpc_clnt_xprt_switch_put()
2991 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)  in rpc_clnt_xprt_switch_add_xprt()  argument
2994 	rpc_xprt_switch_add_xprt(rcu_dereference(clnt->cl_xpi.xpi_xpswitch),  in rpc_clnt_xprt_switch_add_xprt()
3000 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt,  in rpc_clnt_xprt_switch_has_addr()  argument
3007 	xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch);  in rpc_clnt_xprt_switch_has_addr()
3021 static void rpc_show_task(const struct rpc_clnt *clnt,  in rpc_show_task()  argument
3031 		clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops,  in rpc_show_task()
3032 		clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task),  in rpc_show_task()
3038 	struct rpc_clnt *clnt;  in rpc_show_tasks()  local
3044 	list_for_each_entry(clnt, &sn->all_clients, cl_clients) {  in rpc_show_tasks()
3045 		spin_lock(&clnt->cl_lock);  in rpc_show_tasks()
3046 		list_for_each_entry(task, &clnt->cl_tasks, tk_task) {  in rpc_show_tasks()
3051 			rpc_show_task(clnt, task);  in rpc_show_tasks()
3053 		spin_unlock(&clnt->cl_lock);  in rpc_show_tasks()
3061 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt,  in rpc_clnt_swap_activate_callback()  argument
3069 rpc_clnt_swap_activate(struct rpc_clnt *clnt)  in rpc_clnt_swap_activate()  argument
3071 	if (atomic_inc_return(&clnt->cl_swapper) == 1)  in rpc_clnt_swap_activate()
3072 		return rpc_clnt_iterate_for_each_xprt(clnt,  in rpc_clnt_swap_activate()
3079 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt,  in rpc_clnt_swap_deactivate_callback()  argument
3088 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt)  in rpc_clnt_swap_deactivate()  argument
3090 	if (atomic_dec_if_positive(&clnt->cl_swapper) == 0)  in rpc_clnt_swap_deactivate()
3091 		rpc_clnt_iterate_for_each_xprt(clnt,  in rpc_clnt_swap_deactivate()