clnt 1201 drivers/video/fbdev/matrox/matroxfb_maven.c static int maven_init_client(struct i2c_client* clnt) { clnt 1202 drivers/video/fbdev/matrox/matroxfb_maven.c struct maven_data* md = i2c_get_clientdata(clnt); clnt 1203 drivers/video/fbdev/matrox/matroxfb_maven.c struct matrox_fb_info *minfo = container_of(clnt->adapter, clnt 1208 drivers/video/fbdev/matrox/matroxfb_maven.c md->client = clnt; clnt 1215 drivers/video/fbdev/matrox/matroxfb_maven.c if (maven_get_reg(clnt, 0xB2) < 0x14) { clnt 1235 drivers/video/fbdev/matrox/matroxfb_maven.c static int maven_shutdown_client(struct i2c_client* clnt) { clnt 1236 drivers/video/fbdev/matrox/matroxfb_maven.c struct maven_data* md = i2c_get_clientdata(clnt); clnt 142 fs/9p/fid.c fid = p9_client_attach(v9ses->clnt, NULL, uname, uid, clnt 152 fs/9p/v9fs.c return p9_show_client_options(m, v9ses->clnt); clnt 406 fs/9p/v9fs.c v9ses->clnt = p9_client_create(dev_name, data); clnt 407 fs/9p/v9fs.c if (IS_ERR(v9ses->clnt)) { clnt 408 fs/9p/v9fs.c rc = PTR_ERR(v9ses->clnt); clnt 415 fs/9p/v9fs.c if (p9_is_proto_dotl(v9ses->clnt)) { clnt 418 fs/9p/v9fs.c } else if (p9_is_proto_dotu(v9ses->clnt)) { clnt 426 fs/9p/v9fs.c v9ses->maxdata = v9ses->clnt->msize - P9_IOHDRSZ; clnt 455 fs/9p/v9fs.c fid = p9_client_attach(v9ses->clnt, NULL, v9ses->uname, INVALID_UID, clnt 482 fs/9p/v9fs.c p9_client_destroy(v9ses->clnt); clnt 497 fs/9p/v9fs.c if (v9ses->clnt) { clnt 498 fs/9p/v9fs.c p9_client_destroy(v9ses->clnt); clnt 499 fs/9p/v9fs.c v9ses->clnt = NULL; clnt 525 fs/9p/v9fs.c p9_client_disconnect(v9ses->clnt); clnt 538 fs/9p/v9fs.c p9_client_begin_disconnect(v9ses->clnt); clnt 101 fs/9p/v9fs.h struct p9_client *clnt; /* 9p client */ clnt 99 fs/9p/vfs_dir.c buflen = fid->clnt->msize - P9_IOHDRSZ; clnt 123 fs/9p/vfs_dir.c err = p9stat_read(fid->clnt, rdir->buf + rdir->head, clnt 159 fs/9p/vfs_dir.c buflen = fid->clnt->msize - P9_READDIRHDRSZ; clnt 178 fs/9p/vfs_dir.c err = p9dirent_read(fid->clnt, rdir->buf + rdir->head, clnt 174 fs/9p/vfs_file.c flock.client_id = fid->clnt->name; clnt 200 fs/9p/vfs_file.c if (flock.client_id != fid->clnt->name) { clnt 202 fs/9p/vfs_file.c flock.client_id = fid->clnt->name; clnt 235 fs/9p/vfs_file.c if (flock.client_id != fid->clnt->name) clnt 267 fs/9p/vfs_file.c glock.client_id = fid->clnt->name; clnt 293 fs/9p/vfs_file.c if (glock.client_id != fid->clnt->name) clnt 264 fs/lockd/clntproc.c struct rpc_clnt *clnt; clnt 282 fs/lockd/clntproc.c if ((clnt = nlm_bind_host(host)) == NULL) clnt 284 fs/lockd/clntproc.c msg.rpc_proc = &clnt->cl_procinfo[proc]; clnt 287 fs/lockd/clntproc.c if ((status = rpc_call_sync(clnt, &msg, 0)) < 0) { clnt 342 fs/lockd/clntproc.c struct rpc_clnt *clnt; clnt 354 fs/lockd/clntproc.c clnt = nlm_bind_host(host); clnt 355 fs/lockd/clntproc.c if (clnt == NULL) clnt 357 fs/lockd/clntproc.c msg->rpc_proc = &clnt->cl_procinfo[proc]; clnt 358 fs/lockd/clntproc.c task_setup_data.rpc_client = clnt; clnt 180 fs/lockd/host.c struct rpc_clnt *clnt; clnt 190 fs/lockd/host.c clnt = host->h_rpcclnt; clnt 191 fs/lockd/host.c if (clnt != NULL) clnt 192 fs/lockd/host.c rpc_shutdown_client(clnt); clnt 430 fs/lockd/host.c struct rpc_clnt *clnt; clnt 441 fs/lockd/host.c if ((clnt = host->h_rpcclnt) != NULL) { clnt 443 fs/lockd/host.c rpc_force_rebind(clnt); clnt 483 fs/lockd/host.c clnt = rpc_create(&args); clnt 484 fs/lockd/host.c if (!IS_ERR(clnt)) clnt 485 fs/lockd/host.c host->h_rpcclnt = clnt; clnt 488 fs/lockd/host.c clnt = NULL; clnt 493 fs/lockd/host.c return clnt; clnt 95 fs/lockd/mon.c struct rpc_clnt *clnt; clnt 111 fs/lockd/mon.c clnt = nsm_create(host->net, host->nodename); clnt 112 fs/lockd/mon.c if (IS_ERR(clnt)) { clnt 114 fs/lockd/mon.c "status=%ld, net=%x\n", PTR_ERR(clnt), clnt 116 fs/lockd/mon.c return PTR_ERR(clnt); clnt 119 fs/lockd/mon.c msg.rpc_proc = &clnt->cl_procinfo[proc]; clnt 120 fs/lockd/mon.c status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); clnt 124 fs/lockd/mon.c rpc_force_rebind(clnt); clnt 125 fs/lockd/mon.c status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); clnt 133 fs/lockd/mon.c rpc_shutdown_client(clnt); clnt 495 fs/nfs/client.c struct rpc_clnt *clnt = NULL; clnt 523 fs/nfs/client.c clnt = rpc_create(&args); clnt 524 fs/nfs/client.c if (IS_ERR(clnt)) { clnt 526 fs/nfs/client.c __func__, PTR_ERR(clnt)); clnt 527 fs/nfs/client.c return PTR_ERR(clnt); clnt 530 fs/nfs/client.c clnt->cl_principal = clp->cl_principal; clnt 531 fs/nfs/client.c clp->cl_rpcclient = clnt; clnt 492 fs/nfs/file.c struct rpc_clnt *clnt = NFS_CLIENT(file->f_mapping->host); clnt 496 fs/nfs/file.c return rpc_clnt_swap_activate(clnt); clnt 501 fs/nfs/file.c struct rpc_clnt *clnt = NFS_CLIENT(file->f_mapping->host); clnt 503 fs/nfs/file.c rpc_clnt_swap_deactivate(clnt); clnt 251 fs/nfs/internal.h int nfs_initiate_pgio(struct rpc_clnt *clnt, struct nfs_pgio_header *hdr, clnt 473 fs/nfs/internal.h extern int nfs_initiate_commit(struct rpc_clnt *clnt, clnt 566 fs/nfs/internal.h extern void nfs4_test_session_trunk(struct rpc_clnt *clnt, clnt 259 fs/nfs/mount_clnt.c struct rpc_clnt *clnt; clnt 268 fs/nfs/mount_clnt.c clnt = rpc_create(&args); clnt 269 fs/nfs/mount_clnt.c if (IS_ERR(clnt)) clnt 276 fs/nfs/mount_clnt.c msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; clnt 278 fs/nfs/mount_clnt.c msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; clnt 280 fs/nfs/mount_clnt.c status = rpc_call_sync(clnt, &msg, 0); clnt 281 fs/nfs/mount_clnt.c rpc_shutdown_client(clnt); clnt 290 fs/nfs/mount_clnt.c PTR_ERR(clnt)); clnt 79 fs/nfs/nfs2xdr.c static struct user_namespace *rpc_userns(const struct rpc_clnt *clnt) clnt 81 fs/nfs/nfs2xdr.c if (clnt && clnt->cl_cred) clnt 82 fs/nfs/nfs2xdr.c return clnt->cl_cred->user_ns; clnt 32 fs/nfs/nfs3proc.c nfs3_rpc_wrapper(struct rpc_clnt *clnt, struct rpc_message *msg, int flags) clnt 36 fs/nfs/nfs3proc.c res = rpc_call_sync(clnt, msg, flags); clnt 45 fs/nfs/nfs3proc.c #define rpc_call_sync(clnt, msg, flags) nfs3_rpc_wrapper(clnt, msg, flags) clnt 862 fs/nfs/nfs3proc.c struct rpc_clnt **clnt) clnt 884 fs/nfs/nfs3proc.c struct rpc_clnt **clnt) clnt 107 fs/nfs/nfs3xdr.c static struct user_namespace *rpc_userns(const struct rpc_clnt *clnt) clnt 109 fs/nfs/nfs3xdr.c if (clnt && clnt->cl_cred) clnt 110 fs/nfs/nfs3xdr.c return clnt->cl_cred->user_ns; clnt 68 fs/nfs/nfs4_fs.h void (*session_trunk)(struct rpc_clnt *clnt, clnt 1257 fs/nfs/nfs4client.c struct rpc_clnt *clnt = server->client; clnt 1270 fs/nfs/nfs4client.c error = rpc_switch_client_transport(clnt, &xargs, clnt->cl_timeout); clnt 1274 fs/nfs/nfs4client.c error = rpc_localaddr(clnt, localaddr, sizeof(address)); clnt 1284 fs/nfs/nfs4client.c clp->cl_proto, clnt->cl_timeout, clnt 155 fs/nfs/nfs4namespace.c static struct rpc_clnt *nfs_find_best_sec(struct rpc_clnt *clnt, clnt 179 fs/nfs/nfs4namespace.c new = rpc_clone_client_set_auth(clnt, pflavor); clnt 212 fs/nfs/nfs4namespace.c nfs4_negotiate_security(struct rpc_clnt *clnt, struct inode *inode, clnt 232 fs/nfs/nfs4namespace.c new = nfs_find_best_sec(clnt, NFS_SERVER(inode), flavors); clnt 1100 fs/nfs/nfs4proc.c static int nfs4_call_sync_sequence(struct rpc_clnt *clnt, clnt 1113 fs/nfs/nfs4proc.c .rpc_client = clnt, clnt 1122 fs/nfs/nfs4proc.c int nfs4_call_sync(struct rpc_clnt *clnt, clnt 1130 fs/nfs/nfs4proc.c return nfs4_call_sync_sequence(clnt, server, msg, args, res); clnt 4177 fs/nfs/nfs4proc.c static int _nfs4_proc_lookup(struct rpc_clnt *clnt, struct inode *dir, clnt 4205 fs/nfs/nfs4proc.c status = nfs4_call_sync(clnt, server, &msg, &args.seq_args, &res.seq_res, 0); clnt 4218 fs/nfs/nfs4proc.c static int nfs4_proc_lookup_common(struct rpc_clnt **clnt, struct inode *dir, clnt 4225 fs/nfs/nfs4proc.c struct rpc_clnt *client = *clnt; clnt 4241 fs/nfs/nfs4proc.c if (client != *clnt) clnt 4256 fs/nfs/nfs4proc.c *clnt = client; clnt 4257 fs/nfs/nfs4proc.c else if (client != *clnt) clnt 4295 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = NFS_CLIENT(inode); clnt 4319 fs/nfs/nfs4proc.c status = nfs4_call_sync(clnt, server, &msg, &args.seq_args, clnt 5294 fs/nfs/nfs4proc.c struct rpc_clnt **clnt) clnt 5311 fs/nfs/nfs4proc.c nfs4_state_protect_write(server->nfs_client, clnt, msg, hdr); clnt 5343 fs/nfs/nfs4proc.c struct rpc_clnt **clnt) clnt 5352 fs/nfs/nfs4proc.c nfs4_state_protect(server->nfs_client, NFS_SP4_MACH_CRED_COMMIT, clnt, msg); clnt 7469 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = server->client; clnt 7500 fs/nfs/nfs4proc.c status = nfs4_call_sync_sequence(clnt, server, &msg, clnt 7526 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = server->client; clnt 7553 fs/nfs/nfs4proc.c status = nfs4_call_sync_sequence(clnt, server, &msg, clnt 7619 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = server->client; clnt 7642 fs/nfs/nfs4proc.c status = nfs4_call_sync_sequence(clnt, server, &msg, clnt 7664 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = server->client; clnt 7683 fs/nfs/nfs4proc.c status = nfs4_call_sync_sequence(clnt, server, &msg, clnt 7744 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = NFS_SERVER(dir)->client; clnt 7764 fs/nfs/nfs4proc.c .rpc_client = clnt, clnt 7773 fs/nfs/nfs4proc.c clnt = clp->cl_rpcclient; clnt 7774 fs/nfs/nfs4proc.c task_setup.rpc_client = clnt; clnt 7782 fs/nfs/nfs4proc.c nfs4_state_protect(clp, NFS_SP4_MACH_CRED_SECINFO, &clnt, &msg); clnt 7883 fs/nfs/nfs4proc.c int nfs4_proc_bind_one_conn_to_session(struct rpc_clnt *clnt, clnt 7903 fs/nfs/nfs4proc.c .rpc_client = clnt, clnt 7916 fs/nfs/nfs4proc.c if (xprt != rcu_access_pointer(clnt->cl_xprt)) clnt 7953 fs/nfs/nfs4proc.c nfs4_proc_bind_conn_to_session_callback(struct rpc_clnt *clnt, clnt 7959 fs/nfs/nfs4proc.c return nfs4_proc_bind_one_conn_to_session(clnt, xprt, p->clp, p->cred); clnt 8326 fs/nfs/nfs4proc.c void nfs4_test_session_trunk(struct rpc_clnt *clnt, struct rpc_xprt *xprt, clnt 8351 fs/nfs/nfs4proc.c rpc_clnt_xprt_switch_add_xprt(clnt, xprt); clnt 8514 fs/nfs/nfs4proc.c struct rpc_clnt *clnt) clnt 8517 fs/nfs/nfs4proc.c unsigned int max_bc_payload = rpc_max_bc_payload(clnt); clnt 8518 fs/nfs/nfs4proc.c unsigned int max_bc_slots = rpc_num_bc_slots(clnt); clnt 9482 fs/nfs/nfs4proc.c struct rpc_clnt *clnt = server->client; clnt 9499 fs/nfs/nfs4proc.c clnt = server->nfs_client->cl_rpcclient; clnt 9500 fs/nfs/nfs4proc.c task_setup.rpc_client = clnt; clnt 2216 fs/nfs/nfs4state.c struct rpc_clnt *clnt; clnt 2222 fs/nfs/nfs4state.c clnt = clp->cl_rpcclient; clnt 2240 fs/nfs/nfs4state.c if (clnt->cl_softrtry) clnt 2256 fs/nfs/nfs4state.c if (clnt->cl_auth->au_flavor == RPC_AUTH_UNIX) clnt 2262 fs/nfs/nfs4state.c if (clnt->cl_auth->au_flavor == RPC_AUTH_UNIX) { clnt 2266 fs/nfs/nfs4state.c clnt = rpc_clone_client_set_auth(clnt, RPC_AUTH_UNIX); clnt 2267 fs/nfs/nfs4state.c if (IS_ERR(clnt)) { clnt 2268 fs/nfs/nfs4state.c status = PTR_ERR(clnt); clnt 2275 fs/nfs/nfs4state.c clnt = xchg(&clp->cl_rpcclient, clnt); clnt 2276 fs/nfs/nfs4state.c rpc_shutdown_client(clnt); clnt 2277 fs/nfs/nfs4state.c clnt = clp->cl_rpcclient; clnt 1839 fs/nfs/nfs4xdr.c struct rpc_clnt *clnt = clp->cl_rpcclient; clnt 1851 fs/nfs/nfs4xdr.c p = reserve_space(xdr, 16 + 2*28 + 20 + clnt->cl_nodelen + 12); clnt 1880 fs/nfs/nfs4xdr.c p = xdr_encode_array(p, clnt->cl_nodename, clnt->cl_nodelen); clnt 613 fs/nfs/pagelist.c int nfs_initiate_pgio(struct rpc_clnt *clnt, struct nfs_pgio_header *hdr, clnt 624 fs/nfs/pagelist.c .rpc_client = clnt, clnt 628 fs/nfs/proc.c struct rpc_clnt **clnt) clnt 642 fs/nfs/proc.c struct rpc_clnt **clnt) clnt 1689 fs/nfs/write.c int nfs_initiate_commit(struct rpc_clnt *clnt, struct nfs_commit_data *data, clnt 1703 fs/nfs/write.c .rpc_client = clnt, clnt 1243 fs/nfsd/nfs4callback.c struct rpc_clnt *clnt; clnt 1256 fs/nfsd/nfs4callback.c clnt = clp->cl_cb_client; clnt 1257 fs/nfsd/nfs4callback.c if (!clnt) { clnt 1274 fs/nfsd/nfs4callback.c rpc_call_async(clnt, &cb->cb_msg, RPC_TASK_SOFT | flags, clnt 135 include/linux/sunrpc/clnt.h void (*add_xprt_test)(struct rpc_clnt *clnt, clnt 167 include/linux/sunrpc/clnt.h struct rpc_xprt *rpc_task_get_xprt(struct rpc_clnt *clnt, clnt 183 include/linux/sunrpc/clnt.h int rpc_call_async(struct rpc_clnt *clnt, clnt 187 include/linux/sunrpc/clnt.h int rpc_call_sync(struct rpc_clnt *clnt, clnt 189 include/linux/sunrpc/clnt.h struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, clnt 203 include/linux/sunrpc/clnt.h int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, clnt 207 include/linux/sunrpc/clnt.h int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, clnt 217 include/linux/sunrpc/clnt.h void rpc_set_connect_timeout(struct rpc_clnt *clnt, clnt 230 include/linux/sunrpc/clnt.h bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt, clnt 106 include/linux/sunrpc/debug.h rpc_clnt_debugfs_register(struct rpc_clnt *clnt) clnt 112 include/linux/sunrpc/debug.h rpc_clnt_debugfs_unregister(struct rpc_clnt *clnt) clnt 95 include/linux/sunrpc/metrics.h static inline struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) { return NULL; } clnt 103 include/linux/sunrpc/metrics.h static inline void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) {} clnt 300 include/linux/sunrpc/sched.h int rpc_clnt_swap_activate(struct rpc_clnt *clnt); clnt 301 include/linux/sunrpc/sched.h void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt); clnt 304 include/linux/sunrpc/sched.h rpc_clnt_swap_activate(struct rpc_clnt *clnt) clnt 310 include/linux/sunrpc/sched.h rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) clnt 147 include/net/9p/client.h struct p9_client *clnt; clnt 176 include/net/9p/client.h int p9_show_client_options(struct seq_file *m, struct p9_client *clnt); clnt 183 include/net/9p/client.h void p9_client_destroy(struct p9_client *clnt); clnt 184 include/net/9p/client.h void p9_client_disconnect(struct p9_client *clnt); clnt 185 include/net/9p/client.h void p9_client_begin_disconnect(struct p9_client *clnt); clnt 186 include/net/9p/client.h struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid, clnt 205 include/net/9p/client.h int p9dirent_read(struct p9_client *clnt, char *buf, int len, clnt 241 include/net/9p/client.h int p9_is_proto_dotu(struct p9_client *clnt); clnt 242 include/net/9p/client.h int p9_is_proto_dotl(struct p9_client *clnt); clnt 101 include/trace/events/9p.h TP_PROTO(struct p9_client *clnt, int8_t type, int tag), clnt 103 include/trace/events/9p.h TP_ARGS(clnt, type, tag), clnt 106 include/trace/events/9p.h __field( void *, clnt ) clnt 112 include/trace/events/9p.h __entry->clnt = clnt; clnt 118 include/trace/events/9p.h (long)__entry->clnt, show_9p_op(__entry->type), clnt 123 include/trace/events/9p.h TP_PROTO(struct p9_client *clnt, int8_t type, int tag, int err), clnt 125 include/trace/events/9p.h TP_ARGS(clnt, type, tag, err), clnt 128 include/trace/events/9p.h __field( void *, clnt ) clnt 135 include/trace/events/9p.h __entry->clnt = clnt; clnt 142 include/trace/events/9p.h (long)__entry->clnt, show_9p_op(__entry->type), clnt 149 include/trace/events/9p.h TP_PROTO(struct p9_client *clnt, struct p9_fcall *pdu), clnt 151 include/trace/events/9p.h TP_ARGS(clnt, pdu), clnt 154 include/trace/events/9p.h __field( void *, clnt ) clnt 161 include/trace/events/9p.h __entry->clnt = clnt; clnt 167 include/trace/events/9p.h (unsigned long)__entry->clnt, show_9p_op(__entry->type), clnt 54 net/9p/client.c inline int p9_is_proto_dotl(struct p9_client *clnt) clnt 56 net/9p/client.c return clnt->proto_version == p9_proto_2000L; clnt 60 net/9p/client.c inline int p9_is_proto_dotu(struct p9_client *clnt) clnt 62 net/9p/client.c return clnt->proto_version == p9_proto_2000u; clnt 66 net/9p/client.c int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) clnt 68 net/9p/client.c if (clnt->msize != 8192) clnt 69 net/9p/client.c seq_printf(m, ",msize=%u", clnt->msize); clnt 70 net/9p/client.c seq_printf(m, ",trans=%s", clnt->trans_mod->name); clnt 72 net/9p/client.c switch (clnt->proto_version) { clnt 84 net/9p/client.c if (clnt->trans_mod->show_options) clnt 85 net/9p/client.c return clnt->trans_mod->show_options(m, clnt); clnt 132 net/9p/client.c static int parse_opts(char *opts, struct p9_client *clnt) clnt 141 net/9p/client.c clnt->proto_version = p9_proto_2000L; clnt 142 net/9p/client.c clnt->msize = 8192; clnt 175 net/9p/client.c clnt->msize = option; clnt 186 net/9p/client.c v9fs_put_trans(clnt->trans_mod); clnt 187 net/9p/client.c clnt->trans_mod = v9fs_get_trans_by_name(s); clnt 188 net/9p/client.c if (clnt->trans_mod == NULL) { clnt 196 net/9p/client.c clnt->proto_version = p9_proto_legacy; clnt 210 net/9p/client.c clnt->proto_version = r; clnt 220 net/9p/client.c v9fs_put_trans(clnt->trans_mod); clnt 888 net/9p/client.c static struct p9_fid *p9_fid_create(struct p9_client *clnt) clnt 893 net/9p/client.c p9_debug(P9_DEBUG_FID, "clnt %p\n", clnt); clnt 901 net/9p/client.c fid->clnt = clnt; clnt 906 net/9p/client.c spin_lock_irq(&clnt->lock); clnt 907 net/9p/client.c ret = idr_alloc_u32(&clnt->fids, fid, &fid->fid, P9_NOFID - 1, clnt 909 net/9p/client.c spin_unlock_irq(&clnt->lock); clnt 921 net/9p/client.c struct p9_client *clnt; clnt 925 net/9p/client.c clnt = fid->clnt; clnt 926 net/9p/client.c spin_lock_irqsave(&clnt->lock, flags); clnt 927 net/9p/client.c idr_remove(&clnt->fids, fid->fid); clnt 928 net/9p/client.c spin_unlock_irqrestore(&clnt->lock, flags); clnt 1003 net/9p/client.c struct p9_client *clnt; clnt 1007 net/9p/client.c clnt = kmalloc(sizeof(struct p9_client), GFP_KERNEL); clnt 1008 net/9p/client.c if (!clnt) clnt 1011 net/9p/client.c clnt->trans_mod = NULL; clnt 1012 net/9p/client.c clnt->trans = NULL; clnt 1013 net/9p/client.c clnt->fcall_cache = NULL; clnt 1016 net/9p/client.c memcpy(clnt->name, client_id, strlen(client_id) + 1); clnt 1018 net/9p/client.c spin_lock_init(&clnt->lock); clnt 1019 net/9p/client.c idr_init(&clnt->fids); clnt 1020 net/9p/client.c idr_init(&clnt->reqs); clnt 1022 net/9p/client.c err = parse_opts(options, clnt); clnt 1026 net/9p/client.c if (!clnt->trans_mod) clnt 1027 net/9p/client.c clnt->trans_mod = v9fs_get_default_trans(); clnt 1029 net/9p/client.c if (clnt->trans_mod == NULL) { clnt 1037 net/9p/client.c clnt, clnt->trans_mod, clnt->msize, clnt->proto_version); clnt 1039 net/9p/client.c err = clnt->trans_mod->create(clnt, dev_name, options); clnt 1043 net/9p/client.c if (clnt->msize > clnt->trans_mod->maxsize) clnt 1044 net/9p/client.c clnt->msize = clnt->trans_mod->maxsize; clnt 1046 net/9p/client.c if (clnt->msize < 4096) { clnt 1053 net/9p/client.c err = p9_client_version(clnt); clnt 1060 net/9p/client.c clnt->fcall_cache = clnt 1061 net/9p/client.c kmem_cache_create_usercopy("9p-fcall-cache", clnt->msize, clnt 1063 net/9p/client.c clnt->msize - (P9_HDRSZ + 4), clnt 1066 net/9p/client.c return clnt; clnt 1069 net/9p/client.c clnt->trans_mod->close(clnt); clnt 1071 net/9p/client.c v9fs_put_trans(clnt->trans_mod); clnt 1073 net/9p/client.c kfree(clnt); clnt 1078 net/9p/client.c void p9_client_destroy(struct p9_client *clnt) clnt 1083 net/9p/client.c p9_debug(P9_DEBUG_MUX, "clnt %p\n", clnt); clnt 1085 net/9p/client.c if (clnt->trans_mod) clnt 1086 net/9p/client.c clnt->trans_mod->close(clnt); clnt 1088 net/9p/client.c v9fs_put_trans(clnt->trans_mod); clnt 1090 net/9p/client.c idr_for_each_entry(&clnt->fids, fid, id) { clnt 1095 net/9p/client.c p9_tag_cleanup(clnt); clnt 1097 net/9p/client.c kmem_cache_destroy(clnt->fcall_cache); clnt 1098 net/9p/client.c kfree(clnt); clnt 1102 net/9p/client.c void p9_client_disconnect(struct p9_client *clnt) clnt 1104 net/9p/client.c p9_debug(P9_DEBUG_9P, "clnt %p\n", clnt); clnt 1105 net/9p/client.c clnt->status = Disconnected; clnt 1109 net/9p/client.c void p9_client_begin_disconnect(struct p9_client *clnt) clnt 1111 net/9p/client.c p9_debug(P9_DEBUG_9P, "clnt %p\n", clnt); clnt 1112 net/9p/client.c clnt->status = BeginDisconnect; clnt 1116 net/9p/client.c struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid, clnt 1127 net/9p/client.c fid = p9_fid_create(clnt); clnt 1134 net/9p/client.c req = p9_client_rpc(clnt, P9_TATTACH, "ddss?u", fid->fid, clnt 1141 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Q", &qid); clnt 1143 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1144 net/9p/client.c p9_tag_remove(clnt, req); clnt 1153 net/9p/client.c p9_tag_remove(clnt, req); clnt 1167 net/9p/client.c struct p9_client *clnt; clnt 1175 net/9p/client.c clnt = oldfid->clnt; clnt 1177 net/9p/client.c fid = p9_fid_create(clnt); clnt 1191 net/9p/client.c req = p9_client_rpc(clnt, P9_TWALK, "ddT", oldfid->fid, fid->fid, clnt 1198 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "R", &nwqids, &wqids); clnt 1200 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1201 net/9p/client.c p9_tag_remove(clnt, req); clnt 1204 net/9p/client.c p9_tag_remove(clnt, req); clnt 1243 net/9p/client.c struct p9_client *clnt; clnt 1248 net/9p/client.c clnt = fid->clnt; clnt 1250 net/9p/client.c p9_is_proto_dotl(clnt) ? "TLOPEN" : "TOPEN", fid->fid, mode); clnt 1256 net/9p/client.c if (p9_is_proto_dotl(clnt)) clnt 1257 net/9p/client.c req = p9_client_rpc(clnt, P9_TLOPEN, "dd", fid->fid, mode); clnt 1259 net/9p/client.c req = p9_client_rpc(clnt, P9_TOPEN, "db", fid->fid, mode); clnt 1265 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Qd", &qid, &iounit); clnt 1267 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1272 net/9p/client.c p9_is_proto_dotl(clnt) ? "RLOPEN" : "ROPEN", qid.type, clnt 1279 net/9p/client.c p9_tag_remove(clnt, req); clnt 1289 net/9p/client.c struct p9_client *clnt; clnt 1297 net/9p/client.c clnt = ofid->clnt; clnt 1302 net/9p/client.c req = p9_client_rpc(clnt, P9_TLCREATE, "dsddg", ofid->fid, name, flags, clnt 1309 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Qd", qid, &iounit); clnt 1311 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1324 net/9p/client.c p9_tag_remove(clnt, req); clnt 1334 net/9p/client.c struct p9_client *clnt; clnt 1342 net/9p/client.c clnt = fid->clnt; clnt 1347 net/9p/client.c req = p9_client_rpc(clnt, P9_TCREATE, "dsdb?s", fid->fid, name, perm, clnt 1354 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Qd", &qid, &iounit); clnt 1356 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1369 net/9p/client.c p9_tag_remove(clnt, req); clnt 1379 net/9p/client.c struct p9_client *clnt; clnt 1384 net/9p/client.c clnt = dfid->clnt; clnt 1386 net/9p/client.c req = p9_client_rpc(clnt, P9_TSYMLINK, "dssg", dfid->fid, name, symtgt, clnt 1393 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Q", qid); clnt 1395 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1403 net/9p/client.c p9_tag_remove(clnt, req); clnt 1411 net/9p/client.c struct p9_client *clnt; clnt 1416 net/9p/client.c clnt = dfid->clnt; clnt 1417 net/9p/client.c req = p9_client_rpc(clnt, P9_TLINK, "dds", dfid->fid, oldfid->fid, clnt 1423 net/9p/client.c p9_tag_remove(clnt, req); clnt 1431 net/9p/client.c struct p9_client *clnt; clnt 1437 net/9p/client.c clnt = fid->clnt; clnt 1439 net/9p/client.c req = p9_client_rpc(clnt, P9_TFSYNC, "dd", fid->fid, datasync); clnt 1447 net/9p/client.c p9_tag_remove(clnt, req); clnt 1457 net/9p/client.c struct p9_client *clnt; clnt 1472 net/9p/client.c clnt = fid->clnt; clnt 1474 net/9p/client.c req = p9_client_rpc(clnt, P9_TCLUNK, "d", fid->fid); clnt 1482 net/9p/client.c p9_tag_remove(clnt, req); clnt 1501 net/9p/client.c struct p9_client *clnt; clnt 1506 net/9p/client.c clnt = fid->clnt; clnt 1508 net/9p/client.c req = p9_client_rpc(clnt, P9_TREMOVE, "d", fid->fid); clnt 1516 net/9p/client.c p9_tag_remove(clnt, req); clnt 1530 net/9p/client.c struct p9_client *clnt; clnt 1535 net/9p/client.c clnt = dfid->clnt; clnt 1536 net/9p/client.c req = p9_client_rpc(clnt, P9_TUNLINKAT, "dsd", dfid->fid, name, flags); clnt 1543 net/9p/client.c p9_tag_remove(clnt, req); clnt 1552 net/9p/client.c struct p9_client *clnt = fid->clnt; clnt 1566 net/9p/client.c if (!rsize || rsize > clnt->msize-P9_IOHDRSZ) clnt 1567 net/9p/client.c rsize = clnt->msize - P9_IOHDRSZ; clnt 1573 net/9p/client.c if (clnt->trans_mod->zc_request && rsize > 1024) { clnt 1578 net/9p/client.c req = p9_client_zc_rpc(clnt, P9_TREAD, to, NULL, rsize, clnt 1583 net/9p/client.c req = p9_client_rpc(clnt, P9_TREAD, "dqd", fid->fid, offset, clnt 1591 net/9p/client.c *err = p9pdu_readf(&req->rc, clnt->proto_version, clnt 1594 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1595 net/9p/client.c p9_tag_remove(clnt, req); clnt 1605 net/9p/client.c p9_tag_remove(clnt, req); clnt 1615 net/9p/client.c p9_tag_remove(clnt, req); clnt 1623 net/9p/client.c p9_tag_remove(clnt, req); clnt 1632 net/9p/client.c struct p9_client *clnt = fid->clnt; clnt 1644 net/9p/client.c if (!rsize || rsize > clnt->msize-P9_IOHDRSZ) clnt 1645 net/9p/client.c rsize = clnt->msize - P9_IOHDRSZ; clnt 1651 net/9p/client.c if (clnt->trans_mod->zc_request && rsize > 1024) { clnt 1652 net/9p/client.c req = p9_client_zc_rpc(clnt, P9_TWRITE, NULL, from, 0, clnt 1656 net/9p/client.c req = p9_client_rpc(clnt, P9_TWRITE, "dqV", fid->fid, clnt 1664 net/9p/client.c *err = p9pdu_readf(&req->rc, clnt->proto_version, "d", &count); clnt 1666 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1667 net/9p/client.c p9_tag_remove(clnt, req); clnt 1677 net/9p/client.c p9_tag_remove(clnt, req); clnt 1689 net/9p/client.c struct p9_client *clnt; clnt 1700 net/9p/client.c clnt = fid->clnt; clnt 1702 net/9p/client.c req = p9_client_rpc(clnt, P9_TSTAT, "d", fid->fid); clnt 1708 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "wS", &ignored, ret); clnt 1710 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1711 net/9p/client.c p9_tag_remove(clnt, req); clnt 1728 net/9p/client.c p9_tag_remove(clnt, req); clnt 1741 net/9p/client.c struct p9_client *clnt; clnt 1753 net/9p/client.c clnt = fid->clnt; clnt 1755 net/9p/client.c req = p9_client_rpc(clnt, P9_TGETATTR, "dq", fid->fid, request_mask); clnt 1761 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "A", ret); clnt 1763 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1764 net/9p/client.c p9_tag_remove(clnt, req); clnt 1789 net/9p/client.c p9_tag_remove(clnt, req); clnt 1831 net/9p/client.c struct p9_client *clnt; clnt 1834 net/9p/client.c clnt = fid->clnt; clnt 1835 net/9p/client.c wst->size = p9_client_statsize(wst, clnt->proto_version); clnt 1850 net/9p/client.c req = p9_client_rpc(clnt, P9_TWSTAT, "dwS", fid->fid, wst->size+2, wst); clnt 1858 net/9p/client.c p9_tag_remove(clnt, req); clnt 1868 net/9p/client.c struct p9_client *clnt; clnt 1871 net/9p/client.c clnt = fid->clnt; clnt 1883 net/9p/client.c req = p9_client_rpc(clnt, P9_TSETATTR, "dI", fid->fid, p9attr); clnt 1890 net/9p/client.c p9_tag_remove(clnt, req); clnt 1900 net/9p/client.c struct p9_client *clnt; clnt 1903 net/9p/client.c clnt = fid->clnt; clnt 1907 net/9p/client.c req = p9_client_rpc(clnt, P9_TSTATFS, "d", fid->fid); clnt 1913 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "ddqqqqqqd", &sb->type, clnt 1917 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 1918 net/9p/client.c p9_tag_remove(clnt, req); clnt 1929 net/9p/client.c p9_tag_remove(clnt, req); clnt 1940 net/9p/client.c struct p9_client *clnt; clnt 1943 net/9p/client.c clnt = fid->clnt; clnt 1948 net/9p/client.c req = p9_client_rpc(clnt, P9_TRENAME, "dds", fid->fid, clnt 1957 net/9p/client.c p9_tag_remove(clnt, req); clnt 1968 net/9p/client.c struct p9_client *clnt; clnt 1971 net/9p/client.c clnt = olddirfid->clnt; clnt 1977 net/9p/client.c req = p9_client_rpc(clnt, P9_TRENAMEAT, "dsds", olddirfid->fid, clnt 1987 net/9p/client.c p9_tag_remove(clnt, req); clnt 2001 net/9p/client.c struct p9_client *clnt; clnt 2005 net/9p/client.c clnt = file_fid->clnt; clnt 2006 net/9p/client.c attr_fid = p9_fid_create(clnt); clnt 2015 net/9p/client.c req = p9_client_rpc(clnt, P9_TXATTRWALK, "dds", clnt 2021 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "q", attr_size); clnt 2023 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2024 net/9p/client.c p9_tag_remove(clnt, req); clnt 2027 net/9p/client.c p9_tag_remove(clnt, req); clnt 2047 net/9p/client.c struct p9_client *clnt; clnt 2053 net/9p/client.c clnt = fid->clnt; clnt 2054 net/9p/client.c req = p9_client_rpc(clnt, P9_TXATTRCREATE, "dsqd", clnt 2061 net/9p/client.c p9_tag_remove(clnt, req); clnt 2070 net/9p/client.c struct p9_client *clnt; clnt 2082 net/9p/client.c clnt = fid->clnt; clnt 2085 net/9p/client.c if (!rsize || rsize > clnt->msize-P9_READDIRHDRSZ) clnt 2086 net/9p/client.c rsize = clnt->msize - P9_READDIRHDRSZ; clnt 2092 net/9p/client.c if (clnt->trans_mod->zc_request && rsize > 1024) { clnt 2097 net/9p/client.c req = p9_client_zc_rpc(clnt, P9_TREADDIR, &to, NULL, rsize, 0, clnt 2101 net/9p/client.c req = p9_client_rpc(clnt, P9_TREADDIR, "dqd", fid->fid, clnt 2109 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "D", &count, &dataptr); clnt 2111 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2124 net/9p/client.c p9_tag_remove(clnt, req); clnt 2128 net/9p/client.c p9_tag_remove(clnt, req); clnt 2138 net/9p/client.c struct p9_client *clnt; clnt 2142 net/9p/client.c clnt = fid->clnt; clnt 2145 net/9p/client.c req = p9_client_rpc(clnt, P9_TMKNOD, "dsdddg", fid->fid, name, mode, clnt 2150 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Q", qid); clnt 2152 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2159 net/9p/client.c p9_tag_remove(clnt, req); clnt 2169 net/9p/client.c struct p9_client *clnt; clnt 2173 net/9p/client.c clnt = fid->clnt; clnt 2176 net/9p/client.c req = p9_client_rpc(clnt, P9_TMKDIR, "dsdg", fid->fid, name, mode, clnt 2181 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "Q", qid); clnt 2183 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2190 net/9p/client.c p9_tag_remove(clnt, req); clnt 2199 net/9p/client.c struct p9_client *clnt; clnt 2203 net/9p/client.c clnt = fid->clnt; clnt 2209 net/9p/client.c req = p9_client_rpc(clnt, P9_TLOCK, "dbdqqds", fid->fid, flock->type, clnt 2216 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "b", status); clnt 2218 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2223 net/9p/client.c p9_tag_remove(clnt, req); clnt 2232 net/9p/client.c struct p9_client *clnt; clnt 2236 net/9p/client.c clnt = fid->clnt; clnt 2241 net/9p/client.c req = p9_client_rpc(clnt, P9_TGETLOCK, "dbqqds", fid->fid, glock->type, clnt 2247 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "bqqds", &glock->type, clnt 2251 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2258 net/9p/client.c p9_tag_remove(clnt, req); clnt 2266 net/9p/client.c struct p9_client *clnt; clnt 2270 net/9p/client.c clnt = fid->clnt; clnt 2273 net/9p/client.c req = p9_client_rpc(clnt, P9_TREADLINK, "d", fid->fid); clnt 2277 net/9p/client.c err = p9pdu_readf(&req->rc, clnt->proto_version, "s", target); clnt 2279 net/9p/client.c trace_9p_protocol_dump(clnt, &req->rc); clnt 2284 net/9p/client.c p9_tag_remove(clnt, req); clnt 545 net/9p/protocol.c int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) clnt 555 net/9p/protocol.c ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); clnt 558 net/9p/protocol.c trace_9p_protocol_dump(clnt, &fake_pdu); clnt 572 net/9p/protocol.c int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) clnt 581 net/9p/protocol.c trace_9p_protocol_dump(clnt, pdu); clnt 594 net/9p/protocol.c int p9dirent_read(struct p9_client *clnt, char *buf, int len, clnt 606 net/9p/protocol.c ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, clnt 610 net/9p/protocol.c trace_9p_protocol_dump(clnt, &fake_pdu); clnt 17 net/9p/protocol.h int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu); clnt 717 net/9p/trans_fd.c static int p9_fd_show_options(struct seq_file *m, struct p9_client *clnt) clnt 719 net/9p/trans_fd.c if (clnt->trans_mod == &p9_tcp_trans) { clnt 720 net/9p/trans_fd.c if (clnt->trans_opts.tcp.port != P9_PORT) clnt 721 net/9p/trans_fd.c seq_printf(m, ",port=%u", clnt->trans_opts.tcp.port); clnt 722 net/9p/trans_fd.c } else if (clnt->trans_mod == &p9_fd_trans) { clnt 723 net/9p/trans_fd.c if (clnt->trans_opts.fd.rfd != ~0) clnt 724 net/9p/trans_fd.c seq_printf(m, ",rfd=%u", clnt->trans_opts.fd.rfd); clnt 725 net/9p/trans_fd.c if (clnt->trans_opts.fd.wfd != ~0) clnt 726 net/9p/trans_fd.c seq_printf(m, ",wfd=%u", clnt->trans_opts.fd.wfd); clnt 150 net/9p/trans_rdma.c static int p9_rdma_show_options(struct seq_file *m, struct p9_client *clnt) clnt 152 net/9p/trans_rdma.c struct p9_trans_rdma *rdma = clnt->trans; clnt 274 net/sunrpc/auth.c rpcauth_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) clnt 284 net/sunrpc/auth.c auth = ops->create(args, clnt); clnt 289 net/sunrpc/auth.c if (clnt->cl_auth) clnt 290 net/sunrpc/auth.c rpcauth_release(clnt->cl_auth); clnt 291 net/sunrpc/auth.c clnt->cl_auth = auth; clnt 62 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *clnt; clnt 898 net/sunrpc/auth_gss/auth_gss.c dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); clnt 910 net/sunrpc/auth_gss/auth_gss.c static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, clnt 926 net/sunrpc/auth_gss/auth_gss.c p->clnt = clnt; clnt 939 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *clnt; clnt 964 net/sunrpc/auth_gss/auth_gss.c gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); clnt 970 net/sunrpc/auth_gss/auth_gss.c static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, clnt 974 net/sunrpc/auth_gss/auth_gss.c struct net *net = rpc_net_ns(clnt); clnt 977 net/sunrpc/auth_gss/auth_gss.c .clnt = clnt, clnt 983 net/sunrpc/auth_gss/auth_gss.c &clnt->cl_pipedir_objects, clnt 994 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *clnt = p->clnt; clnt 995 net/sunrpc/auth_gss/auth_gss.c struct net *net = rpc_net_ns(clnt); clnt 998 net/sunrpc/auth_gss/auth_gss.c &clnt->cl_pipedir_objects, clnt 1022 net/sunrpc/auth_gss/auth_gss.c gss_create_new(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) clnt 1041 net/sunrpc/auth_gss/auth_gss.c gss_auth->client = clnt; clnt 1042 net/sunrpc/auth_gss/auth_gss.c gss_auth->net = get_net(rpc_net_ns(clnt)); clnt 1074 net/sunrpc/auth_gss/auth_gss.c gss_pipe = gss_pipe_get(clnt, "gssd", &gss_upcall_ops_v1); clnt 1081 net/sunrpc/auth_gss/auth_gss.c gss_pipe = gss_pipe_get(clnt, gss_auth->mech->gm_name, clnt 1166 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *clnt, clnt 1170 net/sunrpc/auth_gss/auth_gss.c unsigned long hashval = (unsigned long)clnt; clnt 1177 net/sunrpc/auth_gss/auth_gss.c if (gss_auth->client != clnt) clnt 1203 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *clnt) clnt 1208 net/sunrpc/auth_gss/auth_gss.c gss_auth = gss_auth_find_or_add_hashed(args, clnt, NULL); clnt 1211 net/sunrpc/auth_gss/auth_gss.c new = gss_create_new(args, clnt); clnt 1214 net/sunrpc/auth_gss/auth_gss.c gss_auth = gss_auth_find_or_add_hashed(args, clnt, new); clnt 1222 net/sunrpc/auth_gss/auth_gss.c gss_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) clnt 1225 net/sunrpc/auth_gss/auth_gss.c struct rpc_xprt_switch *xps = rcu_access_pointer(clnt->cl_xpi.xpi_xpswitch); clnt 1227 net/sunrpc/auth_gss/auth_gss.c while (clnt != clnt->cl_parent) { clnt 1228 net/sunrpc/auth_gss/auth_gss.c struct rpc_clnt *parent = clnt->cl_parent; clnt 1232 net/sunrpc/auth_gss/auth_gss.c clnt = parent; clnt 1235 net/sunrpc/auth_gss/auth_gss.c gss_auth = gss_create_hashed(args, clnt); clnt 103 net/sunrpc/auth_gss/gss_rpc_upcall.c struct rpc_clnt *clnt; clnt 106 net/sunrpc/auth_gss/gss_rpc_upcall.c clnt = rpc_create(&args); clnt 107 net/sunrpc/auth_gss/gss_rpc_upcall.c if (IS_ERR(clnt)) { clnt 109 net/sunrpc/auth_gss/gss_rpc_upcall.c "client (errno %ld).\n", PTR_ERR(clnt)); clnt 110 net/sunrpc/auth_gss/gss_rpc_upcall.c result = PTR_ERR(clnt); clnt 116 net/sunrpc/auth_gss/gss_rpc_upcall.c "%p)\n", clnt); clnt 117 net/sunrpc/auth_gss/gss_rpc_upcall.c *_clnt = clnt; clnt 132 net/sunrpc/auth_gss/gss_rpc_upcall.c struct rpc_clnt *clnt; clnt 136 net/sunrpc/auth_gss/gss_rpc_upcall.c ret = gssp_rpc_create(net, &clnt); clnt 140 net/sunrpc/auth_gss/gss_rpc_upcall.c sn->gssp_clnt = clnt; clnt 158 net/sunrpc/auth_gss/gss_rpc_upcall.c struct rpc_clnt *clnt; clnt 161 net/sunrpc/auth_gss/gss_rpc_upcall.c clnt = sn->gssp_clnt; clnt 162 net/sunrpc/auth_gss/gss_rpc_upcall.c if (clnt) clnt 163 net/sunrpc/auth_gss/gss_rpc_upcall.c atomic_inc(&clnt->cl_count); clnt 165 net/sunrpc/auth_gss/gss_rpc_upcall.c return clnt; clnt 171 net/sunrpc/auth_gss/gss_rpc_upcall.c struct rpc_clnt *clnt; clnt 174 net/sunrpc/auth_gss/gss_rpc_upcall.c clnt = get_gssp_clnt(sn); clnt 175 net/sunrpc/auth_gss/gss_rpc_upcall.c if (!clnt) clnt 177 net/sunrpc/auth_gss/gss_rpc_upcall.c status = rpc_call_sync(clnt, msg, 0); clnt 197 net/sunrpc/auth_gss/gss_rpc_upcall.c rpc_release_client(clnt); clnt 22 net/sunrpc/auth_null.c nul_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) clnt 29 net/sunrpc/auth_unix.c unx_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) clnt 105 net/sunrpc/auth_unix.c struct rpc_clnt *clnt = task->tk_client; clnt 110 net/sunrpc/auth_unix.c struct user_namespace *userns = clnt->cl_cred ? clnt 111 net/sunrpc/auth_unix.c clnt->cl_cred->user_ns : &init_user_ns; clnt 121 net/sunrpc/auth_unix.c if (xdr_stream_encode_opaque(xdr, clnt->cl_nodename, clnt 122 net/sunrpc/auth_unix.c clnt->cl_nodelen) < 0) clnt 81 net/sunrpc/clnt.c static int rpc_ping(struct rpc_clnt *clnt); clnt 84 net/sunrpc/clnt.c static void rpc_register_client(struct rpc_clnt *clnt) clnt 86 net/sunrpc/clnt.c struct net *net = rpc_net_ns(clnt); clnt 90 net/sunrpc/clnt.c list_add(&clnt->cl_clients, &sn->all_clients); clnt 94 net/sunrpc/clnt.c static void rpc_unregister_client(struct rpc_clnt *clnt) clnt 96 net/sunrpc/clnt.c struct net *net = rpc_net_ns(clnt); clnt 100 net/sunrpc/clnt.c list_del(&clnt->cl_clients); clnt 104 net/sunrpc/clnt.c static void __rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) clnt 106 net/sunrpc/clnt.c rpc_remove_client_dir(clnt); clnt 109 net/sunrpc/clnt.c static void rpc_clnt_remove_pipedir(struct rpc_clnt *clnt) clnt 111 net/sunrpc/clnt.c struct net *net = rpc_net_ns(clnt); clnt 116 net/sunrpc/clnt.c __rpc_clnt_remove_pipedir(clnt); clnt 122 net/sunrpc/clnt.c struct rpc_clnt *clnt) clnt 125 net/sunrpc/clnt.c const char *dir_name = clnt->cl_program->pipe_dir_name; clnt 137 net/sunrpc/clnt.c dentry = rpc_create_client_dir(dir, name, clnt); clnt 152 net/sunrpc/clnt.c rpc_setup_pipedir(struct super_block *pipefs_sb, struct rpc_clnt *clnt) clnt 156 net/sunrpc/clnt.c if (clnt->cl_program->pipe_dir_name != NULL) { clnt 157 net/sunrpc/clnt.c dentry = rpc_setup_pipedir_sb(pipefs_sb, clnt); clnt 164 net/sunrpc/clnt.c static int rpc_clnt_skip_event(struct rpc_clnt *clnt, unsigned long event) clnt 166 net/sunrpc/clnt.c if (clnt->cl_program->pipe_dir_name == NULL) clnt 171 net/sunrpc/clnt.c if (clnt->cl_pipedir_objects.pdh_dentry != NULL) clnt 173 net/sunrpc/clnt.c if (atomic_read(&clnt->cl_count) == 0) clnt 177 net/sunrpc/clnt.c if (clnt->cl_pipedir_objects.pdh_dentry == NULL) clnt 184 net/sunrpc/clnt.c static int __rpc_clnt_handle_event(struct rpc_clnt *clnt, unsigned long event, clnt 191 net/sunrpc/clnt.c dentry = rpc_setup_pipedir_sb(sb, clnt); clnt 198 net/sunrpc/clnt.c __rpc_clnt_remove_pipedir(clnt); clnt 207 net/sunrpc/clnt.c static int __rpc_pipefs_event(struct rpc_clnt *clnt, unsigned long event, clnt 212 net/sunrpc/clnt.c for (;; clnt = clnt->cl_parent) { clnt 213 net/sunrpc/clnt.c if (!rpc_clnt_skip_event(clnt, event)) clnt 214 net/sunrpc/clnt.c error = __rpc_clnt_handle_event(clnt, event, sb); clnt 215 net/sunrpc/clnt.c if (error || clnt == clnt->cl_parent) clnt 224 net/sunrpc/clnt.c struct rpc_clnt *clnt; clnt 227 net/sunrpc/clnt.c list_for_each_entry(clnt, &sn->all_clients, cl_clients) { clnt 228 net/sunrpc/clnt.c if (rpc_clnt_skip_event(clnt, event)) clnt 231 net/sunrpc/clnt.c return clnt; clnt 241 net/sunrpc/clnt.c struct rpc_clnt *clnt; clnt 244 net/sunrpc/clnt.c while ((clnt = rpc_get_client_for_event(sb->s_fs_info, event))) { clnt 245 net/sunrpc/clnt.c error = __rpc_pipefs_event(clnt, event, sb); clnt 267 net/sunrpc/clnt.c static struct rpc_xprt *rpc_clnt_set_transport(struct rpc_clnt *clnt, clnt 273 net/sunrpc/clnt.c spin_lock(&clnt->cl_lock); clnt 274 net/sunrpc/clnt.c old = rcu_dereference_protected(clnt->cl_xprt, clnt 275 net/sunrpc/clnt.c lockdep_is_held(&clnt->cl_lock)); clnt 278 net/sunrpc/clnt.c clnt->cl_autobind = 1; clnt 280 net/sunrpc/clnt.c clnt->cl_timeout = timeout; clnt 281 net/sunrpc/clnt.c rcu_assign_pointer(clnt->cl_xprt, xprt); clnt 282 net/sunrpc/clnt.c spin_unlock(&clnt->cl_lock); clnt 287 net/sunrpc/clnt.c static void rpc_clnt_set_nodename(struct rpc_clnt *clnt, const char *nodename) clnt 289 net/sunrpc/clnt.c clnt->cl_nodelen = strlcpy(clnt->cl_nodename, clnt 290 net/sunrpc/clnt.c nodename, sizeof(clnt->cl_nodename)); clnt 293 net/sunrpc/clnt.c static int rpc_client_register(struct rpc_clnt *clnt, clnt 302 net/sunrpc/clnt.c struct net *net = rpc_net_ns(clnt); clnt 306 net/sunrpc/clnt.c rpc_clnt_debugfs_register(clnt); clnt 310 net/sunrpc/clnt.c err = rpc_setup_pipedir(pipefs_sb, clnt); clnt 315 net/sunrpc/clnt.c rpc_register_client(clnt); clnt 319 net/sunrpc/clnt.c auth = rpcauth_create(&auth_args, clnt); clnt 329 net/sunrpc/clnt.c rpc_unregister_client(clnt); clnt 330 net/sunrpc/clnt.c __rpc_clnt_remove_pipedir(clnt); clnt 334 net/sunrpc/clnt.c rpc_clnt_debugfs_unregister(clnt); clnt 345 net/sunrpc/clnt.c static int rpc_alloc_clid(struct rpc_clnt *clnt) clnt 352 net/sunrpc/clnt.c clnt->cl_clid = clid; clnt 356 net/sunrpc/clnt.c static void rpc_free_clid(struct rpc_clnt *clnt) clnt 358 net/sunrpc/clnt.c ida_simple_remove(&rpc_clids, clnt->cl_clid); clnt 368 net/sunrpc/clnt.c struct rpc_clnt *clnt = NULL; clnt 389 net/sunrpc/clnt.c clnt = kzalloc(sizeof(*clnt), GFP_KERNEL); clnt 390 net/sunrpc/clnt.c if (!clnt) clnt 392 net/sunrpc/clnt.c clnt->cl_parent = parent ? : clnt; clnt 394 net/sunrpc/clnt.c err = rpc_alloc_clid(clnt); clnt 398 net/sunrpc/clnt.c clnt->cl_cred = get_cred(args->cred); clnt 399 net/sunrpc/clnt.c clnt->cl_procinfo = version->procs; clnt 400 net/sunrpc/clnt.c clnt->cl_maxproc = version->nrprocs; clnt 401 net/sunrpc/clnt.c clnt->cl_prog = args->prognumber ? : program->number; clnt 402 net/sunrpc/clnt.c clnt->cl_vers = version->number; clnt 403 net/sunrpc/clnt.c clnt->cl_stats = program->stats; clnt 404 net/sunrpc/clnt.c clnt->cl_metrics = rpc_alloc_iostats(clnt); clnt 405 net/sunrpc/clnt.c rpc_init_pipe_dir_head(&clnt->cl_pipedir_objects); clnt 407 net/sunrpc/clnt.c if (clnt->cl_metrics == NULL) clnt 409 net/sunrpc/clnt.c clnt->cl_program = program; clnt 410 net/sunrpc/clnt.c INIT_LIST_HEAD(&clnt->cl_tasks); clnt 411 net/sunrpc/clnt.c spin_lock_init(&clnt->cl_lock); clnt 415 net/sunrpc/clnt.c memcpy(&clnt->cl_timeout_default, args->timeout, clnt 416 net/sunrpc/clnt.c sizeof(clnt->cl_timeout_default)); clnt 417 net/sunrpc/clnt.c timeout = &clnt->cl_timeout_default; clnt 420 net/sunrpc/clnt.c rpc_clnt_set_transport(clnt, xprt, timeout); clnt 421 net/sunrpc/clnt.c xprt_iter_init(&clnt->cl_xpi, xps); clnt 424 net/sunrpc/clnt.c clnt->cl_rtt = &clnt->cl_rtt_default; clnt 425 net/sunrpc/clnt.c rpc_init_rtt(&clnt->cl_rtt_default, clnt->cl_timeout->to_initval); clnt 427 net/sunrpc/clnt.c atomic_set(&clnt->cl_count, 1); clnt 432 net/sunrpc/clnt.c rpc_clnt_set_nodename(clnt, nodename); clnt 434 net/sunrpc/clnt.c err = rpc_client_register(clnt, args->authflavor, args->client_name); clnt 439 net/sunrpc/clnt.c return clnt; clnt 442 net/sunrpc/clnt.c rpc_free_iostats(clnt->cl_metrics); clnt 444 net/sunrpc/clnt.c put_cred(clnt->cl_cred); clnt 445 net/sunrpc/clnt.c rpc_free_clid(clnt); clnt 447 net/sunrpc/clnt.c kfree(clnt); clnt 459 net/sunrpc/clnt.c struct rpc_clnt *clnt = NULL; clnt 477 net/sunrpc/clnt.c clnt = rpc_new_client(args, xps, xprt, NULL); clnt 478 net/sunrpc/clnt.c if (IS_ERR(clnt)) clnt 479 net/sunrpc/clnt.c return clnt; clnt 482 net/sunrpc/clnt.c int err = rpc_ping(clnt); clnt 484 net/sunrpc/clnt.c rpc_shutdown_client(clnt); clnt 489 net/sunrpc/clnt.c clnt->cl_softrtry = 1; clnt 491 net/sunrpc/clnt.c clnt->cl_softrtry = 0; clnt 493 net/sunrpc/clnt.c clnt->cl_softerr = 1; clnt 497 net/sunrpc/clnt.c clnt->cl_autobind = 1; clnt 499 net/sunrpc/clnt.c clnt->cl_noretranstimeo = 1; clnt 501 net/sunrpc/clnt.c clnt->cl_discrtry = 1; clnt 503 net/sunrpc/clnt.c clnt->cl_chatty = 1; clnt 505 net/sunrpc/clnt.c return clnt; clnt 531 net/sunrpc/clnt.c struct rpc_clnt *clnt; clnt 595 net/sunrpc/clnt.c clnt = rpc_create_xprt(args, xprt); clnt 596 net/sunrpc/clnt.c if (IS_ERR(clnt) || args->nconnect <= 1) clnt 597 net/sunrpc/clnt.c return clnt; clnt 600 net/sunrpc/clnt.c if (rpc_clnt_add_xprt(clnt, &xprtargs, NULL, NULL) < 0) clnt 603 net/sunrpc/clnt.c return clnt; clnt 613 net/sunrpc/clnt.c struct rpc_clnt *clnt) clnt 622 net/sunrpc/clnt.c xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); clnt 623 net/sunrpc/clnt.c xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); clnt 631 net/sunrpc/clnt.c args->nodename = clnt->cl_nodename; clnt 633 net/sunrpc/clnt.c new = rpc_new_client(args, xps, xprt, clnt); clnt 641 net/sunrpc/clnt.c new->cl_softrtry = clnt->cl_softrtry; clnt 642 net/sunrpc/clnt.c new->cl_softerr = clnt->cl_softerr; clnt 643 net/sunrpc/clnt.c new->cl_noretranstimeo = clnt->cl_noretranstimeo; clnt 644 net/sunrpc/clnt.c new->cl_discrtry = clnt->cl_discrtry; clnt 645 net/sunrpc/clnt.c new->cl_chatty = clnt->cl_chatty; clnt 646 net/sunrpc/clnt.c new->cl_principal = clnt->cl_principal; clnt 661 net/sunrpc/clnt.c struct rpc_clnt *rpc_clone_client(struct rpc_clnt *clnt) clnt 664 net/sunrpc/clnt.c .program = clnt->cl_program, clnt 665 net/sunrpc/clnt.c .prognumber = clnt->cl_prog, clnt 666 net/sunrpc/clnt.c .version = clnt->cl_vers, clnt 667 net/sunrpc/clnt.c .authflavor = clnt->cl_auth->au_flavor, clnt 668 net/sunrpc/clnt.c .cred = clnt->cl_cred, clnt 670 net/sunrpc/clnt.c return __rpc_clone_client(&args, clnt); clnt 683 net/sunrpc/clnt.c rpc_clone_client_set_auth(struct rpc_clnt *clnt, rpc_authflavor_t flavor) clnt 686 net/sunrpc/clnt.c .program = clnt->cl_program, clnt 687 net/sunrpc/clnt.c .prognumber = clnt->cl_prog, clnt 688 net/sunrpc/clnt.c .version = clnt->cl_vers, clnt 690 net/sunrpc/clnt.c .cred = clnt->cl_cred, clnt 692 net/sunrpc/clnt.c return __rpc_clone_client(&args, clnt); clnt 711 net/sunrpc/clnt.c int rpc_switch_client_transport(struct rpc_clnt *clnt, clnt 725 net/sunrpc/clnt.c clnt); clnt 735 net/sunrpc/clnt.c pseudoflavor = clnt->cl_auth->au_flavor; clnt 737 net/sunrpc/clnt.c old_timeo = clnt->cl_timeout; clnt 738 net/sunrpc/clnt.c old = rpc_clnt_set_transport(clnt, xprt, timeout); clnt 739 net/sunrpc/clnt.c oldxps = xprt_iter_xchg_switch(&clnt->cl_xpi, xps); clnt 741 net/sunrpc/clnt.c rpc_unregister_client(clnt); clnt 742 net/sunrpc/clnt.c __rpc_clnt_remove_pipedir(clnt); clnt 743 net/sunrpc/clnt.c rpc_clnt_debugfs_unregister(clnt); clnt 750 net/sunrpc/clnt.c parent = clnt->cl_parent; clnt 751 net/sunrpc/clnt.c clnt->cl_parent = clnt; clnt 758 net/sunrpc/clnt.c err = rpc_client_register(clnt, pseudoflavor, NULL); clnt 763 net/sunrpc/clnt.c if (parent != clnt) clnt 767 net/sunrpc/clnt.c dprintk("RPC: replaced xprt for clnt %p\n", clnt); clnt 771 net/sunrpc/clnt.c xps = xprt_iter_xchg_switch(&clnt->cl_xpi, oldxps); clnt 772 net/sunrpc/clnt.c rpc_clnt_set_transport(clnt, old, old_timeo); clnt 773 net/sunrpc/clnt.c clnt->cl_parent = parent; clnt 774 net/sunrpc/clnt.c rpc_client_register(clnt, pseudoflavor, NULL); clnt 777 net/sunrpc/clnt.c dprintk("RPC: failed to switch xprt for clnt %p\n", clnt); clnt 783 net/sunrpc/clnt.c int rpc_clnt_xprt_iter_init(struct rpc_clnt *clnt, struct rpc_xprt_iter *xpi) clnt 788 net/sunrpc/clnt.c xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); clnt 808 net/sunrpc/clnt.c int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, clnt 815 net/sunrpc/clnt.c ret = rpc_clnt_xprt_iter_init(clnt, &xpi); clnt 823 net/sunrpc/clnt.c ret = fn(clnt, xprt, data); clnt 837 net/sunrpc/clnt.c void rpc_killall_tasks(struct rpc_clnt *clnt) clnt 842 net/sunrpc/clnt.c if (list_empty(&clnt->cl_tasks)) clnt 844 net/sunrpc/clnt.c dprintk("RPC: killing all tasks for client %p\n", clnt); clnt 848 net/sunrpc/clnt.c spin_lock(&clnt->cl_lock); clnt 849 net/sunrpc/clnt.c list_for_each_entry(rovr, &clnt->cl_tasks, tk_task) clnt 851 net/sunrpc/clnt.c spin_unlock(&clnt->cl_lock); clnt 859 net/sunrpc/clnt.c void rpc_shutdown_client(struct rpc_clnt *clnt) clnt 864 net/sunrpc/clnt.c clnt->cl_program->name, clnt 865 net/sunrpc/clnt.c rcu_dereference(clnt->cl_xprt)->servername); clnt 867 net/sunrpc/clnt.c while (!list_empty(&clnt->cl_tasks)) { clnt 868 net/sunrpc/clnt.c rpc_killall_tasks(clnt); clnt 870 net/sunrpc/clnt.c list_empty(&clnt->cl_tasks), 1*HZ); clnt 873 net/sunrpc/clnt.c rpc_release_client(clnt); clnt 881 net/sunrpc/clnt.c rpc_free_client(struct rpc_clnt *clnt) clnt 886 net/sunrpc/clnt.c clnt->cl_program->name, clnt 887 net/sunrpc/clnt.c rcu_dereference(clnt->cl_xprt)->servername); clnt 888 net/sunrpc/clnt.c if (clnt->cl_parent != clnt) clnt 889 net/sunrpc/clnt.c parent = clnt->cl_parent; clnt 890 net/sunrpc/clnt.c rpc_clnt_debugfs_unregister(clnt); clnt 891 net/sunrpc/clnt.c rpc_clnt_remove_pipedir(clnt); clnt 892 net/sunrpc/clnt.c rpc_unregister_client(clnt); clnt 893 net/sunrpc/clnt.c rpc_free_iostats(clnt->cl_metrics); clnt 894 net/sunrpc/clnt.c clnt->cl_metrics = NULL; clnt 895 net/sunrpc/clnt.c xprt_put(rcu_dereference_raw(clnt->cl_xprt)); clnt 896 net/sunrpc/clnt.c xprt_iter_destroy(&clnt->cl_xpi); clnt 898 net/sunrpc/clnt.c put_cred(clnt->cl_cred); clnt 899 net/sunrpc/clnt.c rpc_free_clid(clnt); clnt 900 net/sunrpc/clnt.c kfree(clnt); clnt 908 net/sunrpc/clnt.c rpc_free_auth(struct rpc_clnt *clnt) clnt 910 net/sunrpc/clnt.c if (clnt->cl_auth == NULL) clnt 911 net/sunrpc/clnt.c return rpc_free_client(clnt); clnt 918 net/sunrpc/clnt.c atomic_inc(&clnt->cl_count); clnt 919 net/sunrpc/clnt.c rpcauth_release(clnt->cl_auth); clnt 920 net/sunrpc/clnt.c clnt->cl_auth = NULL; clnt 921 net/sunrpc/clnt.c if (atomic_dec_and_test(&clnt->cl_count)) clnt 922 net/sunrpc/clnt.c return rpc_free_client(clnt); clnt 930 net/sunrpc/clnt.c rpc_release_client(struct rpc_clnt *clnt) clnt 932 net/sunrpc/clnt.c dprintk("RPC: rpc_release_client(%p)\n", clnt); clnt 935 net/sunrpc/clnt.c if (list_empty(&clnt->cl_tasks)) clnt 937 net/sunrpc/clnt.c if (!atomic_dec_and_test(&clnt->cl_count)) clnt 939 net/sunrpc/clnt.c clnt = rpc_free_auth(clnt); clnt 940 net/sunrpc/clnt.c } while (clnt != NULL); clnt 965 net/sunrpc/clnt.c struct rpc_clnt *clnt; clnt 968 net/sunrpc/clnt.c clnt = __rpc_clone_client(&args, old); clnt 969 net/sunrpc/clnt.c if (IS_ERR(clnt)) clnt 971 net/sunrpc/clnt.c err = rpc_ping(clnt); clnt 973 net/sunrpc/clnt.c rpc_shutdown_client(clnt); clnt 974 net/sunrpc/clnt.c clnt = ERR_PTR(err); clnt 977 net/sunrpc/clnt.c return clnt; clnt 982 net/sunrpc/clnt.c rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) clnt 989 net/sunrpc/clnt.c xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); clnt 998 net/sunrpc/clnt.c rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) clnt 1004 net/sunrpc/clnt.c xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); clnt 1027 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 1030 net/sunrpc/clnt.c if (clnt != NULL) { clnt 1032 net/sunrpc/clnt.c spin_lock(&clnt->cl_lock); clnt 1034 net/sunrpc/clnt.c spin_unlock(&clnt->cl_lock); clnt 1037 net/sunrpc/clnt.c rpc_release_client(clnt); clnt 1042 net/sunrpc/clnt.c rpc_task_get_first_xprt(struct rpc_clnt *clnt) clnt 1047 net/sunrpc/clnt.c xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); clnt 1049 net/sunrpc/clnt.c return rpc_task_get_xprt(clnt, xprt); clnt 1053 net/sunrpc/clnt.c rpc_task_get_next_xprt(struct rpc_clnt *clnt) clnt 1055 net/sunrpc/clnt.c return rpc_task_get_xprt(clnt, xprt_iter_get_next(&clnt->cl_xpi)); clnt 1059 net/sunrpc/clnt.c void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt) clnt 1064 net/sunrpc/clnt.c task->tk_xprt = rpc_task_get_first_xprt(clnt); clnt 1066 net/sunrpc/clnt.c task->tk_xprt = rpc_task_get_next_xprt(clnt); clnt 1070 net/sunrpc/clnt.c void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) clnt 1073 net/sunrpc/clnt.c if (clnt != NULL) { clnt 1074 net/sunrpc/clnt.c rpc_task_set_transport(task, clnt); clnt 1075 net/sunrpc/clnt.c task->tk_client = clnt; clnt 1076 net/sunrpc/clnt.c atomic_inc(&clnt->cl_count); clnt 1077 net/sunrpc/clnt.c if (clnt->cl_softrtry) clnt 1079 net/sunrpc/clnt.c if (clnt->cl_softerr) clnt 1081 net/sunrpc/clnt.c if (clnt->cl_noretranstimeo) clnt 1083 net/sunrpc/clnt.c if (atomic_read(&clnt->cl_swapper)) clnt 1086 net/sunrpc/clnt.c spin_lock(&clnt->cl_lock); clnt 1087 net/sunrpc/clnt.c list_add_tail(&task->tk_task, &clnt->cl_tasks); clnt 1088 net/sunrpc/clnt.c spin_unlock(&clnt->cl_lock); clnt 1144 net/sunrpc/clnt.c int rpc_call_sync(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags) clnt 1148 net/sunrpc/clnt.c .rpc_client = clnt, clnt 1180 net/sunrpc/clnt.c rpc_call_async(struct rpc_clnt *clnt, const struct rpc_message *msg, int flags, clnt 1185 net/sunrpc/clnt.c .rpc_client = clnt, clnt 1272 net/sunrpc/clnt.c size_t rpc_peeraddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t bufsize) clnt 1278 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1299 net/sunrpc/clnt.c const char *rpc_peeraddr2str(struct rpc_clnt *clnt, clnt 1304 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1437 net/sunrpc/clnt.c int rpc_localaddr(struct rpc_clnt *clnt, struct sockaddr *buf, size_t buflen) clnt 1447 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1464 net/sunrpc/clnt.c rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize) clnt 1469 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1481 net/sunrpc/clnt.c struct net *rpc_net_ns(struct rpc_clnt *clnt) clnt 1486 net/sunrpc/clnt.c ret = rcu_dereference(clnt->cl_xprt)->xprt_net; clnt 1501 net/sunrpc/clnt.c size_t rpc_max_payload(struct rpc_clnt *clnt) clnt 1506 net/sunrpc/clnt.c ret = rcu_dereference(clnt->cl_xprt)->max_payload; clnt 1516 net/sunrpc/clnt.c size_t rpc_max_bc_payload(struct rpc_clnt *clnt) clnt 1522 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1529 net/sunrpc/clnt.c unsigned int rpc_num_bc_slots(struct rpc_clnt *clnt) clnt 1535 net/sunrpc/clnt.c xprt = rcu_dereference(clnt->cl_xprt); clnt 1547 net/sunrpc/clnt.c void rpc_force_rebind(struct rpc_clnt *clnt) clnt 1549 net/sunrpc/clnt.c if (clnt->cl_autobind) { clnt 1551 net/sunrpc/clnt.c xprt_clear_bound(rcu_dereference(clnt->cl_xprt)); clnt 1626 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 1631 net/sunrpc/clnt.c clnt->cl_program->name, clnt->cl_vers, clnt 1636 net/sunrpc/clnt.c if (clnt->cl_program->version[clnt->cl_vers]) clnt 1637 net/sunrpc/clnt.c clnt->cl_program->version[clnt->cl_vers]->counts[idx]++; clnt 1638 net/sunrpc/clnt.c clnt->cl_stats->rpccnt++; clnt 1640 net/sunrpc/clnt.c rpc_task_set_transport(task, clnt); clnt 2103 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2115 net/sunrpc/clnt.c clnt->cl_stats->netreconn++; clnt 2129 net/sunrpc/clnt.c if (clnt->cl_autobind) { clnt 2130 net/sunrpc/clnt.c rpc_force_rebind(clnt); clnt 2351 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2387 net/sunrpc/clnt.c rpc_force_rebind(clnt); clnt 2399 net/sunrpc/clnt.c if (clnt->cl_chatty) clnt 2401 net/sunrpc/clnt.c clnt->cl_program->name, -status); clnt 2423 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2451 net/sunrpc/clnt.c if (clnt->cl_chatty) { clnt 2454 net/sunrpc/clnt.c clnt->cl_program->name, clnt 2466 net/sunrpc/clnt.c if (clnt->cl_chatty) { clnt 2469 net/sunrpc/clnt.c clnt->cl_program->name, clnt 2473 net/sunrpc/clnt.c rpc_force_rebind(clnt); clnt 2487 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2500 net/sunrpc/clnt.c if (clnt->cl_chatty) { clnt 2502 net/sunrpc/clnt.c clnt->cl_program->name, clnt 2559 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2571 net/sunrpc/clnt.c *p++ = cpu_to_be32(clnt->cl_prog); clnt 2572 net/sunrpc/clnt.c *p++ = cpu_to_be32(clnt->cl_vers); clnt 2588 net/sunrpc/clnt.c struct rpc_clnt *clnt = task->tk_client; clnt 2641 net/sunrpc/clnt.c clnt->cl_stats->rpcgarbage++; clnt 2725 net/sunrpc/clnt.c static int rpc_ping(struct rpc_clnt *clnt) clnt 2731 net/sunrpc/clnt.c err = rpc_call_sync(clnt, &msg, RPC_TASK_SOFT | RPC_TASK_SOFTCONN | clnt 2737 net/sunrpc/clnt.c struct rpc_task *rpc_call_null_helper(struct rpc_clnt *clnt, clnt 2745 net/sunrpc/clnt.c .rpc_client = clnt, clnt 2757 net/sunrpc/clnt.c struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, int flags) clnt 2759 net/sunrpc/clnt.c return rpc_call_null_helper(clnt, NULL, cred, flags, NULL, NULL); clnt 2797 net/sunrpc/clnt.c int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, clnt 2814 net/sunrpc/clnt.c task = rpc_call_null_helper(clnt, xprt, NULL, clnt 2843 net/sunrpc/clnt.c int rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt, clnt 2859 net/sunrpc/clnt.c task = rpc_call_null_helper(clnt, xprt, NULL, clnt 2873 net/sunrpc/clnt.c xtest->add_xprt_test(clnt, xprt, xtest->data); clnt 2902 net/sunrpc/clnt.c int rpc_clnt_add_xprt(struct rpc_clnt *clnt, clnt 2918 net/sunrpc/clnt.c xps = xprt_switch_get(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); clnt 2919 net/sunrpc/clnt.c xprt = xprt_iter_xprt(&clnt->cl_xpi); clnt 2943 net/sunrpc/clnt.c ret = setup(clnt, xps, xprt, data); clnt 2962 net/sunrpc/clnt.c rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt, clnt 2976 net/sunrpc/clnt.c rpc_set_connect_timeout(struct rpc_clnt *clnt, clnt 2984 net/sunrpc/clnt.c rpc_clnt_iterate_for_each_xprt(clnt, clnt 2990 net/sunrpc/clnt.c void rpc_clnt_xprt_switch_put(struct rpc_clnt *clnt) clnt 2993 net/sunrpc/clnt.c xprt_switch_put(rcu_dereference(clnt->cl_xpi.xpi_xpswitch)); clnt 2998 net/sunrpc/clnt.c void rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) clnt 3001 net/sunrpc/clnt.c rpc_xprt_switch_add_xprt(rcu_dereference(clnt->cl_xpi.xpi_xpswitch), clnt 3007 net/sunrpc/clnt.c bool rpc_clnt_xprt_switch_has_addr(struct rpc_clnt *clnt, clnt 3014 net/sunrpc/clnt.c xps = rcu_dereference(clnt->cl_xpi.xpi_xpswitch); clnt 3028 net/sunrpc/clnt.c static void rpc_show_task(const struct rpc_clnt *clnt, clnt 3038 net/sunrpc/clnt.c clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops, clnt 3039 net/sunrpc/clnt.c clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), clnt 3045 net/sunrpc/clnt.c struct rpc_clnt *clnt; clnt 3051 net/sunrpc/clnt.c list_for_each_entry(clnt, &sn->all_clients, cl_clients) { clnt 3052 net/sunrpc/clnt.c spin_lock(&clnt->cl_lock); clnt 3053 net/sunrpc/clnt.c list_for_each_entry(task, &clnt->cl_tasks, tk_task) { clnt 3058 net/sunrpc/clnt.c rpc_show_task(clnt, task); clnt 3060 net/sunrpc/clnt.c spin_unlock(&clnt->cl_lock); clnt 3068 net/sunrpc/clnt.c rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt, clnt 3076 net/sunrpc/clnt.c rpc_clnt_swap_activate(struct rpc_clnt *clnt) clnt 3078 net/sunrpc/clnt.c if (atomic_inc_return(&clnt->cl_swapper) == 1) clnt 3079 net/sunrpc/clnt.c return rpc_clnt_iterate_for_each_xprt(clnt, clnt 3086 net/sunrpc/clnt.c rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt, clnt 3095 net/sunrpc/clnt.c rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) clnt 3097 net/sunrpc/clnt.c if (atomic_dec_if_positive(&clnt->cl_swapper) == 0) clnt 3098 net/sunrpc/clnt.c rpc_clnt_iterate_for_each_xprt(clnt, clnt 24 net/sunrpc/debugfs.c struct rpc_clnt *clnt = task->tk_client; clnt 35 net/sunrpc/debugfs.c clnt->cl_clid, xid, rpc_task_timeout(task), task->tk_ops, clnt 36 net/sunrpc/debugfs.c clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), clnt 43 net/sunrpc/debugfs.c __acquires(&clnt->cl_lock) clnt 45 net/sunrpc/debugfs.c struct rpc_clnt *clnt = f->private; clnt 49 net/sunrpc/debugfs.c spin_lock(&clnt->cl_lock); clnt 50 net/sunrpc/debugfs.c list_for_each_entry(task, &clnt->cl_tasks, tk_task) clnt 59 net/sunrpc/debugfs.c struct rpc_clnt *clnt = f->private; clnt 66 net/sunrpc/debugfs.c if (next == &clnt->cl_tasks) clnt 73 net/sunrpc/debugfs.c __releases(&clnt->cl_lock) clnt 75 net/sunrpc/debugfs.c struct rpc_clnt *clnt = f->private; clnt 76 net/sunrpc/debugfs.c spin_unlock(&clnt->cl_lock); clnt 91 net/sunrpc/debugfs.c struct rpc_clnt *clnt = seq->private = inode->i_private; clnt 93 net/sunrpc/debugfs.c if (!atomic_inc_not_zero(&clnt->cl_count)) { clnt 106 net/sunrpc/debugfs.c struct rpc_clnt *clnt = seq->private; clnt 108 net/sunrpc/debugfs.c rpc_release_client(clnt); clnt 120 net/sunrpc/debugfs.c static int do_xprt_debugfs(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *numv) clnt 140 net/sunrpc/debugfs.c debugfs_create_symlink(link, clnt->cl_debugfs, name); clnt 146 net/sunrpc/debugfs.c rpc_clnt_debugfs_register(struct rpc_clnt *clnt) clnt 152 net/sunrpc/debugfs.c len = snprintf(name, sizeof(name), "%x", clnt->cl_clid); clnt 157 net/sunrpc/debugfs.c clnt->cl_debugfs = debugfs_create_dir(name, rpc_clnt_dir); clnt 160 net/sunrpc/debugfs.c debugfs_create_file("tasks", S_IFREG | 0400, clnt->cl_debugfs, clnt, clnt 163 net/sunrpc/debugfs.c rpc_clnt_iterate_for_each_xprt(clnt, do_xprt_debugfs, &xprtnum); clnt 167 net/sunrpc/debugfs.c rpc_clnt_debugfs_unregister(struct rpc_clnt *clnt) clnt 169 net/sunrpc/debugfs.c debugfs_remove_recursive(clnt->cl_debugfs); clnt 170 net/sunrpc/debugfs.c clnt->cl_debugfs = NULL; clnt 400 net/sunrpc/rpc_pipe.c struct rpc_clnt *clnt = m->private; clnt 404 net/sunrpc/rpc_pipe.c rcu_dereference(clnt->cl_xprt)->servername); clnt 405 net/sunrpc/rpc_pipe.c seq_printf(m, "service: %s (%d) version %d\n", clnt->cl_program->name, clnt 406 net/sunrpc/rpc_pipe.c clnt->cl_prog, clnt->cl_vers); clnt 407 net/sunrpc/rpc_pipe.c seq_printf(m, "address: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR)); clnt 408 net/sunrpc/rpc_pipe.c seq_printf(m, "protocol: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PROTO)); clnt 409 net/sunrpc/rpc_pipe.c seq_printf(m, "port: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PORT)); clnt 417 net/sunrpc/rpc_pipe.c struct rpc_clnt *clnt = NULL; clnt 425 net/sunrpc/rpc_pipe.c clnt = RPC_I(inode)->private; clnt 426 net/sunrpc/rpc_pipe.c if (clnt != NULL && atomic_inc_not_zero(&clnt->cl_count)) { clnt 428 net/sunrpc/rpc_pipe.c m->private = clnt; clnt 442 net/sunrpc/rpc_pipe.c struct rpc_clnt *clnt = (struct rpc_clnt *)m->private; clnt 444 net/sunrpc/rpc_pipe.c if (clnt) clnt 445 net/sunrpc/rpc_pipe.c rpc_release_client(clnt); clnt 182 net/sunrpc/rpcb_clnt.c struct rpc_clnt *clnt = sn->rpcb_local_clnt; clnt 202 net/sunrpc/rpcb_clnt.c if (clnt) clnt 203 net/sunrpc/rpcb_clnt.c rpc_shutdown_client(clnt); clnt 207 net/sunrpc/rpcb_clnt.c static void rpcb_set_local(struct net *net, struct rpc_clnt *clnt, clnt 214 net/sunrpc/rpcb_clnt.c sn->rpcb_local_clnt = clnt; clnt 254 net/sunrpc/rpcb_clnt.c struct rpc_clnt *clnt, *clnt4; clnt 262 net/sunrpc/rpcb_clnt.c clnt = rpc_create(&args); clnt 263 net/sunrpc/rpcb_clnt.c if (IS_ERR(clnt)) { clnt 265 net/sunrpc/rpcb_clnt.c "client (errno %ld).\n", PTR_ERR(clnt)); clnt 266 net/sunrpc/rpcb_clnt.c result = PTR_ERR(clnt); clnt 270 net/sunrpc/rpcb_clnt.c clnt4 = rpc_bind_new_program(clnt, &rpcb_program, RPCBVERS_4); clnt 278 net/sunrpc/rpcb_clnt.c rpcb_set_local(net, clnt, clnt4, true); clnt 307 net/sunrpc/rpcb_clnt.c struct rpc_clnt *clnt, *clnt4; clnt 310 net/sunrpc/rpcb_clnt.c clnt = rpc_create(&args); clnt 311 net/sunrpc/rpcb_clnt.c if (IS_ERR(clnt)) { clnt 313 net/sunrpc/rpcb_clnt.c "client (errno %ld).\n", PTR_ERR(clnt)); clnt 314 net/sunrpc/rpcb_clnt.c result = PTR_ERR(clnt); clnt 323 net/sunrpc/rpcb_clnt.c clnt4 = rpc_bind_new_program(clnt, &rpcb_program, RPCBVERS_4); clnt 331 net/sunrpc/rpcb_clnt.c rpcb_set_local(net, clnt, clnt4, false); clnt 396 net/sunrpc/rpcb_clnt.c static int rpcb_register_call(struct sunrpc_net *sn, struct rpc_clnt *clnt, struct rpc_message *msg, bool is_set) clnt 405 net/sunrpc/rpcb_clnt.c error = rpc_call_sync(clnt, msg, flags); clnt 654 net/sunrpc/rpcb_clnt.c static struct rpc_clnt *rpcb_find_transport_owner(struct rpc_clnt *clnt) clnt 656 net/sunrpc/rpcb_clnt.c struct rpc_clnt *parent = clnt->cl_parent; clnt 657 net/sunrpc/rpcb_clnt.c struct rpc_xprt_switch *xps = rcu_access_pointer(clnt->cl_xpi.xpi_xpswitch); clnt 659 net/sunrpc/rpcb_clnt.c while (parent != clnt) { clnt 662 net/sunrpc/rpcb_clnt.c if (clnt->cl_autobind) clnt 664 net/sunrpc/rpcb_clnt.c clnt = parent; clnt 667 net/sunrpc/rpcb_clnt.c return clnt; clnt 679 net/sunrpc/rpcb_clnt.c struct rpc_clnt *clnt; clnt 692 net/sunrpc/rpcb_clnt.c clnt = rpcb_find_transport_owner(task->tk_client); clnt 698 net/sunrpc/rpcb_clnt.c xprt->servername, clnt->cl_prog, clnt->cl_vers, xprt->prot); clnt 721 net/sunrpc/rpcb_clnt.c salen = rpc_peeraddr(clnt, sap, sizeof(addr)); clnt 751 net/sunrpc/rpcb_clnt.c clnt->cl_nodename, clnt 754 net/sunrpc/rpcb_clnt.c clnt->cl_cred); clnt 769 net/sunrpc/rpcb_clnt.c map->r_prog = clnt->cl_prog; clnt 770 net/sunrpc/rpcb_clnt.c map->r_vers = clnt->cl_vers; clnt 120 net/sunrpc/stats.c struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) clnt 125 net/sunrpc/stats.c stats = kcalloc(clnt->cl_maxproc, sizeof(*stats), GFP_KERNEL); clnt 127 net/sunrpc/stats.c for (i = 0; i < clnt->cl_maxproc; i++) clnt 243 net/sunrpc/stats.c static int do_print_stats(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *seqv) clnt 251 net/sunrpc/stats.c void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) clnt 253 net/sunrpc/stats.c unsigned int op, maxproc = clnt->cl_maxproc; clnt 255 net/sunrpc/stats.c if (!clnt->cl_metrics) clnt 260 net/sunrpc/stats.c clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); clnt 262 net/sunrpc/stats.c rpc_clnt_iterate_for_each_xprt(clnt, do_print_stats, seq); clnt 267 net/sunrpc/stats.c struct rpc_clnt *next = clnt; clnt 274 net/sunrpc/stats.c _print_rpc_iostats(seq, &stats, op, clnt->cl_procinfo); clnt 1176 net/sunrpc/xprt.c struct rpc_clnt *clnt = task->tk_client; clnt 1177 net/sunrpc/xprt.c struct rpc_rtt *rtt = clnt->cl_rtt; clnt 1179 net/sunrpc/xprt.c unsigned long max_timeout = clnt->cl_timeout->to_maxval;