Lines Matching refs:xprt

148 static void rpcb_wake_rpcbind_waiters(struct rpc_xprt *xprt, int status)  in rpcb_wake_rpcbind_waiters()  argument
150 xprt_clear_binding(xprt); in rpcb_wake_rpcbind_waiters()
151 rpc_wake_up_status(&xprt->binding, status); in rpcb_wake_rpcbind_waiters()
651 struct rpc_xprt *xprt = rcu_dereference(clnt->cl_xprt); in rpcb_find_transport_owner() local
654 if (rcu_dereference(parent->cl_xprt) != xprt) in rpcb_find_transport_owner()
676 struct rpc_xprt *xprt; in rpcb_getport_async() local
688 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); in rpcb_getport_async()
689 } while (xprt == NULL); in rpcb_getport_async()
694 xprt->servername, clnt->cl_prog, clnt->cl_vers, xprt->prot); in rpcb_getport_async()
698 rpc_sleep_on(&xprt->binding, task, NULL); in rpcb_getport_async()
700 if (xprt_test_and_set_binding(xprt)) { in rpcb_getport_async()
703 xprt_put(xprt); in rpcb_getport_async()
708 if (xprt_bound(xprt)) { in rpcb_getport_async()
721 proc = rpcb_next_version[xprt->bind_index].rpc_proc; in rpcb_getport_async()
722 bind_version = rpcb_next_version[xprt->bind_index].rpc_vers; in rpcb_getport_async()
725 proc = rpcb_next_version6[xprt->bind_index].rpc_proc; in rpcb_getport_async()
726 bind_version = rpcb_next_version6[xprt->bind_index].rpc_vers; in rpcb_getport_async()
735 xprt->bind_index = 0; in rpcb_getport_async()
745 rpcb_clnt = rpcb_create(xprt->xprt_net, in rpcb_getport_async()
747 xprt->servername, sap, salen, in rpcb_getport_async()
748 xprt->prot, bind_version); in rpcb_getport_async()
765 map->r_prot = xprt->prot; in rpcb_getport_async()
767 map->r_xprt = xprt; in rpcb_getport_async()
773 map->r_netid = xprt->address_strings[RPC_DISPLAY_NETID]; in rpcb_getport_async()
793 xprt->stat.bind_count++; in rpcb_getport_async()
800 rpcb_wake_rpcbind_waiters(xprt, status); in rpcb_getport_async()
802 xprt_put(xprt); in rpcb_getport_async()
812 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done() local
821 xprt->bind_index++; in rpcb_getport_done()
825 xprt->ops->set_port(xprt, 0); in rpcb_getport_done()
828 xprt->ops->set_port(xprt, 0); in rpcb_getport_done()
832 xprt->ops->set_port(xprt, map->r_port); in rpcb_getport_done()
833 xprt_set_bound(xprt); in rpcb_getport_done()