Index: components/sync/engine_impl/model_type_registry.cc |
diff --git a/components/sync/engine_impl/model_type_registry.cc b/components/sync/engine_impl/model_type_registry.cc |
index e6b3fba780e3445e5d011d852c4a2debc2f5c16c..3e986ecf098ba64ec6529d9ad63ceb6ade18da92 100644 |
--- a/components/sync/engine_impl/model_type_registry.cc |
+++ b/components/sync/engine_impl/model_type_registry.cc |
@@ -25,31 +25,29 @@ namespace syncer { |
namespace { |
-class CommitQueueProxy : public syncer_v2::CommitQueue { |
+class CommitQueueProxy : public CommitQueue { |
public: |
- CommitQueueProxy(const base::WeakPtr<syncer_v2::ModelTypeWorker>& worker, |
+ CommitQueueProxy(const base::WeakPtr<ModelTypeWorker>& worker, |
const scoped_refptr<base::SequencedTaskRunner>& sync_thread); |
~CommitQueueProxy() override; |
- void EnqueueForCommit(const syncer_v2::CommitRequestDataList& list) override; |
+ void EnqueueForCommit(const CommitRequestDataList& list) override; |
private: |
- base::WeakPtr<syncer_v2::ModelTypeWorker> worker_; |
+ base::WeakPtr<ModelTypeWorker> worker_; |
scoped_refptr<base::SequencedTaskRunner> sync_thread_; |
}; |
CommitQueueProxy::CommitQueueProxy( |
- const base::WeakPtr<syncer_v2::ModelTypeWorker>& worker, |
+ const base::WeakPtr<ModelTypeWorker>& worker, |
const scoped_refptr<base::SequencedTaskRunner>& sync_thread) |
: worker_(worker), sync_thread_(sync_thread) {} |
CommitQueueProxy::~CommitQueueProxy() {} |
-void CommitQueueProxy::EnqueueForCommit( |
- const syncer_v2::CommitRequestDataList& list) { |
+void CommitQueueProxy::EnqueueForCommit(const CommitRequestDataList& list) { |
sync_thread_->PostTask( |
- FROM_HERE, |
- base::Bind(&syncer_v2::ModelTypeWorker::EnqueueForCommit, worker_, list)); |
+ FROM_HERE, base::Bind(&ModelTypeWorker::EnqueueForCommit, worker_, list)); |
} |
} // namespace |
@@ -140,27 +138,23 @@ void ModelTypeRegistry::SetEnabledDirectoryTypes( |
void ModelTypeRegistry::ConnectType( |
ModelType type, |
- std::unique_ptr<syncer_v2::ActivationContext> activation_context) { |
+ std::unique_ptr<ActivationContext> activation_context) { |
DVLOG(1) << "Enabling an off-thread sync type: " << ModelTypeToString(type); |
// Initialize Worker -> Processor communication channel. |
- syncer_v2::ModelTypeProcessor* type_processor = |
- activation_context->type_processor.get(); |
+ ModelTypeProcessor* type_processor = activation_context->type_processor.get(); |
std::unique_ptr<Cryptographer> cryptographer_copy; |
if (encrypted_types_.Has(type)) |
cryptographer_copy.reset(new Cryptographer(*cryptographer_)); |
- std::unique_ptr<syncer_v2::ModelTypeWorker> worker( |
- new syncer_v2::ModelTypeWorker( |
- type, activation_context->data_type_state, |
- std::move(cryptographer_copy), nudge_handler_, |
- std::move(activation_context->type_processor))); |
+ std::unique_ptr<ModelTypeWorker> worker(new ModelTypeWorker( |
+ type, activation_context->data_type_state, std::move(cryptographer_copy), |
+ nudge_handler_, std::move(activation_context->type_processor))); |
// Initialize Processor -> Worker communication channel. |
- std::unique_ptr<syncer_v2::CommitQueue> commit_queue_proxy( |
- new CommitQueueProxy(worker->AsWeakPtr(), |
- scoped_refptr<base::SequencedTaskRunner>( |
+ std::unique_ptr<CommitQueue> commit_queue_proxy(new CommitQueueProxy( |
+ worker->AsWeakPtr(), scoped_refptr<base::SequencedTaskRunner>( |
base::ThreadTaskRunnerHandle::Get()))); |
type_processor->ConnectSync(std::move(commit_queue_proxy)); |
@@ -190,8 +184,7 @@ void ModelTypeRegistry::DisconnectType(ModelType type) { |
DCHECK_EQ(1U, committers_erased); |
// Remove from the ScopedVector, deleting the worker in the process. |
- for (ScopedVector<syncer_v2::ModelTypeWorker>::iterator it = |
- model_type_workers_.begin(); |
+ for (ScopedVector<ModelTypeWorker>::iterator it = model_type_workers_.begin(); |
it != model_type_workers_.end(); ++it) { |
if ((*it)->GetModelType() == type) { |
model_type_workers_.erase(it); |
@@ -234,18 +227,18 @@ ModelTypeRegistry::directory_type_debug_info_emitter_map() { |
} |
void ModelTypeRegistry::RegisterDirectoryTypeDebugInfoObserver( |
- syncer::TypeDebugInfoObserver* observer) { |
+ TypeDebugInfoObserver* observer) { |
if (!type_debug_info_observers_.HasObserver(observer)) |
type_debug_info_observers_.AddObserver(observer); |
} |
void ModelTypeRegistry::UnregisterDirectoryTypeDebugInfoObserver( |
- syncer::TypeDebugInfoObserver* observer) { |
+ TypeDebugInfoObserver* observer) { |
type_debug_info_observers_.RemoveObserver(observer); |
} |
bool ModelTypeRegistry::HasDirectoryTypeDebugInfoObserver( |
- const syncer::TypeDebugInfoObserver* observer) const { |
+ const TypeDebugInfoObserver* observer) const { |
return type_debug_info_observers_.HasObserver(observer); |
} |
@@ -259,7 +252,7 @@ void ModelTypeRegistry::RequestEmitDebugInfo() { |
} |
} |
-base::WeakPtr<syncer_v2::ModelTypeConnector> ModelTypeRegistry::AsWeakPtr() { |
+base::WeakPtr<ModelTypeConnector> ModelTypeRegistry::AsWeakPtr() { |
return weak_ptr_factory_.GetWeakPtr(); |
} |
@@ -298,8 +291,7 @@ ModelTypeSet ModelTypeRegistry::GetEnabledDirectoryTypes() const { |
} |
void ModelTypeRegistry::OnEncryptionStateChanged() { |
- for (ScopedVector<syncer_v2::ModelTypeWorker>::iterator it = |
- model_type_workers_.begin(); |
+ for (ScopedVector<ModelTypeWorker>::iterator it = model_type_workers_.begin(); |
it != model_type_workers_.end(); ++it) { |
if (encrypted_types_.Has((*it)->GetModelType())) { |
(*it)->UpdateCryptographer( |
@@ -310,7 +302,7 @@ void ModelTypeRegistry::OnEncryptionStateChanged() { |
ModelTypeSet ModelTypeRegistry::GetEnabledNonBlockingTypes() const { |
ModelTypeSet enabled_non_blocking_types; |
- for (ScopedVector<syncer_v2::ModelTypeWorker>::const_iterator it = |
+ for (ScopedVector<ModelTypeWorker>::const_iterator it = |
model_type_workers_.begin(); |
it != model_type_workers_.end(); ++it) { |
enabled_non_blocking_types.Put((*it)->GetModelType()); |