Bug Summary

File:src/sbin/resolvd/resolvd.c
Warning:line 616, column 11
Although the value stored to 'linelen' is used in the enclosing expression, the value is never actually read from 'linelen'

Annotated Source Code

Press '?' to see keyboard shortcuts

clang -cc1 -cc1 -triple amd64-unknown-openbsd7.0 -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name resolvd.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 1 -pic-is-pie -mframe-pointer=all -relaxed-aliasing -fno-rounding-math -mconstructor-aliases -munwind-tables -target-cpu x86-64 -target-feature +retpoline-indirect-calls -target-feature +retpoline-indirect-branches -tune-cpu generic -debugger-tuning=gdb -fcoverage-compilation-dir=/usr/src/sbin/resolvd/obj -resource-dir /usr/local/lib/clang/13.0.0 -I /usr/src/sbin/resolvd -internal-isystem /usr/local/lib/clang/13.0.0/include -internal-externc-isystem /usr/include -O2 -fdebug-compilation-dir=/usr/src/sbin/resolvd/obj -ferror-limit 19 -fwrapv -D_RET_PROTECTOR -ret-protector -fgnuc-version=4.2.1 -vectorize-loops -vectorize-slp -fno-builtin-malloc -fno-builtin-calloc -fno-builtin-realloc -fno-builtin-valloc -fno-builtin-free -fno-builtin-strdup -fno-builtin-strndup -analyzer-output=html -faddrsig -D__GCC_HAVE_DWARF2_CFI_ASM=1 -o /home/ben/Projects/vmm/scan-build/2022-01-12-194120-40624-1 -x c /usr/src/sbin/resolvd/resolvd.c
1/* $OpenBSD: resolvd.c,v 1.25 2021/11/16 16:24:22 kn Exp $ */
2/*
3 * Copyright (c) 2021 Florian Obser <florian@openbsd.org>
4 * Copyright (c) 2021 Theo de Raadt <deraadt@openbsd.org>
5 *
6 * Permission to use, copy, modify, and distribute this software for any
7 * purpose with or without fee is hereby granted, provided that the above
8 * copyright notice and this permission notice appear in all copies.
9 *
10 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
15 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
16 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17 */
18
19#include <sys/types.h>
20#include <sys/event.h>
21#include <sys/socket.h>
22#include <sys/stat.h>
23#include <sys/syslog.h>
24#include <sys/time.h>
25#include <sys/un.h>
26#include <netdb.h>
27
28#include <arpa/inet.h>
29#include <netinet/in.h>
30#include <net/if.h>
31#include <net/route.h>
32
33#include <err.h>
34#include <errno(*__errno()).h>
35#include <fcntl.h>
36#include <event.h>
37#include <signal.h>
38#include <stddef.h>
39#include <stdio.h>
40#include <stdlib.h>
41#include <string.h>
42#include <unistd.h>
43
44#define ROUTE_SOCKET_BUF_SIZE16384 16384
45#define ASR_MAXNS10 10
46#define _PATH_LOCKFILE"/dev/resolvd.lock" "/dev/resolvd.lock"
47#define _PATH_UNWIND_SOCKET"/dev/unwind.sock" "/dev/unwind.sock"
48#define _PATH_RESCONF"/etc/resolv.conf" "/etc/resolv.conf"
49#define _PATH_RESCONF_NEW"/etc/resolv.conf.new" "/etc/resolv.conf.new"
50
51#ifndef nitems
52#define nitems(_a)(sizeof((_a)) / sizeof((_a)[0])) (sizeof((_a)) / sizeof((_a)[0]))
53#endif
54
55__dead__attribute__((__noreturn__)) void usage(void);
56
57struct rdns_proposal {
58 uint32_t if_index;
59 int af;
60 int prio;
61 char ip[INET6_ADDRSTRLEN46];
62};
63
64void route_receive(int);
65void handle_route_message(struct rt_msghdr *, struct sockaddr **);
66void get_rtaddrs(int, struct sockaddr *, struct sockaddr **);
67void solicit_dns_proposals(int);
68void regen_resolvconf(char *reason);
69int cmp(const void *, const void *);
70int findslot(struct rdns_proposal *);
71void zeroslot(struct rdns_proposal *);
72
73struct rdns_proposal learned[ASR_MAXNS10];
74int resolvfd = -1;
75int newkevent = 1;
76
77#ifndef SMALL
78int open_unwind_ctl(void);
79int check_unwind = 1, unwind_running = 0;
80
81struct loggers {
82 __dead__attribute__((__noreturn__)) void (*err)(int, const char *, ...)
83 __attribute__((__format__ (printf, 2, 3)));
84 __dead__attribute__((__noreturn__)) void (*errx)(int, const char *, ...)
85 __attribute__((__format__ (printf, 2, 3)));
86 void (*warn)(const char *, ...)
87 __attribute__((__format__ (printf, 1, 2)));
88 void (*warnx)(const char *, ...)
89 __attribute__((__format__ (printf, 1, 2)));
90 void (*info)(const char *, ...)
91 __attribute__((__format__ (printf, 1, 2)));
92 void (*debug)(const char *, ...)
93 __attribute__((__format__ (printf, 1, 2)));
94};
95
96void warnx_verbose(const char *, ...)
97 __attribute__((__format__ (printf, 1, 2)));
98
99const struct loggers conslogger = {
100 err,
101 errx,
102 warn,
103 warnx,
104 warnx_verbose, /* info */
105 warnx_verbose /* debug */
106};
107
108__dead__attribute__((__noreturn__)) void syslog_err(int, const char *, ...)
109 __attribute__((__format__ (printf, 2, 3)));
110__dead__attribute__((__noreturn__)) void syslog_errx(int, const char *, ...)
111 __attribute__((__format__ (printf, 2, 3)));
112void syslog_warn(const char *, ...)
113 __attribute__((__format__ (printf, 1, 2)));
114void syslog_warnx(const char *, ...)
115 __attribute__((__format__ (printf, 1, 2)));
116void syslog_info(const char *, ...)
117 __attribute__((__format__ (printf, 1, 2)));
118void syslog_debug(const char *, ...)
119 __attribute__((__format__ (printf, 1, 2)));
120void syslog_vstrerror(int, int, const char *, va_list)
121 __attribute__((__format__ (printf, 3, 0)));
122
123int verbose = 0;
124
125const struct loggers syslogger = {
126 syslog_err,
127 syslog_errx,
128 syslog_warn,
129 syslog_warnx,
130 syslog_info,
131 syslog_debug
132};
133
134const struct loggers *logger = &conslogger;
135
136#define lerr(_e, _f...)logger->err((_e), _f...) logger->err((_e), _f)
137#define lerrx(_e, _f...)logger->errx((_e), _f...) logger->errx((_e), _f)
138#define lwarn(_f...)logger->warn(_f...) logger->warn(_f)
139#define lwarnx(_f...)logger->warnx(_f...) logger->warnx(_f)
140#define linfo(_f...)logger->info(_f...) logger->info(_f)
141#define ldebug(_f...)logger->debug(_f...) logger->debug(_f)
142#else
143#define lerr(x...)logger->err((x...), ) do {} while(0)
144#define lerrx(x...)logger->errx((x...), ) do {} while(0)
145#define lwarn(x...)logger->warn(x...) do {} while(0)
146#define lwarnx(x...)logger->warnx(x...) do {} while(0)
147#define linfo(x...)logger->info(x...) do {} while(0)
148#define ldebug(x...)logger->debug(x...) do {} while(0)
149#endif /* SMALL */
150
151enum {
152 KQ_ROUTE,
153 KQ_RESOLVE_CONF,
154#ifndef SMALL
155 KQ_UNWIND,
156#endif
157 KQ_TOTAL
158};
159
160int
161main(int argc, char *argv[])
162{
163 struct timespec one = {1, 0};
164 int kq, ch, debug = 0, routesock;
165 int rtfilter, nready, lockfd;
166 struct kevent kev[KQ_TOTAL];
167#ifndef SMALL
168 int unwindsock = -1;
169#endif
170
171 while ((ch = getopt(argc, argv, "dv")) != -1) {
172 switch (ch) {
173 case 'd':
174 debug = 1;
175 break;
176 case 'v':
177#ifndef SMALL
178 verbose++;
179#endif
180 break;
181 default:
182 usage();
183 }
184 }
185
186 argc -= optind;
187 argv += optind;
188 if (argc > 0)
189 usage();
190
191 /* Check for root privileges. */
192 if (geteuid())
193 errx(1, "need root privileges");
194
195 lockfd = open(_PATH_LOCKFILE"/dev/resolvd.lock", O_CREAT0x0200|O_RDWR0x0002|O_EXLOCK0x0020|O_NONBLOCK0x0004, 0600);
196 if (lockfd == -1)
197 errx(1, "already running");
198
199 if (!debug)
200 daemon(0, 0);
201
202#ifndef SMALL
203 if (!debug) {
204 openlog("resolvd", LOG_PID0x01|LOG_NDELAY0x08, LOG_DAEMON(3<<3));
205 logger = &syslogger;
206 }
207#endif
208
209 signal(SIGHUP1, SIG_IGN(void (*)(int))1);
210
211 if ((routesock = socket(AF_ROUTE17, SOCK_RAW3, 0)) == -1)
212 lerr(1, "route socket")logger->err((1), "route socket");
213
214 rtfilter = ROUTE_FILTER(RTM_PROPOSAL)(1 << (0x13)) | ROUTE_FILTER(RTM_IFANNOUNCE)(1 << (0xf));
215 if (setsockopt(routesock, AF_ROUTE17, ROUTE_MSGFILTER1, &rtfilter,
216 sizeof(rtfilter)) == -1)
217 lerr(1, "setsockopt(ROUTE_MSGFILTER)")logger->err((1), "setsockopt(ROUTE_MSGFILTER)");
218
219 solicit_dns_proposals(routesock);
220
221 if (unveil(_PATH_RESCONF"/etc/resolv.conf", "rwc") == -1)
222 lerr(1, "unveil " _PATH_RESCONF)logger->err((1), "unveil " "/etc/resolv.conf");
223 if (unveil(_PATH_RESCONF_NEW"/etc/resolv.conf.new", "rwc") == -1)
224 lerr(1, "unveil " _PATH_RESCONF_NEW)logger->err((1), "unveil " "/etc/resolv.conf.new");
225#ifndef SMALL
226 if (unveil(_PATH_UNWIND_SOCKET"/dev/unwind.sock", "r") == -1)
227 lerr(1, "unveil " _PATH_UNWIND_SOCKET)logger->err((1), "unveil " "/dev/unwind.sock");
228#endif
229
230 if (pledge("stdio unix rpath wpath cpath", NULL((void*)0)) == -1)
231 lerr(1, "pledge")logger->err((1), "pledge");
232
233 if ((kq = kqueue()) == -1)
234 lerr(1, "kqueue")logger->err((1), "kqueue");
235
236 for(;;) {
237 int i;
238
239#ifndef SMALL
240 if (!unwind_running && check_unwind) {
241 check_unwind = 0;
242 unwindsock = open_unwind_ctl();
243 unwind_running = unwindsock != -1;
244 if (unwind_running)
245 regen_resolvconf("new unwind");
246 }
247#endif
248
249 if (newkevent) {
250 int kevi = 0;
251
252 if (routesock != -1)
253 EV_SET(&kev[kevi++], routesock, EVFILT_READ,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (routesock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_ROUTE); } while(0)
254 EV_ADD, 0, 0,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (routesock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_ROUTE); } while(0)
255 (void *)KQ_ROUTE)do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (routesock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_ROUTE); } while(0);
256 if (resolvfd != -1)
257 EV_SET(&kev[kevi++], resolvfd, EVFILT_VNODE,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (resolvfd); (__kevp)->filter = ((-4)); (__kevp)->
flags = (0x0001 | 0x0020); (__kevp)->fflags = (0x0001 | 0x0020
| 0x0080 | 0x0002); (__kevp)->data = (0); (__kevp)->udata
= ((void *)KQ_RESOLVE_CONF); } while(0)
258 EV_ADD | EV_CLEAR,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (resolvfd); (__kevp)->filter = ((-4)); (__kevp)->
flags = (0x0001 | 0x0020); (__kevp)->fflags = (0x0001 | 0x0020
| 0x0080 | 0x0002); (__kevp)->data = (0); (__kevp)->udata
= ((void *)KQ_RESOLVE_CONF); } while(0)
259 NOTE_DELETE | NOTE_RENAME | NOTE_TRUNCATE | NOTE_WRITE, 0,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (resolvfd); (__kevp)->filter = ((-4)); (__kevp)->
flags = (0x0001 | 0x0020); (__kevp)->fflags = (0x0001 | 0x0020
| 0x0080 | 0x0002); (__kevp)->data = (0); (__kevp)->udata
= ((void *)KQ_RESOLVE_CONF); } while(0)
260 (void *)KQ_RESOLVE_CONF)do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (resolvfd); (__kevp)->filter = ((-4)); (__kevp)->
flags = (0x0001 | 0x0020); (__kevp)->fflags = (0x0001 | 0x0020
| 0x0080 | 0x0002); (__kevp)->data = (0); (__kevp)->udata
= ((void *)KQ_RESOLVE_CONF); } while(0);
261
262#ifndef SMALL
263 if (unwind_running) {
264 EV_SET(&kev[kevi++], unwindsock, EVFILT_READ,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (unwindsock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_UNWIND); } while(0)
265 EV_ADD, 0, 0,do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (unwindsock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_UNWIND); } while(0)
266 (void *)KQ_UNWIND)do { struct kevent *__kevp = (&kev[kevi++]); (__kevp)->
ident = (unwindsock); (__kevp)->filter = ((-1)); (__kevp)->
flags = (0x0001); (__kevp)->fflags = (0); (__kevp)->data
= (0); (__kevp)->udata = ((void *)KQ_UNWIND); } while(0);
267 }
268#endif /* SMALL */
269
270 if (kevent(kq, kev, kevi, NULL((void*)0), 0, NULL((void*)0)) == -1)
271 lerr(1, "kevent")logger->err((1), "kevent");
272 newkevent = 0;
273 }
274
275 nready = kevent(kq, NULL((void*)0), 0, kev, KQ_TOTAL, NULL((void*)0));
276 if (nready == -1) {
277 if (errno(*__errno()) == EINTR4)
278 continue;
279 lerr(1, "kevent")logger->err((1), "kevent");
280 }
281
282 if (nready == 0)
283 continue;
284
285 for (i = 0; i < nready; i++) {
286 unsigned short fflags = kev[i].fflags;
287
288 switch ((int)(long)kev[i].udata) {
289 case KQ_ROUTE:
290 route_receive(routesock);
291 break;
292
293 case KQ_RESOLVE_CONF:
294 if (fflags & (NOTE_DELETE0x0001 | NOTE_RENAME0x0020)) {
295 close(resolvfd);
296 resolvfd = -1;
297 regen_resolvconf("file delete/rename");
298 }
299 if (fflags & (NOTE_TRUNCATE0x0080 | NOTE_WRITE0x0002)) {
300 /* some editors truncate and write */
301 if (fflags & NOTE_TRUNCATE0x0080)
302 nanosleep(&one, NULL((void*)0));
303 regen_resolvconf("file trunc/write");
304 }
305 break;
306
307#ifndef SMALL
308 case KQ_UNWIND: {
309 uint8_t buf[1024];
310 ssize_t n;
311
312 n = read(unwindsock, buf, sizeof(buf));
313 if (n == -1) {
314 if (errno(*__errno()) == EAGAIN35 || errno(*__errno()) == EINTR4)
315 continue;
316 }
317 if (n == 0 || n == -1) {
318 if (n == -1)
319 check_unwind = 1;
320 newkevent = 1;
321 close(unwindsock);
322 unwindsock = -1;
323 unwind_running = 0;
324 regen_resolvconf("unwind closed");
325 } else
326 lwarnx("read %ld from unwind ctl", n)logger->warnx("read %ld from unwind ctl", n);
327 break;
328 }
329#endif
330
331 default:
332 lwarnx("unknown kqueue event on %lu",logger->warnx("unknown kqueue event on %lu", kev[i].ident)
333 kev[i].ident)logger->warnx("unknown kqueue event on %lu", kev[i].ident);
334 }
335 }
336 }
337 return 0;
338}
339
340__dead__attribute__((__noreturn__)) void
341usage(void)
342{
343 fprintf(stderr(&__sF[2]), "usage: resolvd [-dv]\n");
344 exit(1);
345}
346
347void
348route_receive(int fd)
349{
350 uint8_t rsock_buf[ROUTE_SOCKET_BUF_SIZE16384];
351 struct sockaddr *sa, *rti_info[RTAX_MAX15];
352 struct rt_msghdr *rtm;
353 ssize_t n;
354
355 rtm = (struct rt_msghdr *) rsock_buf;
356 if ((n = read(fd, rsock_buf, sizeof(rsock_buf))) == -1) {
357 if (errno(*__errno()) == EAGAIN35 || errno(*__errno()) == EINTR4)
358 return;
359 lwarn("%s: read error", __func__)logger->warn("%s: read error", __func__);
360 return;
361 }
362
363 if (n == 0)
364 lerr(1, "routing socket closed")logger->err((1), "routing socket closed");
365
366 if (n < (ssize_t)sizeof(rtm->rtm_msglen) || n < rtm->rtm_msglen) {
367 lwarnx("partial rtm of %zd in buffer", n)logger->warnx("partial rtm of %zd in buffer", n);
368 return;
369 }
370
371 if (rtm->rtm_version != RTM_VERSION5)
372 return;
373
374 if (rtm->rtm_pid == getpid())
375 return;
376
377 sa = (struct sockaddr *)(rsock_buf + rtm->rtm_hdrlen);
378 get_rtaddrs(rtm->rtm_addrs, sa, rti_info);
379 handle_route_message(rtm, rti_info);
380}
381
382void
383zeroslot(struct rdns_proposal *tab)
384{
385 tab->prio = 0;
386 tab->af = 0;
387 tab->if_index = 0;
388 tab->ip[0] = '\0';
389}
390
391int
392findslot(struct rdns_proposal *tab)
393{
394 int i;
395
396 for (i = 0; i < ASR_MAXNS10; i++)
397 if (tab[i].prio == 0)
398 return i;
399
400 /* New proposals might be important, so replace the last slot */
401 i = ASR_MAXNS10 - 1;
402 zeroslot(&tab[i]);
403 return i;
404}
405
406void
407handle_route_message(struct rt_msghdr *rtm, struct sockaddr **rti_info)
408{
409 struct rdns_proposal learning[nitems(learned)(sizeof((learned)) / sizeof((learned)[0]))];
410 struct sockaddr_rtdns *rtdns;
411 struct if_announcemsghdr *ifan;
412 size_t addrsz;
413 int rdns_count, af, i;
414 char *src;
415
416 memcpy(learning, learned, sizeof learned);
417
418 switch (rtm->rtm_type) {
419 case RTM_IFANNOUNCE0xf:
420 ifan = (struct if_announcemsghdr *)rtm;
421 if (ifan->ifan_what == IFAN_ARRIVAL0)
422 return;
423 /* Delete proposals learned from departing interfaces */
424 for (i = 0; i < ASR_MAXNS10; i++)
425 if (learning[i].if_index == ifan->ifan_index)
426 zeroslot(&learning[i]);
427 break;
428 case RTM_PROPOSAL0x13:
429 if (rtm->rtm_priority == RTP_PROPOSAL_SOLICIT62) {
430#ifndef SMALL
431 check_unwind = 1;
432#endif /* SMALL */
433 return;
434 }
435
436 if (!(rtm->rtm_addrs & RTA_DNS0x1000))
437 return;
438
439 rtdns = (struct sockaddr_rtdns*)rti_info[RTAX_DNS12];
440 src = rtdns->sr_dns;
441 af = rtdns->sr_family;
442
443 switch (af) {
444 case AF_INET2:
445 addrsz = sizeof(struct in_addr);
446 break;
447 case AF_INET624:
448 addrsz = sizeof(struct in6_addr);
449 break;
450 default:
451 lwarnx("ignoring invalid RTM_PROPOSAL")logger->warnx("ignoring invalid RTM_PROPOSAL");
452 return;
453 }
454
455 if ((rtdns->sr_len - 2) % addrsz != 0) {
456 lwarnx("ignoring invalid RTM_PROPOSAL")logger->warnx("ignoring invalid RTM_PROPOSAL");
457 return;
458 }
459 rdns_count = (rtdns->sr_len -
460 offsetof(struct sockaddr_rtdns, sr_dns)__builtin_offsetof(struct sockaddr_rtdns, sr_dns)) / addrsz;
461
462 /* New proposal from interface means previous proposals expire */
463 for (i = 0; i < ASR_MAXNS10; i++)
464 if (learning[i].af == af &&
465 learning[i].if_index == rtm->rtm_index)
466 zeroslot(&learning[i]);
467
468 /* Add the new proposals */
469 for (i = 0; i < rdns_count; i++) {
470 struct sockaddr_storage ss;
471 struct sockaddr_in *sin = (struct sockaddr_in *)&ss;
472 struct sockaddr_in6 *sin6 = (struct sockaddr_in6 *)&ss;
473 int new, err;
474
475 memset(&ss, 0, sizeof(ss));
476 ss.ss_family = af;
477 new = findslot(learning);
478 switch (af) {
479 case AF_INET2:
480 memcpy(&sin->sin_addr, src, addrsz);
481 ss.ss_len = sizeof(*sin);
482 break;
483 case AF_INET624:
484 memcpy(&sin6->sin6_addr, src, addrsz);
485 if (IN6_IS_ADDR_LINKLOCAL(&sin6->sin6_addr)(((&sin6->sin6_addr)->__u6_addr.__u6_addr8[0] == 0xfe
) && (((&sin6->sin6_addr)->__u6_addr.__u6_addr8
[1] & 0xc0) == 0x80)))
486 sin6->sin6_scope_id = rtm->rtm_index;
487 ss.ss_len = sizeof(*sin6);
488 break;
489 }
490 src += addrsz;
491
492 if ((err = getnameinfo((struct sockaddr *)&ss, ss.ss_len,
493 learning[new].ip, sizeof(learning[new].ip),
494 NULL((void*)0), 0, NI_NUMERICHOST1)) == 0) {
495 learning[new].prio = rtm->rtm_priority;
496 learning[new].if_index = rtm->rtm_index;
497 learning[new].af = af;
498 } else
499 lwarnx("getnameinfo: %s", gai_strerror(err))logger->warnx("getnameinfo: %s", gai_strerror(err));
500 }
501 break;
502 default:
503 return;
504 }
505
506 /* Sort proposals, based upon priority and IP */
507 qsort(learning, ASR_MAXNS10, sizeof(learning[0]), cmp);
508
509 /* Eliminate duplicates */
510 for (i = 0; i < ASR_MAXNS10 - 1; i++) {
511 if (learning[i].prio == 0)
512 continue;
513 if (learning[i].if_index == learning[i+1].if_index &&
514 strcmp(learning[i].ip, learning[i+1].ip) == 0) {
515 zeroslot(&learning[i + 1]);
516 i--; /* backup and re-check */
517 }
518 }
519
520 /* If proposal result is different, rebuild the file */
521 if (memcmp(learned, learning, sizeof(learned)) != 0) {
522 memcpy(learned, learning, sizeof(learned));
523 regen_resolvconf("route proposals");
524 }
525}
526
527#define ROUNDUP(a)((a) > 0 ? (1 + (((a) - 1) | (sizeof(long) - 1))) : sizeof
(long)) \
528 ((a) > 0 ? (1 + (((a) - 1) | (sizeof(long) - 1))) : sizeof(long))
529
530void
531get_rtaddrs(int addrs, struct sockaddr *sa, struct sockaddr **rti_info)
532{
533 int i;
534
535 for (i = 0; i < RTAX_MAX15; i++) {
536 if (addrs & (1 << i)) {
537 rti_info[i] = sa;
538 sa = (struct sockaddr *)((char *)(sa) +
539 ROUNDUP(sa->sa_len)((sa->sa_len) > 0 ? (1 + (((sa->sa_len) - 1) | (sizeof
(long) - 1))) : sizeof(long)));
540 } else
541 rti_info[i] = NULL((void*)0);
542 }
543}
544
545void
546solicit_dns_proposals(int routesock)
547{
548 struct rt_msghdr rtm;
549 struct iovec iov[1];
550 int iovcnt = 0;
551
552 memset(&rtm, 0, sizeof(rtm));
553
554 rtm.rtm_version = RTM_VERSION5;
555 rtm.rtm_type = RTM_PROPOSAL0x13;
556 rtm.rtm_msglen = sizeof(rtm);
557 rtm.rtm_tableid = 0;
558 rtm.rtm_index = 0;
559 rtm.rtm_seq = arc4random();
560 rtm.rtm_priority = RTP_PROPOSAL_SOLICIT62;
561
562 iov[iovcnt].iov_base = &rtm;
563 iov[iovcnt++].iov_len = sizeof(rtm);
564
565 if (writev(routesock, iov, iovcnt) == -1)
566 lwarn("failed to send solicitation")logger->warn("failed to send solicitation");
567}
568
569void
570regen_resolvconf(char *why)
571{
572 int i, fd;
573
574 linfo("rebuilding: %s", why)logger->info("rebuilding: %s", why);
575
576 if ((fd = open(_PATH_RESCONF_NEW"/etc/resolv.conf.new", O_CREAT0x0200|O_TRUNC0x0400|O_RDWR0x0002, 0644)) == -1) {
577 lwarn(_PATH_RESCONF_NEW)logger->warn("/etc/resolv.conf.new");
578 return;
579 }
580
581#ifndef SMALL
582 if (unwind_running)
583 dprintf(fd, "nameserver 127.0.0.1 # resolvd: unwind\n");
584
585#endif /* SMALL */
586 for (i = 0; i < ASR_MAXNS10; i++) {
587 if (learned[i].prio != 0) {
588 char ifnambuf[IF_NAMESIZE16], *ifnam;
589
590 ifnam = if_indextoname(learned[i].if_index,
591 ifnambuf);
592 dprintf(fd, "%snameserver %s # resolvd: %s\n",
593#ifndef SMALL
594 unwind_running ? "#" : "",
595#else
596 "",
597#endif
598 learned[i].ip,
599 ifnam ? ifnam : "");
600 }
601 }
602
603 /* Replay user-managed lines from old resolv.conf file */
604 if (resolvfd == -1)
605 resolvfd = open(_PATH_RESCONF"/etc/resolv.conf", O_RDWR0x0002);
606 if (resolvfd != -1) {
607 char *line = NULL((void*)0);
608 size_t linesize = 0;
609 ssize_t linelen;
610 FILE *fp;
611
612 lseek(resolvfd, 0, SEEK_SET0);
613 fp = fdopen(resolvfd, "r");
614 if (fp == NULL((void*)0))
615 goto err;
616 while ((linelen = getline(&line, &linesize, fp)) != -1) {
Although the value stored to 'linelen' is used in the enclosing expression, the value is never actually read from 'linelen'
617 char *end = strchr(line, '\n');
618 if (end)
619 *end = '\0';
620 if (strstr(line, "# resolvd: "))
621 continue;
622 dprintf(fd, "%s\n", line);
623 }
624 free(line);
625 }
626
627 if (rename(_PATH_RESCONF_NEW"/etc/resolv.conf.new", _PATH_RESCONF"/etc/resolv.conf") == -1)
628 goto err;
629
630 if (resolvfd == -1) {
631 close(fd);
632 resolvfd = open(_PATH_RESCONF"/etc/resolv.conf", O_RDWR0x0002 | O_CREAT0x0200);
633 } else {
634 dup2(fd, resolvfd);
635 close(fd);
636 }
637
638 newkevent = 1;
639 return;
640
641 err:
642 if (fd != -1)
643 close(fd);
644 unlink(_PATH_RESCONF_NEW"/etc/resolv.conf.new");
645}
646
647int
648cmp(const void *a, const void *b)
649{
650 const struct rdns_proposal *rpa = a, *rpb = b;
651
652 if (rpa->prio == rpb->prio)
653 return strcmp(rpa->ip, rpb->ip);
654 else
655 return rpa->prio < rpb->prio ? -1 : 1;
656}
657
658#ifndef SMALL
659int
660open_unwind_ctl(void)
661{
662 static struct sockaddr_un sun;
663 int s;
664
665 if (sun.sun_family == 0) {
666 sun.sun_family = AF_UNIX1;
667 strlcpy(sun.sun_path, _PATH_UNWIND_SOCKET"/dev/unwind.sock", sizeof(sun.sun_path));
668 }
669
670 if ((s = socket(AF_UNIX1, SOCK_STREAM1, 0)) != -1) {
671 if (connect(s, (struct sockaddr *)&sun, sizeof(sun)) == -1) {
672 close(s);
673 s = -1;
674 }
675 }
676 newkevent = 1;
677 return s;
678}
679
680void
681syslog_vstrerror(int e, int priority, const char *fmt, va_list ap)
682{
683 char *s;
684
685 if (vasprintf(&s, fmt, ap) == -1) {
686 syslog(LOG_EMERG0, "unable to alloc in syslog_vstrerror");
687 exit(1);
688 }
689 syslog(priority, "%s: %s", s, strerror(e));
690 free(s);
691}
692
693__dead__attribute__((__noreturn__)) void
694syslog_err(int ecode, const char *fmt, ...)
695{
696 va_list ap;
697
698 va_start(ap, fmt)__builtin_va_start(ap, fmt);
699 syslog_vstrerror(errno(*__errno()), LOG_CRIT2, fmt, ap);
700 va_end(ap)__builtin_va_end(ap);
701 exit(ecode);
702}
703
704__dead__attribute__((__noreturn__)) void
705syslog_errx(int ecode, const char *fmt, ...)
706{
707 va_list ap;
708
709 va_start(ap, fmt)__builtin_va_start(ap, fmt);
710 vsyslog(LOG_CRIT2, fmt, ap);
711 va_end(ap)__builtin_va_end(ap);
712 exit(ecode);
713}
714
715void
716syslog_warn(const char *fmt, ...)
717{
718 va_list ap;
719
720 va_start(ap, fmt)__builtin_va_start(ap, fmt);
721 syslog_vstrerror(errno(*__errno()), LOG_ERR3, fmt, ap);
722 va_end(ap)__builtin_va_end(ap);
723}
724
725void
726syslog_warnx(const char *fmt, ...)
727{
728 va_list ap;
729
730 va_start(ap, fmt)__builtin_va_start(ap, fmt);
731 vsyslog(LOG_ERR3, fmt, ap);
732 va_end(ap)__builtin_va_end(ap);
733}
734
735void
736syslog_info(const char *fmt, ...)
737{
738 va_list ap;
739
740 va_start(ap, fmt)__builtin_va_start(ap, fmt);
741 vsyslog(LOG_INFO6, fmt, ap);
742 va_end(ap)__builtin_va_end(ap);
743}
744
745void
746syslog_debug(const char *fmt, ...)
747{
748 va_list ap;
749
750 va_start(ap, fmt)__builtin_va_start(ap, fmt);
751 vsyslog(LOG_DEBUG7, fmt, ap);
752 va_end(ap)__builtin_va_end(ap);
753}
754
755void
756warnx_verbose(const char *fmt, ...)
757{
758 va_list ap;
759
760 va_start(ap, fmt)__builtin_va_start(ap, fmt);
761 if (verbose)
762 vwarnx(fmt, ap);
763 va_end(ap)__builtin_va_end(ap);
764}
765
766#endif /* SMALL */