Lines Matching refs:rqst

21 				 struct rpc_rqst *rqst)  in rpcrdma_bc_free_rqst()  argument
24 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in rpcrdma_bc_free_rqst()
32 kfree(rqst); in rpcrdma_bc_free_rqst()
36 struct rpc_rqst *rqst) in rpcrdma_bc_setup_rqst() argument
49 size = RPCRDMA_INLINE_WRITE_THRESHOLD(rqst); in rpcrdma_bc_setup_rqst()
55 size += RPCRDMA_INLINE_READ_THRESHOLD(rqst); in rpcrdma_bc_setup_rqst()
62 rqst->rq_buffer = (void *)req->rl_sendbuf->rg_base; in rpcrdma_bc_setup_rqst()
64 buf = &rqst->rq_snd_buf; in rpcrdma_bc_setup_rqst()
65 buf->head[0].iov_base = rqst->rq_buffer; in rpcrdma_bc_setup_rqst()
76 rpcrdma_bc_free_rqst(r_xprt, rqst); in rpcrdma_bc_setup_rqst()
120 struct rpc_rqst *rqst; in xprt_rdma_bc_setup() local
137 rqst = kzalloc(sizeof(*rqst), GFP_KERNEL); in xprt_rdma_bc_setup()
138 if (!rqst) { in xprt_rdma_bc_setup()
144 rqst->rq_xprt = &r_xprt->rx_xprt; in xprt_rdma_bc_setup()
145 INIT_LIST_HEAD(&rqst->rq_list); in xprt_rdma_bc_setup()
146 INIT_LIST_HEAD(&rqst->rq_bc_list); in xprt_rdma_bc_setup()
148 if (rpcrdma_bc_setup_rqst(r_xprt, rqst)) in xprt_rdma_bc_setup()
152 list_add(&rqst->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_rdma_bc_setup()
203 int rpcrdma_bc_marshal_reply(struct rpc_rqst *rqst) in rpcrdma_bc_marshal_reply() argument
205 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_bc_marshal_reply()
207 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in rpcrdma_bc_marshal_reply()
212 headerp->rm_xid = rqst->rq_xid; in rpcrdma_bc_marshal_reply()
221 rpclen = rqst->rq_svec[0].iov_len; in rpcrdma_bc_marshal_reply()
228 __func__, (int)rpclen, rqst->rq_svec[0].iov_base); in rpcrdma_bc_marshal_reply()
250 struct rpc_rqst *rqst, *tmp; in xprt_rdma_bc_destroy() local
253 list_for_each_entry_safe(rqst, tmp, &xprt->bc_pa_list, rq_bc_pa_list) { in xprt_rdma_bc_destroy()
254 list_del(&rqst->rq_bc_pa_list); in xprt_rdma_bc_destroy()
257 rpcrdma_bc_free_rqst(r_xprt, rqst); in xprt_rdma_bc_destroy()
268 void xprt_rdma_bc_free_rqst(struct rpc_rqst *rqst) in xprt_rdma_bc_free_rqst() argument
270 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst()
273 WARN_ON_ONCE(!test_bit(RPC_BC_PA_IN_USE, &rqst->rq_bc_pa_state)); in xprt_rdma_bc_free_rqst()
274 clear_bit(RPC_BC_PA_IN_USE, &rqst->rq_bc_pa_state); in xprt_rdma_bc_free_rqst()
278 list_add_tail(&rqst->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_rdma_bc_free_rqst()
303 struct rpc_rqst *rqst; in rpcrdma_bc_receive_call() local
332 rqst = list_first_entry(&xprt->bc_pa_list, in rpcrdma_bc_receive_call()
334 list_del(&rqst->rq_bc_pa_list); in rpcrdma_bc_receive_call()
337 pr_info("RPC: %s: using rqst %p\n", __func__, rqst); in rpcrdma_bc_receive_call()
341 rqst->rq_reply_bytes_recvd = 0; in rpcrdma_bc_receive_call()
342 rqst->rq_bytes_sent = 0; in rpcrdma_bc_receive_call()
343 rqst->rq_xid = headerp->rm_xid; in rpcrdma_bc_receive_call()
344 set_bit(RPC_BC_PA_IN_USE, &rqst->rq_bc_pa_state); in rpcrdma_bc_receive_call()
346 buf = &rqst->rq_rcv_buf; in rpcrdma_bc_receive_call()
357 req = rpcr_to_rdmar(rqst); in rpcrdma_bc_receive_call()
370 list_add(&rqst->rq_bc_list, &bc_serv->sv_cb_list); in rpcrdma_bc_receive_call()