Lines Matching refs:rpc_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)
92 static void rpc_unregister_client(struct rpc_clnt *clnt)
102 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)
107 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt)
121 struct rpc_clnt *clnt)
151 rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt)
165 static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event)
185 static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event,
208 static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event,
222 static struct rpc_clnt *rpc_get_client_for_event(struct net *net, int event)
225 struct rpc_clnt *clnt;
242 struct rpc_clnt *clnt;
268 static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt,
288 static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename)
294 static int rpc_client_register(struct rpc_clnt *clnt,
347 static int rpc_alloc_clid(struct rpc_clnt *clnt)
358 static void rpc_free_clid(struct rpc_clnt *clnt)
363 static struct rpc_clnt * rpc_new_client(const struct rpc_create_args *args,
366 struct rpc_clnt *parent)
370 struct rpc_clnt *clnt = NULL;
460 static struct rpc_clnt *rpc_create_xprt(struct rpc_create_args *args,
463 struct rpc_clnt *clnt = NULL;
520 * @args: rpc_clnt create argument structure
528 struct rpc_clnt *rpc_create(struct rpc_create_args *args)
544 struct rpc_clnt *clnt;
600 return (struct rpc_clnt *)xprt;
632 static struct rpc_clnt *__rpc_clone_client(struct rpc_create_args *args,
633 struct rpc_clnt *clnt)
637 struct rpc_clnt *new;
680 struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt)
701 struct rpc_clnt *
702 rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor)
717 * @clnt: pointer to a struct rpc_clnt
722 * rpc_clnt structure 'clnt' to allow it to connect to a mirrored NFS
730 int rpc_switch_client_transport(struct rpc_clnt *clnt,
738 struct rpc_clnt *parent;
801 int _rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi,
817 int rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi)
823 int rpc_clnt_xprt_iter_offline_init(struct rpc_clnt *clnt,
840 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,
841 int (*fn)(struct rpc_clnt *, struct rpc_xprt *, void *),
869 void rpc_killall_tasks(struct rpc_clnt *clnt)
898 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error,
925 static int rpc_clnt_disconnect_xprt(struct rpc_clnt *clnt,
933 void rpc_clnt_disconnect(struct rpc_clnt *clnt)
943 void rpc_shutdown_client(struct rpc_clnt *clnt)
964 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work);
981 static struct rpc_clnt *
982 rpc_free_client(struct rpc_clnt *clnt)
984 struct rpc_clnt *parent = NULL;
1003 static struct rpc_clnt *
1004 rpc_free_auth(struct rpc_clnt *clnt)
1024 rpc_release_client(struct rpc_clnt *clnt)
1046 struct rpc_clnt *rpc_bind_new_program(struct rpc_clnt *old,
1057 struct rpc_clnt *clnt;
1074 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
1090 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
1119 struct rpc_clnt *clnt = task->tk_client;
1134 rpc_task_get_first_xprt(struct rpc_clnt *clnt)
1145 rpc_task_get_next_xprt(struct rpc_clnt *clnt)
1151 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)
1167 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)
1242 int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags)
1278 rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags,
1372 size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize)
1399 const char *rpc_peeraddr2str(struct rpc_clnt *clnt,
1537 int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen)
1564 rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize)
1581 struct net *rpc_net_ns(struct rpc_clnt *clnt)
1601 size_t rpc_max_payload(struct rpc_clnt *clnt)
1616 size_t rpc_max_bc_payload(struct rpc_clnt *clnt)
1629 unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt)
1647 void rpc_force_rebind(struct rpc_clnt *clnt)
1727 struct rpc_clnt *clnt = task->tk_client;
2155 struct rpc_clnt *clnt = task->tk_client;
2425 struct rpc_clnt *clnt = task->tk_client;
2500 struct rpc_clnt *clnt = task->tk_client;
2562 struct rpc_clnt *clnt = task->tk_client;
2631 struct rpc_clnt *clnt = task->tk_client;
2660 struct rpc_clnt *clnt = task->tk_client;
2823 struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt,
2844 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags)
2850 static int rpc_ping(struct rpc_clnt *clnt)
2866 static int rpc_ping_noreply(struct rpc_clnt *clnt)
2917 * rpc_clnt_test_and_add_xprt - Test and add a new transport to a rpc_clnt
2918 * @clnt: pointer to struct rpc_clnt
2923 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,
2964 static int rpc_clnt_add_xprt_helper(struct rpc_clnt *clnt,
2998 * transport to the rpc_clnt xprt switch
3000 * @clnt: struct rpc_clnt to get the new transport
3006 int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt,
3037 * rpc_clnt_add_xprt - Add a new transport to a rpc_clnt
3038 * @clnt: pointer to struct rpc_clnt
3049 int rpc_clnt_add_xprt(struct rpc_clnt *clnt,
3051 int (*setup)(struct rpc_clnt *,
3114 static int rpc_xprt_probe_trunked(struct rpc_clnt *clnt,
3142 * @clnt rpc_clnt structure
3144 * For each offlined transport found in the rpc_clnt structure call
3148 void rpc_clnt_probe_trunked_xprts(struct rpc_clnt *clnt,
3172 static int rpc_xprt_offline(struct rpc_clnt *clnt,
3206 * @clnt rpc_clnt structure
3208 * For each active transport found in the rpc_clnt structure call
3212 void rpc_clnt_manage_trunked_xprts(struct rpc_clnt *clnt)
3224 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt,
3238 rpc_set_connect_timeout(struct rpc_clnt *clnt,
3252 void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt)
3260 void rpc_clnt_xprt_set_online(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
3270 void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
3283 void rpc_clnt_xprt_switch_remove_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt)
3296 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt,
3317 static void rpc_show_task(const struct rpc_clnt *clnt,
3334 struct rpc_clnt *clnt;
3357 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt,
3365 rpc_clnt_swap_activate(struct rpc_clnt *clnt)
3377 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt,
3386 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt)