Add non-blocking sync code to ProfileSyncService

chrome/browser/sync/glue/sync_backend_host_impl.h

 // Copyright 2013 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 CHROME_BROWSER_SYNC_GLUE_SYNC_BACKEND_HOST_IMPL_H_
 #define CHROME_BROWSER_SYNC_GLUE_SYNC_BACKEND_HOST_IMPL_H_
 
 #include <string>
 
 #include "base/basictypes.h"
@@ skipping 82 matching lines @@
       const syncer::SyncCredentials& credentials) OVERRIDE;
   virtual void StartSyncingWithServer() OVERRIDE;
   virtual void SetEncryptionPassphrase(
       const std::string& passphrase,
       bool is_explicit) OVERRIDE;
   virtual bool SetDecryptionPassphrase(const std::string& passphrase)
       OVERRIDE WARN_UNUSED_RESULT;
   virtual void StopSyncingForShutdown() OVERRIDE;
   virtual scoped_ptr<base::Thread> Shutdown(ShutdownOption option) OVERRIDE;
   virtual void UnregisterInvalidationIds() OVERRIDE;
+  virtual void SetPreferredNonBlockingTypes(
+      syncer::ModelTypeSet types) OVERRIDE;
   virtual void ConfigureDataTypes(
       syncer::ConfigureReason reason,
       const DataTypeConfigStateMap& config_state_map,
       const base::Callback<void(syncer::ModelTypeSet,
                                 syncer::ModelTypeSet)>& ready_task,
       const base::Callback<void()>& retry_callback) OVERRIDE;
   virtual void EnableEncryptEverything() OVERRIDE;
   virtual void ActivateDataType(
       syncer::ModelType type, syncer::ModelSafeGroup group,
       ChangeProcessor* change_processor) OVERRIDE;
   virtual void DeactivateDataType(syncer::ModelType type) OVERRIDE;
   virtual syncer::UserShare* GetUserShare() const OVERRIDE;
+  virtual syncer::SyncCoreProxy GetSyncCoreProxy() OVERRIDE;
   virtual Status GetDetailedStatus() OVERRIDE;
   virtual syncer::sessions::SyncSessionSnapshot
       GetLastSessionSnapshot() const OVERRIDE;
   virtual bool HasUnsyncedItems() const OVERRIDE;
   virtual bool IsNigoriEnabled() const OVERRIDE;
   virtual syncer::PassphraseType GetPassphraseType() const OVERRIDE;
   virtual base::Time GetExplicitPassphraseTime() const OVERRIDE;
   virtual bool IsCryptographerReady(
       const syncer::BaseTransaction* trans) const OVERRIDE;
   virtual void GetModelSafeRoutingInfo(
@@ skipping 29 matching lines @@
       const syncer::ModelTypeSet succeeded_configuration_types,
       const syncer::ModelTypeSet failed_configuration_types,
       const base::Callback<void(syncer::ModelTypeSet,
                                 syncer::ModelTypeSet)>& ready_task);
 
   // Reports backend initialization success.  Includes some objects from sync
   // manager initialization to be passed back to the UI thread.
   virtual void HandleInitializationSuccessOnFrontendLoop(
     const syncer::WeakHandle<syncer::JsBackend> js_backend,
     const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>
-        debug_info_listener);
+        debug_info_listener,
+    base::WeakPtr<syncer::SyncCore> sync_core);
 
   // Downloading of control types failed and will be retried. Invokes the
   // frontend's sync configure retry method.
   void HandleControlTypesDownloadRetry();
 
   // Forwards a ProtocolEvent to the frontend.  Will not be called unless a
   // call to SetForwardProtocolEvents() explicitly requested that we start
   // forwarding these events.
   void HandleProtocolEventOnFrontendLoop(syncer::ProtocolEvent* event);
 
@@ skipping 75 matching lines @@
       syncer::PassphraseType type,
       base::Time explicit_passphrase_time);
 
   void HandleStopSyncingPermanentlyOnFrontendLoop();
 
   // Dispatched to from OnConnectionStatusChange to handle updating
   // frontend UI components.
   void HandleConnectionStatusChangeOnFrontendLoop(
       syncer::ConnectionStatus status);
 
+  // Re-registers the appropriate set of ObjectIds with the invalidator.
+  void UpdateRegisteredInvalidationTypes();
+
   // NotificationObserver implementation.
   virtual void Observe(
     int type,
     const content::NotificationSource& source,
     const content::NotificationDetails& details) OVERRIDE;
 
   // InvalidationHandler implementation.
   virtual void OnInvalidatorStateChange(
       syncer::InvalidatorState state) OVERRIDE;
   virtual void OnIncomingInvalidation(
       const syncer::ObjectIdInvalidationMap& invalidation_map) OVERRIDE;
   virtual std::string GetOwnerName() const OVERRIDE;
 
   content::NotificationRegistrar notification_registrar_;
 
   // A reference to the MessageLoop used to construct |this|, so we know how
   // to safely talk back to the SyncFrontend.
   base::MessageLoop* const frontend_loop_;
 
   Profile* const profile_;
 
   // Name used for debugging (set from profile_->GetDebugName()).
   const std::string name_;
 
   // Our core, which communicates directly to the syncapi. Use refptr instead
   // of WeakHandle because |core_| is created on UI loop but released on
   // sync loop.
   scoped_refptr<SyncBackendHostCore> core_;
 
+  // A handle referencing the main interface for non-blocking sync types.
+  scoped_ptr<syncer::SyncCoreProxy> sync_core_proxy_;
+
   bool initialized_;
 
   const base::WeakPtr<sync_driver::SyncPrefs> sync_prefs_;
 
   ExtensionsActivityMonitor extensions_activity_monitor_;
 
   scoped_ptr<SyncBackendRegistrar> registrar_;
 
   // The frontend which we serve (and are owned by).
   SyncFrontend* frontend_;
@@ skipping 17 matching lines @@
   // If an explicit passphrase is in use, the time at which the passphrase was
   // first set (if available).
   base::Time cached_explicit_passphrase_time_;
 
   // UI-thread cache of the last SyncSessionSnapshot received from syncapi.
   syncer::sessions::SyncSessionSnapshot last_snapshot_;
 
   invalidation::InvalidationService* invalidator_;
   bool invalidation_handler_registered_;
 
+  // The set of enabled directory types, as of the last successful configure.
+  syncer::ModelTypeSet enabled_directory_types_;
+
+  // The set of preferred non-blocking types, as set by the frontend.
+  syncer::ModelTypeSet preferred_non_blocking_types_;
+
   base::WeakPtrFactory<SyncBackendHostImpl> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(SyncBackendHostImpl);
 };
 
 }  // namespace browser_sync
 
 #endif  // CHROME_BROWSER_SYNC_GLUE_SYNC_BACKEND_HOST_IMPL_H_