OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/dns/host_resolver_impl.h" | 5 #include "net/dns/host_resolver_impl.h" |
6 | 6 |
7 #if defined(OS_WIN) | 7 #if defined(OS_WIN) |
8 #include <Winsock2.h> | 8 #include <Winsock2.h> |
9 #elif defined(OS_POSIX) | 9 #elif defined(OS_POSIX) |
10 #include <netdb.h> | 10 #include <netdb.h> |
11 #endif | 11 #endif |
12 | 12 |
13 #include <cmath> | 13 #include <cmath> |
14 #include <utility> | 14 #include <utility> |
15 #include <vector> | 15 #include <vector> |
16 | 16 |
17 #include "base/basictypes.h" | 17 #include "base/basictypes.h" |
18 #include "base/bind.h" | 18 #include "base/bind.h" |
19 #include "base/bind_helpers.h" | 19 #include "base/bind_helpers.h" |
20 #include "base/callback.h" | 20 #include "base/callback.h" |
21 #include "base/compiler_specific.h" | 21 #include "base/compiler_specific.h" |
22 #include "base/debug/debugger.h" | 22 #include "base/debug/debugger.h" |
23 #include "base/debug/stack_trace.h" | 23 #include "base/debug/stack_trace.h" |
24 #include "base/message_loop/message_loop_proxy.h" | |
25 #include "base/metrics/field_trial.h" | 24 #include "base/metrics/field_trial.h" |
26 #include "base/metrics/histogram_macros.h" | 25 #include "base/metrics/histogram_macros.h" |
27 #include "base/metrics/sparse_histogram.h" | 26 #include "base/metrics/sparse_histogram.h" |
28 #include "base/profiler/scoped_tracker.h" | 27 #include "base/profiler/scoped_tracker.h" |
29 #include "base/stl_util.h" | 28 #include "base/stl_util.h" |
30 #include "base/strings/string_util.h" | 29 #include "base/strings/string_util.h" |
31 #include "base/strings/utf_string_conversions.h" | 30 #include "base/strings/utf_string_conversions.h" |
| 31 #include "base/thread_task_runner_handle.h" |
32 #include "base/threading/worker_pool.h" | 32 #include "base/threading/worker_pool.h" |
33 #include "base/time/time.h" | 33 #include "base/time/time.h" |
34 #include "base/values.h" | 34 #include "base/values.h" |
35 #include "net/base/address_family.h" | 35 #include "net/base/address_family.h" |
36 #include "net/base/address_list.h" | 36 #include "net/base/address_list.h" |
37 #include "net/base/dns_reloader.h" | 37 #include "net/base/dns_reloader.h" |
38 #include "net/base/dns_util.h" | 38 #include "net/base/dns_util.h" |
39 #include "net/base/host_port_pair.h" | 39 #include "net/base/host_port_pair.h" |
40 #include "net/base/ip_endpoint.h" | 40 #include "net/base/ip_endpoint.h" |
41 #include "net/base/net_errors.h" | 41 #include "net/base/net_errors.h" |
(...skipping 230 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
272 | 272 |
273 bool ConfigureAsyncDnsNoFallbackFieldTrial() { | 273 bool ConfigureAsyncDnsNoFallbackFieldTrial() { |
274 const bool kDefault = false; | 274 const bool kDefault = false; |
275 | 275 |
276 // Configure the AsyncDns field trial as follows: | 276 // Configure the AsyncDns field trial as follows: |
277 // groups AsyncDnsNoFallbackA and AsyncDnsNoFallbackB: return true, | 277 // groups AsyncDnsNoFallbackA and AsyncDnsNoFallbackB: return true, |
278 // groups AsyncDnsA and AsyncDnsB: return false, | 278 // groups AsyncDnsA and AsyncDnsB: return false, |
279 // groups SystemDnsA and SystemDnsB: return false, | 279 // groups SystemDnsA and SystemDnsB: return false, |
280 // otherwise (trial absent): return default. | 280 // otherwise (trial absent): return default. |
281 std::string group_name = base::FieldTrialList::FindFullName("AsyncDns"); | 281 std::string group_name = base::FieldTrialList::FindFullName("AsyncDns"); |
282 if (!group_name.empty()) | 282 if (!group_name.empty()) { |
283 return StartsWithASCII(group_name, "AsyncDnsNoFallback", false); | 283 return base::StartsWith(group_name, "AsyncDnsNoFallback", |
| 284 base::CompareCase::INSENSITIVE_ASCII); |
| 285 } |
284 return kDefault; | 286 return kDefault; |
285 } | 287 } |
286 | 288 |
287 //----------------------------------------------------------------------------- | 289 //----------------------------------------------------------------------------- |
288 | 290 |
289 AddressList EnsurePortOnAddressList(const AddressList& list, uint16 port) { | 291 AddressList EnsurePortOnAddressList(const AddressList& list, uint16 port) { |
290 if (list.empty() || list.front().port() == port) | 292 if (list.empty() || list.front().port() == port) |
291 return list; | 293 return list; |
292 return AddressList::CopyWithPort(list, port); | 294 return AddressList::CopyWithPort(list, port); |
293 } | 295 } |
(...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
585 typedef base::Callback<void(int net_error, | 587 typedef base::Callback<void(int net_error, |
586 const AddressList& addr_list)> Callback; | 588 const AddressList& addr_list)> Callback; |
587 | 589 |
588 ProcTask(const Key& key, | 590 ProcTask(const Key& key, |
589 const ProcTaskParams& params, | 591 const ProcTaskParams& params, |
590 const Callback& callback, | 592 const Callback& callback, |
591 const BoundNetLog& job_net_log) | 593 const BoundNetLog& job_net_log) |
592 : key_(key), | 594 : key_(key), |
593 params_(params), | 595 params_(params), |
594 callback_(callback), | 596 callback_(callback), |
595 origin_loop_(base::MessageLoopProxy::current()), | 597 origin_loop_(base::ThreadTaskRunnerHandle::Get()), |
596 attempt_number_(0), | 598 attempt_number_(0), |
597 completed_attempt_number_(0), | 599 completed_attempt_number_(0), |
598 completed_attempt_error_(ERR_UNEXPECTED), | 600 completed_attempt_error_(ERR_UNEXPECTED), |
599 had_non_speculative_request_(false), | 601 had_non_speculative_request_(false), |
600 net_log_(job_net_log) { | 602 net_log_(job_net_log) { |
601 if (!params_.resolver_proc.get()) | 603 if (!params_.resolver_proc.get()) |
602 params_.resolver_proc = HostResolverProc::GetDefault(); | 604 params_.resolver_proc = HostResolverProc::GetDefault(); |
603 // If default is unset, use the system proc. | 605 // If default is unset, use the system proc. |
604 if (!params_.resolver_proc.get()) | 606 if (!params_.resolver_proc.get()) |
605 params_.resolver_proc = new SystemHostResolverProc(); | 607 params_.resolver_proc = new SystemHostResolverProc(); |
(...skipping 310 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
916 // Holds an owning reference to the HostResolverProc that we are going to use. | 918 // Holds an owning reference to the HostResolverProc that we are going to use. |
917 // This may not be the current resolver procedure by the time we call | 919 // This may not be the current resolver procedure by the time we call |
918 // ResolveAddrInfo, but that's OK... we'll use it anyways, and the owning | 920 // ResolveAddrInfo, but that's OK... we'll use it anyways, and the owning |
919 // reference ensures that it remains valid until we are done. | 921 // reference ensures that it remains valid until we are done. |
920 ProcTaskParams params_; | 922 ProcTaskParams params_; |
921 | 923 |
922 // The listener to the results of this ProcTask. | 924 // The listener to the results of this ProcTask. |
923 Callback callback_; | 925 Callback callback_; |
924 | 926 |
925 // Used to post ourselves onto the origin thread. | 927 // Used to post ourselves onto the origin thread. |
926 scoped_refptr<base::MessageLoopProxy> origin_loop_; | 928 scoped_refptr<base::SingleThreadTaskRunner> origin_loop_; |
927 | 929 |
928 // Keeps track of the number of attempts we have made so far to resolve the | 930 // Keeps track of the number of attempts we have made so far to resolve the |
929 // host. Whenever we start an attempt to resolve the host, we increase this | 931 // host. Whenever we start an attempt to resolve the host, we increase this |
930 // number. | 932 // number. |
931 uint32 attempt_number_; | 933 uint32 attempt_number_; |
932 | 934 |
933 // The index of the attempt which finished first (or 0 if the job is still in | 935 // The index of the attempt which finished first (or 0 if the job is still in |
934 // progress). | 936 // progress). |
935 uint32 completed_attempt_number_; | 937 uint32 completed_attempt_number_; |
936 | 938 |
(...skipping 1481 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2418 dns_client_->SetConfig(dns_config); | 2420 dns_client_->SetConfig(dns_config); |
2419 num_dns_failures_ = 0; | 2421 num_dns_failures_ = 0; |
2420 if (dns_client_->GetConfig()) | 2422 if (dns_client_->GetConfig()) |
2421 UMA_HISTOGRAM_BOOLEAN("AsyncDNS.DnsClientEnabled", true); | 2423 UMA_HISTOGRAM_BOOLEAN("AsyncDNS.DnsClientEnabled", true); |
2422 } | 2424 } |
2423 | 2425 |
2424 AbortDnsTasks(); | 2426 AbortDnsTasks(); |
2425 } | 2427 } |
2426 | 2428 |
2427 } // namespace net | 2429 } // namespace net |
OLD | NEW |