Lines Matching refs:xprt
8 #include <linux/sunrpc/xprt.h>
24 * @xprt: transport associated with these backchannel resources
29 int xprt_rdma_bc_setup(struct rpc_xprt *xprt, unsigned int reqs)
31 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
40 * @xprt: transport
44 size_t xprt_rdma_bc_maxpayload(struct rpc_xprt *xprt)
46 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
55 unsigned int xprt_rdma_bc_max_slots(struct rpc_xprt *xprt)
103 struct rpc_xprt *xprt = rqst->rq_xprt;
104 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
108 if (!xprt_connected(xprt))
111 if (!xprt_request_get_cong(xprt, rqst))
126 xprt_rdma_close(xprt);
132 * @xprt: transport associated with these backchannel resources
135 void xprt_rdma_bc_destroy(struct rpc_xprt *xprt, unsigned int reqs)
139 spin_lock(&xprt->bc_pa_lock);
140 list_for_each_entry_safe(rqst, tmp, &xprt->bc_pa_list, rq_bc_pa_list) {
142 spin_unlock(&xprt->bc_pa_lock);
146 spin_lock(&xprt->bc_pa_lock);
148 spin_unlock(&xprt->bc_pa_lock);
158 struct rpc_xprt *xprt = rqst->rq_xprt;
163 spin_lock(&xprt->bc_pa_lock);
164 list_add_tail(&rqst->rq_bc_pa_list, &xprt->bc_pa_list);
165 spin_unlock(&xprt->bc_pa_lock);
166 xprt_put(xprt);
171 struct rpc_xprt *xprt = &r_xprt->rx_xprt;
176 spin_lock(&xprt->bc_pa_lock);
177 rqst = list_first_entry_or_null(&xprt->bc_pa_list, struct rpc_rqst,
182 spin_unlock(&xprt->bc_pa_lock);
186 spin_unlock(&xprt->bc_pa_lock);
190 if (xprt->bc_alloc_count >= RPCRDMA_BACKWARD_WRS)
202 xprt->bc_alloc_count++;
204 rqst->rq_xprt = xprt;
224 struct rpc_xprt *xprt = &r_xprt->rx_xprt;
266 bc_serv = xprt->bc_serv;
267 xprt_get(xprt);
279 xprt_force_disconnect(xprt);