/openbmc/linux/net/sunrpc/ |
H A D | clnt.c | 213 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event() 216 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event() 390 clnt->cl_parent = parent ? : clnt; in rpc_new_client() 424 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client() 771 clnt->cl_parent = clnt; in rpc_switch_client_transport() 989 if (clnt->cl_parent != clnt) in rpc_free_client() 1033 clnt = rpc_free_auth(clnt); in rpc_release_client() 3371 while (clnt != clnt->cl_parent) in rpc_clnt_swap_activate() 3372 clnt = clnt->cl_parent; in rpc_clnt_swap_activate() 3392 while (clnt != clnt->cl_parent) in rpc_clnt_swap_deactivate() [all …]
|
H 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() 108 rpc_release_client(clnt); in tasks_release() 160 debugfs_create_file("tasks", S_IFREG | 0400, clnt->cl_debugfs, clnt, in rpc_clnt_debugfs_register() [all …]
|
H 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 …]
|
H 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 …]
|
H 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()
|
H A D | sysfs.h | 24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, 27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
|
H 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
|
H A 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()
|
H 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 …]
|
/openbmc/linux/net/9p/ |
H A D | client.c | 861 fid->clnt = clnt; in p9_fid_create() 886 clnt = fid->clnt; in p9_fid_destroy() 1012 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create() 1226 clnt = fid->clnt; in p9_client_open() 1318 clnt = fid->clnt; in p9_client_fcreate() 1411 clnt = fid->clnt; in p9_client_fsync() 1438 clnt = fid->clnt; in p9_client_clunk() 1471 clnt = fid->clnt; in p9_client_remove() 1680 clnt = fid->clnt; in p9_client_stat() 1732 clnt = fid->clnt; in p9_client_getattr_dotl() [all …]
|
/openbmc/linux/include/trace/events/ |
H A D | 9p.h | 127 TP_ARGS(clnt, type, tag), 130 __field( void *, clnt ) 136 __entry->clnt = clnt; 142 (long)__entry->clnt, show_9p_op(__entry->type), 149 TP_ARGS(clnt, type, tag, err), 152 __field( void *, clnt ) 159 __entry->clnt = clnt; 166 (long)__entry->clnt, show_9p_op(__entry->type), 175 TP_ARGS(clnt, pdu), 178 __field( void *, clnt ) [all …]
|
H A D | sunrpc.h | 111 const struct rpc_clnt *clnt 114 TP_ARGS(clnt), 131 const struct rpc_clnt *clnt \ 133 TP_ARGS(clnt)) 170 const struct rpc_clnt *clnt, 175 TP_ARGS(clnt, xprt, args), 233 const struct rpc_clnt *clnt, 237 TP_ARGS(clnt, error), 1378 const struct rpc_clnt *clnt, 1538 TP_ARGS(clnt, xprt), [all …]
|
/openbmc/linux/net/sunrpc/auth_gss/ |
H 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 …]
|
H A D | auth_gss.c | 79 struct rpc_clnt *clnt; member 932 p->clnt = clnt; in gss_pipe_alloc() 945 struct rpc_clnt *clnt; member 983 .clnt = clnt, in gss_pipe_get() 989 &clnt->cl_pipedir_objects, in gss_pipe_get() 1000 struct rpc_clnt *clnt = p->clnt; in __gss_pipe_free() local 1047 gss_auth->client = clnt; in gss_create_new() 1174 struct rpc_clnt *clnt, in gss_auth_find_or_add_hashed() argument 1211 struct rpc_clnt *clnt) in gss_create_hashed() argument 1235 while (clnt != clnt->cl_parent) { in gss_create() [all …]
|
/openbmc/linux/include/linux/sunrpc/ |
H A D | clnt.h | 36 struct rpc_clnt *clnt; member 158 void (*add_xprt_test)(struct rpc_clnt *clnt, 192 struct rpc_xprt *rpc_task_get_xprt(struct rpc_clnt *clnt, 208 int rpc_call_async(struct rpc_clnt *clnt, 212 int rpc_call_sync(struct rpc_clnt *clnt, 214 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, 228 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, 232 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, 242 void rpc_set_connect_timeout(struct rpc_clnt *clnt, 259 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt, [all …]
|
H A D | sched.h | 218 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error, 291 int rpc_clnt_swap_activate(struct rpc_clnt *clnt); 292 void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt); 295 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument 301 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
|
H A D | metrics.h | 95 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
|
H A D | debug.h | 106 rpc_clnt_debugfs_register(struct rpc_clnt *clnt) in rpc_clnt_debugfs_register() argument 112 rpc_clnt_debugfs_unregister(struct rpc_clnt *clnt) in rpc_clnt_debugfs_unregister() argument
|
/openbmc/linux/include/net/9p/ |
H A D | client.h | 149 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, 211 int p9dirent_read(struct p9_client *clnt, char *buf, int len, 285 int p9stat_read(struct p9_client *clnt, char *buf, int len, 289 int p9_is_proto_dotu(struct p9_client *clnt); 290 int p9_is_proto_dotl(struct p9_client *clnt);
|
/openbmc/linux/fs/9p/ |
H A D | v9fs.c | 152 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options() 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() 490 p9_client_destroy(v9ses->clnt); in v9fs_session_init() 505 if (v9ses->clnt) { in v9fs_session_close() 506 p9_client_destroy(v9ses->clnt); in v9fs_session_close() 507 v9ses->clnt = NULL; in v9fs_session_close() 532 p9_client_disconnect(v9ses->clnt); in v9fs_session_cancel() [all …]
|
H A D | vfs_dir.c | 97 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()
|
/openbmc/linux/fs/lockd/ |
H A D | mon.c | 95 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 D | host.c | 180 struct rpc_clnt *clnt; in nlm_destroy_host_locked() local 190 clnt = host->h_rpcclnt; in nlm_destroy_host_locked() 191 if (clnt != NULL) in nlm_destroy_host_locked() 192 rpc_shutdown_client(clnt); in nlm_destroy_host_locked() 430 struct rpc_clnt *clnt; in nlm_bind_host() local 441 if ((clnt = host->h_rpcclnt) != NULL) { in nlm_bind_host() 479 clnt = rpc_create(&args); in nlm_bind_host() 480 if (!IS_ERR(clnt)) in nlm_bind_host() 481 host->h_rpcclnt = clnt; in nlm_bind_host() 484 clnt = NULL; in nlm_bind_host() [all …]
|
/openbmc/linux/fs/nfs/ |
H A D | mount_clnt.c | 261 struct rpc_clnt *clnt; in nfs_umount() local 270 clnt = rpc_create(&args); in nfs_umount() 271 if (IS_ERR(clnt)) in nfs_umount() 278 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount() 280 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount() 282 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount() 283 rpc_shutdown_client(clnt); in nfs_umount() 292 PTR_ERR(clnt)); in nfs_umount()
|
H A D | sysfs.c | 225 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 strcpy(name, clnt->cl_program->name); in nfs_sysfs_link_rpc_client() 288 &clnt->cl_sysfs->kobject, name); in nfs_sysfs_link_rpc_client()
|