Lines Matching refs:rqst
534 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst) in xprt_rdma_free_slot() argument
539 rpcrdma_reply_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot()
540 if (!xprt_wake_up_backlog(xprt, rqst)) { in xprt_rdma_free_slot()
541 memset(rqst, 0, sizeof(*rqst)); in xprt_rdma_free_slot()
542 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot()
570 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_allocate() local
571 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
572 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_allocate()
575 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize, in xprt_rdma_allocate()
578 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize, in xprt_rdma_allocate()
582 rqst->rq_buffer = rdmab_data(req->rl_sendbuf); in xprt_rdma_allocate()
583 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf); in xprt_rdma_allocate()
599 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_free() local
600 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_free()
604 frwr_unmap_sync(rpcx_to_rdmax(rqst->rq_xprt), req); in xprt_rdma_free()
631 xprt_rdma_send_request(struct rpc_rqst *rqst) in xprt_rdma_send_request() argument
633 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
634 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_send_request()
639 if (unlikely(!rqst->rq_buffer)) in xprt_rdma_send_request()
640 return xprt_rdma_bc_send_reply(rqst); in xprt_rdma_send_request()
646 if (!xprt_request_get_cong(xprt, rqst)) in xprt_rdma_send_request()
649 rc = rpcrdma_marshal_req(r_xprt, rqst); in xprt_rdma_send_request()
654 if (rqst->rq_connect_cookie == xprt->connect_cookie) in xprt_rdma_send_request()
656 rqst->rq_xtime = ktime_get(); in xprt_rdma_send_request()
661 rqst->rq_xmit_bytes_sent += rqst->rq_snd_buf.len; in xprt_rdma_send_request()
666 if (!rpc_reply_expected(rqst->rq_task)) in xprt_rdma_send_request()