svc_simple.c revision 1.20 1 1.20 christos /* $NetBSD: svc_simple.c,v 1.20 2000/07/06 03:10:35 christos Exp $ */
2 1.3 cgd
3 1.1 cgd /*
4 1.1 cgd * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
5 1.1 cgd * unrestricted use provided that this legend is included on all tape
6 1.1 cgd * media and as a part of the software program in whole or part. Users
7 1.1 cgd * may copy or modify Sun RPC without charge, but are not authorized
8 1.1 cgd * to license or distribute it to anyone else except as part of a product or
9 1.1 cgd * program developed by the user.
10 1.1 cgd *
11 1.1 cgd * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
12 1.1 cgd * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
13 1.1 cgd * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
14 1.1 cgd *
15 1.1 cgd * Sun RPC is provided with no support and without any obligation on the
16 1.1 cgd * part of Sun Microsystems, Inc. to assist in its use, correction,
17 1.1 cgd * modification or enhancement.
18 1.1 cgd *
19 1.1 cgd * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
20 1.1 cgd * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
21 1.1 cgd * OR ANY PART THEREOF.
22 1.1 cgd *
23 1.1 cgd * In no event will Sun Microsystems, Inc. be liable for any lost revenue
24 1.1 cgd * or profits or other special, indirect and consequential damages, even if
25 1.1 cgd * Sun has been advised of the possibility of such damages.
26 1.1 cgd *
27 1.1 cgd * Sun Microsystems, Inc.
28 1.1 cgd * 2550 Garcia Avenue
29 1.1 cgd * Mountain View, California 94043
30 1.1 cgd */
31 1.19 fvdl /*
32 1.19 fvdl * Copyright (c) 1986-1991 by Sun Microsystems Inc.
33 1.19 fvdl */
34 1.1 cgd
35 1.19 fvdl /* #pragma ident "@(#)svc_simple.c 1.18 94/04/24 SMI" */
36 1.1 cgd
37 1.19 fvdl /*
38 1.1 cgd * svc_simple.c
39 1.1 cgd * Simplified front end to rpc.
40 1.19 fvdl */
41 1.19 fvdl
42 1.19 fvdl /*
43 1.19 fvdl * This interface creates a virtual listener for all the services
44 1.19 fvdl * started thru rpc_reg(). It listens on the same endpoint for
45 1.19 fvdl * all the services and then executes the corresponding service
46 1.19 fvdl * for the given prognum and procnum.
47 1.1 cgd */
48 1.1 cgd
49 1.7 jtc #include "namespace.h"
50 1.19 fvdl #include "reentrant.h"
51 1.10 lukem #include <sys/types.h>
52 1.19 fvdl #include <rpc/rpc.h>
53 1.20 christos #include <rpc/nettype.h>
54 1.1 cgd #include <stdio.h>
55 1.2 cgd #include <stdlib.h>
56 1.4 jtc #include <string.h>
57 1.19 fvdl #include <err.h>
58 1.10 lukem
59 1.19 fvdl #include "rpc_com.h"
60 1.7 jtc
61 1.7 jtc #ifdef __weak_alias
62 1.19 fvdl __weak_alias(rpc_reg,_rpc_reg)
63 1.7 jtc #endif
64 1.1 cgd
65 1.19 fvdl static void universal __P((struct svc_req *, SVCXPRT *));
66 1.19 fvdl
67 1.1 cgd static struct proglst {
68 1.19 fvdl char *(*p_progname) __P((char *));
69 1.19 fvdl rpcprog_t p_prognum;
70 1.19 fvdl rpcvers_t p_versnum;
71 1.19 fvdl rpcproc_t p_procnum;
72 1.19 fvdl SVCXPRT *p_transp;
73 1.19 fvdl char *p_netid;
74 1.19 fvdl char *p_xdrbuf;
75 1.19 fvdl int p_recvsz;
76 1.1 cgd xdrproc_t p_inproc, p_outproc;
77 1.1 cgd struct proglst *p_nxt;
78 1.1 cgd } *proglst;
79 1.6 christos
80 1.19 fvdl static const char rpc_reg_err[] = "%s: %s";
81 1.19 fvdl static const char rpc_reg_msg[] = "rpc_reg: ";
82 1.19 fvdl static const char __reg_err1[] = "can't find appropriate transport";
83 1.19 fvdl static const char __reg_err2[] = "can't get protocol info";
84 1.19 fvdl static const char __reg_err3[] = "unsupported transport size";
85 1.19 fvdl static const char __no_mem_str[] = "out of memory";
86 1.1 cgd
87 1.19 fvdl /*
88 1.19 fvdl * For simplified, easy to use kind of rpc interfaces.
89 1.19 fvdl * nettype indicates the type of transport on which the service will be
90 1.19 fvdl * listening. Used for conservation of the system resource. Only one
91 1.19 fvdl * handle is created for all the services (actually one of each netid)
92 1.19 fvdl * and same xdrbuf is used for same netid. The size of the arguments
93 1.19 fvdl * is also limited by the recvsize for that transport, even if it is
94 1.19 fvdl * a COTS transport. This may be wrong, but for cases like these, they
95 1.19 fvdl * should not use the simplified interfaces like this.
96 1.19 fvdl */
97 1.6 christos
98 1.5 jtc int
99 1.19 fvdl rpc_reg(prognum, versnum, procnum, progname, inproc, outproc, nettype)
100 1.19 fvdl rpcprog_t prognum; /* program number */
101 1.19 fvdl rpcvers_t versnum; /* version number */
102 1.19 fvdl rpcproc_t procnum; /* procedure number */
103 1.19 fvdl char *(*progname) __P((char *)); /* Server routine */
104 1.19 fvdl xdrproc_t inproc, outproc; /* in/out XDR procedures */
105 1.19 fvdl char *nettype; /* nettype */
106 1.1 cgd {
107 1.19 fvdl struct netconfig *nconf;
108 1.19 fvdl int done = FALSE;
109 1.19 fvdl void *handle;
110 1.19 fvdl #ifdef __REENT
111 1.19 fvdl extern mutex_t proglst_lock;
112 1.19 fvdl #endif
113 1.19 fvdl
114 1.19 fvdl
115 1.19 fvdl
116 1.1 cgd if (procnum == NULLPROC) {
117 1.19 fvdl warnx("%s can't reassign procedure number %u", rpc_reg_msg,
118 1.19 fvdl NULLPROC);
119 1.19 fvdl return (-1);
120 1.19 fvdl }
121 1.19 fvdl
122 1.19 fvdl if (nettype == NULL)
123 1.19 fvdl nettype = "netpath"; /* The default behavior */
124 1.19 fvdl if ((handle = __rpc_setconf(nettype)) == NULL) {
125 1.19 fvdl warnx(rpc_reg_err, rpc_reg_msg, __reg_err1);
126 1.1 cgd return (-1);
127 1.1 cgd }
128 1.19 fvdl /* VARIABLES PROTECTED BY proglst_lock: proglst */
129 1.19 fvdl mutex_lock(&proglst_lock);
130 1.20 christos while ((nconf = __rpc_getconf(handle)) != NULL) {
131 1.19 fvdl struct proglst *pl;
132 1.19 fvdl SVCXPRT *svcxprt;
133 1.19 fvdl int madenow;
134 1.19 fvdl u_int recvsz;
135 1.19 fvdl char *xdrbuf;
136 1.19 fvdl char *netid;
137 1.19 fvdl
138 1.19 fvdl madenow = FALSE;
139 1.20 christos svcxprt = NULL;
140 1.19 fvdl for (pl = proglst; pl; pl = pl->p_nxt)
141 1.19 fvdl if (strcmp(pl->p_netid, nconf->nc_netid) == 0) {
142 1.19 fvdl svcxprt = pl->p_transp;
143 1.19 fvdl xdrbuf = pl->p_xdrbuf;
144 1.19 fvdl recvsz = pl->p_recvsz;
145 1.19 fvdl netid = pl->p_netid;
146 1.19 fvdl break;
147 1.19 fvdl }
148 1.19 fvdl
149 1.20 christos if (svcxprt == NULL) {
150 1.19 fvdl struct __rpc_sockinfo si;
151 1.19 fvdl
152 1.20 christos svcxprt = svc_tli_create(RPC_ANYFD, nconf, NULL, 0, 0);
153 1.20 christos if (svcxprt == NULL)
154 1.19 fvdl continue;
155 1.19 fvdl if (!__rpc_fd2sockinfo(svcxprt->xp_fd, &si)) {
156 1.19 fvdl warnx(rpc_reg_err, rpc_reg_msg, __reg_err2);
157 1.19 fvdl SVC_DESTROY(svcxprt);
158 1.19 fvdl continue;
159 1.19 fvdl }
160 1.19 fvdl recvsz = __rpc_get_t_size(si.si_af, si.si_proto, 0);
161 1.19 fvdl if (recvsz == 0) {
162 1.19 fvdl warnx(rpc_reg_err, rpc_reg_msg, __reg_err3);
163 1.19 fvdl SVC_DESTROY(svcxprt);
164 1.19 fvdl continue;
165 1.19 fvdl }
166 1.19 fvdl if (((xdrbuf = malloc((unsigned)recvsz)) == NULL) ||
167 1.19 fvdl ((netid = strdup(nconf->nc_netid)) == NULL)) {
168 1.19 fvdl warnx(rpc_reg_err, rpc_reg_msg, __no_mem_str);
169 1.19 fvdl SVC_DESTROY(svcxprt);
170 1.19 fvdl break;
171 1.19 fvdl }
172 1.19 fvdl madenow = TRUE;
173 1.19 fvdl }
174 1.19 fvdl /*
175 1.19 fvdl * Check if this (program, version, netid) had already been
176 1.19 fvdl * registered. The check may save a few RPC calls to rpcbind
177 1.19 fvdl */
178 1.19 fvdl for (pl = proglst; pl; pl = pl->p_nxt)
179 1.19 fvdl if ((pl->p_prognum == prognum) &&
180 1.19 fvdl (pl->p_versnum == versnum) &&
181 1.19 fvdl (strcmp(pl->p_netid, netid) == 0))
182 1.19 fvdl break;
183 1.19 fvdl if (pl == NULL) { /* Not yet */
184 1.19 fvdl (void) rpcb_unset(prognum, versnum, nconf);
185 1.19 fvdl } else {
186 1.19 fvdl /* so that svc_reg does not call rpcb_set() */
187 1.19 fvdl nconf = NULL;
188 1.19 fvdl }
189 1.19 fvdl
190 1.19 fvdl if (!svc_reg(svcxprt, prognum, versnum, universal, nconf)) {
191 1.19 fvdl warnx("%s couldn't register prog %u vers %u for %s",
192 1.19 fvdl rpc_reg_msg, (unsigned)prognum,
193 1.19 fvdl (unsigned)versnum, netid);
194 1.19 fvdl if (madenow) {
195 1.19 fvdl SVC_DESTROY(svcxprt);
196 1.19 fvdl free(xdrbuf);
197 1.19 fvdl free(netid);
198 1.19 fvdl }
199 1.19 fvdl continue;
200 1.19 fvdl }
201 1.19 fvdl
202 1.20 christos pl = malloc(sizeof (struct proglst));
203 1.20 christos if (pl == NULL) {
204 1.19 fvdl warnx(rpc_reg_err, rpc_reg_msg, __no_mem_str);
205 1.19 fvdl if (madenow) {
206 1.19 fvdl SVC_DESTROY(svcxprt);
207 1.19 fvdl free(xdrbuf);
208 1.19 fvdl free(netid);
209 1.19 fvdl }
210 1.19 fvdl break;
211 1.1 cgd }
212 1.19 fvdl pl->p_progname = progname;
213 1.19 fvdl pl->p_prognum = prognum;
214 1.19 fvdl pl->p_versnum = versnum;
215 1.19 fvdl pl->p_procnum = procnum;
216 1.19 fvdl pl->p_inproc = inproc;
217 1.19 fvdl pl->p_outproc = outproc;
218 1.19 fvdl pl->p_transp = svcxprt;
219 1.19 fvdl pl->p_xdrbuf = xdrbuf;
220 1.19 fvdl pl->p_recvsz = recvsz;
221 1.19 fvdl pl->p_netid = netid;
222 1.19 fvdl pl->p_nxt = proglst;
223 1.19 fvdl proglst = pl;
224 1.19 fvdl done = TRUE;
225 1.1 cgd }
226 1.19 fvdl __rpc_endconf(handle);
227 1.19 fvdl mutex_unlock(&proglst_lock);
228 1.19 fvdl
229 1.19 fvdl if (done == FALSE) {
230 1.19 fvdl warnx("%s cant find suitable transport for %s",
231 1.19 fvdl rpc_reg_msg, nettype);
232 1.1 cgd return (-1);
233 1.1 cgd }
234 1.1 cgd return (0);
235 1.1 cgd }
236 1.1 cgd
237 1.19 fvdl /*
238 1.19 fvdl * The universal handler for the services registered using registerrpc.
239 1.19 fvdl * It handles both the connectionless and the connection oriented cases.
240 1.19 fvdl */
241 1.19 fvdl
242 1.1 cgd static void
243 1.1 cgd universal(rqstp, transp)
244 1.1 cgd struct svc_req *rqstp;
245 1.1 cgd SVCXPRT *transp;
246 1.1 cgd {
247 1.19 fvdl rpcprog_t prog;
248 1.19 fvdl rpcvers_t vers;
249 1.19 fvdl rpcproc_t proc;
250 1.1 cgd char *outdata;
251 1.19 fvdl char *xdrbuf;
252 1.19 fvdl struct proglst *pl;
253 1.19 fvdl #ifdef __REENT
254 1.19 fvdl extern mutex_t proglst_lock;
255 1.19 fvdl #endif
256 1.1 cgd
257 1.19 fvdl /*
258 1.1 cgd * enforce "procnum 0 is echo" convention
259 1.1 cgd */
260 1.1 cgd if (rqstp->rq_proc == NULLPROC) {
261 1.20 christos if (svc_sendreply(transp, (xdrproc_t) xdr_void, NULL) ==
262 1.20 christos FALSE) {
263 1.19 fvdl warnx("svc_sendreply failed");
264 1.19 fvdl }
265 1.1 cgd return;
266 1.1 cgd }
267 1.1 cgd prog = rqstp->rq_prog;
268 1.19 fvdl vers = rqstp->rq_vers;
269 1.1 cgd proc = rqstp->rq_proc;
270 1.19 fvdl mutex_lock(&proglst_lock);
271 1.19 fvdl for (pl = proglst; pl; pl = pl->p_nxt)
272 1.19 fvdl if (pl->p_prognum == prog && pl->p_procnum == proc &&
273 1.19 fvdl pl->p_versnum == vers &&
274 1.19 fvdl (strcmp(pl->p_netid, transp->xp_netid) == 0)) {
275 1.1 cgd /* decode arguments into a CLEAN buffer */
276 1.19 fvdl xdrbuf = pl->p_xdrbuf;
277 1.19 fvdl /* Zero the arguments: reqd ! */
278 1.19 fvdl (void) memset(xdrbuf, 0, sizeof (pl->p_recvsz));
279 1.19 fvdl /*
280 1.19 fvdl * Assuming that sizeof (xdrbuf) would be enough
281 1.19 fvdl * for the arguments; if not then the program
282 1.19 fvdl * may bomb. BEWARE!
283 1.19 fvdl */
284 1.19 fvdl if (!svc_getargs(transp, pl->p_inproc, xdrbuf)) {
285 1.1 cgd svcerr_decode(transp);
286 1.19 fvdl mutex_unlock(&proglst_lock);
287 1.1 cgd return;
288 1.1 cgd }
289 1.19 fvdl outdata = (*(pl->p_progname))(xdrbuf);
290 1.2 cgd if (outdata == NULL &&
291 1.19 fvdl pl->p_outproc != (xdrproc_t) xdr_void){
292 1.1 cgd /* there was an error */
293 1.19 fvdl mutex_unlock(&proglst_lock);
294 1.1 cgd return;
295 1.19 fvdl }
296 1.19 fvdl if (!svc_sendreply(transp, pl->p_outproc, outdata)) {
297 1.19 fvdl warnx(
298 1.19 fvdl "rpc: rpc_reg trouble replying to prog %u vers %u",
299 1.19 fvdl (unsigned)prog, (unsigned)vers);
300 1.19 fvdl mutex_unlock(&proglst_lock);
301 1.19 fvdl return;
302 1.19 fvdl }
303 1.1 cgd /* free the decoded arguments */
304 1.19 fvdl (void) svc_freeargs(transp, pl->p_inproc, xdrbuf);
305 1.19 fvdl mutex_unlock(&proglst_lock);
306 1.1 cgd return;
307 1.1 cgd }
308 1.19 fvdl mutex_unlock(&proglst_lock);
309 1.19 fvdl /* This should never happen */
310 1.19 fvdl warnx("rpc: rpc_reg: never registered prog %u vers %u",
311 1.19 fvdl (unsigned)prog, (unsigned)vers);
312 1.19 fvdl return;
313 1.1 cgd }
314