| // 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. |
| |
| #ifndef SYNC_INTERNAL_API_SYNC_CORE_PROXY_IMPL_H_ |
| #define SYNC_INTERNAL_API_SYNC_CORE_PROXY_IMPL_H_ |
| |
| #include "base/memory/scoped_ptr.h" |
| #include "base/memory/weak_ptr.h" |
| #include "base/sequenced_task_runner.h" |
| #include "sync/base/sync_export.h" |
| #include "sync/internal_api/public/base/model_type.h" |
| #include "sync/internal_api/public/sync_core_proxy.h" |
| |
| namespace syncer { |
| |
| class SyncCore; |
| class NonBlockingTypeProcessor; |
| struct DataTypeState; |
| |
| // Encapsulates a reference to the sync core and the thread it's running on. |
| // Used by sync's data types to connect with the sync core. |
| // |
| // It is epxected that this object will be copied to and used on many different |
| // threads. It is small and safe to pass by value. |
| class SYNC_EXPORT_PRIVATE SyncCoreProxyImpl : public SyncCoreProxy { |
| public: |
| SyncCoreProxyImpl( |
| scoped_refptr<base::SequencedTaskRunner> sync_task_runner, |
| base::WeakPtr<SyncCore> sync_core); |
| virtual ~SyncCoreProxyImpl(); |
| |
| // Attempts to connect a non-blocking type to the sync core. |
| // |
| // This may fail under some unusual circumstances, like shutdown. Due to the |
| // nature of WeakPtrs and cross-thread communication, the caller will be |
| // unable to distinguish a slow success from failure. |
| // |
| // Must be called from the thread where the data type lives. |
| virtual void ConnectTypeToCore( |
| syncer::ModelType type, |
| const DataTypeState& data_type_state, |
| base::WeakPtr<NonBlockingTypeProcessor> type_processor) OVERRIDE; |
| |
| // Disables syncing for the given type on the sync thread. |
| virtual void Disconnect(syncer::ModelType type) OVERRIDE; |
| |
| virtual scoped_ptr<SyncCoreProxy> Clone() const OVERRIDE; |
| |
| private: |
| // A SequencedTaskRunner representing the thread where the SyncCore lives. |
| scoped_refptr<base::SequencedTaskRunner> sync_task_runner_; |
| |
| // The SyncCore this object is wrapping. |
| base::WeakPtr<SyncCore> sync_core_; |
| }; |
| |
| } // namespace syncer |
| |
| #endif // SYNC_INTERNAL_API_SYNC_CORE_PROXY_IMPL_H_ |