| /net/sunrpc/ |
| D | clnt.c | 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) in rpc_register_client() argument
84 struct net *net = rpc_net_ns(clnt); in rpc_register_client()
88 list_add(&clnt->cl_clients, &sn->all_clients); in rpc_register_client()
92 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client() argument
94 struct net *net = rpc_net_ns(clnt); in rpc_unregister_client()
98 list_del(&clnt->cl_clients); in rpc_unregister_client()
102 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in __rpc_clnt_remove_pipedir() argument
104 rpc_remove_client_dir(clnt); in __rpc_clnt_remove_pipedir()
[all …]
|
| D | debugfs.c | 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 = f->private; in tasks_next() local
66 if (next == &clnt->cl_tasks) in tasks_next()
73 __releases(&clnt->cl_lock) in tasks_stop()
[all …]
|
| D | rpcb_clnt.c | 180 struct rpc_clnt *clnt = sn->rpcb_local_clnt; in rpcb_put_local() local
200 if (clnt) in rpcb_put_local()
201 rpc_shutdown_client(clnt); in rpcb_put_local()
205 static void rpcb_set_local(struct net *net, struct rpc_clnt *clnt, in rpcb_set_local() argument
212 sn->rpcb_local_clnt = clnt; in rpcb_set_local()
248 struct rpc_clnt *clnt, *clnt4; in rpcb_create_local_unix() local
256 clnt = rpc_create(&args); in rpcb_create_local_unix()
257 if (IS_ERR(clnt)) { in rpcb_create_local_unix()
258 result = PTR_ERR(clnt); in rpcb_create_local_unix()
262 clnt4 = rpc_bind_new_program(clnt, &rpcb_program, RPCBVERS_4); in rpcb_create_local_unix()
[all …]
|
| D | stats.c | 119 struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) in rpc_alloc_iostats() argument
124 stats = kcalloc(clnt->cl_maxproc, sizeof(*stats), GFP_KERNEL); in rpc_alloc_iostats()
126 for (i = 0; i < clnt->cl_maxproc; i++) in rpc_alloc_iostats()
242 static int do_print_stats(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *seqv) in do_print_stats() argument
250 void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) in rpc_clnt_show_stats() argument
252 unsigned int op, maxproc = clnt->cl_maxproc; in rpc_clnt_show_stats()
254 if (!clnt->cl_metrics) in rpc_clnt_show_stats()
259 clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); in rpc_clnt_show_stats()
261 rpc_clnt_iterate_for_each_xprt(clnt, do_print_stats, seq); in rpc_clnt_show_stats()
266 struct rpc_clnt *next = clnt; in rpc_clnt_show_stats()
[all …]
|
| D | auth_unix.c | 29 unx_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in unx_create() argument
105 struct rpc_clnt *clnt = task->tk_client; in unx_marshal() local
110 struct user_namespace *userns = clnt->cl_cred ? in unx_marshal()
111 clnt->cl_cred->user_ns : &init_user_ns; in unx_marshal()
121 if (xdr_stream_encode_opaque(xdr, clnt->cl_nodename, in unx_marshal()
122 clnt->cl_nodelen) < 0) in unx_marshal()
|
| D | sysfs.h | 11 struct rpc_clnt *clnt; member
31 void rpc_sysfs_client_setup(struct rpc_clnt *clnt,
34 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
|
| D | rpc_pipe.c | 400 struct rpc_clnt *clnt = m->private; in rpc_show_info() local
404 rcu_dereference(clnt->cl_xprt)->servername); in rpc_show_info()
405 seq_printf(m, "service: %s (%d) version %d\n", clnt->cl_program->name, in rpc_show_info()
406 clnt->cl_prog, clnt->cl_vers); in rpc_show_info()
407 seq_printf(m, "address: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR)); in rpc_show_info()
408 seq_printf(m, "protocol: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PROTO)); in rpc_show_info()
409 seq_printf(m, "port: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PORT)); in rpc_show_info()
417 struct rpc_clnt *clnt = NULL; in rpc_info_open() local
425 clnt = RPC_I(inode)->private; in rpc_info_open()
426 if (clnt != NULL && refcount_inc_not_zero(&clnt->cl_count)) { in rpc_info_open()
[all …]
|
| D | sysfs.c | 523 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, in rpc_sysfs_client_setup() argument
535 net, clnt->cl_clid); in rpc_sysfs_client_setup()
540 clnt->cl_sysfs = rpc_client; in rpc_sysfs_client_setup()
541 rpc_client->clnt = clnt; in rpc_sysfs_client_setup()
596 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) in rpc_sysfs_client_destroy() argument
598 struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; in rpc_sysfs_client_destroy()
607 clnt->cl_sysfs = NULL; in rpc_sysfs_client_destroy()
|
| D | auth.c | 225 rpcauth_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in rpcauth_create() argument
235 auth = ops->create(args, clnt); in rpcauth_create()
240 if (clnt->cl_auth) in rpcauth_create()
241 rpcauth_release(clnt->cl_auth); in rpcauth_create()
242 clnt->cl_auth = auth; in rpcauth_create()
|
| D | Makefile | 11 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| D | auth_null.c | 22 nul_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in nul_create() argument
|
| D | xprt.c | 1270 struct rpc_clnt *clnt = task->tk_client; in xprt_wait_for_reply_request_rtt() local
1271 struct rpc_rtt *rtt = clnt->cl_rtt; in xprt_wait_for_reply_request_rtt()
1273 unsigned long max_timeout = clnt->cl_timeout->to_maxval; in xprt_wait_for_reply_request_rtt()
|
| /net/9p/ |
| D | client.c | 55 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
57 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
61 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
63 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
67 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument
69 if (clnt->msize != DEFAULT_MSIZE) in p9_show_client_options()
70 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options()
71 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options()
73 switch (clnt->proto_version) { in p9_show_client_options()
85 if (clnt->trans_mod->show_options) in p9_show_client_options()
[all …]
|
| D | protocol.c | 556 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
566 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
569 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
583 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
592 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
605 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
617 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
621 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
|
| D | trans_fd.c | 745 static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) in p9_fd_show_options() argument
747 if (clnt->trans_mod == &p9_tcp_trans) { in p9_fd_show_options()
748 if (clnt->trans_opts.tcp.port != P9_PORT) in p9_fd_show_options()
749 seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); in p9_fd_show_options()
750 } else if (clnt->trans_mod == &p9_fd_trans) { in p9_fd_show_options()
751 if (clnt->trans_opts.fd.rfd != ~0) in p9_fd_show_options()
752 seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); in p9_fd_show_options()
753 if (clnt->trans_opts.fd.wfd != ~0) in p9_fd_show_options()
754 seq_printf(m, ",wfd=%u", clnt->trans_opts.fd.wfd); in p9_fd_show_options()
|
| D | protocol.h | 17 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu);
|
| D | trans_rdma.c | 153 static int p9_rdma_show_options(struct seq_file *m, struct p9_client *clnt) in p9_rdma_show_options() argument
155 struct p9_trans_rdma *rdma = clnt->trans; in p9_rdma_show_options()
|
| /net/sunrpc/auth_gss/ |
| D | gss_rpc_upcall.c | 104 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 …]
|
| D | auth_gss.c | 63 struct rpc_clnt *clnt; member
887 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
899 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument
915 p->clnt = clnt; in gss_pipe_alloc()
928 struct rpc_clnt *clnt; member
953 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo()
959 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument
963 struct net *net = rpc_net_ns(clnt); in gss_pipe_get()
966 .clnt = clnt, in gss_pipe_get()
972 &clnt->cl_pipedir_objects, in gss_pipe_get()
[all …]
|
| /net/smc/ |
| D | smc_stats.h | 44 struct smc_stats_fback clnt[SMC_MAX_FBACK_RSN_CNT]; member
|
| D | smc_stats.c | 336 trgt_arr = &net->smc.fback_rsn->clnt[0]; in smc_nl_get_fback_details()
|
| D | af_smc.c | 555 smc_stat_inc_fback_rsn_cnt(smc, net->smc.fback_rsn->clnt); in smc_stat_fallback()
|