• Home
  • Raw
  • Download

Lines Matching refs:req

298 			 struct rpcrdma_req *req, struct rpc_rqst *rqst,  in rpcrdma_encode_read_list()  argument
314 seg = req->rl_segments; in rpcrdma_encode_read_list()
325 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_read_list()
363 rpcrdma_encode_write_list(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_encode_write_list() argument
377 seg = req->rl_segments; in rpcrdma_encode_write_list()
393 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_write_list()
431 struct rpcrdma_req *req, struct rpc_rqst *rqst, in rpcrdma_encode_reply_chunk() argument
444 seg = req->rl_segments; in rpcrdma_encode_reply_chunk()
458 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_reply_chunk()
483 rpcrdma_prepare_hdr_sge(struct rpcrdma_ia *ia, struct rpcrdma_req *req, in rpcrdma_prepare_hdr_sge() argument
486 struct rpcrdma_regbuf *rb = req->rl_rdmabuf; in rpcrdma_prepare_hdr_sge()
487 struct ib_sge *sge = &req->rl_send_sge[0]; in rpcrdma_prepare_hdr_sge()
499 req->rl_send_wr.num_sge++; in rpcrdma_prepare_hdr_sge()
507 rpcrdma_prepare_msg_sges(struct rpcrdma_ia *ia, struct rpcrdma_req *req, in rpcrdma_prepare_msg_sges() argument
511 struct rpcrdma_regbuf *rb = req->rl_sendbuf; in rpcrdma_prepare_msg_sges()
513 struct ib_sge *sge = req->rl_send_sge; in rpcrdma_prepare_msg_sges()
576 req->rl_mapped_sges++; in rpcrdma_prepare_msg_sges()
602 req->rl_mapped_sges++; in rpcrdma_prepare_msg_sges()
606 req->rl_send_wr.num_sge = sge_no + 1; in rpcrdma_prepare_msg_sges()
619 rpcrdma_prepare_send_sges(struct rpcrdma_ia *ia, struct rpcrdma_req *req, in rpcrdma_prepare_send_sges() argument
623 req->rl_send_wr.num_sge = 0; in rpcrdma_prepare_send_sges()
624 req->rl_mapped_sges = 0; in rpcrdma_prepare_send_sges()
626 if (!rpcrdma_prepare_hdr_sge(ia, req, hdrlen)) in rpcrdma_prepare_send_sges()
630 if (!rpcrdma_prepare_msg_sges(ia, req, xdr, rtype)) in rpcrdma_prepare_send_sges()
641 rpcrdma_unmap_sges(struct rpcrdma_ia *ia, struct rpcrdma_req *req) in rpcrdma_unmap_sges() argument
647 sge = &req->rl_send_sge[2]; in rpcrdma_unmap_sges()
648 for (count = req->rl_mapped_sges; count--; sge++) in rpcrdma_unmap_sges()
651 req->rl_mapped_sges = 0; in rpcrdma_unmap_sges()
666 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in rpcrdma_marshal_req() local
679 headerp = rdmab_to_msg(req->rl_rdmabuf); in rpcrdma_marshal_req()
760 iptr = rpcrdma_encode_read_list(r_xprt, req, rqst, iptr, rtype); in rpcrdma_marshal_req()
763 iptr = rpcrdma_encode_write_list(r_xprt, req, rqst, iptr, wtype); in rpcrdma_marshal_req()
766 iptr = rpcrdma_encode_reply_chunk(r_xprt, req, rqst, iptr, wtype); in rpcrdma_marshal_req()
776 if (!rpcrdma_prepare_send_sges(&r_xprt->rx_ia, req, hdrlen, in rpcrdma_marshal_req()
784 r_xprt->rx_ia.ri_ops->ro_unmap_safe(r_xprt, req, false); in rpcrdma_marshal_req()
1003 struct rpcrdma_req *req; in rpcrdma_reply_handler() local
1032 req = rpcr_to_rdmar(rqst); in rpcrdma_reply_handler()
1033 if (req->rl_reply) in rpcrdma_reply_handler()
1042 __func__, rep, req, be32_to_cpu(headerp->rm_xid)); in rpcrdma_reply_handler()
1045 req->rl_reply = rep; in rpcrdma_reply_handler()
1062 list_empty(&req->rl_registered))) in rpcrdma_reply_handler()
1100 list_empty(&req->rl_registered)) in rpcrdma_reply_handler()
1133 if (!list_empty(&req->rl_registered)) in rpcrdma_reply_handler()
1134 r_xprt->rx_ia.ri_ops->ro_unmap_sync(r_xprt, req); in rpcrdma_reply_handler()
1212 __func__, rep, req, be32_to_cpu(headerp->rm_xid)); in rpcrdma_reply_handler()