Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 1 | /* |
| 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 Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 20 | #include <algorithm> |
| 21 | #include <cstdlib> |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 22 | #include <map> |
| 23 | #include <mutex> |
| 24 | #include <set> |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 25 | #include <string> |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 26 | #include <thread> |
| 27 | #include <utility> |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 28 | #include <vector> |
Logan Chien | 3f46148 | 2018-04-23 14:31:32 +0800 | [diff] [blame] | 29 | #include <log/log.h> |
Elliott Hughes | 970274a | 2012-09-11 18:56:36 -0700 | [diff] [blame] | 30 | #include <net/if.h> |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 31 | #include <sys/socket.h> |
| 32 | #include <netdb.h> |
David 'Digit' Turner | 4da10dd | 2012-01-13 13:43:43 +0100 | [diff] [blame] | 33 | |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 34 | #include <arpa/inet.h> |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 35 | |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 36 | #include <android-base/strings.h> |
Ben Schwartz | cbdd64a | 2017-08-23 18:21:46 -0400 | [diff] [blame] | 37 | #include <android-base/thread_annotations.h> |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 38 | #include <android/net/INetd.h> |
dalyk | 6250dbd | 2017-12-28 16:20:04 -0500 | [diff] [blame] | 39 | #include <android/net/metrics/INetdEventListener.h> |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 40 | |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 41 | #include "DumpWriter.h" |
dalyk | 6250dbd | 2017-12-28 16:20:04 -0500 | [diff] [blame] | 42 | #include "EventReporter.h" |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 43 | #include "NetdConstants.h" |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 44 | #include "ResolverController.h" |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 45 | #include "ResolverStats.h" |
Ben Schwartz | 66810f6 | 2017-10-16 19:27:46 -0400 | [diff] [blame] | 46 | #include "dns/DnsTlsServer.h" |
Bernie Innocenti | 189eb50 | 2018-10-01 23:10:18 +0900 | [diff] [blame^] | 47 | #include "dns/DnsTlsTransport.h" |
| 48 | #include "netd_resolv/params.h" |
| 49 | #include "netd_resolv/resolv.h" |
| 50 | #include "netd_resolv/stats.h" |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 51 | #include "netdutils/BackoffSequence.h" |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 52 | |
Lorenzo Colitti | 7035f22 | 2017-02-13 18:29:00 +0900 | [diff] [blame] | 53 | namespace android { |
Lorenzo Colitti | 7035f22 | 2017-02-13 18:29:00 +0900 | [diff] [blame] | 54 | |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 55 | using netdutils::BackoffSequence; |
| 56 | |
| 57 | namespace net { |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 58 | namespace { |
| 59 | |
Ben Schwartz | 4204ecf | 2017-10-02 12:35:48 -0400 | [diff] [blame] | 60 | std::string addrToString(const sockaddr_storage* addr) { |
| 61 | char out[INET6_ADDRSTRLEN] = {0}; |
| 62 | getnameinfo((const sockaddr*)addr, sizeof(sockaddr_storage), out, |
Yi Kong | bdfd57e | 2018-07-25 13:26:10 -0700 | [diff] [blame] | 63 | INET6_ADDRSTRLEN, nullptr, 0, NI_NUMERICHOST); |
Ben Schwartz | 4204ecf | 2017-10-02 12:35:48 -0400 | [diff] [blame] | 64 | return std::string(out); |
| 65 | } |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 66 | |
Ben Schwartz | 008f74c | 2017-12-07 17:27:20 -0500 | [diff] [blame] | 67 | bool 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 Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 78 | } |
Ben Schwartz | 008f74c | 2017-12-07 17:27:20 -0500 | [diff] [blame] | 79 | |
| 80 | memcpy(parsed, res->ai_addr, res->ai_addrlen); |
| 81 | freeaddrinfo(res); |
| 82 | return true; |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 83 | } |
| 84 | |
Erik Kline | 1564d48 | 2018-03-07 17:09:35 +0900 | [diff] [blame] | 85 | const 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 Kline | fb75753 | 2018-01-18 20:12:06 +0900 | [diff] [blame] | 93 | constexpr 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 Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 104 | |
| 105 | class 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 Innocenti | abf8a34 | 2018-08-10 15:17:16 +0900 | [diff] [blame] | 133 | std::lock_guard guard(mPrivateDnsLock); |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 134 | 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 Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 168 | if (needsValidation(tracker, server)) { |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 169 | 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 Innocenti | abf8a34 | 2018-08-10 15:17:16 +0900 | [diff] [blame] | 183 | std::lock_guard guard(mPrivateDnsLock); |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 184 | |
| 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 Innocenti | abf8a34 | 2018-08-10 15:17:16 +0900 | [diff] [blame] | 205 | std::lock_guard guard(mPrivateDnsLock); |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 206 | mPrivateDnsModes.erase(netId); |
| 207 | mPrivateDnsTransports.erase(netId); |
| 208 | } |
| 209 | |
| 210 | void dump(DumpWriter& dw, unsigned netId) { |
Bernie Innocenti | abf8a34 | 2018-08-10 15:17:16 +0900 | [diff] [blame] | 211 | std::lock_guard guard(mPrivateDnsLock); |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 212 | |
| 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 Innocenti | abf8a34 | 2018-08-10 15:17:16 +0900 | [diff] [blame] | 295 | std::lock_guard guard(mPrivateDnsLock); |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 296 | |
| 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 Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 303 | 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 Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 312 | |
| 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 Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 356 | tracker[server] = (reevaluationStatus == NEEDS_REEVALUATION) ? Validation::in_process |
| 357 | : Validation::fail; |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 358 | if (DBG) { |
| 359 | ALOGD("Validation failed for %s!", addrToString(&(server.ss)).c_str()); |
| 360 | } |
| 361 | } |
| 362 | |
| 363 | return reevaluationStatus; |
| 364 | } |
| 365 | |
Erik Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 366 | // 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 Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 375 | 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 Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 384 | } sPrivateDnsConfiguration; |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 385 | |
Erik Kline | d26a2c2 | 2018-05-11 19:33:19 +0900 | [diff] [blame] | 386 | bool 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 Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 393 | } // namespace |
| 394 | |
Pierre Imai | 95f5f94 | 2016-03-09 18:09:25 +0900 | [diff] [blame] | 395 | int ResolverController::setDnsServers(unsigned netId, const char* searchDomains, |
| 396 | const char** servers, int numservers, const __res_params* params) { |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 397 | if (DBG) { |
Ben Schwartz | 4204ecf | 2017-10-02 12:35:48 -0400 | [diff] [blame] | 398 | ALOGD("setDnsServers netId = %u, numservers = %d", netId, numservers); |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 399 | } |
Bernie Innocenti | 189eb50 | 2018-10-01 23:10:18 +0900 | [diff] [blame^] | 400 | return -resolv_set_nameservers_for_net(netId, servers, numservers, searchDomains, params); |
Mattias Falk | 89c1e97 | 2011-04-29 14:48:51 +0200 | [diff] [blame] | 401 | } |
Paul Jensen | 6a46f33 | 2014-08-06 18:42:27 +0000 | [diff] [blame] | 402 | |
Erik Kline | 1564d48 | 2018-03-07 17:09:35 +0900 | [diff] [blame] | 403 | ResolverController::PrivateDnsStatus |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 404 | ResolverController::getPrivateDnsStatus(unsigned netId) const { |
Erik Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 405 | return sPrivateDnsConfiguration.getStatus(netId); |
Ben Schwartz | e760181 | 2017-04-28 16:38:29 -0400 | [diff] [blame] | 406 | } |
| 407 | |
Lorenzo Colitti | dadc5f8 | 2014-11-29 13:54:25 +0900 | [diff] [blame] | 408 | int ResolverController::clearDnsServers(unsigned netId) { |
Bernie Innocenti | 189eb50 | 2018-10-01 23:10:18 +0900 | [diff] [blame^] | 409 | resolv_set_nameservers_for_net(netId, nullptr, 0, "", nullptr); |
Lorenzo Colitti | dadc5f8 | 2014-11-29 13:54:25 +0900 | [diff] [blame] | 410 | if (DBG) { |
| 411 | ALOGD("clearDnsServers netId = %u\n", netId); |
| 412 | } |
Erik Kline | d26a2c2 | 2018-05-11 19:33:19 +0900 | [diff] [blame] | 413 | mDns64Configuration.stopPrefixDiscovery(netId); |
Erik Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 414 | sPrivateDnsConfiguration.clear(netId); |
Lorenzo Colitti | dadc5f8 | 2014-11-29 13:54:25 +0900 | [diff] [blame] | 415 | return 0; |
| 416 | } |
| 417 | |
Paul Jensen | 6a46f33 | 2014-08-06 18:42:27 +0000 | [diff] [blame] | 418 | int ResolverController::flushDnsCache(unsigned netId) { |
| 419 | if (DBG) { |
| 420 | ALOGD("flushDnsCache netId = %u\n", netId); |
| 421 | } |
| 422 | |
Bernie Innocenti | 189eb50 | 2018-10-01 23:10:18 +0900 | [diff] [blame^] | 423 | resolv_flush_cache_for_net(netId); |
Paul Jensen | 6a46f33 | 2014-08-06 18:42:27 +0000 | [diff] [blame] | 424 | |
| 425 | return 0; |
| 426 | } |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 427 | |
| 428 | int 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 Innocenti | 189eb50 | 2018-10-01 23:10:18 +0900 | [diff] [blame^] | 446 | res_stats res_stats[MAXNS]; |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 447 | 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 | |
| 499 | int ResolverController::setResolverConfiguration(int32_t netId, |
| 500 | const std::vector<std::string>& servers, const std::vector<std::string>& domains, |
Erik Kline | a1476fb | 2018-03-04 21:01:56 +0900 | [diff] [blame] | 501 | const std::vector<int32_t>& params, const std::string& tlsName, |
| 502 | const std::vector<std::string>& tlsServers, |
Ben Schwartz | 4204ecf | 2017-10-02 12:35:48 -0400 | [diff] [blame] | 503 | const std::set<std::vector<uint8_t>>& tlsFingerprints) { |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 504 | using android::net::INetd; |
Bernie Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 505 | // 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 Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 509 | ALOGE("%s: params.size()=%zu", __FUNCTION__, params.size()); |
| 510 | return -EINVAL; |
| 511 | } |
| 512 | |
Erik Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 513 | const int err = sPrivateDnsConfiguration.set(netId, tlsServers, tlsName, tlsFingerprints); |
Erik Kline | 1564d48 | 2018-03-07 17:09:35 +0900 | [diff] [blame] | 514 | if (err != 0) { |
| 515 | return err; |
Ben Schwartz | 4204ecf | 2017-10-02 12:35:48 -0400 | [diff] [blame] | 516 | } |
| 517 | |
Erik Kline | 1564d48 | 2018-03-07 17:09:35 +0900 | [diff] [blame] | 518 | // Convert network-assigned server list to bionic's format. |
| 519 | auto server_count = std::min<size_t>(MAXNS, servers.size()); |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 520 | std::vector<const char*> server_ptrs; |
Pierre Imai | 0452cb5 | 2016-05-30 16:42:34 +0900 | [diff] [blame] | 521 | for (size_t i = 0 ; i < server_count ; ++i) { |
Erik Kline | 1564d48 | 2018-03-07 17:09:35 +0900 | [diff] [blame] | 522 | server_ptrs.push_back(servers[i].c_str()); |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 523 | } |
| 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 Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 533 | __res_params res_params = {}; |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 534 | 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 Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 538 | if (params.size() > INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC) { |
| 539 | res_params.base_timeout_msec = params[INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC]; |
| 540 | } |
Erik Kline | d26a2c2 | 2018-05-11 19:33:19 +0900 | [diff] [blame] | 541 | |
| 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 Kline | 603df20 | 2018-09-10 18:16:26 +0900 | [diff] [blame] | 554 | // 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 Kline | d26a2c2 | 2018-05-11 19:33:19 +0900 | [diff] [blame] | 559 | mDns64Configuration.startPrefixDiscovery(netId); |
| 560 | } else { |
| 561 | mDns64Configuration.stopPrefixDiscovery(netId); |
| 562 | } |
| 563 | } |
| 564 | |
| 565 | return rval; |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 566 | } |
| 567 | |
| 568 | int 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 Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 588 | (*params)[INetd::RESOLVER_PARAMS_BASE_TIMEOUT_MSEC] = res_params.base_timeout_msec; |
Pierre Imai | beedec3 | 2016-04-13 06:44:51 +0900 | [diff] [blame] | 589 | return 0; |
| 590 | } |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 591 | |
| 592 | void 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 Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 597 | __res_params params = {}; |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 598 | std::vector<ResolverStats> stats; |
| 599 | time_t now = time(nullptr); |
| 600 | int rv = getDnsInfo(netId, &servers, &domains, ¶ms, &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 Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 636 | 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 Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 640 | static_cast<unsigned>(params.min_samples), |
Bernie Innocenti | cc93c37 | 2018-08-06 15:18:59 +0900 | [diff] [blame] | 641 | static_cast<unsigned>(params.max_samples), params.base_timeout_msec); |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 642 | } |
Erik Kline | d739c21 | 2018-04-24 23:09:39 +0900 | [diff] [blame] | 643 | |
Erik Kline | d26a2c2 | 2018-05-11 19:33:19 +0900 | [diff] [blame] | 644 | mDns64Configuration.dump(dw, netId); |
Erik Kline | 533a842 | 2018-06-14 15:16:27 +0900 | [diff] [blame] | 645 | sPrivateDnsConfiguration.dump(dw, netId); |
Pierre Imai | 3a27207 | 2016-04-19 16:17:07 +0900 | [diff] [blame] | 646 | } |
| 647 | dw.decIndent(); |
| 648 | } |
Lorenzo Colitti | 7035f22 | 2017-02-13 18:29:00 +0900 | [diff] [blame] | 649 | |
| 650 | } // namespace net |
| 651 | } // namespace android |