1 // SPDX-License-Identifier: GPL-2.0-only
3  * In-kernel rpcbind client supporting versions 2, 3, and 4 of the rpcbind
123 	unsigned short		r_port;
151 	rpc_wake_up_status(&xprt->binding, status);  in rpcb_wake_rpcbind_waiters()
158 	rpcb_wake_rpcbind_waiters(map->r_xprt, map->r_status);  in rpcb_map_release()
159 	xprt_put(map->r_xprt);  in rpcb_map_release()
160 	kfree(map->r_addr);  in rpcb_map_release()
169 	spin_lock(&sn->rpcb_clnt_lock);  in rpcb_get_local()
170 	if (sn->rpcb_users)  in rpcb_get_local()
171 		sn->rpcb_users++;  in rpcb_get_local()
172 	cnt = sn->rpcb_users;  in rpcb_get_local()
173 	spin_unlock(&sn->rpcb_clnt_lock);  in rpcb_get_local()
181 	struct rpc_clnt *clnt = sn->rpcb_local_clnt;  in rpcb_put_local()
182 	struct rpc_clnt *clnt4 = sn->rpcb_local_clnt4;  in rpcb_put_local()
185 	spin_lock(&sn->rpcb_clnt_lock);  in rpcb_put_local()
186 	if (sn->rpcb_users) {  in rpcb_put_local()
187 		if (--sn->rpcb_users == 0) {  in rpcb_put_local()
188 			sn->rpcb_local_clnt = NULL;  in rpcb_put_local()
189 			sn->rpcb_local_clnt4 = NULL;  in rpcb_put_local()
191 		shutdown = !sn->rpcb_users;  in rpcb_put_local()
193 	spin_unlock(&sn->rpcb_clnt_lock);  in rpcb_put_local()
197 		 * cleanup_rpcb_clnt - remove xprtsock's sysctls, unregister  in rpcb_put_local()
213 	sn->rpcb_local_clnt = clnt;  in rpcb_set_local()
214 	sn->rpcb_local_clnt4 = clnt4;  in rpcb_set_local()
215 	sn->rpcb_is_af_local = is_af_local ? 1 : 0;  in rpcb_set_local()
217 	sn->rpcb_users = 1;  in rpcb_set_local()
222 		      + 1 + strlen((ptr)->sun_path + 1))
254 	 * Because we requested an RPC PING at transport creation time,  in rpcb_create_af_local()
327 	 * This results in an RPC ping.  On systems running portmapper,  in rpcb_create_local_net()
328 	 * the v4 ping will fail.  Proceed anyway, but disallow rpcb  in rpcb_create_local_net()
389 	switch (srvaddr->sa_family) {  in rpcb_create()
391 		((struct sockaddr_in *)srvaddr)->sin_port = htons(RPCBIND_PORT);  in rpcb_create()
394 		((struct sockaddr_in6 *)srvaddr)->sin6_port = htons(RPCBIND_PORT);  in rpcb_create()
397 		return ERR_PTR(-EAFNOSUPPORT);  in rpcb_create()
408 	if (is_set || !sn->rpcb_is_af_local)  in rpcb_register_call()
410 	msg->rpc_resp = &result;  in rpcb_register_call()
417 		return -EACCES;  in rpcb_register_call()
422  * rpcb_register - set or unset a port registration with the local rpcbind svc
440  * available by setting the passed-in port to zero.  This removes
454 int rpcb_register(struct net *net, u32 prog, u32 vers, int prot, unsigned short port)  in rpcb_register()
476 	return rpcb_register_call(sn, sn->rpcb_local_clnt, &msg, is_set);  in rpcb_register()
480  * Fill in AF_INET family-specific arguments to register
487 	struct rpcbind_args *map = msg->rpc_argp;  in rpcb_register_inet4()
488 	unsigned short port = ntohs(sin->sin_port);  in rpcb_register_inet4()
492 	map->r_addr = rpc_sockaddr2uaddr(sap, GFP_KERNEL);  in rpcb_register_inet4()
494 	msg->rpc_proc = &rpcb_procedures4[RPCBPROC_UNSET];  in rpcb_register_inet4()
496 		msg->rpc_proc = &rpcb_procedures4[RPCBPROC_SET];  in rpcb_register_inet4()
500 	result = rpcb_register_call(sn, sn->rpcb_local_clnt4, msg, is_set);  in rpcb_register_inet4()
501 	kfree(map->r_addr);  in rpcb_register_inet4()
506  * Fill in AF_INET6 family-specific arguments to register
513 	struct rpcbind_args *map = msg->rpc_argp;  in rpcb_register_inet6()
514 	unsigned short port = ntohs(sin6->sin6_port);  in rpcb_register_inet6()
518 	map->r_addr = rpc_sockaddr2uaddr(sap, GFP_KERNEL);  in rpcb_register_inet6()
520 	msg->rpc_proc = &rpcb_procedures4[RPCBPROC_UNSET];  in rpcb_register_inet6()
522 		msg->rpc_proc = &rpcb_procedures4[RPCBPROC_SET];  in rpcb_register_inet6()
526 	result = rpcb_register_call(sn, sn->rpcb_local_clnt4, msg, is_set);  in rpcb_register_inet6()
527 	kfree(map->r_addr);  in rpcb_register_inet6()
534 	struct rpcbind_args *map = msg->rpc_argp;  in rpcb_unregister_all_protofamilies()
536 	trace_rpcb_unregister(map->r_prog, map->r_vers, map->r_netid);  in rpcb_unregister_all_protofamilies()
538 	map->r_addr = "";  in rpcb_unregister_all_protofamilies()
539 	msg->rpc_proc = &rpcb_procedures4[RPCBPROC_UNSET];  in rpcb_unregister_all_protofamilies()
541 	return rpcb_register_call(sn, sn->rpcb_local_clnt4, msg, false);  in rpcb_unregister_all_protofamilies()
545  * rpcb_v4_register - set or unset a port registration with the local rpcbind
579  * as the raw address, but specifying a non-zero address is also
602 	if (sn->rpcb_local_clnt4 == NULL)  in rpcb_v4_register()
603 		return -EPROTONOSUPPORT;  in rpcb_v4_register()
610 	switch (address->sa_family) {  in rpcb_v4_register()
617 	return -EAFNOSUPPORT;  in rpcb_v4_register()
648 	struct rpc_clnt *parent = clnt->cl_parent;  in rpcb_find_transport_owner()
649 	struct rpc_xprt_switch *xps = rcu_access_pointer(clnt->cl_xpi.xpi_xpswitch);  in rpcb_find_transport_owner()
652 		if (rcu_access_pointer(parent->cl_xpi.xpi_xpswitch) != xps)  in rpcb_find_transport_owner()
654 		if (clnt->cl_autobind)  in rpcb_find_transport_owner()
657 		parent = parent->cl_parent;  in rpcb_find_transport_owner()
663  * rpcb_getport_async - obtain the port for a given RPC service on a given host
684 	clnt = rpcb_find_transport_owner(task->tk_client);  in rpcb_getport_async()
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()
708 	switch (sap->sa_family) {  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()
718 		status = -EAFNOSUPPORT;  in rpcb_getport_async()
722 		xprt->bind_index = 0;  in rpcb_getport_async()
723 		status = -EPFNOSUPPORT;  in rpcb_getport_async()
729 	rpcb_clnt = rpcb_create(xprt->xprt_net,  in rpcb_getport_async()
730 				clnt->cl_nodename,  in rpcb_getport_async()
731 				xprt->servername, sap, salen,  in rpcb_getport_async()
732 				xprt->prot, bind_version,  in rpcb_getport_async()
733 				clnt->cl_cred,  in rpcb_getport_async()
734 				task->tk_client->cl_timeout);  in rpcb_getport_async()
742 		status = -ENOMEM;  in rpcb_getport_async()
745 	map->r_prog = clnt->cl_prog;  in rpcb_getport_async()
746 	map->r_vers = clnt->cl_vers;  in rpcb_getport_async()
747 	map->r_prot = xprt->prot;  in rpcb_getport_async()
748 	map->r_port = 0;  in rpcb_getport_async()
749 	map->r_xprt = xprt;  in rpcb_getport_async()
750 	map->r_status = -EIO;  in rpcb_getport_async()
755 		map->r_netid = xprt->address_strings[RPC_DISPLAY_NETID];  in rpcb_getport_async()
756 		map->r_addr = rpc_sockaddr2uaddr(sap, rpc_task_gfp_mask());  in rpcb_getport_async()
757 		if (!map->r_addr) {  in rpcb_getport_async()
758 			status = -ENOMEM;  in rpcb_getport_async()
761 		map->r_owner = "";  in rpcb_getport_async()
764 		map->r_addr = NULL;  in rpcb_getport_async()
777 	xprt->stat.bind_count++;  in rpcb_getport_async()
787 	task->tk_status = status;  in rpcb_getport_async()
798 	struct rpc_xprt *xprt = map->r_xprt;  in rpcb_getport_done()
800 	map->r_status = child->tk_status;  in rpcb_getport_done()
803 	if (map->r_status == -EIO)  in rpcb_getport_done()
804 		map->r_status = -EPROTONOSUPPORT;  in rpcb_getport_done()
807 	if (map->r_status == -EPROTONOSUPPORT)  in rpcb_getport_done()
808 		xprt->bind_index++;  in rpcb_getport_done()
810 	if (map->r_status < 0) {  in rpcb_getport_done()
812 		map->r_port = 0;  in rpcb_getport_done()
814 	} else if (map->r_port == 0) {  in rpcb_getport_done()
816 		map->r_status = -EACCES;  in rpcb_getport_done()
819 		map->r_status = 0;  in rpcb_getport_done()
822 	trace_rpcb_setport(child, map->r_status, map->r_port);  in rpcb_getport_done()
823 	xprt->ops->set_port(xprt, map->r_port);  in rpcb_getport_done()
824 	if (map->r_port)  in rpcb_getport_done()
839 	*p++ = cpu_to_be32(rpcb->r_prog);  in rpcb_enc_mapping()
840 	*p++ = cpu_to_be32(rpcb->r_vers);  in rpcb_enc_mapping()
841 	*p++ = cpu_to_be32(rpcb->r_prot);  in rpcb_enc_mapping()
842 	*p   = cpu_to_be32(rpcb->r_port);  in rpcb_enc_mapping()
852 	rpcb->r_port = 0;  in rpcb_dec_getport()
856 		return -EIO;  in rpcb_dec_getport()
860 		return -EIO;  in rpcb_dec_getport()
862 	rpcb->r_port = port;  in rpcb_dec_getport()
874 		return -EIO;  in rpcb_dec_set()
904 	*p++ = cpu_to_be32(rpcb->r_prog);  in rpcb_enc_getaddr()
905 	*p = cpu_to_be32(rpcb->r_vers);  in rpcb_enc_getaddr()
907 	encode_rpcb_string(xdr, rpcb->r_netid, RPCBIND_MAXNETIDLEN);  in rpcb_enc_getaddr()
908 	encode_rpcb_string(xdr, rpcb->r_addr, RPCBIND_MAXUADDRLEN);  in rpcb_enc_getaddr()
909 	encode_rpcb_string(xdr, rpcb->r_owner, RPCB_MAXOWNERLEN);  in rpcb_enc_getaddr()
921 	rpcb->r_port = 0;  in rpcb_dec_getaddr()
942 	if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len,  in rpcb_dec_getaddr()
945 	rpcb->r_port = rpc_get_port(sap);  in rpcb_dec_getaddr()
950 	return -EIO;  in rpcb_dec_getaddr()