| /net/sunrpc/ |
| A D | clnt.c | 200 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
203 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
380 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
414 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
764 clnt->cl_parent = clnt; in rpc_switch_client_transport()
996 if (clnt->cl_parent != clnt) in rpc_free_client()
1040 clnt = rpc_free_auth(clnt); in rpc_release_client()
3397 while (clnt != clnt->cl_parent) in rpc_clnt_swap_activate()
3398 clnt = clnt->cl_parent; in rpc_clnt_swap_activate()
3418 while (clnt != clnt->cl_parent) in rpc_clnt_swap_deactivate()
[all …]
|
| A D | debugfs.c | 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()
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()
76 spin_unlock(&clnt->cl_lock); in tasks_stop()
111 rpc_release_client(clnt); in tasks_release()
163 debugfs_create_file("tasks", S_IFREG | 0400, clnt->cl_debugfs, clnt, in rpc_clnt_debugfs_register()
[all …]
|
| A D | rpcb_clnt.c | 201 if (clnt) in rpcb_put_local()
259 if (IS_ERR(clnt)) { in rpcb_create_af_local()
260 result = PTR_ERR(clnt); in rpcb_create_af_local()
321 if (IS_ERR(clnt)) { in rpcb_create_local_net()
322 result = PTR_ERR(clnt); in rpcb_create_local_net()
654 if (clnt->cl_autobind) in rpcb_find_transport_owner()
656 clnt = parent; in rpcb_find_transport_owner()
659 return clnt; in rpcb_find_transport_owner()
671 struct rpc_clnt *clnt; in rpcb_getport_async() local
730 clnt->cl_nodename, in rpcb_getport_async()
[all …]
|
| A 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 …]
|
| A D | sysfs.c | 67 struct rpc_clnt *ret = c->clnt; in rpc_sysfs_client_kobj_get_clnt()
106 if (!clnt) in rpc_sysfs_clnt_version_show()
110 refcount_dec(&clnt->cl_count); in rpc_sysfs_clnt_version_show()
121 if (!clnt) in rpc_sysfs_clnt_program_show()
125 refcount_dec(&clnt->cl_count); in rpc_sysfs_clnt_program_show()
136 if (!clnt) in rpc_sysfs_clnt_max_connect_show()
140 refcount_dec(&clnt->cl_count); in rpc_sysfs_clnt_max_connect_show()
731 net, clnt->cl_clid); in rpc_sysfs_client_setup()
736 clnt->cl_sysfs = rpc_client; in rpc_sysfs_client_setup()
737 rpc_client->clnt = clnt; in rpc_sysfs_client_setup()
[all …]
|
| A 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()
|
| A 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()
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()
428 m->private = clnt; in rpc_info_open()
442 struct rpc_clnt *clnt = (struct rpc_clnt *)m->private; in rpc_info_release() local
444 if (clnt) in rpc_info_release()
[all …]
|
| A D | svcauth.c | 186 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()
|
| A 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
|
| A D | sysfs.h | 24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt,
27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
|
| A 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()
|
| A D | Makefile | 11 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| A D | auth_null.c | 22 nul_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in nul_create() argument
|
| A D | sched.c | 290 struct rpc_clnt *clnt = task->tk_client; in rpc_task_set_debuginfo() local
293 if (!clnt) { in rpc_task_set_debuginfo()
300 task->tk_pid = atomic_inc_return(&clnt->cl_pid); in rpc_task_set_debuginfo()
|
| A D | xprt.c | 1280 struct rpc_clnt *clnt = task->tk_client; in xprt_wait_for_reply_request_rtt() local
1281 struct rpc_rtt *rtt = clnt->cl_rtt; in xprt_wait_for_reply_request_rtt()
1283 unsigned long max_timeout = clnt->cl_timeout->to_maxval; in xprt_wait_for_reply_request_rtt()
|
| A D | xprtsock.c | 2689 struct rpc_clnt *upper_clnt = upper_transport->clnt; in xs_tcp_tls_setup_socket()
2759 upper_transport->clnt = NULL; in xs_tcp_tls_setup_socket()
2807 transport->clnt = task->tk_client; in xs_connect()
|
| /net/9p/ |
| A D | client.c | 862 fid->clnt = clnt; in p9_fid_create()
887 clnt = fid->clnt; in p9_fid_destroy()
1015 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create()
1237 clnt = fid->clnt; in p9_client_open()
1329 clnt = fid->clnt; in p9_client_fcreate()
1422 clnt = fid->clnt; in p9_client_fsync()
1449 clnt = fid->clnt; in p9_client_clunk()
1482 clnt = fid->clnt; in p9_client_remove()
1745 clnt = fid->clnt; in p9_client_stat()
1797 clnt = fid->clnt; in p9_client_getattr_dotl()
[all …]
|
| A 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()
|
| A D | trans_fd.c | 749 static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) in p9_fd_show_options() argument
751 if (clnt->trans_mod == &p9_tcp_trans) { in p9_fd_show_options()
752 if (clnt->trans_opts.tcp.port != P9_PORT) in p9_fd_show_options()
753 seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); in p9_fd_show_options()
754 } else if (clnt->trans_mod == &p9_fd_trans) { in p9_fd_show_options()
755 if (clnt->trans_opts.fd.rfd != ~0) in p9_fd_show_options()
756 seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); in p9_fd_show_options()
757 if (clnt->trans_opts.fd.wfd != ~0) in p9_fd_show_options()
758 seq_printf(m, ",wfd=%u", clnt->trans_opts.fd.wfd); in p9_fd_show_options()
|
| A D | protocol.h | 17 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu);
|
| A 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/ |
| A D | gss_rpc_upcall.c | 104 struct rpc_clnt *clnt; in gssp_rpc_create() local
108 if (IS_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
141 sn->gssp_clnt = clnt; in set_gssp_clnt()
159 struct rpc_clnt *clnt; in get_gssp_clnt() local
162 clnt = sn->gssp_clnt; in get_gssp_clnt()
163 if (clnt) in get_gssp_clnt()
166 return clnt; in get_gssp_clnt()
[all …]
|
| A D | auth_gss.c | 79 struct rpc_clnt *clnt; member
923 p->clnt = clnt; in gss_pipe_alloc()
936 struct rpc_clnt *clnt; member
974 .clnt = clnt, in gss_pipe_get()
980 &clnt->cl_pipedir_objects, in gss_pipe_get()
991 struct rpc_clnt *clnt = p->clnt; in __gss_pipe_free() local
1038 gss_auth->client = clnt; in gss_create_new()
1165 struct rpc_clnt *clnt, in gss_auth_find_or_add_hashed() argument
1202 struct rpc_clnt *clnt) in gss_create_hashed() argument
1226 while (clnt != clnt->cl_parent) { in gss_create()
[all …]
|
| /net/smc/ |
| A D | smc_stats.h | 44 struct smc_stats_fback clnt[SMC_MAX_FBACK_RSN_CNT]; member
|
| A D | smc_stats.c | 342 trgt_arr = &net->smc.fback_rsn->clnt[0]; in smc_nl_get_fback_details()
|