resolved: let's propagate errors from dns_scope_announce() and elsewhere

We don't actually make use of the return value for now, but it matches
our coding style elsewhere, and it actually shortens our code quite a
bit.

Also, add a missing OOM check after dns_answer_new().
This commit is contained in:
Lennart Poettering 2017-02-13 20:44:11 +01:00
parent bceaa99d49
commit 1a63fc5430
4 changed files with 26 additions and 29 deletions

View file

@ -1061,49 +1061,46 @@ static int on_announcement_timeout(sd_event_source *s, usec_t usec, void *userda
scope->announce_event_source = sd_event_source_unref(scope->announce_event_source); scope->announce_event_source = sd_event_source_unref(scope->announce_event_source);
dns_scope_announce(scope, false); (void) dns_scope_announce(scope, false);
return 0; return 0;
} }
void dns_scope_announce(DnsScope *scope, bool goodbye) { int dns_scope_announce(DnsScope *scope, bool goodbye) {
_cleanup_(dns_answer_unrefp) DnsAnswer *answer = NULL; _cleanup_(dns_answer_unrefp) DnsAnswer *answer = NULL;
_cleanup_(dns_packet_unrefp) DnsPacket *p = NULL; _cleanup_(dns_packet_unrefp) DnsPacket *p = NULL;
LinkAddress *a; LinkAddress *a;
int r; int r;
if (!scope) if (!scope)
return; return 0;
if (scope->protocol != DNS_PROTOCOL_MDNS) if (scope->protocol != DNS_PROTOCOL_MDNS)
return; return 0;
answer = dns_answer_new(4); answer = dns_answer_new(4);
if (!answer)
return log_oom();
LIST_FOREACH(addresses, a, scope->link->addresses) { LIST_FOREACH(addresses, a, scope->link->addresses) {
r = dns_answer_add(answer, a->mdns_address_rr, 0, goodbye ? DNS_ANSWER_GOODBYE : DNS_ANSWER_CACHE_FLUSH); r = dns_answer_add(answer, a->mdns_address_rr, 0, goodbye ? DNS_ANSWER_GOODBYE : DNS_ANSWER_CACHE_FLUSH);
if (r < 0) { if (r < 0)
log_debug_errno(r, "Failed to add address RR to answer: %m"); return log_debug_errno(r, "Failed to add address RR to answer: %m");
return;
}
r = dns_answer_add(answer, a->mdns_ptr_rr, 0, goodbye ? DNS_ANSWER_GOODBYE : DNS_ANSWER_CACHE_FLUSH); r = dns_answer_add(answer, a->mdns_ptr_rr, 0, goodbye ? DNS_ANSWER_GOODBYE : DNS_ANSWER_CACHE_FLUSH);
if (r < 0) { if (r < 0)
log_debug_errno(r, "Failed to add PTR RR to answer: %m"); return log_debug_errno(r, "Failed to add PTR RR to answer: %m");
return;
}
} }
if (dns_answer_isempty(answer)) if (dns_answer_isempty(answer))
return; return 0;
r = dns_scope_make_reply_packet(scope, 0, DNS_RCODE_SUCCESS, NULL, answer, NULL, false, &p); r = dns_scope_make_reply_packet(scope, 0, DNS_RCODE_SUCCESS, NULL, answer, NULL, false, &p);
if (r < 0) { if (r < 0)
log_debug_errno(r, "Failed to build reply packet: %m"); return log_debug_errno(r, "Failed to build reply packet: %m");
return;
}
r = dns_scope_emit_udp(scope, -1, p); r = dns_scope_emit_udp(scope, -1, p);
if (r < 0) { if (r < 0)
log_debug_errno(r, "Failed to send reply packet: %m"); return log_debug_errno(r, "Failed to send reply packet: %m");
return;
}
/* In section 8.3 of RFC6762: "The Multicast DNS responder MUST send at least two unsolicited /* In section 8.3 of RFC6762: "The Multicast DNS responder MUST send at least two unsolicited
* responses, one second apart." */ * responses, one second apart." */
@ -1123,6 +1120,8 @@ void dns_scope_announce(DnsScope *scope, bool goodbye) {
MDNS_JITTER_RANGE_USEC, MDNS_JITTER_RANGE_USEC,
on_announcement_timeout, scope); on_announcement_timeout, scope);
if (r < 0) if (r < 0)
log_debug_errno(r, "Failed to schedule second announcement: %m"); return log_debug_errno(r, "Failed to schedule second announcement: %m");
} }
return 0;
} }

View file

@ -117,4 +117,4 @@ bool dns_scope_network_good(DnsScope *s);
int dns_scope_ifindex(DnsScope *s); int dns_scope_ifindex(DnsScope *s);
void dns_scope_announce(DnsScope *scope, bool goodbye); int dns_scope_announce(DnsScope *scope, bool goodbye);

View file

@ -364,7 +364,7 @@ void dns_transaction_complete(DnsTransaction *t, DnsTransactionState state) {
dns_zone_item_notify(z); dns_zone_item_notify(z);
SWAP_TWO(t->notify_zone_items, t->notify_zone_items_done); SWAP_TWO(t->notify_zone_items, t->notify_zone_items_done);
if (t->probing) if (t->probing)
dns_scope_announce(t->scope, false); (void) dns_scope_announce(t->scope, false);
SET_FOREACH_MOVE(d, t->notify_transactions_done, t->notify_transactions) SET_FOREACH_MOVE(d, t->notify_transactions_done, t->notify_transactions)
dns_transaction_notify(d, t); dns_transaction_notify(d, t);

View file

@ -78,10 +78,8 @@ static int mdns_scope_process_query(DnsScope *s, DnsPacket *p) {
assert(p); assert(p);
r = dns_packet_extract(p); r = dns_packet_extract(p);
if (r < 0) { if (r < 0)
log_debug_errno(r, "Failed to extract resource records from incoming packet: %m"); return log_debug_errno(r, "Failed to extract resource records from incoming packet: %m");
return r;
}
/* TODO: there might be more than one question in mDNS queries. */ /* TODO: there might be more than one question in mDNS queries. */
assert_return((dns_question_size(p->question) > 0), -EINVAL); assert_return((dns_question_size(p->question) > 0), -EINVAL);
@ -182,7 +180,7 @@ static int on_mdns_packet(sd_event_source *s, int fd, uint32_t revents, void *us
r = mdns_scope_process_query(scope, p); r = mdns_scope_process_query(scope, p);
if (r < 0) { if (r < 0) {
log_debug("mDNS query processing failed."); log_debug_errno(r, "mDNS query processing failed: %m");
return 0; return 0;
} }
} else } else