Lines Matching refs:xprt
25 int xprt_rdma_bc_setup(struct rpc_xprt *xprt, unsigned int reqs) in xprt_rdma_bc_setup() argument
27 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_setup()
40 size_t xprt_rdma_bc_maxpayload(struct rpc_xprt *xprt) in xprt_rdma_bc_maxpayload() argument
42 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_maxpayload()
51 unsigned int xprt_rdma_bc_max_slots(struct rpc_xprt *xprt) in xprt_rdma_bc_max_slots() argument
99 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply() local
100 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_send_reply()
104 if (!xprt_connected(xprt)) in xprt_rdma_bc_send_reply()
107 if (!xprt_request_get_cong(xprt, rqst)) in xprt_rdma_bc_send_reply()
122 xprt_rdma_close(xprt); in xprt_rdma_bc_send_reply()
131 void xprt_rdma_bc_destroy(struct rpc_xprt *xprt, unsigned int reqs) in xprt_rdma_bc_destroy() argument
135 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
136 list_for_each_entry_safe(rqst, tmp, &xprt->bc_pa_list, rq_bc_pa_list) { in xprt_rdma_bc_destroy()
138 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
142 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
144 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
155 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst() local
156 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_free_rqst()
161 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
162 list_add_tail(&rqst->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_rdma_bc_free_rqst()
163 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
164 xprt_put(xprt); in xprt_rdma_bc_free_rqst()
169 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_bc_rqst_get() local
174 spin_lock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
175 rqst = list_first_entry_or_null(&xprt->bc_pa_list, struct rpc_rqst, in rpcrdma_bc_rqst_get()
180 spin_unlock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
184 spin_unlock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
188 if (xprt->bc_alloc_count >= RPCRDMA_BACKWARD_WRS) in rpcrdma_bc_rqst_get()
200 xprt->bc_alloc_count++; in rpcrdma_bc_rqst_get()
202 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
222 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_bc_receive_call() local
264 bc_serv = xprt->bc_serv; in rpcrdma_bc_receive_call()
265 xprt_get(xprt); in rpcrdma_bc_receive_call()
277 xprt_force_disconnect(xprt); in rpcrdma_bc_receive_call()