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/base/backoff_entry.h" | 5 #include "net/base/backoff_entry.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <cmath> | 8 #include <cmath> |
9 #include <limits> | 9 #include <limits> |
10 | 10 |
11 #include "base/basictypes.h" | 11 #include "base/basictypes.h" |
12 #include "base/logging.h" | 12 #include "base/logging.h" |
13 #include "base/numerics/safe_math.h" | 13 #include "base/numerics/safe_math.h" |
14 #include "base/rand_util.h" | 14 #include "base/rand_util.h" |
| 15 #include "base/strings/string_number_conversions.h" |
15 #include "base/values.h" | 16 #include "base/values.h" |
16 | 17 |
17 namespace net { | 18 namespace net { |
18 | 19 |
19 BackoffEntry::BackoffEntry(const BackoffEntry::Policy* const policy) | 20 BackoffEntry::BackoffEntry(const BackoffEntry::Policy* const policy) |
20 : policy_(policy) { | 21 : policy_(policy) { |
21 DCHECK(policy_); | 22 DCHECK(policy_); |
22 Reset(); | 23 Reset(); |
23 } | 24 } |
24 | 25 |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
108 // We leave exponential_backoff_release_time_ unset, meaning 0. We could | 109 // We leave exponential_backoff_release_time_ unset, meaning 0. We could |
109 // initialize to ImplGetTimeNow() but because it's a virtual method it's | 110 // initialize to ImplGetTimeNow() but because it's a virtual method it's |
110 // not safe to call in the constructor (and the constructor calls Reset()). | 111 // not safe to call in the constructor (and the constructor calls Reset()). |
111 // The effects are the same, i.e. ShouldRejectRequest() will return false | 112 // The effects are the same, i.e. ShouldRejectRequest() will return false |
112 // right after Reset(). | 113 // right after Reset(). |
113 exponential_backoff_release_time_ = base::TimeTicks(); | 114 exponential_backoff_release_time_ = base::TimeTicks(); |
114 } | 115 } |
115 | 116 |
116 scoped_ptr<base::ListValue> BackoffEntry::Serialize() const { | 117 scoped_ptr<base::ListValue> BackoffEntry::Serialize() const { |
117 scoped_ptr<base::ListValue> serialized(new base::ListValue()); | 118 scoped_ptr<base::ListValue> serialized(new base::ListValue()); |
| 119 const int64 time_ticks_now_us = |
| 120 (ImplGetTimeNow() - base::TimeTicks()).InMicroseconds(); |
| 121 const int64 wall_clock_time_now_us = |
| 122 (ImplGetWallClockTimeNow() - base::Time()).InMicroseconds(); |
| 123 // Do overflow checking in microseconds, the internal unit of TimeTicks, Time |
| 124 // and TimeDelta. |
| 125 base::internal::CheckedNumeric<int64> time_until_release_us = |
| 126 (GetReleaseTime() - base::TimeTicks()).InMicroseconds(); |
| 127 time_until_release_us -= time_ticks_now_us; |
| 128 base::internal::CheckedNumeric<int64> wall_clock_release_time_us = |
| 129 time_until_release_us.ValueOrDefault(kint64min); |
| 130 wall_clock_release_time_us += wall_clock_time_now_us; |
| 131 serialized->AppendString(base::Int64ToString( |
| 132 wall_clock_release_time_us.ValueOrDefault(kint64max))); |
118 serialized->AppendInteger(failure_count_); | 133 serialized->AppendInteger(failure_count_); |
119 base::Time absolute_release_time = | |
120 (GetReleaseTime() - ImplGetTimeNow()) + ImplGetWallClockTimeNow(); | |
121 serialized->AppendDouble(absolute_release_time.ToDoubleT()); | |
122 return serialized; | 134 return serialized; |
123 } | 135 } |
124 | 136 |
125 bool BackoffEntry::Deserialize(const base::ListValue& serialized) { | 137 bool BackoffEntry::Deserialize(const base::ListValue& serialized) { |
126 if (serialized.GetSize() != 2) | 138 if (serialized.GetSize() != 2) |
127 return false; | 139 return false; |
| 140 std::string wall_clock_release_time_string; |
| 141 if (!serialized.GetString(0, &wall_clock_release_time_string)) |
| 142 return false; |
| 143 int64 wall_clock_release_time_us; |
| 144 if (!base::StringToInt64(wall_clock_release_time_string, |
| 145 &wall_clock_release_time_us)) |
| 146 return false; |
128 int failure_count; | 147 int failure_count; |
129 if (!serialized.GetInteger(0, &failure_count)) | 148 if (!serialized.GetInteger(1, &failure_count)) |
130 return false; | 149 return false; |
131 double absolute_release_time_double; | 150 const int64 wall_clock_time_now_us = |
132 if (!serialized.GetDouble(1, &absolute_release_time_double)) | 151 (ImplGetWallClockTimeNow() - base::Time()).InMicroseconds(); |
133 return false; | 152 base::internal::CheckedNumeric<int64> time_until_release_us = |
| 153 wall_clock_release_time_us; |
| 154 time_until_release_us -= wall_clock_time_now_us; |
| 155 exponential_backoff_release_time_ = |
| 156 TimeUntilReleaseToReleaseTime(base::TimeDelta::FromMicroseconds( |
| 157 time_until_release_us.ValueOrDefault(kint64min))); |
134 failure_count_ = failure_count; | 158 failure_count_ = failure_count; |
135 base::Time absolute_release_time = | |
136 base::Time::FromDoubleT(absolute_release_time_double); | |
137 base::TimeDelta time_until_release = | |
138 absolute_release_time - ImplGetWallClockTimeNow(); | |
139 exponential_backoff_release_time_ = | |
140 TimeUntilReleaseToReleaseTime(time_until_release); | |
141 return true; | 159 return true; |
142 } | 160 } |
143 | 161 |
144 base::TimeTicks BackoffEntry::ImplGetTimeNow() const { | 162 base::TimeTicks BackoffEntry::ImplGetTimeNow() const { |
145 return base::TimeTicks::Now(); | 163 return base::TimeTicks::Now(); |
146 } | 164 } |
147 | 165 |
148 base::Time BackoffEntry::ImplGetWallClockTimeNow() const { | 166 base::Time BackoffEntry::ImplGetWallClockTimeNow() const { |
149 return base::Time::Now(); | 167 return base::Time::Now(); |
150 } | 168 } |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 // Decide between maximum release time and calculated release time, accounting | 225 // Decide between maximum release time and calculated release time, accounting |
208 // for overflow with both. | 226 // for overflow with both. |
209 int64 release_time_us = std::min( | 227 int64 release_time_us = std::min( |
210 calculated_release_time_us.ValueOrDefault(kint64max), | 228 calculated_release_time_us.ValueOrDefault(kint64max), |
211 maximum_release_time_us.ValueOrDefault(kint64max)); | 229 maximum_release_time_us.ValueOrDefault(kint64max)); |
212 | 230 |
213 return base::TimeTicks() + base::TimeDelta::FromMicroseconds(release_time_us); | 231 return base::TimeTicks() + base::TimeDelta::FromMicroseconds(release_time_us); |
214 } | 232 } |
215 | 233 |
216 } // namespace net | 234 } // namespace net |
OLD | NEW |