| /net/sunrpc/ |
| D | clnt.c | 81 static int rpc_ping(struct rpc_clnt *clnt);
83 static void rpc_register_client(struct rpc_clnt *clnt) in rpc_register_client() argument
85 struct net *net = rpc_net_ns(clnt); in rpc_register_client()
89 list_add(&clnt->cl_clients, &sn->all_clients); in rpc_register_client()
93 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client() argument
95 struct net *net = rpc_net_ns(clnt); in rpc_unregister_client()
99 list_del(&clnt->cl_clients); in rpc_unregister_client()
103 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in __rpc_clnt_remove_pipedir() argument
105 rpc_remove_client_dir(clnt); in __rpc_clnt_remove_pipedir()
108 static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in rpc_clnt_remove_pipedir() argument
[all …]
|
| D | debugfs.c | 20 struct rpc_clnt *clnt; member
29 struct rpc_clnt *clnt = task->tk_client; in tasks_show() local
40 clnt->cl_clid, xid, task->tk_timeout, task->tk_ops, in tasks_show()
41 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in tasks_show()
48 __acquires(&clnt->cl_lock) in tasks_start()
52 struct rpc_clnt *clnt = iter->clnt; in tasks_start() local
56 spin_lock(&clnt->cl_lock); in tasks_start()
57 list_for_each_entry(task, &clnt->cl_tasks, tk_task) in tasks_start()
67 struct rpc_clnt *clnt = iter->clnt; in tasks_next() local
75 if (next == &clnt->cl_tasks) in tasks_next()
[all …]
|
| D | rpcb_clnt.c | 181 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()
252 struct rpc_clnt *clnt, *clnt4; in rpcb_create_local_unix() local
260 clnt = rpc_create(&args); in rpcb_create_local_unix()
261 if (IS_ERR(clnt)) { in rpcb_create_local_unix()
263 "client (errno %ld).\n", PTR_ERR(clnt)); in rpcb_create_local_unix()
264 result = PTR_ERR(clnt); in rpcb_create_local_unix()
[all …]
|
| D | stats.c | 117 struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) in rpc_alloc_iostats() argument
122 stats = kcalloc(clnt->cl_maxproc, sizeof(*stats), GFP_KERNEL); in rpc_alloc_iostats()
124 for (i = 0; i < clnt->cl_maxproc; i++) in rpc_alloc_iostats()
203 void rpc_print_iostats(struct seq_file *seq, struct rpc_clnt *clnt) in rpc_print_iostats() argument
205 struct rpc_iostats *stats = clnt->cl_metrics; in rpc_print_iostats()
207 unsigned int op, maxproc = clnt->cl_maxproc; in rpc_print_iostats()
214 clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); in rpc_print_iostats()
217 xprt = rcu_dereference(clnt->cl_xprt); in rpc_print_iostats()
225 _print_name(seq, op, clnt->cl_procinfo); in rpc_print_iostats()
|
| D | auth_unix.c | 36 unx_create(struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in unx_create() argument
39 clnt); in unx_create()
146 struct rpc_clnt *clnt = task->tk_client; in unx_marshal() local
158 p = xdr_encode_array(p, clnt->cl_nodename, clnt->cl_nodelen); in unx_marshal()
|
| D | rpc_pipe.c | 405 struct rpc_clnt *clnt = m->private; in rpc_show_info() local
409 rcu_dereference(clnt->cl_xprt)->servername); in rpc_show_info()
410 seq_printf(m, "service: %s (%d) version %d\n", clnt->cl_program->name, in rpc_show_info()
411 clnt->cl_prog, clnt->cl_vers); in rpc_show_info()
412 seq_printf(m, "address: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR)); in rpc_show_info()
413 seq_printf(m, "protocol: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PROTO)); in rpc_show_info()
414 seq_printf(m, "port: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PORT)); in rpc_show_info()
422 struct rpc_clnt *clnt = NULL; in rpc_info_open() local
430 clnt = RPC_I(inode)->private; in rpc_info_open()
431 if (clnt != NULL && atomic_inc_not_zero(&clnt->cl_count)) { in rpc_info_open()
[all …]
|
| D | auth.c | 257 rpcauth_create(struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in rpcauth_create() argument
276 auth = ops->create(args, clnt); in rpcauth_create()
280 if (clnt->cl_auth) in rpcauth_create()
281 rpcauth_release(clnt->cl_auth); in rpcauth_create()
282 clnt->cl_auth = auth; in rpcauth_create()
|
| D | Makefile | 10 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| D | auth_null.c | 21 nul_create(struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in nul_create() argument
|
| D | xprt.c | 546 struct rpc_clnt *clnt = task->tk_client; in xprt_set_retrans_timeout_rtt() local
547 struct rpc_rtt *rtt = clnt->cl_rtt; in xprt_set_retrans_timeout_rtt()
549 unsigned long max_timeout = clnt->cl_timeout->to_maxval; in xprt_set_retrans_timeout_rtt()
|
| /net/9p/ |
| D | client.c | 68 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
70 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
74 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
76 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
122 static int parse_opts(char *opts, struct p9_client *clnt) in parse_opts() argument
131 clnt->proto_version = p9_proto_2000L; in parse_opts()
132 clnt->msize = 8192; in parse_opts()
165 clnt->msize = option; in parse_opts()
175 clnt->trans_mod = v9fs_get_trans_by_name(s); in parse_opts()
176 if (clnt->trans_mod == NULL) { in parse_opts()
[all …]
|
| D | protocol.c | 559 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
569 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
572 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
586 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
595 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
608 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
620 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
624 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
|
| D | protocol.h | 32 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu);
|
| /net/sunrpc/auth_gss/ |
| D | gss_rpc_upcall.c | 116 struct rpc_clnt *clnt; in gssp_rpc_create() local
119 clnt = rpc_create(&args); in gssp_rpc_create()
120 if (IS_ERR(clnt)) { in gssp_rpc_create()
122 "client (errno %ld).\n", PTR_ERR(clnt)); in gssp_rpc_create()
123 result = PTR_ERR(clnt); in gssp_rpc_create()
129 "%p)\n", clnt); in gssp_rpc_create()
130 *_clnt = clnt; in gssp_rpc_create()
145 struct rpc_clnt *clnt; in set_gssp_clnt() local
149 ret = gssp_rpc_create(net, &clnt); in set_gssp_clnt()
153 sn->gssp_clnt = clnt; in set_gssp_clnt()
[all …]
|
| D | auth_gss.c | 85 struct rpc_clnt *clnt; member
836 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
848 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument
864 p->clnt = clnt; in gss_pipe_alloc()
877 struct rpc_clnt *clnt; member
902 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo()
908 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument
912 struct net *net = rpc_net_ns(clnt); in gss_pipe_get()
915 .clnt = clnt, in gss_pipe_get()
921 &clnt->cl_pipedir_objects, in gss_pipe_get()
[all …]
|