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()
674 struct rpc_xprt *xprt; in rpcb_getport_async() local
686 xprt = xprt_get(task->tk_xprt); in rpcb_getport_async()
690 rpc_sleep_on_timeout(&xprt->binding, task, in rpcb_getport_async()
691 NULL, jiffies + xprt->bind_timeout); in rpcb_getport_async()
693 if (xprt_test_and_set_binding(xprt)) { in rpcb_getport_async()
694 xprt_put(xprt); in rpcb_getport_async()
699 if (xprt_bound(xprt)) { in rpcb_getport_async()
710 proc = rpcb_next_version[xprt->bind_index].rpc_proc; in rpcb_getport_async()
711 bind_version = rpcb_next_version[xprt->bind_index].rpc_vers; in rpcb_getport_async()
714 proc = rpcb_next_version6[xprt->bind_index].rpc_proc; in rpcb_getport_async()
715 bind_version = rpcb_next_version6[xprt->bind_index].rpc_vers; in rpcb_getport_async()
722 xprt->bind_index = 0; in rpcb_getport_async()
729 rpcb_clnt = rpcb_create(xprt->xprt_net, in rpcb_getport_async()
731 xprt->servername, sap, salen, in rpcb_getport_async()
732 xprt->prot, bind_version, in rpcb_getport_async()
747 map->r_prot = xprt->prot; in rpcb_getport_async()
749 map->r_xprt = xprt; in rpcb_getport_async()
755 map->r_netid = xprt->address_strings[RPC_DISPLAY_NETID]; in rpcb_getport_async()
777 xprt->stat.bind_count++; in rpcb_getport_async()
786 rpcb_wake_rpcbind_waiters(xprt, status); in rpcb_getport_async()
788 xprt_put(xprt); in rpcb_getport_async()
798 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done() local
808 xprt->bind_index++; in rpcb_getport_done()
823 xprt->ops->set_port(xprt, map->r_port); in rpcb_getport_done()
825 xprt_set_bound(xprt); in rpcb_getport_done()