| Index: sync/notifier/sync_notifier_helper.cc
|
| diff --git a/sync/notifier/sync_notifier_helper.cc b/sync/notifier/sync_notifier_helper.cc
|
| deleted file mode 100644
|
| index af3b2ea72d5587b1295b33bac027677b80ecdbe0..0000000000000000000000000000000000000000
|
| --- a/sync/notifier/sync_notifier_helper.cc
|
| +++ /dev/null
|
| @@ -1,95 +0,0 @@
|
| -// Copyright (c) 2012 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 "sync/notifier/sync_notifier_helper.h"
|
| -
|
| -#include "base/logging.h"
|
| -
|
| -namespace syncer {
|
| -
|
| -SyncNotifierHelper::SyncNotifierHelper() {}
|
| -SyncNotifierHelper::~SyncNotifierHelper() {}
|
| -
|
| -ObjectIdSet SyncNotifierHelper::UpdateRegisteredIds(
|
| - SyncNotifierObserver* handler, const ObjectIdSet& ids) {
|
| - if (ids.empty()) {
|
| - handlers_.RemoveObserver(handler);
|
| - } else if (!handlers_.HasObserver(handler)) {
|
| - handlers_.AddObserver(handler);
|
| - }
|
| -
|
| - ObjectIdSet registered_ids(ids);
|
| - // Remove all existing entries for |handler| and fill |registered_ids| with
|
| - // the rest.
|
| - for (ObjectIdHandlerMap::iterator it = id_to_handler_map_.begin();
|
| - it != id_to_handler_map_.end(); ) {
|
| - if (it->second == handler) {
|
| - ObjectIdHandlerMap::iterator erase_it = it;
|
| - ++it;
|
| - id_to_handler_map_.erase(erase_it);
|
| - } else {
|
| - registered_ids.insert(it->first);
|
| - ++it;
|
| - }
|
| - }
|
| -
|
| - // Now add the entries for |handler|. We keep track of the last insertion
|
| - // point so we only traverse the map once to insert all the new entries.
|
| - ObjectIdHandlerMap::iterator insert_it = id_to_handler_map_.begin();
|
| - for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
|
| - insert_it = id_to_handler_map_.insert(insert_it,
|
| - std::make_pair(*it, handler));
|
| - CHECK_EQ(handler, insert_it->second) << "Duplicate registration for "
|
| - << ObjectIdToString(insert_it->first);
|
| - }
|
| - if (logging::DEBUG_MODE) {
|
| - // The mapping shouldn't contain any handlers that aren't in |handlers_|.
|
| - for (ObjectIdHandlerMap::const_iterator it = id_to_handler_map_.begin();
|
| - it != id_to_handler_map_.end(); ++it) {
|
| - CHECK(handlers_.HasObserver(it->second));
|
| - }
|
| - }
|
| - return registered_ids;
|
| -}
|
| -
|
| -void SyncNotifierHelper::DispatchInvalidationsToHandlers(
|
| - const ObjectIdPayloadMap& id_payloads,
|
| - IncomingNotificationSource source) {
|
| - typedef std::map<SyncNotifierObserver*, ObjectIdPayloadMap> DispatchMap;
|
| - DispatchMap dispatch_map;
|
| - for (ObjectIdPayloadMap::const_iterator it = id_payloads.begin();
|
| - it != id_payloads.end(); ++it) {
|
| - ObjectIdHandlerMap::const_iterator find_it =
|
| - id_to_handler_map_.find(it->first);
|
| - // If we get an invalidation with a source type that we can't map to an
|
| - // observer, just drop it--the observer was unregistered while the
|
| - // invalidation was in flight.
|
| - if (find_it == id_to_handler_map_.end())
|
| - continue;
|
| - dispatch_map[find_it->second].insert(*it);
|
| - }
|
| -
|
| - if (handlers_.might_have_observers()) {
|
| - ObserverListBase<SyncNotifierObserver>::Iterator it(handlers_);
|
| - SyncNotifierObserver* handler = NULL;
|
| - while ((handler = it.GetNext()) != NULL) {
|
| - DispatchMap::const_iterator dispatch_it = dispatch_map.find(handler);
|
| - if (dispatch_it != dispatch_map.end()) {
|
| - handler->OnIncomingNotification(dispatch_it->second, source);
|
| - }
|
| - }
|
| - }
|
| -}
|
| -
|
| -void SyncNotifierHelper::EmitOnNotificationsEnabled() {
|
| - FOR_EACH_OBSERVER(SyncNotifierObserver, handlers_, OnNotificationsEnabled());
|
| -}
|
| -
|
| -void SyncNotifierHelper::EmitOnNotificationsDisabled(
|
| - NotificationsDisabledReason reason) {
|
| - FOR_EACH_OBSERVER(SyncNotifierObserver, handlers_,
|
| - OnNotificationsDisabled(reason));
|
| -}
|
| -
|
| -} // namespace syncer
|
|
|