Home | History | Annotate | Line # | Download | only in rpc.bootparamd
bootparamd.c revision 1.34
      1 /*	$NetBSD: bootparamd.c,v 1.34 2000/06/28 01:30:56 thorpej Exp $	*/
      2 
      3 /*
      4  * This code is not copyright, and is placed in the public domain.
      5  * Feel free to use and modify. Please send modifications and/or
      6  * suggestions + bug fixes to Klas Heggemann <klas (at) nada.kth.se>
      7  *
      8  * Various small changes by Theo de Raadt <deraadt (at) fsa.ca>
      9  * Parser rewritten (adding YP support) by Roland McGrath <roland (at) frob.com>
     10  */
     11 
     12 #include <sys/cdefs.h>
     13 #ifndef lint
     14 __RCSID("$NetBSD: bootparamd.c,v 1.34 2000/06/28 01:30:56 thorpej Exp $");
     15 #endif
     16 
     17 #include <sys/types.h>
     18 #include <sys/ioctl.h>
     19 #include <sys/stat.h>
     20 #include <sys/socket.h>
     21 
     22 #include <assert.h>
     23 #include <ctype.h>
     24 #include <errno.h>
     25 #include <err.h>
     26 #include <fnmatch.h>
     27 #include <netdb.h>
     28 #include <stdlib.h>
     29 #include <stdio.h>
     30 #include <string.h>
     31 #include <syslog.h>
     32 #include <unistd.h>
     33 #include <util.h>
     34 #include <ifaddrs.h>
     35 
     36 #include <net/if.h>
     37 
     38 #include <netinet/in.h>
     39 #include <arpa/inet.h>
     40 
     41 #include <rpc/rpc.h>
     42 #include <rpc/pmap_clnt.h>
     43 #include <rpcsvc/bootparam_prot.h>
     44 #include <rpcsvc/ypclnt.h>
     45 
     46 #include "pathnames.h"
     47 
     48 #define MAXLEN 800
     49 
     50 static char hostname[MAX_MACHINE_NAME];
     51 static char askname[MAX_MACHINE_NAME];
     52 static char domain_name[MAX_MACHINE_NAME];
     53 
     54 extern void bootparamprog_1 __P((struct svc_req *, SVCXPRT *));
     55 
     56 int	_rpcsvcdirty = 0;
     57 int	_rpcpmstart = 0;
     58 int     debug = 0;
     59 int     dolog = 0;
     60 struct in_addr route_addr;
     61 struct sockaddr_in my_addr;
     62 extern char *__progname;
     63 char   *bootpfile = _PATH_BOOTPARAMS;
     64 
     65 int	main __P((int, char *[]));
     66 int	lookup_bootparam __P((char *, char *, char *, char **, char **));
     67 void	usage __P((void));
     68 static int get_localaddr __P((const char *, struct sockaddr_in *));
     69 
     70 
     71 /*
     72  * ever familiar
     73  */
     74 int
     75 main(argc, argv)
     76 	int     argc;
     77 	char  *argv[];
     78 {
     79 	SVCXPRT *transp;
     80 	struct hostent *he;
     81 	struct stat buf;
     82 	int    c;
     83 
     84 	while ((c = getopt(argc, argv, "dsr:f:")) != -1)
     85 		switch (c) {
     86 		case 'd':
     87 			debug = 1;
     88 			break;
     89 		case 'r':
     90 			if (isdigit(*optarg)) {
     91 				if (inet_aton(optarg, &route_addr) != 0)
     92 					break;
     93 			}
     94 			he = gethostbyname(optarg);
     95 			if (he == 0) {
     96 				warnx("no such host: %s", optarg);
     97 				usage();
     98 			}
     99 			memmove(&route_addr.s_addr, he->h_addr, he->h_length);
    100 			break;
    101 		case 'f':
    102 			bootpfile = optarg;
    103 			break;
    104 		case 's':
    105 			dolog = 1;
    106 #ifndef LOG_DAEMON
    107 			openlog(__progname, 0, 0);
    108 #else
    109 			openlog(__progname, 0, LOG_DAEMON);
    110 			setlogmask(LOG_UPTO(LOG_NOTICE));
    111 #endif
    112 			break;
    113 		default:
    114 			usage();
    115 		}
    116 
    117 	if (stat(bootpfile, &buf))
    118 		err(1, "%s", bootpfile);
    119 
    120 	if (route_addr.s_addr == 0) {
    121 		if (get_localaddr(NULL, &my_addr) != 0)
    122 			errx(1, "router address not found");
    123 		route_addr.s_addr = my_addr.sin_addr.s_addr;
    124 	}
    125 	if (!debug) {
    126 		if (daemon(0, 0))
    127 			err(1, "can't detach from terminal");
    128 	}
    129 	pidfile(NULL);
    130 
    131 	(void) pmap_unset(BOOTPARAMPROG, BOOTPARAMVERS);
    132 
    133 	transp = svcudp_create(RPC_ANYSOCK);
    134 	if (transp == NULL)
    135 		errx(1, "can't create udp service");
    136 
    137 	if (!svc_register(transp, BOOTPARAMPROG, BOOTPARAMVERS, bootparamprog_1,
    138 	    IPPROTO_UDP))
    139 /*
    140  * Do NOT change the "%u" in the format string below to "%lu". If your
    141  * build fails update the "rpcgen" program and use "make cleandir" and
    142  * "make includes" in "src/lib/librpcsvc" afterwards.
    143  */
    144 		errx(1, "unable to register BOOTPARAMPROG version %u, udp",
    145 		    BOOTPARAMVERS);
    146 
    147 	svc_run();
    148 	errx(1, "svc_run returned");
    149 }
    150 
    151 bp_whoami_res *
    152 bootparamproc_whoami_1_svc(whoami, rqstp)
    153 	bp_whoami_arg *whoami;
    154 	struct svc_req *rqstp;
    155 {
    156 	static bp_whoami_res res;
    157 	struct hostent *he;
    158 	struct in_addr haddr;
    159 	int e;
    160 
    161 	if (debug)
    162 		warnx("whoami got question for %d.%d.%d.%d",
    163 		    255 & whoami->client_address.bp_address_u.ip_addr.net,
    164 		    255 & whoami->client_address.bp_address_u.ip_addr.host,
    165 		    255 & whoami->client_address.bp_address_u.ip_addr.lh,
    166 		    255 & whoami->client_address.bp_address_u.ip_addr.impno);
    167 	if (dolog)
    168 		syslog(LOG_NOTICE, "whoami got question for %d.%d.%d.%d",
    169 		    255 & whoami->client_address.bp_address_u.ip_addr.net,
    170 		    255 & whoami->client_address.bp_address_u.ip_addr.host,
    171 		    255 & whoami->client_address.bp_address_u.ip_addr.lh,
    172 		    255 & whoami->client_address.bp_address_u.ip_addr.impno);
    173 
    174 	memmove((char *) &haddr,
    175 	    (char *) &whoami->client_address.bp_address_u.ip_addr,
    176 	    sizeof(haddr));
    177 	he = gethostbyaddr((char *) &haddr, sizeof(haddr), AF_INET);
    178 	if (he) {
    179 		strncpy(askname, he->h_name, sizeof(askname));
    180 		askname[sizeof(askname)-1] = 0;
    181 	} else {
    182 		strncpy(askname, inet_ntoa(haddr), sizeof(askname));
    183 		askname[sizeof(askname)-1] = 0;
    184 	}
    185 
    186 	if (debug)
    187 		warnx("This is host %s", askname);
    188 	if (dolog)
    189 		syslog(LOG_NOTICE, "This is host %s", askname);
    190 
    191 	if ((e = lookup_bootparam(askname, hostname, NULL, NULL, NULL)) == 0) {
    192 		res.client_name = hostname;
    193 		getdomainname(domain_name, MAX_MACHINE_NAME);
    194 		res.domain_name = domain_name;
    195 
    196 		if (res.router_address.address_type != IP_ADDR_TYPE) {
    197 			res.router_address.address_type = IP_ADDR_TYPE;
    198 			memmove(&res.router_address.bp_address_u.ip_addr,
    199 			    &route_addr.s_addr,4);
    200 		}
    201 		if (debug)
    202 			warnx("Returning %s   %s    %d.%d.%d.%d",
    203 			    res.client_name, res.domain_name,
    204 			    255 & res.router_address.bp_address_u.ip_addr.net,
    205 			    255 & res.router_address.bp_address_u.ip_addr.host,
    206 			    255 & res.router_address.bp_address_u.ip_addr.lh,
    207 			    255 &res.router_address.bp_address_u.ip_addr.impno);
    208 		if (dolog)
    209 			syslog(LOG_NOTICE, "Returning %s   %s    %d.%d.%d.%d",
    210 			    res.client_name, res.domain_name,
    211 			    255 & res.router_address.bp_address_u.ip_addr.net,
    212 			    255 & res.router_address.bp_address_u.ip_addr.host,
    213 			    255 & res.router_address.bp_address_u.ip_addr.lh,
    214 			    255 &res.router_address.bp_address_u.ip_addr.impno);
    215 
    216 		return (&res);
    217 	}
    218 	errno = e;
    219 	if (debug)
    220 		warn("whoami failed");
    221 	if (dolog)
    222 		syslog(LOG_NOTICE, "whoami failed %m");
    223 	return (NULL);
    224 }
    225 
    226 
    227 bp_getfile_res *
    228 bootparamproc_getfile_1_svc(getfile, rqstp)
    229 	bp_getfile_arg *getfile;
    230 	struct svc_req *rqstp;
    231 {
    232 	static bp_getfile_res res;
    233 	struct hostent *he;
    234 	int     err;
    235 
    236 	if (debug)
    237 		warnx("getfile got question for \"%s\" and file \"%s\"",
    238 		    getfile->client_name, getfile->file_id);
    239 
    240 	if (dolog)
    241 		syslog(LOG_NOTICE,
    242 		    "getfile got question for \"%s\" and file \"%s\"",
    243 		    getfile->client_name, getfile->file_id);
    244 
    245 	he = NULL;
    246 	he = gethostbyname(getfile->client_name);
    247 	if (!he)
    248 		goto failed;
    249 
    250 	strncpy(askname, he->h_name, sizeof(askname));
    251 	askname[sizeof(askname)-1] = 0;
    252 	err = lookup_bootparam(askname, NULL, getfile->file_id,
    253 	    &res.server_name, &res.server_path);
    254 	if (err == 0) {
    255 		he = gethostbyname(res.server_name);
    256 		if (!he)
    257 			goto failed;
    258 		memmove(&res.server_address.bp_address_u.ip_addr,
    259 		    he->h_addr, 4);
    260 		res.server_address.address_type = IP_ADDR_TYPE;
    261 	} else if (err == ENOENT && !strcmp(getfile->file_id, "dump")) {
    262 		/* Special for dump, answer with null strings. */
    263 		res.server_name[0] = '\0';
    264 		res.server_path[0] = '\0';
    265 		memset(&res.server_address.bp_address_u.ip_addr, 0, 4);
    266 	} else {
    267 failed:
    268 		if (debug)
    269 			warnx("getfile failed for %s",
    270 			    getfile->client_name);
    271 		if (dolog)
    272 			syslog(LOG_NOTICE,
    273 			    "getfile failed for %s", getfile->client_name);
    274 		return (NULL);
    275 	}
    276 
    277 	if (debug)
    278 		warnx(
    279 		    "returning server:%s path:%s address: %d.%d.%d.%d",
    280 		    res.server_name, res.server_path,
    281 		    255 & res.server_address.bp_address_u.ip_addr.net,
    282 		    255 & res.server_address.bp_address_u.ip_addr.host,
    283 		    255 & res.server_address.bp_address_u.ip_addr.lh,
    284 		    255 & res.server_address.bp_address_u.ip_addr.impno);
    285 	if (dolog)
    286 		syslog(LOG_NOTICE,
    287 		    "returning server:%s path:%s address: %d.%d.%d.%d",
    288 		    res.server_name, res.server_path,
    289 		    255 & res.server_address.bp_address_u.ip_addr.net,
    290 		    255 & res.server_address.bp_address_u.ip_addr.host,
    291 		    255 & res.server_address.bp_address_u.ip_addr.lh,
    292 		    255 & res.server_address.bp_address_u.ip_addr.impno);
    293 	return (&res);
    294 }
    295 
    296 
    297 int
    298 lookup_bootparam(client, client_canonical, id, server, path)
    299 	char	*client;
    300 	char	*client_canonical;
    301 	char	*id;
    302 	char	**server;
    303 	char	**path;
    304 {
    305 	FILE   *f = fopen(bootpfile, "r");
    306 #ifdef YP
    307 	static char *ypbuf = NULL;
    308 	static int ypbuflen = 0;
    309 #endif
    310 	static char buf[BUFSIZ];
    311 	char   *canon = NULL, *bp, *word = NULL;
    312 	size_t  idlen = id == NULL ? 0 : strlen(id);
    313 	int     contin = 0;
    314 	int     found = 0;
    315 
    316 	if (f == NULL)
    317 		return EINVAL;	/* ? */
    318 
    319 	while (fgets(buf, sizeof buf, f)) {
    320 		int     wascontin = contin;
    321 		contin = buf[strlen(buf) - 2] == '\\';
    322 		bp = buf + strspn(buf, " \t\n");
    323 
    324 		switch (wascontin) {
    325 		case -1:
    326 			/* Continuation of uninteresting line */
    327 			contin *= -1;
    328 			continue;
    329 		case 0:
    330 			/* New line */
    331 			contin *= -1;
    332 			if (*bp == '#')
    333 				continue;
    334 			if ((word = strsep(&bp, " \t\n")) == NULL)
    335 				continue;
    336 #ifdef YP
    337 			/* A + in the file means try YP now */
    338 			if (!strcmp(word, "+")) {
    339 				char   *ypdom;
    340 
    341 				if (yp_get_default_domain(&ypdom) ||
    342 				    yp_match(ypdom, "bootparams", client,
    343 					strlen(client), &ypbuf, &ypbuflen))
    344 					continue;
    345 				bp = ypbuf;
    346 				word = client;
    347 				contin *= -1;
    348 				break;
    349 			}
    350 #endif
    351 			if (debug)
    352 				warnx("match %s with %s", word, client);
    353 
    354 #define	HASGLOB(str) \
    355 	(strchr(str, '*') != NULL || \
    356 	 strchr(str, '?') != NULL || \
    357 	 strchr(str, '[') != NULL || \
    358 	 strchr(str, ']') != NULL)
    359 
    360 			/* See if this line's client is the one we are
    361 			 * looking for */
    362 			if (fnmatch(word, client, FNM_CASEFOLD) == 0) {
    363 				/*
    364 				 * Match.  The token may be globbed, we
    365 				 * can't just return that as the canonical
    366 				 * name.  Check to see if the token has any
    367 				 * globbing characters in it (*, ?, [, ]).
    368 				 * If so, just return the name we already
    369 				 * have.  Otherwise, return the token.
    370 				 */
    371 				if (HASGLOB(word))
    372 					canon = client;
    373 				else
    374 					canon = word;
    375 			} else {
    376 				/*
    377 				 * If it didn't match, try getting the
    378 				 * canonical host name of the client
    379 				 * on this line and comparing that to
    380 				 * the client we are looking for
    381 				 */
    382 				struct hostent *hp = gethostbyname(word);
    383 				if (hp == NULL) {
    384 					if (debug)
    385 						warnx(
    386 					    "Unknown bootparams host %s", word);
    387 					if (dolog)
    388 						syslog(LOG_NOTICE,
    389 					    "Unknown bootparams host %s", word);
    390 					continue;
    391 				}
    392 				if (fnmatch(word, hp->h_name,
    393 					    FNM_CASEFOLD) == 0) {
    394 					/* See above. */
    395 					if (HASGLOB(word))
    396 						canon = hp->h_name;
    397 					else
    398 						canon = word;
    399 				}
    400 			}
    401 
    402 #undef HASGLOB
    403 
    404 			contin *= -1;
    405 			break;
    406 		case 1:
    407 			/* Continued line we want to parse below */
    408 			break;
    409 		}
    410 
    411 		assert(canon != NULL);
    412 		if (client_canonical)
    413 			strncpy(client_canonical, canon, MAX_MACHINE_NAME);
    414 
    415 		/* We have found a line for CLIENT */
    416 		if (id == NULL) {
    417 			(void) fclose(f);
    418 			return 0;
    419 		}
    420 
    421 		/* Look for a value for the parameter named by ID */
    422 		while ((word = strsep(&bp, " \t\n")) != NULL) {
    423 			if (!strncmp(word, id, idlen) && word[idlen] == '=') {
    424 				/* We have found the entry we want */
    425 				*server = &word[idlen + 1];
    426 				*path = strchr(*server, ':');
    427 				if (*path == NULL)
    428 					/* Malformed entry */
    429 					continue;
    430 				*(*path)++ = '\0';
    431 				(void) fclose(f);
    432 				return 0;
    433 			}
    434 		}
    435 
    436 		found = 1;
    437 	}
    438 
    439 	(void) fclose(f);
    440 	return found ? ENOENT : EPERM;
    441 }
    442 
    443 void
    444 usage()
    445 {
    446 	fprintf(stderr,
    447 	    "usage: %s [-d] [-s] [-r router] [-f bootparmsfile]\n", __progname);
    448 	exit(1);
    449 }
    450 
    451 static int
    452 get_localaddr(ifname, sin)
    453 	const char *ifname;
    454 	struct sockaddr_in *sin;
    455 {
    456 	struct ifaddrs *ifap, *ifa;
    457 
    458 	if (getifaddrs(&ifap) != 0)
    459 		return -1;
    460 
    461 	for (ifa = ifap; ifa; ifa = ifa->ifa_next) {
    462 		if (ifname && strcmp(ifname, ifa->ifa_name) != 0)
    463 			continue;
    464 		if (ifa->ifa_addr->sa_family != AF_INET)
    465 			continue;
    466 		if (ifa->ifa_addr->sa_len != sizeof(*sin))
    467 			continue;
    468 
    469 		/* no loopback please */
    470 #ifdef IFF_LOOPBACK
    471 		if (ifa->ifa_flags & IFF_LOOPBACK)
    472 			continue;
    473 #else
    474 		if (strncmp(ifa->ifa_name, "lo", 2) == 0 &&
    475 		    (isdigit(ifa->ifa_name[2]) || ifa->ifa_name[2] == '\0'))
    476 			continue;
    477 #endif
    478 
    479 		/* XXX more sanity checks? */
    480 
    481 		/* candidate found */
    482 		memcpy(sin, ifa->ifa_addr, ifa->ifa_addr->sa_len);
    483 		freeifaddrs(ifap);
    484 		return 0;
    485 	}
    486 
    487 	/* no candidate */
    488 	freeifaddrs(ifap);
    489 	return -1;
    490 }
    491