sunrpc/xprtrdma/svc_rdma_backchannel.c

23 	struct rpc_xprt *xprt = sxprt->xpt_bc_xprt;
24 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
31 	spin_lock(&xprt->queue_lock);
32 	req = xprt_lookup_rqst(xprt, *rdma_resp);
42 	spin_unlock(&xprt->queue_lock);
49 	spin_lock(&xprt->transport_lock);
50 	xprt->cwnd = credits << RPC_CWNDSHIFT;
51 	spin_unlock(&xprt->transport_lock);
53 	spin_lock(&xprt->queue_lock);
59 	spin_unlock(&xprt->queue_lock);
138 	struct rpc_xprt *xprt = rqst->rq_xprt;
139 	struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
197 xprt_rdma_bc_close(struct rpc_xprt *xprt)
199 	xprt_disconnect_done(xprt);
200 	xprt->cwnd = RPC_CWNDSHIFT;
204 xprt_rdma_bc_put(struct rpc_xprt *xprt)
206 	xprt_rdma_free_addresses(xprt);
207 	xprt_free(xprt);
237 	struct rpc_xprt *xprt;
240 	if (args->addrlen > sizeof(xprt->addr))
243 	xprt = xprt_alloc(args->net, sizeof(*new_xprt),
246 	if (!xprt)
249 	xprt->timeout = &xprt_rdma_bc_timeout;
250 	xprt_set_bound(xprt);
251 	xprt_set_connected(xprt);
252 	xprt->bind_timeout = 0;
253 	xprt->reestablish_timeout = 0;
254 	xprt->idle_timeout = 0;
256 	xprt->prot = XPRT_TRANSPORT_BC_RDMA;
257 	xprt->ops = &xprt_rdma_bc_procs;
259 	memcpy(&xprt->addr, args->dstaddr, args->addrlen);
260 	xprt->addrlen = args->addrlen;
261 	xprt_rdma_format_addresses(xprt, (struct sockaddr *)&xprt->addr);
262 	xprt->resvport = 0;
264 	xprt->max_payload = xprt_rdma_max_inline_read;
266 	new_xprt = rpcx_to_rdmax(xprt);
267 	new_xprt->rx_buf.rb_bc_max_requests = xprt->max_reqs;
269 	xprt_get(xprt);
270 	args->bc_xprt->xpt_bc_xprt = xprt;
271 	xprt->bc_xprt = args->bc_xprt;
273 	/* Final put for backchannel xprt is in __svc_rdma_free */
274 	xprt_get(xprt);
275 	return xprt;