Lines Matching refs:rqst
533 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst) in xprt_rdma_free_slot() argument
538 rpcrdma_reply_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot()
539 if (!xprt_wake_up_backlog(xprt, rqst)) { in xprt_rdma_free_slot()
540 memset(rqst, 0, sizeof(*rqst)); in xprt_rdma_free_slot()
541 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot()
569 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_allocate() local
570 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
571 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_allocate()
578 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize, in xprt_rdma_allocate()
581 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize, in xprt_rdma_allocate()
585 rqst->rq_buffer = rdmab_data(req->rl_sendbuf); in xprt_rdma_allocate()
586 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf); in xprt_rdma_allocate()
602 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_free() local
603 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_free()
604 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_free()
633 xprt_rdma_send_request(struct rpc_rqst *rqst) in xprt_rdma_send_request() argument
635 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
636 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_send_request()
641 if (unlikely(!rqst->rq_buffer)) in xprt_rdma_send_request()
642 return xprt_rdma_bc_send_reply(rqst); in xprt_rdma_send_request()
648 if (!xprt_request_get_cong(xprt, rqst)) in xprt_rdma_send_request()
651 rc = rpcrdma_marshal_req(r_xprt, rqst); in xprt_rdma_send_request()
656 if (rqst->rq_connect_cookie == xprt->connect_cookie) in xprt_rdma_send_request()
658 rqst->rq_xtime = ktime_get(); in xprt_rdma_send_request()
663 rqst->rq_xmit_bytes_sent += rqst->rq_snd_buf.len; in xprt_rdma_send_request()
668 if (!rpc_reply_expected(rqst->rq_task)) in xprt_rdma_send_request()