Lines Matching defs:rqst
521 * @rqst: rpc_rqst to release
525 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst)
530 rpcrdma_reply_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst));
531 if (!xprt_wake_up_backlog(xprt, rqst)) {
532 memset(rqst, 0, sizeof(*rqst));
533 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst));
561 struct rpc_rqst *rqst = task->tk_rqstp;
562 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt);
563 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
566 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize,
569 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize,
573 rqst->rq_buffer = rdmab_data(req->rl_sendbuf);
574 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf);
585 * Caller guarantees rqst->rq_buffer is non-NULL.
590 struct rpc_rqst *rqst = task->tk_rqstp;
591 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
595 frwr_unmap_sync(rpcx_to_rdmax(rqst->rq_xprt), req);
607 * @rqst: RPC message in rq_snd_buf
622 xprt_rdma_send_request(struct rpc_rqst *rqst)
624 struct rpc_xprt *xprt = rqst->rq_xprt;
625 struct rpcrdma_req *req = rpcr_to_rdmar(rqst);
630 if (unlikely(!rqst->rq_buffer))
631 return xprt_rdma_bc_send_reply(rqst);
637 if (!xprt_request_get_cong(xprt, rqst))
640 rc = rpcrdma_marshal_req(r_xprt, rqst);
645 if (rqst->rq_connect_cookie == xprt->connect_cookie)
647 rqst->rq_xtime = ktime_get();
652 rqst->rq_xmit_bytes_sent += rqst->rq_snd_buf.len;
657 if (!rpc_reply_expected(rqst->rq_task))