blob: 89f06607ce420f782c0b37fd6316e46747ebd1e4 [file] [log] [blame]
Mattias Falk89c1e972011-04-29 14:48:51 +02001/*
2 * Copyright (C) 2011 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#define LOG_TAG "ResolverController"
18#define DBG 0
19
Pierre Imaibeedec32016-04-13 06:44:51 +090020#include <algorithm>
21#include <cstdlib>
Ben Schwartze7601812017-04-28 16:38:29 -040022#include <map>
23#include <mutex>
24#include <set>
Pierre Imaibeedec32016-04-13 06:44:51 +090025#include <string>
Ben Schwartze7601812017-04-28 16:38:29 -040026#include <thread>
27#include <utility>
Pierre Imaibeedec32016-04-13 06:44:51 +090028#include <vector>
Logan Chien3f461482018-04-23 14:31:32 +080029#include <log/log.h>
Elliott Hughes970274a2012-09-11 18:56:36 -070030#include <net/if.h>
Pierre Imaibeedec32016-04-13 06:44:51 +090031#include <sys/socket.h>
32#include <netdb.h>
David 'Digit' Turner4da10dd2012-01-13 13:43:43 +010033
Ben Schwartze7601812017-04-28 16:38:29 -040034#include <arpa/inet.h>
Pierre Imaibeedec32016-04-13 06:44:51 +090035
Pierre Imai3a272072016-04-19 16:17:07 +090036#include <android-base/strings.h>
Ben Schwartzcbdd64a2017-08-23 18:21:46 -040037#include <android-base/thread_annotations.h>
Pierre Imaibeedec32016-04-13 06:44:51 +090038#include <android/net/INetd.h>
dalyk6250dbd2017-12-28 16:20:04 -050039#include <android/net/metrics/INetdEventListener.h>
Mattias Falk89c1e972011-04-29 14:48:51 +020040
Pierre Imai3a272072016-04-19 16:17:07 +090041#include "DumpWriter.h"
dalyk6250dbd2017-12-28 16:20:04 -050042#include "EventReporter.h"
Ben Schwartze7601812017-04-28 16:38:29 -040043#include "NetdConstants.h"
Mattias Falk89c1e972011-04-29 14:48:51 +020044#include "ResolverController.h"
Pierre Imaibeedec32016-04-13 06:44:51 +090045#include "ResolverStats.h"
Ben Schwartz66810f62017-10-16 19:27:46 -040046#include "dns/DnsTlsServer.h"
Bernie Innocenti189eb502018-10-01 23:10:18 +090047#include "dns/DnsTlsTransport.h"
48#include "netd_resolv/params.h"
49#include "netd_resolv/resolv.h"
50#include "netd_resolv/stats.h"
Erik Klined739c212018-04-24 23:09:39 +090051#include "netdutils/BackoffSequence.h"
Mattias Falk89c1e972011-04-29 14:48:51 +020052
Lorenzo Colitti7035f222017-02-13 18:29:00 +090053namespace android {
Lorenzo Colitti7035f222017-02-13 18:29:00 +090054
Erik Klined739c212018-04-24 23:09:39 +090055using netdutils::BackoffSequence;
56
57namespace net {
Ben Schwartze7601812017-04-28 16:38:29 -040058namespace {
59
Ben Schwartz4204ecf2017-10-02 12:35:48 -040060std::string addrToString(const sockaddr_storage* addr) {
61 char out[INET6_ADDRSTRLEN] = {0};
62 getnameinfo((const sockaddr*)addr, sizeof(sockaddr_storage), out,
Yi Kongbdfd57e2018-07-25 13:26:10 -070063 INET6_ADDRSTRLEN, nullptr, 0, NI_NUMERICHOST);
Ben Schwartz4204ecf2017-10-02 12:35:48 -040064 return std::string(out);
65}
Ben Schwartze7601812017-04-28 16:38:29 -040066
Ben Schwartz008f74c2017-12-07 17:27:20 -050067bool parseServer(const char* server, sockaddr_storage* parsed) {
68 addrinfo hints = {
69 .ai_family = AF_UNSPEC,
70 .ai_flags = AI_NUMERICHOST | AI_NUMERICSERV
71 };
72 addrinfo* res;
73
74 int err = getaddrinfo(server, "853", &hints, &res);
75 if (err != 0) {
76 ALOGW("Failed to parse server address (%s): %s", server, gai_strerror(err));
77 return false;
Ben Schwartze7601812017-04-28 16:38:29 -040078 }
Ben Schwartz008f74c2017-12-07 17:27:20 -050079
80 memcpy(parsed, res->ai_addr, res->ai_addrlen);
81 freeaddrinfo(res);
82 return true;
Ben Schwartze7601812017-04-28 16:38:29 -040083}
84
Erik Kline1564d482018-03-07 17:09:35 +090085const char* getPrivateDnsModeString(PrivateDnsMode mode) {
86 switch (mode) {
87 case PrivateDnsMode::OFF: return "OFF";
88 case PrivateDnsMode::OPPORTUNISTIC: return "OPPORTUNISTIC";
89 case PrivateDnsMode::STRICT: return "STRICT";
90 }
91}
92
Erik Klinefb757532018-01-18 20:12:06 +090093constexpr const char* validationStatusToString(ResolverController::Validation value) {
94 switch (value) {
95 case ResolverController::Validation::in_process: return "in_process";
96 case ResolverController::Validation::success: return "success";
97 case ResolverController::Validation::fail: return "fail";
98 case ResolverController::Validation::unknown_server: return "unknown_server";
99 case ResolverController::Validation::unknown_netid: return "unknown_netid";
100 default: return "unknown_status";
101 }
102}
103
Erik Klined739c212018-04-24 23:09:39 +0900104
105class PrivateDnsConfiguration {
106 public:
107 typedef ResolverController::PrivateDnsStatus PrivateDnsStatus;
108 typedef ResolverController::Validation Validation;
109 typedef std::map<DnsTlsServer, Validation, AddressComparator> PrivateDnsTracker;
110
111 int set(int32_t netId, const std::vector<std::string>& servers, const std::string& name,
112 const std::set<std::vector<uint8_t>>& fingerprints) {
113 if (DBG) {
114 ALOGD("PrivateDnsConfiguration::set(%u, %zu, %s, %zu)",
115 netId, servers.size(), name.c_str(), fingerprints.size());
116 }
117
118 const bool explicitlyConfigured = !name.empty() || !fingerprints.empty();
119
120 // Parse the list of servers that has been passed in
121 std::set<DnsTlsServer> tlsServers;
122 for (size_t i = 0; i < servers.size(); ++i) {
123 sockaddr_storage parsed;
124 if (!parseServer(servers[i].c_str(), &parsed)) {
125 return -EINVAL;
126 }
127 DnsTlsServer server(parsed);
128 server.name = name;
129 server.fingerprints = fingerprints;
130 tlsServers.insert(server);
131 }
132
Bernie Innocentiabf8a342018-08-10 15:17:16 +0900133 std::lock_guard guard(mPrivateDnsLock);
Erik Klined739c212018-04-24 23:09:39 +0900134 if (explicitlyConfigured) {
135 mPrivateDnsModes[netId] = PrivateDnsMode::STRICT;
136 } else if (!tlsServers.empty()) {
137 mPrivateDnsModes[netId] = PrivateDnsMode::OPPORTUNISTIC;
138 } else {
139 mPrivateDnsModes[netId] = PrivateDnsMode::OFF;
140 mPrivateDnsTransports.erase(netId);
141 return 0;
142 }
143
144 // Create the tracker if it was not present
145 auto netPair = mPrivateDnsTransports.find(netId);
146 if (netPair == mPrivateDnsTransports.end()) {
147 // No TLS tracker yet for this netId.
148 bool added;
149 std::tie(netPair, added) = mPrivateDnsTransports.emplace(netId, PrivateDnsTracker());
150 if (!added) {
151 ALOGE("Memory error while recording private DNS for netId %d", netId);
152 return -ENOMEM;
153 }
154 }
155 auto& tracker = netPair->second;
156
157 // Remove any servers from the tracker that are not in |servers| exactly.
158 for (auto it = tracker.begin(); it != tracker.end();) {
159 if (tlsServers.count(it->first) == 0) {
160 it = tracker.erase(it);
161 } else {
162 ++it;
163 }
164 }
165
166 // Add any new or changed servers to the tracker, and initiate async checks for them.
167 for (const auto& server : tlsServers) {
Erik Kline533a8422018-06-14 15:16:27 +0900168 if (needsValidation(tracker, server)) {
Erik Klined739c212018-04-24 23:09:39 +0900169 validatePrivateDnsProvider(server, tracker, netId);
170 }
171 }
172 return 0;
173 }
174
175 PrivateDnsStatus getStatus(unsigned netId) {
176 PrivateDnsStatus status{PrivateDnsMode::OFF, {}};
177
178 // This mutex is on the critical path of every DNS lookup.
179 //
180 // If the overhead of mutex acquisition proves too high, we could reduce
181 // it by maintaining an atomic_int32_t counter of TLS-enabled netids, or
182 // by using an RWLock.
Bernie Innocentiabf8a342018-08-10 15:17:16 +0900183 std::lock_guard guard(mPrivateDnsLock);
Erik Klined739c212018-04-24 23:09:39 +0900184
185 const auto mode = mPrivateDnsModes.find(netId);
186 if (mode == mPrivateDnsModes.end()) return status;
187 status.mode = mode->second;
188
189 const auto netPair = mPrivateDnsTransports.find(netId);
190 if (netPair != mPrivateDnsTransports.end()) {
191 for (const auto& serverPair : netPair->second) {
192 if (serverPair.second == Validation::success) {
193 status.validatedServers.push_back(serverPair.first);
194 }
195 }
196 }
197
198 return status;
199 }
200
201 void clear(unsigned netId) {
202 if (DBG) {
203 ALOGD("PrivateDnsConfiguration::clear(%u)", netId);
204 }
Bernie Innocentiabf8a342018-08-10 15:17:16 +0900205 std::lock_guard guard(mPrivateDnsLock);
Erik Klined739c212018-04-24 23:09:39 +0900206 mPrivateDnsModes.erase(netId);
207 mPrivateDnsTransports.erase(netId);
208 }
209
210 void dump(DumpWriter& dw, unsigned netId) {
Bernie Innocentiabf8a342018-08-10 15:17:16 +0900211 std::lock_guard guard(mPrivateDnsLock);
Erik Klined739c212018-04-24 23:09:39 +0900212
213 const auto& mode = mPrivateDnsModes.find(netId);
214 dw.println("Private DNS mode: %s", getPrivateDnsModeString(
215 (mode != mPrivateDnsModes.end()) ? mode->second : PrivateDnsMode::OFF));
216 const auto& netPair = mPrivateDnsTransports.find(netId);
217 if (netPair == mPrivateDnsTransports.end()) {
218 dw.println("No Private DNS servers configured");
219 } else {
220 const auto& tracker = netPair->second;
221 dw.println("Private DNS configuration (%zu entries)", tracker.size());
222 dw.incIndent();
223 for (const auto& kv : tracker) {
224 const auto& server = kv.first;
225 const auto status = kv.second;
226 dw.println("%s name{%s} status{%s}",
227 addrToString(&(server.ss)).c_str(),
228 server.name.c_str(),
229 validationStatusToString(status));
230 }
231 dw.decIndent();
232 }
233 }
234
235 private:
236 void validatePrivateDnsProvider(const DnsTlsServer& server, PrivateDnsTracker& tracker,
237 unsigned netId) REQUIRES(mPrivateDnsLock) {
238 if (DBG) {
239 ALOGD("validatePrivateDnsProvider(%s, %u)", addrToString(&(server.ss)).c_str(), netId);
240 }
241
242 tracker[server] = Validation::in_process;
243 if (DBG) {
244 ALOGD("Server %s marked as in_process. Tracker now has size %zu",
245 addrToString(&(server.ss)).c_str(), tracker.size());
246 }
247 // Note that capturing |server| and |netId| in this lambda create copies.
248 std::thread validate_thread([this, server, netId] {
249 // cat /proc/sys/net/ipv4/tcp_syn_retries yields "6".
250 //
251 // Start with a 1 minute delay and backoff to once per hour.
252 //
253 // Assumptions:
254 // [1] Each TLS validation is ~10KB of certs+handshake+payload.
255 // [2] Network typically provision clients with <=4 nameservers.
256 // [3] Average month has 30 days.
257 //
258 // Each validation pass in a given hour is ~1.2MB of data. And 24
259 // such validation passes per day is about ~30MB per month, in the
260 // worst case. Otherwise, this will cost ~600 SYNs per month
261 // (6 SYNs per ip, 4 ips per validation pass, 24 passes per day).
262 auto backoff = BackoffSequence<>::Builder()
263 .withInitialRetransmissionTime(std::chrono::seconds(60))
264 .withMaximumRetransmissionTime(std::chrono::seconds(3600))
265 .build();
266
267 while (true) {
268 // ::validate() is a blocking call that performs network operations.
269 // It can take milliseconds to minutes, up to the SYN retry limit.
270 const bool success = DnsTlsTransport::validate(server, netId);
271 if (DBG) {
272 ALOGD("validateDnsTlsServer returned %d for %s", success,
273 addrToString(&(server.ss)).c_str());
274 }
275
276 const bool needs_reeval = this->recordPrivateDnsValidation(server, netId, success);
277 if (!needs_reeval) {
278 break;
279 }
280
281 if (backoff.hasNextTimeout()) {
282 std::this_thread::sleep_for(backoff.getNextTimeout());
283 } else {
284 break;
285 }
286 }
287 });
288 validate_thread.detach();
289 }
290
291 bool recordPrivateDnsValidation(const DnsTlsServer& server, unsigned netId, bool success) {
292 constexpr bool NEEDS_REEVALUATION = true;
293 constexpr bool DONT_REEVALUATE = false;
294
Bernie Innocentiabf8a342018-08-10 15:17:16 +0900295 std::lock_guard guard(mPrivateDnsLock);
Erik Klined739c212018-04-24 23:09:39 +0900296
297 auto netPair = mPrivateDnsTransports.find(netId);
298 if (netPair == mPrivateDnsTransports.end()) {
299 ALOGW("netId %u was erased during private DNS validation", netId);
300 return DONT_REEVALUATE;
301 }
302
Erik Kline533a8422018-06-14 15:16:27 +0900303 const auto mode = mPrivateDnsModes.find(netId);
304 if (mode == mPrivateDnsModes.end()) {
305 ALOGW("netId %u has no private DNS validation mode", netId);
306 return DONT_REEVALUATE;
307 }
308 const bool modeDoesReevaluation = (mode->second == PrivateDnsMode::STRICT);
309
310 bool reevaluationStatus =
311 (success || !modeDoesReevaluation) ? DONT_REEVALUATE : NEEDS_REEVALUATION;
Erik Klined739c212018-04-24 23:09:39 +0900312
313 auto& tracker = netPair->second;
314 auto serverPair = tracker.find(server);
315 if (serverPair == tracker.end()) {
316 ALOGW("Server %s was removed during private DNS validation",
317 addrToString(&(server.ss)).c_str());
318 success = false;
319 reevaluationStatus = DONT_REEVALUATE;
320 } else if (!(serverPair->first == server)) {
321 // TODO: It doesn't seem correct to overwrite the tracker entry for
322 // |server| down below in this circumstance... Fix this.
323 ALOGW("Server %s was changed during private DNS validation",
324 addrToString(&(server.ss)).c_str());
325 success = false;
326 reevaluationStatus = DONT_REEVALUATE;
327 }
328
329 // Send a validation event to NetdEventListenerService.
330 if (mNetdEventListener == nullptr) {
331 mNetdEventListener = mEventReporter.getNetdEventListener();
332 }
333 if (mNetdEventListener != nullptr) {
334 const String16 ipLiteral(addrToString(&(server.ss)).c_str());
335 const String16 hostname(server.name.empty() ? "" : server.name.c_str());
336 mNetdEventListener->onPrivateDnsValidationEvent(netId, ipLiteral, hostname, success);
337 if (DBG) {
338 ALOGD("Sending validation %s event on netId %u for %s with hostname %s",
339 success ? "success" : "failure", netId,
340 addrToString(&(server.ss)).c_str(), server.name.c_str());
341 }
342 } else {
343 ALOGE("Validation event not sent since NetdEventListenerService is unavailable.");
344 }
345
346 if (success) {
347 tracker[server] = Validation::success;
348 if (DBG) {
349 ALOGD("Validation succeeded for %s! Tracker now has %zu entries.",
350 addrToString(&(server.ss)).c_str(), tracker.size());
351 }
352 } else {
353 // Validation failure is expected if a user is on a captive portal.
354 // TODO: Trigger a second validation attempt after captive portal login
355 // succeeds.
Erik Kline533a8422018-06-14 15:16:27 +0900356 tracker[server] = (reevaluationStatus == NEEDS_REEVALUATION) ? Validation::in_process
357 : Validation::fail;
Erik Klined739c212018-04-24 23:09:39 +0900358 if (DBG) {
359 ALOGD("Validation failed for %s!", addrToString(&(server.ss)).c_str());
360 }
361 }
362
363 return reevaluationStatus;
364 }
365
Erik Kline533a8422018-06-14 15:16:27 +0900366 // Start validation for newly added servers as well as any servers that have
367 // landed in Validation::fail state. Note that servers that have failed
368 // multiple validation attempts but for which there is still a validating
369 // thread running are marked as being Validation::in_process.
370 static bool needsValidation(const PrivateDnsTracker& tracker, const DnsTlsServer& server) {
371 const auto& iter = tracker.find(server);
372 return (iter == tracker.end()) || (iter->second == Validation::fail);
373 }
374
Erik Klined739c212018-04-24 23:09:39 +0900375 EventReporter mEventReporter;
376
377 std::mutex mPrivateDnsLock;
378 std::map<unsigned, PrivateDnsMode> mPrivateDnsModes GUARDED_BY(mPrivateDnsLock);
379 // Structure for tracking the validation status of servers on a specific netId.
380 // Using the AddressComparator ensures at most one entry per IP address.
381 std::map<unsigned, PrivateDnsTracker> mPrivateDnsTransports GUARDED_BY(mPrivateDnsLock);
382 android::sp<android::net::metrics::INetdEventListener>
383 mNetdEventListener GUARDED_BY(mPrivateDnsLock);
Erik Kline533a8422018-06-14 15:16:27 +0900384} sPrivateDnsConfiguration;
Erik Klined739c212018-04-24 23:09:39 +0900385
Erik Klined26a2c22018-05-11 19:33:19 +0900386bool allIPv6Only(const std::vector<std::string>& servers) {
387 for (const auto& server : servers) {
388 if (server.find(':') == std::string::npos) return false;
389 }
390 return !servers.empty();
391}
392
Ben Schwartze7601812017-04-28 16:38:29 -0400393} // namespace
394
Pierre Imai95f5f942016-03-09 18:09:25 +0900395int ResolverController::setDnsServers(unsigned netId, const char* searchDomains,
396 const char** servers, int numservers, const __res_params* params) {
Mattias Falk89c1e972011-04-29 14:48:51 +0200397 if (DBG) {
Ben Schwartz4204ecf2017-10-02 12:35:48 -0400398 ALOGD("setDnsServers netId = %u, numservers = %d", netId, numservers);
Mattias Falk89c1e972011-04-29 14:48:51 +0200399 }
Bernie Innocenti189eb502018-10-01 23:10:18 +0900400 return -resolv_set_nameservers_for_net(netId, servers, numservers, searchDomains, params);
Mattias Falk89c1e972011-04-29 14:48:51 +0200401}
Paul Jensen6a46f332014-08-06 18:42:27 +0000402
Erik Kline1564d482018-03-07 17:09:35 +0900403ResolverController::PrivateDnsStatus
Erik Klined739c212018-04-24 23:09:39 +0900404ResolverController::getPrivateDnsStatus(unsigned netId) const {
Erik Kline533a8422018-06-14 15:16:27 +0900405 return sPrivateDnsConfiguration.getStatus(netId);
Ben Schwartze7601812017-04-28 16:38:29 -0400406}
407
Lorenzo Colittidadc5f82014-11-29 13:54:25 +0900408int ResolverController::clearDnsServers(unsigned netId) {
Bernie Innocenti189eb502018-10-01 23:10:18 +0900409 resolv_set_nameservers_for_net(netId, nullptr, 0, "", nullptr);
Lorenzo Colittidadc5f82014-11-29 13:54:25 +0900410 if (DBG) {
411 ALOGD("clearDnsServers netId = %u\n", netId);
412 }
Erik Klined26a2c22018-05-11 19:33:19 +0900413 mDns64Configuration.stopPrefixDiscovery(netId);
Erik Kline533a8422018-06-14 15:16:27 +0900414 sPrivateDnsConfiguration.clear(netId);
Lorenzo Colittidadc5f82014-11-29 13:54:25 +0900415 return 0;
416}
417
Paul Jensen6a46f332014-08-06 18:42:27 +0000418int ResolverController::flushDnsCache(unsigned netId) {
419 if (DBG) {
420 ALOGD("flushDnsCache netId = %u\n", netId);
421 }
422
Bernie Innocenti189eb502018-10-01 23:10:18 +0900423 resolv_flush_cache_for_net(netId);
Paul Jensen6a46f332014-08-06 18:42:27 +0000424
425 return 0;
426}
Pierre Imaibeedec32016-04-13 06:44:51 +0900427
428int ResolverController::getDnsInfo(unsigned netId, std::vector<std::string>* servers,
429 std::vector<std::string>* domains, __res_params* params,
430 std::vector<android::net::ResolverStats>* stats) {
431 using android::net::ResolverStats;
432 using android::net::INetd;
433 static_assert(ResolverStats::STATS_SUCCESSES == INetd::RESOLVER_STATS_SUCCESSES &&
434 ResolverStats::STATS_ERRORS == INetd::RESOLVER_STATS_ERRORS &&
435 ResolverStats::STATS_TIMEOUTS == INetd::RESOLVER_STATS_TIMEOUTS &&
436 ResolverStats::STATS_INTERNAL_ERRORS == INetd::RESOLVER_STATS_INTERNAL_ERRORS &&
437 ResolverStats::STATS_RTT_AVG == INetd::RESOLVER_STATS_RTT_AVG &&
438 ResolverStats::STATS_LAST_SAMPLE_TIME == INetd::RESOLVER_STATS_LAST_SAMPLE_TIME &&
439 ResolverStats::STATS_USABLE == INetd::RESOLVER_STATS_USABLE &&
440 ResolverStats::STATS_COUNT == INetd::RESOLVER_STATS_COUNT,
441 "AIDL and ResolverStats.h out of sync");
442 int nscount = -1;
443 sockaddr_storage res_servers[MAXNS];
444 int dcount = -1;
445 char res_domains[MAXDNSRCH][MAXDNSRCHPATH];
Bernie Innocenti189eb502018-10-01 23:10:18 +0900446 res_stats res_stats[MAXNS];
Pierre Imaibeedec32016-04-13 06:44:51 +0900447 servers->clear();
448 domains->clear();
449 *params = __res_params{};
450 stats->clear();
451 int revision_id = android_net_res_stats_get_info_for_net(netId, &nscount, res_servers, &dcount,
452 res_domains, params, res_stats);
453
454 // If the netId is unknown (which can happen for valid net IDs for which no DNS servers have
455 // yet been configured), there is no revision ID. In this case there is no data to return.
456 if (revision_id < 0) {
457 return 0;
458 }
459
460 // Verify that the returned data is sane.
461 if (nscount < 0 || nscount > MAXNS || dcount < 0 || dcount > MAXDNSRCH) {
462 ALOGE("%s: nscount=%d, dcount=%d", __FUNCTION__, nscount, dcount);
463 return -ENOTRECOVERABLE;
464 }
465
466 // Determine which servers are considered usable by the resolver.
467 bool valid_servers[MAXNS];
468 std::fill_n(valid_servers, MAXNS, false);
469 android_net_res_stats_get_usable_servers(params, res_stats, nscount, valid_servers);
470
471 // Convert the server sockaddr structures to std::string.
472 stats->resize(nscount);
473 for (int i = 0 ; i < nscount ; ++i) {
474 char hbuf[NI_MAXHOST];
475 int rv = getnameinfo(reinterpret_cast<const sockaddr*>(&res_servers[i]),
476 sizeof(res_servers[i]), hbuf, sizeof(hbuf), nullptr, 0, NI_NUMERICHOST);
477 std::string server_str;
478 if (rv == 0) {
479 server_str.assign(hbuf);
480 } else {
481 ALOGE("getnameinfo() failed for server #%d: %s", i, gai_strerror(rv));
482 server_str.assign("<invalid>");
483 }
484 servers->push_back(std::move(server_str));
485 android::net::ResolverStats& cur_stats = (*stats)[i];
486 android_net_res_stats_aggregate(&res_stats[i], &cur_stats.successes, &cur_stats.errors,
487 &cur_stats.timeouts, &cur_stats.internal_errors, &cur_stats.rtt_avg,
488 &cur_stats.last_sample_time);
489 cur_stats.usable = valid_servers[i];
490 }
491
492 // Convert the stack-allocated search domain strings to std::string.
493 for (int i = 0 ; i < dcount ; ++i) {
494 domains->push_back(res_domains[i]);
495 }
496 return 0;
497}
498
499int ResolverController::setResolverConfiguration(int32_t netId,
500 const std::vector<std::string>& servers, const std::vector<std::string>& domains,
Erik Klinea1476fb2018-03-04 21:01:56 +0900501 const std::vector<int32_t>& params, const std::string& tlsName,
502 const std::vector<std::string>& tlsServers,
Ben Schwartz4204ecf2017-10-02 12:35:48 -0400503 const std::set<std::vector<uint8_t>>& tlsFingerprints) {
Pierre Imaibeedec32016-04-13 06:44:51 +0900504 using android::net::INetd;
Bernie Innocenticc93c372018-08-06 15:18:59 +0900505 // TODO: make RESOLVER_PARAMS_BASE_TIMEOUT_MSEC a mandatory parameter once all callers
506 // have been updated to specify it.
507 if (params.size() < INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC ||
508 params.size() > INetd::RESOLVER_PARAMS_COUNT) {
Pierre Imaibeedec32016-04-13 06:44:51 +0900509 ALOGE("%s: params.size()=%zu", __FUNCTION__, params.size());
510 return -EINVAL;
511 }
512
Erik Kline533a8422018-06-14 15:16:27 +0900513 const int err = sPrivateDnsConfiguration.set(netId, tlsServers, tlsName, tlsFingerprints);
Erik Kline1564d482018-03-07 17:09:35 +0900514 if (err != 0) {
515 return err;
Ben Schwartz4204ecf2017-10-02 12:35:48 -0400516 }
517
Erik Kline1564d482018-03-07 17:09:35 +0900518 // Convert network-assigned server list to bionic's format.
519 auto server_count = std::min<size_t>(MAXNS, servers.size());
Pierre Imaibeedec32016-04-13 06:44:51 +0900520 std::vector<const char*> server_ptrs;
Pierre Imai0452cb52016-05-30 16:42:34 +0900521 for (size_t i = 0 ; i < server_count ; ++i) {
Erik Kline1564d482018-03-07 17:09:35 +0900522 server_ptrs.push_back(servers[i].c_str());
Pierre Imaibeedec32016-04-13 06:44:51 +0900523 }
524
525 std::string domains_str;
526 if (!domains.empty()) {
527 domains_str = domains[0];
528 for (size_t i = 1 ; i < domains.size() ; ++i) {
529 domains_str += " " + domains[i];
530 }
531 }
532
Bernie Innocenticc93c372018-08-06 15:18:59 +0900533 __res_params res_params = {};
Pierre Imaibeedec32016-04-13 06:44:51 +0900534 res_params.sample_validity = params[INetd::RESOLVER_PARAMS_SAMPLE_VALIDITY];
535 res_params.success_threshold = params[INetd::RESOLVER_PARAMS_SUCCESS_THRESHOLD];
536 res_params.min_samples = params[INetd::RESOLVER_PARAMS_MIN_SAMPLES];
537 res_params.max_samples = params[INetd::RESOLVER_PARAMS_MAX_SAMPLES];
Bernie Innocenticc93c372018-08-06 15:18:59 +0900538 if (params.size() > INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC) {
539 res_params.base_timeout_msec = params[INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC];
540 }
Erik Klined26a2c22018-05-11 19:33:19 +0900541
542 const auto rval = setDnsServers(netId, domains_str.c_str(), server_ptrs.data(),
543 server_ptrs.size(), &res_params);
544
545 if (rval == 0) {
546 // Start DNS64 discovery after successfully setting any new DNS servers
547 // as the cache may have been cleared (if the nameservers differ), and
548 // we might discover a different DNS64 prefix. If the cache has not been
549 // cleared, we may quickly rediscover the same prefix.
550 //
551 // Operators may choose to use a longer TTL in order to reduce repeated
552 // resolution (see also https://tools.ietf.org/html/rfc7050#section-5).
553 if (allIPv6Only(servers)) {
Erik Kline603df202018-09-10 18:16:26 +0900554 // TODO: Keep any existing discovered prefix around for use while
555 // re-discovery is in progress. Otherwise, whenever DNS servers are
556 // pushed to netd there can be gaps where it would appear there was
557 // no prefix64 when in fact we had previously discovered one (and
558 // are highly likely to rediscover the same one).
Erik Klined26a2c22018-05-11 19:33:19 +0900559 mDns64Configuration.startPrefixDiscovery(netId);
560 } else {
561 mDns64Configuration.stopPrefixDiscovery(netId);
562 }
563 }
564
565 return rval;
Pierre Imaibeedec32016-04-13 06:44:51 +0900566}
567
568int ResolverController::getResolverInfo(int32_t netId, std::vector<std::string>* servers,
569 std::vector<std::string>* domains, std::vector<int32_t>* params,
570 std::vector<int32_t>* stats) {
571 using android::net::ResolverStats;
572 using android::net::INetd;
573 __res_params res_params;
574 std::vector<ResolverStats> res_stats;
575 int ret = getDnsInfo(netId, servers, domains, &res_params, &res_stats);
576 if (ret != 0) {
577 return ret;
578 }
579
580 // Serialize the information for binder.
581 ResolverStats::encodeAll(res_stats, stats);
582
583 params->resize(INetd::RESOLVER_PARAMS_COUNT);
584 (*params)[INetd::RESOLVER_PARAMS_SAMPLE_VALIDITY] = res_params.sample_validity;
585 (*params)[INetd::RESOLVER_PARAMS_SUCCESS_THRESHOLD] = res_params.success_threshold;
586 (*params)[INetd::RESOLVER_PARAMS_MIN_SAMPLES] = res_params.min_samples;
587 (*params)[INetd::RESOLVER_PARAMS_MAX_SAMPLES] = res_params.max_samples;
Bernie Innocenticc93c372018-08-06 15:18:59 +0900588 (*params)[INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC] = res_params.base_timeout_msec;
Pierre Imaibeedec32016-04-13 06:44:51 +0900589 return 0;
590}
Pierre Imai3a272072016-04-19 16:17:07 +0900591
592void ResolverController::dump(DumpWriter& dw, unsigned netId) {
593 // No lock needed since Bionic's resolver locks all accessed data structures internally.
594 using android::net::ResolverStats;
595 std::vector<std::string> servers;
596 std::vector<std::string> domains;
Bernie Innocenticc93c372018-08-06 15:18:59 +0900597 __res_params params = {};
Pierre Imai3a272072016-04-19 16:17:07 +0900598 std::vector<ResolverStats> stats;
599 time_t now = time(nullptr);
600 int rv = getDnsInfo(netId, &servers, &domains, &params, &stats);
601 dw.incIndent();
602 if (rv != 0) {
603 dw.println("getDnsInfo() failed for netid %u", netId);
604 } else {
605 if (servers.empty()) {
606 dw.println("No DNS servers defined");
607 } else {
608 dw.println("DNS servers: # IP (total, successes, errors, timeouts, internal errors, "
609 "RTT avg, last sample)");
610 dw.incIndent();
611 for (size_t i = 0 ; i < servers.size() ; ++i) {
612 if (i < stats.size()) {
613 const ResolverStats& s = stats[i];
614 int total = s.successes + s.errors + s.timeouts + s.internal_errors;
615 if (total > 0) {
616 int time_delta = (s.last_sample_time > 0) ? now - s.last_sample_time : -1;
617 dw.println("%s (%d, %d, %d, %d, %d, %dms, %ds)%s", servers[i].c_str(),
618 total, s.successes, s.errors, s.timeouts, s.internal_errors,
619 s.rtt_avg, time_delta, s.usable ? "" : " BROKEN");
620 } else {
621 dw.println("%s <no data>", servers[i].c_str());
622 }
623 } else {
624 dw.println("%s <no stats>", servers[i].c_str());
625 }
626 }
627 dw.decIndent();
628 }
629 if (domains.empty()) {
630 dw.println("No search domains defined");
631 } else {
632 std::string domains_str = android::base::Join(domains, ", ");
633 dw.println("search domains: %s", domains_str.c_str());
634 }
635 if (params.sample_validity != 0) {
Bernie Innocenticc93c372018-08-06 15:18:59 +0900636 dw.println(
637 "DNS parameters: sample validity = %us, success threshold = %u%%, "
638 "samples (min, max) = (%u, %u), base_timeout = %dmsec",
639 params.sample_validity, static_cast<unsigned>(params.success_threshold),
Pierre Imai3a272072016-04-19 16:17:07 +0900640 static_cast<unsigned>(params.min_samples),
Bernie Innocenticc93c372018-08-06 15:18:59 +0900641 static_cast<unsigned>(params.max_samples), params.base_timeout_msec);
Pierre Imai3a272072016-04-19 16:17:07 +0900642 }
Erik Klined739c212018-04-24 23:09:39 +0900643
Erik Klined26a2c22018-05-11 19:33:19 +0900644 mDns64Configuration.dump(dw, netId);
Erik Kline533a8422018-06-14 15:16:27 +0900645 sPrivateDnsConfiguration.dump(dw, netId);
Pierre Imai3a272072016-04-19 16:17:07 +0900646 }
647 dw.decIndent();
648}
Lorenzo Colitti7035f222017-02-13 18:29:00 +0900649
650} // namespace net
651} // namespace android