18360efbdSAlfred Perlstein /* $NetBSD: svc_simple.c,v 1.20 2000/07/06 03:10:35 christos Exp $ */
28360efbdSAlfred Perlstein
32e322d37SHiroki Sato /*-
48a16b7a1SPedro F. Giffuni * SPDX-License-Identifier: BSD-3-Clause
58a16b7a1SPedro F. Giffuni *
62e322d37SHiroki Sato * Copyright (c) 2009, Sun Microsystems, Inc.
72e322d37SHiroki Sato * All rights reserved.
899064799SGarrett Wollman *
92e322d37SHiroki Sato * Redistribution and use in source and binary forms, with or without
102e322d37SHiroki Sato * modification, are permitted provided that the following conditions are met:
112e322d37SHiroki Sato * - Redistributions of source code must retain the above copyright notice,
122e322d37SHiroki Sato * this list of conditions and the following disclaimer.
132e322d37SHiroki Sato * - Redistributions in binary form must reproduce the above copyright notice,
142e322d37SHiroki Sato * this list of conditions and the following disclaimer in the documentation
152e322d37SHiroki Sato * and/or other materials provided with the distribution.
162e322d37SHiroki Sato * - Neither the name of Sun Microsystems, Inc. nor the names of its
172e322d37SHiroki Sato * contributors may be used to endorse or promote products derived
182e322d37SHiroki Sato * from this software without specific prior written permission.
1999064799SGarrett Wollman *
202e322d37SHiroki Sato * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
212e322d37SHiroki Sato * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
222e322d37SHiroki Sato * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
232e322d37SHiroki Sato * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
242e322d37SHiroki Sato * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
252e322d37SHiroki Sato * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
262e322d37SHiroki Sato * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
272e322d37SHiroki Sato * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
282e322d37SHiroki Sato * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
292e322d37SHiroki Sato * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
302e322d37SHiroki Sato * POSSIBILITY OF SUCH DAMAGE.
3199064799SGarrett Wollman */
328360efbdSAlfred Perlstein /*
338360efbdSAlfred Perlstein * Copyright (c) 1986-1991 by Sun Microsystems Inc.
348360efbdSAlfred Perlstein */
3599064799SGarrett Wollman
3699064799SGarrett Wollman /*
3799064799SGarrett Wollman * svc_simple.c
3899064799SGarrett Wollman * Simplified front end to rpc.
3999064799SGarrett Wollman */
4099064799SGarrett Wollman
418360efbdSAlfred Perlstein /*
428360efbdSAlfred Perlstein * This interface creates a virtual listener for all the services
4332223c1bSPedro F. Giffuni * started through rpc_reg(). It listens on the same endpoint for
448360efbdSAlfred Perlstein * all the services and then executes the corresponding service
458360efbdSAlfred Perlstein * for the given prognum and procnum.
468360efbdSAlfred Perlstein */
478360efbdSAlfred Perlstein
488360efbdSAlfred Perlstein #include "namespace.h"
499f5afc13SIan Dowse #include "reentrant.h"
508360efbdSAlfred Perlstein #include <sys/types.h>
518360efbdSAlfred Perlstein #include <rpc/rpc.h>
528360efbdSAlfred Perlstein #include <rpc/nettype.h>
5399064799SGarrett Wollman #include <stdio.h>
544c3af266SPoul-Henning Kamp #include <stdlib.h>
554c3af266SPoul-Henning Kamp #include <string.h>
568360efbdSAlfred Perlstein #include <err.h>
578360efbdSAlfred Perlstein #include "un-namespace.h"
588360efbdSAlfred Perlstein
598360efbdSAlfred Perlstein #include "rpc_com.h"
60235baf26SDaniel Eischen #include "mt_misc.h"
618360efbdSAlfred Perlstein
62c05ac53bSDavid E. O'Brien static void universal(struct svc_req *, SVCXPRT *);
6399064799SGarrett Wollman
6499064799SGarrett Wollman static struct proglst {
65c05ac53bSDavid E. O'Brien char *(*p_progname)(char *);
668360efbdSAlfred Perlstein rpcprog_t p_prognum;
678360efbdSAlfred Perlstein rpcvers_t p_versnum;
688360efbdSAlfred Perlstein rpcproc_t p_procnum;
698360efbdSAlfred Perlstein SVCXPRT *p_transp;
708360efbdSAlfred Perlstein char *p_netid;
718360efbdSAlfred Perlstein char *p_xdrbuf;
728360efbdSAlfred Perlstein int p_recvsz;
7399064799SGarrett Wollman xdrproc_t p_inproc, p_outproc;
7499064799SGarrett Wollman struct proglst *p_nxt;
7599064799SGarrett Wollman } *proglst;
768360efbdSAlfred Perlstein
778360efbdSAlfred Perlstein static const char rpc_reg_err[] = "%s: %s";
788360efbdSAlfred Perlstein static const char rpc_reg_msg[] = "rpc_reg: ";
798360efbdSAlfred Perlstein static const char __reg_err1[] = "can't find appropriate transport";
808360efbdSAlfred Perlstein static const char __reg_err2[] = "can't get protocol info";
818360efbdSAlfred Perlstein static const char __reg_err3[] = "unsupported transport size";
828360efbdSAlfred Perlstein static const char __no_mem_str[] = "out of memory";
838360efbdSAlfred Perlstein
848360efbdSAlfred Perlstein /*
858360efbdSAlfred Perlstein * For simplified, easy to use kind of rpc interfaces.
868360efbdSAlfred Perlstein * nettype indicates the type of transport on which the service will be
878360efbdSAlfred Perlstein * listening. Used for conservation of the system resource. Only one
888360efbdSAlfred Perlstein * handle is created for all the services (actually one of each netid)
898360efbdSAlfred Perlstein * and same xdrbuf is used for same netid. The size of the arguments
908360efbdSAlfred Perlstein * is also limited by the recvsize for that transport, even if it is
918360efbdSAlfred Perlstein * a COTS transport. This may be wrong, but for cases like these, they
928360efbdSAlfred Perlstein * should not use the simplified interfaces like this.
93587cf682SCraig Rodrigues *
94587cf682SCraig Rodrigues * prognum - program number
95587cf682SCraig Rodrigues * versnum - version number
96587cf682SCraig Rodrigues * procnum - procedure number
97587cf682SCraig Rodrigues * progname - Server routine
98587cf682SCraig Rodrigues * inproc, outproc - in/out XDR procedures
99587cf682SCraig Rodrigues * nettype - nettype
1008360efbdSAlfred Perlstein */
10175a98e21SPeter Wemm int
rpc_reg(rpcprog_t prognum,rpcvers_t versnum,rpcproc_t procnum,char * (* progname)(char *),xdrproc_t inproc,xdrproc_t outproc,char * nettype)102587cf682SCraig Rodrigues rpc_reg(rpcprog_t prognum, rpcvers_t versnum, rpcproc_t procnum,
103587cf682SCraig Rodrigues char *(*progname)(char *), xdrproc_t inproc, xdrproc_t outproc,
104587cf682SCraig Rodrigues char *nettype)
10599064799SGarrett Wollman {
1068360efbdSAlfred Perlstein struct netconfig *nconf;
1078360efbdSAlfred Perlstein int done = FALSE;
1088360efbdSAlfred Perlstein void *handle;
1098360efbdSAlfred Perlstein
11099064799SGarrett Wollman
11199064799SGarrett Wollman if (procnum == NULLPROC) {
1128360efbdSAlfred Perlstein warnx("%s can't reassign procedure number %u", rpc_reg_msg,
1138360efbdSAlfred Perlstein NULLPROC);
11499064799SGarrett Wollman return (-1);
11599064799SGarrett Wollman }
1168360efbdSAlfred Perlstein
1178360efbdSAlfred Perlstein if (nettype == NULL)
1188360efbdSAlfred Perlstein nettype = "netpath"; /* The default behavior */
1198360efbdSAlfred Perlstein if ((handle = __rpc_setconf(nettype)) == NULL) {
1208360efbdSAlfred Perlstein warnx(rpc_reg_err, rpc_reg_msg, __reg_err1);
12199064799SGarrett Wollman return (-1);
12299064799SGarrett Wollman }
1238360efbdSAlfred Perlstein /* VARIABLES PROTECTED BY proglst_lock: proglst */
1248360efbdSAlfred Perlstein mutex_lock(&proglst_lock);
1258360efbdSAlfred Perlstein while ((nconf = __rpc_getconf(handle)) != NULL) {
1268360efbdSAlfred Perlstein struct proglst *pl;
1278360efbdSAlfred Perlstein SVCXPRT *svcxprt;
1288360efbdSAlfred Perlstein int madenow;
1298360efbdSAlfred Perlstein u_int recvsz;
1308360efbdSAlfred Perlstein char *xdrbuf;
1318360efbdSAlfred Perlstein char *netid;
1328360efbdSAlfred Perlstein
1338360efbdSAlfred Perlstein madenow = FALSE;
1348360efbdSAlfred Perlstein svcxprt = NULL;
1358d630135SAlfred Perlstein recvsz = 0;
1368d630135SAlfred Perlstein xdrbuf = netid = NULL;
1378d630135SAlfred Perlstein for (pl = proglst; pl; pl = pl->p_nxt) {
1388360efbdSAlfred Perlstein if (strcmp(pl->p_netid, nconf->nc_netid) == 0) {
1398360efbdSAlfred Perlstein svcxprt = pl->p_transp;
1408360efbdSAlfred Perlstein xdrbuf = pl->p_xdrbuf;
1418360efbdSAlfred Perlstein recvsz = pl->p_recvsz;
1428360efbdSAlfred Perlstein netid = pl->p_netid;
1438360efbdSAlfred Perlstein break;
14499064799SGarrett Wollman }
1458d630135SAlfred Perlstein }
1468360efbdSAlfred Perlstein
1478360efbdSAlfred Perlstein if (svcxprt == NULL) {
1488360efbdSAlfred Perlstein struct __rpc_sockinfo si;
1498360efbdSAlfred Perlstein
1508360efbdSAlfred Perlstein svcxprt = svc_tli_create(RPC_ANYFD, nconf, NULL, 0, 0);
1518360efbdSAlfred Perlstein if (svcxprt == NULL)
1528360efbdSAlfred Perlstein continue;
1538360efbdSAlfred Perlstein if (!__rpc_fd2sockinfo(svcxprt->xp_fd, &si)) {
1548360efbdSAlfred Perlstein warnx(rpc_reg_err, rpc_reg_msg, __reg_err2);
1558360efbdSAlfred Perlstein SVC_DESTROY(svcxprt);
1568360efbdSAlfred Perlstein continue;
15799064799SGarrett Wollman }
1588360efbdSAlfred Perlstein recvsz = __rpc_get_t_size(si.si_af, si.si_proto, 0);
1598360efbdSAlfred Perlstein if (recvsz == 0) {
1608360efbdSAlfred Perlstein warnx(rpc_reg_err, rpc_reg_msg, __reg_err3);
1618360efbdSAlfred Perlstein SVC_DESTROY(svcxprt);
1628360efbdSAlfred Perlstein continue;
1638360efbdSAlfred Perlstein }
1648360efbdSAlfred Perlstein if (((xdrbuf = malloc((unsigned)recvsz)) == NULL) ||
1658360efbdSAlfred Perlstein ((netid = strdup(nconf->nc_netid)) == NULL)) {
1668360efbdSAlfred Perlstein warnx(rpc_reg_err, rpc_reg_msg, __no_mem_str);
1678306b515SMartin Blapp free(xdrbuf);
1688306b515SMartin Blapp free(netid);
1698360efbdSAlfred Perlstein SVC_DESTROY(svcxprt);
1708360efbdSAlfred Perlstein break;
1718360efbdSAlfred Perlstein }
1728360efbdSAlfred Perlstein madenow = TRUE;
1738360efbdSAlfred Perlstein }
1748360efbdSAlfred Perlstein /*
1758360efbdSAlfred Perlstein * Check if this (program, version, netid) had already been
1768360efbdSAlfred Perlstein * registered. The check may save a few RPC calls to rpcbind
1778360efbdSAlfred Perlstein */
1788360efbdSAlfred Perlstein for (pl = proglst; pl; pl = pl->p_nxt)
1798360efbdSAlfred Perlstein if ((pl->p_prognum == prognum) &&
1808360efbdSAlfred Perlstein (pl->p_versnum == versnum) &&
1818360efbdSAlfred Perlstein (strcmp(pl->p_netid, netid) == 0))
1828360efbdSAlfred Perlstein break;
1838360efbdSAlfred Perlstein if (pl == NULL) { /* Not yet */
1848360efbdSAlfred Perlstein (void) rpcb_unset(prognum, versnum, nconf);
1858360efbdSAlfred Perlstein } else {
1868360efbdSAlfred Perlstein /* so that svc_reg does not call rpcb_set() */
1878360efbdSAlfred Perlstein nconf = NULL;
1888360efbdSAlfred Perlstein }
1898360efbdSAlfred Perlstein
1908360efbdSAlfred Perlstein if (!svc_reg(svcxprt, prognum, versnum, universal, nconf)) {
1918360efbdSAlfred Perlstein warnx("%s couldn't register prog %u vers %u for %s",
1928360efbdSAlfred Perlstein rpc_reg_msg, (unsigned)prognum,
1938360efbdSAlfred Perlstein (unsigned)versnum, netid);
1948360efbdSAlfred Perlstein if (madenow) {
1958360efbdSAlfred Perlstein SVC_DESTROY(svcxprt);
1968360efbdSAlfred Perlstein free(xdrbuf);
1978360efbdSAlfred Perlstein free(netid);
1988360efbdSAlfred Perlstein }
1998360efbdSAlfred Perlstein continue;
2008360efbdSAlfred Perlstein }
2018360efbdSAlfred Perlstein
2028360efbdSAlfred Perlstein pl = malloc(sizeof (struct proglst));
20399064799SGarrett Wollman if (pl == NULL) {
2048360efbdSAlfred Perlstein warnx(rpc_reg_err, rpc_reg_msg, __no_mem_str);
2058360efbdSAlfred Perlstein if (madenow) {
2068360efbdSAlfred Perlstein SVC_DESTROY(svcxprt);
2078360efbdSAlfred Perlstein free(xdrbuf);
2088360efbdSAlfred Perlstein free(netid);
2098360efbdSAlfred Perlstein }
2108360efbdSAlfred Perlstein break;
21199064799SGarrett Wollman }
21299064799SGarrett Wollman pl->p_progname = progname;
21399064799SGarrett Wollman pl->p_prognum = prognum;
2148360efbdSAlfred Perlstein pl->p_versnum = versnum;
21599064799SGarrett Wollman pl->p_procnum = procnum;
21699064799SGarrett Wollman pl->p_inproc = inproc;
21799064799SGarrett Wollman pl->p_outproc = outproc;
2188360efbdSAlfred Perlstein pl->p_transp = svcxprt;
2198360efbdSAlfred Perlstein pl->p_xdrbuf = xdrbuf;
2208360efbdSAlfred Perlstein pl->p_recvsz = recvsz;
2218360efbdSAlfred Perlstein pl->p_netid = netid;
22299064799SGarrett Wollman pl->p_nxt = proglst;
22399064799SGarrett Wollman proglst = pl;
2248360efbdSAlfred Perlstein done = TRUE;
2258360efbdSAlfred Perlstein }
2268360efbdSAlfred Perlstein __rpc_endconf(handle);
2278360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
2288360efbdSAlfred Perlstein
2298360efbdSAlfred Perlstein if (done == FALSE) {
23032223c1bSPedro F. Giffuni warnx("%s can't find suitable transport for %s",
2318360efbdSAlfred Perlstein rpc_reg_msg, nettype);
2328360efbdSAlfred Perlstein return (-1);
2338360efbdSAlfred Perlstein }
23499064799SGarrett Wollman return (0);
23599064799SGarrett Wollman }
23699064799SGarrett Wollman
2378360efbdSAlfred Perlstein /*
2388360efbdSAlfred Perlstein * The universal handler for the services registered using registerrpc.
2398360efbdSAlfred Perlstein * It handles both the connectionless and the connection oriented cases.
2408360efbdSAlfred Perlstein */
2418360efbdSAlfred Perlstein
24299064799SGarrett Wollman static void
universal(struct svc_req * rqstp,SVCXPRT * transp)243587cf682SCraig Rodrigues universal(struct svc_req *rqstp, SVCXPRT *transp)
24499064799SGarrett Wollman {
2458360efbdSAlfred Perlstein rpcprog_t prog;
2468360efbdSAlfred Perlstein rpcvers_t vers;
2478360efbdSAlfred Perlstein rpcproc_t proc;
24899064799SGarrett Wollman char *outdata;
2498360efbdSAlfred Perlstein char *xdrbuf;
25099064799SGarrett Wollman struct proglst *pl;
25199064799SGarrett Wollman
25299064799SGarrett Wollman /*
25399064799SGarrett Wollman * enforce "procnum 0 is echo" convention
25499064799SGarrett Wollman */
25599064799SGarrett Wollman if (rqstp->rq_proc == NULLPROC) {
2568360efbdSAlfred Perlstein if (svc_sendreply(transp, (xdrproc_t) xdr_void, NULL) ==
2578360efbdSAlfred Perlstein FALSE) {
2588360efbdSAlfred Perlstein warnx("svc_sendreply failed");
25999064799SGarrett Wollman }
26099064799SGarrett Wollman return;
26199064799SGarrett Wollman }
26299064799SGarrett Wollman prog = rqstp->rq_prog;
2638360efbdSAlfred Perlstein vers = rqstp->rq_vers;
26499064799SGarrett Wollman proc = rqstp->rq_proc;
2658360efbdSAlfred Perlstein mutex_lock(&proglst_lock);
2668360efbdSAlfred Perlstein for (pl = proglst; pl; pl = pl->p_nxt)
2678360efbdSAlfred Perlstein if (pl->p_prognum == prog && pl->p_procnum == proc &&
2688360efbdSAlfred Perlstein pl->p_versnum == vers &&
2698360efbdSAlfred Perlstein (strcmp(pl->p_netid, transp->xp_netid) == 0)) {
27099064799SGarrett Wollman /* decode arguments into a CLEAN buffer */
2718360efbdSAlfred Perlstein xdrbuf = pl->p_xdrbuf;
2728360efbdSAlfred Perlstein /* Zero the arguments: reqd ! */
273a6221f7bSPedro F. Giffuni (void) memset(xdrbuf, 0, (size_t)pl->p_recvsz);
2748360efbdSAlfred Perlstein /*
2758360efbdSAlfred Perlstein * Assuming that sizeof (xdrbuf) would be enough
2768360efbdSAlfred Perlstein * for the arguments; if not then the program
2778360efbdSAlfred Perlstein * may bomb. BEWARE!
2788360efbdSAlfred Perlstein */
27999064799SGarrett Wollman if (!svc_getargs(transp, pl->p_inproc, xdrbuf)) {
28099064799SGarrett Wollman svcerr_decode(transp);
2818360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
28299064799SGarrett Wollman return;
28399064799SGarrett Wollman }
28499064799SGarrett Wollman outdata = (*(pl->p_progname))(xdrbuf);
2858360efbdSAlfred Perlstein if (outdata == NULL &&
2868360efbdSAlfred Perlstein pl->p_outproc != (xdrproc_t) xdr_void){
28799064799SGarrett Wollman /* there was an error */
2888360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
28999064799SGarrett Wollman return;
2908360efbdSAlfred Perlstein }
29199064799SGarrett Wollman if (!svc_sendreply(transp, pl->p_outproc, outdata)) {
2928360efbdSAlfred Perlstein warnx(
2938360efbdSAlfred Perlstein "rpc: rpc_reg trouble replying to prog %u vers %u",
2948360efbdSAlfred Perlstein (unsigned)prog, (unsigned)vers);
2958360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
2968360efbdSAlfred Perlstein return;
29799064799SGarrett Wollman }
29899064799SGarrett Wollman /* free the decoded arguments */
29999064799SGarrett Wollman (void)svc_freeargs(transp, pl->p_inproc, xdrbuf);
3008360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
30199064799SGarrett Wollman return;
30299064799SGarrett Wollman }
3038360efbdSAlfred Perlstein mutex_unlock(&proglst_lock);
3048360efbdSAlfred Perlstein /* This should never happen */
3058360efbdSAlfred Perlstein warnx("rpc: rpc_reg: never registered prog %u vers %u",
3068360efbdSAlfred Perlstein (unsigned)prog, (unsigned)vers);
3078360efbdSAlfred Perlstein return;
30899064799SGarrett Wollman }
309