Lines Matching refs:r_xprt
239 struct rpcrdma_xprt *r_xprt = in rpcrdma_connect_worker() local
241 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_connect_worker()
257 struct rpcrdma_xprt *r_xprt = container_of(work, struct rpcrdma_xprt, in xprt_rdma_connect_worker() local
259 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in xprt_rdma_connect_worker()
264 rc = rpcrdma_ep_connect(&r_xprt->rx_ep, &r_xprt->rx_ia); in xprt_rdma_connect_worker()
274 struct rpcrdma_xprt *r_xprt = container_of(xprt, struct rpcrdma_xprt, in xprt_rdma_inject_disconnect() local
277 trace_xprtrdma_inject_dsc(r_xprt); in xprt_rdma_inject_disconnect()
278 rdma_disconnect(r_xprt->rx_ia.ri_id); in xprt_rdma_inject_disconnect()
295 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_destroy() local
297 trace_xprtrdma_destroy(r_xprt); in xprt_rdma_destroy()
299 cancel_delayed_work_sync(&r_xprt->rx_connect_worker); in xprt_rdma_destroy()
303 rpcrdma_ep_destroy(&r_xprt->rx_ep, &r_xprt->rx_ia); in xprt_rdma_destroy()
304 rpcrdma_buffer_destroy(&r_xprt->rx_buf); in xprt_rdma_destroy()
305 rpcrdma_ia_close(&r_xprt->rx_ia); in xprt_rdma_destroy()
454 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_close() local
455 struct rpcrdma_ep *ep = &r_xprt->rx_ep; in xprt_rdma_close()
456 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in xprt_rdma_close()
525 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_connect() local
527 if (r_xprt->rx_ep.rep_connected != 0) { in xprt_rdma_connect()
529 schedule_delayed_work(&r_xprt->rx_connect_worker, in xprt_rdma_connect()
537 schedule_delayed_work(&r_xprt->rx_connect_worker, 0); in xprt_rdma_connect()
539 flush_delayed_work(&r_xprt->rx_connect_worker); in xprt_rdma_connect()
555 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_alloc_slot() local
558 req = rpcrdma_buffer_get(&r_xprt->rx_buf); in xprt_rdma_alloc_slot()
585 rpcrdma_get_sendbuf(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_get_sendbuf() argument
598 r_xprt->rx_stats.hardway_register_count += size; in rpcrdma_get_sendbuf()
615 rpcrdma_get_recvbuf(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_get_recvbuf() argument
628 r_xprt->rx_stats.hardway_register_count += size; in rpcrdma_get_recvbuf()
653 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate() local
661 if (!rpcrdma_get_sendbuf(r_xprt, req, rqst->rq_callsize, flags)) in xprt_rdma_allocate()
663 if (!rpcrdma_get_recvbuf(r_xprt, req, rqst->rq_rcvsize, flags)) in xprt_rdma_allocate()
686 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_free() local
690 rpcrdma_release_rqst(r_xprt, req); in xprt_rdma_free()
714 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_send_request() local
725 rc = rpcrdma_marshal_req(r_xprt, rqst); in xprt_rdma_send_request()
735 if (rpcrdma_ep_post(&r_xprt->rx_ia, &r_xprt->rx_ep, req)) in xprt_rdma_send_request()
758 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_print_stats() local
777 r_xprt->rx_stats.read_chunk_count, in xprt_rdma_print_stats()
778 r_xprt->rx_stats.write_chunk_count, in xprt_rdma_print_stats()
779 r_xprt->rx_stats.reply_chunk_count, in xprt_rdma_print_stats()
780 r_xprt->rx_stats.total_rdma_request, in xprt_rdma_print_stats()
781 r_xprt->rx_stats.total_rdma_reply, in xprt_rdma_print_stats()
782 r_xprt->rx_stats.pullup_copy_count, in xprt_rdma_print_stats()
783 r_xprt->rx_stats.fixup_copy_count, in xprt_rdma_print_stats()
784 r_xprt->rx_stats.hardway_register_count, in xprt_rdma_print_stats()
785 r_xprt->rx_stats.failed_marshal_count, in xprt_rdma_print_stats()
786 r_xprt->rx_stats.bad_reply_count, in xprt_rdma_print_stats()
787 r_xprt->rx_stats.nomsg_call_count); in xprt_rdma_print_stats()
789 r_xprt->rx_stats.mrs_recovered, in xprt_rdma_print_stats()
790 r_xprt->rx_stats.mrs_orphaned, in xprt_rdma_print_stats()
791 r_xprt->rx_stats.mrs_allocated, in xprt_rdma_print_stats()
792 r_xprt->rx_stats.local_inv_needed, in xprt_rdma_print_stats()
793 r_xprt->rx_stats.empty_sendctx_q, in xprt_rdma_print_stats()
794 r_xprt->rx_stats.reply_waits_for_send); in xprt_rdma_print_stats()