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