Index: sync/sessions/directory_type_debug_info_emitter.cc |
diff --git a/sync/sessions/directory_type_debug_info_emitter.cc b/sync/sessions/directory_type_debug_info_emitter.cc |
index 031d0eb756017f2f75288bc7e96aab688100f61e..c8228d23a4e85ff928eb48b3c2aa7c9153b68b1c 100644 |
--- a/sync/sessions/directory_type_debug_info_emitter.cc |
+++ b/sync/sessions/directory_type_debug_info_emitter.cc |
@@ -6,6 +6,7 @@ |
#include "sync/internal_api/public/sessions/status_counters.h" |
#include "sync/internal_api/public/sessions/type_debug_info_observer.h" |
+#include "sync/syncable/entry.h" |
#include "sync/syncable/syncable_read_transaction.h" |
namespace syncer { |
@@ -61,7 +62,27 @@ void DirectoryTypeDebugInfoEmitter::EmitUpdateCountersUpdate() { |
} |
void DirectoryTypeDebugInfoEmitter::EmitStatusCountersUpdate() { |
- // TODO(rlarocque): Implement this. Part of crbug.com/328606. |
+ // This is expensive. Avoid running this code unless about:sync is open. |
+ if (!type_debug_info_observers_->might_have_observers()) |
+ return; |
+ |
+ syncable::ReadTransaction trans(FROM_HERE, directory_); |
+ std::vector<int64> result; |
+ directory_->GetMetaHandlesOfType(&trans, type_, &result); |
+ |
+ StatusCounters counters; |
+ counters.num_entries_and_tombstones = result.size(); |
+ |
+ for (std::vector<int64>::const_iterator it = result.begin(); |
+ it != result.end(); ++it) { |
+ syncable::Entry e(&trans, syncable::GET_BY_HANDLE, *it); |
+ if (!e.GetIsDel()) { |
+ counters.num_entries++; |
+ } |
+ } |
+ |
+ FOR_EACH_OBSERVER(TypeDebugInfoObserver, (*type_debug_info_observers_), |
+ OnStatusCountersUpdated(type_, counters)); |
} |
} // namespace syncer |