Lines Matching refs:clnt
78 static int rpc_ping(struct rpc_clnt *clnt);
79 static int rpc_ping_noreply(struct rpc_clnt *clnt);
82 static void rpc_register_client(struct rpc_clnt *clnt) in rpc_register_client() argument
84 struct net *net = rpc_net_ns(clnt); in rpc_register_client()
88 list_add(&clnt->cl_clients, &sn->all_clients); in rpc_register_client()
92 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client() argument
94 struct net *net = rpc_net_ns(clnt); in rpc_unregister_client()
98 list_del(&clnt->cl_clients); in rpc_unregister_client()
102 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in __rpc_clnt_remove_pipedir() argument
104 rpc_remove_client_dir(clnt); in __rpc_clnt_remove_pipedir()
107 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in rpc_clnt_remove_pipedir() argument
109 struct net *net = rpc_net_ns(clnt); in rpc_clnt_remove_pipedir()
114 __rpc_clnt_remove_pipedir(clnt); in rpc_clnt_remove_pipedir()
120 struct rpc_clnt *clnt) in rpc_setup_pipedir_sb() argument
123 const char *dir_name = clnt->cl_program->pipe_dir_name; in rpc_setup_pipedir_sb()
135 dentry = rpc_create_client_dir(dir, name, clnt); in rpc_setup_pipedir_sb()
150 rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt) in rpc_setup_pipedir() argument
154 if (clnt->cl_program->pipe_dir_name != NULL) { in rpc_setup_pipedir()
155 dentry = rpc_setup_pipedir_sb(pipefs_sb, clnt); in rpc_setup_pipedir()
162 static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event) in rpc_clnt_skip_event() argument
164 if (clnt->cl_program->pipe_dir_name == NULL) in rpc_clnt_skip_event()
169 if (clnt->cl_pipedir_objects.pdh_dentry != NULL) in rpc_clnt_skip_event()
171 if (refcount_read(&clnt->cl_count) == 0) in rpc_clnt_skip_event()
175 if (clnt->cl_pipedir_objects.pdh_dentry == NULL) in rpc_clnt_skip_event()
182 static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event, in __rpc_clnt_handle_event() argument
189 dentry = rpc_setup_pipedir_sb(sb, clnt); in __rpc_clnt_handle_event()
196 __rpc_clnt_remove_pipedir(clnt); in __rpc_clnt_handle_event()
205 static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event, in __rpc_pipefs_event() argument
210 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
211 if (!rpc_clnt_skip_event(clnt, event)) in __rpc_pipefs_event()
212 error = __rpc_clnt_handle_event(clnt, event, sb); in __rpc_pipefs_event()
213 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
222 struct rpc_clnt *clnt; in rpc_get_client_for_event() local
225 list_for_each_entry(clnt, &sn->all_clients, cl_clients) { in rpc_get_client_for_event()
226 if (rpc_clnt_skip_event(clnt, event)) in rpc_get_client_for_event()
229 return clnt; in rpc_get_client_for_event()
239 struct rpc_clnt *clnt; in rpc_pipefs_event() local
242 while ((clnt = rpc_get_client_for_event(sb->s_fs_info, event))) { in rpc_pipefs_event()
243 error = __rpc_pipefs_event(clnt, event, sb); in rpc_pipefs_event()
265 static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt, in rpc_clnt_set_transport() argument
271 spin_lock(&clnt->cl_lock); in rpc_clnt_set_transport()
272 old = rcu_dereference_protected(clnt->cl_xprt, in rpc_clnt_set_transport()
273 lockdep_is_held(&clnt->cl_lock)); in rpc_clnt_set_transport()
276 clnt->cl_autobind = 1; in rpc_clnt_set_transport()
278 clnt->cl_timeout = timeout; in rpc_clnt_set_transport()
279 rcu_assign_pointer(clnt->cl_xprt, xprt); in rpc_clnt_set_transport()
280 spin_unlock(&clnt->cl_lock); in rpc_clnt_set_transport()
285 static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename) in rpc_clnt_set_nodename() argument
287 clnt->cl_nodelen = strlcpy(clnt->cl_nodename, in rpc_clnt_set_nodename()
288 nodename, sizeof(clnt->cl_nodename)); in rpc_clnt_set_nodename()
291 static int rpc_client_register(struct rpc_clnt *clnt, in rpc_client_register() argument
300 struct net *net = rpc_net_ns(clnt); in rpc_client_register()
304 rpc_clnt_debugfs_register(clnt); in rpc_client_register()
308 err = rpc_setup_pipedir(pipefs_sb, clnt); in rpc_client_register()
313 rpc_register_client(clnt); in rpc_client_register()
317 auth = rpcauth_create(&auth_args, clnt); in rpc_client_register()
327 rpc_unregister_client(clnt); in rpc_client_register()
328 __rpc_clnt_remove_pipedir(clnt); in rpc_client_register()
332 rpc_sysfs_client_destroy(clnt); in rpc_client_register()
333 rpc_clnt_debugfs_unregister(clnt); in rpc_client_register()
344 static int rpc_alloc_clid(struct rpc_clnt *clnt) in rpc_alloc_clid() argument
351 clnt->cl_clid = clid; in rpc_alloc_clid()
355 static void rpc_free_clid(struct rpc_clnt *clnt) in rpc_free_clid() argument
357 ida_free(&rpc_clids, clnt->cl_clid); in rpc_free_clid()
367 struct rpc_clnt *clnt = NULL; in rpc_new_client() local
384 clnt = kzalloc(sizeof(*clnt), GFP_KERNEL); in rpc_new_client()
385 if (!clnt) in rpc_new_client()
387 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
389 err = rpc_alloc_clid(clnt); in rpc_new_client()
393 clnt->cl_cred = get_cred(args->cred); in rpc_new_client()
394 clnt->cl_procinfo = version->procs; in rpc_new_client()
395 clnt->cl_maxproc = version->nrprocs; in rpc_new_client()
396 clnt->cl_prog = args->prognumber ? : program->number; in rpc_new_client()
397 clnt->cl_vers = version->number; in rpc_new_client()
398 clnt->cl_stats = program->stats; in rpc_new_client()
399 clnt->cl_metrics = rpc_alloc_iostats(clnt); in rpc_new_client()
400 rpc_init_pipe_dir_head(&clnt->cl_pipedir_objects); in rpc_new_client()
402 if (clnt->cl_metrics == NULL) in rpc_new_client()
404 clnt->cl_program = program; in rpc_new_client()
405 INIT_LIST_HEAD(&clnt->cl_tasks); in rpc_new_client()
406 spin_lock_init(&clnt->cl_lock); in rpc_new_client()
410 memcpy(&clnt->cl_timeout_default, args->timeout, in rpc_new_client()
411 sizeof(clnt->cl_timeout_default)); in rpc_new_client()
412 timeout = &clnt->cl_timeout_default; in rpc_new_client()
415 rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_new_client()
417 xprt_iter_init(&clnt->cl_xpi, xps); in rpc_new_client()
420 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
421 rpc_init_rtt(&clnt->cl_rtt_default, clnt->cl_timeout->to_initval); in rpc_new_client()
423 refcount_set(&clnt->cl_count, 1); in rpc_new_client()
428 rpc_clnt_set_nodename(clnt, nodename); in rpc_new_client()
430 rpc_sysfs_client_setup(clnt, xps, rpc_net_ns(clnt)); in rpc_new_client()
431 err = rpc_client_register(clnt, args->authflavor, args->client_name); in rpc_new_client()
437 trace_rpc_clnt_new(clnt, xprt, program->name, args->servername); in rpc_new_client()
438 return clnt; in rpc_new_client()
441 rpc_free_iostats(clnt->cl_metrics); in rpc_new_client()
443 put_cred(clnt->cl_cred); in rpc_new_client()
444 rpc_free_clid(clnt); in rpc_new_client()
446 kfree(clnt); in rpc_new_client()
459 struct rpc_clnt *clnt = NULL; in rpc_create_xprt() local
477 clnt = rpc_new_client(args, xps, xprt, NULL); in rpc_create_xprt()
478 if (IS_ERR(clnt)) in rpc_create_xprt()
479 return clnt; in rpc_create_xprt()
482 int err = rpc_ping(clnt); in rpc_create_xprt()
484 rpc_shutdown_client(clnt); in rpc_create_xprt()
488 int err = rpc_ping_noreply(clnt); in rpc_create_xprt()
490 rpc_shutdown_client(clnt); in rpc_create_xprt()
495 clnt->cl_softrtry = 1; in rpc_create_xprt()
497 clnt->cl_softrtry = 0; in rpc_create_xprt()
499 clnt->cl_softerr = 1; in rpc_create_xprt()
503 clnt->cl_autobind = 1; in rpc_create_xprt()
505 clnt->cl_noretranstimeo = 1; in rpc_create_xprt()
507 clnt->cl_discrtry = 1; in rpc_create_xprt()
509 clnt->cl_chatty = 1; in rpc_create_xprt()
511 return clnt; in rpc_create_xprt()
537 struct rpc_clnt *clnt; in rpc_create() local
604 clnt = rpc_create_xprt(args, xprt); in rpc_create()
605 if (IS_ERR(clnt) || args->nconnect <= 1) in rpc_create()
606 return clnt; in rpc_create()
609 if (rpc_clnt_add_xprt(clnt, &xprtargs, NULL, NULL) < 0) in rpc_create()
612 return clnt; in rpc_create()
622 struct rpc_clnt *clnt) in __rpc_clone_client() argument
631 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in __rpc_clone_client()
632 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in __rpc_clone_client()
640 args->nodename = clnt->cl_nodename; in __rpc_clone_client()
642 new = rpc_new_client(args, xps, xprt, clnt); in __rpc_clone_client()
648 new->cl_softrtry = clnt->cl_softrtry; in __rpc_clone_client()
649 new->cl_softerr = clnt->cl_softerr; in __rpc_clone_client()
650 new->cl_noretranstimeo = clnt->cl_noretranstimeo; in __rpc_clone_client()
651 new->cl_discrtry = clnt->cl_discrtry; in __rpc_clone_client()
652 new->cl_chatty = clnt->cl_chatty; in __rpc_clone_client()
653 new->cl_principal = clnt->cl_principal; in __rpc_clone_client()
654 new->cl_max_connect = clnt->cl_max_connect; in __rpc_clone_client()
658 trace_rpc_clnt_clone_err(clnt, err); in __rpc_clone_client()
669 struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt) in rpc_clone_client() argument
672 .program = clnt->cl_program, in rpc_clone_client()
673 .prognumber = clnt->cl_prog, in rpc_clone_client()
674 .version = clnt->cl_vers, in rpc_clone_client()
675 .authflavor = clnt->cl_auth->au_flavor, in rpc_clone_client()
676 .cred = clnt->cl_cred, in rpc_clone_client()
678 return __rpc_clone_client(&args, clnt); in rpc_clone_client()
691 rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor) in rpc_clone_client_set_auth() argument
694 .program = clnt->cl_program, in rpc_clone_client_set_auth()
695 .prognumber = clnt->cl_prog, in rpc_clone_client_set_auth()
696 .version = clnt->cl_vers, in rpc_clone_client_set_auth()
698 .cred = clnt->cl_cred, in rpc_clone_client_set_auth()
700 return __rpc_clone_client(&args, clnt); in rpc_clone_client_set_auth()
719 int rpc_switch_client_transport(struct rpc_clnt *clnt, in rpc_switch_client_transport() argument
740 pseudoflavor = clnt->cl_auth->au_flavor; in rpc_switch_client_transport()
742 old_timeo = clnt->cl_timeout; in rpc_switch_client_transport()
743 old = rpc_clnt_set_transport(clnt, xprt, timeout); in rpc_switch_client_transport()
744 oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps); in rpc_switch_client_transport()
746 rpc_unregister_client(clnt); in rpc_switch_client_transport()
747 __rpc_clnt_remove_pipedir(clnt); in rpc_switch_client_transport()
748 rpc_sysfs_client_destroy(clnt); in rpc_switch_client_transport()
749 rpc_clnt_debugfs_unregister(clnt); in rpc_switch_client_transport()
756 parent = clnt->cl_parent; in rpc_switch_client_transport()
757 clnt->cl_parent = clnt; in rpc_switch_client_transport()
764 err = rpc_client_register(clnt, pseudoflavor, NULL); in rpc_switch_client_transport()
769 if (parent != clnt) in rpc_switch_client_transport()
773 trace_rpc_clnt_replace_xprt(clnt); in rpc_switch_client_transport()
777 xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps); in rpc_switch_client_transport()
778 rpc_clnt_set_transport(clnt, old, old_timeo); in rpc_switch_client_transport()
779 clnt->cl_parent = parent; in rpc_switch_client_transport()
780 rpc_client_register(clnt, pseudoflavor, NULL); in rpc_switch_client_transport()
783 trace_rpc_clnt_replace_xprt_err(clnt); in rpc_switch_client_transport()
789 int _rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi, in _rpc_clnt_xprt_iter_init() argument
795 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in _rpc_clnt_xprt_iter_init()
805 int rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi) in rpc_clnt_xprt_iter_init() argument
807 return _rpc_clnt_xprt_iter_init(clnt, xpi, xprt_iter_init_listall); in rpc_clnt_xprt_iter_init()
811 int rpc_clnt_xprt_iter_offline_init(struct rpc_clnt *clnt, in rpc_clnt_xprt_iter_offline_init() argument
814 return _rpc_clnt_xprt_iter_init(clnt, xpi, xprt_iter_init_listoffline); in rpc_clnt_xprt_iter_offline_init()
828 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, in rpc_clnt_iterate_for_each_xprt() argument
835 ret = rpc_clnt_xprt_iter_init(clnt, &xpi); in rpc_clnt_iterate_for_each_xprt()
843 ret = fn(clnt, xprt, data); in rpc_clnt_iterate_for_each_xprt()
857 void rpc_killall_tasks(struct rpc_clnt *clnt) in rpc_killall_tasks() argument
862 if (list_empty(&clnt->cl_tasks)) in rpc_killall_tasks()
868 trace_rpc_clnt_killall(clnt); in rpc_killall_tasks()
869 spin_lock(&clnt->cl_lock); in rpc_killall_tasks()
870 list_for_each_entry(rovr, &clnt->cl_tasks, tk_task) in rpc_killall_tasks()
872 spin_unlock(&clnt->cl_lock); in rpc_killall_tasks()
886 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error, in rpc_cancel_tasks() argument
894 if (list_empty(&clnt->cl_tasks)) in rpc_cancel_tasks()
899 spin_lock(&clnt->cl_lock); in rpc_cancel_tasks()
900 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_cancel_tasks()
908 spin_unlock(&clnt->cl_lock); in rpc_cancel_tasks()
913 static int rpc_clnt_disconnect_xprt(struct rpc_clnt *clnt, in rpc_clnt_disconnect_xprt() argument
921 void rpc_clnt_disconnect(struct rpc_clnt *clnt) in rpc_clnt_disconnect() argument
923 rpc_clnt_iterate_for_each_xprt(clnt, rpc_clnt_disconnect_xprt, NULL); in rpc_clnt_disconnect()
931 void rpc_shutdown_client(struct rpc_clnt *clnt) in rpc_shutdown_client() argument
935 trace_rpc_clnt_shutdown(clnt); in rpc_shutdown_client()
937 while (!list_empty(&clnt->cl_tasks)) { in rpc_shutdown_client()
938 rpc_killall_tasks(clnt); in rpc_shutdown_client()
940 list_empty(&clnt->cl_tasks), 1*HZ); in rpc_shutdown_client()
943 rpc_release_client(clnt); in rpc_shutdown_client()
952 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work); in rpc_free_client_work() local
954 trace_rpc_clnt_free(clnt); in rpc_free_client_work()
960 rpc_sysfs_client_destroy(clnt); in rpc_free_client_work()
961 rpc_clnt_debugfs_unregister(clnt); in rpc_free_client_work()
962 rpc_free_clid(clnt); in rpc_free_client_work()
963 rpc_clnt_remove_pipedir(clnt); in rpc_free_client_work()
964 xprt_put(rcu_dereference_raw(clnt->cl_xprt)); in rpc_free_client_work()
966 kfree(clnt); in rpc_free_client_work()
970 rpc_free_client(struct rpc_clnt *clnt) in rpc_free_client() argument
974 trace_rpc_clnt_release(clnt); in rpc_free_client()
975 if (clnt->cl_parent != clnt) in rpc_free_client()
976 parent = clnt->cl_parent; in rpc_free_client()
977 rpc_unregister_client(clnt); in rpc_free_client()
978 rpc_free_iostats(clnt->cl_metrics); in rpc_free_client()
979 clnt->cl_metrics = NULL; in rpc_free_client()
980 xprt_iter_destroy(&clnt->cl_xpi); in rpc_free_client()
981 put_cred(clnt->cl_cred); in rpc_free_client()
983 INIT_WORK(&clnt->cl_work, rpc_free_client_work); in rpc_free_client()
984 schedule_work(&clnt->cl_work); in rpc_free_client()
992 rpc_free_auth(struct rpc_clnt *clnt) in rpc_free_auth() argument
999 if (clnt->cl_auth != NULL) { in rpc_free_auth()
1000 rpcauth_release(clnt->cl_auth); in rpc_free_auth()
1001 clnt->cl_auth = NULL; in rpc_free_auth()
1003 if (refcount_dec_and_test(&clnt->cl_count)) in rpc_free_auth()
1004 return rpc_free_client(clnt); in rpc_free_auth()
1012 rpc_release_client(struct rpc_clnt *clnt) in rpc_release_client() argument
1015 if (list_empty(&clnt->cl_tasks)) in rpc_release_client()
1017 if (refcount_dec_not_one(&clnt->cl_count)) in rpc_release_client()
1019 clnt = rpc_free_auth(clnt); in rpc_release_client()
1020 } while (clnt != NULL); in rpc_release_client()
1045 struct rpc_clnt *clnt; in rpc_bind_new_program() local
1048 clnt = __rpc_clone_client(&args, old); in rpc_bind_new_program()
1049 if (IS_ERR(clnt)) in rpc_bind_new_program()
1051 err = rpc_ping(clnt); in rpc_bind_new_program()
1053 rpc_shutdown_client(clnt); in rpc_bind_new_program()
1054 clnt = ERR_PTR(err); in rpc_bind_new_program()
1057 return clnt; in rpc_bind_new_program()
1062 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_get_xprt() argument
1069 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_get_xprt()
1078 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_release_xprt() argument
1084 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_task_release_xprt()
1107 struct rpc_clnt *clnt = task->tk_client; in rpc_task_release_client() local
1110 if (clnt != NULL) { in rpc_task_release_client()
1112 spin_lock(&clnt->cl_lock); in rpc_task_release_client()
1114 spin_unlock(&clnt->cl_lock); in rpc_task_release_client()
1117 rpc_release_client(clnt); in rpc_task_release_client()
1122 rpc_task_get_first_xprt(struct rpc_clnt *clnt) in rpc_task_get_first_xprt() argument
1127 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_task_get_first_xprt()
1129 return rpc_task_get_xprt(clnt, xprt); in rpc_task_get_first_xprt()
1133 rpc_task_get_next_xprt(struct rpc_clnt *clnt) in rpc_task_get_next_xprt() argument
1135 return rpc_task_get_xprt(clnt, xprt_iter_get_next(&clnt->cl_xpi)); in rpc_task_get_next_xprt()
1139 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_transport() argument
1149 task->tk_xprt = rpc_task_get_first_xprt(clnt); in rpc_task_set_transport()
1151 task->tk_xprt = rpc_task_get_next_xprt(clnt); in rpc_task_set_transport()
1155 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_client() argument
1157 rpc_task_set_transport(task, clnt); in rpc_task_set_client()
1158 task->tk_client = clnt; in rpc_task_set_client()
1159 refcount_inc(&clnt->cl_count); in rpc_task_set_client()
1160 if (clnt->cl_softrtry) in rpc_task_set_client()
1162 if (clnt->cl_softerr) in rpc_task_set_client()
1164 if (clnt->cl_noretranstimeo) in rpc_task_set_client()
1167 spin_lock(&clnt->cl_lock); in rpc_task_set_client()
1168 list_add_tail(&task->tk_task, &clnt->cl_tasks); in rpc_task_set_client()
1169 spin_unlock(&clnt->cl_lock); in rpc_task_set_client()
1230 int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags) in rpc_call_sync() argument
1234 .rpc_client = clnt, in rpc_call_sync()
1266 rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags, in rpc_call_async() argument
1271 .rpc_client = clnt, in rpc_call_async()
1360 size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize) in rpc_peeraddr() argument
1366 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr()
1387 const char *rpc_peeraddr2str(struct rpc_clnt *clnt, in rpc_peeraddr2str() argument
1392 xprt = rcu_dereference(clnt->cl_xprt); in rpc_peeraddr2str()
1525 int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen) in rpc_localaddr() argument
1535 xprt = rcu_dereference(clnt->cl_xprt); in rpc_localaddr()
1552 rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize) in rpc_setbufsize() argument
1557 xprt = rcu_dereference(clnt->cl_xprt); in rpc_setbufsize()
1569 struct net *rpc_net_ns(struct rpc_clnt *clnt) in rpc_net_ns() argument
1574 ret = rcu_dereference(clnt->cl_xprt)->xprt_net; in rpc_net_ns()
1589 size_t rpc_max_payload(struct rpc_clnt *clnt) in rpc_max_payload() argument
1594 ret = rcu_dereference(clnt->cl_xprt)->max_payload; in rpc_max_payload()
1604 size_t rpc_max_bc_payload(struct rpc_clnt *clnt) in rpc_max_bc_payload() argument
1610 xprt = rcu_dereference(clnt->cl_xprt); in rpc_max_bc_payload()
1617 unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt) in rpc_num_bc_slots() argument
1623 xprt = rcu_dereference(clnt->cl_xprt); in rpc_num_bc_slots()
1635 void rpc_force_rebind(struct rpc_clnt *clnt) in rpc_force_rebind() argument
1637 if (clnt->cl_autobind) { in rpc_force_rebind()
1639 xprt_clear_bound(rcu_dereference(clnt->cl_xprt)); in rpc_force_rebind()
1715 struct rpc_clnt *clnt = task->tk_client; in call_start() local
1721 if (clnt->cl_program->version[clnt->cl_vers]) in call_start()
1722 clnt->cl_program->version[clnt->cl_vers]->counts[idx]++; in call_start()
1723 clnt->cl_stats->rpccnt++; in call_start()
1725 rpc_task_set_transport(task, clnt); in call_start()
2141 struct rpc_clnt *clnt = task->tk_client; in call_connect_status() local
2152 clnt->cl_stats->netreconn++; in call_connect_status()
2166 if (clnt->cl_autobind) { in call_connect_status()
2167 rpc_force_rebind(clnt); in call_connect_status()
2196 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in call_connect_status()
2411 struct rpc_clnt *clnt = task->tk_client; in call_status() local
2445 rpc_force_rebind(clnt); in call_status()
2462 if (clnt->cl_chatty) in call_status()
2464 clnt->cl_program->name, -status); in call_status()
2487 struct rpc_clnt *clnt = task->tk_client; in rpc_check_timeout() local
2513 if (clnt->cl_chatty) { in rpc_check_timeout()
2516 clnt->cl_program->name, in rpc_check_timeout()
2528 if (clnt->cl_chatty) { in rpc_check_timeout()
2531 clnt->cl_program->name, in rpc_check_timeout()
2535 rpc_force_rebind(clnt); in rpc_check_timeout()
2549 struct rpc_clnt *clnt = task->tk_client; in call_decode() local
2560 if (clnt->cl_chatty) { in call_decode()
2562 clnt->cl_program->name, in call_decode()
2617 struct rpc_clnt *clnt = task->tk_client; in rpc_encode_header() local
2629 *p++ = cpu_to_be32(clnt->cl_prog); in rpc_encode_header()
2630 *p++ = cpu_to_be32(clnt->cl_vers); in rpc_encode_header()
2646 struct rpc_clnt *clnt = task->tk_client; in rpc_decode_header() local
2699 clnt->cl_stats->rpcgarbage++; in rpc_decode_header()
2800 struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt, in rpc_call_null_helper() argument
2808 .rpc_client = clnt, in rpc_call_null_helper()
2821 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags) in rpc_call_null() argument
2823 return rpc_call_null_helper(clnt, NULL, cred, flags, NULL, NULL); in rpc_call_null()
2827 static int rpc_ping(struct rpc_clnt *clnt) in rpc_ping() argument
2832 task = rpc_call_null_helper(clnt, NULL, NULL, 0, NULL, NULL); in rpc_ping()
2840 static int rpc_ping_noreply(struct rpc_clnt *clnt) in rpc_ping_noreply() argument
2846 .rpc_client = clnt, in rpc_ping_noreply()
2897 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_test_and_add_xprt() argument
2904 if (xps->xps_nunique_destaddr_xprts + 1 > clnt->cl_max_connect) { in rpc_clnt_test_and_add_xprt()
2907 "transport to server: %s\n", clnt->cl_max_connect, in rpc_clnt_test_and_add_xprt()
2908 rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR)); in rpc_clnt_test_and_add_xprt()
2923 task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC, in rpc_clnt_test_and_add_xprt()
2935 static int rpc_clnt_add_xprt_helper(struct rpc_clnt *clnt, in rpc_clnt_add_xprt_helper() argument
2943 task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL); in rpc_clnt_add_xprt_helper()
2954 data->add_xprt_test(clnt, xprt, data->data); in rpc_clnt_add_xprt_helper()
2977 int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_setup_test_and_add_xprt() argument
2990 status = rpc_clnt_add_xprt_helper(clnt, xprt, data); in rpc_clnt_setup_test_and_add_xprt()
3020 int rpc_clnt_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_add_xprt() argument
3036 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_add_xprt()
3037 xprt = xprt_iter_xprt(&clnt->cl_xpi); in rpc_clnt_add_xprt()
3066 ret = setup(clnt, xps, xprt, data); in rpc_clnt_add_xprt()
3079 static int rpc_xprt_probe_trunked(struct rpc_clnt *clnt, in rpc_xprt_probe_trunked() argument
3090 main_xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_xprt_probe_trunked()
3091 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_xprt_probe_trunked()
3099 status = rpc_clnt_add_xprt_helper(clnt, xprt, data); in rpc_xprt_probe_trunked()
3113 void rpc_clnt_probe_trunked_xprts(struct rpc_clnt *clnt, in rpc_clnt_probe_trunked_xprts() argument
3119 ret = rpc_clnt_xprt_iter_offline_init(clnt, &xpi); in rpc_clnt_probe_trunked_xprts()
3127 ret = rpc_xprt_probe_trunked(clnt, xprt, data); in rpc_clnt_probe_trunked_xprts()
3137 static int rpc_xprt_offline(struct rpc_clnt *clnt, in rpc_xprt_offline() argument
3148 main_xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpc_xprt_offline()
3149 xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_xprt_offline()
3177 void rpc_clnt_manage_trunked_xprts(struct rpc_clnt *clnt) in rpc_clnt_manage_trunked_xprts() argument
3179 rpc_clnt_iterate_for_each_xprt(clnt, rpc_xprt_offline, NULL); in rpc_clnt_manage_trunked_xprts()
3189 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt, in rpc_xprt_set_connect_timeout() argument
3203 rpc_set_connect_timeout(struct rpc_clnt *clnt, in rpc_set_connect_timeout() argument
3211 rpc_clnt_iterate_for_each_xprt(clnt, in rpc_set_connect_timeout()
3217 void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt) in rpc_clnt_xprt_switch_put() argument
3220 xprt_switch_put(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); in rpc_clnt_xprt_switch_put()
3225 void rpc_clnt_xprt_set_online(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_set_online() argument
3230 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_set_online()
3235 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_add_xprt() argument
3237 if (rpc_clnt_xprt_switch_has_addr(clnt, in rpc_clnt_xprt_switch_add_xprt()
3239 return rpc_clnt_xprt_set_online(clnt, xprt); in rpc_clnt_xprt_switch_add_xprt()
3242 rpc_xprt_switch_add_xprt(rcu_dereference(clnt->cl_xpi.xpi_xpswitch), in rpc_clnt_xprt_switch_add_xprt()
3248 void rpc_clnt_xprt_switch_remove_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_remove_xprt() argument
3253 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_remove_xprt()
3254 rpc_xprt_switch_remove_xprt(rcu_dereference(clnt->cl_xpi.xpi_xpswitch), in rpc_clnt_xprt_switch_remove_xprt()
3261 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt, in rpc_clnt_xprt_switch_has_addr() argument
3268 xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); in rpc_clnt_xprt_switch_has_addr()
3282 static void rpc_show_task(const struct rpc_clnt *clnt, in rpc_show_task() argument
3292 clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops, in rpc_show_task()
3293 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in rpc_show_task()
3299 struct rpc_clnt *clnt; in rpc_show_tasks() local
3305 list_for_each_entry(clnt, &sn->all_clients, cl_clients) { in rpc_show_tasks()
3306 spin_lock(&clnt->cl_lock); in rpc_show_tasks()
3307 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_show_tasks()
3312 rpc_show_task(clnt, task); in rpc_show_tasks()
3314 spin_unlock(&clnt->cl_lock); in rpc_show_tasks()
3322 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt, in rpc_clnt_swap_activate_callback() argument
3330 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument
3332 while (clnt != clnt->cl_parent) in rpc_clnt_swap_activate()
3333 clnt = clnt->cl_parent; in rpc_clnt_swap_activate()
3334 if (atomic_inc_return(&clnt->cl_swapper) == 1) in rpc_clnt_swap_activate()
3335 return rpc_clnt_iterate_for_each_xprt(clnt, in rpc_clnt_swap_activate()
3342 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt, in rpc_clnt_swap_deactivate_callback() argument
3351 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
3353 while (clnt != clnt->cl_parent) in rpc_clnt_swap_deactivate()
3354 clnt = clnt->cl_parent; in rpc_clnt_swap_deactivate()
3355 if (atomic_dec_if_positive(&clnt->cl_swapper) == 0) in rpc_clnt_swap_deactivate()
3356 rpc_clnt_iterate_for_each_xprt(clnt, in rpc_clnt_swap_deactivate()