Expand PMF_FN_* macros.
[netbsd-mini2440.git] / usr.sbin / rpc.bootparamd / bootparamd.c
blob7d0cf5cdf6c4b9e01c5b542df997ab7173f453e5
1 /* $NetBSD: bootparamd.c,v 1.44 2004/10/30 15:23:30 dsl Exp $ */
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@nada.kth.se>
8 * Various small changes by Theo de Raadt <deraadt@fsa.ca>
9 * Parser rewritten (adding YP support) by Roland McGrath <roland@frob.com>
12 #include <sys/cdefs.h>
13 #ifndef lint
14 __RCSID("$NetBSD: bootparamd.c,v 1.44 2004/10/30 15:23:30 dsl Exp $");
15 #endif
17 #include <sys/types.h>
18 #include <sys/ioctl.h>
19 #include <sys/stat.h>
20 #include <sys/socket.h>
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>
36 #include <net/if.h>
38 #include <netinet/in.h>
39 #include <arpa/inet.h>
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
48 #include "pathnames.h"
50 #define MAXLEN 800
52 static char hostname[MAX_MACHINE_NAME];
53 static char askname[MAX_MACHINE_NAME];
54 static char domain_name[MAX_MACHINE_NAME];
56 extern void bootparamprog_1 __P((struct svc_req *, SVCXPRT *));
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 const char *bootpfile = _PATH_BOOTPARAMS;
65 char *iface = NULL;
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 *));
74 * ever familiar
76 int
77 main(argc, argv)
78 int argc;
79 char *argv[];
81 SVCXPRT *transp;
82 struct hostent *he;
83 struct stat buf;
84 int c;
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((unsigned char)*optarg)) {
96 if (inet_aton(optarg, &route_addr) != 0)
97 break;
99 he = gethostbyname(optarg);
100 if (he == 0) {
101 warnx("no such host: %s", optarg);
102 usage();
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();
122 if (stat(bootpfile, &buf))
123 err(1, "%s", bootpfile);
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;
130 if (!debug) {
131 if (daemon(0, 0))
132 err(1, "can't detach from terminal");
134 pidfile(NULL);
136 (void) pmap_unset(BOOTPARAMPROG, BOOTPARAMVERS);
138 transp = svcudp_create(RPC_ANYSOCK);
139 if (transp == NULL)
140 errx(1, "can't create udp service");
142 if (!svc_register(transp, BOOTPARAMPROG, BOOTPARAMVERS, bootparamprog_1,
143 IPPROTO_UDP))
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.
149 errx(1, "unable to register BOOTPARAMPROG version %u, udp",
150 BOOTPARAMVERS);
152 svc_run();
153 errx(1, "svc_run returned");
156 bp_whoami_res *
157 bootparamproc_whoami_1_svc(whoami, rqstp)
158 bp_whoami_arg *whoami;
159 struct svc_req *rqstp;
161 static bp_whoami_res res;
162 struct hostent *he;
163 struct in_addr haddr;
164 int e;
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);
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 (void)strlcpy(askname, he->h_name, sizeof(askname));
185 } else {
186 (void)strlcpy(askname, inet_ntoa(haddr), sizeof(askname));
189 if (debug)
190 warnx("This is host %s", askname);
191 if (dolog)
192 syslog(LOG_NOTICE, "This is host %s", askname);
194 if ((e = lookup_bootparam(askname, hostname, NULL, NULL, NULL)) == 0) {
195 res.client_name = hostname;
196 getdomainname(domain_name, MAX_MACHINE_NAME);
197 res.domain_name = domain_name;
199 if (res.router_address.address_type != IP_ADDR_TYPE) {
200 res.router_address.address_type = IP_ADDR_TYPE;
201 memmove(&res.router_address.bp_address_u.ip_addr,
202 &route_addr.s_addr,4);
204 if (debug)
205 warnx("Returning %s %s %d.%d.%d.%d",
206 res.client_name, res.domain_name,
207 255 & res.router_address.bp_address_u.ip_addr.net,
208 255 & res.router_address.bp_address_u.ip_addr.host,
209 255 & res.router_address.bp_address_u.ip_addr.lh,
210 255 &res.router_address.bp_address_u.ip_addr.impno);
211 if (dolog)
212 syslog(LOG_NOTICE, "Returning %s %s %d.%d.%d.%d",
213 res.client_name, res.domain_name,
214 255 & res.router_address.bp_address_u.ip_addr.net,
215 255 & res.router_address.bp_address_u.ip_addr.host,
216 255 & res.router_address.bp_address_u.ip_addr.lh,
217 255 &res.router_address.bp_address_u.ip_addr.impno);
219 return (&res);
221 errno = e;
222 if (debug)
223 warn("whoami failed");
224 if (dolog)
225 syslog(LOG_NOTICE, "whoami failed %m");
226 return (NULL);
230 bp_getfile_res *
231 bootparamproc_getfile_1_svc(getfile, rqstp)
232 bp_getfile_arg *getfile;
233 struct svc_req *rqstp;
235 static bp_getfile_res res;
236 struct hostent *he;
237 int error;
239 if (debug)
240 warnx("getfile got question for \"%s\" and file \"%s\"",
241 getfile->client_name, getfile->file_id);
243 if (dolog)
244 syslog(LOG_NOTICE,
245 "getfile got question for \"%s\" and file \"%s\"",
246 getfile->client_name, getfile->file_id);
248 he = NULL;
249 he = gethostbyname(getfile->client_name);
250 if (!he) {
251 if (debug)
252 warnx("getfile can't resolve client %s",
253 getfile->client_name);
254 if (dolog)
255 syslog(LOG_NOTICE, "getfile can't resolve client %s",
256 getfile->client_name);
257 return (NULL);
260 (void)strlcpy(askname, he->h_name, sizeof(askname));
261 error = lookup_bootparam(askname, NULL, getfile->file_id,
262 &res.server_name, &res.server_path);
263 if (error == 0) {
264 he = gethostbyname(res.server_name);
265 if (!he) {
266 if (debug)
267 warnx("getfile can't resolve server %s for %s",
268 res.server_name, getfile->client_name);
269 if (dolog)
270 syslog(LOG_NOTICE,
271 "getfile can't resolve server %s for %s",
272 res.server_name, getfile->client_name);
273 return (NULL);
276 memmove(&res.server_address.bp_address_u.ip_addr,
277 he->h_addr, 4);
278 res.server_address.address_type = IP_ADDR_TYPE;
279 } else if (error == ENOENT && !strcmp(getfile->file_id, "dump")) {
280 /* Special for dump, answer with null strings. */
281 res.server_name[0] = '\0';
282 res.server_path[0] = '\0';
283 memset(&res.server_address.bp_address_u.ip_addr, 0, 4);
284 } else {
285 if (debug)
286 warnx("getfile lookup failed for %s",
287 getfile->client_name);
288 if (dolog)
289 syslog(LOG_NOTICE,
290 "getfile lookup failed for %s",
291 getfile->client_name);
292 return (NULL);
295 if (debug)
296 warnx(
297 "returning server:%s path:%s address: %d.%d.%d.%d",
298 res.server_name, res.server_path,
299 255 & res.server_address.bp_address_u.ip_addr.net,
300 255 & res.server_address.bp_address_u.ip_addr.host,
301 255 & res.server_address.bp_address_u.ip_addr.lh,
302 255 & res.server_address.bp_address_u.ip_addr.impno);
303 if (dolog)
304 syslog(LOG_NOTICE,
305 "returning server:%s path:%s address: %d.%d.%d.%d",
306 res.server_name, res.server_path,
307 255 & res.server_address.bp_address_u.ip_addr.net,
308 255 & res.server_address.bp_address_u.ip_addr.host,
309 255 & res.server_address.bp_address_u.ip_addr.lh,
310 255 & res.server_address.bp_address_u.ip_addr.impno);
311 return (&res);
316 lookup_bootparam(client, client_canonical, id, server, path)
317 char *client;
318 char *client_canonical;
319 char *id;
320 char **server;
321 char **path;
323 FILE *f = fopen(bootpfile, "r");
324 #ifdef YP
325 static char *ypbuf = NULL;
326 static int ypbuflen = 0;
327 #endif
328 static char buf[BUFSIZ];
329 char *canon = NULL, *bp, *word = NULL;
330 size_t idlen = id == NULL ? 0 : strlen(id);
331 int contin = 0;
332 int found = 0;
334 if (f == NULL)
335 return EINVAL; /* ? */
337 while (fgets(buf, sizeof buf, f)) {
338 int wascontin = contin;
339 contin = buf[strlen(buf) - 2] == '\\';
340 bp = buf + strspn(buf, " \t\n");
342 switch (wascontin) {
343 case -1:
344 /* Continuation of uninteresting line */
345 contin *= -1;
346 continue;
347 case 0:
348 /* New line */
349 contin *= -1;
350 if (*bp == '#')
351 continue;
352 if ((word = strsep(&bp, " \t\n")) == NULL)
353 continue;
354 #ifdef YP
355 /* A + in the file means try YP now */
356 if (!strcmp(word, "+")) {
357 char *ypdom;
359 if (yp_get_default_domain(&ypdom) ||
360 yp_match(ypdom, "bootparams", client,
361 strlen(client), &ypbuf, &ypbuflen))
362 continue;
363 bp = ypbuf;
364 word = client;
365 contin *= -1;
366 break;
368 #endif
369 if (debug)
370 warnx("match %s with %s", word, client);
372 #define HASGLOB(str) \
373 (strchr(str, '*') != NULL || \
374 strchr(str, '?') != NULL || \
375 strchr(str, '[') != NULL || \
376 strchr(str, ']') != NULL)
378 /* See if this line's client is the one we are
379 * looking for */
380 if (fnmatch(word, client, FNM_CASEFOLD) == 0) {
382 * Match. The token may be globbed, we
383 * can't just return that as the canonical
384 * name. Check to see if the token has any
385 * globbing characters in it (*, ?, [, ]).
386 * If so, just return the name we already
387 * have. Otherwise, return the token.
389 if (HASGLOB(word))
390 canon = client;
391 else
392 canon = word;
393 } else {
394 struct hostent *hp;
396 * If it didn't match, try getting the
397 * canonical host name of the client
398 * on this line, if it's not a glob,
399 * and comparing it to the client we
400 * are looking up.
402 if (HASGLOB(word)) {
403 if (debug)
404 warnx("Skipping non-match: %s",
405 word);
406 continue;
408 if ((hp = gethostbyname(word)) == NULL) {
409 if (debug)
410 warnx(
411 "Unknown bootparams host %s",
412 word);
413 if (dolog)
414 syslog(LOG_NOTICE,
415 "Unknown bootparams host %s",
416 word);
417 continue;
419 if (strcasecmp(hp->h_name, client) != 0)
420 continue;
421 canon = hp->h_name;
424 #undef HASGLOB
426 contin *= -1;
427 break;
428 case 1:
429 /* Continued line we want to parse below */
430 break;
433 assert(canon != NULL);
434 if (client_canonical)
435 strncpy(client_canonical, canon, MAX_MACHINE_NAME);
437 /* We have found a line for CLIENT */
438 if (id == NULL) {
439 (void) fclose(f);
440 return 0;
443 /* Look for a value for the parameter named by ID */
444 while ((word = strsep(&bp, " \t\n")) != NULL) {
445 if (!strncmp(word, id, idlen) && word[idlen] == '=') {
446 /* We have found the entry we want */
447 *server = &word[idlen + 1];
448 *path = strchr(*server, ':');
449 if (*path == NULL)
450 /* Malformed entry */
451 continue;
452 *(*path)++ = '\0';
453 (void) fclose(f);
454 return 0;
458 found = 1;
461 (void) fclose(f);
462 return found ? ENOENT : EPERM;
465 void
466 usage()
468 fprintf(stderr,
469 "usage: %s [-ds] [-i interface] [-r router] [-f bootparamsfile]\n",
470 getprogname());
471 exit(1);
474 static int
475 get_localaddr(ifname, sin)
476 const char *ifname;
477 struct sockaddr_in *sin;
479 struct ifaddrs *ifap, *ifa;
481 if (getifaddrs(&ifap) != 0)
482 return -1;
484 for (ifa = ifap; ifa; ifa = ifa->ifa_next) {
485 if (ifname && strcmp(ifname, ifa->ifa_name) != 0)
486 continue;
487 if (ifa->ifa_addr->sa_family != AF_INET)
488 continue;
489 if (ifa->ifa_addr->sa_len != sizeof(*sin))
490 continue;
492 /* no loopback please */
493 #ifdef IFF_LOOPBACK
494 if (ifa->ifa_flags & IFF_LOOPBACK)
495 continue;
496 #else
497 if (strncmp(ifa->ifa_name, "lo", 2) == 0 &&
498 (isdigit(ifa->ifa_name[2]) || ifa->ifa_name[2] == '\0'))
499 continue;
500 #endif
502 if (!iface || strcmp(ifa->ifa_name, iface) == 0)
504 else
505 continue;
507 /* candidate found */
508 memcpy(sin, ifa->ifa_addr, ifa->ifa_addr->sa_len);
509 freeifaddrs(ifap);
510 return 0;
513 /* no candidate */
514 freeifaddrs(ifap);
515 return -1;