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

Unified Diff: sync/notifier/sync_invalidation_listener.h

Issue 294123004: Move some sync/notifier to components/invalidation (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 6 years, 7 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
« no previous file with comments | « sync/notifier/state_writer.h ('k') | sync/notifier/sync_invalidation_listener.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/notifier/sync_invalidation_listener.h
diff --git a/sync/notifier/sync_invalidation_listener.h b/sync/notifier/sync_invalidation_listener.h
deleted file mode 100644
index aa332fb74db8f77e0dcb7c4608505177d97558e5..0000000000000000000000000000000000000000
--- a/sync/notifier/sync_invalidation_listener.h
+++ /dev/null
@@ -1,196 +0,0 @@
-// Copyright 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.
-//
-// A simple wrapper around invalidation::InvalidationClient that
-// handles all the startup/shutdown details and hookups.
-
-#ifndef SYNC_NOTIFIER_SYNC_INVALIDATION_LISTENER_H_
-#define SYNC_NOTIFIER_SYNC_INVALIDATION_LISTENER_H_
-
-#include <string>
-
-#include "base/basictypes.h"
-#include "base/callback_forward.h"
-#include "base/compiler_specific.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/memory/weak_ptr.h"
-#include "base/threading/non_thread_safe.h"
-#include "google/cacheinvalidation/include/invalidation-listener.h"
-#include "sync/base/sync_export.h"
-#include "sync/internal_api/public/util/weak_handle.h"
-#include "sync/notifier/ack_handler.h"
-#include "sync/notifier/invalidation_state_tracker.h"
-#include "sync/notifier/invalidator_state.h"
-#include "sync/notifier/state_writer.h"
-#include "sync/notifier/sync_system_resources.h"
-#include "sync/notifier/unacked_invalidation_set.h"
-
-namespace buzz {
-class XmppTaskParentInterface;
-} // namespace buzz
-
-namespace notifier {
-class PushClient;
-} // namespace notifier
-
-namespace syncer {
-
-class ObjectIdInvalidationMap;
-class RegistrationManager;
-
-// SyncInvalidationListener is not thread-safe and lives on the sync
-// thread.
-class SYNC_EXPORT_PRIVATE SyncInvalidationListener
- : public NON_EXPORTED_BASE(invalidation::InvalidationListener),
- public StateWriter,
- public SyncNetworkChannel::Observer,
- public AckHandler,
- public base::NonThreadSafe {
- public:
- typedef base::Callback<invalidation::InvalidationClient*(
- invalidation::SystemResources*,
- int,
- const invalidation::string&,
- const invalidation::string&,
- invalidation::InvalidationListener*)> CreateInvalidationClientCallback;
-
- class SYNC_EXPORT_PRIVATE Delegate {
- public:
- virtual ~Delegate();
-
- virtual void OnInvalidate(
- const ObjectIdInvalidationMap& invalidations) = 0;
-
- virtual void OnInvalidatorStateChange(InvalidatorState state) = 0;
- };
-
- explicit SyncInvalidationListener(
- scoped_ptr<SyncNetworkChannel> network_channel);
-
- // Calls Stop().
- virtual ~SyncInvalidationListener();
-
- // Does not take ownership of |delegate| or |state_writer|.
- // |invalidation_state_tracker| must be initialized.
- void Start(
- const CreateInvalidationClientCallback&
- create_invalidation_client_callback,
- const std::string& client_id, const std::string& client_info,
- const std::string& invalidation_bootstrap_data,
- const UnackedInvalidationsMap& initial_object_states,
- const WeakHandle<InvalidationStateTracker>& invalidation_state_tracker,
- Delegate* delegate);
-
- void UpdateCredentials(const std::string& email, const std::string& token);
-
- // Update the set of object IDs that we're interested in getting
- // notifications for. May be called at any time.
- void UpdateRegisteredIds(const ObjectIdSet& ids);
-
- // invalidation::InvalidationListener implementation.
- virtual void Ready(
- invalidation::InvalidationClient* client) OVERRIDE;
- virtual void Invalidate(
- invalidation::InvalidationClient* client,
- const invalidation::Invalidation& invalidation,
- const invalidation::AckHandle& ack_handle) OVERRIDE;
- virtual void InvalidateUnknownVersion(
- invalidation::InvalidationClient* client,
- const invalidation::ObjectId& object_id,
- const invalidation::AckHandle& ack_handle) OVERRIDE;
- virtual void InvalidateAll(
- invalidation::InvalidationClient* client,
- const invalidation::AckHandle& ack_handle) OVERRIDE;
- virtual void InformRegistrationStatus(
- invalidation::InvalidationClient* client,
- const invalidation::ObjectId& object_id,
- invalidation::InvalidationListener::RegistrationState reg_state) OVERRIDE;
- virtual void InformRegistrationFailure(
- invalidation::InvalidationClient* client,
- const invalidation::ObjectId& object_id,
- bool is_transient,
- const std::string& error_message) OVERRIDE;
- virtual void ReissueRegistrations(
- invalidation::InvalidationClient* client,
- const std::string& prefix,
- int prefix_length) OVERRIDE;
- virtual void InformError(
- invalidation::InvalidationClient* client,
- const invalidation::ErrorInfo& error_info) OVERRIDE;
-
- // AckHandler implementation.
- virtual void Acknowledge(
- const invalidation::ObjectId& id,
- const syncer::AckHandle& handle) OVERRIDE;
- virtual void Drop(
- const invalidation::ObjectId& id,
- const syncer::AckHandle& handle) OVERRIDE;
-
- // StateWriter implementation.
- virtual void WriteState(const std::string& state) OVERRIDE;
-
- // SyncNetworkChannel::Observer implementation.
- virtual void OnNetworkChannelStateChanged(
- InvalidatorState invalidator_state) OVERRIDE;
-
- void DoRegistrationUpdate();
-
- void RequestDetailedStatus(
- base::Callback<void(const base::DictionaryValue&)> callback) const;
-
- void StopForTest();
-
- private:
- void Stop();
-
- InvalidatorState GetState() const;
-
- void EmitStateChange();
-
- // Sends invalidations to their appropriate destination.
- //
- // If there are no observers registered for them, they will be saved for
- // later.
- //
- // If there are observers registered, they will be saved (to make sure we
- // don't drop them until they've been acted on) and emitted to the observers.
- void DispatchInvalidations(const ObjectIdInvalidationMap& invalidations);
-
- // Saves invalidations.
- //
- // This call isn't synchronous so we can't guarantee these invalidations will
- // be safely on disk by the end of the call, but it should ensure that the
- // data makes it to disk eventually.
- void SaveInvalidations(const ObjectIdInvalidationMap& to_save);
-
- // Emits previously saved invalidations to their registered observers.
- void EmitSavedInvalidations(const ObjectIdInvalidationMap& to_emit);
-
- // Generate a Dictionary with all the debugging information.
- scoped_ptr<base::DictionaryValue> CollectDebugData() const;
-
- WeakHandle<AckHandler> GetThisAsAckHandler();
-
- scoped_ptr<SyncNetworkChannel> sync_network_channel_;
- SyncSystemResources sync_system_resources_;
- UnackedInvalidationsMap unacked_invalidations_map_;
- WeakHandle<InvalidationStateTracker> invalidation_state_tracker_;
- Delegate* delegate_;
- scoped_ptr<invalidation::InvalidationClient> invalidation_client_;
- scoped_ptr<RegistrationManager> registration_manager_;
- // Stored to pass to |registration_manager_| on start.
- ObjectIdSet registered_ids_;
-
- // The states of the ticl and the push client.
- InvalidatorState ticl_state_;
- InvalidatorState push_client_state_;
-
- base::WeakPtrFactory<SyncInvalidationListener> weak_ptr_factory_;
-
- DISALLOW_COPY_AND_ASSIGN(SyncInvalidationListener);
-};
-
-} // namespace syncer
-
-#endif // SYNC_NOTIFIER_SYNC_INVALIDATION_LISTENER_H_
« no previous file with comments | « sync/notifier/state_writer.h ('k') | sync/notifier/sync_invalidation_listener.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698