Home
last modified time | relevance | path

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

12

/linux/net/sunrpc/
H A Dclnt.c73 static int rpc_ping(struct rpc_clnt *clnt);
74 static int rpc_ping_noreply(struct rpc_clnt *clnt);
77 static void rpc_register_client(struct rpc_clnt *clnt) in rpc_register_client() argument
79 struct net *net = rpc_net_ns(clnt); in rpc_register_client()
83 list_add(&clnt->cl_clients, &sn->all_clients); in rpc_register_client()
87 static void rpc_unregister_client(struct rpc_clnt *clnt) in rpc_unregister_client() argument
89 struct net *net = rpc_net_ns(clnt); in rpc_unregister_client()
93 list_del(&clnt->cl_clients); in rpc_unregister_client()
97 static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) in __rpc_clnt_remove_pipedir() argument
99 rpc_remove_client_dir(clnt); in __rpc_clnt_remove_pipedir()
[all …]
H A 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()
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 …]
H A Dstats.c124 struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) in rpc_alloc_iostats() argument
129 stats = kzalloc_objs(*stats, clnt->cl_maxproc); 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 Dsysfs.c68 struct rpc_clnt *ret = c->clnt; in rpc_sysfs_client_kobj_get_clnt()
104 struct rpc_clnt *clnt = rpc_sysfs_client_kobj_get_clnt(kobj); in rpc_sysfs_clnt_version_show() local
107 if (!clnt) in rpc_sysfs_clnt_version_show()
110 ret = sprintf(buf, "%u", clnt->cl_vers); in rpc_sysfs_clnt_version_show()
111 refcount_dec(&clnt->cl_count); in rpc_sysfs_clnt_version_show()
119 struct rpc_clnt *clnt = rpc_sysfs_client_kobj_get_clnt(kobj); in rpc_sysfs_clnt_program_show() local
122 if (!clnt) in rpc_sysfs_clnt_program_show()
125 ret = sprintf(buf, "%s", clnt->cl_program->name); in rpc_sysfs_clnt_program_show()
126 refcount_dec(&clnt->cl_count); in rpc_sysfs_clnt_program_show()
134 struct rpc_clnt *clnt = rpc_sysfs_client_kobj_get_clnt(kobj); in rpc_sysfs_clnt_max_connect_show() local
[all …]
H 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()
H 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()
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 …]
H A Dsvcauth.c186 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()
H A Dsysfs.h24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt,
27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
H A Dauth_tls.c50 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 Dauth.c222 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()
/linux/net/9p/
H A Dclient.c36 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument
38 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl()
42 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument
44 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu()
48 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument
50 if (clnt->msize != DEFAULT_MSIZE) in p9_show_client_options()
51 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options()
52 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options()
54 switch (clnt->proto_version) { in p9_show_client_options()
66 if (clnt->trans_mod->show_options) in p9_show_client_options()
[all …]
H A Dprotocol.c719 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument
729 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read()
732 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read()
746 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument
755 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize()
768 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument
780 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read()
784 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
H A Dtrans_fd.c706 static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) in p9_fd_show_options() argument
708 if (clnt->trans_mod == &p9_tcp_trans) { in p9_fd_show_options()
709 if (clnt->trans_opts.tcp.port != P9_FD_PORT) in p9_fd_show_options()
710 seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); in p9_fd_show_options()
711 } else if (clnt->trans_mod == &p9_fd_trans) { in p9_fd_show_options()
712 if (clnt->trans_opts.fd.rfd != ~0) in p9_fd_show_options()
713 seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); in p9_fd_show_options()
714 if (clnt->trans_opts.fd.wfd != ~0) in p9_fd_show_options()
715 seq_printf(m, ",wfd=%u", clnt->trans_opts.fd.wfd); in p9_fd_show_options()
/linux/include/trace/events/
H A D9p.h125 TP_PROTO(struct p9_client *clnt, int8_t type, int tag),
127 TP_ARGS(clnt, type, tag),
130 __field( void *, clnt )
136 __entry->clnt = clnt;
142 (long)__entry->clnt, show_9p_op(__entry->type),
147 TP_PROTO(struct p9_client *clnt, int8_t type, int tag, int err),
149 TP_ARGS(clnt, type, tag, err),
152 __field( void *, clnt )
159 __entry->clnt = clnt;
166 (long)__entry->clnt, show_9p_op(__entry->type),
[all …]
/linux/net/sunrpc/auth_gss/
H A Dgss_rpc_upcall.c104 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 …]
H A Dauth_gss.c81 struct rpc_clnt *clnt; member
902 return rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
910 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument
926 p->clnt = clnt; in gss_pipe_alloc()
939 struct rpc_clnt *clnt; member
964 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo()
970 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument
974 struct net *net = rpc_net_ns(clnt); in gss_pipe_get()
977 .clnt = clnt, in gss_pipe_get()
983 &clnt->cl_pipedir_objects, in gss_pipe_get()
[all …]
/linux/fs/9p/
H A Dv9fs.c201 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options()
218 struct p9_client_opts *clnt = &ctx->client_opts; in v9fs_parse_param() local
350 clnt->msize = result.uint_32; in v9fs_parse_param()
353 v9fs_put_trans(clnt->trans_mod); in v9fs_parse_param()
354 clnt->trans_mod = v9fs_get_trans_by_name(param->string); in v9fs_parse_param()
355 if (!clnt->trans_mod) { in v9fs_parse_param()
362 clnt->proto_version = p9_proto_legacy; in v9fs_parse_param()
365 clnt->proto_version = result.uint_32; in v9fs_parse_param()
446 v9ses->clnt = p9_client_create(fc); in v9fs_session_init()
447 if (IS_ERR(v9ses->clnt)) { in v9fs_session_init()
[all …]
H A Dvfs_dir.c97 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()
/linux/include/net/9p/
H A Dclient.h245 struct p9_client *clnt; member
276 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt);
283 void p9_client_destroy(struct p9_client *clnt);
284 void p9_client_disconnect(struct p9_client *clnt);
285 void p9_client_begin_disconnect(struct p9_client *clnt);
286 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
309 int p9dirent_read(struct p9_client *clnt, char *buf, int len,
383 int p9stat_read(struct p9_client *clnt, char *buf, int len,
387 int p9_is_proto_dotu(struct p9_client *clnt);
388 int p9_is_proto_dotl(struct p9_client *clnt);
/linux/fs/nfs/
H A Dsysfs.c230 static void shutdown_client(struct rpc_clnt *clnt) in shutdown_client() argument
232 clnt->cl_shutdown = 1; in shutdown_client()
233 rpc_cancel_tasks(clnt, -EIO, shutdown_match_client, NULL); in shutdown_client()
334 struct rpc_clnt *clnt, const char *uniq) in nfs_sysfs_link_rpc_client() argument
339 strscpy(name, clnt->cl_program->name, sizeof(name)); in nfs_sysfs_link_rpc_client()
344 &clnt->cl_sysfs->kobject, name); in nfs_sysfs_link_rpc_client()
H A Dnfs40proc.c172 struct rpc_clnt *clnt = server->client; in _nfs40_proc_get_locations() local
204 status = nfs4_call_sync_sequence(clnt, server, &msg, in _nfs40_proc_get_locations()
224 struct rpc_clnt *clnt = server->client; in _nfs40_proc_fsid_present() local
247 status = nfs4_call_sync_sequence(clnt, server, &msg, in _nfs40_proc_fsid_present()
H A Dnfs4namespace.c204 static struct rpc_clnt *nfs_find_best_sec(struct rpc_clnt *clnt, in nfs_find_best_sec() argument
228 new = rpc_clone_client_set_auth(clnt, pflavor); in nfs_find_best_sec()
261 nfs4_negotiate_security(struct rpc_clnt *clnt, struct inode *inode, in nfs4_negotiate_security() argument
281 new = nfs_find_best_sec(clnt, NFS_SERVER(inode), flavors); in nfs4_negotiate_security()
H A Dnfs4state.c1146 struct rpc_clnt *clnt = clp->cl_rpcclient; in nfs4_schedule_state_manager() local
1154 if (atomic_read(&clnt->cl_swapper)) { in nfs4_schedule_state_manager()
2224 struct rpc_clnt *clnt; in nfs4_discover_server_trunking() local
2230 clnt = clp->cl_rpcclient; in nfs4_discover_server_trunking()
2248 if (clnt->cl_softrtry) in nfs4_discover_server_trunking()
2264 if (clnt->cl_auth->au_flavor == RPC_AUTH_UNIX) in nfs4_discover_server_trunking()
2270 if (clnt->cl_auth->au_flavor == RPC_AUTH_UNIX) { in nfs4_discover_server_trunking()
2274 clnt = rpc_clone_client_set_auth(clnt, RPC_AUTH_UNIX); in nfs4_discover_server_trunking()
2275 if (IS_ERR(clnt)) { in nfs4_discover_server_trunking()
2276 status = PTR_ERR(clnt); in nfs4_discover_server_trunking()
[all …]
/linux/include/linux/sunrpc/
H 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
/linux/drivers/video/fbdev/matrox/
H A Dmatroxfb_maven.c1201 static int maven_init_client(struct i2c_client* clnt) { in maven_init_client() argument
1202 struct maven_data* md = i2c_get_clientdata(clnt); in maven_init_client()
1203 struct matrox_fb_info *minfo = container_of(clnt->adapter, in maven_init_client()
1208 md->client = clnt; in maven_init_client()
1215 if (maven_get_reg(clnt, 0xB2) < 0x14) { in maven_init_client()
1235 static int maven_shutdown_client(struct i2c_client* clnt) { in maven_shutdown_client() argument
1236 struct maven_data* md = i2c_get_clientdata(clnt); in maven_shutdown_client()

12