| 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/dns_session.h" | 5 #include "net/dns/dns_session.h" |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/lazy_instance.h" | 9 #include "base/lazy_instance.h" |
| 10 #include "base/metrics/histogram.h" | 10 #include "base/metrics/histogram.h" |
| (...skipping 20 matching lines...) Expand all Loading... |
| 31 const size_t kRTTBucketCount = 100; | 31 const size_t kRTTBucketCount = 100; |
| 32 // Target percentile in the RTT histogram used for retransmission timeout. | 32 // Target percentile in the RTT histogram used for retransmission timeout. |
| 33 const unsigned kRTOPercentile = 99; | 33 const unsigned kRTOPercentile = 99; |
| 34 } // namespace | 34 } // namespace |
| 35 | 35 |
| 36 // Runtime statistics of DNS server. | 36 // Runtime statistics of DNS server. |
| 37 struct DnsSession::ServerStats { | 37 struct DnsSession::ServerStats { |
| 38 ServerStats(base::TimeDelta rtt_estimate_param, RttBuckets* buckets) | 38 ServerStats(base::TimeDelta rtt_estimate_param, RttBuckets* buckets) |
| 39 : last_failure_count(0), rtt_estimate(rtt_estimate_param) { | 39 : last_failure_count(0), rtt_estimate(rtt_estimate_param) { |
| 40 rtt_histogram.reset(new base::SampleVector(buckets)); | 40 rtt_histogram.reset(new base::SampleVector(buckets)); |
| 41 // Seed histogram with 2 samples at |rtt_estimate| timeout. |
| 42 rtt_histogram->Accumulate(rtt_estimate.InMilliseconds(), 2); |
| 41 } | 43 } |
| 42 | 44 |
| 43 // Count of consecutive failures after last success. | 45 // Count of consecutive failures after last success. |
| 44 int last_failure_count; | 46 int last_failure_count; |
| 45 | 47 |
| 46 // Last time when server returned failure or timeout. | 48 // Last time when server returned failure or timeout. |
| 47 base::Time last_failure; | 49 base::Time last_failure; |
| 48 // Last time when server returned success. | 50 // Last time when server returned success. |
| 49 base::Time last_success; | 51 base::Time last_success; |
| 50 | 52 |
| (...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 } else { | 204 } else { |
| 203 UMA_HISTOGRAM_COUNTS("AsyncDNS.ServerFailuresAfterSuccess", | 205 UMA_HISTOGRAM_COUNTS("AsyncDNS.ServerFailuresAfterSuccess", |
| 204 server_stats_[index]->last_failure_count); | 206 server_stats_[index]->last_failure_count); |
| 205 } | 207 } |
| 206 } | 208 } |
| 207 } | 209 } |
| 208 } | 210 } |
| 209 | 211 |
| 210 | 212 |
| 211 base::TimeDelta DnsSession::NextTimeout(unsigned server_index, int attempt) { | 213 base::TimeDelta DnsSession::NextTimeout(unsigned server_index, int attempt) { |
| 212 DCHECK_LT(server_index, server_stats_.size()); | 214 // Respect config timeout if it exceeds |kMaxTimeoutMs|. |
| 213 | 215 if (config_.timeout.InMilliseconds() >= kMaxTimeoutMs) |
| 214 base::TimeDelta timeout = config_.timeout; | 216 return config_.timeout; |
| 215 // If this server has not responded successfully, then don't wait too long. | 217 return NextTimeoutFromHistogram(server_index, attempt); |
| 216 if (server_stats_[server_index]->last_success.is_null()) | |
| 217 return timeout; | |
| 218 | |
| 219 // The timeout doubles every full round (each nameserver once). | |
| 220 unsigned num_backoffs = attempt / config_.nameservers.size(); | |
| 221 | |
| 222 return std::min(timeout * (1 << num_backoffs), | |
| 223 base::TimeDelta::FromMilliseconds(kMaxTimeoutMs)); | |
| 224 } | 218 } |
| 225 | 219 |
| 226 // Allocate a socket, already connected to the server address. | 220 // Allocate a socket, already connected to the server address. |
| 227 scoped_ptr<DnsSession::SocketLease> DnsSession::AllocateSocket( | 221 scoped_ptr<DnsSession::SocketLease> DnsSession::AllocateSocket( |
| 228 unsigned server_index, const NetLog::Source& source) { | 222 unsigned server_index, const NetLog::Source& source) { |
| 229 scoped_ptr<DatagramClientSocket> socket; | 223 scoped_ptr<DatagramClientSocket> socket; |
| 230 | 224 |
| 231 socket = socket_pool_->AllocateSocket(server_index); | 225 socket = socket_pool_->AllocateSocket(server_index); |
| 232 if (!socket.get()) | 226 if (!socket.get()) |
| 233 return scoped_ptr<SocketLease>(); | 227 return scoped_ptr<SocketLease>(); |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 295 timeout = std::max(timeout, base::TimeDelta::FromMilliseconds(kMinTimeoutMs)); | 289 timeout = std::max(timeout, base::TimeDelta::FromMilliseconds(kMinTimeoutMs)); |
| 296 | 290 |
| 297 // The timeout still doubles every full round. | 291 // The timeout still doubles every full round. |
| 298 unsigned num_backoffs = attempt / config_.nameservers.size(); | 292 unsigned num_backoffs = attempt / config_.nameservers.size(); |
| 299 | 293 |
| 300 return std::min(timeout * (1 << num_backoffs), | 294 return std::min(timeout * (1 << num_backoffs), |
| 301 base::TimeDelta::FromMilliseconds(kMaxTimeoutMs)); | 295 base::TimeDelta::FromMilliseconds(kMaxTimeoutMs)); |
| 302 } | 296 } |
| 303 | 297 |
| 304 } // namespace net | 298 } // namespace net |
| OLD | NEW |