| Index: sync/notifier/sync_invalidation_listener.cc
|
| diff --git a/sync/notifier/sync_invalidation_listener.cc b/sync/notifier/sync_invalidation_listener.cc
|
| index 1b235010bf598e924ef9607c410da7b94b64e1fc..e84bc3893b20c633e93c092c4a6e0c6071f9380a 100644
|
| --- a/sync/notifier/sync_invalidation_listener.cc
|
| +++ b/sync/notifier/sync_invalidation_listener.cc
|
| @@ -148,19 +148,20 @@ void SyncInvalidationListener::Invalidate(
|
| client->Acknowledge(ack_handle);
|
| return;
|
| }
|
| - DVLOG(2) << "Setting max invalidation version for " << ObjectIdToString(id)
|
| - << " to " << invalidation.version();
|
| - invalidation_state_map_[id].version = invalidation.version();
|
| - invalidation_state_tracker_.Call(
|
| - FROM_HERE,
|
| - &InvalidationStateTracker::SetMaxVersion,
|
| - id, invalidation.version());
|
|
|
| std::string payload;
|
| // payload() CHECK()'s has_payload(), so we must check it ourselves first.
|
| if (invalidation.has_payload())
|
| payload = invalidation.payload();
|
|
|
| + DVLOG(2) << "Setting max invalidation version for " << ObjectIdToString(id)
|
| + << " to " << invalidation.version();
|
| + invalidation_state_map_[id].version = invalidation.version();
|
| + invalidation_state_tracker_.Call(
|
| + FROM_HERE,
|
| + &InvalidationStateTracker::SetMaxVersionAndPayload,
|
| + id, invalidation.version(), payload);
|
| +
|
| ObjectIdInvalidationMap invalidation_map;
|
| invalidation_map[id].payload = payload;
|
| EmitInvalidation(invalidation_map);
|
|
|