Searched refs:rqstp (Results 1 - 16 of 16) sorted by relevance

/net/sunrpc/xprtrdma/
H A Dsvc_rdma_recvfrom.c59 static void rdma_build_arg_xdr(struct svc_rqst *rqstp, argument
69 put_page(rqstp->rq_pages[0]);
70 rqstp->rq_pages[0] = page;
73 rqstp->rq_arg.head[0].iov_base = page_address(page);
74 rqstp->rq_arg.head[0].iov_len =
76 rqstp->rq_arg.len = byte_count;
77 rqstp->rq_arg.buflen = byte_count;
80 bc = byte_count - rqstp->rq_arg.head[0].iov_len;
83 rqstp->rq_arg.page_len = bc;
84 rqstp
139 rdma_read_chunk_lcl(struct svcxprt_rdma *xprt, struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *head, int *page_no, u32 *page_offset, u32 rs_handle, u32 rs_length, u64 rs_offset, int last) argument
232 rdma_read_chunk_frmr(struct svcxprt_rdma *xprt, struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *head, int *page_no, u32 *page_offset, u32 rs_handle, u32 rs_length, u64 rs_offset, int last) argument
368 rdma_read_chunks(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rmsgp, struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *head) argument
465 rdma_read_complete(struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *head) argument
517 svc_rdma_recvfrom(struct svc_rqst *rqstp) argument
[all...]
H A Dsvc_rdma_marshal.c165 struct svc_rqst *rqstp)
172 rmsgp = (struct rpcrdma_msg *)rqstp->rq_arg.head[0].iov_base;
175 if (rqstp->rq_arg.len <= RPCRDMA_HDRLEN_MIN) {
177 rqstp->rq_arg.len);
199 rqstp->rq_arg.head[0].iov_base = va;
201 rqstp->rq_arg.head[0].iov_len -= hdrlen;
202 if (hdrlen > rqstp->rq_arg.len)
211 vaend = (u32 *)((unsigned long)rmsgp + rqstp->rq_arg.len);
222 rqstp->rq_arg.head[0].iov_base = va;
224 rqstp
164 svc_rdma_xdr_decode_req(struct rpcrdma_msg **rdma_req, struct svc_rqst *rqstp) argument
230 svc_rdma_xdr_decode_deferred_req(struct svc_rqst *rqstp) argument
[all...]
H A Dsvc_rdma_sendto.c139 static int send_write(struct svcxprt_rdma *xprt, struct svc_rqst *rqstp, argument
181 dma_map_xdr(xprt, &rqstp->rq_res, xdr_off,
225 struct svc_rqst *rqstp,
228 u32 xfer_len = rqstp->rq_res.page_len + rqstp->rq_res.tail[0].iov_len;
244 for (xdr_off = rqstp->rq_res.head[0].iov_len, chunk_no = 0;
262 ret = send_write(xprt, rqstp,
282 return rqstp->rq_res.page_len + rqstp->rq_res.tail[0].iov_len;
288 struct svc_rqst *rqstp,
222 send_write_chunks(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rdma_argp, struct rpcrdma_msg *rdma_resp, struct svc_rqst *rqstp, struct svc_rdma_req_map *vec) argument
285 send_reply_chunks(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rdma_argp, struct rpcrdma_msg *rdma_resp, struct svc_rqst *rqstp, struct svc_rdma_req_map *vec) argument
366 send_reply(struct svcxprt_rdma *rdma, struct svc_rqst *rqstp, struct page *page, struct rpcrdma_msg *rdma_resp, struct svc_rdma_op_ctxt *ctxt, struct svc_rdma_req_map *vec, int byte_count) argument
466 svc_rdma_prep_reply_hdr(struct svc_rqst *rqstp) argument
482 svc_rdma_sendto(struct svc_rqst *rqstp) argument
[all...]
H A Dsvc_rdma_transport.c1095 static void svc_rdma_release_rqst(struct svc_rqst *rqstp) argument
1208 static int svc_rdma_secure_port(struct svc_rqst *rqstp) argument
/net/sunrpc/
H A Dsvc_xprt.c22 static int svc_deferred_recv(struct svc_rqst *rqstp);
283 * Copy the local and remote xprt addresses to the rqstp structure
285 void svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument
287 memcpy(&rqstp->rq_addr, &xprt->xpt_remote, xprt->xpt_remotelen);
288 rqstp->rq_addrlen = xprt->xpt_remotelen;
294 memcpy(&rqstp->rq_daddr, &xprt->xpt_local, xprt->xpt_locallen);
295 rqstp->rq_daddrlen = xprt->xpt_locallen;
301 * @rqstp: svc_rqst struct containing address to print
306 char *svc_print_addr(struct svc_rqst *rqstp, char *buf, size_t len) argument
308 return __svc_print_addr(svc_addr(rqstp), bu
318 svc_thread_enqueue(struct svc_pool *pool, struct svc_rqst *rqstp) argument
326 svc_thread_dequeue(struct svc_pool *pool, struct svc_rqst *rqstp) argument
343 struct svc_rqst *rqstp; local
439 svc_reserve(struct svc_rqst *rqstp, int space) argument
455 svc_xprt_release(struct svc_rqst *rqstp) argument
492 struct svc_rqst *rqstp; local
582 svc_alloc_arg(struct svc_rqst *rqstp) argument
624 svc_get_next_xprt(struct svc_rqst *rqstp, long timeout) argument
712 svc_handle_xprt(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument
760 svc_recv(struct svc_rqst *rqstp, long timeout) argument
811 svc_drop(struct svc_rqst *rqstp) argument
821 svc_send(struct svc_rqst *rqstp) argument
1069 struct svc_rqst *rqstp = container_of(req, struct svc_rqst, rq_chandle); local
1110 svc_deferred_recv(struct svc_rqst *rqstp) argument
[all...]
H A Dsvc.c568 svc_init_buffer(struct svc_rqst *rqstp, unsigned int size, int node) argument
573 if (svc_is_backchannel(rqstp))
587 rqstp->rq_pages[arghi++] = p;
597 svc_release_buffer(struct svc_rqst *rqstp) argument
601 for (i = 0; i < ARRAY_SIZE(rqstp->rq_pages); i++)
602 if (rqstp->rq_pages[i])
603 put_page(rqstp->rq_pages[i]);
609 struct svc_rqst *rqstp; local
611 rqstp = kzalloc_node(sizeof(*rqstp), GFP_KERNE
679 struct svc_rqst *rqstp; local
711 struct svc_rqst *rqstp; local
772 svc_exit_thread(struct svc_rqst *rqstp) argument
1045 svc_printk(struct svc_rqst *rqstp, const char *fmt, ...) argument
1061 svc_printk(struct svc_rqst *rqstp, const char *fmt, ...) argument
1068 svc_process_common(struct svc_rqst *rqstp, struct kvec *argv, struct kvec *resv) argument
1295 svc_process(struct svc_rqst *rqstp) argument
1343 bc_svc_process(struct svc_serv *serv, struct rpc_rqst *req, struct svc_rqst *rqstp) argument
1392 svc_max_payload(const struct svc_rqst *rqstp) argument
[all...]
H A Dsvcauth.c37 svc_authenticate(struct svc_rqst *rqstp, __be32 *authp) argument
44 flavor = svc_getnl(&rqstp->rq_arg.head[0]);
57 rqstp->rq_auth_slack = 0;
59 rqstp->rq_authop = aops;
60 return aops->accept(rqstp, authp);
64 int svc_set_client(struct svc_rqst *rqstp) argument
66 return rqstp->rq_authop->set_client(rqstp);
74 int svc_authorise(struct svc_rqst *rqstp) argument
76 struct auth_ops *aops = rqstp
[all...]
H A Dsvcsock.c120 static void svc_release_skb(struct svc_rqst *rqstp) argument
122 struct sk_buff *skb = rqstp->rq_xprt_ctxt;
126 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);
127 rqstp->rq_xprt_ctxt = NULL;
129 dprintk("svc: service %p, releasing skb %p\n", rqstp, skb);
141 static void svc_set_cmsg_data(struct svc_rqst *rqstp, struct cmsghdr *cmh) argument
144 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);
153 svc_daddr_in(rqstp)->sin_addr.s_addr;
160 struct sockaddr_in6 *daddr = svc_daddr_in6(rqstp);
234 static int svc_sendto(struct svc_rqst *rqstp, struc argument
317 svc_recvfrom(struct svc_rqst *rqstp, struct kvec *iov, int nr, int buflen) argument
343 svc_partial_recvfrom(struct svc_rqst *rqstp, struct kvec *iov, int nr, int buflen, unsigned int base) argument
397 svc_sock_secure_port(struct svc_rqst *rqstp) argument
482 svc_udp_get_dest_address4(struct svc_rqst *rqstp, struct cmsghdr *cmh) argument
499 svc_udp_get_dest_address6(struct svc_rqst *rqstp, struct cmsghdr *cmh) argument
521 svc_udp_get_dest_address(struct svc_rqst *rqstp, struct cmsghdr *cmh) argument
537 svc_udp_recvfrom(struct svc_rqst *rqstp) argument
650 svc_udp_sendto(struct svc_rqst *rqstp) argument
662 svc_udp_prep_reply_hdr(struct svc_rqst *rqstp) argument
912 svc_tcp_restore_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) argument
931 svc_tcp_save_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) argument
970 svc_tcp_recv_record(struct svc_sock *svsk, struct svc_rqst *rqstp) argument
1010 receive_cb_reply(struct svc_sock *svsk, struct svc_rqst *rqstp) argument
1082 svc_tcp_recvfrom(struct svc_rqst *rqstp) argument
1184 svc_tcp_sendto(struct svc_rqst *rqstp) argument
1215 svc_tcp_prep_reply_hdr(struct svc_rqst *rqstp) argument
[all...]
H A Dsvcauth_unix.c628 static struct group_info *unix_gid_find(kuid_t uid, struct svc_rqst *rqstp) argument
633 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net,
639 ret = cache_check(sn->unix_gid_cache, &ug->h, &rqstp->rq_chandle);
655 svcauth_unix_set_client(struct svc_rqst *rqstp) argument
661 struct svc_cred *cred = &rqstp->rq_cred;
662 struct svc_xprt *xprt = rqstp->rq_xprt;
666 switch (rqstp->rq_addr.ss_family) {
668 sin = svc_addr_in(rqstp);
673 sin6 = svc_addr_in6(rqstp);
679 rqstp
725 svcauth_null_accept(struct svc_rqst *rqstp, __be32 *authp) argument
765 svcauth_null_release(struct svc_rqst *rqstp) argument
789 svcauth_unix_accept(struct svc_rqst *rqstp, __be32 *authp) argument
848 svcauth_unix_release(struct svc_rqst *rqstp) argument
[all...]
H A Dauth.c770 static void rpcauth_wrap_req_encode(kxdreproc_t encode, struct rpc_rqst *rqstp, argument
775 xdr_init_encode(&xdr, &rqstp->rq_snd_buf, data);
776 encode(rqstp, &xdr, obj);
780 rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, argument
788 return cred->cr_ops->crwrap_req(task, encode, rqstp, data, obj);
790 rpcauth_wrap_req_encode(encode, rqstp, data, obj);
795 rpcauth_unwrap_req_decode(kxdrdproc_t decode, struct rpc_rqst *rqstp, argument
800 xdr_init_decode(&xdr, &rqstp->rq_rcv_buf, data);
801 return decode(rqstp, &xdr, obj);
805 rpcauth_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, argument
[all...]
H A Dcache.c250 struct cache_head *h, struct cache_req *rqstp)
262 if (rqstp == NULL) {
282 if (!cache_defer_req(rqstp, h)) {
249 cache_check(struct cache_detail *detail, struct cache_head *h, struct cache_req *rqstp) argument
H A Dclnt.c2382 static void rpcproc_encode_null(void *rqstp, struct xdr_stream *xdr, void *obj) argument
2386 static int rpcproc_decode_null(void *rqstp, struct xdr_stream *xdr, void *obj) argument
2427 printk(KERN_INFO "-pid- flgs status -client- --rqstp- "
/net/sunrpc/auth_gss/
H A Dsvcauth_gss.c657 gss_verify_header(struct svc_rqst *rqstp, struct rsc *rsci, argument
664 struct kvec *argv = &rqstp->rq_arg.head[0];
681 if (rqstp->rq_deferred) /* skip verification of revisited request */
703 gss_write_null_verf(struct svc_rqst *rqstp) argument
707 svc_putnl(rqstp->rq_res.head, RPC_AUTH_NULL);
708 p = rqstp->rq_res.head->iov_base + rqstp->rq_res.head->iov_len;
711 if (!xdr_ressize_check(rqstp, p))
717 gss_write_verf(struct svc_rqst *rqstp, struct gss_ctx *ctx_id, u32 seq) argument
726 svc_putnl(rqstp
825 unwrap_integ_data(struct svc_rqst *rqstp, struct xdr_buf *buf, u32 seq, struct gss_ctx *ctx) argument
884 unwrap_priv_data(struct svc_rqst *rqstp, struct xdr_buf *buf, u32 seq, struct gss_ctx *ctx) argument
944 svcauth_gss_set_client(struct svc_rqst *rqstp) argument
970 gss_write_init_verf(struct cache_detail *cd, struct svc_rqst *rqstp, struct xdr_netobj *out_handle, int *major_status) argument
1047 gss_read_proxy_verf(struct svc_rqst *rqstp, struct rpc_gss_wire_cred *gc, __be32 *authp, struct xdr_netobj *in_handle, struct gssp_in_token *in_token) argument
1098 svcauth_gss_legacy_init(struct svc_rqst *rqstp, struct rpc_gss_wire_cred *gc, __be32 *authp) argument
1207 svcauth_gss_proxy_init(struct svc_rqst *rqstp, struct rpc_gss_wire_cred *gc, __be32 *authp) argument
1395 svcauth_gss_accept(struct svc_rqst *rqstp, __be32 *authp) argument
1576 svcauth_gss_wrap_resp_integ(struct svc_rqst *rqstp) argument
1623 svcauth_gss_wrap_resp_priv(struct svc_rqst *rqstp) argument
1688 svcauth_gss_release(struct svc_rqst *rqstp) argument
[all...]
H A Dauth_gss.c1654 static void gss_wrap_req_encode(kxdreproc_t encode, struct rpc_rqst *rqstp, argument
1659 xdr_init_encode(&xdr, &rqstp->rq_snd_buf, p);
1660 encode(rqstp, &xdr, obj);
1665 kxdreproc_t encode, struct rpc_rqst *rqstp,
1668 struct xdr_buf *snd_buf = &rqstp->rq_snd_buf;
1680 *p++ = htonl(rqstp->rq_seqno);
1682 gss_wrap_req_encode(encode, rqstp, p, obj);
1712 priv_release_snd_buf(struct rpc_rqst *rqstp) argument
1716 for (i=0; i < rqstp->rq_enc_pages_num; i++)
1717 __free_page(rqstp
1664 gss_wrap_req_integ(struct rpc_cred *cred, struct gss_cl_ctx *ctx, kxdreproc_t encode, struct rpc_rqst *rqstp, __be32 *p, void *obj) argument
1722 alloc_enc_pages(struct rpc_rqst *rqstp) argument
1755 gss_wrap_req_priv(struct rpc_cred *cred, struct gss_cl_ctx *ctx, kxdreproc_t encode, struct rpc_rqst *rqstp, __be32 *p, void *obj) argument
1823 gss_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *p, void *obj) argument
1860 gss_unwrap_resp_integ(struct rpc_cred *cred, struct gss_cl_ctx *ctx, struct rpc_rqst *rqstp, __be32 **p) argument
1897 gss_unwrap_resp_priv(struct rpc_cred *cred, struct gss_cl_ctx *ctx, struct rpc_rqst *rqstp, __be32 **p) argument
1925 gss_unwrap_req_decode(kxdrdproc_t decode, struct rpc_rqst *rqstp, __be32 *p, void *obj) argument
1935 gss_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, __be32 *p, void *obj) argument
[all...]
H A Dgss_rpc_xdr.h183 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp,
H A Dgss_rpc_xdr.c790 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp, argument

Completed in 158 milliseconds