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

Unified Diff: sync/internal_api/sync_manager_impl.cc

Issue 14963002: sync: Report GetUpdate triggers to the server (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fix handling of NEW_CLIENT GU source Created 7 years, 7 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sync/engine/syncer_unittest.cc ('k') | sync/protocol/client_commands.proto » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/internal_api/sync_manager_impl.cc
diff --git a/sync/internal_api/sync_manager_impl.cc b/sync/internal_api/sync_manager_impl.cc
index 931f2790e5afedfdff8d830df0f4126494ef63e7..50c56d0dd25a0f75287b21f1d043f81e49691a89 100644
--- a/sync/internal_api/sync_manager_impl.cc
+++ b/sync/internal_api/sync_manager_impl.cc
@@ -958,8 +958,7 @@ void SyncManagerImpl::RequestNudgeForDataTypes(
types.First().Get(),
this);
allstatus_.IncrementNudgeCounter(NUDGE_SOURCE_LOCAL);
- scheduler_->ScheduleNudgeAsync(nudge_delay,
- NUDGE_SOURCE_LOCAL,
+ scheduler_->ScheduleLocalNudge(nudge_delay,
types,
nudge_location);
}
@@ -1262,9 +1261,8 @@ void SyncManagerImpl::OnIncomingInvalidation(
LOG(WARNING) << "Sync received invalidation without any type information.";
} else {
allstatus_.IncrementNudgeCounter(NUDGE_SOURCE_NOTIFICATION);
- scheduler_->ScheduleNudgeWithStatesAsync(
+ scheduler_->ScheduleInvalidationNudge(
TimeDelta::FromMilliseconds(kSyncSchedulerDelayMsec),
- NUDGE_SOURCE_NOTIFICATION,
type_invalidation_map, FROM_HERE);
allstatus_.IncrementNotificationsReceived();
UpdateNotificationInfo(type_invalidation_map);
@@ -1292,27 +1290,22 @@ void SyncManagerImpl::OnIncomingInvalidation(
void SyncManagerImpl::RefreshTypes(ModelTypeSet types) {
DCHECK(thread_checker_.CalledOnValidThread());
- const ModelTypeInvalidationMap& type_invalidation_map =
- ModelTypeSetToInvalidationMap(types, std::string());
- if (type_invalidation_map.empty()) {
+ if (types.Empty()) {
LOG(WARNING) << "Sync received refresh request with no types specified.";
} else {
allstatus_.IncrementNudgeCounter(NUDGE_SOURCE_LOCAL_REFRESH);
- scheduler_->ScheduleNudgeWithStatesAsync(
+ scheduler_->ScheduleLocalRefreshRequest(
TimeDelta::FromMilliseconds(kSyncRefreshDelayMsec),
- NUDGE_SOURCE_LOCAL_REFRESH,
- type_invalidation_map, FROM_HERE);
+ types, FROM_HERE);
}
if (js_event_handler_.IsInitialized()) {
base::DictionaryValue details;
base::ListValue* changed_types = new base::ListValue();
details.Set("changedTypes", changed_types);
- for (ModelTypeInvalidationMap::const_iterator it =
- type_invalidation_map.begin(); it != type_invalidation_map.end();
- ++it) {
+ for (ModelTypeSet::Iterator it = types.First(); it.Good(); it.Inc()) {
const std::string& model_type_str =
- ModelTypeToString(it->first);
+ ModelTypeToString(it.Get());
changed_types->Append(new base::StringValue(model_type_str));
}
details.SetString("source", "LOCAL_INVALIDATION");
« no previous file with comments | « sync/engine/syncer_unittest.cc ('k') | sync/protocol/client_commands.proto » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698