sunrpc/xprtrdma/backchannel.c

8 #include <linux/sunrpc/xprt.h>
20  * @xprt: transport associated with these backchannel resources
25 int xprt_rdma_bc_setup(struct rpc_xprt *xprt, unsigned int reqs)
27 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
36  * @xprt: transport
40 size_t xprt_rdma_bc_maxpayload(struct rpc_xprt *xprt)
42 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
51 unsigned int xprt_rdma_bc_max_slots(struct rpc_xprt *xprt)
99 	struct rpc_xprt *xprt = rqst->rq_xprt;
100 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
104 	if (!xprt_connected(xprt))
107 	if (!xprt_request_get_cong(xprt, rqst))
122 	xprt_rdma_close(xprt);
128  * @xprt: transport associated with these backchannel resources
131 void xprt_rdma_bc_destroy(struct rpc_xprt *xprt, unsigned int reqs)
135 	spin_lock(&xprt->bc_pa_lock);
136 	list_for_each_entry_safe(rqst, tmp, &xprt->bc_pa_list, rq_bc_pa_list) {
138 		spin_unlock(&xprt->bc_pa_lock);
142 		spin_lock(&xprt->bc_pa_lock);
144 	spin_unlock(&xprt->bc_pa_lock);
155 	struct rpc_xprt *xprt = rqst->rq_xprt;
156 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
161 	spin_lock(&xprt->bc_pa_lock);
162 	list_add_tail(&rqst->rq_bc_pa_list, &xprt->bc_pa_list);
163 	spin_unlock(&xprt->bc_pa_lock);
164 	xprt_put(xprt);
169 	struct rpc_xprt *xprt = &r_xprt->rx_xprt;
174 	spin_lock(&xprt->bc_pa_lock);
175 	rqst = list_first_entry_or_null(&xprt->bc_pa_list, struct rpc_rqst,
180 	spin_unlock(&xprt->bc_pa_lock);
184 	spin_unlock(&xprt->bc_pa_lock);
188 	if (xprt->bc_alloc_count >= RPCRDMA_BACKWARD_WRS)
200 	xprt->bc_alloc_count++;
202 	rqst->rq_xprt = xprt;
222 	struct rpc_xprt *xprt = &r_xprt->rx_xprt;
264 	bc_serv = xprt->bc_serv;
265 	xprt_get(xprt);
275 	xprt_force_disconnect(xprt);