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 0e3caf3e23f73566e817af1f0bcfd132152d50a8..d0ae30960d266eca3afc75dee22ff1b4149c9639 100644 |
--- a/sync/internal_api/sync_manager_impl.cc |
+++ b/sync/internal_api/sync_manager_impl.cc |
@@ -20,6 +20,7 @@ |
#include "sync/engine/syncer_types.h" |
#include "sync/internal_api/change_reorder_buffer.h" |
#include "sync/internal_api/public/base/cancelation_signal.h" |
+#include "sync/internal_api/public/base/invalidation_interface.h" |
#include "sync/internal_api/public/base/model_type.h" |
#include "sync/internal_api/public/base_node.h" |
#include "sync/internal_api/public/configure_reason.h" |
@@ -979,30 +980,17 @@ void SyncManagerImpl::OnInvalidatorStateChange(InvalidatorState state) { |
} |
void SyncManagerImpl::OnIncomingInvalidation( |
- const ObjectIdInvalidationMap& invalidation_map) { |
+ syncer::ModelType type, |
+ scoped_ptr<InvalidationInterface> invalidation) { |
DCHECK(thread_checker_.CalledOnValidThread()); |
- // We should never receive IDs from non-sync objects. |
- ObjectIdSet ids = invalidation_map.GetObjectIds(); |
- for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) { |
- ModelType type; |
- if (!ObjectIdToRealModelType(*it, &type)) { |
- DLOG(WARNING) << "Notification has invalid id: " << ObjectIdToString(*it); |
- } |
- } |
- |
- if (invalidation_map.Empty()) { |
- LOG(WARNING) << "Sync received invalidation without any type information."; |
- } else { |
- scheduler_->ScheduleInvalidationNudge( |
- TimeDelta::FromMilliseconds(kSyncSchedulerDelayMsec), |
- invalidation_map, FROM_HERE); |
- debug_info_event_listener_.OnIncomingNotification(invalidation_map); |
- } |
+ scheduler_->ScheduleInvalidationNudge( |
+ TimeDelta::FromMilliseconds(kSyncSchedulerDelayMsec), |
+ type, |
+ invalidation.Pass(), |
+ FROM_HERE); |
} |
-std::string SyncManagerImpl::GetOwnerName() const { return "SyncManagerImpl"; } |
- |
void SyncManagerImpl::RefreshTypes(ModelTypeSet types) { |
DCHECK(thread_checker_.CalledOnValidThread()); |
if (types.Empty()) { |