Lines Matching refs:xprt
147 static void rpcb_wake_rpcbind_waiters(struct rpc_xprt *xprt, int status) in rpcb_wake_rpcbind_waiters() argument
149 xprt_clear_binding(xprt); in rpcb_wake_rpcbind_waiters()
150 rpc_wake_up_status(&xprt->binding, status); in rpcb_wake_rpcbind_waiters()
651 struct rpc_xprt *xprt; in rpcb_getport_async() local
663 xprt = xprt_get(task->tk_xprt); in rpcb_getport_async()
667 rpc_sleep_on_timeout(&xprt->binding, task, in rpcb_getport_async()
668 NULL, jiffies + xprt->bind_timeout); in rpcb_getport_async()
670 if (xprt_test_and_set_binding(xprt)) { in rpcb_getport_async()
671 xprt_put(xprt); in rpcb_getport_async()
676 if (xprt_bound(xprt)) { in rpcb_getport_async()
687 proc = rpcb_next_version[xprt->bind_index].rpc_proc; in rpcb_getport_async()
688 bind_version = rpcb_next_version[xprt->bind_index].rpc_vers; in rpcb_getport_async()
691 proc = rpcb_next_version6[xprt->bind_index].rpc_proc; in rpcb_getport_async()
692 bind_version = rpcb_next_version6[xprt->bind_index].rpc_vers; in rpcb_getport_async()
699 xprt->bind_index = 0; in rpcb_getport_async()
706 rpcb_clnt = rpcb_create(xprt->xprt_net, in rpcb_getport_async()
708 xprt->servername, sap, salen, in rpcb_getport_async()
709 xprt->prot, bind_version, in rpcb_getport_async()
724 map->r_prot = xprt->prot; in rpcb_getport_async()
726 map->r_xprt = xprt; in rpcb_getport_async()
732 map->r_netid = xprt->address_strings[RPC_DISPLAY_NETID]; in rpcb_getport_async()
750 xprt->stat.bind_count++; in rpcb_getport_async()
759 rpcb_wake_rpcbind_waiters(xprt, status); in rpcb_getport_async()
761 xprt_put(xprt); in rpcb_getport_async()
771 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done() local
781 xprt->bind_index++; in rpcb_getport_done()
796 xprt->ops->set_port(xprt, map->r_port); in rpcb_getport_done()
798 xprt_set_bound(xprt); in rpcb_getport_done()