| /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 | 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()
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 …]
|
| D | stats.c | 124 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 …]
|
| D | auth_unix.c | 29 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()
|
| 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 | 517 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()
|
| D | auth_tls.c | 50 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
|
| D | sysfs.h | 24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt,
27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
|
| D | auth.c | 222 rpcauth_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in rpcauth_create() argument
232 auth = ops->create(args, clnt); in rpcauth_create()
237 if (clnt->cl_auth) in rpcauth_create()
238 rpcauth_release(clnt->cl_auth); in rpcauth_create()
239 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 | sched.c | 288 struct rpc_clnt *clnt = task->tk_client; in rpc_task_set_debuginfo() local
291 if (!clnt) { in rpc_task_set_debuginfo()
298 task->tk_pid = atomic_inc_return(&clnt->cl_pid); in rpc_task_set_debuginfo()
|
| D | xprt.c | 1277 struct rpc_clnt *clnt = task->tk_client; in xprt_wait_for_reply_request_rtt() local
1278 struct rpc_rtt *rtt = clnt->cl_rtt; in xprt_wait_for_reply_request_rtt()
1280 unsigned long max_timeout = clnt->cl_timeout->to_maxval; in xprt_wait_for_reply_request_rtt()
|
| D | xprtsock.c | 2637 struct rpc_clnt *upper_clnt = upper_transport->clnt; in xs_tcp_tls_setup_socket()
2713 upper_transport->clnt = NULL; in xs_tcp_tls_setup_socket()
2761 transport->clnt = task->tk_client; in xs_connect()
|
| /net/9p/ |
| D | client.c | 57 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
59 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
63 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
65 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
69 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument
71 if (clnt->msize != DEFAULT_MSIZE) in p9_show_client_options()
72 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options()
73 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options()
75 switch (clnt->proto_version) { in p9_show_client_options()
87 if (clnt->trans_mod->show_options) in p9_show_client_options()
[all …]
|
| D | protocol.c | 720 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()
|
| D | trans_fd.c | 742 static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) in p9_fd_show_options() argument
744 if (clnt->trans_mod == &p9_tcp_trans) { in p9_fd_show_options()
745 if (clnt->trans_opts.tcp.port != P9_PORT) in p9_fd_show_options()
746 seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); in p9_fd_show_options()
747 } else if (clnt->trans_mod == &p9_fd_trans) { in p9_fd_show_options()
748 if (clnt->trans_opts.fd.rfd != ~0) in p9_fd_show_options()
749 seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); in p9_fd_show_options()
750 if (clnt->trans_opts.fd.wfd != ~0) in p9_fd_show_options()
751 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 | 150 static int p9_rdma_show_options(struct seq_file *m, struct p9_client *clnt) in p9_rdma_show_options() argument
152 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 | 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()
983 .clnt = clnt, in gss_pipe_get()
989 &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 | 763 smc_stat_inc_fback_rsn_cnt(smc, net->smc.fback_rsn->clnt); in smc_stat_fallback()
|