Home
last modified time | relevance | path

Searched refs:rqstp (Results 1 – 25 of 44) sorted by relevance

12

/linux/net/sunrpc/
H A Dsvc.c637 svc_init_buffer(struct svc_rqst *rqstp, const struct svc_serv *serv, int node) in svc_init_buffer() argument
639 rqstp->rq_maxpages = svc_serv_maxpages(serv); in svc_init_buffer()
642 rqstp->rq_pages = kcalloc_node(rqstp->rq_maxpages + 1, in svc_init_buffer()
645 if (!rqstp->rq_pages) in svc_init_buffer()
649 rqstp->rq_respages = kcalloc_node(rqstp->rq_maxpages + 1, in svc_init_buffer()
652 if (!rqstp->rq_respages) {
653 kfree(rqstp->rq_pages);
654 rqstp
655 svc_release_buffer(struct svc_rqst * rqstp) svc_release_buffer() argument
666 svc_rqst_free(struct svc_rqst * rqstp) svc_rqst_free() argument
682 struct svc_rqst *rqstp; svc_prepare_thread() local
742 struct svc_rqst *rqstp; svc_pool_wake_idle_thread() local
777 struct svc_rqst *rqstp; svc_new_thread() local
948 svc_rqst_replace_page(struct svc_rqst * rqstp,struct page * page) svc_rqst_replace_page() argument
977 svc_rqst_release_pages(struct svc_rqst * rqstp) svc_rqst_release_pages() argument
1003 svc_exit_thread(struct svc_rqst * rqstp) svc_exit_thread() argument
1295 svc_printk(struct svc_rqst * rqstp,const char * fmt,...) svc_printk() argument
1311 svc_printk(struct svc_rqst * rqstp,const char * fmt,...) svc_printk() argument
1315 svc_generic_init_request(struct svc_rqst * rqstp,const struct svc_program * progp,struct svc_process_info * ret) svc_generic_init_request() argument
1369 svc_process_common(struct svc_rqst * rqstp) svc_process_common() argument
1566 svc_drop(struct svc_rqst * rqstp) svc_drop() argument
1571 svc_release_rqst(struct svc_rqst * rqstp) svc_release_rqst() argument
1584 svc_process(struct svc_rqst * rqstp) svc_process() argument
1642 svc_process_bc(struct rpc_rqst * req,struct svc_rqst * rqstp) svc_process_bc() argument
1722 svc_max_payload(const struct svc_rqst * rqstp) svc_max_payload() argument
1739 svc_proc_name(const struct svc_rqst * rqstp) svc_proc_name() argument
1756 svc_encode_result_payload(struct svc_rqst * rqstp,unsigned int offset,unsigned int length) svc_encode_result_payload() argument
1775 svc_fill_symlink_pathname(struct svc_rqst * rqstp,struct kvec * first,void * p,size_t total) svc_fill_symlink_pathname() argument
[all...]
H A Dsvc_xprt.c31 static int svc_deferred_recv(struct svc_rqst *rqstp);
380 * Copy the local and remote xprt addresses to the rqstp structure
382 void svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) in svc_xprt_copy_addrs() argument
384 memcpy(&rqstp->rq_addr, &xprt->xpt_remote, xprt->xpt_remotelen); in svc_xprt_copy_addrs()
385 rqstp->rq_addrlen = xprt->xpt_remotelen; in svc_xprt_copy_addrs()
391 memcpy(&rqstp->rq_daddr, &xprt->xpt_local, xprt->xpt_locallen); in svc_xprt_copy_addrs()
392 rqstp->rq_daddrlen = xprt->xpt_locallen; in svc_xprt_copy_addrs()
398 * @rqstp: svc_rqst struct containing address to print
403 char *svc_print_addr(struct svc_rqst *rqstp, char *buf, size_t len) in svc_print_addr() argument
405 return __svc_print_addr(svc_addr(rqstp), bu in svc_print_addr()
417 svc_xprt_reserve_slot(struct svc_rqst * rqstp,struct svc_xprt * xprt) svc_xprt_reserve_slot() argument
428 svc_xprt_release_slot(struct svc_rqst * rqstp) svc_xprt_release_slot() argument
521 svc_reserve(struct svc_rqst * rqstp,int space) svc_reserve() argument
545 svc_xprt_release(struct svc_rqst * rqstp) svc_xprt_release() argument
653 svc_alloc_arg(struct svc_rqst * rqstp) svc_alloc_arg() argument
691 svc_thread_should_sleep(struct svc_rqst * rqstp) svc_thread_should_sleep() argument
717 svc_thread_wait_for_work(struct svc_rqst * rqstp) svc_thread_wait_for_work() argument
763 svc_handle_xprt(struct svc_rqst * rqstp,struct svc_xprt * xprt) svc_handle_xprt() argument
826 svc_thread_wake_next(struct svc_rqst * rqstp) svc_thread_wake_next() argument
843 svc_recv(struct svc_rqst * rqstp) svc_recv() argument
898 svc_send(struct svc_rqst * rqstp) svc_send() argument
1186 struct svc_rqst *rqstp = container_of(req, struct svc_rqst, rq_chandle); svc_defer() local
1229 svc_deferred_recv(struct svc_rqst * rqstp) svc_deferred_recv() argument
[all...]
H A Dsvcsock.c139 * @ctxt: the context from rqstp->rq_xprt_ctxt or dr->xprt_ctxt
149 * @ctxt: the context from rqstp->rq_xprt_ctxt or dr->xprt_ctxt
167 static void svc_set_cmsg_data(struct svc_rqst *rqstp, struct cmsghdr *cmh) in svc_set_cmsg_data() argument
170 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
179 svc_daddr_in(rqstp)->sin_addr.s_addr; in svc_set_cmsg_data()
186 struct sockaddr_in6 *daddr = svc_daddr_in6(rqstp); in svc_set_cmsg_data()
198 static int svc_sock_result_payload(struct svc_rqst *rqstp, unsigned int offset, in svc_sock_result_payload() argument
335 * Read from @rqstp's transport socket. The incoming message fills whole
336 * pages in @rqstp's rq_pages array until the last page of the message
339 static ssize_t svc_tcp_read_msg(struct svc_rqst *rqstp, size_ argument
392 svc_sock_secure_port(struct svc_rqst * rqstp) svc_sock_secure_port() argument
538 svc_udp_get_dest_address4(struct svc_rqst * rqstp,struct cmsghdr * cmh) svc_udp_get_dest_address4() argument
555 svc_udp_get_dest_address6(struct svc_rqst * rqstp,struct cmsghdr * cmh) svc_udp_get_dest_address6() argument
577 svc_udp_get_dest_address(struct svc_rqst * rqstp,struct cmsghdr * cmh) svc_udp_get_dest_address() argument
600 svc_udp_recvfrom(struct svc_rqst * rqstp) svc_udp_recvfrom() argument
724 svc_udp_sendto(struct svc_rqst * rqstp) svc_udp_sendto() argument
987 svc_tcp_restore_pages(struct svc_sock * svsk,struct svc_rqst * rqstp) svc_tcp_restore_pages() argument
1006 svc_tcp_save_pages(struct svc_sock * svsk,struct svc_rqst * rqstp) svc_tcp_save_pages() argument
1045 svc_tcp_read_marker(struct svc_sock * svsk,struct svc_rqst * rqstp) svc_tcp_read_marker() argument
1085 receive_cb_reply(struct svc_sock * svsk,struct svc_rqst * rqstp) receive_cb_reply() argument
1145 svc_tcp_recvfrom(struct svc_rqst * rqstp) svc_tcp_recvfrom() argument
1239 svc_tcp_sendmsg(struct svc_sock * svsk,struct svc_rqst * rqstp,rpc_fraghdr marker) svc_tcp_sendmsg() argument
1278 svc_tcp_sendto(struct svc_rqst * rqstp) svc_tcp_sendto() argument
[all...]
H A Dsvcauth_unix.c642 static struct group_info *unix_gid_find(kuid_t uid, struct svc_rqst *rqstp) in unix_gid_find() argument
647 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
653 ret = cache_check(sn->unix_gid_cache, &ug->h, &rqstp->rq_chandle); in unix_gid_find()
669 svcauth_unix_set_client(struct svc_rqst *rqstp) in svcauth_unix_set_client() argument
675 struct svc_cred *cred = &rqstp->rq_cred; in svcauth_unix_set_client()
676 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
680 switch (rqstp->rq_addr.ss_family) { in svcauth_unix_set_client()
682 sin = svc_addr_in(rqstp); in svcauth_unix_set_client()
687 sin6 = svc_addr_in6(rqstp); in svcauth_unix_set_client()
693 rqstp->rq_client = NULL; in svcauth_unix_set_client()
[all …]
H A Dsvcauth.c76 enum svc_auth_status svc_authenticate(struct svc_rqst *rqstp) in svc_authenticate() argument
81 rqstp->rq_auth_stat = rpc_auth_ok; in svc_authenticate()
87 if (xdr_stream_decode_u32(&rqstp->rq_arg_stream, &flavor) < 0) in svc_authenticate()
92 rqstp->rq_auth_stat = rpc_autherr_badcred; in svc_authenticate()
96 rqstp->rq_auth_slack = 0; in svc_authenticate()
97 init_svc_cred(&rqstp->rq_cred); in svc_authenticate()
99 rqstp->rq_authop = aops; in svc_authenticate()
100 return aops->accept(rqstp); in svc_authenticate()
113 enum svc_auth_status svc_set_client(struct svc_rqst *rqstp) in svc_set_client() argument
115 rqstp->rq_client = NULL; in svc_set_client()
[all …]
/linux/fs/nfsd/
H A Dxdr3.h183 struct svc_rqst * rqstp; member
268 bool nfs3svc_decode_fhandleargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
269 bool nfs3svc_decode_sattrargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
270 bool nfs3svc_decode_diropargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
271 bool nfs3svc_decode_accessargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
272 bool nfs3svc_decode_readargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
273 bool nfs3svc_decode_writeargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
274 bool nfs3svc_decode_createargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
275 bool nfs3svc_decode_mkdirargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
276 bool nfs3svc_decode_mknodargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
[all …]
H A Dxdr.h144 bool nfssvc_decode_fhandleargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
145 bool nfssvc_decode_sattrargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
146 bool nfssvc_decode_diropargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
147 bool nfssvc_decode_readargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
148 bool nfssvc_decode_writeargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
149 bool nfssvc_decode_createargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
150 bool nfssvc_decode_renameargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
151 bool nfssvc_decode_linkargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
152 bool nfssvc_decode_symlinkargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
153 bool nfssvc_decode_readdirargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
[all …]
H A Dnfs3acl.c20 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() argument
28 static __be32 nfsd3_proc_getacl(struct svc_rqst *rqstp) in nfsd3_proc_getacl() argument
30 struct nfsd3_getaclargs *argp = rqstp->rq_argp; in nfsd3_proc_getacl()
31 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsd3_proc_getacl()
37 resp->status = fh_verify(rqstp, &resp->fh, 0, NFSD_MAY_NOP); in nfsd3_proc_getacl()
87 static __be32 nfsd3_proc_setacl(struct svc_rqst *rqstp) in nfsd3_proc_setacl() argument
89 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfsd3_proc_setacl()
90 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfsd3_proc_setacl()
96 resp->status = fh_verify(rqstp, &resp->fh, 0, NFSD_MAY_SATTR); in nfsd3_proc_setacl()
133 nfs3svc_decode_getaclargs(struct svc_rqst *rqstp, struct xdr_stream *xdr) in nfs3svc_decode_getaclargs() argument
[all …]
H A Dnfssvc.c805 nfsd_acl_init_request(struct svc_rqst *rqstp, in nfsd_acl_init_request() argument
809 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in nfsd_acl_init_request()
812 if (likely(nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
813 nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST))) in nfsd_acl_init_request()
814 return svc_generic_init_request(rqstp, progp, ret); in nfsd_acl_init_request()
818 if (nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
828 if (nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
850 nfsd_init_request(struct svc_rqst *rqstp, in nfsd_init_request() argument
854 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in nfsd_init_request()
857 if (likely(nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST))) in nfsd_init_request()
[all …]
H A Dnfs4idmap.c507 idmap_lookup(struct svc_rqst *rqstp, in idmap_lookup() argument
517 ret = cache_check(detail, &(*item)->h, &rqstp->rq_chandle); in idmap_lookup()
530 rqst_authname(struct svc_rqst *rqstp) in rqst_authname() argument
534 clp = rqstp->rq_gssclient ? rqstp->rq_gssclient : rqstp->rq_client; in rqst_authname()
539 idmap_name_to_id(struct svc_rqst *rqstp, int type, const char *name, u32 namelen, in idmap_name_to_id() argument
546 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in idmap_name_to_id()
552 strscpy(key.authname, rqst_authname(rqstp), sizeof(key.authname)); in idmap_name_to_id()
553 ret = idmap_lookup(rqstp, nametoid_lookup, &key, nn->nametoid_cache, &item); in idmap_name_to_id()
578 struct svc_rqst *rqstp, int type, u32 id) in idmap_id_to_name() argument
587 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in idmap_id_to_name()
[all …]
H A Dvfs.h76 int nfsd_cross_mnt(struct svc_rqst *rqstp, struct dentry **dpp,
89 __be32 nfsd4_clone_file_range(struct svc_rqst *rqstp,
101 __be32 nfsd_create_setattr(struct svc_rqst *rqstp, struct svc_fh *fhp,
107 __be32 nfsd_getxattr(struct svc_rqst *rqstp, struct svc_fh *fhp,
109 __be32 nfsd_listxattr(struct svc_rqst *rqstp, struct svc_fh *fhp,
111 __be32 nfsd_removexattr(struct svc_rqst *rqstp, struct svc_fh *fhp,
113 __be32 nfsd_setxattr(struct svc_rqst *rqstp, struct svc_fh *fhp,
121 __be32 nfsd_splice_read(struct svc_rqst *rqstp, struct svc_fh *fhp,
125 __be32 nfsd_iter_read(struct svc_rqst *rqstp, struct svc_fh *fhp,
129 bool nfsd_read_splice_ok(struct svc_rqst *rqstp);
[all …]
H A Dflexfilelayout.c23 nfsd4_ff_proc_layoutget(struct svc_rqst *rqstp, struct inode *inode, in nfsd4_ff_proc_layoutget() argument
81 nfsd4_ff_proc_getdeviceinfo(struct super_block *sb, struct svc_rqst *rqstp, in nfsd4_ff_proc_getdeviceinfo() argument
98 da->rsize = svc_max_payload(rqstp); in nfsd4_ff_proc_getdeviceinfo()
101 rpc_ntop((struct sockaddr *)&rqstp->rq_daddr, in nfsd4_ff_proc_getdeviceinfo()
103 if (rqstp->rq_daddr.ss_family == AF_INET) { in nfsd4_ff_proc_getdeviceinfo()
106 sin = (struct sockaddr_in *)&rqstp->rq_daddr; in nfsd4_ff_proc_getdeviceinfo()
113 sin6 = (struct sockaddr_in6 *)&rqstp->rq_daddr; in nfsd4_ff_proc_getdeviceinfo()
129 nfsd4_ff_proc_layoutcommit(struct inode *inode, struct svc_rqst *rqstp, in nfsd4_ff_proc_layoutcommit() argument
H A Dlocalio.c148 static __be32 localio_proc_null(struct svc_rqst *rqstp) in localio_proc_null() argument
157 static __be32 localio_proc_uuid_is_local(struct svc_rqst *rqstp) in localio_proc_uuid_is_local() argument
159 struct localio_uuidarg *argp = rqstp->rq_argp; in localio_proc_uuid_is_local()
160 struct net *net = SVC_NET(rqstp); in localio_proc_uuid_is_local()
165 net, rqstp->rq_client, THIS_MODULE); in localio_proc_uuid_is_local()
170 static bool localio_decode_uuidarg(struct svc_rqst *rqstp, in localio_decode_uuidarg() argument
173 struct localio_uuidarg *argp = rqstp->rq_argp; in localio_decode_uuidarg()
H A Dexport.c1112 __be32 check_xprtsec_policy(struct svc_export *exp, struct svc_rqst *rqstp) in check_xprtsec_policy() argument
1114 struct svc_xprt *xprt = rqstp->rq_xprt; in check_xprtsec_policy()
1149 __be32 check_security_flavor(struct svc_export *exp, struct svc_rqst *rqstp, in check_security_flavor() argument
1155 if (exp->ex_client == rqstp->rq_gssclient) in check_security_flavor()
1159 if (f->pseudoflavor == rqstp->rq_cred.cr_flavor) in check_security_flavor()
1164 if (rqstp->rq_cred.cr_flavor == RPC_AUTH_NULL || in check_security_flavor()
1165 rqstp->rq_cred.cr_flavor == RPC_AUTH_UNIX) in check_security_flavor()
1175 if (nfsd4_spo_must_allow(rqstp)) in check_security_flavor()
1187 rqstp->rq_cred.cr_flavor == RPC_AUTH_NULL || in check_security_flavor()
1188 rqstp->rq_cred.cr_flavor == RPC_AUTH_UNIX)) { in check_security_flavor()
[all …]
H A Dfilecache.c1084 nfsd_file_do_acquire(struct svc_rqst *rqstp, struct net *net, in nfsd_file_do_acquire() argument
1100 if (rqstp) in nfsd_file_do_acquire()
1101 status = fh_verify(rqstp, fhp, type, in nfsd_file_do_acquire()
1141 trace_nfsd_file_insert_err(rqstp, inode, may_flags, ret); in nfsd_file_do_acquire()
1150 trace_nfsd_file_cons_err(rqstp, inode, may_flags, nf); in nfsd_file_do_acquire()
1174 trace_nfsd_file_acquire(rqstp, inode, may_flags, nf, status); in nfsd_file_do_acquire()
1248 nfsd_file_acquire_gc(struct svc_rqst *rqstp, struct svc_fh *fhp, in nfsd_file_acquire_gc() argument
1251 return nfsd_file_do_acquire(rqstp, SVC_NET(rqstp), NULL, NULL, in nfsd_file_acquire_gc()
1273 nfsd_file_acquire(struct svc_rqst *rqstp, struct svc_fh *fhp, in nfsd_file_acquire() argument
1276 return nfsd_file_do_acquire(rqstp, SVC_NET(rqstp), NULL, NULL, in nfsd_file_acquire()
[all …]
/linux/net/sunrpc/auth_gss/
H A Dsvcauth_gss.c655 static bool gss_check_seq_num(const struct svc_rqst *rqstp, struct rsc *rsci, in gss_check_seq_num() argument
685 trace_rpcgss_svc_seqno_low(rqstp, seq_num, in gss_check_seq_num()
690 trace_rpcgss_svc_seqno_seen(rqstp, seq_num); in gss_check_seq_num()
702 svcauth_gss_verify_header(struct svc_rqst *rqstp, struct rsc *rsci, in svcauth_gss_verify_header() argument
705 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcauth_gss_verify_header()
724 rqstp->rq_auth_stat = rpc_autherr_badverf; in svcauth_gss_verify_header()
728 rqstp->rq_auth_stat = rpc_autherr_badverf; in svcauth_gss_verify_header()
732 if (rqstp->rq_deferred) in svcauth_gss_verify_header()
736 trace_rpcgss_svc_mic(rqstp, maj_stat); in svcauth_gss_verify_header()
737 rqstp->rq_auth_stat = rpcsec_gsserr_credproblem; in svcauth_gss_verify_header()
[all …]
H A Dauth_gss.c1750 struct rpc_rqst *rqstp = task->tk_rqstp; in gss_wrap_req_integ() local
1751 struct xdr_buf integ_buf, *snd_buf = &rqstp->rq_snd_buf; in gss_wrap_req_integ()
1760 *p = cpu_to_be32(*rqstp->rq_seqnos); in gss_wrap_req_integ()
1792 priv_release_snd_buf(struct rpc_rqst *rqstp) in priv_release_snd_buf() argument
1796 for (i=0; i < rqstp->rq_enc_pages_num; i++) in priv_release_snd_buf()
1797 __free_page(rqstp->rq_enc_pages[i]); in priv_release_snd_buf()
1798 kfree(rqstp->rq_enc_pages); in priv_release_snd_buf()
1799 rqstp->rq_release_snd_buf = NULL; in priv_release_snd_buf()
1803 alloc_enc_pages(struct rpc_rqst *rqstp) in alloc_enc_pages() argument
1805 struct xdr_buf *snd_buf = &rqstp->rq_snd_buf; in alloc_enc_pages()
[all …]
/linux/include/trace/events/
H A Drpcgss.h177 const struct svc_rqst *rqstp,
181 TP_ARGS(rqstp, maj_stat),
186 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
190 __entry->xid = __be32_to_cpu(rqstp->rq_xid);
204 const struct svc_rqst *rqstp, \
207 TP_ARGS(rqstp, maj_stat))
216 const struct svc_rqst *rqstp
219 TP_ARGS(rqstp),
223 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
227 __entry->xid = be32_to_cpu(rqstp->rq_xid);
[all …]
/linux/fs/nfs/
H A Dcallback_xdr.c60 static __be32 nfs4_callback_null(struct svc_rqst *rqstp) in nfs4_callback_null() argument
69 static bool nfs4_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr) in nfs4_encode_void() argument
176 static __be32 decode_getattr_args(struct svc_rqst *rqstp, in decode_getattr_args() argument
188 static __be32 decode_recall_args(struct svc_rqst *rqstp, in decode_recall_args() argument
211 static __be32 decode_layoutrecall_args(struct svc_rqst *rqstp, in decode_layoutrecall_args() argument
255 __be32 decode_devicenotify_args(struct svc_rqst *rqstp, in decode_devicenotify_args() argument
395 static __be32 decode_cb_sequence_args(struct svc_rqst *rqstp, in decode_cb_sequence_args() argument
412 args->csa_addr = svc_addr(rqstp); in decode_cb_sequence_args()
442 static __be32 decode_recallany_args(struct svc_rqst *rqstp, in decode_recallany_args() argument
462 static __be32 decode_recallslot_args(struct svc_rqst *rqstp, in decode_recallslot_args() argument
[all …]
/linux/net/sunrpc/xprtrdma/
H A Dsvc_rdma_rw.c801 * @rqstp: RPC transaction context in svc_rdma_build_read_segment()
812 svc_rdma_fill_contig_bvec(struct svc_rqst *rqstp,
825 if (head->rc_curpage + npages > rqstp->rq_maxpages) { in svc_rdma_build_read_chunk()
837 svc_rqst_page_release(rqstp,
838 rqstp->rq_pages[head->rc_curpage + i]);
839 rqstp->rq_pages[head->rc_curpage + i] = page + i;
889 * @rqstp: RPC transaction context
907 static int svc_rdma_build_read_segment_contig(struct svc_rqst *rqstp, in svc_rdma_read_multiple_chunks()
911 struct svcxprt_rdma *rdma = svc_rdma_rqst_rdma(rqstp); in svc_rdma_read_multiple_chunks()
919 if (head->rc_curpage + nr_data_pages > rqstp in svc_rdma_read_multiple_chunks()
747 svc_rdma_build_read_segment(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head,const struct svc_rdma_segment * segment) svc_rdma_build_read_segment() argument
816 svc_rdma_build_read_chunk(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head,const struct svc_rdma_chunk * chunk) svc_rdma_build_read_chunk() argument
849 svc_rdma_copy_inline_range(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head,unsigned int offset,unsigned int remaining) svc_rdma_copy_inline_range() argument
902 svc_rdma_read_multiple_chunks(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_read_multiple_chunks() argument
956 svc_rdma_read_data_item(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_read_data_item() argument
978 svc_rdma_read_chunk_range(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head,const struct svc_rdma_chunk * chunk,unsigned int offset,unsigned int length) svc_rdma_read_chunk_range() argument
1022 svc_rdma_read_call_chunk(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_read_call_chunk() argument
1085 svc_rdma_read_special(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_read_special() argument
1101 svc_rdma_clear_rqst_pages(struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_clear_rqst_pages() argument
1136 svc_rdma_process_read_list(struct svcxprt_rdma * rdma,struct svc_rqst * rqstp,struct svc_rdma_recv_ctxt * head) svc_rdma_process_read_list() argument
[all...]
H A Dsvc_rdma_sendto.c946 static void svc_rdma_save_io_pages(struct svc_rqst *rqstp, in svc_rdma_send_error_msg()
949 int i, pages = rqstp->rq_next_page - rqstp->rq_respages; in svc_rdma_send_error_msg()
953 ctxt->sc_pages[i] = rqstp->rq_respages[i]; in svc_rdma_send_error_msg()
954 rqstp->rq_respages[i] = NULL; in svc_rdma_send_error_msg()
973 struct svc_rqst *rqstp) in svc_rdma_send_error_msg()
979 &rctxt->rc_reply_pcl, &rqstp->rq_res);
986 svc_rdma_save_io_pages(rqstp, sctxt);
1075 * @rqstp: processed RPC request, reply XDR already in ::rq_res
1077 * Any resources still associated with @rqstp ar
853 svc_rdma_save_io_pages(struct svc_rqst * rqstp,struct svc_rdma_send_ctxt * ctxt) svc_rdma_save_io_pages() argument
883 svc_rdma_send_reply_msg(struct svcxprt_rdma * rdma,struct svc_rdma_send_ctxt * sctxt,const struct svc_rdma_recv_ctxt * rctxt,struct svc_rqst * rqstp) svc_rdma_send_reply_msg() argument
989 svc_rdma_sendto(struct svc_rqst * rqstp) svc_rdma_sendto() argument
1083 svc_rdma_result_payload(struct svc_rqst * rqstp,unsigned int offset,unsigned int length) svc_rdma_result_payload() argument
[all...]
/linux/include/linux/sunrpc/
H A Dsvcauth.h145 enum svc_auth_status (*accept)(struct svc_rqst *rqstp);
146 int (*release)(struct svc_rqst *rqstp);
148 enum svc_auth_status (*set_client)(struct svc_rqst *rqstp);
149 rpc_authflavor_t (*pseudoflavor)(struct svc_rqst *rqstp);
154 extern rpc_authflavor_t svc_auth_flavor(struct svc_rqst *rqstp);
155 extern int svc_authorise(struct svc_rqst *rqstp);
156 extern enum svc_auth_status svc_set_client(struct svc_rqst *rqstp);
170 extern enum svc_auth_status svcauth_unix_set_client(struct svc_rqst *rqstp);
H A Dbc_xprt.h40 static inline bool svc_is_backchannel(const struct svc_rqst *rqstp) in svc_is_backchannel() argument
42 return rqstp->rq_server->sv_bc_enabled; in svc_is_backchannel()
61 static inline bool svc_is_backchannel(const struct svc_rqst *rqstp) in svc_is_backchannel() argument
/linux/tools/net/sunrpc/xdrgen/templates/C/program/encoder/
H A Dresult.j25 * @rqstp: RPC transaction context
12 bool {{ program }}_svc_encode_{{ result }}(struct svc_rqst *rqstp, struct xdr_stream *xdr)
18 struct {{ result }} *resp = rqstp->rq_resp;
22 {{ result }} *resp = rqstp->rq_resp;
/linux/tools/net/sunrpc/xdrgen/templates/C/program/decoder/
H A Dargument.j25 * @rqstp: RPC transaction context
12 bool {{ program }}_svc_decode_{{ argument }}(struct svc_rqst *rqstp, struct xdr_stream *xdr)
18 struct {{ argument }} *argp = rqstp->rq_argp;
20 {{ argument }} *argp = rqstp->rq_argp;

12