Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(107)

Side by Side Diff: components/sync/engine_impl/cycle/nudge_tracker.cc

Issue 2376123003: [Sync] Move //components/sync to the syncer namespace. (Closed)
Patch Set: Rebase. Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2013 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/sync/engine_impl/cycle/nudge_tracker.h" 5 #include "components/sync/engine_impl/cycle/nudge_tracker.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/memory/ptr_util.h" 9 #include "base/memory/ptr_util.h"
10 #include "components/sync/engine/polling_constants.h" 10 #include "components/sync/engine/polling_constants.h"
(...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after
147 base::TimeDelta NudgeTracker::RecordLocalRefreshRequest(ModelTypeSet types) { 147 base::TimeDelta NudgeTracker::RecordLocalRefreshRequest(ModelTypeSet types) {
148 for (ModelTypeSet::Iterator it = types.First(); it.Good(); it.Inc()) { 148 for (ModelTypeSet::Iterator it = types.First(); it.Good(); it.Inc()) {
149 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(it.Get()); 149 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(it.Get());
150 DCHECK(tracker_it != type_trackers_.end()); 150 DCHECK(tracker_it != type_trackers_.end());
151 tracker_it->second->RecordLocalRefreshRequest(); 151 tracker_it->second->RecordLocalRefreshRequest();
152 } 152 }
153 return local_refresh_nudge_delay_; 153 return local_refresh_nudge_delay_;
154 } 154 }
155 155
156 base::TimeDelta NudgeTracker::RecordRemoteInvalidation( 156 base::TimeDelta NudgeTracker::RecordRemoteInvalidation(
157 syncer::ModelType type, 157 ModelType type,
158 std::unique_ptr<InvalidationInterface> invalidation) { 158 std::unique_ptr<InvalidationInterface> invalidation) {
159 // Forward the invalidations to the proper recipient. 159 // Forward the invalidations to the proper recipient.
160 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type); 160 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type);
161 DCHECK(tracker_it != type_trackers_.end()); 161 DCHECK(tracker_it != type_trackers_.end());
162 tracker_it->second->RecordRemoteInvalidation(std::move(invalidation)); 162 tracker_it->second->RecordRemoteInvalidation(std::move(invalidation));
163 return remote_invalidation_nudge_delay_; 163 return remote_invalidation_nudge_delay_;
164 } 164 }
165 165
166 void NudgeTracker::RecordInitialSyncRequired(syncer::ModelType type) { 166 void NudgeTracker::RecordInitialSyncRequired(ModelType type) {
167 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type); 167 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type);
168 DCHECK(tracker_it != type_trackers_.end()); 168 DCHECK(tracker_it != type_trackers_.end());
169 tracker_it->second->RecordInitialSyncRequired(); 169 tracker_it->second->RecordInitialSyncRequired();
170 } 170 }
171 171
172 void NudgeTracker::RecordCommitConflict(syncer::ModelType type) { 172 void NudgeTracker::RecordCommitConflict(ModelType type) {
173 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type); 173 TypeTrackerMap::const_iterator tracker_it = type_trackers_.find(type);
174 DCHECK(tracker_it != type_trackers_.end()); 174 DCHECK(tracker_it != type_trackers_.end());
175 tracker_it->second->RecordCommitConflict(); 175 tracker_it->second->RecordCommitConflict();
176 } 176 }
177 177
178 void NudgeTracker::OnInvalidationsEnabled() { 178 void NudgeTracker::OnInvalidationsEnabled() {
179 invalidations_enabled_ = true; 179 invalidations_enabled_ = true;
180 } 180 }
181 181
182 void NudgeTracker::OnInvalidationsDisabled() { 182 void NudgeTracker::OnInvalidationsDisabled() {
(...skipping 194 matching lines...) Expand 10 before | Expand all | Expand 10 after
377 void NudgeTracker::SetNextRetryTime(base::TimeTicks retry_time) { 377 void NudgeTracker::SetNextRetryTime(base::TimeTicks retry_time) {
378 next_retry_time_ = retry_time; 378 next_retry_time_ = retry_time;
379 } 379 }
380 380
381 void NudgeTracker::OnReceivedCustomNudgeDelays( 381 void NudgeTracker::OnReceivedCustomNudgeDelays(
382 const std::map<ModelType, base::TimeDelta>& delay_map) { 382 const std::map<ModelType, base::TimeDelta>& delay_map) {
383 for (std::map<ModelType, base::TimeDelta>::const_iterator iter = 383 for (std::map<ModelType, base::TimeDelta>::const_iterator iter =
384 delay_map.begin(); 384 delay_map.begin();
385 iter != delay_map.end(); ++iter) { 385 iter != delay_map.end(); ++iter) {
386 ModelType type = iter->first; 386 ModelType type = iter->first;
387 DCHECK(syncer::ProtocolTypes().Has(type)); 387 DCHECK(ProtocolTypes().Has(type));
388 TypeTrackerMap::const_iterator type_iter = type_trackers_.find(type); 388 TypeTrackerMap::const_iterator type_iter = type_trackers_.find(type);
389 if (type_iter == type_trackers_.end()) 389 if (type_iter == type_trackers_.end())
390 continue; 390 continue;
391 391
392 if (iter->second > minimum_local_nudge_delay_) { 392 if (iter->second > minimum_local_nudge_delay_) {
393 type_iter->second->UpdateLocalNudgeDelay(iter->second); 393 type_iter->second->UpdateLocalNudgeDelay(iter->second);
394 } else { 394 } else {
395 type_iter->second->UpdateLocalNudgeDelay( 395 type_iter->second->UpdateLocalNudgeDelay(
396 GetDefaultDelayForType(type, minimum_local_nudge_delay_)); 396 GetDefaultDelayForType(type, minimum_local_nudge_delay_));
397 } 397 }
398 } 398 }
399 } 399 }
400 400
401 void NudgeTracker::SetDefaultNudgeDelay(base::TimeDelta nudge_delay) { 401 void NudgeTracker::SetDefaultNudgeDelay(base::TimeDelta nudge_delay) {
402 minimum_local_nudge_delay_ = nudge_delay; 402 minimum_local_nudge_delay_ = nudge_delay;
403 } 403 }
404 404
405 } // namespace syncer 405 } // namespace syncer
OLDNEW
« no previous file with comments | « components/sync/engine_impl/cycle/nudge_tracker.h ('k') | components/sync/engine_impl/cycle/nudge_tracker_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698