Lines Matching refs:rqst
588 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst) in xprt_rdma_free_slot() argument
593 memset(rqst, 0, sizeof(*rqst)); in xprt_rdma_free_slot()
594 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot()
623 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_allocate() local
624 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
625 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_allocate()
634 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize, in xprt_rdma_allocate()
637 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize, in xprt_rdma_allocate()
641 rqst->rq_buffer = rdmab_data(req->rl_sendbuf); in xprt_rdma_allocate()
642 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf); in xprt_rdma_allocate()
660 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_free() local
661 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_free()
662 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_free()
693 xprt_rdma_send_request(struct rpc_rqst *rqst) in xprt_rdma_send_request() argument
695 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
696 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_send_request()
701 if (unlikely(!rqst->rq_buffer)) in xprt_rdma_send_request()
702 return xprt_rdma_bc_send_reply(rqst); in xprt_rdma_send_request()
708 if (!xprt_request_get_cong(xprt, rqst)) in xprt_rdma_send_request()
711 rc = rpcrdma_marshal_req(r_xprt, rqst); in xprt_rdma_send_request()
716 if (rqst->rq_connect_cookie == xprt->connect_cookie) in xprt_rdma_send_request()
718 rqst->rq_xtime = ktime_get(); in xprt_rdma_send_request()
723 rqst->rq_xmit_bytes_sent += rqst->rq_snd_buf.len; in xprt_rdma_send_request()
728 if (!rpc_reply_expected(rqst->rq_task)) in xprt_rdma_send_request()