Home
last modified time | relevance | path

Searched refs:clnt (Results 1 – 25 of 47) sorted by relevance

12

/Linux-v4.19/net/sunrpc/
Dclnt.c81 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 …]
Ddebugfs.c25 struct rpc_clnt *clnt = task->tk_client; in tasks_show() local
36 clnt->cl_clid, xid, task->tk_timeout, task->tk_ops, in tasks_show()
37 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in tasks_show()
44 __acquires(&clnt->cl_lock) in tasks_start()
46 struct rpc_clnt *clnt = f->private; in tasks_start() local
50 spin_lock(&clnt->cl_lock); in tasks_start()
51 list_for_each_entry(task, &clnt->cl_tasks, tk_task) in tasks_start()
60 struct rpc_clnt *clnt = f->private; in tasks_next() local
67 if (next == &clnt->cl_tasks) in tasks_next()
74 __releases(&clnt->cl_lock) in tasks_stop()
[all …]
Drpcb_clnt.c181 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 …]
Dstats.c119 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()
238 void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) in rpc_clnt_show_stats() argument
241 unsigned int op, maxproc = clnt->cl_maxproc; in rpc_clnt_show_stats()
243 if (!clnt->cl_metrics) in rpc_clnt_show_stats()
248 clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); in rpc_clnt_show_stats()
251 xprt = rcu_dereference(clnt->cl_xprt); in rpc_clnt_show_stats()
259 struct rpc_clnt *next = clnt; in rpc_clnt_show_stats()
266 _print_rpc_iostats(seq, &stats, op, clnt->cl_procinfo); in rpc_clnt_show_stats()
Dauth_unix.c33 unx_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in unx_create() argument
36 clnt); in unx_create()
151 struct rpc_clnt *clnt = task->tk_client; in unx_marshal() local
163 p = xdr_encode_array(p, clnt->cl_nodename, clnt->cl_nodelen); in unx_marshal()
Drpc_pipe.c405 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 …]
/Linux-v4.19/net/9p/
Dclient.c69 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
71 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
75 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
77 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
81 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument
83 if (clnt->msize != 8192) in p9_show_client_options()
84 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options()
85 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options()
87 switch (clnt->proto_version) { in p9_show_client_options()
99 if (clnt->trans_mod->show_options) in p9_show_client_options()
[all …]
Dprotocol.c555 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
565 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
568 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
581 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
590 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
603 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
615 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
619 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
Dtrans_fd.c718 static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) in p9_fd_show_options() argument
720 if (clnt->trans_mod == &p9_tcp_trans) { in p9_fd_show_options()
721 if (clnt->trans_opts.tcp.port != P9_PORT) in p9_fd_show_options()
722 seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); in p9_fd_show_options()
723 } else if (clnt->trans_mod == &p9_fd_trans) { in p9_fd_show_options()
724 if (clnt->trans_opts.fd.rfd != ~0) in p9_fd_show_options()
725 seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); in p9_fd_show_options()
726 if (clnt->trans_opts.fd.wfd != ~0) in p9_fd_show_options()
727 seq_printf(m, ",wfd=%u", clnt->trans_opts.fd.wfd); in p9_fd_show_options()
Dprotocol.h32 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu);
/Linux-v4.19/include/trace/events/
D9p.h101 TP_PROTO(struct p9_client *clnt, int8_t type, int tag),
103 TP_ARGS(clnt, type, tag),
106 __field( void *, clnt )
112 __entry->clnt = clnt;
118 (long)__entry->clnt, show_9p_op(__entry->type),
123 TP_PROTO(struct p9_client *clnt, int8_t type, int tag, int err),
125 TP_ARGS(clnt, type, tag, err),
128 __field( void *, clnt )
135 __entry->clnt = clnt;
142 (long)__entry->clnt, show_9p_op(__entry->type),
[all …]
/Linux-v4.19/net/sunrpc/auth_gss/
Dgss_rpc_upcall.c116 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 …]
Dauth_gss.c84 struct rpc_clnt *clnt; member
895 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
907 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument
923 p->clnt = clnt; in gss_pipe_alloc()
936 struct rpc_clnt *clnt; member
961 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo()
967 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument
971 struct net *net = rpc_net_ns(clnt); in gss_pipe_get()
974 .clnt = clnt, in gss_pipe_get()
980 &clnt->cl_pipedir_objects, in gss_pipe_get()
[all …]
/Linux-v4.19/include/net/9p/
Dclient.h196 struct p9_client *clnt; member
225 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt);
232 void p9_client_destroy(struct p9_client *clnt);
233 void p9_client_disconnect(struct p9_client *clnt);
234 void p9_client_begin_disconnect(struct p9_client *clnt);
235 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
254 int p9dirent_read(struct p9_client *clnt, char *buf, int len,
276 int p9_is_proto_dotu(struct p9_client *clnt);
277 int p9_is_proto_dotl(struct p9_client *clnt);
/Linux-v4.19/include/linux/sunrpc/
Dclnt.h172 int rpc_call_async(struct rpc_clnt *clnt,
176 int rpc_call_sync(struct rpc_clnt *clnt,
178 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
191 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,
195 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,
205 void rpc_set_connect_timeout(struct rpc_clnt *clnt,
218 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt,
Dmetrics.h90 static inline struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) { return NULL; } in rpc_alloc_iostats() argument
98 static inline void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) {} in rpc_clnt_show_stats() argument
Dsched.h287 int rpc_clnt_swap_activate(struct rpc_clnt *clnt);
288 void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt);
291 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument
297 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
Ddebug.h106 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
/Linux-v4.19/fs/9p/
Dv9fs.c164 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options()
400 v9ses->clnt = p9_client_create(dev_name, data); in v9fs_session_init()
401 if (IS_ERR(v9ses->clnt)) { in v9fs_session_init()
402 rc = PTR_ERR(v9ses->clnt); in v9fs_session_init()
409 if (p9_is_proto_dotl(v9ses->clnt)) { in v9fs_session_init()
412 } else if (p9_is_proto_dotu(v9ses->clnt)) { in v9fs_session_init()
420 v9ses->maxdata = v9ses->clnt->msize - P9_IOHDRSZ; in v9fs_session_init()
449 fid = p9_client_attach(v9ses->clnt, NULL, v9ses->uname, INVALID_UID, in v9fs_session_init()
476 p9_client_destroy(v9ses->clnt); in v9fs_session_init()
491 if (v9ses->clnt) { in v9fs_session_close()
[all …]
Dvfs_dir.c124 buflen = fid->clnt->msize - P9_IOHDRSZ; in v9fs_dir_readdir()
149 err = p9stat_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir()
187 buflen = fid->clnt->msize - P9_READDIRHDRSZ; in v9fs_dir_readdir_dotl()
206 err = p9dirent_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir_dotl()
/Linux-v4.19/fs/lockd/
Dmon.c94 struct rpc_clnt *clnt; in nsm_mon_unmon() local
110 clnt = nsm_create(host->net, host->nodename); in nsm_mon_unmon()
111 if (IS_ERR(clnt)) { in nsm_mon_unmon()
113 "status=%ld, net=%x\n", PTR_ERR(clnt), in nsm_mon_unmon()
115 return PTR_ERR(clnt); in nsm_mon_unmon()
118 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nsm_mon_unmon()
119 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon()
123 rpc_force_rebind(clnt); in nsm_mon_unmon()
124 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon()
132 rpc_shutdown_client(clnt); in nsm_mon_unmon()
Dhost.c178 struct rpc_clnt *clnt; in nlm_destroy_host_locked() local
188 clnt = host->h_rpcclnt; in nlm_destroy_host_locked()
189 if (clnt != NULL) in nlm_destroy_host_locked()
190 rpc_shutdown_client(clnt); in nlm_destroy_host_locked()
424 struct rpc_clnt *clnt; in nlm_bind_host() local
435 if ((clnt = host->h_rpcclnt) != NULL) { in nlm_bind_host()
437 rpc_force_rebind(clnt); in nlm_bind_host()
476 clnt = rpc_create(&args); in nlm_bind_host()
477 if (!IS_ERR(clnt)) in nlm_bind_host()
478 host->h_rpcclnt = clnt; in nlm_bind_host()
[all …]
Dclntproc.c262 struct rpc_clnt *clnt; in nlmclnt_call() local
280 if ((clnt = nlm_bind_host(host)) == NULL) in nlmclnt_call()
282 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nlmclnt_call()
285 if ((status = rpc_call_sync(clnt, &msg, 0)) < 0) { in nlmclnt_call()
340 struct rpc_clnt *clnt; in __nlm_async_call() local
352 clnt = nlm_bind_host(host); in __nlm_async_call()
353 if (clnt == NULL) in __nlm_async_call()
355 msg->rpc_proc = &clnt->cl_procinfo[proc]; in __nlm_async_call()
356 task_setup_data.rpc_client = clnt; in __nlm_async_call()
/Linux-v4.19/fs/nfs/
Dmount_clnt.c256 struct rpc_clnt *clnt; in nfs_umount() local
265 clnt = rpc_create(&args); in nfs_umount()
266 if (IS_ERR(clnt)) in nfs_umount()
273 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount()
275 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount()
277 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount()
278 rpc_shutdown_client(clnt); in nfs_umount()
287 PTR_ERR(clnt)); in nfs_umount()
Dnfs4namespace.c154 static struct rpc_clnt *nfs_find_best_sec(struct rpc_clnt *clnt, in nfs_find_best_sec() argument
178 new = rpc_clone_client_set_auth(clnt, pflavor); in nfs_find_best_sec()
211 nfs4_negotiate_security(struct rpc_clnt *clnt, struct inode *inode, in nfs4_negotiate_security() argument
231 new = nfs_find_best_sec(clnt, NFS_SERVER(inode), flavors); in nfs4_negotiate_security()

12