Home
last modified time | relevance | path

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

123

/linux-6.3-rc2/net/sunrpc/
A Dclnt.c210 for (;; clnt = clnt->cl_parent) { in __rpc_pipefs_event()
213 if (error || clnt == clnt->cl_parent) in __rpc_pipefs_event()
387 clnt->cl_parent = parent ? : clnt; in rpc_new_client()
420 clnt->cl_rtt = &clnt->cl_rtt_default; in rpc_new_client()
757 clnt->cl_parent = clnt; in rpc_switch_client_transport()
975 if (clnt->cl_parent != clnt) in rpc_free_client()
1019 clnt = rpc_free_auth(clnt); in rpc_release_client()
3332 while (clnt != clnt->cl_parent) in rpc_clnt_swap_activate()
3333 clnt = clnt->cl_parent; in rpc_clnt_swap_activate()
3353 while (clnt != clnt->cl_parent) in rpc_clnt_swap_deactivate()
[all …]
A Ddebugfs.c36 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 …]
A Drpcb_clnt.c200 if (clnt) in rpcb_put_local()
257 if (IS_ERR(clnt)) { in rpcb_create_local_unix()
258 result = PTR_ERR(clnt); in rpcb_create_local_unix()
299 if (IS_ERR(clnt)) { in rpcb_create_local_net()
300 result = PTR_ERR(clnt); in rpcb_create_local_net()
631 if (clnt->cl_autobind) in rpcb_find_transport_owner()
633 clnt = parent; in rpcb_find_transport_owner()
636 return clnt; in rpcb_find_transport_owner()
648 struct rpc_clnt *clnt; in rpcb_getport_async() local
707 clnt->cl_nodename, in rpcb_getport_async()
[all …]
A Dstats.c124 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 Dsysfs.h11 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);
A Dauth_unix.c29 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 Dsysfs.c516 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, in rpc_sysfs_client_setup() argument
528 net, clnt->cl_clid); in rpc_sysfs_client_setup()
533 clnt->cl_sysfs = rpc_client; in rpc_sysfs_client_setup()
534 rpc_client->clnt = clnt; in rpc_sysfs_client_setup()
589 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) in rpc_sysfs_client_destroy() argument
591 struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; in rpc_sysfs_client_destroy()
600 clnt->cl_sysfs = NULL; in rpc_sysfs_client_destroy()
A Drpc_pipe.c400 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 …]
/linux-6.3-rc2/net/9p/
A Dclient.c857 fid->clnt = clnt; in p9_fid_create()
882 clnt = fid->clnt; in p9_fid_destroy()
1009 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); in p9_client_create()
1224 clnt = fid->clnt; in p9_client_open()
1318 clnt = fid->clnt; in p9_client_fcreate()
1412 clnt = fid->clnt; in p9_client_fsync()
1440 clnt = fid->clnt; in p9_client_clunk()
1474 clnt = fid->clnt; in p9_client_remove()
1684 clnt = fid->clnt; in p9_client_stat()
1737 clnt = fid->clnt; in p9_client_getattr_dotl()
[all …]
A Dprotocol.c711 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
721 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
724 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
738 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
747 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
760 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
772 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
776 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
/linux-6.3-rc2/include/trace/events/
A D9p.h127 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 …]
/linux-6.3-rc2/net/sunrpc/auth_gss/
A Dgss_rpc_upcall.c104 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 Dauth_gss.c79 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 …]
/linux-6.3-rc2/include/linux/sunrpc/
A Dclnt.h145 void (*add_xprt_test)(struct rpc_clnt *clnt,
179 struct rpc_xprt *rpc_task_get_xprt(struct rpc_clnt *clnt,
195 int rpc_call_async(struct rpc_clnt *clnt,
199 int rpc_call_sync(struct rpc_clnt *clnt,
201 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
215 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt,
219 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt,
229 void rpc_set_connect_timeout(struct rpc_clnt *clnt,
246 bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt,
248 void rpc_clnt_xprt_set_online(struct rpc_clnt *clnt, struct rpc_xprt *xprt);
[all …]
A Dsched.h219 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error,
292 int rpc_clnt_swap_activate(struct rpc_clnt *clnt);
293 void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt);
296 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument
302 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
A Dmetrics.h95 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
A 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-6.3-rc2/include/net/9p/
A Dclient.h149 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);
/linux-6.3-rc2/fs/9p/
A Dv9fs.c149 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options()
408 if (IS_ERR(v9ses->clnt)) { in v9fs_session_init()
409 rc = PTR_ERR(v9ses->clnt); in v9fs_session_init()
416 if (p9_is_proto_dotl(v9ses->clnt)) { in v9fs_session_init()
419 } else if (p9_is_proto_dotu(v9ses->clnt)) { in v9fs_session_init()
487 p9_client_destroy(v9ses->clnt); in v9fs_session_init()
502 if (v9ses->clnt) { in v9fs_session_close()
503 p9_client_destroy(v9ses->clnt); in v9fs_session_close()
504 v9ses->clnt = NULL; in v9fs_session_close()
529 p9_client_disconnect(v9ses->clnt); in v9fs_session_cancel()
[all …]
A Dvfs_dir.c98 buflen = fid->clnt->msize - P9_IOHDRSZ; in v9fs_dir_readdir()
123 err = p9stat_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir()
159 buflen = fid->clnt->msize - P9_READDIRHDRSZ; in v9fs_dir_readdir_dotl()
178 err = p9dirent_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir_dotl()
A Dvfs_file.c170 flock.client_id = fid->clnt->name; in v9fs_file_do_lock()
196 if (flock.client_id != fid->clnt->name) { in v9fs_file_do_lock()
198 flock.client_id = fid->clnt->name; in v9fs_file_do_lock()
231 if (flock.client_id != fid->clnt->name) in v9fs_file_do_lock()
263 glock.client_id = fid->clnt->name; in v9fs_file_getlock()
289 if (glock.client_id != fid->clnt->name) in v9fs_file_getlock()
/linux-6.3-rc2/fs/lockd/
A Dmon.c95 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()
A Dhost.c180 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 …]
A Dclntproc.c265 struct rpc_clnt *clnt; in nlmclnt_call() local
283 if ((clnt = nlm_bind_host(host)) == NULL) in nlmclnt_call()
285 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nlmclnt_call()
288 if ((status = rpc_call_sync(clnt, &msg, 0)) < 0) { in nlmclnt_call()
343 struct rpc_clnt *clnt; in __nlm_async_call() local
355 clnt = nlm_bind_host(host); in __nlm_async_call()
356 if (clnt == NULL) in __nlm_async_call()
358 msg->rpc_proc = &clnt->cl_procinfo[proc]; in __nlm_async_call()
359 task_setup_data.rpc_client = clnt; in __nlm_async_call()
/linux-6.3-rc2/fs/nfs/
A Dmount_clnt.c261 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()

Completed in 56 milliseconds

123