| 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 8a53d788cb6b4fa842b512836988644659d7c0c3..b5ee26b2d387201d6506994c67c2a9349d2bc733 100644
|
| --- a/sync/internal_api/sync_manager_impl.cc
|
| +++ b/sync/internal_api/sync_manager_impl.cc
|
| @@ -21,7 +21,7 @@
|
| #include "sync/engine/syncer_types.h"
|
| #include "sync/internal_api/change_reorder_buffer.h"
|
| #include "sync/internal_api/public/base/model_type.h"
|
| -#include "sync/internal_api/public/base/model_type_state_map.h"
|
| +#include "sync/internal_api/public/base/model_type_invalidation_map.h"
|
| #include "sync/internal_api/public/base_node.h"
|
| #include "sync/internal_api/public/configure_reason.h"
|
| #include "sync/internal_api/public/engine/polling_constants.h"
|
| @@ -1016,9 +1016,10 @@ void SyncManagerImpl::OnSyncEngineEvent(const SyncEngineEvent& event) {
|
| (event.snapshot.model_neutral_state().num_successful_commits > 0);
|
| if (is_notifiable_commit) {
|
| if (invalidator_.get()) {
|
| - const ObjectIdStateMap& id_state_map =
|
| - ModelTypeStateMapToObjectIdStateMap(event.snapshot.source().types);
|
| - invalidator_->SendInvalidation(id_state_map);
|
| + const ObjectIdInvalidationMap& invalidation_map =
|
| + ModelTypeInvalidationMapToObjectIdInvalidationMap(
|
| + event.snapshot.source().types);
|
| + invalidator_->SendInvalidation(invalidation_map);
|
| } else {
|
| DVLOG(1) << "Not sending invalidation: invalidator_ is NULL";
|
| }
|
| @@ -1236,9 +1237,9 @@ JsArgList SyncManagerImpl::GetChildNodeIds(const JsArgList& args) {
|
| }
|
|
|
| void SyncManagerImpl::UpdateNotificationInfo(
|
| - const ModelTypeStateMap& type_state_map) {
|
| - for (ModelTypeStateMap::const_iterator it = type_state_map.begin();
|
| - it != type_state_map.end(); ++it) {
|
| + const ModelTypeInvalidationMap& invalidation_map) {
|
| + for (ModelTypeInvalidationMap::const_iterator it = invalidation_map.begin();
|
| + it != invalidation_map.end(); ++it) {
|
| NotificationInfo* info = ¬ification_info_map_[it->first];
|
| info->total_count++;
|
| info->payload = it->second.payload;
|
| @@ -1268,26 +1269,26 @@ void SyncManagerImpl::OnInvalidatorStateChange(InvalidatorState state) {
|
| }
|
|
|
| void SyncManagerImpl::OnIncomingInvalidation(
|
| - const ObjectIdStateMap& id_state_map,
|
| + const ObjectIdInvalidationMap& invalidation_map,
|
| IncomingInvalidationSource source) {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| - const ModelTypeStateMap& type_state_map =
|
| - ObjectIdStateMapToModelTypeStateMap(id_state_map);
|
| + const ModelTypeInvalidationMap& type_invalidation_map =
|
| + ObjectIdInvalidationMapToModelTypeInvalidationMap(invalidation_map);
|
| if (source == LOCAL_INVALIDATION) {
|
| allstatus_.IncrementNudgeCounter(NUDGE_SOURCE_LOCAL_REFRESH);
|
| scheduler_->ScheduleNudgeWithStatesAsync(
|
| TimeDelta::FromMilliseconds(kSyncRefreshDelayMsec),
|
| NUDGE_SOURCE_LOCAL_REFRESH,
|
| - type_state_map, FROM_HERE);
|
| - } else if (!type_state_map.empty()) {
|
| + type_invalidation_map, FROM_HERE);
|
| + } else if (!type_invalidation_map.empty()) {
|
| allstatus_.IncrementNudgeCounter(NUDGE_SOURCE_NOTIFICATION);
|
| scheduler_->ScheduleNudgeWithStatesAsync(
|
| TimeDelta::FromMilliseconds(kSyncSchedulerDelayMsec),
|
| NUDGE_SOURCE_NOTIFICATION,
|
| - type_state_map, FROM_HERE);
|
| + type_invalidation_map, FROM_HERE);
|
| allstatus_.IncrementNotificationsReceived();
|
| - UpdateNotificationInfo(type_state_map);
|
| - debug_info_event_listener_.OnIncomingNotification(type_state_map);
|
| + UpdateNotificationInfo(type_invalidation_map);
|
| + debug_info_event_listener_.OnIncomingNotification(type_invalidation_map);
|
| } else {
|
| LOG(WARNING) << "Sync received invalidation without any type information.";
|
| }
|
| @@ -1296,8 +1297,9 @@ void SyncManagerImpl::OnIncomingInvalidation(
|
| DictionaryValue details;
|
| ListValue* changed_types = new ListValue();
|
| details.Set("changedTypes", changed_types);
|
| - for (ModelTypeStateMap::const_iterator it = type_state_map.begin();
|
| - it != type_state_map.end(); ++it) {
|
| + for (ModelTypeInvalidationMap::const_iterator it =
|
| + type_invalidation_map.begin(); it != type_invalidation_map.end();
|
| + ++it) {
|
| const std::string& model_type_str =
|
| ModelTypeToString(it->first);
|
| changed_types->Append(Value::CreateStringValue(model_type_str));
|
|
|