2 * Copyright (c) 2009, Sun Microsystems, Inc.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 * - Redistributions of source code must retain the above copyright notice,
8 * this list of conditions and the following disclaimer.
9 * - Redistributions in binary form must reproduce the above copyright notice,
10 * this list of conditions and the following disclaimer in the documentation
11 * and/or other materials provided with the distribution.
12 * - Neither the name of Sun Microsystems, Inc. nor the names of its
13 * contributors may be used to endorse or promote products derived
14 * from this software without specific prior written permission.
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26 * POSSIBILITY OF SUCH DAMAGE.
28 * @(#)rpcb_svc_4.c 1.8 93/07/05 SMI
29 * $NetBSD: rpcb_svc_4.c,v 1.1 2000/06/02 23:15:41 fvdl Exp $
30 * $FreeBSD: src/usr.sbin/rpcbind/rpcb_svc_4.c,v 1.5 2007/11/07 10:53:39 kevlo Exp $
33 * Copyright (c) 1986 - 1991 by Sun Microsystems, Inc.
38 * The server procedure for the version 4 rpcbind.
42 #include <sys/types.h>
47 #include <netconfig.h>
53 static void *rpcbproc_getaddr_4_local(void *, struct svc_req *, SVCXPRT *,
55 static void *rpcbproc_getversaddr_4_local(void *, struct svc_req *,
56 SVCXPRT *, rpcvers_t);
57 static void *rpcbproc_getaddrlist_4_local(void *, struct svc_req *,
58 SVCXPRT *, rpcvers_t);
59 static void free_rpcb_entry_list(rpcb_entry_list_ptr *);
60 static void *rpcbproc_dump_4_local(void *, struct svc_req *, SVCXPRT *,
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 svc_sendreply(transp, (xdrproc_t) xdr_void, NULL);
98 * Check to see whether the message came from
99 * loopback transports (for security reasons)
101 xdr_argument = (xdrproc_t)xdr_rpcb;
102 xdr_result = (xdrproc_t)xdr_bool;
103 local = rpcbproc_set_com;
108 * Check to see whether the message came from
109 * loopback transports (for security reasons)
111 xdr_argument = (xdrproc_t)xdr_rpcb;
112 xdr_result = (xdrproc_t)xdr_bool;
113 local = rpcbproc_unset_com;
116 case RPCBPROC_GETADDR:
117 xdr_argument = (xdrproc_t)xdr_rpcb;
118 xdr_result = (xdrproc_t)xdr_wrapstring;
119 local = rpcbproc_getaddr_4_local;
122 case RPCBPROC_GETVERSADDR:
125 fprintf(stderr, "RPCBPROC_GETVERSADDR\n");
127 xdr_argument = (xdrproc_t)xdr_rpcb;
128 xdr_result = (xdrproc_t)xdr_wrapstring;
129 local = rpcbproc_getversaddr_4_local;
135 fprintf(stderr, "RPCBPROC_DUMP\n");
137 xdr_argument = (xdrproc_t)xdr_void;
138 xdr_result = (xdrproc_t)xdr_rpcblist_ptr;
139 local = rpcbproc_dump_4_local;
142 case RPCBPROC_INDIRECT:
145 fprintf(stderr, "RPCBPROC_INDIRECT\n");
147 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4);
150 /* case RPCBPROC_CALLIT: */
154 fprintf(stderr, "RPCBPROC_BCAST\n");
156 rpcbproc_callit_com(rqstp, transp, rqstp->rq_proc, RPCBVERS4);
159 case RPCBPROC_GETTIME:
162 fprintf(stderr, "RPCBPROC_GETTIME\n");
164 xdr_argument = (xdrproc_t)xdr_void;
165 xdr_result = (xdrproc_t)xdr_u_long;
166 local = rpcbproc_gettime_com;
169 case RPCBPROC_UADDR2TADDR:
172 fprintf(stderr, "RPCBPROC_UADDR2TADDR\n");
174 xdr_argument = (xdrproc_t)xdr_wrapstring;
175 xdr_result = (xdrproc_t)xdr_netbuf;
176 local = rpcbproc_uaddr2taddr_com;
179 case RPCBPROC_TADDR2UADDR:
182 fprintf(stderr, "RPCBPROC_TADDR2UADDR\n");
184 xdr_argument = (xdrproc_t)xdr_netbuf;
185 xdr_result = (xdrproc_t)xdr_wrapstring;
186 local = rpcbproc_taddr2uaddr_com;
189 case RPCBPROC_GETADDRLIST:
192 fprintf(stderr, "RPCBPROC_GETADDRLIST\n");
194 xdr_argument = (xdrproc_t)xdr_rpcb;
195 xdr_result = (xdrproc_t)xdr_rpcb_entry_list_ptr;
196 local = rpcbproc_getaddrlist_4_local;
199 case RPCBPROC_GETSTAT:
202 fprintf(stderr, "RPCBPROC_GETSTAT\n");
204 xdr_argument = (xdrproc_t)xdr_void;
205 xdr_result = (xdrproc_t)xdr_rpcb_stat_byvers;
206 local = rpcbproc_getstat;
210 svcerr_noproc(transp);
213 memset((char *)&argument, 0, sizeof (argument));
214 if (!svc_getargs(transp, (xdrproc_t) xdr_argument,
215 (char *)&argument)) {
216 svcerr_decode(transp);
218 fprintf(stderr, "rpcbind: could not decode\n");
221 if (!check_access(transp, rqstp->rq_proc, &argument, RPCBVERS4)) {
222 svcerr_weakauth(transp);
225 result = (*local)(&argument, rqstp, transp, RPCBVERS4);
226 if (result != NULL && !svc_sendreply(transp, (xdrproc_t) xdr_result,
228 svcerr_systemerr(transp);
230 fprintf(stderr, "rpcbind: svc_sendreply\n");
237 if (!svc_freeargs(transp, (xdrproc_t) xdr_argument,
238 (char *)&argument)) {
240 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;
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 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);