Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(216)

Unified Diff: components/invalidation/invalidation_logger.cc

Issue 1191393008: Introduce a layering in the invalidation component as public and impl (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Explicitly forbid content to prevent future additions Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/invalidation/invalidation_logger.cc
diff --git a/components/invalidation/invalidation_logger.cc b/components/invalidation/invalidation_logger.cc
deleted file mode 100644
index c4326868f712decec7f17fa7e414087656f25a37..0000000000000000000000000000000000000000
--- a/components/invalidation/invalidation_logger.cc
+++ /dev/null
@@ -1,122 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "components/invalidation/invalidation_logger.h"
-
-#include "base/memory/scoped_ptr.h"
-#include "base/values.h"
-#include "components/invalidation/invalidation_handler.h"
-#include "components/invalidation/invalidation_logger_observer.h"
-
-namespace invalidation {
-class InvalidationLoggerObserver;
-
-InvalidationLogger::InvalidationLogger()
- : last_invalidator_state_(syncer::TRANSIENT_INVALIDATION_ERROR),
- last_invalidator_state_timestamp_(base::Time::Now()) { }
-
-InvalidationLogger::~InvalidationLogger() {}
-
-void InvalidationLogger::OnRegistration(const std::string& registrar_name) {
- registered_handlers_.insert(registrar_name);
- EmitRegisteredHandlers();
-}
-
-void InvalidationLogger::OnUnregistration(const std::string& registrar_name) {
- DCHECK(registered_handlers_.find(registrar_name) !=
- registered_handlers_.end());
- std::multiset<std::string>::iterator it =
- registered_handlers_.find(registrar_name);
- // Delete only one instance of registrar_name.
- registered_handlers_.erase(it);
- EmitRegisteredHandlers();
-}
-
-void InvalidationLogger::EmitRegisteredHandlers() {
- FOR_EACH_OBSERVER(InvalidationLoggerObserver, observer_list_,
- OnRegistrationChange(registered_handlers_));
-}
-
-void InvalidationLogger::OnStateChange(
- const syncer::InvalidatorState& new_state) {
- // Prevent spurious same state emissions from updating the timestamp.
- if (new_state != last_invalidator_state_)
- last_invalidator_state_timestamp_ = base::Time::Now();
- last_invalidator_state_ = new_state;
- EmitState();
-}
-
-void InvalidationLogger::EmitState() {
- FOR_EACH_OBSERVER(InvalidationLoggerObserver,
- observer_list_,
- OnStateChange(last_invalidator_state_,
- last_invalidator_state_timestamp_));
-}
-
-void InvalidationLogger::OnUpdateIds(
- std::map<std::string, syncer::ObjectIdSet> updated_ids) {
- for (std::map<std::string, syncer::ObjectIdSet>::const_iterator it =
- updated_ids.begin(); it != updated_ids.end(); ++it) {
- latest_ids_[it->first] = syncer::ObjectIdSet(it->second);
- }
- EmitUpdatedIds();
-}
-
-void InvalidationLogger::EmitUpdatedIds() {
- for (std::map<std::string, syncer::ObjectIdSet>::const_iterator it =
- latest_ids_.begin(); it != latest_ids_.end(); ++it) {
- const syncer::ObjectIdSet& object_ids_for_handler = it->second;
- syncer::ObjectIdCountMap per_object_invalidation_count;
- for (syncer::ObjectIdSet::const_iterator oid_it =
- object_ids_for_handler.begin();
- oid_it != object_ids_for_handler.end();
- ++oid_it) {
- per_object_invalidation_count[*oid_it] = invalidation_count_[*oid_it];
- }
- FOR_EACH_OBSERVER(InvalidationLoggerObserver,
- observer_list_,
- OnUpdateIds(it->first, per_object_invalidation_count));
- }
-}
-
-void InvalidationLogger::OnDebugMessage(const base::DictionaryValue& details) {
- FOR_EACH_OBSERVER(
- InvalidationLoggerObserver, observer_list_, OnDebugMessage(details));
-}
-
-void InvalidationLogger::OnInvalidation(
- const syncer::ObjectIdInvalidationMap& details) {
- std::vector<syncer::Invalidation> internal_invalidations;
- details.GetAllInvalidations(&internal_invalidations);
- for (std::vector<syncer::Invalidation>::const_iterator it =
- internal_invalidations.begin();
- it != internal_invalidations.end();
- ++it) {
- invalidation_count_[it->object_id()]++;
- }
- FOR_EACH_OBSERVER(
- InvalidationLoggerObserver, observer_list_, OnInvalidation(details));
-}
-
-void InvalidationLogger::EmitContent() {
- EmitState();
- EmitUpdatedIds();
- EmitRegisteredHandlers();
-}
-
-void InvalidationLogger::RegisterObserver(
- InvalidationLoggerObserver* debug_observer) {
- observer_list_.AddObserver(debug_observer);
-}
-
-void InvalidationLogger::UnregisterObserver(
- InvalidationLoggerObserver* debug_observer) {
- observer_list_.RemoveObserver(debug_observer);
-}
-
-bool InvalidationLogger::IsObserverRegistered(
- const InvalidationLoggerObserver* debug_observer) const {
- return observer_list_.HasObserver(debug_observer);
-}
-} // namespace invalidation
« no previous file with comments | « components/invalidation/invalidation_logger.h ('k') | components/invalidation/invalidation_logger_observer.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698