| /kernel/linux/linux-6.6/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_recvfrom.c | 399 * @rctxt: Ingress receive context
410 * %true: Read list is valid. @rctxt's xdr_stream is updated to point
414 * %false: Read list is corrupt. @rctxt's xdr_stream is left in an
417 static bool xdr_count_read_segments(struct svc_rdma_recv_ctxt *rctxt, __be32 *p) in xdr_count_read_segments() argument
419 rctxt->rc_call_pcl.cl_count = 0; in xdr_count_read_segments()
420 rctxt->rc_read_pcl.cl_count = 0; in xdr_count_read_segments()
425 p = xdr_inline_decode(&rctxt->rc_stream, in xdr_count_read_segments()
435 ++rctxt->rc_read_pcl.cl_count; in xdr_count_read_segments()
437 ++rctxt->rc_call_pcl.cl_count; in xdr_count_read_segments()
440 p = xdr_inline_decode(&rctxt in xdr_count_read_segments()
459 xdr_check_read_list(struct svc_rdma_recv_ctxt *rctxt) xdr_check_read_list() argument
473 xdr_check_write_chunk(struct svc_rdma_recv_ctxt *rctxt) xdr_check_write_chunk() argument
502 xdr_count_write_chunks(struct svc_rdma_recv_ctxt *rctxt, __be32 *p) xdr_count_write_chunks() argument
531 xdr_check_write_list(struct svc_rdma_recv_ctxt *rctxt) xdr_check_write_list() argument
559 xdr_check_reply_chunk(struct svc_rdma_recv_ctxt *rctxt) xdr_check_reply_chunk() argument
647 svc_rdma_xdr_decode_req(struct xdr_buf *rq_arg, struct svc_rdma_recv_ctxt *rctxt) svc_rdma_xdr_decode_req() argument
713 svc_rdma_send_error(struct svcxprt_rdma *rdma, struct svc_rdma_recv_ctxt *rctxt, int status) svc_rdma_send_error() argument
730 svc_rdma_is_reverse_direction_reply(struct svc_xprt *xprt, struct svc_rdma_recv_ctxt *rctxt) svc_rdma_is_reverse_direction_reply() argument
[all...] |
| H A D | svc_rdma_sendto.c | 446 * @rctxt: Reply context with information about the RPC Call
454 static ssize_t svc_rdma_encode_write_list(struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_encode_write_list() argument
461 pcl_for_each_chunk(chunk, &rctxt->rc_write_pcl) { in svc_rdma_encode_write_list()
478 * @rctxt: Reply context with information about the RPC Call
489 svc_rdma_encode_reply_chunk(struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_encode_reply_chunk() argument
495 if (pcl_is_empty(&rctxt->rc_reply_pcl)) in svc_rdma_encode_reply_chunk()
498 chunk = pcl_first_chunk(&rctxt->rc_reply_pcl); in svc_rdma_encode_reply_chunk()
656 * @rctxt: Write and Reply chunks provided by client
665 const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_pull_up_needed()
675 ret = pcl_process_nonpayloads(&rctxt in svc_rdma_pull_up_needed()
663 svc_rdma_pull_up_needed(const struct svcxprt_rdma *rdma, const struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, const struct xdr_buf *xdr) svc_rdma_pull_up_needed() argument
744 svc_rdma_pull_up_reply_msg(const struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, const struct xdr_buf *xdr) svc_rdma_pull_up_reply_msg() argument
777 svc_rdma_map_reply_msg(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, const struct xdr_buf *xdr) svc_rdma_map_reply_msg() argument
844 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
882 svc_rdma_send_error_msg(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, struct svc_rdma_recv_ctxt *rctxt, int status) svc_rdma_send_error_msg() argument
953 struct svc_rdma_recv_ctxt *rctxt = rqstp->rq_xprt_ctxt; svc_rdma_sendto() local
1037 struct svc_rdma_recv_ctxt *rctxt = rqstp->rq_xprt_ctxt; svc_rdma_result_payload() local
[all...] |
| H A D | svc_rdma_pcl.c | 68 static void pcl_set_read_segment(const struct svc_rdma_recv_ctxt *rctxt, in pcl_set_read_segment() argument
79 trace_svcrdma_decode_rseg(&rctxt->rc_cid, chunk, segment); in pcl_set_read_segment()
87 * @rctxt: Ingress receive context
102 bool pcl_alloc_call(struct svc_rdma_recv_ctxt *rctxt, __be32 *p) in pcl_alloc_call() argument
104 struct svc_rdma_pcl *pcl = &rctxt->rc_call_pcl; in pcl_alloc_call()
130 pcl_set_read_segment(rctxt, chunk, handle, length, offset); in pcl_alloc_call()
138 * @rctxt: Ingress receive context
156 bool pcl_alloc_read(struct svc_rdma_recv_ctxt *rctxt, __be32 *p) in pcl_alloc_read() argument
158 struct svc_rdma_pcl *pcl = &rctxt->rc_read_pcl; in pcl_alloc_read()
181 pcl_set_read_segment(rctxt, chun in pcl_alloc_read()
201 pcl_alloc_write(struct svc_rdma_recv_ctxt *rctxt, struct svc_rdma_pcl *pcl, __be32 *p) pcl_alloc_write() argument
[all...] |
| H A D | svc_rdma_backchannel.c | 16 * @rctxt: Received message
20 struct svc_rdma_recv_ctxt *rctxt) in svc_rdma_handle_bc_reply()
27 __be32 *rdma_resp = rctxt->rc_recv_buf; in svc_rdma_handle_bc_reply()
79 struct svc_rdma_recv_ctxt *rctxt; in svc_rdma_bc_sendto() local
82 rctxt = svc_rdma_recv_ctxt_get(rdma); in svc_rdma_bc_sendto()
83 if (!rctxt) in svc_rdma_bc_sendto()
86 ret = svc_rdma_map_reply_msg(rdma, sctxt, rctxt, &rqst->rq_snd_buf); in svc_rdma_bc_sendto()
87 svc_rdma_recv_ctxt_put(rdma, rctxt); in svc_rdma_bc_sendto()
19 svc_rdma_handle_bc_reply(struct svc_rqst *rqstp, struct svc_rdma_recv_ctxt *rctxt) svc_rdma_handle_bc_reply() argument
|
| H A D | svc_rdma_rw.c | 649 * @rctxt: Write and Reply chunks from client
660 const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_send_reply_chunk()
668 if (pcl_is_empty(&rctxt->rc_reply_pcl)) in svc_rdma_send_reply_chunk()
671 chunk = pcl_first_chunk(&rctxt->rc_reply_pcl); in svc_rdma_send_reply_chunk()
677 ret = pcl_process_nonpayloads(&rctxt->rc_write_pcl, xdr, in svc_rdma_send_reply_chunk()
659 svc_rdma_send_reply_chunk(struct svcxprt_rdma *rdma, const struct svc_rdma_recv_ctxt *rctxt, const struct xdr_buf *xdr) svc_rdma_send_reply_chunk() argument
|
| /kernel/linux/linux-5.10/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_sendto.c | 449 * @rctxt: Reply context with information about the RPC Call
467 svc_rdma_encode_write_list(const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_encode_write_list() argument
473 ret = svc_rdma_encode_write_chunk(rctxt->rc_write_list, sctxt, length); in svc_rdma_encode_write_list()
488 * @rctxt: Reply context with information about the RPC Call
501 svc_rdma_encode_reply_chunk(const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_encode_reply_chunk() argument
505 return svc_rdma_encode_write_chunk(rctxt->rc_reply_chunk, sctxt, in svc_rdma_encode_reply_chunk()
548 * @rctxt: Write and Reply chunks provided by client
557 const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_pull_up_needed()
574 if (!rctxt || !rctxt in svc_rdma_pull_up_needed()
555 svc_rdma_pull_up_needed(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, struct xdr_buf *xdr) svc_rdma_pull_up_needed() argument
608 svc_rdma_pull_up_reply_msg(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, const struct xdr_buf *xdr) svc_rdma_pull_up_reply_msg() argument
668 svc_rdma_map_reply_msg(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, const struct svc_rdma_recv_ctxt *rctxt, struct xdr_buf *xdr) svc_rdma_map_reply_msg() argument
787 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
824 svc_rdma_send_error_msg(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *sctxt, struct svc_rdma_recv_ctxt *rctxt, int status) svc_rdma_send_error_msg() argument
895 struct svc_rdma_recv_ctxt *rctxt = rqstp->rq_xprt_ctxt; svc_rdma_sendto() local
996 struct svc_rdma_recv_ctxt *rctxt = rqstp->rq_xprt_ctxt; svc_rdma_read_payload() local
[all...] |
| H A D | svc_rdma_recvfrom.c | 412 * %true: Read list is valid. @rctxt's xdr_stream is updated
414 * %false: Read list is corrupt. @rctxt's xdr_stream is left
417 static bool xdr_check_read_list(struct svc_rdma_recv_ctxt *rctxt) in xdr_check_read_list() argument
423 p = xdr_inline_decode(&rctxt->rc_stream, sizeof(*p)); in xdr_check_read_list()
430 p = xdr_inline_decode(&rctxt->rc_stream, in xdr_check_read_list()
444 p = xdr_inline_decode(&rctxt->rc_stream, sizeof(*p)); in xdr_check_read_list()
456 static bool xdr_check_write_chunk(struct svc_rdma_recv_ctxt *rctxt, u32 maxlen) in xdr_check_write_chunk() argument
461 p = xdr_inline_decode(&rctxt->rc_stream, sizeof(*p)); in xdr_check_write_chunk()
471 p = xdr_inline_decode(&rctxt->rc_stream, in xdr_check_write_chunk()
494 * %true: Write list is valid. @rctxt'
499 xdr_check_write_list(struct svc_rdma_recv_ctxt *rctxt) xdr_check_write_list() argument
533 xdr_check_reply_chunk(struct svc_rdma_recv_ctxt *rctxt) xdr_check_reply_chunk() argument
627 svc_rdma_xdr_decode_req(struct xdr_buf *rq_arg, struct svc_rdma_recv_ctxt *rctxt) svc_rdma_xdr_decode_req() argument
721 svc_rdma_send_error(struct svcxprt_rdma *rdma, struct svc_rdma_recv_ctxt *rctxt, int status) svc_rdma_send_error() argument
[all...] |
| H A D | svc_rdma_backchannel.c | 16 * @rctxt: Received message
20 struct svc_rdma_recv_ctxt *rctxt) in svc_rdma_handle_bc_reply()
27 __be32 *rdma_resp = rctxt->rc_recv_buf; in svc_rdma_handle_bc_reply()
19 svc_rdma_handle_bc_reply(struct svc_rqst *rqstp, struct svc_rdma_recv_ctxt *rctxt) svc_rdma_handle_bc_reply() argument
|
| H A D | svc_rdma_rw.c | 572 * @rctxt: Write and Reply chunks from client
583 const struct svc_rdma_recv_ctxt *rctxt, in svc_rdma_send_reply_chunk()
589 info = svc_rdma_write_info_alloc(rdma, rctxt->rc_reply_chunk); in svc_rdma_send_reply_chunk()
601 if (!rctxt->rc_write_list && xdr->page_len) { in svc_rdma_send_reply_chunk()
582 svc_rdma_send_reply_chunk(struct svcxprt_rdma *rdma, const struct svc_rdma_recv_ctxt *rctxt, struct xdr_buf *xdr) svc_rdma_send_reply_chunk() argument
|
| /kernel/linux/linux-6.6/include/linux/sunrpc/ |
| H A D | svc_rdma_pcl.h | 118 extern bool pcl_alloc_call(struct svc_rdma_recv_ctxt *rctxt, __be32 *p);
119 extern bool pcl_alloc_read(struct svc_rdma_recv_ctxt *rctxt, __be32 *p);
120 extern bool pcl_alloc_write(struct svc_rdma_recv_ctxt *rctxt,
|
| H A D | svc_rdma.h | 168 struct svc_rdma_recv_ctxt *rctxt);
187 const struct svc_rdma_recv_ctxt *rctxt,
203 const struct svc_rdma_recv_ctxt *rctxt,
207 struct svc_rdma_recv_ctxt *rctxt,
|
| /kernel/linux/linux-5.10/include/linux/sunrpc/ |
| H A D | svc_rdma.h | 169 struct svc_rdma_recv_ctxt *rctxt);
190 const struct svc_rdma_recv_ctxt *rctxt,
203 const struct svc_rdma_recv_ctxt *rctxt,
207 struct svc_rdma_recv_ctxt *rctxt,
|