]> git.ipfire.org Git - thirdparty/systemd.git/blame - src/resolve/resolved-dns-transaction.c
resolved: fallback to TCP if UDP fails
[thirdparty/systemd.git] / src / resolve / resolved-dns-transaction.c
CommitLineData
ec2c5e43
LP
1/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
2
3/***
4 This file is part of systemd.
5
6 Copyright 2014 Lennart Poettering
7
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU Lesser General Public License as published by
10 the Free Software Foundation; either version 2.1 of the License, or
11 (at your option) any later version.
12
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 Lesser General Public License for more details.
17
18 You should have received a copy of the GNU Lesser General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
20***/
21
22#include "af-list.h"
b5efdb8a 23#include "alloc-util.h"
f52e61da 24#include "dns-domain.h"
3ffd4af2
LP
25#include "fd-util.h"
26#include "random-util.h"
27#include "resolved-dns-transaction.h"
28#include "resolved-llmnr.h"
8b43440b 29#include "string-table.h"
ec2c5e43
LP
30
31DnsTransaction* dns_transaction_free(DnsTransaction *t) {
801ad6a6 32 DnsQueryCandidate *c;
ec2c5e43
LP
33 DnsZoneItem *i;
34
35 if (!t)
36 return NULL;
37
38 sd_event_source_unref(t->timeout_event_source);
39
ec2c5e43
LP
40 dns_packet_unref(t->sent);
41 dns_packet_unref(t->received);
ae6a4bbf
LP
42
43 dns_answer_unref(t->answer);
ec2c5e43 44
4667e00a
LP
45 sd_event_source_unref(t->dns_udp_event_source);
46 safe_close(t->dns_udp_fd);
d20b1667 47
8300ba21 48 dns_server_unref(t->server);
ec2c5e43
LP
49 dns_stream_free(t->stream);
50
51 if (t->scope) {
f9ebb22a
LP
52 hashmap_remove_value(t->scope->transactions_by_key, t->key, t);
53 LIST_REMOVE(transactions_by_scope, t->scope->transactions, t);
ec2c5e43
LP
54
55 if (t->id != 0)
56 hashmap_remove(t->scope->manager->dns_transactions, UINT_TO_PTR(t->id));
57 }
58
da0c630e
LP
59 dns_resource_key_unref(t->key);
60
801ad6a6
LP
61 while ((c = set_steal_first(t->query_candidates)))
62 set_remove(c->transactions, t);
63
64 set_free(t->query_candidates);
ec2c5e43
LP
65
66 while ((i = set_steal_first(t->zone_items)))
67 i->probe_transaction = NULL;
68 set_free(t->zone_items);
69
70 free(t);
71 return NULL;
72}
73
74DEFINE_TRIVIAL_CLEANUP_FUNC(DnsTransaction*, dns_transaction_free);
75
76void dns_transaction_gc(DnsTransaction *t) {
77 assert(t);
78
79 if (t->block_gc > 0)
80 return;
81
801ad6a6 82 if (set_isempty(t->query_candidates) && set_isempty(t->zone_items))
ec2c5e43
LP
83 dns_transaction_free(t);
84}
85
f52e61da 86int dns_transaction_new(DnsTransaction **ret, DnsScope *s, DnsResourceKey *key) {
ec2c5e43
LP
87 _cleanup_(dns_transaction_freep) DnsTransaction *t = NULL;
88 int r;
89
90 assert(ret);
91 assert(s);
f52e61da 92 assert(key);
ec2c5e43 93
d5099efc 94 r = hashmap_ensure_allocated(&s->manager->dns_transactions, NULL);
ec2c5e43
LP
95 if (r < 0)
96 return r;
97
f9ebb22a 98 r = hashmap_ensure_allocated(&s->transactions_by_key, &dns_resource_key_hash_ops);
da0c630e
LP
99 if (r < 0)
100 return r;
101
ec2c5e43
LP
102 t = new0(DnsTransaction, 1);
103 if (!t)
104 return -ENOMEM;
105
4667e00a 106 t->dns_udp_fd = -1;
c3bc53e6 107 t->answer_source = _DNS_TRANSACTION_SOURCE_INVALID;
f52e61da 108 t->key = dns_resource_key_ref(key);
ec2c5e43 109
da0c630e 110 /* Find a fresh, unused transaction id */
ec2c5e43
LP
111 do
112 random_bytes(&t->id, sizeof(t->id));
113 while (t->id == 0 ||
114 hashmap_get(s->manager->dns_transactions, UINT_TO_PTR(t->id)));
115
116 r = hashmap_put(s->manager->dns_transactions, UINT_TO_PTR(t->id), t);
117 if (r < 0) {
118 t->id = 0;
119 return r;
120 }
121
f9ebb22a 122 r = hashmap_replace(s->transactions_by_key, t->key, t);
da0c630e
LP
123 if (r < 0) {
124 hashmap_remove(s->manager->dns_transactions, UINT_TO_PTR(t->id));
125 return r;
126 }
127
f9ebb22a 128 LIST_PREPEND(transactions_by_scope, s->transactions, t);
ec2c5e43
LP
129 t->scope = s;
130
131 if (ret)
132 *ret = t;
133
134 t = NULL;
135
136 return 0;
137}
138
139static void dns_transaction_stop(DnsTransaction *t) {
140 assert(t);
141
142 t->timeout_event_source = sd_event_source_unref(t->timeout_event_source);
143 t->stream = dns_stream_free(t->stream);
ae6a4bbf
LP
144
145 /* Note that we do not drop the UDP socket here, as we want to
146 * reuse it to repeat the interaction. */
ec2c5e43
LP
147}
148
149static void dns_transaction_tentative(DnsTransaction *t, DnsPacket *p) {
2fb3034c 150 _cleanup_free_ char *pretty = NULL;
ec2c5e43 151 DnsZoneItem *z;
ec2c5e43
LP
152
153 assert(t);
154 assert(p);
155
156 if (manager_our_packet(t->scope->manager, p) != 0)
157 return;
158
2fb3034c
LP
159 in_addr_to_string(p->family, &p->sender, &pretty);
160
161 log_debug("Transaction on scope %s on %s/%s got tentative packet from %s",
ec2c5e43
LP
162 dns_protocol_to_string(t->scope->protocol),
163 t->scope->link ? t->scope->link->name : "*",
2fb3034c
LP
164 t->scope->family == AF_UNSPEC ? "*" : af_to_name(t->scope->family),
165 pretty);
ec2c5e43 166
a4076574
LP
167 /* RFC 4795, Section 4.1 says that the peer with the
168 * lexicographically smaller IP address loses */
4d91eec4
LP
169 if (memcmp(&p->sender, &p->destination, FAMILY_ADDRESS_SIZE(p->family)) >= 0) {
170 log_debug("Peer has lexicographically larger IP address and thus lost in the conflict.");
a4076574
LP
171 return;
172 }
173
4d91eec4 174 log_debug("We have the lexicographically larger IP address and thus lost in the conflict.");
a4076574 175
ec2c5e43 176 t->block_gc++;
3ef64445
LP
177 while ((z = set_first(t->zone_items))) {
178 /* First, make sure the zone item drops the reference
179 * to us */
180 dns_zone_item_probe_stop(z);
181
182 /* Secondly, report this as conflict, so that we might
183 * look for a different hostname */
ec2c5e43 184 dns_zone_item_conflict(z);
3ef64445 185 }
ec2c5e43
LP
186 t->block_gc--;
187
188 dns_transaction_gc(t);
189}
190
191void dns_transaction_complete(DnsTransaction *t, DnsTransactionState state) {
801ad6a6 192 DnsQueryCandidate *c;
ec2c5e43
LP
193 DnsZoneItem *z;
194 Iterator i;
195
196 assert(t);
197 assert(!IN_SET(state, DNS_TRANSACTION_NULL, DNS_TRANSACTION_PENDING));
e56187ca 198
ec2c5e43
LP
199 /* Note that this call might invalidate the query. Callers
200 * should hence not attempt to access the query or transaction
201 * after calling this function. */
202
c3bc53e6 203 log_debug("Transaction on scope %s on %s/%s now complete with <%s> from %s",
ec2c5e43
LP
204 dns_protocol_to_string(t->scope->protocol),
205 t->scope->link ? t->scope->link->name : "*",
206 t->scope->family == AF_UNSPEC ? "*" : af_to_name(t->scope->family),
c3bc53e6
LP
207 dns_transaction_state_to_string(state),
208 t->answer_source < 0 ? "none" : dns_transaction_source_to_string(t->answer_source));
ec2c5e43
LP
209
210 t->state = state;
211
212 dns_transaction_stop(t);
213
214 /* Notify all queries that are interested, but make sure the
215 * transaction isn't freed while we are still looking at it */
216 t->block_gc++;
801ad6a6
LP
217 SET_FOREACH(c, t->query_candidates, i)
218 dns_query_candidate_ready(c);
ec2c5e43
LP
219 SET_FOREACH(z, t->zone_items, i)
220 dns_zone_item_ready(z);
221 t->block_gc--;
222
223 dns_transaction_gc(t);
224}
225
226static int on_stream_complete(DnsStream *s, int error) {
227 _cleanup_(dns_packet_unrefp) DnsPacket *p = NULL;
228 DnsTransaction *t;
229
230 assert(s);
231 assert(s->transaction);
232
233 /* Copy the data we care about out of the stream before we
234 * destroy it. */
235 t = s->transaction;
236 p = dns_packet_ref(s->read_packet);
237
238 t->stream = dns_stream_free(t->stream);
239
240 if (error != 0) {
241 dns_transaction_complete(t, DNS_TRANSACTION_RESOURCES);
242 return 0;
243 }
244
a4076574
LP
245 if (dns_packet_validate_reply(p) <= 0) {
246 log_debug("Invalid LLMNR TCP packet.");
247 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
248 return 0;
249 }
250
251 dns_scope_check_conflicts(t->scope, p);
252
ec2c5e43
LP
253 t->block_gc++;
254 dns_transaction_process_reply(t, p);
255 t->block_gc--;
256
257 /* If the response wasn't useful, then complete the transition now */
258 if (t->state == DNS_TRANSACTION_PENDING)
259 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
260
261 return 0;
262}
263
264static int dns_transaction_open_tcp(DnsTransaction *t) {
088480fa 265 DnsServer *server = NULL;
ec2c5e43
LP
266 _cleanup_close_ int fd = -1;
267 int r;
268
269 assert(t);
270
271 if (t->stream)
272 return 0;
273
106784eb
DM
274 switch (t->scope->protocol) {
275 case DNS_PROTOCOL_DNS:
8300ba21 276 fd = dns_scope_tcp_socket(t->scope, AF_UNSPEC, NULL, 53, &server);
106784eb 277 break;
ec2c5e43 278
106784eb 279 case DNS_PROTOCOL_LLMNR:
a8f6397f 280 /* When we already received a reply to this (but it was truncated), send to its sender address */
ec2c5e43 281 if (t->received)
8300ba21 282 fd = dns_scope_tcp_socket(t->scope, t->received->family, &t->received->sender, t->received->sender_port, NULL);
ec2c5e43
LP
283 else {
284 union in_addr_union address;
a7f7d1bd 285 int family = AF_UNSPEC;
ec2c5e43
LP
286
287 /* Otherwise, try to talk to the owner of a
288 * the IP address, in case this is a reverse
289 * PTR lookup */
f52e61da
LP
290
291 r = dns_name_address(DNS_RESOURCE_KEY_NAME(t->key), &family, &address);
ec2c5e43
LP
292 if (r < 0)
293 return r;
294 if (r == 0)
295 return -EINVAL;
9e08a6e0 296 if (family != t->scope->family)
9318cdd3 297 return -ESRCH;
ec2c5e43 298
8300ba21 299 fd = dns_scope_tcp_socket(t->scope, family, &address, LLMNR_PORT, NULL);
ec2c5e43 300 }
106784eb
DM
301
302 break;
303
304 default:
ec2c5e43 305 return -EAFNOSUPPORT;
106784eb 306 }
ec2c5e43
LP
307
308 if (fd < 0)
309 return fd;
310
311 r = dns_stream_new(t->scope->manager, &t->stream, t->scope->protocol, fd);
312 if (r < 0)
313 return r;
314
315 fd = -1;
316
317 r = dns_stream_write_packet(t->stream, t->sent);
318 if (r < 0) {
319 t->stream = dns_stream_free(t->stream);
320 return r;
321 }
322
8300ba21
TG
323 dns_server_unref(t->server);
324 t->server = dns_server_ref(server);
ec2c5e43 325 t->received = dns_packet_unref(t->received);
ae6a4bbf
LP
326 t->answer = dns_answer_unref(t->answer);
327 t->answer_rcode = 0;
ec2c5e43
LP
328 t->stream->complete = on_stream_complete;
329 t->stream->transaction = t;
330
331 /* The interface index is difficult to determine if we are
332 * connecting to the local host, hence fill this in right away
333 * instead of determining it from the socket */
334 if (t->scope->link)
335 t->stream->ifindex = t->scope->link->ifindex;
336
337 return 0;
338}
339
647f6aa8
TG
340static void dns_transaction_next_dns_server(DnsTransaction *t) {
341 assert(t);
342
343 t->server = dns_server_unref(t->server);
4667e00a
LP
344 t->dns_udp_event_source = sd_event_source_unref(t->dns_udp_event_source);
345 t->dns_udp_fd = safe_close(t->dns_udp_fd);
647f6aa8
TG
346
347 dns_scope_next_dns_server(t->scope);
348}
349
ec2c5e43 350void dns_transaction_process_reply(DnsTransaction *t, DnsPacket *p) {
9df3ba6c 351 usec_t ts;
ec2c5e43
LP
352 int r;
353
354 assert(t);
355 assert(p);
356 assert(t->state == DNS_TRANSACTION_PENDING);
9df3ba6c
TG
357 assert(t->scope);
358 assert(t->scope->manager);
ec2c5e43
LP
359
360 /* Note that this call might invalidate the query. Callers
361 * should hence not attempt to access the query or transaction
362 * after calling this function. */
363
106784eb
DM
364 switch (t->scope->protocol) {
365 case DNS_PROTOCOL_LLMNR:
ec2c5e43
LP
366 assert(t->scope->link);
367
368 /* For LLMNR we will not accept any packets from other
369 * interfaces */
370
371 if (p->ifindex != t->scope->link->ifindex)
372 return;
373
374 if (p->family != t->scope->family)
375 return;
376
377 /* Tentative packets are not full responses but still
378 * useful for identifying uniqueness conflicts during
379 * probing. */
8b757a38 380 if (DNS_PACKET_LLMNR_T(p)) {
ec2c5e43
LP
381 dns_transaction_tentative(t, p);
382 return;
383 }
106784eb
DM
384
385 break;
386
387 case DNS_PROTOCOL_DNS:
388 break;
389
390 default:
9c56a6f3 391 assert_not_reached("Invalid DNS protocol.");
ec2c5e43
LP
392 }
393
ec2c5e43
LP
394 if (t->received != p) {
395 dns_packet_unref(t->received);
396 t->received = dns_packet_ref(p);
397 }
398
c3bc53e6
LP
399 t->answer_source = DNS_TRANSACTION_NETWORK;
400
ec2c5e43
LP
401 if (p->ipproto == IPPROTO_TCP) {
402 if (DNS_PACKET_TC(p)) {
403 /* Truncated via TCP? Somebody must be fucking with us */
404 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
405 return;
406 }
407
408 if (DNS_PACKET_ID(p) != t->id) {
409 /* Not the reply to our query? Somebody must be fucking with us */
410 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
411 return;
412 }
413 }
414
38a03f06 415 assert_se(sd_event_now(t->scope->manager->event, clock_boottime_or_monotonic(), &ts) >= 0);
9df3ba6c
TG
416
417 switch (t->scope->protocol) {
418 case DNS_PROTOCOL_DNS:
419 assert(t->server);
420
be808ea0 421 dns_server_packet_received(t->server, t->current_features, ts - t->start_usec);
9df3ba6c
TG
422
423 break;
424 case DNS_PROTOCOL_LLMNR:
425 case DNS_PROTOCOL_MDNS:
426 dns_scope_packet_received(t->scope, ts - t->start_usec);
427
428 break;
429 default:
9c56a6f3 430 break;
9df3ba6c
TG
431 }
432
ec2c5e43
LP
433 if (DNS_PACKET_TC(p)) {
434 /* Response was truncated, let's try again with good old TCP */
435 r = dns_transaction_open_tcp(t);
436 if (r == -ESRCH) {
437 /* No servers found? Damn! */
438 dns_transaction_complete(t, DNS_TRANSACTION_NO_SERVERS);
439 return;
440 }
441 if (r < 0) {
442 /* On LLMNR, if we cannot connect to the host,
443 * we immediately give up */
444 if (t->scope->protocol == DNS_PROTOCOL_LLMNR) {
445 dns_transaction_complete(t, DNS_TRANSACTION_RESOURCES);
446 return;
447 }
448
449 /* On DNS, couldn't send? Try immediately again, with a new server */
647f6aa8 450 dns_transaction_next_dns_server(t);
ec2c5e43
LP
451
452 r = dns_transaction_go(t);
453 if (r < 0) {
454 dns_transaction_complete(t, DNS_TRANSACTION_RESOURCES);
455 return;
456 }
457
458 return;
459 }
460 }
461
462 /* Parse and update the cache */
463 r = dns_packet_extract(p);
464 if (r < 0) {
465 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
466 return;
467 }
468
ae6a4bbf
LP
469 /* Install the answer as answer to the transaction */
470 dns_answer_unref(t->answer);
471 t->answer = dns_answer_ref(p->answer);
472 t->answer_rcode = DNS_PACKET_RCODE(p);
473
29815b6c 474 /* Only consider responses with equivalent query section to the request */
f52e61da 475 if (p->question->n_keys != 1 || dns_resource_key_equal(p->question->keys[0], t->key) <= 0) {
29815b6c 476 dns_transaction_complete(t, DNS_TRANSACTION_INVALID_REPLY);
6709eb94
TG
477 return;
478 }
29815b6c 479
ec2c5e43 480 /* According to RFC 4795, section 2.9. only the RRs from the answer section shall be cached */
d830ebbd
LP
481 if (DNS_PACKET_SHALL_CACHE(p))
482 dns_cache_put(&t->scope->cache, t->key, DNS_PACKET_RCODE(p), p->answer, DNS_PACKET_ANCOUNT(p), 0, p->family, &p->sender);
ec2c5e43
LP
483
484 if (DNS_PACKET_RCODE(p) == DNS_RCODE_SUCCESS)
485 dns_transaction_complete(t, DNS_TRANSACTION_SUCCESS);
486 else
487 dns_transaction_complete(t, DNS_TRANSACTION_FAILURE);
488}
489
c19ffd9f
TG
490static int on_dns_packet(sd_event_source *s, int fd, uint32_t revents, void *userdata) {
491 _cleanup_(dns_packet_unrefp) DnsPacket *p = NULL;
492 DnsTransaction *t = userdata;
493 int r;
494
495 assert(t);
496 assert(t->scope);
497
498 r = manager_recv(t->scope->manager, fd, DNS_PROTOCOL_DNS, &p);
499 if (r <= 0)
500 return r;
501
502 if (dns_packet_validate_reply(p) > 0 &&
9df3ba6c 503 DNS_PACKET_ID(p) == t->id)
c19ffd9f 504 dns_transaction_process_reply(t, p);
9df3ba6c 505 else
c19ffd9f
TG
506 log_debug("Invalid DNS packet.");
507
508 return 0;
509}
510
471d40d9 511static int dns_transaction_emit(DnsTransaction *t) {
c19ffd9f
TG
512 int r;
513
514 assert(t);
c19ffd9f 515
471d40d9
TG
516 if (t->scope->protocol == DNS_PROTOCOL_DNS && !t->server) {
517 DnsServer *server = NULL;
518 _cleanup_close_ int fd = -1;
c19ffd9f 519
471d40d9
TG
520 fd = dns_scope_udp_dns_socket(t->scope, &server);
521 if (fd < 0)
522 return fd;
c19ffd9f 523
4667e00a 524 r = sd_event_add_io(t->scope->manager->event, &t->dns_udp_event_source, fd, EPOLLIN, on_dns_packet, t);
471d40d9
TG
525 if (r < 0)
526 return r;
c19ffd9f 527
4667e00a 528 t->dns_udp_fd = fd;
471d40d9
TG
529 fd = -1;
530 t->server = dns_server_ref(server);
531 }
c19ffd9f 532
4667e00a 533 r = dns_scope_emit(t->scope, t->dns_udp_fd, t->sent);
471d40d9
TG
534 if (r < 0)
535 return r;
c19ffd9f 536
be808ea0
TG
537 if (t->server)
538 t->current_features = t->server->possible_features;
539
471d40d9 540 return 0;
c19ffd9f
TG
541}
542
ec2c5e43
LP
543static int on_transaction_timeout(sd_event_source *s, usec_t usec, void *userdata) {
544 DnsTransaction *t = userdata;
545 int r;
546
547 assert(s);
548 assert(t);
549
be808ea0
TG
550 /* Timeout reached? Increase the timeout for the server used */
551 switch (t->scope->protocol) {
552 case DNS_PROTOCOL_DNS:
553 assert(t->server);
ec2c5e43 554
be808ea0
TG
555 dns_server_packet_lost(t->server, t->current_features, usec - t->start_usec);
556
557 break;
558 case DNS_PROTOCOL_LLMNR:
559 case DNS_PROTOCOL_MDNS:
9df3ba6c
TG
560 dns_scope_packet_lost(t->scope, usec - t->start_usec);
561
be808ea0
TG
562 break;
563 default:
564 assert_not_reached("Invalid DNS protocol.");
565 }
566
567 /* ...and try again with a new server */
568 dns_transaction_next_dns_server(t);
569
ec2c5e43
LP
570 r = dns_transaction_go(t);
571 if (r < 0)
572 dns_transaction_complete(t, DNS_TRANSACTION_RESOURCES);
573
574 return 0;
575}
576
577static int dns_transaction_make_packet(DnsTransaction *t) {
578 _cleanup_(dns_packet_unrefp) DnsPacket *p = NULL;
ec2c5e43
LP
579 int r;
580
581 assert(t);
582
583 if (t->sent)
584 return 0;
585
586 r = dns_packet_new_query(&p, t->scope->protocol, 0);
587 if (r < 0)
588 return r;
589
f52e61da
LP
590 r = dns_scope_good_key(t->scope, t->key);
591 if (r < 0)
592 return r;
593 if (r == 0)
ec2c5e43
LP
594 return -EDOM;
595
f52e61da
LP
596 r = dns_packet_append_key(p, t->key, NULL);
597 if (r < 0)
598 return r;
599
600 DNS_PACKET_HEADER(p)->qdcount = htobe16(1);
ec2c5e43
LP
601 DNS_PACKET_HEADER(p)->id = t->id;
602
603 t->sent = p;
604 p = NULL;
605
606 return 0;
607}
608
9df3ba6c
TG
609static usec_t transaction_get_resend_timeout(DnsTransaction *t) {
610 assert(t);
611 assert(t->scope);
612
613 switch (t->scope->protocol) {
614 case DNS_PROTOCOL_DNS:
615 assert(t->server);
616
617 return t->server->resend_timeout;
618 case DNS_PROTOCOL_LLMNR:
619 case DNS_PROTOCOL_MDNS:
620 return t->scope->resend_timeout;
621 default:
622 assert_not_reached("Invalid DNS protocol.");
623 }
624}
625
ec2c5e43
LP
626int dns_transaction_go(DnsTransaction *t) {
627 bool had_stream;
9df3ba6c 628 usec_t ts;
ec2c5e43
LP
629 int r;
630
631 assert(t);
632
633 had_stream = !!t->stream;
634
635 dns_transaction_stop(t);
636
e56187ca 637 log_debug("Excercising transaction on scope %s on %s/%s",
ec2c5e43
LP
638 dns_protocol_to_string(t->scope->protocol),
639 t->scope->link ? t->scope->link->name : "*",
640 t->scope->family == AF_UNSPEC ? "*" : af_to_name(t->scope->family));
641
642 if (t->n_attempts >= TRANSACTION_ATTEMPTS_MAX(t->scope->protocol)) {
643 dns_transaction_complete(t, DNS_TRANSACTION_ATTEMPTS_MAX_REACHED);
644 return 0;
645 }
646
647 if (t->scope->protocol == DNS_PROTOCOL_LLMNR && had_stream) {
648 /* If we already tried via a stream, then we don't
649 * retry on LLMNR. See RFC 4795, Section 2.7. */
650 dns_transaction_complete(t, DNS_TRANSACTION_ATTEMPTS_MAX_REACHED);
651 return 0;
652 }
653
38a03f06 654 assert_se(sd_event_now(t->scope->manager->event, clock_boottime_or_monotonic(), &ts) >= 0);
9df3ba6c 655
ec2c5e43 656 t->n_attempts++;
9df3ba6c 657 t->start_usec = ts;
ec2c5e43 658 t->received = dns_packet_unref(t->received);
ae6a4bbf
LP
659 t->answer = dns_answer_unref(t->answer);
660 t->answer_rcode = 0;
c3bc53e6 661 t->answer_source = _DNS_TRANSACTION_SOURCE_INVALID;
ec2c5e43 662
d746bb3e
LP
663 /* Check the zone, but obly if this transaction is not used
664 * for probing or verifying a zone item. */
665 if (set_isempty(t->zone_items)) {
666
ae6a4bbf 667 r = dns_zone_lookup(&t->scope->zone, t->key, &t->answer, NULL, NULL);
d746bb3e
LP
668 if (r < 0)
669 return r;
670 if (r > 0) {
ae6a4bbf 671 t->answer_rcode = DNS_RCODE_SUCCESS;
c3bc53e6 672 t->answer_source = DNS_TRANSACTION_ZONE;
d746bb3e
LP
673 dns_transaction_complete(t, DNS_TRANSACTION_SUCCESS);
674 return 0;
675 }
676 }
677
4d926a69
LP
678 /* Check the cache, but only if this transaction is not used
679 * for probing or verifying a zone item. */
680 if (set_isempty(t->zone_items)) {
2c27fbca 681
4d926a69
LP
682 /* Before trying the cache, let's make sure we figured out a
683 * server to use. Should this cause a change of server this
684 * might flush the cache. */
685 dns_scope_get_dns_server(t->scope);
2c27fbca 686
4d926a69
LP
687 /* Let's then prune all outdated entries */
688 dns_cache_prune(&t->scope->cache);
689
ae6a4bbf 690 r = dns_cache_lookup(&t->scope->cache, t->key, &t->answer_rcode, &t->answer);
4d926a69
LP
691 if (r < 0)
692 return r;
693 if (r > 0) {
c3bc53e6 694 t->answer_source = DNS_TRANSACTION_CACHE;
ae6a4bbf 695 if (t->answer_rcode == DNS_RCODE_SUCCESS)
4d926a69
LP
696 dns_transaction_complete(t, DNS_TRANSACTION_SUCCESS);
697 else
698 dns_transaction_complete(t, DNS_TRANSACTION_FAILURE);
699 return 0;
700 }
ec2c5e43
LP
701 }
702
6e068472
LP
703 if (t->scope->protocol == DNS_PROTOCOL_LLMNR && !t->initial_jitter) {
704 usec_t jitter;
705
706 /* RFC 4795 Section 2.7 suggests all queries should be
707 * delayed by a random time from 0 to JITTER_INTERVAL. */
708
709 t->initial_jitter = true;
710
711 random_bytes(&jitter, sizeof(jitter));
712 jitter %= LLMNR_JITTER_INTERVAL_USEC;
713
714 r = sd_event_add_time(
715 t->scope->manager->event,
716 &t->timeout_event_source,
717 clock_boottime_or_monotonic(),
9df3ba6c 718 ts + jitter,
a4076574 719 LLMNR_JITTER_INTERVAL_USEC,
6e068472
LP
720 on_transaction_timeout, t);
721 if (r < 0)
722 return r;
723
724 t->n_attempts = 0;
725 t->state = DNS_TRANSACTION_PENDING;
726
727 log_debug("Delaying LLMNR transaction for " USEC_FMT "us.", jitter);
728 return 0;
729 }
730
ec2c5e43
LP
731 /* Otherwise, we need to ask the network */
732 r = dns_transaction_make_packet(t);
733 if (r == -EDOM) {
734 /* Not the right request to make on this network?
735 * (i.e. an A request made on IPv6 or an AAAA request
736 * made on IPv4, on LLMNR or mDNS.) */
737 dns_transaction_complete(t, DNS_TRANSACTION_NO_SERVERS);
738 return 0;
739 }
740 if (r < 0)
741 return r;
742
743 if (t->scope->protocol == DNS_PROTOCOL_LLMNR &&
f52e61da
LP
744 (dns_name_endswith(DNS_RESOURCE_KEY_NAME(t->key), "in-addr.arpa") > 0 ||
745 dns_name_endswith(DNS_RESOURCE_KEY_NAME(t->key), "ip6.arpa") > 0)) {
ec2c5e43
LP
746
747 /* RFC 4795, Section 2.4. says reverse lookups shall
748 * always be made via TCP on LLMNR */
749 r = dns_transaction_open_tcp(t);
750 } else {
be808ea0
TG
751 /* Try via UDP, and if that fails due to large size or lack of
752 * support try via TCP */
471d40d9 753 r = dns_transaction_emit(t);
be808ea0 754 if (r == -EMSGSIZE || r == -EAGAIN)
ec2c5e43
LP
755 r = dns_transaction_open_tcp(t);
756 }
be808ea0 757
ec2c5e43
LP
758 if (r == -ESRCH) {
759 /* No servers to send this to? */
760 dns_transaction_complete(t, DNS_TRANSACTION_NO_SERVERS);
761 return 0;
8300ba21 762 } else if (r < 0) {
13b551ac
LP
763 if (t->scope->protocol != DNS_PROTOCOL_DNS) {
764 dns_transaction_complete(t, DNS_TRANSACTION_RESOURCES);
765 return 0;
766 }
767
ec2c5e43 768 /* Couldn't send? Try immediately again, with a new server */
647f6aa8 769 dns_transaction_next_dns_server(t);
ec2c5e43
LP
770
771 return dns_transaction_go(t);
772 }
773
9a015429
LP
774 r = sd_event_add_time(
775 t->scope->manager->event,
776 &t->timeout_event_source,
777 clock_boottime_or_monotonic(),
9df3ba6c 778 ts + transaction_get_resend_timeout(t), 0,
9a015429 779 on_transaction_timeout, t);
ec2c5e43
LP
780 if (r < 0)
781 return r;
782
783 t->state = DNS_TRANSACTION_PENDING;
784 return 1;
785}
786
787static const char* const dns_transaction_state_table[_DNS_TRANSACTION_STATE_MAX] = {
788 [DNS_TRANSACTION_NULL] = "null",
789 [DNS_TRANSACTION_PENDING] = "pending",
790 [DNS_TRANSACTION_FAILURE] = "failure",
791 [DNS_TRANSACTION_SUCCESS] = "success",
792 [DNS_TRANSACTION_NO_SERVERS] = "no-servers",
793 [DNS_TRANSACTION_TIMEOUT] = "timeout",
794 [DNS_TRANSACTION_ATTEMPTS_MAX_REACHED] = "attempts-max-reached",
795 [DNS_TRANSACTION_INVALID_REPLY] = "invalid-reply",
796 [DNS_TRANSACTION_RESOURCES] = "resources",
797 [DNS_TRANSACTION_ABORTED] = "aborted",
798};
799DEFINE_STRING_TABLE_LOOKUP(dns_transaction_state, DnsTransactionState);
c3bc53e6
LP
800
801static const char* const dns_transaction_source_table[_DNS_TRANSACTION_SOURCE_MAX] = {
802 [DNS_TRANSACTION_NETWORK] = "network",
803 [DNS_TRANSACTION_CACHE] = "cache",
804 [DNS_TRANSACTION_ZONE] = "zone",
805};
806DEFINE_STRING_TABLE_LOOKUP(dns_transaction_source, DnsTransactionSource);