Merge pull request #3520 from keszybz/add-release.md
[thirdparty/systemd.git] / src / resolve / resolved-manager.c
CommitLineData
091a364c
TG
1/***
2 This file is part of systemd.
3
4 Copyright 2014 Tom Gundersen <teg@jklm.no>
5
6 systemd is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as published by
8 the Free Software Foundation; either version 2.1 of the License, or
9 (at your option) any later version.
10
11 systemd is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
15
16 You should have received a copy of the GNU Lesser General Public License
17 along with systemd; If not, see <http://www.gnu.org/licenses/>.
18 ***/
19
07630cea
LP
20#include <netinet/in.h>
21#include <poll.h>
74b2466e 22#include <sys/ioctl.h>
091a364c 23
a2a416f7 24#include "af-list.h"
b5efdb8a 25#include "alloc-util.h"
07630cea 26#include "dns-domain.h"
3ffd4af2 27#include "fd-util.h"
a5a807e6 28#include "fileio-label.h"
07630cea 29#include "hostname-util.h"
c004493c 30#include "io-util.h"
07630cea
LP
31#include "netlink-util.h"
32#include "network-internal.h"
822db23c 33#include "ordered-set.h"
6bedfcbb 34#include "parse-util.h"
3df3e884 35#include "random-util.h"
39d8db04 36#include "resolved-bus.h"
07630cea 37#include "resolved-conf.h"
dd0bc0f1 38#include "resolved-etc-hosts.h"
5f402ae8 39#include "resolved-llmnr.h"
07630cea 40#include "resolved-manager.h"
bc7702b0 41#include "resolved-mdns.h"
dd0bc0f1 42#include "resolved-resolv-conf.h"
07630cea 43#include "socket-util.h"
8b43440b 44#include "string-table.h"
07630cea
LP
45#include "string-util.h"
46#include "utf8.h"
74b2466e
LP
47
48#define SEND_TIMEOUT_USEC (200 * USEC_PER_MSEC)
49
1c4baffc 50static int manager_process_link(sd_netlink *rtnl, sd_netlink_message *mm, void *userdata) {
74b2466e
LP
51 Manager *m = userdata;
52 uint16_t type;
53 Link *l;
54 int ifindex, r;
55
56 assert(rtnl);
57 assert(m);
58 assert(mm);
59
1c4baffc 60 r = sd_netlink_message_get_type(mm, &type);
74b2466e
LP
61 if (r < 0)
62 goto fail;
63
64 r = sd_rtnl_message_link_get_ifindex(mm, &ifindex);
65 if (r < 0)
66 goto fail;
67
68 l = hashmap_get(m->links, INT_TO_PTR(ifindex));
69
70 switch (type) {
71
a2a416f7
LP
72 case RTM_NEWLINK:{
73 bool is_new = !l;
74b2466e 74
a2a416f7 75 if (!l) {
74b2466e
LP
76 r = link_new(m, &l, ifindex);
77 if (r < 0)
78 goto fail;
79 }
80
81 r = link_update_rtnl(l, mm);
82 if (r < 0)
83 goto fail;
84
21d73c87
LP
85 r = link_update_monitor(l);
86 if (r < 0)
87 goto fail;
88
a2a416f7
LP
89 if (is_new)
90 log_debug("Found new link %i/%s", ifindex, l->name);
91
74b2466e 92 break;
a2a416f7 93 }
74b2466e
LP
94
95 case RTM_DELLINK:
96 if (l) {
a2a416f7 97 log_debug("Removing link %i/%s", l->ifindex, l->name);
74b2466e
LP
98 link_free(l);
99 }
100
101 break;
102 }
103
104 return 0;
105
106fail:
da927ba9 107 log_warning_errno(r, "Failed to process RTNL link message: %m");
74b2466e
LP
108 return 0;
109}
110
1c4baffc 111static int manager_process_address(sd_netlink *rtnl, sd_netlink_message *mm, void *userdata) {
74b2466e
LP
112 Manager *m = userdata;
113 union in_addr_union address;
74b2466e 114 uint16_t type;
0dd25fb9 115 int r, ifindex, family;
74b2466e
LP
116 LinkAddress *a;
117 Link *l;
118
119 assert(rtnl);
120 assert(mm);
121 assert(m);
122
1c4baffc 123 r = sd_netlink_message_get_type(mm, &type);
74b2466e
LP
124 if (r < 0)
125 goto fail;
126
127 r = sd_rtnl_message_addr_get_ifindex(mm, &ifindex);
128 if (r < 0)
129 goto fail;
130
131 l = hashmap_get(m->links, INT_TO_PTR(ifindex));
132 if (!l)
133 return 0;
134
135 r = sd_rtnl_message_addr_get_family(mm, &family);
136 if (r < 0)
137 goto fail;
138
139 switch (family) {
140
141 case AF_INET:
1c4baffc 142 r = sd_netlink_message_read_in_addr(mm, IFA_LOCAL, &address.in);
74b2466e 143 if (r < 0) {
1c4baffc 144 r = sd_netlink_message_read_in_addr(mm, IFA_ADDRESS, &address.in);
74b2466e
LP
145 if (r < 0)
146 goto fail;
147 }
148
149 break;
150
151 case AF_INET6:
1c4baffc 152 r = sd_netlink_message_read_in6_addr(mm, IFA_LOCAL, &address.in6);
74b2466e 153 if (r < 0) {
1c4baffc 154 r = sd_netlink_message_read_in6_addr(mm, IFA_ADDRESS, &address.in6);
74b2466e
LP
155 if (r < 0)
156 goto fail;
157 }
158
159 break;
160
161 default:
162 return 0;
163 }
164
165 a = link_find_address(l, family, &address);
166
167 switch (type) {
168
169 case RTM_NEWADDR:
170
171 if (!a) {
172 r = link_address_new(l, &a, family, &address);
173 if (r < 0)
174 return r;
175 }
176
177 r = link_address_update_rtnl(a, mm);
178 if (r < 0)
179 return r;
180
181 break;
182
183 case RTM_DELADDR:
3e044c49 184 link_address_free(a);
74b2466e
LP
185 break;
186 }
187
188 return 0;
189
190fail:
da927ba9 191 log_warning_errno(r, "Failed to process RTNL address message: %m");
74b2466e
LP
192 return 0;
193}
194
74b2466e 195static int manager_rtnl_listen(Manager *m) {
4afd3348 196 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL, *reply = NULL;
1c4baffc 197 sd_netlink_message *i;
74b2466e
LP
198 int r;
199
200 assert(m);
201
cc98b302 202 /* First, subscribe to interfaces coming and going */
1c4baffc 203 r = sd_netlink_open(&m->rtnl);
74b2466e
LP
204 if (r < 0)
205 return r;
206
2d895038 207 r = sd_netlink_attach_event(m->rtnl, m->event, SD_EVENT_PRIORITY_IMPORTANT);
74b2466e
LP
208 if (r < 0)
209 return r;
210
1c4baffc 211 r = sd_netlink_add_match(m->rtnl, RTM_NEWLINK, manager_process_link, m);
74b2466e
LP
212 if (r < 0)
213 return r;
214
1c4baffc 215 r = sd_netlink_add_match(m->rtnl, RTM_DELLINK, manager_process_link, m);
74b2466e
LP
216 if (r < 0)
217 return r;
218
1c4baffc 219 r = sd_netlink_add_match(m->rtnl, RTM_NEWADDR, manager_process_address, m);
74b2466e
LP
220 if (r < 0)
221 return r;
091a364c 222
1c4baffc 223 r = sd_netlink_add_match(m->rtnl, RTM_DELADDR, manager_process_address, m);
74b2466e
LP
224 if (r < 0)
225 return r;
226
227 /* Then, enumerate all links */
228 r = sd_rtnl_message_new_link(m->rtnl, &req, RTM_GETLINK, 0);
229 if (r < 0)
230 return r;
231
1c4baffc 232 r = sd_netlink_message_request_dump(req, true);
74b2466e
LP
233 if (r < 0)
234 return r;
235
1c4baffc 236 r = sd_netlink_call(m->rtnl, req, 0, &reply);
74b2466e
LP
237 if (r < 0)
238 return r;
239
1c4baffc 240 for (i = reply; i; i = sd_netlink_message_next(i)) {
74b2466e
LP
241 r = manager_process_link(m->rtnl, i, m);
242 if (r < 0)
243 return r;
244 }
245
1c4baffc
TG
246 req = sd_netlink_message_unref(req);
247 reply = sd_netlink_message_unref(reply);
74b2466e
LP
248
249 /* Finally, enumerate all addresses, too */
250 r = sd_rtnl_message_new_addr(m->rtnl, &req, RTM_GETADDR, 0, AF_UNSPEC);
251 if (r < 0)
252 return r;
253
1c4baffc 254 r = sd_netlink_message_request_dump(req, true);
74b2466e
LP
255 if (r < 0)
256 return r;
257
1c4baffc 258 r = sd_netlink_call(m->rtnl, req, 0, &reply);
74b2466e
LP
259 if (r < 0)
260 return r;
261
1c4baffc 262 for (i = reply; i; i = sd_netlink_message_next(i)) {
74b2466e
LP
263 r = manager_process_address(m->rtnl, i, m);
264 if (r < 0)
265 return r;
266 }
267
268 return r;
269}
270
271static int on_network_event(sd_event_source *s, int fd, uint32_t revents, void *userdata) {
272 Manager *m = userdata;
273 Iterator i;
274 Link *l;
275 int r;
276
277 assert(m);
278
279 sd_network_monitor_flush(m->network_monitor);
280
281 HASHMAP_FOREACH(l, m->links, i) {
282 r = link_update_monitor(l);
283 if (r < 0)
da927ba9 284 log_warning_errno(r, "Failed to update monitor information for %i: %m", l->ifindex);
74b2466e
LP
285 }
286
7207052d 287 (void) manager_write_resolv_conf(m);
74b2466e
LP
288
289 return 0;
290}
291
292static int manager_network_monitor_listen(Manager *m) {
293 int r, fd, events;
294
295 assert(m);
296
0014a4ad 297 r = sd_network_monitor_new(&m->network_monitor, NULL);
74b2466e
LP
298 if (r < 0)
299 return r;
300
301 fd = sd_network_monitor_get_fd(m->network_monitor);
302 if (fd < 0)
303 return fd;
304
305 events = sd_network_monitor_get_events(m->network_monitor);
306 if (events < 0)
307 return events;
308
309 r = sd_event_add_io(m->event, &m->network_event_source, fd, events, &on_network_event, m);
310 if (r < 0)
2d895038
LP
311 return r;
312
313 r = sd_event_source_set_priority(m->network_event_source, SD_EVENT_PRIORITY_IMPORTANT+5);
314 if (r < 0)
74b2466e
LP
315 return r;
316
aa4a9deb
LP
317 (void) sd_event_source_set_description(m->network_event_source, "network-monitor");
318
74b2466e
LP
319 return 0;
320}
321
78c6a153 322static int determine_hostname(char **llmnr_hostname, char **mdns_hostname) {
eb60f9cd 323 _cleanup_free_ char *h = NULL, *n = NULL;
78c6a153
LP
324 char label[DNS_LABEL_MAX];
325 const char *p;
326 int r, k;
eb60f9cd 327
78c6a153
LP
328 assert(llmnr_hostname);
329 assert(mdns_hostname);
330
331 /* Extract and normalize the first label of the locally
332 * configured hostname, and check it's not "localhost". */
eb60f9cd
LP
333
334 h = gethostname_malloc();
335 if (!h)
336 return log_oom();
337
78c6a153
LP
338 p = h;
339 r = dns_label_unescape(&p, label, sizeof(label));
340 if (r < 0)
341 return log_error_errno(r, "Failed to unescape host name: %m");
342 if (r == 0) {
343 log_error("Couldn't find a single label in hosntame.");
344 return -EINVAL;
345 }
346
347 k = dns_label_undo_idna(label, r, label, sizeof(label));
348 if (k < 0)
349 return log_error_errno(k, "Failed to undo IDNA: %m");
350 if (k > 0)
351 r = k;
352
353 if (!utf8_is_valid(label)) {
eb60f9cd
LP
354 log_error("System hostname is not UTF-8 clean.");
355 return -EINVAL;
356 }
357
422baca0 358 r = dns_label_escape_new(label, r, &n);
78c6a153
LP
359 if (r < 0)
360 return log_error_errno(r, "Failed to escape host name: %m");
361
362 if (is_localhost(n)) {
363 log_debug("System hostname is 'localhost', ignoring.");
364 return -EINVAL;
eb60f9cd
LP
365 }
366
78c6a153
LP
367 r = dns_name_concat(n, "local", mdns_hostname);
368 if (r < 0)
369 return log_error_errno(r, "Failed to determine mDNS hostname: %m");
370
371 *llmnr_hostname = n;
eb60f9cd
LP
372 n = NULL;
373
374 return 0;
375}
376
377static int on_hostname_change(sd_event_source *es, int fd, uint32_t revents, void *userdata) {
78c6a153 378 _cleanup_free_ char *llmnr_hostname = NULL, *mdns_hostname = NULL;
eb60f9cd
LP
379 Manager *m = userdata;
380 int r;
381
382 assert(m);
383
78c6a153 384 r = determine_hostname(&llmnr_hostname, &mdns_hostname);
eb60f9cd
LP
385 if (r < 0)
386 return 0; /* ignore invalid hostnames */
387
78c6a153 388 if (streq(llmnr_hostname, m->llmnr_hostname) && streq(mdns_hostname, m->mdns_hostname))
eb60f9cd
LP
389 return 0;
390
78c6a153
LP
391 log_info("System hostname changed to '%s'.", llmnr_hostname);
392
393 free(m->llmnr_hostname);
394 free(m->mdns_hostname);
395
396 m->llmnr_hostname = llmnr_hostname;
397 m->mdns_hostname = mdns_hostname;
398
399 llmnr_hostname = mdns_hostname = NULL;
eb60f9cd
LP
400
401 manager_refresh_rrs(m);
402
403 return 0;
404}
405
406static int manager_watch_hostname(Manager *m) {
eb60f9cd
LP
407 int r;
408
409 assert(m);
410
411 m->hostname_fd = open("/proc/sys/kernel/hostname", O_RDONLY|O_CLOEXEC|O_NDELAY|O_NOCTTY);
412 if (m->hostname_fd < 0) {
56f64d95 413 log_warning_errno(errno, "Failed to watch hostname: %m");
eb60f9cd
LP
414 return 0;
415 }
416
417 r = sd_event_add_io(m->event, &m->hostname_event_source, m->hostname_fd, 0, on_hostname_change, m);
418 if (r < 0) {
419 if (r == -EPERM)
420 /* kernels prior to 3.2 don't support polling this file. Ignore the failure. */
421 m->hostname_fd = safe_close(m->hostname_fd);
8d3d7072
MS
422 else
423 return log_error_errno(r, "Failed to add hostname event source: %m");
eb60f9cd
LP
424 }
425
aa4a9deb
LP
426 (void) sd_event_source_set_description(m->hostname_event_source, "hostname");
427
78c6a153 428 r = determine_hostname(&m->llmnr_hostname, &m->mdns_hostname);
eb60f9cd
LP
429 if (r < 0) {
430 log_info("Defaulting to hostname 'linux'.");
78c6a153
LP
431 m->llmnr_hostname = strdup("linux");
432 if (!m->llmnr_hostname)
433 return log_oom();
434
435 m->mdns_hostname = strdup("linux.local");
436 if (!m->mdns_hostname)
eb60f9cd
LP
437 return log_oom();
438 } else
78c6a153 439 log_info("Using system hostname '%s'.", m->llmnr_hostname);
eb60f9cd
LP
440
441 return 0;
442}
443
4d506d6b
LP
444static int manager_sigusr1(sd_event_source *s, const struct signalfd_siginfo *si, void *userdata) {
445 _cleanup_free_ char *buffer = NULL;
446 _cleanup_fclose_ FILE *f = NULL;
447 Manager *m = userdata;
448 size_t size = 0;
449 DnsScope *scope;
450
451 assert(s);
452 assert(si);
453 assert(m);
454
455 f = open_memstream(&buffer, &size);
456 if (!f)
457 return log_oom();
458
459 LIST_FOREACH(scopes, scope, m->dns_scopes)
460 dns_scope_dump(scope, f);
461
462 if (fflush_and_check(f) < 0)
463 return log_oom();
464
465 log_dump(LOG_INFO, buffer);
466 return 0;
467}
468
bc81447e
LP
469static int manager_sigusr2(sd_event_source *s, const struct signalfd_siginfo *si, void *userdata) {
470 Manager *m = userdata;
bc81447e
LP
471
472 assert(s);
473 assert(si);
474 assert(m);
475
ba35662f 476 manager_flush_caches(m);
bc81447e 477 log_info("Flushed all caches.");
ba35662f 478
bc81447e
LP
479 return 0;
480}
481
091a364c 482int manager_new(Manager **ret) {
74b2466e 483 _cleanup_(manager_freep) Manager *m = NULL;
091a364c
TG
484 int r;
485
c92e531c
LP
486 assert(ret);
487
091a364c
TG
488 m = new0(Manager, 1);
489 if (!m)
490 return -ENOMEM;
491
1716f6dc 492 m->llmnr_ipv4_udp_fd = m->llmnr_ipv6_udp_fd = -1;
623a4c97 493 m->llmnr_ipv4_tcp_fd = m->llmnr_ipv6_tcp_fd = -1;
bc7702b0 494 m->mdns_ipv4_fd = m->mdns_ipv6_fd = -1;
eb60f9cd 495 m->hostname_fd = -1;
1716f6dc 496
af49ca27 497 m->llmnr_support = RESOLVE_SUPPORT_YES;
ad6c0475 498 m->mdns_support = RESOLVE_SUPPORT_NO;
61ecb465 499 m->dnssec_mode = DEFAULT_DNSSEC_MODE;
5cb36f41 500 m->read_resolv_conf = true;
00fa60ae 501 m->need_builtin_fallbacks = true;
dd0bc0f1 502 m->etc_hosts_last = m->etc_hosts_mtime = USEC_INFINITY;
091a364c 503
0d2cd476
LP
504 r = dns_trust_anchor_load(&m->trust_anchor);
505 if (r < 0)
506 return r;
507
ad6c0475
LP
508 r = manager_parse_config_file(m);
509 if (r < 0)
510 return r;
511
091a364c
TG
512 r = sd_event_default(&m->event);
513 if (r < 0)
514 return r;
515
516 sd_event_add_signal(m->event, NULL, SIGTERM, NULL, NULL);
517 sd_event_add_signal(m->event, NULL, SIGINT, NULL, NULL);
518
519 sd_event_set_watchdog(m->event, true);
520
eb60f9cd
LP
521 r = manager_watch_hostname(m);
522 if (r < 0)
523 return r;
524
1716f6dc 525 r = dns_scope_new(m, &m->unicast_scope, NULL, DNS_PROTOCOL_DNS, AF_UNSPEC);
74b2466e
LP
526 if (r < 0)
527 return r;
528
529 r = manager_network_monitor_listen(m);
530 if (r < 0)
531 return r;
532
533 r = manager_rtnl_listen(m);
534 if (r < 0)
535 return r;
536
537 r = manager_connect_bus(m);
538 if (r < 0)
539 return r;
540
4d506d6b 541 (void) sd_event_add_signal(m->event, &m->sigusr1_event_source, SIGUSR1, manager_sigusr1, m);
bc81447e 542 (void) sd_event_add_signal(m->event, &m->sigusr2_event_source, SIGUSR2, manager_sigusr2, m);
4d506d6b 543
091a364c
TG
544 *ret = m;
545 m = NULL;
546
547 return 0;
548}
549
edc501d4
LP
550int manager_start(Manager *m) {
551 int r;
552
553 assert(m);
554
555 r = manager_llmnr_start(m);
556 if (r < 0)
557 return r;
558
bc7702b0
DM
559 r = manager_mdns_start(m);
560 if (r < 0)
561 return r;
562
edc501d4
LP
563 return 0;
564}
565
74b2466e
LP
566Manager *manager_free(Manager *m) {
567 Link *l;
091a364c
TG
568
569 if (!m)
74b2466e
LP
570 return NULL;
571
4b95f179
LP
572 dns_server_unlink_all(m->dns_servers);
573 dns_server_unlink_all(m->fallback_dns_servers);
a51c1048
LP
574 dns_search_domain_unlink_all(m->search_domains);
575
74b2466e
LP
576 while ((l = hashmap_first(m->links)))
577 link_free(l);
f0e15467
LP
578
579 while (m->dns_queries)
580 dns_query_free(m->dns_queries);
74b2466e 581
cab5b059
LP
582 dns_scope_free(m->unicast_scope);
583
f0e15467
LP
584 hashmap_free(m->links);
585 hashmap_free(m->dns_transactions);
586
096b6773
LP
587 sd_event_source_unref(m->network_event_source);
588 sd_network_monitor_unref(m->network_monitor);
091a364c 589
a564ca2f
LP
590 sd_netlink_unref(m->rtnl);
591 sd_event_source_unref(m->rtnl_event_source);
592
edc501d4 593 manager_llmnr_stop(m);
bc7702b0 594 manager_mdns_stop(m);
623a4c97 595
902bb5d8 596 sd_bus_slot_unref(m->prepare_for_sleep_slot);
74b2466e
LP
597 sd_event_source_unref(m->bus_retry_event_source);
598 sd_bus_unref(m->bus);
091a364c 599
4d506d6b 600 sd_event_source_unref(m->sigusr1_event_source);
bc81447e 601 sd_event_source_unref(m->sigusr2_event_source);
4d506d6b 602
74b2466e 603 sd_event_unref(m->event);
623a4c97 604
78c6a153
LP
605 dns_resource_key_unref(m->llmnr_host_ipv4_key);
606 dns_resource_key_unref(m->llmnr_host_ipv6_key);
eb60f9cd 607
eb60f9cd 608 sd_event_source_unref(m->hostname_event_source);
d9fcf2ba 609 safe_close(m->hostname_fd);
78c6a153
LP
610 free(m->llmnr_hostname);
611 free(m->mdns_hostname);
eb60f9cd 612
0d2cd476 613 dns_trust_anchor_flush(&m->trust_anchor);
dd0bc0f1 614 manager_etc_hosts_flush(m);
0d2cd476 615
091a364c 616 free(m);
74b2466e
LP
617
618 return NULL;
091a364c
TG
619}
620
1716f6dc 621int manager_recv(Manager *m, int fd, DnsProtocol protocol, DnsPacket **ret) {
74b2466e 622 _cleanup_(dns_packet_unrefp) DnsPacket *p = NULL;
1716f6dc
LP
623 union {
624 struct cmsghdr header; /* For alignment */
40a1eebd 625 uint8_t buffer[CMSG_SPACE(MAXSIZE(struct in_pktinfo, struct in6_pktinfo))
1716f6dc 626 + CMSG_SPACE(int) /* ttl/hoplimit */
623a4c97 627 + EXTRA_CMSG_SPACE /* kernel appears to require extra buffer space */];
1716f6dc
LP
628 } control;
629 union sockaddr_union sa;
74b2466e 630 struct msghdr mh = {};
1716f6dc 631 struct cmsghdr *cmsg;
74b2466e 632 struct iovec iov;
4edc2c9b
LP
633 ssize_t ms, l;
634 int r;
74b2466e
LP
635
636 assert(m);
1716f6dc 637 assert(fd >= 0);
74b2466e
LP
638 assert(ret);
639
4edc2c9b 640 ms = next_datagram_size_fd(fd);
74b2466e 641 if (ms < 0)
4edc2c9b 642 return ms;
74b2466e 643
1716f6dc 644 r = dns_packet_new(&p, protocol, ms);
74b2466e
LP
645 if (r < 0)
646 return r;
647
648 iov.iov_base = DNS_PACKET_DATA(p);
649 iov.iov_len = p->allocated;
650
1716f6dc
LP
651 mh.msg_name = &sa.sa;
652 mh.msg_namelen = sizeof(sa);
74b2466e
LP
653 mh.msg_iov = &iov;
654 mh.msg_iovlen = 1;
1716f6dc
LP
655 mh.msg_control = &control;
656 mh.msg_controllen = sizeof(control);
74b2466e 657
a38d9945 658 l = recvmsg(fd, &mh, 0);
f134289a
EV
659 if (l == 0)
660 return 0;
74b2466e 661 if (l < 0) {
ad867662 662 if (errno == EAGAIN || errno == EINTR)
74b2466e
LP
663 return 0;
664
665 return -errno;
091a364c
TG
666 }
667
1716f6dc
LP
668 assert(!(mh.msg_flags & MSG_CTRUNC));
669 assert(!(mh.msg_flags & MSG_TRUNC));
670
74b2466e 671 p->size = (size_t) l;
091a364c 672
1716f6dc 673 p->family = sa.sa.sa_family;
623a4c97
LP
674 p->ipproto = IPPROTO_UDP;
675 if (p->family == AF_INET) {
1716f6dc 676 p->sender.in = sa.in.sin_addr;
623a4c97
LP
677 p->sender_port = be16toh(sa.in.sin_port);
678 } else if (p->family == AF_INET6) {
1716f6dc 679 p->sender.in6 = sa.in6.sin6_addr;
623a4c97
LP
680 p->sender_port = be16toh(sa.in6.sin6_port);
681 p->ifindex = sa.in6.sin6_scope_id;
682 } else
1716f6dc 683 return -EAFNOSUPPORT;
74b2466e 684
2a1288ff 685 CMSG_FOREACH(cmsg, &mh) {
74b2466e 686
1716f6dc
LP
687 if (cmsg->cmsg_level == IPPROTO_IPV6) {
688 assert(p->family == AF_INET6);
74b2466e 689
1716f6dc 690 switch (cmsg->cmsg_type) {
74b2466e 691
1716f6dc
LP
692 case IPV6_PKTINFO: {
693 struct in6_pktinfo *i = (struct in6_pktinfo*) CMSG_DATA(cmsg);
74b2466e 694
623a4c97
LP
695 if (p->ifindex <= 0)
696 p->ifindex = i->ipi6_ifindex;
697
1716f6dc
LP
698 p->destination.in6 = i->ipi6_addr;
699 break;
700 }
74b2466e 701
1716f6dc
LP
702 case IPV6_HOPLIMIT:
703 p->ttl = *(int *) CMSG_DATA(cmsg);
704 break;
74b2466e 705
1716f6dc
LP
706 }
707 } else if (cmsg->cmsg_level == IPPROTO_IP) {
708 assert(p->family == AF_INET);
74b2466e 709
1716f6dc 710 switch (cmsg->cmsg_type) {
74b2466e 711
1716f6dc
LP
712 case IP_PKTINFO: {
713 struct in_pktinfo *i = (struct in_pktinfo*) CMSG_DATA(cmsg);
091a364c 714
623a4c97
LP
715 if (p->ifindex <= 0)
716 p->ifindex = i->ipi_ifindex;
717
1716f6dc
LP
718 p->destination.in = i->ipi_addr;
719 break;
720 }
74b2466e 721
623a4c97 722 case IP_TTL:
1716f6dc
LP
723 p->ttl = *(int *) CMSG_DATA(cmsg);
724 break;
725 }
726 }
727 }
74b2466e 728
623a4c97
LP
729 /* The Linux kernel sets the interface index to the loopback
730 * device if the packet came from the local host since it
731 * avoids the routing table in such a case. Let's unset the
732 * interface index in such a case. */
a5f03596 733 if (p->ifindex == LOOPBACK_IFINDEX)
623a4c97
LP
734 p->ifindex = 0;
735
86ad4cd7
TG
736 if (protocol != DNS_PROTOCOL_DNS) {
737 /* If we don't know the interface index still, we look for the
738 * first local interface with a matching address. Yuck! */
739 if (p->ifindex <= 0)
740 p->ifindex = manager_find_ifindex(m, p->family, &p->destination);
741 }
623a4c97 742
74b2466e
LP
743 *ret = p;
744 p = NULL;
745
746 return 1;
747}
748
74b2466e
LP
749static int sendmsg_loop(int fd, struct msghdr *mh, int flags) {
750 int r;
751
752 assert(fd >= 0);
753 assert(mh);
754
755 for (;;) {
756 if (sendmsg(fd, mh, flags) >= 0)
757 return 0;
758
759 if (errno == EINTR)
760 continue;
761
762 if (errno != EAGAIN)
763 return -errno;
764
765 r = fd_wait_for_event(fd, POLLOUT, SEND_TIMEOUT_USEC);
766 if (r < 0)
767 return r;
768 if (r == 0)
769 return -ETIMEDOUT;
770 }
771}
772
72290734
TG
773static int write_loop(int fd, void *message, size_t length) {
774 int r;
775
776 assert(fd >= 0);
777 assert(message);
778
779 for (;;) {
780 if (write(fd, message, length) >= 0)
781 return 0;
782
783 if (errno == EINTR)
784 continue;
785
786 if (errno != EAGAIN)
787 return -errno;
788
789 r = fd_wait_for_event(fd, POLLOUT, SEND_TIMEOUT_USEC);
790 if (r < 0)
791 return r;
792 if (r == 0)
793 return -ETIMEDOUT;
794 }
795}
796
797int manager_write(Manager *m, int fd, DnsPacket *p) {
798 int r;
799
deb3f3d3 800 log_debug("Sending %s packet with id %" PRIu16 ".", DNS_PACKET_QR(p) ? "response" : "query", DNS_PACKET_ID(p));
72290734
TG
801
802 r = write_loop(fd, DNS_PACKET_DATA(p), p->size);
803 if (r < 0)
804 return r;
805
806 return 0;
807}
808
623a4c97 809static int manager_ipv4_send(Manager *m, int fd, int ifindex, const struct in_addr *addr, uint16_t port, DnsPacket *p) {
74b2466e
LP
810 union sockaddr_union sa = {
811 .in.sin_family = AF_INET,
74b2466e 812 };
1716f6dc
LP
813 union {
814 struct cmsghdr header; /* For alignment */
815 uint8_t buffer[CMSG_SPACE(sizeof(struct in_pktinfo))];
816 } control;
74b2466e
LP
817 struct msghdr mh = {};
818 struct iovec iov;
74b2466e
LP
819
820 assert(m);
1716f6dc
LP
821 assert(fd >= 0);
822 assert(addr);
823 assert(port > 0);
74b2466e
LP
824 assert(p);
825
74b2466e
LP
826 iov.iov_base = DNS_PACKET_DATA(p);
827 iov.iov_len = p->size;
091a364c 828
1716f6dc
LP
829 sa.in.sin_addr = *addr;
830 sa.in.sin_port = htobe16(port),
091a364c 831
74b2466e
LP
832 mh.msg_iov = &iov;
833 mh.msg_iovlen = 1;
834 mh.msg_name = &sa.sa;
835 mh.msg_namelen = sizeof(sa.in);
091a364c 836
74b2466e
LP
837 if (ifindex > 0) {
838 struct cmsghdr *cmsg;
839 struct in_pktinfo *pi;
840
841 zero(control);
842
1716f6dc 843 mh.msg_control = &control;
74b2466e
LP
844 mh.msg_controllen = CMSG_LEN(sizeof(struct in_pktinfo));
845
846 cmsg = CMSG_FIRSTHDR(&mh);
847 cmsg->cmsg_len = mh.msg_controllen;
848 cmsg->cmsg_level = IPPROTO_IP;
849 cmsg->cmsg_type = IP_PKTINFO;
850
851 pi = (struct in_pktinfo*) CMSG_DATA(cmsg);
852 pi->ipi_ifindex = ifindex;
853 }
854
855 return sendmsg_loop(fd, &mh, 0);
856}
857
623a4c97 858static int manager_ipv6_send(Manager *m, int fd, int ifindex, const struct in6_addr *addr, uint16_t port, DnsPacket *p) {
74b2466e
LP
859 union sockaddr_union sa = {
860 .in6.sin6_family = AF_INET6,
74b2466e 861 };
1716f6dc
LP
862 union {
863 struct cmsghdr header; /* For alignment */
864 uint8_t buffer[CMSG_SPACE(sizeof(struct in6_pktinfo))];
865 } control;
74b2466e
LP
866 struct msghdr mh = {};
867 struct iovec iov;
74b2466e
LP
868
869 assert(m);
1716f6dc
LP
870 assert(fd >= 0);
871 assert(addr);
872 assert(port > 0);
74b2466e
LP
873 assert(p);
874
74b2466e
LP
875 iov.iov_base = DNS_PACKET_DATA(p);
876 iov.iov_len = p->size;
877
1716f6dc
LP
878 sa.in6.sin6_addr = *addr;
879 sa.in6.sin6_port = htobe16(port),
74b2466e
LP
880 sa.in6.sin6_scope_id = ifindex;
881
882 mh.msg_iov = &iov;
883 mh.msg_iovlen = 1;
884 mh.msg_name = &sa.sa;
885 mh.msg_namelen = sizeof(sa.in6);
886
887 if (ifindex > 0) {
888 struct cmsghdr *cmsg;
889 struct in6_pktinfo *pi;
890
891 zero(control);
892
1716f6dc 893 mh.msg_control = &control;
74b2466e
LP
894 mh.msg_controllen = CMSG_LEN(sizeof(struct in6_pktinfo));
895
896 cmsg = CMSG_FIRSTHDR(&mh);
897 cmsg->cmsg_len = mh.msg_controllen;
898 cmsg->cmsg_level = IPPROTO_IPV6;
899 cmsg->cmsg_type = IPV6_PKTINFO;
900
901 pi = (struct in6_pktinfo*) CMSG_DATA(cmsg);
902 pi->ipi6_ifindex = ifindex;
903 }
904
905 return sendmsg_loop(fd, &mh, 0);
906}
907
623a4c97 908int manager_send(Manager *m, int fd, int ifindex, int family, const union in_addr_union *addr, uint16_t port, DnsPacket *p) {
1716f6dc
LP
909 assert(m);
910 assert(fd >= 0);
911 assert(addr);
912 assert(port > 0);
913 assert(p);
914
deb3f3d3 915 log_debug("Sending %s packet with id %" PRIu16 " on interface %i/%s.", DNS_PACKET_QR(p) ? "response" : "query", DNS_PACKET_ID(p), ifindex, af_to_name(family));
a2a416f7 916
1716f6dc
LP
917 if (family == AF_INET)
918 return manager_ipv4_send(m, fd, ifindex, &addr->in, port, p);
2817157b 919 if (family == AF_INET6)
1716f6dc
LP
920 return manager_ipv6_send(m, fd, ifindex, &addr->in6, port, p);
921
922 return -EAFNOSUPPORT;
923}
924
e1c95994
LP
925uint32_t manager_find_mtu(Manager *m) {
926 uint32_t mtu = 0;
927 Link *l;
928 Iterator i;
929
930 /* If we don't know on which link a DNS packet would be
931 * delivered, let's find the largest MTU that works on all
932 * interfaces we know of */
933
934 HASHMAP_FOREACH(l, m->links, i) {
935 if (l->mtu <= 0)
936 continue;
937
938 if (mtu <= 0 || l->mtu < mtu)
939 mtu = l->mtu;
940 }
941
942 return mtu;
943}
1716f6dc 944
623a4c97 945int manager_find_ifindex(Manager *m, int family, const union in_addr_union *in_addr) {
ec2c5e43
LP
946 LinkAddress *a;
947
948 assert(m);
949
4e945a6f 950 a = manager_find_link_address(m, family, in_addr);
ec2c5e43
LP
951 if (a)
952 return a->link->ifindex;
953
954 return 0;
955}
956
eb60f9cd
LP
957void manager_refresh_rrs(Manager *m) {
958 Iterator i;
959 Link *l;
960
961 assert(m);
962
78c6a153
LP
963 m->llmnr_host_ipv4_key = dns_resource_key_unref(m->llmnr_host_ipv4_key);
964 m->llmnr_host_ipv6_key = dns_resource_key_unref(m->llmnr_host_ipv6_key);
eb60f9cd
LP
965
966 HASHMAP_FOREACH(l, m->links, i) {
967 link_add_rrs(l, true);
968 link_add_rrs(l, false);
969 }
970}
971
ec2c5e43
LP
972int manager_next_hostname(Manager *m) {
973 const char *p;
556a2294 974 uint64_t u, a;
78c6a153
LP
975 char *h, *k;
976 int r;
623a4c97
LP
977
978 assert(m);
979
78c6a153 980 p = strchr(m->llmnr_hostname, 0);
ec2c5e43
LP
981 assert(p);
982
78c6a153 983 while (p > m->llmnr_hostname) {
ec2c5e43
LP
984 if (!strchr("0123456789", p[-1]))
985 break;
986
987 p--;
988 }
989
990 if (*p == 0 || safe_atou64(p, &u) < 0 || u <= 0)
991 u = 1;
992
556a2294
LP
993 /* Add a random number to the old value. This way we can avoid
994 * that two hosts pick the same hostname, win on IPv4 and lose
995 * on IPv6 (or vice versa), and pick the same hostname
996 * replacement hostname, ad infinitum. We still want the
997 * numbers to go up monotonically, hence we just add a random
998 * value 1..10 */
999
1000 random_bytes(&a, sizeof(a));
1001 u += 1 + a % 10;
ec2c5e43 1002
78c6a153 1003 if (asprintf(&h, "%.*s%" PRIu64, (int) (p - m->llmnr_hostname), m->llmnr_hostname, u) < 0)
ec2c5e43
LP
1004 return -ENOMEM;
1005
78c6a153
LP
1006 r = dns_name_concat(h, "local", &k);
1007 if (r < 0) {
1008 free(h);
1009 return r;
1010 }
1011
1012 log_info("Hostname conflict, changing published hostname from '%s' to '%s'.", m->llmnr_hostname, h);
1013
1014 free(m->llmnr_hostname);
1015 m->llmnr_hostname = h;
ec2c5e43 1016
78c6a153
LP
1017 free(m->mdns_hostname);
1018 m->mdns_hostname = k;
ec2c5e43 1019
eb60f9cd 1020 manager_refresh_rrs(m);
623a4c97
LP
1021
1022 return 0;
1023}
ec2c5e43 1024
4e945a6f 1025LinkAddress* manager_find_link_address(Manager *m, int family, const union in_addr_union *in_addr) {
ec2c5e43
LP
1026 Iterator i;
1027 Link *l;
1028
1029 assert(m);
1030
1031 HASHMAP_FOREACH(l, m->links, i) {
1032 LinkAddress *a;
1033
1034 a = link_find_address(l, family, in_addr);
1035 if (a)
1036 return a;
1037 }
1038
1039 return NULL;
1040}
1041
a4076574 1042bool manager_our_packet(Manager *m, DnsPacket *p) {
ec2c5e43
LP
1043 assert(m);
1044 assert(p);
1045
4e945a6f 1046 return !!manager_find_link_address(m, p->family, &p->sender);
ec2c5e43 1047}
4e945a6f 1048
a4076574
LP
1049DnsScope* manager_find_scope(Manager *m, DnsPacket *p) {
1050 Link *l;
1051
1052 assert(m);
1053 assert(p);
1054
1055 l = hashmap_get(m->links, INT_TO_PTR(p->ifindex));
1056 if (!l)
1057 return NULL;
1058
b4f1862d
DM
1059 switch (p->protocol) {
1060 case DNS_PROTOCOL_LLMNR:
a4076574
LP
1061 if (p->family == AF_INET)
1062 return l->llmnr_ipv4_scope;
1063 else if (p->family == AF_INET6)
1064 return l->llmnr_ipv6_scope;
b4f1862d
DM
1065
1066 break;
1067
1068 case DNS_PROTOCOL_MDNS:
1069 if (p->family == AF_INET)
1070 return l->mdns_ipv4_scope;
1071 else if (p->family == AF_INET6)
1072 return l->mdns_ipv6_scope;
1073
1074 break;
1075
1076 default:
1077 break;
a4076574
LP
1078 }
1079
1080 return NULL;
1081}
1082
902bb5d8
LP
1083void manager_verify_all(Manager *m) {
1084 DnsScope *s;
1085
1086 assert(m);
1087
1088 LIST_FOREACH(scopes, s, m->dns_scopes)
1089 dns_zone_verify_all(&s->zone);
1090}
1091
78c6a153 1092int manager_is_own_hostname(Manager *m, const char *name) {
78c6a153
LP
1093 int r;
1094
1095 assert(m);
1096 assert(name);
1097
1098 if (m->llmnr_hostname) {
1099 r = dns_name_equal(name, m->llmnr_hostname);
1100 if (r != 0)
1101 return r;
1102 }
1103
1104 if (m->mdns_hostname)
1105 return dns_name_equal(name, m->mdns_hostname);
1106
1107 return 0;
1108}
1109
9176a57c
LP
1110int manager_compile_dns_servers(Manager *m, OrderedSet **dns) {
1111 DnsServer *s;
1112 Iterator i;
1113 Link *l;
1114 int r;
1115
1116 assert(m);
1117 assert(dns);
1118
1119 r = ordered_set_ensure_allocated(dns, &dns_server_hash_ops);
1120 if (r < 0)
1121 return r;
1122
1123 /* First add the system-wide servers and domains */
1124 LIST_FOREACH(servers, s, m->dns_servers) {
1125 r = ordered_set_put(*dns, s);
1126 if (r == -EEXIST)
1127 continue;
1128 if (r < 0)
1129 return r;
1130 }
1131
1132 /* Then, add the per-link servers */
1133 HASHMAP_FOREACH(l, m->links, i) {
1134 LIST_FOREACH(servers, s, l->dns_servers) {
1135 r = ordered_set_put(*dns, s);
1136 if (r == -EEXIST)
1137 continue;
1138 if (r < 0)
1139 return r;
1140 }
1141 }
1142
1143 /* If we found nothing, add the fallback servers */
1144 if (ordered_set_isempty(*dns)) {
1145 LIST_FOREACH(servers, s, m->fallback_dns_servers) {
1146 r = ordered_set_put(*dns, s);
1147 if (r == -EEXIST)
1148 continue;
1149 if (r < 0)
1150 return r;
1151 }
1152 }
1153
1154 return 0;
1155}
1156
1157int manager_compile_search_domains(Manager *m, OrderedSet **domains) {
1158 DnsSearchDomain *d;
1159 Iterator i;
1160 Link *l;
1161 int r;
1162
1163 assert(m);
1164 assert(domains);
1165
1166 r = ordered_set_ensure_allocated(domains, &dns_name_hash_ops);
1167 if (r < 0)
1168 return r;
1169
1170 LIST_FOREACH(domains, d, m->search_domains) {
1171 r = ordered_set_put(*domains, d->name);
1172 if (r == -EEXIST)
1173 continue;
1174 if (r < 0)
1175 return r;
1176 }
1177
1178 HASHMAP_FOREACH(l, m->links, i) {
1179
1180 LIST_FOREACH(domains, d, l->search_domains) {
1181 r = ordered_set_put(*domains, d->name);
1182 if (r == -EEXIST)
1183 continue;
1184 if (r < 0)
1185 return r;
1186 }
1187 }
1188
1189 return 0;
1190}
c69fa7e3
LP
1191
1192DnssecMode manager_get_dnssec_mode(Manager *m) {
1193 assert(m);
1194
1195 if (m->dnssec_mode != _DNSSEC_MODE_INVALID)
1196 return m->dnssec_mode;
1197
1198 return DNSSEC_NO;
1199}
1200
1201bool manager_dnssec_supported(Manager *m) {
1202 DnsServer *server;
1203 Iterator i;
1204 Link *l;
1205
1206 assert(m);
1207
1208 if (manager_get_dnssec_mode(m) == DNSSEC_NO)
1209 return false;
1210
1211 server = manager_get_dns_server(m);
1212 if (server && !dns_server_dnssec_supported(server))
1213 return false;
1214
1215 HASHMAP_FOREACH(l, m->links, i)
1216 if (!link_dnssec_supported(l))
1217 return false;
1218
1219 return true;
1220}
59c5b597
LP
1221
1222void manager_dnssec_verdict(Manager *m, DnssecVerdict verdict, const DnsResourceKey *key) {
1223
1224 assert(verdict >= 0);
1225 assert(verdict < _DNSSEC_VERDICT_MAX);
1226
1227 if (log_get_max_level() >= LOG_DEBUG) {
202b76ae 1228 char s[DNS_RESOURCE_KEY_STRING_MAX];
59c5b597 1229
202b76ae
ZJS
1230 log_debug("Found verdict for lookup %s: %s",
1231 dns_resource_key_to_string(key, s, sizeof s),
1232 dnssec_verdict_to_string(verdict));
59c5b597
LP
1233 }
1234
1235 m->n_dnssec_verdict[verdict]++;
1236}
011696f7
LP
1237
1238bool manager_routable(Manager *m, int family) {
1239 Iterator i;
1240 Link *l;
1241
1242 assert(m);
1243
1244 /* Returns true if the host has at least one interface with a routable address of the specified type */
1245
1246 HASHMAP_FOREACH(l, m->links, i)
1247 if (link_relevant(l, family, false))
1248 return true;
1249
1250 return false;
1251}
ba35662f
LP
1252
1253void manager_flush_caches(Manager *m) {
1254 DnsScope *scope;
1255
1256 assert(m);
1257
1258 LIST_FOREACH(scopes, scope, m->dns_scopes)
1259 dns_cache_flush(&scope->cache);
1260}