2 * $NetBSD: rpcb_svc_4.c,v 1.1 2000/06/02 23:15:41 fvdl Exp $
6 * SPDX-License-Identifier: BSD-3-Clause
8 * Copyright (c) 2009, Sun Microsystems, Inc.
11 * Redistribution and use in source and binary forms, with or without
12 * modification, are permitted provided that the following conditions are met:
13 * - Redistributions of source code must retain the above copyright notice,
14 * this list of conditions and the following disclaimer.
15 * - Redistributions in binary form must reproduce the above copyright notice,
16 * this list of conditions and the following disclaimer in the documentation
17 * and/or other materials provided with the distribution.
18 * - Neither the name of Sun Microsystems, Inc. nor the names of its
19 * contributors may be used to endorse or promote products derived
20 * from this software without specific prior written permission.
22 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
23 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
26 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
27 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
28 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
29 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
30 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
31 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
32 * POSSIBILITY OF SUCH DAMAGE.
35 * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc.
38 /* #ident "@(#)rpcb_svc_4.c 1.8 93/07/05 SMI" */
42 * The server procedure for the version 4 rpcbind.
46 #include <sys/types.h>
50 #include <netconfig.h>
55 static void *rpcbproc_getaddr_4_local(void *, struct svc_req *, SVCXPRT *,
57 static void *rpcbproc_getversaddr_4_local(void *, struct svc_req *, SVCXPRT *, rpcvers_t);
58 static void *rpcbproc_getaddrlist_4_local
59 (void *, struct svc_req *, SVCXPRT *, rpcvers_t);
60 static void free_rpcb_entry_list(rpcb_entry_list_ptr *);
61 static void *rpcbproc_dump_4_local(void *, struct svc_req *, SVCXPRT *, rpcvers_t);
64 * Called by svc_getreqset. There is a separate server handle for
65 * every transport that it waits on.
68 rpcb_service_4(struct svc_req *rqstp, SVCXPRT *transp)
71 rpcb rpcbproc_set_4_arg;
72 rpcb rpcbproc_unset_4_arg;
73 rpcb rpcbproc_getaddr_4_local_arg;
74 char *rpcbproc_uaddr2taddr_4_arg;
75 struct netbuf rpcbproc_taddr2uaddr_4_arg;
78 xdrproc_t xdr_argument, xdr_result;
79 void *(*local)(void *, struct svc_req *, SVCXPRT *, rpcvers_t);
81 rpcbs_procinfo(RPCBVERS_4_STAT, rqstp->rq_proc);
83 switch (rqstp->rq_proc) {
90 fprintf(stderr, "RPCBPROC_NULL\n");
92 check_access(transp, rqstp->rq_proc, NULL, RPCBVERS4);
93 (void) svc_sendreply(transp, (xdrproc_t) xdr_void,
99 * Check to see whether the message came from
100 * loopback transports (for security reasons)
102 xdr_argument = (xdrproc_t)xdr_rpcb;
103 xdr_result = (xdrproc_t)xdr_bool;
104 local = rpcbproc_set_com;
109 * Check to see whether the message came from
110 * loopback transports (for security reasons)
112 xdr_argument = (xdrproc_t)xdr_rpcb;
113 xdr_result = (xdrproc_t)xdr_bool;
114 local = rpcbproc_unset_com;
117 case RPCBPROC_GETADDR:
118 xdr_argument = (xdrproc_t)xdr_rpcb;
119 xdr_result = (xdrproc_t)xdr_wrapstring;
120 local = rpcbproc_getaddr_4_local;
123 case RPCBPROC_GETVERSADDR:
126 fprintf(stderr, "RPCBPROC_GETVERSADDR\n");
128 xdr_argument = (xdrproc_t)xdr_rpcb;
129 xdr_result = (xdrproc_t)xdr_wrapstring;
130 local = rpcbproc_getversaddr_4_local;
136 fprintf(stderr, "RPCBPROC_DUMP\n");
138 xdr_argument = (xdrproc_t)xdr_void;
139 xdr_result = (xdrproc_t)xdr_rpcblist_ptr;
140 local = rpcbproc_dump_4_local;
143 case RPCBPROC_INDIRECT:
146 fprintf(stderr, "RPCBPROC_INDIRECT\n");
148 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4);
151 /* case RPCBPROC_CALLIT: */
155 fprintf(stderr, "RPCBPROC_BCAST\n");
157 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4);
160 case RPCBPROC_GETTIME:
163 fprintf(stderr, "RPCBPROC_GETTIME\n");
165 xdr_argument = (xdrproc_t)xdr_void;
166 xdr_result = (xdrproc_t)xdr_u_long;
167 local = rpcbproc_gettime_com;
170 case RPCBPROC_UADDR2TADDR:
173 fprintf(stderr, "RPCBPROC_UADDR2TADDR\n");
175 xdr_argument = (xdrproc_t)xdr_wrapstring;
176 xdr_result = (xdrproc_t)xdr_netbuf;
177 local = rpcbproc_uaddr2taddr_com;
180 case RPCBPROC_TADDR2UADDR:
183 fprintf(stderr, "RPCBPROC_TADDR2UADDR\n");
185 xdr_argument = (xdrproc_t)xdr_netbuf;
186 xdr_result = (xdrproc_t)xdr_wrapstring;
187 local = rpcbproc_taddr2uaddr_com;
190 case RPCBPROC_GETADDRLIST:
193 fprintf(stderr, "RPCBPROC_GETADDRLIST\n");
195 xdr_argument = (xdrproc_t)xdr_rpcb;
196 xdr_result = (xdrproc_t)xdr_rpcb_entry_list_ptr;
197 local = rpcbproc_getaddrlist_4_local;
200 case RPCBPROC_GETSTAT:
203 fprintf(stderr, "RPCBPROC_GETSTAT\n");
205 xdr_argument = (xdrproc_t)xdr_void;
206 xdr_result = (xdrproc_t)xdr_rpcb_stat_byvers;
207 local = rpcbproc_getstat;
211 svcerr_noproc(transp);
214 memset((char *)&argument, 0, sizeof (argument));
215 if (!svc_getargs(transp, (xdrproc_t) xdr_argument,
216 (char *)&argument)) {
217 svcerr_decode(transp);
219 (void) fprintf(stderr, "rpcbind: could not decode\n");
222 if (!check_access(transp, rqstp->rq_proc, &argument, RPCBVERS4)) {
223 svcerr_weakauth(transp);
226 result = (*local)(&argument, rqstp, transp, RPCBVERS4);
227 if (result != NULL && !svc_sendreply(transp, (xdrproc_t) xdr_result,
229 svcerr_systemerr(transp);
231 (void) fprintf(stderr, "rpcbind: svc_sendreply\n");
238 if (!svc_freeargs(transp, (xdrproc_t) xdr_argument,
239 (char *)&argument)) {
241 (void) fprintf(stderr, "unable to free arguments\n");
250 * Lookup the mapping for a program, version and return its
251 * address. Assuming that the caller wants the address of the
252 * server running on the transport on which the request came.
253 * Even if a service with a different version number is available,
254 * it will return that address. The client should check with an
255 * clnt_call to verify whether the service is the one that is desired.
256 * We also try to resolve the universal address in terms of
257 * address of the caller.
261 rpcbproc_getaddr_4_local(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
262 rpcvers_t rpcbversnum __unused)
264 RPCB *regp = (RPCB *)arg;
269 uaddr = taddr2uaddr(rpcbind_get_conf(transp->xp_netid),
270 svc_getrpccaller(transp));
271 fprintf(stderr, "RPCB_GETADDR req for (%lu, %lu, %s) from %s: ",
272 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
273 regp->r_netid, uaddr);
277 return (rpcbproc_getaddr_com(regp, rqstp, transp, RPCBVERS4,
282 * Lookup the mapping for a program, version and return its
283 * address. Assuming that the caller wants the address of the
284 * server running on the transport on which the request came.
286 * We also try to resolve the universal address in terms of
287 * address of the caller.
291 rpcbproc_getversaddr_4_local(void *arg, struct svc_req *rqstp, SVCXPRT *transp,
292 rpcvers_t versnum __unused)
294 RPCB *regp = (RPCB *)arg;
299 uaddr = taddr2uaddr(rpcbind_get_conf(transp->xp_netid),
300 svc_getrpccaller(transp));
301 fprintf(stderr, "RPCB_GETVERSADDR rqst for (%lu, %lu, %s)"
303 (unsigned long)regp->r_prog, (unsigned long)regp->r_vers,
304 regp->r_netid, uaddr);
308 return (rpcbproc_getaddr_com(regp, rqstp, transp, RPCBVERS4,
313 * Lookup the mapping for a program, version and return the
314 * addresses for all transports in the current transport family.
315 * We return a merged address.
319 rpcbproc_getaddrlist_4_local(void *arg, struct svc_req *rqstp __unused,
320 SVCXPRT *transp, rpcvers_t versnum __unused)
322 RPCB *regp = (RPCB *)arg;
323 static rpcb_entry_list_ptr rlist;
324 register rpcblist_ptr rbl;
325 rpcb_entry_list_ptr rp, tail;
329 struct netconfig *nconf;
330 struct netconfig *reg_nconf;
331 char *saddr, *maddr = NULL;
333 free_rpcb_entry_list(&rlist);
337 reg_nconf = rpcbind_get_conf(transp->xp_netid);
338 if (reg_nconf == NULL)
340 if (*(regp->r_addr) != '\0') {
341 saddr = regp->r_addr;
347 fprintf(stderr, "r_addr: %s r_netid: %s nc_protofmly: %s\n",
348 regp->r_addr, regp->r_netid, reg_nconf->nc_protofmly);
351 for (rbl = list_rbl; rbl != NULL; rbl = rbl->rpcb_next) {
352 if ((rbl->rpcb_map.r_prog == prog) &&
353 (rbl->rpcb_map.r_vers == vers)) {
354 nconf = rpcbind_get_conf(rbl->rpcb_map.r_netid);
357 if (strcmp(nconf->nc_protofmly, reg_nconf->nc_protofmly)
359 continue; /* not same proto family */
363 fprintf(stderr, "\tmerge with: %s\n",
364 rbl->rpcb_map.r_addr);
366 if ((maddr = mergeaddr(transp, rbl->rpcb_map.r_netid,
367 rbl->rpcb_map.r_addr, saddr)) == NULL) {
370 fprintf(stderr, " FAILED\n");
373 } else if (!maddr[0]) {
376 fprintf(stderr, " SUCCEEDED, but port died - maddr: nullstring\n");
378 /* The server died. Unset this combination */
379 delete_prog(regp->r_prog);
384 fprintf(stderr, " SUCCEEDED maddr: %s\n", maddr);
389 rp = malloc(sizeof (rpcb_entry_list));
392 a = &rp->rpcb_entry_map;
394 a->r_nc_netid = nconf->nc_netid;
395 a->r_nc_semantics = nconf->nc_semantics;
396 a->r_nc_protofmly = nconf->nc_protofmly;
397 a->r_nc_proto = nconf->nc_proto;
398 rp->rpcb_entry_next = NULL;
403 tail->rpcb_entry_next = rp;
411 for (rp = rlist; rp; rp = rp->rpcb_entry_next) {
412 fprintf(stderr, "\t%s %s\n", rp->rpcb_entry_map.r_maddr,
413 rp->rpcb_entry_map.r_nc_proto);
418 * XXX: getaddrlist info is also being stuffed into getaddr.
419 * Perhaps wrong, but better than it not getting counted at all.
421 rpcbs_getaddr(RPCBVERS4 - 2, prog, vers, transp->xp_netid, maddr);
422 return (void *)&rlist;
424 fail: free_rpcb_entry_list(&rlist);
429 * Free only the allocated structure, rest is all a pointer to some
430 * other data somewhere else.
433 free_rpcb_entry_list(rpcb_entry_list_ptr *rlistp)
435 register rpcb_entry_list_ptr rbl, tmp;
437 for (rbl = *rlistp; rbl != NULL; ) {
439 rbl = rbl->rpcb_entry_next;
440 free((char *)tmp->rpcb_entry_map.r_maddr);
448 rpcbproc_dump_4_local(void *arg __unused, struct svc_req *req __unused,
449 SVCXPRT *xprt __unused, rpcvers_t versnum __unused)
451 return ((void *)&list_rbl);