Index: sync/internal_api/public/sync_manager.h |
diff --git a/sync/internal_api/public/sync_manager.h b/sync/internal_api/public/sync_manager.h |
deleted file mode 100644 |
index 1e9cb34b2a4bdeda4f5e0f8305eb690cab2603e1..0000000000000000000000000000000000000000 |
--- a/sync/internal_api/public/sync_manager.h |
+++ /dev/null |
@@ -1,413 +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. |
- |
-#ifndef SYNC_INTERNAL_API_PUBLIC_SYNC_MANAGER_H_ |
-#define SYNC_INTERNAL_API_PUBLIC_SYNC_MANAGER_H_ |
- |
-#include <stdint.h> |
- |
-#include <memory> |
-#include <string> |
-#include <vector> |
- |
-#include "base/callback.h" |
-#include "base/files/file_path.h" |
-#include "base/memory/ref_counted.h" |
-#include "base/memory/scoped_vector.h" |
-#include "base/task_runner.h" |
-#include "base/threading/thread_checker.h" |
-#include "google_apis/gaia/oauth2_token_service.h" |
-#include "sync/base/sync_export.h" |
-#include "sync/internal_api/public/base/invalidation_interface.h" |
-#include "sync/internal_api/public/base/model_type.h" |
-#include "sync/internal_api/public/change_record.h" |
-#include "sync/internal_api/public/configure_reason.h" |
-#include "sync/internal_api/public/connection_status.h" |
-#include "sync/internal_api/public/engine/model_safe_worker.h" |
-#include "sync/internal_api/public/engine/sync_status.h" |
-#include "sync/internal_api/public/events/protocol_event.h" |
-#include "sync/internal_api/public/http_post_provider_factory.h" |
-#include "sync/internal_api/public/internal_components_factory.h" |
-#include "sync/internal_api/public/model_type_connector.h" |
-#include "sync/internal_api/public/shutdown_reason.h" |
-#include "sync/internal_api/public/sync_encryption_handler.h" |
-#include "sync/internal_api/public/util/weak_handle.h" |
-#include "sync/protocol/sync_protocol_error.h" |
- |
-class GURL; |
- |
-namespace sync_pb { |
-class EncryptedData; |
-} // namespace sync_pb |
- |
-namespace syncer { |
- |
-class BaseTransaction; |
-class CancelationSignal; |
-class DataTypeDebugInfoListener; |
-class Encryptor; |
-class ExtensionsActivity; |
-class InternalComponentsFactory; |
-class JsBackend; |
-class JsEventHandler; |
-class ProtocolEvent; |
-class SyncEncryptionHandler; |
-class SyncScheduler; |
-class TypeDebugInfoObserver; |
-class UnrecoverableErrorHandler; |
-struct Experiments; |
-struct UserShare; |
- |
-namespace sessions { |
-class SyncSessionSnapshot; |
-} // namespace sessions |
- |
-// Contains everything needed to talk to and identify a user account. |
-struct SYNC_EXPORT SyncCredentials { |
- SyncCredentials(); |
- SyncCredentials(const SyncCredentials& other); |
- ~SyncCredentials(); |
- |
- // Account_id of signed in account. |
- std::string account_id; |
- |
- // The email associated with this account. |
- std::string email; |
- |
- // The raw authentication token's bytes. |
- std::string sync_token; |
- |
- // The set of scopes to use when talking to sync server. |
- OAuth2TokenService::ScopeSet scope_set; |
-}; |
- |
-// SyncManager encapsulates syncable::Directory and serves as the parent of all |
-// other objects in the sync API. If multiple threads interact with the same |
-// local sync repository (i.e. the same sqlite database), they should share a |
-// single SyncManager instance. The caller should typically create one |
-// SyncManager for the lifetime of a user session. |
-// |
-// Unless stated otherwise, all methods of SyncManager should be called on the |
-// same thread. |
-class SYNC_EXPORT SyncManager { |
- public: |
- // An interface the embedding application implements to be notified |
- // on change events. Note that these methods may be called on *any* |
- // thread. |
- class SYNC_EXPORT ChangeDelegate { |
- public: |
- // Notify the delegate that changes have been applied to the sync model. |
- // |
- // This will be invoked on the same thread as on which ApplyChanges was |
- // called. |changes| is an array of size |change_count|, and contains the |
- // ID of each individual item that was changed. |changes| exists only for |
- // the duration of the call. If items of multiple data types change at |
- // the same time, this method is invoked once per data type and |changes| |
- // is restricted to items of the ModelType indicated by |model_type|. |
- // Because the observer is passed a |trans|, the observer can assume a |
- // read lock on the sync model that will be released after the function |
- // returns. |
- // |
- // The SyncManager constructs |changes| in the following guaranteed order: |
- // |
- // 1. Deletions, from leaves up to parents. |
- // 2. Updates to existing items with synced parents & predecessors. |
- // 3. New items with synced parents & predecessors. |
- // 4. Items with parents & predecessors in |changes|. |
- // 5. Repeat #4 until all items are in |changes|. |
- // |
- // Thus, an implementation of OnChangesApplied should be able to |
- // process the change records in the order without having to worry about |
- // forward dependencies. But since deletions come before reparent |
- // operations, a delete may temporarily orphan a node that is |
- // updated later in the list. |
- virtual void OnChangesApplied(ModelType model_type, |
- int64_t model_version, |
- const BaseTransaction* trans, |
- const ImmutableChangeRecordList& changes) = 0; |
- |
- // OnChangesComplete gets called when the TransactionComplete event is |
- // posted (after OnChangesApplied finishes), after the transaction lock |
- // and the change channel mutex are released. |
- // |
- // The purpose of this function is to support processors that require |
- // split-transactions changes. For example, if a model processor wants to |
- // perform blocking I/O due to a change, it should calculate the changes |
- // while holding the transaction lock (from within OnChangesApplied), buffer |
- // those changes, let the transaction fall out of scope, and then commit |
- // those changes from within OnChangesComplete (postponing the blocking |
- // I/O to when it no longer holds any lock). |
- virtual void OnChangesComplete(ModelType model_type) = 0; |
- |
- protected: |
- virtual ~ChangeDelegate(); |
- }; |
- |
- // Like ChangeDelegate, except called only on the sync thread and |
- // not while a transaction is held. For objects that want to know |
- // when changes happen, but don't need to process them. |
- class SYNC_EXPORT ChangeObserver { |
- public: |
- // Ids referred to in |changes| may or may not be in the write |
- // transaction specified by |write_transaction_id|. If they're |
- // not, that means that the node didn't actually change, but we |
- // marked them as changed for some other reason (e.g., siblings of |
- // re-ordered nodes). |
- // |
- // TODO(sync, long-term): Ideally, ChangeDelegate/Observer would |
- // be passed a transformed version of EntryKernelMutation instead |
- // of a transaction that would have to be used to look up the |
- // changed nodes. That is, ChangeDelegate::OnChangesApplied() |
- // would still be called under the transaction, but all the needed |
- // data will be passed down. |
- // |
- // Even more ideally, we would have sync semantics such that we'd |
- // be able to apply changes without being under a transaction. |
- // But that's a ways off... |
- virtual void OnChangesApplied(ModelType model_type, |
- int64_t write_transaction_id, |
- const ImmutableChangeRecordList& changes) = 0; |
- |
- virtual void OnChangesComplete(ModelType model_type) = 0; |
- |
- protected: |
- virtual ~ChangeObserver(); |
- }; |
- |
- // An interface the embedding application implements to receive |
- // notifications from the SyncManager. Register an observer via |
- // SyncManager::AddObserver. All methods are called only on the |
- // sync thread. |
- class SYNC_EXPORT Observer { |
- public: |
- // A round-trip sync-cycle took place and the syncer has resolved any |
- // conflicts that may have arisen. |
- virtual void OnSyncCycleCompleted( |
- const sessions::SyncSessionSnapshot& snapshot) = 0; |
- |
- // Called when the status of the connection to the sync server has |
- // changed. |
- virtual void OnConnectionStatusChange(ConnectionStatus status) = 0; |
- |
- // Called when initialization is complete to the point that SyncManager can |
- // process changes. This does not necessarily mean authentication succeeded |
- // or that the SyncManager is online. |
- // IMPORTANT: Creating any type of transaction before receiving this |
- // notification is illegal! |
- // WARNING: Calling methods on the SyncManager before receiving this |
- // message, unless otherwise specified, produces undefined behavior. |
- |
- virtual void OnInitializationComplete( |
- const WeakHandle<JsBackend>& js_backend, |
- const WeakHandle<DataTypeDebugInfoListener>& debug_info_listener, |
- bool success, |
- ModelTypeSet restored_types) = 0; |
- |
- virtual void OnActionableError( |
- const SyncProtocolError& sync_protocol_error) = 0; |
- |
- virtual void OnMigrationRequested(ModelTypeSet types) = 0; |
- |
- virtual void OnProtocolEvent(const ProtocolEvent& event) = 0; |
- |
- protected: |
- virtual ~Observer(); |
- }; |
- |
- // Arguments for initializing SyncManager. |
- struct SYNC_EXPORT InitArgs { |
- InitArgs(); |
- ~InitArgs(); |
- |
- // Path in which to create or open sync's sqlite database (aka the |
- // directory). |
- base::FilePath database_location; |
- |
- // Used to propagate events to chrome://sync-internals. Optional. |
- WeakHandle<JsEventHandler> event_handler; |
- |
- // URL of the sync server. |
- GURL service_url; |
- |
- // Used to communicate with the sync server. |
- std::unique_ptr<HttpPostProviderFactory> post_factory; |
- |
- std::vector<scoped_refptr<ModelSafeWorker> > workers; |
- |
- // Must outlive SyncManager. |
- ExtensionsActivity* extensions_activity; |
- |
- // Must outlive SyncManager. |
- ChangeDelegate* change_delegate; |
- |
- // Credentials to be used when talking to the sync server. |
- SyncCredentials credentials; |
- |
- // Unqiuely identifies this client to the invalidation notification server. |
- std::string invalidator_client_id; |
- |
- // Used to boostrap the cryptographer. |
- std::string restored_key_for_bootstrapping; |
- std::string restored_keystore_key_for_bootstrapping; |
- |
- std::unique_ptr<InternalComponentsFactory> internal_components_factory; |
- |
- // Must outlive SyncManager. |
- Encryptor* encryptor; |
- |
- WeakHandle<UnrecoverableErrorHandler> unrecoverable_error_handler; |
- base::Closure report_unrecoverable_error_function; |
- |
- // Carries shutdown requests across threads and will be used to cut short |
- // any network I/O and tell the syncer to exit early. |
- // |
- // Must outlive SyncManager. |
- CancelationSignal* cancelation_signal; |
- |
- // Optional nigori state to be restored. |
- std::unique_ptr<SyncEncryptionHandler::NigoriState> saved_nigori_state; |
- }; |
- |
- typedef base::Callback<void(void)> ClearServerDataCallback; |
- |
- SyncManager(); |
- virtual ~SyncManager(); |
- |
- // Initialize the sync manager using arguments from |args|. |
- // |
- // Note, args is passed by non-const pointer because it contains objects like |
- // unique_ptr. |
- virtual void Init(InitArgs* args) = 0; |
- |
- virtual ModelTypeSet InitialSyncEndedTypes() = 0; |
- |
- // Returns those types within |types| that have an empty progress marker |
- // token. |
- virtual ModelTypeSet GetTypesWithEmptyProgressMarkerToken( |
- ModelTypeSet types) = 0; |
- |
- // Purge from the directory those types with non-empty progress markers |
- // but without initial synced ended set. |
- // Returns false if an error occurred, true otherwise. |
- virtual bool PurgePartiallySyncedTypes() = 0; |
- |
- // Update tokens that we're using in Sync. Email must stay the same. |
- virtual void UpdateCredentials(const SyncCredentials& credentials) = 0; |
- |
- // Put the syncer in normal mode ready to perform nudges and polls. |
- virtual void StartSyncingNormally( |
- const ModelSafeRoutingInfo& routing_info, |
- base::Time last_poll_time) = 0; |
- |
- // Switches the mode of operation to CONFIGURATION_MODE and performs |
- // any configuration tasks needed as determined by the params. Once complete, |
- // syncer will remain in CONFIGURATION_MODE until StartSyncingNormally is |
- // called. |
- // Data whose types are not in |new_routing_info| are purged from sync |
- // directory, unless they're part of |to_ignore|, in which case they're left |
- // untouched. The purged data is backed up in delete journal for recovery in |
- // next session if its type is in |to_journal|. If in |to_unapply| |
- // only the local data is removed; the server data is preserved. |
- // |ready_task| is invoked when the configuration completes. |
- // |retry_task| is invoked if the configuration job could not immediately |
- // execute. |ready_task| will still be called when it eventually |
- // does finish. |
- virtual void ConfigureSyncer( |
- ConfigureReason reason, |
- ModelTypeSet to_download, |
- ModelTypeSet to_purge, |
- ModelTypeSet to_journal, |
- ModelTypeSet to_unapply, |
- const ModelSafeRoutingInfo& new_routing_info, |
- const base::Closure& ready_task, |
- const base::Closure& retry_task) = 0; |
- |
- // Inform the syncer of a change in the invalidator's state. |
- virtual void SetInvalidatorEnabled(bool invalidator_enabled) = 0; |
- |
- // Inform the syncer that its cached information about a type is obsolete. |
- virtual void OnIncomingInvalidation( |
- syncer::ModelType type, |
- std::unique_ptr<syncer::InvalidationInterface> invalidation) = 0; |
- |
- // Adds a listener to be notified of sync events. |
- // NOTE: It is OK (in fact, it's probably a good idea) to call this before |
- // having received OnInitializationCompleted. |
- virtual void AddObserver(Observer* observer) = 0; |
- |
- // Remove the given observer. Make sure to call this if the |
- // Observer is being destroyed so the SyncManager doesn't |
- // potentially dereference garbage. |
- virtual void RemoveObserver(Observer* observer) = 0; |
- |
- // Status-related getter. May be called on any thread. |
- virtual SyncStatus GetDetailedStatus() const = 0; |
- |
- // Call periodically from a database-safe thread to persist recent changes |
- // to the syncapi model. |
- virtual void SaveChanges() = 0; |
- |
- // Issue a final SaveChanges, and close sqlite handles. |
- virtual void ShutdownOnSyncThread(ShutdownReason reason) = 0; |
- |
- // May be called from any thread. |
- virtual UserShare* GetUserShare() = 0; |
- |
- // Returns an instance of the main interface for non-blocking sync types. |
- virtual std::unique_ptr<syncer_v2::ModelTypeConnector> |
- GetModelTypeConnectorProxy() = 0; |
- |
- // Returns the cache_guid of the currently open database. |
- // Requires that the SyncManager be initialized. |
- virtual const std::string cache_guid() = 0; |
- |
- // Reads the nigori node to determine if any experimental features should |
- // be enabled. |
- // Note: opens a transaction. May be called on any thread. |
- virtual bool ReceivedExperiment(Experiments* experiments) = 0; |
- |
- // Uses a read-only transaction to determine if the directory being synced has |
- // any remaining unsynced items. May be called on any thread. |
- virtual bool HasUnsyncedItems() = 0; |
- |
- // Returns the SyncManager's encryption handler. |
- virtual SyncEncryptionHandler* GetEncryptionHandler() = 0; |
- |
- virtual std::unique_ptr<base::ListValue> GetAllNodesForType( |
- syncer::ModelType type) = 0; |
- |
- // Ask the SyncManager to fetch updates for the given types. |
- virtual void RefreshTypes(ModelTypeSet types) = 0; |
- |
- // Returns any buffered protocol events. Does not clear the buffer. |
- virtual ScopedVector<syncer::ProtocolEvent> GetBufferedProtocolEvents() = 0; |
- |
- // Functions to manage registrations of DebugInfoObservers. |
- virtual void RegisterDirectoryTypeDebugInfoObserver( |
- syncer::TypeDebugInfoObserver* observer) = 0; |
- virtual void UnregisterDirectoryTypeDebugInfoObserver( |
- syncer::TypeDebugInfoObserver* observer) = 0; |
- virtual bool HasDirectoryTypeDebugInfoObserver( |
- syncer::TypeDebugInfoObserver* observer) = 0; |
- |
- // Request that all current counter values be emitted as though they had just |
- // been updated. Useful for initializing new observers' state. |
- virtual void RequestEmitDebugInfo() = 0; |
- |
- // Clears server data and invokes |callback| when complete. |
- // |
- // This is an asynchronous operation that requires interaction with the sync |
- // server. The operation will automatically be retried with backoff until it |
- // completes successfully or sync is shutdown. |
- virtual void ClearServerData(const ClearServerDataCallback& callback) = 0; |
- |
- // Updates Sync's tracking of whether the cookie jar has a mismatch with the |
- // chrome account. See ClientConfigParams proto message for more info. |
- // Note: this does not trigger a sync cycle. It just updates the sync context. |
- virtual void OnCookieJarChanged(bool account_mismatch, bool empty_jar) = 0; |
-}; |
- |
-} // namespace syncer |
- |
-#endif // SYNC_INTERNAL_API_PUBLIC_SYNC_MANAGER_H_ |