Lines Matching refs:rpc_clnt
77 static int rpc_ping(struct rpc_clnt *clnt);
80 static void rpc_register_client(struct rpc_clnt *clnt)
90 static void rpc_unregister_client(struct rpc_clnt *clnt)
100 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)
105 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)
119 struct rpc_clnt *clnt)
149 rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt)
163 static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event)
183 static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event,
206 static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event,
220 static struct rpc_clnt *rpc_get_client_for_event(struct net *net, int event)
223 struct rpc_clnt *clnt;
240 struct rpc_clnt *clnt;
266 static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt,
286 static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename)
292 static int rpc_client_register(struct rpc_clnt *clnt,
344 static int rpc_alloc_clid(struct rpc_clnt *clnt)
355 static void rpc_free_clid(struct rpc_clnt *clnt)
360 static struct rpc_clnt * rpc_new_client(const struct rpc_create_args *args,
363 struct rpc_clnt *parent)
367 struct rpc_clnt *clnt = NULL;
454 static struct rpc_clnt *rpc_create_xprt(struct rpc_create_args *args,
457 struct rpc_clnt *clnt = NULL;
508 * @args: rpc_clnt create argument structure
516 struct rpc_clnt *rpc_create(struct rpc_create_args *args)
529 struct rpc_clnt *clnt;
581 return (struct rpc_clnt *)xprt;
613 static struct rpc_clnt *__rpc_clone_client(struct rpc_create_args *args,
614 struct rpc_clnt *clnt)
618 struct rpc_clnt *new;
660 struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt)
682 struct rpc_clnt *
683 rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor)
699 * @clnt: pointer to a struct rpc_clnt
704 * rpc_clnt structure 'clnt' to allow it to connect to a mirrored NFS
712 int rpc_switch_client_transport(struct rpc_clnt *clnt,
720 struct rpc_clnt *parent;
781 int rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi)
806 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,
807 int (*fn)(struct rpc_clnt *, struct rpc_xprt *, void *),
835 void rpc_killall_tasks(struct rpc_clnt *clnt)
858 void rpc_shutdown_client(struct rpc_clnt *clnt)
879 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work);
895 static struct rpc_clnt *
896 rpc_free_client(struct rpc_clnt *clnt)
898 struct rpc_clnt *parent = NULL;
917 static struct rpc_clnt *
918 rpc_free_auth(struct rpc_clnt *clnt)
940 rpc_release_client(struct rpc_clnt *clnt)
962 struct rpc_clnt *rpc_bind_new_program(struct rpc_clnt *old,
974 struct rpc_clnt *clnt;
991 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
1007 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
1036 struct rpc_clnt *clnt = task->tk_client;
1051 rpc_task_get_first_xprt(struct rpc_clnt *clnt)
1062 rpc_task_get_next_xprt(struct rpc_clnt *clnt)
1068 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)
1079 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)
1157 int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags)
1193 rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags,
1285 size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize)
1312 const char *rpc_peeraddr2str(struct rpc_clnt *clnt,
1450 int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen)
1477 rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize)
1494 struct net *rpc_net_ns(struct rpc_clnt *clnt)
1514 size_t rpc_max_payload(struct rpc_clnt *clnt)
1529 size_t rpc_max_bc_payload(struct rpc_clnt *clnt)
1542 unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt)
1560 void rpc_force_rebind(struct rpc_clnt *clnt)
1640 struct rpc_clnt *clnt = task->tk_client;
2061 struct rpc_clnt *clnt = task->tk_client;
2306 struct rpc_clnt *clnt = task->tk_client;
2381 struct rpc_clnt *clnt = task->tk_client;
2445 struct rpc_clnt *clnt = task->tk_client;
2513 struct rpc_clnt *clnt = task->tk_client;
2542 struct rpc_clnt *clnt = task->tk_client;
2680 static int rpc_ping(struct rpc_clnt *clnt)
2692 struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt,
2713 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags)
2747 * rpc_clnt_test_and_add_xprt - Test and add a new transport to a rpc_clnt
2748 * @clnt: pointer to struct rpc_clnt
2753 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,
2789 * transport to the rpc_clnt xprt switch
2791 * @clnt: struct rpc_clnt to get the new transport
2797 int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt,
2842 * rpc_clnt_add_xprt - Add a new transport to a rpc_clnt
2843 * @clnt: pointer to struct rpc_clnt
2854 int rpc_clnt_add_xprt(struct rpc_clnt *clnt,
2856 int (*setup)(struct rpc_clnt *,
2916 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt,
2930 rpc_set_connect_timeout(struct rpc_clnt *clnt,
2944 void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt)
2952 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
2961 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt,
2982 static void rpc_show_task(const struct rpc_clnt *clnt,
2999 struct rpc_clnt *clnt;
3022 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt,
3030 rpc_clnt_swap_activate(struct rpc_clnt *clnt)
3042 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt,
3051 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt)