Index: sync/engine/process_updates_util.cc |
diff --git a/sync/engine/process_updates_util.cc b/sync/engine/process_updates_util.cc |
index 7cfb920c68388ef2dd491dfc071b96936ec9fda5..dca46ab7cfae99ee54acf7af924d0fd5123f20ca 100644 |
--- a/sync/engine/process_updates_util.cc |
+++ b/sync/engine/process_updates_util.cc |
@@ -8,6 +8,7 @@ |
#include "sync/engine/syncer_proto_util.h" |
#include "sync/engine/syncer_types.h" |
#include "sync/engine/syncer_util.h" |
+#include "sync/internal_api/public/sessions/update_counters.h" |
#include "sync/syncable/directory.h" |
#include "sync/syncable/model_neutral_mutable_entry.h" |
#include "sync/syncable/syncable_model_neutral_write_transaction.h" |
@@ -285,14 +286,19 @@ void ProcessDownloadedUpdates( |
syncable::ModelNeutralWriteTransaction* trans, |
ModelType type, |
const SyncEntityList& applicable_updates, |
- sessions::StatusController* status) { |
+ sessions::StatusController* status, |
+ UpdateCounters* counters) { |
for (SyncEntityList::const_iterator update_it = applicable_updates.begin(); |
update_it != applicable_updates.end(); ++update_it) { |
DCHECK_EQ(type, GetModelType(**update_it)); |
- if (!UpdateContainsNewVersion(trans, **update_it)) |
+ if (!UpdateContainsNewVersion(trans, **update_it)) { |
status->increment_num_reflected_updates_downloaded_by(1); |
- if ((*update_it)->deleted()) |
+ counters->num_reflected_updates_received++; |
+ } |
+ if ((*update_it)->deleted()) { |
status->increment_num_tombstone_updates_downloaded_by(1); |
+ counters->num_tombstone_updates_received++; |
+ } |
VerifyResult verify_result = VerifyUpdate(trans, **update_it, type); |
if (verify_result != VERIFY_SUCCESS && verify_result != VERIFY_UNDELETE) |
continue; |