/linux/net/sunrpc/ |
H A D | clnt.c | 3 * linux/net/sunrpc/clnt.c 36 #include <linux/sunrpc/clnt.h> 73 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 in rpc_unregister_client() 97 __rpc_clnt_remove_pipedir(struct rpc_clnt * clnt) __rpc_clnt_remove_pipedir() argument 102 rpc_clnt_remove_pipedir(struct rpc_clnt * clnt) rpc_clnt_remove_pipedir() argument 116 rpc_setup_pipedir_sb(struct super_block * sb,struct rpc_clnt * clnt) rpc_setup_pipedir_sb() argument 146 rpc_setup_pipedir(struct super_block * pipefs_sb,struct rpc_clnt * clnt) rpc_setup_pipedir() argument 160 rpc_clnt_skip_event(struct rpc_clnt * clnt,unsigned long event) rpc_clnt_skip_event() argument 180 __rpc_clnt_handle_event(struct rpc_clnt * clnt,unsigned long event,struct super_block * sb) __rpc_clnt_handle_event() argument 203 __rpc_pipefs_event(struct rpc_clnt * clnt,unsigned long event,struct super_block * sb) __rpc_pipefs_event() argument 220 struct rpc_clnt *clnt; rpc_get_client_for_event() local 237 struct rpc_clnt *clnt; rpc_pipefs_event() local 263 rpc_clnt_set_transport(struct rpc_clnt * clnt,struct rpc_xprt * xprt,const struct rpc_timeout * timeout) rpc_clnt_set_transport() argument 283 rpc_clnt_set_nodename(struct rpc_clnt * clnt,const char * nodename) rpc_clnt_set_nodename() argument 295 rpc_client_register(struct rpc_clnt * clnt,rpc_authflavor_t pseudoflavor,const char * client_name) rpc_client_register() argument 348 rpc_alloc_clid(struct rpc_clnt * clnt) rpc_alloc_clid() argument 359 rpc_free_clid(struct rpc_clnt * clnt) rpc_free_clid() argument 371 struct rpc_clnt *clnt = NULL; rpc_new_client() local 464 struct rpc_clnt *clnt = NULL; rpc_create_xprt() local 545 struct rpc_clnt *clnt; rpc_create() local 634 __rpc_clone_client(struct rpc_create_args * args,struct rpc_clnt * clnt) __rpc_clone_client() argument 681 rpc_clone_client(struct rpc_clnt * clnt) rpc_clone_client() argument 704 rpc_clone_client_set_auth(struct rpc_clnt * clnt,rpc_authflavor_t flavor) rpc_clone_client_set_auth() argument 733 rpc_switch_client_transport(struct rpc_clnt * clnt,struct xprt_create * args,const struct rpc_timeout * timeout) rpc_switch_client_transport() argument 803 rpc_clnt_xprt_switch_get(struct rpc_clnt * clnt) rpc_clnt_xprt_switch_get() argument 815 _rpc_clnt_xprt_iter_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi,void func (struct rpc_xprt_iter * xpi,struct rpc_xprt_switch * xps)) _rpc_clnt_xprt_iter_init() argument 829 rpc_clnt_xprt_iter_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi) rpc_clnt_xprt_iter_init() argument 835 rpc_clnt_xprt_iter_offline_init(struct rpc_clnt * clnt,struct rpc_xprt_iter * xpi) rpc_clnt_xprt_iter_offline_init() argument 852 rpc_clnt_iterate_for_each_xprt(struct rpc_clnt * clnt,int (* fn)(struct rpc_clnt *,struct rpc_xprt *,void *),void * data) rpc_clnt_iterate_for_each_xprt() argument 881 rpc_killall_tasks(struct rpc_clnt * clnt) rpc_killall_tasks() argument 910 rpc_cancel_tasks(struct rpc_clnt * clnt,int error,bool (* fnmatch)(const struct rpc_task *,const void *),const void * data) rpc_cancel_tasks() argument 937 rpc_clnt_disconnect_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_disconnect_xprt() argument 945 rpc_clnt_disconnect(struct rpc_clnt * clnt) rpc_clnt_disconnect() argument 955 rpc_shutdown_client(struct rpc_clnt * clnt) rpc_shutdown_client() argument 976 struct rpc_clnt *clnt = container_of(work, struct rpc_clnt, cl_work); rpc_free_client_work() local 994 rpc_free_client(struct rpc_clnt * clnt) rpc_free_client() argument 1016 rpc_free_auth(struct rpc_clnt * clnt) rpc_free_auth() argument 1036 rpc_release_client(struct rpc_clnt * clnt) rpc_release_client() argument 1071 struct rpc_clnt *clnt; rpc_bind_new_program() local 1088 rpc_task_get_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_task_get_xprt() argument 1104 rpc_task_release_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_task_release_xprt() argument 1133 struct rpc_clnt *clnt = task->tk_client; rpc_task_release_client() local 1148 rpc_task_get_first_xprt(struct rpc_clnt * clnt) rpc_task_get_first_xprt() argument 1159 rpc_task_get_next_xprt(struct rpc_clnt * clnt) rpc_task_get_next_xprt() argument 1165 rpc_task_set_transport(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_transport() argument 1181 rpc_task_set_client(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_client() argument 1256 rpc_call_sync(struct rpc_clnt * clnt,const struct rpc_message * msg,int flags) rpc_call_sync() argument 1292 rpc_call_async(struct rpc_clnt * clnt,const struct rpc_message * msg,int flags,const struct rpc_call_ops * tk_ops,void * data) rpc_call_async() argument 1388 rpc_peeraddr(struct rpc_clnt * clnt,struct sockaddr * buf,size_t bufsize) rpc_peeraddr() argument 1415 rpc_peeraddr2str(struct rpc_clnt * clnt,enum rpc_display_format_t format) rpc_peeraddr2str() argument 1553 rpc_localaddr(struct rpc_clnt * clnt,struct sockaddr * buf,size_t buflen) rpc_localaddr() argument 1580 rpc_setbufsize(struct rpc_clnt * clnt,unsigned int sndsize,unsigned int rcvsize) rpc_setbufsize() argument 1597 rpc_net_ns(struct rpc_clnt * clnt) rpc_net_ns() argument 1617 rpc_max_payload(struct rpc_clnt * clnt) rpc_max_payload() argument 1632 rpc_max_bc_payload(struct rpc_clnt * clnt) rpc_max_bc_payload() argument 1645 rpc_num_bc_slots(struct rpc_clnt * clnt) rpc_num_bc_slots() argument 1663 rpc_force_rebind(struct rpc_clnt * clnt) rpc_force_rebind() argument 1743 struct rpc_clnt *clnt = task->tk_client; call_start() local 2165 struct rpc_clnt *clnt = task->tk_client; call_connect_status() local 2435 struct rpc_clnt *clnt = task->tk_client; call_status() local 2510 struct rpc_clnt *clnt = task->tk_client; rpc_check_timeout() local 2572 struct rpc_clnt *clnt = task->tk_client; call_decode() local 2641 struct rpc_clnt *clnt = task->tk_client; rpc_encode_header() local 2670 struct rpc_clnt *clnt = task->tk_client; rpc_decode_header() local 2844 rpc_call_null_helper(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_cred * cred,int flags,const struct rpc_call_ops * ops,void * data) rpc_call_null_helper() argument 2865 rpc_call_null(struct rpc_clnt * clnt,struct rpc_cred * cred,int flags) rpc_call_null() argument 2871 rpc_ping(struct rpc_clnt * clnt) rpc_ping() argument 2887 rpc_ping_noreply(struct rpc_clnt * clnt) rpc_ping_noreply() argument 2944 rpc_clnt_test_and_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt_switch * xps,struct rpc_xprt * xprt,void * in_max_connect) rpc_clnt_test_and_add_xprt() argument 2985 rpc_clnt_add_xprt_helper(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_add_xprt_test * data) rpc_clnt_add_xprt_helper() argument 3027 rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt_switch * xps,struct rpc_xprt * xprt,void * data) rpc_clnt_setup_test_and_add_xprt() argument 3070 rpc_clnt_add_xprt(struct rpc_clnt * clnt,struct xprt_create * xprtargs,int (* setup)(struct rpc_clnt *,struct rpc_xprt_switch *,struct rpc_xprt *,void *),void * data) rpc_clnt_add_xprt() argument 3135 rpc_xprt_probe_trunked(struct rpc_clnt * clnt,struct rpc_xprt * xprt,struct rpc_add_xprt_test * data) rpc_xprt_probe_trunked() argument 3166 rpc_clnt_probe_trunked_xprts(struct rpc_clnt * clnt,struct rpc_add_xprt_test * data) rpc_clnt_probe_trunked_xprts() argument 3190 rpc_xprt_offline(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * data) rpc_xprt_offline() argument 3230 rpc_clnt_manage_trunked_xprts(struct rpc_clnt * clnt) rpc_clnt_manage_trunked_xprts() argument 3242 rpc_xprt_set_connect_timeout(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * data) rpc_xprt_set_connect_timeout() argument 3256 rpc_set_connect_timeout(struct rpc_clnt * clnt,unsigned long connect_timeout,unsigned long reconnect_timeout) rpc_set_connect_timeout() argument 3270 rpc_clnt_xprt_set_online(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_set_online() argument 3279 rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_switch_add_xprt() argument 3294 rpc_clnt_xprt_switch_remove_xprt(struct rpc_clnt * clnt,struct rpc_xprt * xprt) rpc_clnt_xprt_switch_remove_xprt() argument 3307 rpc_clnt_xprt_switch_has_addr(struct rpc_clnt * clnt,const struct sockaddr * sap) rpc_clnt_xprt_switch_has_addr() argument 3328 rpc_show_task(const struct rpc_clnt * clnt,const struct rpc_task * task) rpc_show_task() argument 3345 struct rpc_clnt *clnt; rpc_show_tasks() local 3368 rpc_clnt_swap_activate_callback(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_swap_activate_callback() argument 3376 rpc_clnt_swap_activate(struct rpc_clnt * clnt) rpc_clnt_swap_activate() argument 3388 rpc_clnt_swap_deactivate_callback(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * dummy) rpc_clnt_swap_deactivate_callback() argument 3397 rpc_clnt_swap_deactivate(struct rpc_clnt * clnt) rpc_clnt_swap_deactivate() argument [all...] |
H A D | debugfs.c | 10 #include <linux/sunrpc/clnt.h> 24 struct rpc_clnt *clnt = task->tk_client; in tasks_show() local 35 clnt->cl_clid, xid, rpc_task_timeout(task), task->tk_ops, in tasks_show() 36 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in tasks_show() 43 __acquires(&clnt->cl_lock) in tasks_start() 45 struct rpc_clnt *clnt = f->private; in tasks_start() local 49 spin_lock(&clnt->cl_lock); in tasks_start() 50 list_for_each_entry(task, &clnt->cl_tasks, tk_task) in tasks_start() 59 struct rpc_clnt *clnt in tasks_next() local 75 struct rpc_clnt *clnt = f->private; tasks_stop() local 91 struct rpc_clnt *clnt = seq->private = inode->i_private; tasks_open() local 106 struct rpc_clnt *clnt = seq->private; tasks_release() local 120 do_xprt_debugfs(struct rpc_clnt * clnt,struct rpc_xprt * xprt,void * numv) do_xprt_debugfs() argument 146 rpc_clnt_debugfs_register(struct rpc_clnt * clnt) rpc_clnt_debugfs_register() argument 167 rpc_clnt_debugfs_unregister(struct rpc_clnt * clnt) rpc_clnt_debugfs_unregister() argument [all...] |
H A D | rpcb_clnt.c | 181 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 D | stats.c | 124 struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) in rpc_alloc_iostats() argument 129 stats = kcalloc(clnt->cl_maxproc, sizeof(*stats), GFP_KERNEL); in rpc_alloc_iostats() 131 for (i = 0; i < clnt->cl_maxproc; i++) in rpc_alloc_iostats() 247 static int do_print_stats(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *seqv) in do_print_stats() argument 255 void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) in rpc_clnt_show_stats() argument 257 unsigned int op, maxproc = clnt->cl_maxproc; in rpc_clnt_show_stats() 259 if (!clnt->cl_metrics) in rpc_clnt_show_stats() 264 clnt->cl_prog, clnt->cl_vers, clnt->cl_program->name); in rpc_clnt_show_stats() 266 rpc_clnt_iterate_for_each_xprt(clnt, do_print_stats, seq); in rpc_clnt_show_stats() 271 struct rpc_clnt *next = clnt; in rpc_clnt_show_stats() [all …]
|
H A D | auth_unix.c | 29 unx_create(const struct rpc_auth_create_args *args, struct rpc_clnt *clnt) in unx_create() argument 113 struct rpc_clnt *clnt = task->tk_client; in unx_marshal() local 118 struct user_namespace *userns = clnt->cl_cred ? in unx_marshal() 119 clnt->cl_cred->user_ns : &init_user_ns; in unx_marshal() 129 if (xdr_stream_encode_opaque(xdr, clnt->cl_nodename, in unx_marshal() 130 clnt->cl_nodelen) < 0) in unx_marshal()
|
H A D | svcauth.c | 186 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 D | sysfs.h | 24 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, 27 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt);
|
H A D | auth_tls.c | 50 static int tls_probe(struct rpc_clnt *clnt) in tls_probe() argument 56 .rpc_client = clnt, in tls_probe() 74 struct rpc_clnt *clnt) in tls_create() argument
|
H A D | sysfs.c | 517 void rpc_sysfs_client_setup(struct rpc_clnt *clnt, in rpc_sysfs_client_setup() argument 529 net, clnt->cl_clid); in rpc_sysfs_client_setup() 534 clnt->cl_sysfs = rpc_client; in rpc_sysfs_client_setup() 535 rpc_client->clnt = clnt; in rpc_sysfs_client_setup() 590 void rpc_sysfs_client_destroy(struct rpc_clnt *clnt) in rpc_sysfs_client_destroy() argument 592 struct rpc_sysfs_client *rpc_client = clnt->cl_sysfs; in rpc_sysfs_client_destroy() 601 clnt->cl_sysfs = NULL; in rpc_sysfs_client_destroy()
|
/linux/net/9p/ |
H A D | client.c | 58 inline int p9_is_proto_dotl(struct p9_client *clnt) in p9_is_proto_dotl() argument 60 return clnt->proto_version == p9_proto_2000L; in p9_is_proto_dotl() 64 inline int p9_is_proto_dotu(struct p9_client *clnt) in p9_is_proto_dotu() argument 66 return clnt->proto_version == p9_proto_2000u; in p9_is_proto_dotu() 70 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt) in p9_show_client_options() argument 72 if (clnt->msize != DEFAULT_MSIZE) in p9_show_client_options() 73 seq_printf(m, ",msize=%u", clnt->msize); in p9_show_client_options() 74 seq_printf(m, ",trans=%s", clnt->trans_mod->name); in p9_show_client_options() 76 switch (clnt->proto_version) { in p9_show_client_options() 88 if (clnt->trans_mod->show_options) in p9_show_client_options() [all …]
|
H A D | protocol.c | 720 int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st) in p9stat_read() argument 730 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st); in p9stat_read() 733 trace_9p_protocol_dump(clnt, &fake_pdu); in p9stat_read() 747 int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu) in p9pdu_finalize() argument 756 trace_9p_protocol_dump(clnt, pdu); in p9pdu_finalize() 769 int p9dirent_read(struct p9_client *clnt, char *buf, int len, in p9dirent_read() argument 781 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid, in p9dirent_read() 785 trace_9p_protocol_dump(clnt, &fake_pdu); in p9dirent_read()
|
/linux/include/trace/events/ |
H A D | 9p.h | 125 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 D | gss_rpc_upcall.c | 104 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 D | auth_gss.c | 20 #include <linux/sunrpc/clnt.h> 79 struct rpc_clnt *clnt; member 904 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create() 916 static struct gss_pipe *gss_pipe_alloc(struct rpc_clnt *clnt, in gss_pipe_alloc() argument 932 p->clnt = clnt; in gss_pipe_alloc() 945 struct rpc_clnt *clnt; member 970 gss_pipe = gss_pipe_alloc(args->clnt, args->name, args->upcall_ops); in gss_pipe_alloc_pdo() 976 static struct gss_pipe *gss_pipe_get(struct rpc_clnt *clnt, in gss_pipe_get() argument 980 struct net *net = rpc_net_ns(clnt); in gss_pipe_get() 1000 struct rpc_clnt *clnt = p->clnt; __gss_pipe_free() local 1028 gss_create_new(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create_new() argument 1174 gss_auth_find_or_add_hashed(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt,struct gss_auth * new) gss_auth_find_or_add_hashed() argument 1211 gss_create_hashed(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create_hashed() argument 1230 gss_create(const struct rpc_auth_create_args * args,struct rpc_clnt * clnt) gss_create() argument [all...] |
/linux/include/linux/sunrpc/ |
H A D | clnt.h | 3 * linux/include/linux/sunrpc/clnt.h 36 struct rpc_clnt *clnt; member 159 void (*add_xprt_test)(struct rpc_clnt *clnt, 193 struct rpc_xprt *rpc_task_get_xprt(struct rpc_clnt *clnt, 209 int rpc_call_async(struct rpc_clnt *clnt, 213 int rpc_call_sync(struct rpc_clnt *clnt, 215 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred, 229 int rpc_clnt_iterate_for_each_xprt(struct rpc_clnt *clnt, 233 int rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, 243 void rpc_set_connect_timeout(struct rpc_clnt *clnt, [all...] |
H A D | sched.h | 231 unsigned long rpc_cancel_tasks(struct rpc_clnt *clnt, int error, 304 int rpc_clnt_swap_activate(struct rpc_clnt *clnt); 305 void rpc_clnt_swap_deactivate(struct rpc_clnt *clnt); 308 rpc_clnt_swap_activate(struct rpc_clnt *clnt) in rpc_clnt_swap_activate() argument 314 rpc_clnt_swap_deactivate(struct rpc_clnt *clnt) in rpc_clnt_swap_deactivate() argument
|
H A D | metrics.h | 95 static inline struct rpc_iostats *rpc_alloc_iostats(struct rpc_clnt *clnt) { return NULL; } in rpc_alloc_iostats() argument 103 static inline void rpc_clnt_show_stats(struct seq_file *seq, struct rpc_clnt *clnt) {} in rpc_clnt_show_stats() argument
|
/linux/include/net/9p/ |
H A D | client.h | 149 struct p9_client *clnt; member 180 int p9_show_client_options(struct seq_file *m, struct p9_client *clnt); 187 void p9_client_destroy(struct p9_client *clnt); 188 void p9_client_disconnect(struct p9_client *clnt); 189 void p9_client_begin_disconnect(struct p9_client *clnt); 190 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid, 213 int p9dirent_read(struct p9_client *clnt, char *buf, int len, 287 int p9stat_read(struct p9_client *clnt, char *buf, int len, 291 int p9_is_proto_dotu(struct p9_client *clnt); 292 int p9_is_proto_dotl(struct p9_client *clnt);
|
/linux/fs/9p/ |
H A D | v9fs.c | 152 return p9_show_client_options(m, v9ses->clnt); in v9fs_show_options() 410 v9ses->clnt = p9_client_create(dev_name, data); in v9fs_session_init() 411 if (IS_ERR(v9ses->clnt)) { in v9fs_session_init() 412 rc = PTR_ERR(v9ses->clnt); in v9fs_session_init() 419 if (p9_is_proto_dotl(v9ses->clnt)) { in v9fs_session_init() 422 } else if (p9_is_proto_dotu(v9ses->clnt)) { in v9fs_session_init() 430 v9ses->maxdata = v9ses->clnt->msize - P9_IOHDRSZ; in v9fs_session_init() 459 fid = p9_client_attach(v9ses->clnt, NULL, v9ses->uname, INVALID_UID, in v9fs_session_init() 490 p9_client_destroy(v9ses->clnt); in v9fs_session_init() 505 if (v9ses->clnt) { in v9fs_session_close() [all …]
|
H A D | vfs_dir.c | 97 buflen = fid->clnt->msize - P9_IOHDRSZ; in v9fs_dir_readdir() 122 err = p9stat_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir() 158 buflen = fid->clnt->msize - P9_READDIRHDRSZ; in v9fs_dir_readdir_dotl() 177 err = p9dirent_read(fid->clnt, rdir->buf + rdir->head, in v9fs_dir_readdir_dotl()
|
H A D | vfs_file.c | 155 flock.client_id = fid->clnt->name; in v9fs_file_do_lock() 181 if (flock.client_id != fid->clnt->name) { in v9fs_file_do_lock() 183 flock.client_id = fid->clnt->name; in v9fs_file_do_lock() 217 if (flock.client_id != fid->clnt->name) in v9fs_file_do_lock() 249 glock.client_id = fid->clnt->name; in v9fs_file_getlock() 275 if (glock.client_id != fid->clnt->name) in v9fs_file_getlock()
|
/linux/fs/lockd/ |
H A D | mon.c | 95 struct rpc_clnt *clnt; in nsm_mon_unmon() local 111 clnt = nsm_create(host->net, host->nodename); in nsm_mon_unmon() 112 if (IS_ERR(clnt)) { in nsm_mon_unmon() 114 "status=%ld, net=%x\n", PTR_ERR(clnt), in nsm_mon_unmon() 116 return PTR_ERR(clnt); in nsm_mon_unmon() 119 msg.rpc_proc = &clnt->cl_procinfo[proc]; in nsm_mon_unmon() 120 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon() 124 rpc_force_rebind(clnt); in nsm_mon_unmon() 125 status = rpc_call_sync(clnt, &msg, RPC_TASK_SOFTCONN); in nsm_mon_unmon() 133 rpc_shutdown_client(clnt); in nsm_mon_unmon()
|
H A D | host.c | 179 struct rpc_clnt *clnt; in nlm_destroy_host_locked() local 189 clnt = host->h_rpcclnt; in nlm_destroy_host_locked() 190 if (clnt != NULL) in nlm_destroy_host_locked() 191 rpc_shutdown_client(clnt); in nlm_destroy_host_locked() 429 struct rpc_clnt *clnt; in nlm_bind_host() local 440 if ((clnt = host->h_rpcclnt) != NULL) { in nlm_bind_host() 478 clnt = rpc_create(&args); in nlm_bind_host() 479 if (!IS_ERR(clnt)) in nlm_bind_host() 480 host->h_rpcclnt = clnt; in nlm_bind_host() 483 clnt = NULL; in nlm_bind_host() [all …]
|
/linux/fs/nfs/ |
H A D | mount_clnt.c | 256 struct rpc_clnt *clnt; in nfs_umount() local 265 clnt = rpc_create(&args); in nfs_umount() 266 if (IS_ERR(clnt)) in nfs_umount() 273 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC3_UMNT]; in nfs_umount() 275 msg.rpc_proc = &clnt->cl_procinfo[MOUNTPROC_UMNT]; in nfs_umount() 277 status = rpc_call_sync(clnt, &msg, 0); in nfs_umount() 278 rpc_shutdown_client(clnt); in nfs_umount() 287 PTR_ERR(clnt)); in nfs_umount()
|
H A D | sysfs.c | 225 static void shutdown_client(struct rpc_clnt *clnt) in shutdown_client() argument 227 clnt->cl_shutdown = 1; in shutdown_client() 228 rpc_cancel_tasks(clnt, -EIO, shutdown_match_client, NULL); in shutdown_client() 278 struct rpc_clnt *clnt, const char *uniq) in nfs_sysfs_link_rpc_client() argument 283 strscpy(name, clnt->cl_program->name, sizeof(name)); in nfs_sysfs_link_rpc_client() 288 &clnt->cl_sysfs->kobject, name); in nfs_sysfs_link_rpc_client()
|