Home
last modified time | relevance | path

Searched refs:clnt (Results 1 – 25 of 61) sorted by relevance

123

/linux/net/sunrpc/
H A Dclnt.c3 * linux/net/sunrpc/clnt.c
36 #include <linux/sunrpc/clnt.h>
73 static int rpc_ping(struct rpc_clnt *clnt);
74 static int rpc_ping_noreply(struct rpc_clnt *clnt);
77 static void rpc_register_client(struct rpc_clnt *clnt) in rpc_register_client() argument
79 struct net *net = rpc_net_ns(clnt); in rpc_register_client()
83 list_add(&clnt->cl_clients, &sn->all_clients); in rpc_register_client()
87 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client() argument
89 struct net *net = rpc_net_ns(clnt); in rpc_unregister_client()
93 list_del(&clnt in rpc_unregister_client()
97 __rpc_clnt_remove_pipedir(struct rpc_clnt * clnt) __rpc_clnt_remove_pipedir() argument
102 rpc_clnt_remove_pipedir(struct rpc_clnt * clnt) rpc_clnt_remove_pipedir() argument
116 rpc_setup_pipedir_sb(struct super_block * sb,struct rpc_clnt * clnt) rpc_setup_pipedir_sb() argument
146 rpc_setup_pipedir(struct super_block * pipefs_sb,struct rpc_clnt * clnt) rpc_setup_pipedir() argument
160 rpc_clnt_skip_event(struct rpc_clnt * clnt,unsigned long event) rpc_clnt_skip_event() argument
180 __rpc_clnt_handle_event(struct rpc_clnt * clnt,unsigned long event,struct super_block * sb) __rpc_clnt_handle_event() argument
203 __rpc_pipefs_event(struct rpc_clnt * clnt,unsigned long event,struct super_block * sb) __rpc_pipefs_event() argument
220 struct rpc_clnt *clnt; rpc_get_client_for_event() local
237 struct rpc_clnt *clnt; rpc_pipefs_event() local
263 rpc_clnt_set_transport(struct rpc_clnt * clnt,struct rpc_xprt * xprt,const struct rpc_timeout * timeout) rpc_clnt_set_transport() argument
283 rpc_clnt_set_nodename(struct rpc_clnt * clnt,const char * nodename) rpc_clnt_set_nodename() argument
295 rpc_client_register(struct rpc_clnt * clnt,rpc_authflavor_t pseudoflavor,const char * client_name) rpc_client_register() argument
348 rpc_alloc_clid(struct rpc_clnt * clnt) rpc_alloc_clid() argument
359 rpc_free_clid(struct rpc_clnt * clnt) rpc_free_clid() argument
371 struct rpc_clnt *clnt = NULL; rpc_new_client() local
464 struct rpc_clnt *clnt = NULL; rpc_create_xprt() local
545 struct rpc_clnt *clnt; rpc_create() local
634 __rpc_clone_client(struct rpc_create_args * args,struct rpc_clnt * clnt) __rpc_clone_client() argument
681 rpc_clone_client(struct rpc_clnt * clnt) rpc_clone_client() argument
704 rpc_clone_client_set_auth(struct rpc_clnt * clnt,rpc_authflavor_t flavor) rpc_clone_client_set_auth() argument
733 rpc_switch_client_transport(struct rpc_clnt * clnt,struct xprt_create * args,const struct rpc_timeout * timeout) rpc_switch_client_transport() argument
803 rpc_clnt_xprt_switch_get(struct rpc_clnt * clnt) rpc_clnt_xprt_switch_get() argument
815 _rpc_clnt_xprt_iter_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi,void func (struct rpc_xprt_iter * xpi,struct rpc_xprt_switch * xps)) _rpc_clnt_xprt_iter_init() argument
829 rpc_clnt_xprt_iter_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi) rpc_clnt_xprt_iter_init() argument
835 rpc_clnt_xprt_iter_offline_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi) rpc_clnt_xprt_iter_offline_init() argument
852 rpc_clnt_iterate_for_each_xprt(struct rpc_clnt * clnt,int (* fn)(struct rpc_clnt *,struct rpc_xprt *,void *),void * data) rpc_clnt_iterate_for_each_xprt() argument
881 rpc_killall_tasks(struct rpc_clnt * clnt) rpc_killall_tasks() argument
910 rpc_cancel_tasks(struct rpc_clnt * clnt,int error,bool (* fnmatch)(const struct rpc_task *,const void *),const void * data) rpc_cancel_tasks() argument
937 rpc_clnt_disconnect_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_disconnect_xprt() argument
945 rpc_clnt_disconnect(struct rpc_clnt * clnt) rpc_clnt_disconnect() argument
955 rpc_shutdown_client(struct rpc_clnt * clnt) rpc_shutdown_client() argument
976 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work); rpc_free_client_work() local
994 rpc_free_client(struct rpc_clnt * clnt) rpc_free_client() argument
1016 rpc_free_auth(struct rpc_clnt * clnt) rpc_free_auth() argument
1036 rpc_release_client(struct rpc_clnt * clnt) rpc_release_client() argument
1071 struct rpc_clnt *clnt; rpc_bind_new_program() local
1088 rpc_task_get_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_task_get_xprt() argument
1104 rpc_task_release_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_task_release_xprt() argument
1133 struct rpc_clnt *clnt = task->tk_client; rpc_task_release_client() local
1148 rpc_task_get_first_xprt(struct rpc_clnt * clnt) rpc_task_get_first_xprt() argument
1159 rpc_task_get_next_xprt(struct rpc_clnt * clnt) rpc_task_get_next_xprt() argument
1165 rpc_task_set_transport(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_transport() argument
1181 rpc_task_set_client(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_client() argument
1256 rpc_call_sync(struct rpc_clnt * clnt,const struct rpc_message * msg,int flags) rpc_call_sync() argument
1292 rpc_call_async(struct rpc_clnt * clnt,const struct rpc_message * msg,int flags,const struct rpc_call_ops * tk_ops,void * data) rpc_call_async() argument
1388 rpc_peeraddr(struct rpc_clnt * clnt,struct sockaddr * buf,size_t bufsize) rpc_peeraddr() argument
1415 rpc_peeraddr2str(struct rpc_clnt * clnt,enum rpc_display_format_t format) rpc_peeraddr2str() argument
1553 rpc_localaddr(struct rpc_clnt * clnt,struct sockaddr * buf,size_t buflen) rpc_localaddr() argument
1580 rpc_setbufsize(struct rpc_clnt * clnt,unsigned int sndsize,unsigned int rcvsize) rpc_setbufsize() argument
1597 rpc_net_ns(struct rpc_clnt * clnt) rpc_net_ns() argument
1617 rpc_max_payload(struct rpc_clnt * clnt) rpc_max_payload() argument
1632 rpc_max_bc_payload(struct rpc_clnt * clnt) rpc_max_bc_payload() argument
1645 rpc_num_bc_slots(struct rpc_clnt * clnt) rpc_num_bc_slots() argument
1663 rpc_force_rebind(struct rpc_clnt * clnt) rpc_force_rebind() argument
1743 struct rpc_clnt *clnt = task->tk_client; call_start() local
2165 struct rpc_clnt *clnt = task->tk_client; call_connect_status() local
2435 struct rpc_clnt *clnt = task->tk_client; call_status() local
2510 struct rpc_clnt *clnt = task->tk_client; rpc_check_timeout() local
2572 struct rpc_clnt *clnt = task->tk_client; call_decode() local
2641 struct rpc_clnt *clnt = task->tk_client; rpc_encode_header() local
2670 struct rpc_clnt *clnt = task->tk_client; rpc_decode_header() local
2844 rpc_call_null_helper(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_cred * cred,int flags,const struct rpc_call_ops * ops,void * data) rpc_call_null_helper() argument
2865 rpc_call_null(struct rpc_clnt * clnt,struct rpc_cred * cred,int flags) rpc_call_null() argument
2871 rpc_ping(struct rpc_clnt * clnt) rpc_ping() argument
2887 rpc_ping_noreply(struct rpc_clnt * clnt) rpc_ping_noreply() argument
2944 rpc_clnt_test_and_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt_switch * xps,struct rpc_xprt * xprt,void * in_max_connect) rpc_clnt_test_and_add_xprt() argument
2985 rpc_clnt_add_xprt_helper(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_add_xprt_test * data) rpc_clnt_add_xprt_helper() argument
3027 rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt_switch * xps,struct rpc_xprt * xprt,void * data) rpc_clnt_setup_test_and_add_xprt() argument
3070 rpc_clnt_add_xprt(struct rpc_clnt * clnt,struct xprt_create * xprtargs,int (* setup)(struct rpc_clnt *,struct rpc_xprt_switch *,struct rpc_xprt *,void *),void * data) rpc_clnt_add_xprt() argument
3135 rpc_xprt_probe_trunked(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_add_xprt_test * data) rpc_xprt_probe_trunked() argument
3166 rpc_clnt_probe_trunked_xprts(struct rpc_clnt * clnt,struct rpc_add_xprt_test * data) rpc_clnt_probe_trunked_xprts() argument
3190 rpc_xprt_offline(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * data) rpc_xprt_offline() argument
3230 rpc_clnt_manage_trunked_xprts(struct rpc_clnt * clnt) rpc_clnt_manage_trunked_xprts() argument
3242 rpc_xprt_set_connect_timeout(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * data) rpc_xprt_set_connect_timeout() argument
3256 rpc_set_connect_timeout(struct rpc_clnt * clnt,unsigned long connect_timeout,unsigned long reconnect_timeout) rpc_set_connect_timeout() argument
3270 rpc_clnt_xprt_set_online(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_set_online() argument
3279 rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_switch_add_xprt() argument
3294 rpc_clnt_xprt_switch_remove_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_switch_remove_xprt() argument
3307 rpc_clnt_xprt_switch_has_addr(struct rpc_clnt * clnt,const struct sockaddr * sap) rpc_clnt_xprt_switch_has_addr() argument
3328 rpc_show_task(const struct rpc_clnt * clnt,const struct rpc_task * task) rpc_show_task() argument
3345 struct rpc_clnt *clnt; rpc_show_tasks() local
3368 rpc_clnt_swap_activate_callback(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_swap_activate_callback() argument
3376 rpc_clnt_swap_activate(struct rpc_clnt * clnt) rpc_clnt_swap_activate() argument
3388 rpc_clnt_swap_deactivate_callback(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_swap_deactivate_callback() argument
3397 rpc_clnt_swap_deactivate(struct rpc_clnt * clnt) rpc_clnt_swap_deactivate() argument
[all...]
H A Ddebugfs.c10 #include <linux/sunrpc/clnt.h>
24 struct rpc_clnt *clnt = task->tk_client; in tasks_show() local
35 clnt->cl_clid, xid, rpc_task_timeout(task), task->tk_ops, in tasks_show()
36 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in tasks_show()
43 __acquires(&clnt->cl_lock) in tasks_start()
45 struct rpc_clnt *clnt = f->private; in tasks_start() local
49 spin_lock(&clnt->cl_lock); in tasks_start()
50 list_for_each_entry(task, &clnt->cl_tasks, tk_task) in tasks_start()
59 struct rpc_clnt *clnt in tasks_next() local
75 struct rpc_clnt *clnt = f->private; tasks_stop() local
91 struct rpc_clnt *clnt = seq->private = inode->i_private; tasks_open() local
106 struct rpc_clnt *clnt = seq->private; tasks_release() local
120 do_xprt_debugfs(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * numv) do_xprt_debugfs() argument
146 rpc_clnt_debugfs_register(struct rpc_clnt * clnt) rpc_clnt_debugfs_register() argument
167 rpc_clnt_debugfs_unregister(struct rpc_clnt * clnt) rpc_clnt_debugfs_unregister() argument
[all...]
H A Drpcb_clnt.c181 struct rpc_clnt *clnt = sn->rpcb_local_clnt; in rpcb_put_local() local
201 if (clnt) in rpcb_put_local()
202 rpc_shutdown_client(clnt); in rpcb_put_local()
206 static void rpcb_set_local(struct net *net, struct rpc_clnt *clnt, in rpcb_set_local() argument
213 sn->rpcb_local_clnt = clnt; in rpcb_set_local()
250 struct rpc_clnt *clnt, *clnt4; in rpcb_create_af_local() local
258 clnt = rpc_create(&args); in rpcb_create_af_local()
259 if (IS_ERR(clnt)) { in rpcb_create_af_local()
260 result = PTR_ERR(clnt); in rpcb_create_af_local()
264 clnt4 = rpc_bind_new_program(clnt, &rpcb_program, RPCBVERS_4); in rpcb_create_af_local()
[all …]
H A Dstats.c124 struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) in rpc_alloc_iostats() argument
129 stats = kcalloc(clnt->cl_maxproc, sizeof(*stats), GFP_KERNEL); in rpc_alloc_iostats()
131 for (i = 0; i < clnt->cl_maxproc; i++) in rpc_alloc_iostats()
247 static int do_print_stats(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *seqv) in do_print_stats() argument
255 void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) in rpc_clnt_show_stats() argument
257 unsigned int op, maxproc = clnt->cl_maxproc; in rpc_clnt_show_stats()
259 if (!clnt->cl_metrics) in rpc_clnt_show_stats()
264 clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); in rpc_clnt_show_stats()
266 rpc_clnt_iterate_for_each_xprt(clnt, do_print_stats, seq); in rpc_clnt_show_stats()
271 struct rpc_clnt *next = clnt; in rpc_clnt_show_stats()
[all …]
H A Dauth_unix.c29 unx_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in unx_create() argument
113 struct rpc_clnt *clnt = task->tk_client; in unx_marshal() local
118 struct user_namespace *userns = clnt->cl_cred ? in unx_marshal()
119 clnt->cl_cred->user_ns : &init_user_ns; in unx_marshal()
129 if (xdr_stream_encode_opaque(xdr, clnt->cl_nodename, in unx_marshal()
130 clnt->cl_nodelen) < 0) in unx_marshal()
H A Dsvcauth.c186 void svcauth_map_clnt_to_svc_cred_local(struct rpc_clnt *clnt, in svcauth_map_clnt_to_svc_cred_local() argument
190 struct user_namespace *userns = clnt->cl_cred ? in svcauth_map_clnt_to_svc_cred_local()
191 clnt->cl_cred->user_ns : &init_user_ns; in svcauth_map_clnt_to_svc_cred_local()
197 svc->cr_flavor = clnt->cl_auth->au_flavor; in svcauth_map_clnt_to_svc_cred_local()
H A Dsysfs.h24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt,
27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
H A Dauth_tls.c50 static int tls_probe(struct rpc_clnt *clnt) in tls_probe() argument
56 .rpc_client = clnt, in tls_probe()
74 struct rpc_clnt *clnt) in tls_create() argument
H A Dsysfs.c517 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, in rpc_sysfs_client_setup() argument
529 net, clnt->cl_clid); in rpc_sysfs_client_setup()
534 clnt->cl_sysfs = rpc_client; in rpc_sysfs_client_setup()
535 rpc_client->clnt = clnt; in rpc_sysfs_client_setup()
590 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) in rpc_sysfs_client_destroy() argument
592 struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; in rpc_sysfs_client_destroy()
601 clnt->cl_sysfs = NULL; in rpc_sysfs_client_destroy()
/linux/net/9p/
H A Dclient.c58 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
60 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
64 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
66 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
70 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument
72 if (clnt->msize != DEFAULT_MSIZE) in p9_show_client_options()
73 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options()
74 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options()
76 switch (clnt->proto_version) { in p9_show_client_options()
88 if (clnt->trans_mod->show_options) in p9_show_client_options()
[all …]
H A Dprotocol.c720 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
730 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
733 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
747 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
756 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
769 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
781 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
785 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
/linux/include/trace/events/
H A D9p.h125 TP_PROTO(struct p9_client *clnt, int8_t type, int tag),
127 TP_ARGS(clnt, type, tag),
130 __field( void *, clnt )
136 __entry->clnt = clnt;
142 (long)__entry->clnt, show_9p_op(__entry->type),
147 TP_PROTO(struct p9_client *clnt, int8_t type, int tag, int err),
149 TP_ARGS(clnt, type, tag, err),
152 __field( void *, clnt )
159 __entry->clnt = clnt;
166 (long)__entry->clnt, show_9p_op(__entry->type),
[all …]
/linux/net/sunrpc/auth_gss/
H A Dgss_rpc_upcall.c104 struct rpc_clnt *clnt; in gssp_rpc_create() local
107 clnt = rpc_create(&args); in gssp_rpc_create()
108 if (IS_ERR(clnt)) { in gssp_rpc_create()
110 "client (errno %ld).\n", PTR_ERR(clnt)); in gssp_rpc_create()
111 result = PTR_ERR(clnt); in gssp_rpc_create()
117 "%p)\n", clnt); in gssp_rpc_create()
118 *_clnt = clnt; in gssp_rpc_create()
133 struct rpc_clnt *clnt; in set_gssp_clnt() local
137 ret = gssp_rpc_create(net, &clnt); in set_gssp_clnt()
141 sn->gssp_clnt = clnt; in set_gssp_clnt()
[all …]
H A Dauth_gss.c20 #include <linux/sunrpc/clnt.h>
79 struct rpc_clnt *clnt; member
904 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
916 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument
932 p->clnt = clnt; in gss_pipe_alloc()
945 struct rpc_clnt *clnt; member
970 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo()
976 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument
980 struct net *net = rpc_net_ns(clnt); in gss_pipe_get()
1000 struct rpc_clnt *clnt = p->clnt; __gss_pipe_free() local
1028 gss_create_new(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create_new() argument
1174 gss_auth_find_or_add_hashed(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt,struct gss_auth * new) gss_auth_find_or_add_hashed() argument
1211 gss_create_hashed(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create_hashed() argument
1230 gss_create(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create() argument
[all...]
/linux/include/linux/sunrpc/
H A Dclnt.h3 * linux/include/linux/sunrpc/clnt.h
36 struct rpc_clnt *clnt; member
159 void (*add_xprt_test)(struct rpc_clnt *clnt,
193 struct rpc_xprt *rpc_task_get_xprt(struct rpc_clnt *clnt,
209 int rpc_call_async(struct rpc_clnt *clnt,
213 int rpc_call_sync(struct rpc_clnt *clnt,
215 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
229 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,
233 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,
243 void rpc_set_connect_timeout(struct rpc_clnt *clnt,
[all...]
H A Dsched.h231 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error,
304 int rpc_clnt_swap_activate(struct rpc_clnt *clnt);
305 void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt);
308 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument
314 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
H A Dmetrics.h95 static inline struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) { return NULL; } in rpc_alloc_iostats() argument
103 static inline void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) {} in rpc_clnt_show_stats() argument
/linux/include/net/9p/
H A Dclient.h149 struct p9_client *clnt; member
180 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt);
187 void p9_client_destroy(struct p9_client *clnt);
188 void p9_client_disconnect(struct p9_client *clnt);
189 void p9_client_begin_disconnect(struct p9_client *clnt);
190 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
213 int p9dirent_read(struct p9_client *clnt, char *buf, int len,
287 int p9stat_read(struct p9_client *clnt, char *buf, int len,
291 int p9_is_proto_dotu(struct p9_client *clnt);
292 int p9_is_proto_dotl(struct p9_client *clnt);
/linux/fs/9p/
H A Dv9fs.c152 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options()
410 v9ses->clnt = p9_client_create(dev_name, data); in v9fs_session_init()
411 if (IS_ERR(v9ses->clnt)) { in v9fs_session_init()
412 rc = PTR_ERR(v9ses->clnt); in v9fs_session_init()
419 if (p9_is_proto_dotl(v9ses->clnt)) { in v9fs_session_init()
422 } else if (p9_is_proto_dotu(v9ses->clnt)) { in v9fs_session_init()
430 v9ses->maxdata = v9ses->clnt->msize - P9_IOHDRSZ; in v9fs_session_init()
459 fid = p9_client_attach(v9ses->clnt, NULL, v9ses->uname, INVALID_UID, in v9fs_session_init()
490 p9_client_destroy(v9ses->clnt); in v9fs_session_init()
505 if (v9ses->clnt) { in v9fs_session_close()
[all …]
H A Dvfs_dir.c97 buflen = fid->clnt->msize - P9_IOHDRSZ; in v9fs_dir_readdir()
122 err = p9stat_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir()
158 buflen = fid->clnt->msize - P9_READDIRHDRSZ; in v9fs_dir_readdir_dotl()
177 err = p9dirent_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir_dotl()
H A Dvfs_file.c155 flock.client_id = fid->clnt->name; in v9fs_file_do_lock()
181 if (flock.client_id != fid->clnt->name) { in v9fs_file_do_lock()
183 flock.client_id = fid->clnt->name; in v9fs_file_do_lock()
217 if (flock.client_id != fid->clnt->name) in v9fs_file_do_lock()
249 glock.client_id = fid->clnt->name; in v9fs_file_getlock()
275 if (glock.client_id != fid->clnt->name) in v9fs_file_getlock()
/linux/fs/lockd/
H A Dmon.c95 struct rpc_clnt *clnt; in nsm_mon_unmon() local
111 clnt = nsm_create(host->net, host->nodename); in nsm_mon_unmon()
112 if (IS_ERR(clnt)) { in nsm_mon_unmon()
114 "status=%ld, net=%x\n", PTR_ERR(clnt), in nsm_mon_unmon()
116 return PTR_ERR(clnt); in nsm_mon_unmon()
119 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nsm_mon_unmon()
120 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon()
124 rpc_force_rebind(clnt); in nsm_mon_unmon()
125 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon()
133 rpc_shutdown_client(clnt); in nsm_mon_unmon()
H A Dhost.c179 struct rpc_clnt *clnt; in nlm_destroy_host_locked() local
189 clnt = host->h_rpcclnt; in nlm_destroy_host_locked()
190 if (clnt != NULL) in nlm_destroy_host_locked()
191 rpc_shutdown_client(clnt); in nlm_destroy_host_locked()
429 struct rpc_clnt *clnt; in nlm_bind_host() local
440 if ((clnt = host->h_rpcclnt) != NULL) { in nlm_bind_host()
478 clnt = rpc_create(&args); in nlm_bind_host()
479 if (!IS_ERR(clnt)) in nlm_bind_host()
480 host->h_rpcclnt = clnt; in nlm_bind_host()
483 clnt = NULL; in nlm_bind_host()
[all …]
/linux/fs/nfs/
H A Dmount_clnt.c256 struct rpc_clnt *clnt; in nfs_umount() local
265 clnt = rpc_create(&args); in nfs_umount()
266 if (IS_ERR(clnt)) in nfs_umount()
273 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount()
275 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount()
277 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount()
278 rpc_shutdown_client(clnt); in nfs_umount()
287 PTR_ERR(clnt)); in nfs_umount()
H A Dsysfs.c225 static void shutdown_client(struct rpc_clnt *clnt) in shutdown_client() argument
227 clnt->cl_shutdown = 1; in shutdown_client()
228 rpc_cancel_tasks(clnt, -EIO, shutdown_match_client, NULL); in shutdown_client()
278 struct rpc_clnt *clnt, const char *uniq) in nfs_sysfs_link_rpc_client() argument
283 strscpy(name, clnt->cl_program->name, sizeof(name)); in nfs_sysfs_link_rpc_client()
288 &clnt->cl_sysfs->kobject, name); in nfs_sysfs_link_rpc_client()

123