• Home
  • Raw
  • Download

Lines Matching refs:xprt

29 int xprt_rdma_bc_setup(struct rpc_xprt *xprt, unsigned int reqs)  in xprt_rdma_bc_setup()  argument
31 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_setup()
44 size_t xprt_rdma_bc_maxpayload(struct rpc_xprt *xprt) in xprt_rdma_bc_maxpayload() argument
46 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_maxpayload()
55 unsigned int xprt_rdma_bc_max_slots(struct rpc_xprt *xprt) in xprt_rdma_bc_max_slots() argument
103 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply() local
104 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_send_reply()
108 if (!xprt_connected(xprt)) in xprt_rdma_bc_send_reply()
111 if (!xprt_request_get_cong(xprt, rqst)) in xprt_rdma_bc_send_reply()
126 xprt_rdma_close(xprt); in xprt_rdma_bc_send_reply()
135 void xprt_rdma_bc_destroy(struct rpc_xprt *xprt, unsigned int reqs) in xprt_rdma_bc_destroy() argument
139 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
140 list_for_each_entry_safe(rqst, tmp, &xprt->bc_pa_list, rq_bc_pa_list) { in xprt_rdma_bc_destroy()
142 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
146 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
148 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
158 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst() local
163 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
164 list_add_tail(&rqst->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_rdma_bc_free_rqst()
165 spin_unlock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
166 xprt_put(xprt); in xprt_rdma_bc_free_rqst()
171 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_bc_rqst_get() local
176 spin_lock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
177 rqst = list_first_entry_or_null(&xprt->bc_pa_list, struct rpc_rqst, in rpcrdma_bc_rqst_get()
182 spin_unlock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
186 spin_unlock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
190 if (xprt->bc_alloc_count >= RPCRDMA_BACKWARD_WRS) in rpcrdma_bc_rqst_get()
202 xprt->bc_alloc_count++; in rpcrdma_bc_rqst_get()
204 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
224 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_bc_receive_call() local
266 bc_serv = xprt->bc_serv; in rpcrdma_bc_receive_call()
267 xprt_get(xprt); in rpcrdma_bc_receive_call()
279 xprt_force_disconnect(xprt); in rpcrdma_bc_receive_call()