OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/domain_reliability/scheduler.h" | 5 #include "components/domain_reliability/scheduler.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/metrics/field_trial.h" | 9 #include "base/metrics/field_trial.h" |
10 #include "base/strings/string_number_conversions.h" | 10 #include "base/strings/string_number_conversions.h" |
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
82 void DomainReliabilityScheduler::OnBeaconAdded() { | 82 void DomainReliabilityScheduler::OnBeaconAdded() { |
83 if (!upload_pending_) | 83 if (!upload_pending_) |
84 first_beacon_time_ = time_->NowTicks(); | 84 first_beacon_time_ = time_->NowTicks(); |
85 upload_pending_ = true; | 85 upload_pending_ = true; |
86 MaybeScheduleUpload(); | 86 MaybeScheduleUpload(); |
87 } | 87 } |
88 | 88 |
89 size_t DomainReliabilityScheduler::OnUploadStart() { | 89 size_t DomainReliabilityScheduler::OnUploadStart() { |
90 DCHECK(upload_scheduled_); | 90 DCHECK(upload_scheduled_); |
91 DCHECK_EQ(kInvalidCollectorIndex, collector_index_); | 91 DCHECK_EQ(kInvalidCollectorIndex, collector_index_); |
| 92 upload_pending_ = false; |
92 upload_scheduled_ = false; | 93 upload_scheduled_ = false; |
93 upload_running_ = true; | 94 upload_running_ = true; |
94 | 95 |
95 base::TimeTicks now = time_->NowTicks(); | 96 base::TimeTicks now = time_->NowTicks(); |
96 base::TimeTicks min_upload_time; | 97 base::TimeTicks min_upload_time; |
97 GetNextUploadTimeAndCollector(now, &min_upload_time, &collector_index_); | 98 GetNextUploadTimeAndCollector(now, &min_upload_time, &collector_index_); |
98 DCHECK(min_upload_time <= now); | 99 DCHECK(min_upload_time <= now); |
99 | 100 |
100 VLOG(1) << "Starting upload to collector " << collector_index_ << "."; | 101 VLOG(1) << "Starting upload to collector " << collector_index_ << "."; |
101 | 102 |
(...skipping 30 matching lines...) Expand all Loading... |
132 | 133 |
133 MaybeScheduleUpload(); | 134 MaybeScheduleUpload(); |
134 } | 135 } |
135 | 136 |
136 DomainReliabilityScheduler::CollectorState::CollectorState() : failures(0) {} | 137 DomainReliabilityScheduler::CollectorState::CollectorState() : failures(0) {} |
137 | 138 |
138 void DomainReliabilityScheduler::MaybeScheduleUpload() { | 139 void DomainReliabilityScheduler::MaybeScheduleUpload() { |
139 if (!upload_pending_ || upload_scheduled_ || upload_running_) | 140 if (!upload_pending_ || upload_scheduled_ || upload_running_) |
140 return; | 141 return; |
141 | 142 |
142 upload_pending_ = false; | |
143 upload_scheduled_ = true; | 143 upload_scheduled_ = true; |
144 old_first_beacon_time_ = first_beacon_time_; | 144 old_first_beacon_time_ = first_beacon_time_; |
145 | 145 |
146 base::TimeTicks now = time_->NowTicks(); | 146 base::TimeTicks now = time_->NowTicks(); |
147 | 147 |
148 base::TimeTicks min_by_deadline, max_by_deadline; | 148 base::TimeTicks min_by_deadline, max_by_deadline; |
149 min_by_deadline = first_beacon_time_ + params_.minimum_upload_delay; | 149 min_by_deadline = first_beacon_time_ + params_.minimum_upload_delay; |
150 max_by_deadline = first_beacon_time_ + params_.maximum_upload_delay; | 150 max_by_deadline = first_beacon_time_ + params_.maximum_upload_delay; |
151 DCHECK(min_by_deadline <= max_by_deadline); | 151 DCHECK(min_by_deadline <= max_by_deadline); |
152 | 152 |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
203 return base::TimeDelta::FromSeconds(0); | 203 return base::TimeDelta::FromSeconds(0); |
204 else { | 204 else { |
205 // Don't back off more than 64x the original delay. | 205 // Don't back off more than 64x the original delay. |
206 if (failures > 7) | 206 if (failures > 7) |
207 failures = 7; | 207 failures = 7; |
208 return params_.upload_retry_interval * (1 << (failures - 1)); | 208 return params_.upload_retry_interval * (1 << (failures - 1)); |
209 } | 209 } |
210 } | 210 } |
211 | 211 |
212 } // namespace domain_reliability | 212 } // namespace domain_reliability |
OLD | NEW |