Lines Matching defs:rqst
529 * @rqst: rpc_rqst to release
533 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst)
538 rpcrdma_reply_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst));
539 if (!xprt_wake_up_backlog(xprt, rqst)) {
540 memset(rqst, 0, sizeof(*rqst));
541 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst));
569 struct rpc_rqst *rqst = task->tk_rqstp;
570 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt);
571 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
580 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize,
583 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize,
587 rqst->rq_buffer = rdmab_data(req->rl_sendbuf);
588 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf);
599 * Caller guarantees rqst->rq_buffer is non-NULL.
604 struct rpc_rqst *rqst = task->tk_rqstp;
605 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt);
606 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
620 * @rqst: RPC message in rq_snd_buf
635 xprt_rdma_send_request(struct rpc_rqst *rqst)
637 struct rpc_xprt *xprt = rqst->rq_xprt;
638 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
643 if (unlikely(!rqst->rq_buffer))
644 return xprt_rdma_bc_send_reply(rqst);
650 if (!xprt_request_get_cong(xprt, rqst))
653 rc = rpcrdma_marshal_req(r_xprt, rqst);
658 if (rqst->rq_connect_cookie == xprt->connect_cookie)
660 rqst->rq_xtime = ktime_get();
665 rqst->rq_xmit_bytes_sent += rqst->rq_snd_buf.len;
670 if (!rpc_reply_expected(rqst->rq_task))