| 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
|
|
|