Lines Matching refs:rpc_clnt
78 static int rpc_ping(struct rpc_clnt *clnt);
81 static void rpc_register_client(struct rpc_clnt *clnt) in rpc_register_client()
91 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client()
101 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in __rpc_clnt_remove_pipedir()
106 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in rpc_clnt_remove_pipedir()
119 struct rpc_clnt *clnt) in rpc_setup_pipedir_sb()
149 rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt) in rpc_setup_pipedir()
161 static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event) in rpc_clnt_skip_event()
181 static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event, in __rpc_clnt_handle_event()
204 static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event, in __rpc_pipefs_event()
218 static struct rpc_clnt *rpc_get_client_for_event(struct net *net, int event) in rpc_get_client_for_event()
221 struct rpc_clnt *clnt; in rpc_get_client_for_event()
238 struct rpc_clnt *clnt; in rpc_pipefs_event()
264 static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt, in rpc_clnt_set_transport()
284 static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename) in rpc_clnt_set_nodename()
290 static int rpc_client_register(struct rpc_clnt *clnt, in rpc_client_register()
343 static int rpc_alloc_clid(struct rpc_clnt *clnt) in rpc_alloc_clid()
354 static void rpc_free_clid(struct rpc_clnt *clnt) in rpc_free_clid()
359 static struct rpc_clnt * rpc_new_client(const struct rpc_create_args *args, in rpc_new_client()
362 struct rpc_clnt *parent) in rpc_new_client()
366 struct rpc_clnt *clnt = NULL; in rpc_new_client()
455 static struct rpc_clnt *rpc_create_xprt(struct rpc_create_args *args, in rpc_create_xprt()
458 struct rpc_clnt *clnt = NULL; in rpc_create_xprt()
517 struct rpc_clnt *rpc_create(struct rpc_create_args *args) in rpc_create()
530 struct rpc_clnt *clnt; in rpc_create()
582 return (struct rpc_clnt *)xprt; in rpc_create()
614 static struct rpc_clnt *__rpc_clone_client(struct rpc_create_args *args, in __rpc_clone_client()
615 struct rpc_clnt *clnt) in __rpc_clone_client()
619 struct rpc_clnt *new; in __rpc_clone_client()
661 struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt) in rpc_clone_client()
682 struct rpc_clnt *
683 rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor) in rpc_clone_client_set_auth()
711 int rpc_switch_client_transport(struct rpc_clnt *clnt, in rpc_switch_client_transport()
719 struct rpc_clnt *parent; 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()
806 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, in rpc_clnt_iterate_for_each_xprt()
807 int (*fn)(struct rpc_clnt *, struct rpc_xprt *, void *), in rpc_clnt_iterate_for_each_xprt() argument
835 void rpc_killall_tasks(struct rpc_clnt *clnt) in rpc_killall_tasks()
858 void rpc_shutdown_client(struct rpc_clnt *clnt) in rpc_shutdown_client()
879 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work); in rpc_free_client_work()
896 static struct rpc_clnt *
897 rpc_free_client(struct rpc_clnt *clnt) in rpc_free_client()
899 struct rpc_clnt *parent = NULL; in rpc_free_client()
918 static struct rpc_clnt *
919 rpc_free_auth(struct rpc_clnt *clnt) in rpc_free_auth()
939 rpc_release_client(struct rpc_clnt *clnt) in rpc_release_client()
961 struct rpc_clnt *rpc_bind_new_program(struct rpc_clnt *old, in rpc_bind_new_program()
972 struct rpc_clnt *clnt; in rpc_bind_new_program()
989 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_get_xprt()
1005 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_task_release_xprt()
1034 struct rpc_clnt *clnt = task->tk_client; in rpc_task_release_client()
1049 rpc_task_get_first_xprt(struct rpc_clnt *clnt) in rpc_task_get_first_xprt()
1060 rpc_task_get_next_xprt(struct rpc_clnt *clnt) 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()
1077 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_client()
1152 int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags) in rpc_call_sync()
1188 rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags, in rpc_call_async()
1277 size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize) in rpc_peeraddr()
1304 const char *rpc_peeraddr2str(struct rpc_clnt *clnt, in rpc_peeraddr2str()
1442 int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen) in rpc_localaddr()
1469 rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize) in rpc_setbufsize()
1486 struct net *rpc_net_ns(struct rpc_clnt *clnt) in rpc_net_ns()
1506 size_t rpc_max_payload(struct rpc_clnt *clnt) in rpc_max_payload()
1521 size_t rpc_max_bc_payload(struct rpc_clnt *clnt) in rpc_max_bc_payload()
1534 unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt) in rpc_num_bc_slots()
1552 void rpc_force_rebind(struct rpc_clnt *clnt) in rpc_force_rebind()
1632 struct rpc_clnt *clnt = task->tk_client; in call_start()
2056 struct rpc_clnt *clnt = task->tk_client; in call_connect_status()
2323 struct rpc_clnt *clnt = task->tk_client; in call_status()
2394 struct rpc_clnt *clnt = task->tk_client; in rpc_check_timeout()
2458 struct rpc_clnt *clnt = task->tk_client; in call_decode()
2526 struct rpc_clnt *clnt = task->tk_client; in rpc_encode_header()
2555 struct rpc_clnt *clnt = task->tk_client; in rpc_decode_header()
2705 struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt, in rpc_call_null_helper()
2726 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags) in rpc_call_null()
2732 static int rpc_ping(struct rpc_clnt *clnt) in rpc_ping()
2780 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_test_and_add_xprt()
2833 int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_setup_test_and_add_xprt()
2890 int rpc_clnt_add_xprt(struct rpc_clnt *clnt, in rpc_clnt_add_xprt()
2892 int (*setup)(struct rpc_clnt *, in rpc_clnt_add_xprt() argument
2952 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt, in rpc_xprt_set_connect_timeout()
2966 rpc_set_connect_timeout(struct rpc_clnt *clnt, in rpc_set_connect_timeout()
2980 void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt) in rpc_clnt_xprt_switch_put()
2988 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) in rpc_clnt_xprt_switch_add_xprt()
2997 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt, in rpc_clnt_xprt_switch_has_addr()
3018 static void rpc_show_task(const struct rpc_clnt *clnt, in rpc_show_task()
3035 struct rpc_clnt *clnt; in rpc_show_tasks()
3058 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt, in rpc_clnt_swap_activate_callback()
3066 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate()
3076 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt, in rpc_clnt_swap_deactivate_callback()
3085 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate()