Revert of [Sync] Move //components/sync to the syncer namespace. (patchset #5 id:40001 of https://co

components/sync/driver/non_blocking_data_type_controller.cc

 // 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.
 
 #include "components/sync/driver/non_blocking_data_type_controller.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/location.h"
 #include "base/memory/ptr_util.h"
 #include "base/single_thread_task_runner.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "components/sync/api/data_type_error_handler_impl.h"
 #include "components/sync/api/model_type_change_processor.h"
 #include "components/sync/api/model_type_service.h"
 #include "components/sync/api/sync_error.h"
 #include "components/sync/api/sync_merge_result.h"
 #include "components/sync/base/bind_to_task_runner.h"
 #include "components/sync/base/data_type_histogram.h"
 #include "components/sync/core/activation_context.h"
 #include "components/sync/driver/backend_data_type_configurer.h"
 #include "components/sync/driver/sync_client.h"
 
-namespace syncer {
+namespace sync_driver_v2 {
 
 NonBlockingDataTypeController::NonBlockingDataTypeController(
-    ModelType type,
+    syncer::ModelType type,
     const base::Closure& dump_stack,
-    SyncClient* sync_client)
-    : DataTypeController(type, dump_stack),
+    sync_driver::SyncClient* sync_client)
+    : sync_driver::DataTypeController(type, dump_stack),
       sync_client_(sync_client),
       sync_prefs_(sync_client->GetPrefService()),
       state_(NOT_RUNNING) {}
 
 NonBlockingDataTypeController::~NonBlockingDataTypeController() {}
 
 bool NonBlockingDataTypeController::ShouldLoadModelBeforeConfigure() const {
   // USS datatypes require loading models because model controls storage where
   // data type context and progress marker are persisted.
   return true;
 }
 
 void NonBlockingDataTypeController::LoadModels(
     const ModelLoadCallback& model_load_callback) {
   DCHECK(CalledOnValidThread());
   DCHECK(!model_load_callback.is_null());
   model_load_callback_ = model_load_callback;
 
   if (state() != NOT_RUNNING) {
-    LoadModelsDone(RUNTIME_ERROR,
-                   SyncError(FROM_HERE, SyncError::DATATYPE_ERROR,
-                             "Model already running", type()));
+    LoadModelsDone(
+        RUNTIME_ERROR,
+        syncer::SyncError(FROM_HERE, syncer::SyncError::DATATYPE_ERROR,
+                          "Model already running", type()));
     return;
   }
 
   state_ = MODEL_STARTING;
 
   // Callback that posts back to the UI thread.
-  ModelTypeChangeProcessor::StartCallback callback = BindToCurrentThread(
-      base::Bind(&NonBlockingDataTypeController::OnProcessorStarted,
-                 base::AsWeakPtr(this)));
+  syncer_v2::ModelTypeChangeProcessor::StartCallback callback =
+      syncer::BindToCurrentThread(
+          base::Bind(&NonBlockingDataTypeController::OnProcessorStarted,
+                     base::AsWeakPtr(this)));
 
   // Start the type processor on the model thread.
   if (!RunOnModelThread(
           FROM_HERE,
-          base::Bind(&ModelTypeService::OnSyncStarting,
+          base::Bind(&syncer_v2::ModelTypeService::OnSyncStarting,
                      sync_client_->GetModelTypeServiceForType(type()),
                      base::Passed(CreateErrorHandler()), callback))) {
-    LoadModelsDone(UNRECOVERABLE_ERROR,
-                   SyncError(FROM_HERE, SyncError::DATATYPE_ERROR,
-                             "Failed to post model Start", type()));
+    LoadModelsDone(
+        UNRECOVERABLE_ERROR,
+        syncer::SyncError(FROM_HERE, syncer::SyncError::DATATYPE_ERROR,
+                          "Failed to post model Start", type()));
   }
 }
 
 void NonBlockingDataTypeController::GetAllNodes(
     const AllNodesCallback& callback) {
-  base::WeakPtr<ModelTypeService> service =
+  base::WeakPtr<syncer_v2::ModelTypeService> service =
       sync_client_->GetModelTypeServiceForType(type());
   // TODO(gangwu): Casting should happen "near" where the processor factory has
   // code that instantiates a new processor.
-  SharedModelTypeProcessor* processor =
-      (SharedModelTypeProcessor*)service->change_processor();
+  syncer_v2::SharedModelTypeProcessor* processor =
+      (syncer_v2::SharedModelTypeProcessor*)service->change_processor();
   RunOnModelThread(FROM_HERE,
-                   base::Bind(&SharedModelTypeProcessor::GetAllNodes,
+                   base::Bind(&syncer_v2::SharedModelTypeProcessor::GetAllNodes,
                               base::Unretained(processor),
                               base::ThreadTaskRunnerHandle::Get(), callback));
 }
 
-void NonBlockingDataTypeController::LoadModelsDone(ConfigureResult result,
-                                                   const SyncError& error) {
+void NonBlockingDataTypeController::LoadModelsDone(
+    ConfigureResult result,
+    const syncer::SyncError& error) {
   DCHECK(CalledOnValidThread());
 
   if (state_ == NOT_RUNNING) {
     // The callback arrived on the UI thread after the type has been already
     // stopped.
     RecordStartFailure(ABORTED);
     return;
   }
 
   if (IsSuccessfulResult(result)) {
     DCHECK_EQ(MODEL_STARTING, state_);
     state_ = MODEL_LOADED;
   } else {
     RecordStartFailure(result);
   }
 
   if (!model_load_callback_.is_null()) {
     model_load_callback_.Run(type(), error);
   }
 }
 
 void NonBlockingDataTypeController::OnProcessorStarted(
-    SyncError error,
-    std::unique_ptr<ActivationContext> activation_context) {
+    syncer::SyncError error,
+    std::unique_ptr<syncer_v2::ActivationContext> activation_context) {
   DCHECK(CalledOnValidThread());
   // Hold on to the activation context until ActivateDataType is called.
   if (state_ == MODEL_STARTING) {
     activation_context_ = std::move(activation_context);
   }
   // TODO(stanisc): Figure out if UNRECOVERABLE_ERROR is OK in this case.
   ConfigureResult result = error.IsSet() ? UNRECOVERABLE_ERROR : OK;
   LoadModelsDone(result, error);
 }
 
 void NonBlockingDataTypeController::RegisterWithBackend(
-    BackendDataTypeConfigurer* configurer) {
+    sync_driver::BackendDataTypeConfigurer* configurer) {
   DCHECK(CalledOnValidThread());
   if (activated_)
     return;
   DCHECK(configurer);
   DCHECK(activation_context_);
   DCHECK_EQ(MODEL_LOADED, state_);
   configurer->ActivateNonBlockingDataType(type(),
                                           std::move(activation_context_));
   activated_ = true;
 }
 
 void NonBlockingDataTypeController::StartAssociating(
     const StartCallback& start_callback) {
   DCHECK(CalledOnValidThread());
   DCHECK(!start_callback.is_null());
 
   state_ = RUNNING;
 
   // There is no association, just call back promptly.
-  SyncMergeResult merge_result(type());
+  syncer::SyncMergeResult merge_result(type());
   start_callback.Run(OK, merge_result, merge_result);
 }
 
 void NonBlockingDataTypeController::ActivateDataType(
-    BackendDataTypeConfigurer* configurer) {
+    sync_driver::BackendDataTypeConfigurer* configurer) {
   DCHECK(CalledOnValidThread());
   DCHECK(configurer);
   DCHECK_EQ(RUNNING, state_);
   // In contrast with directory datatypes, non-blocking data types should be
   // activated in RegisterWithBackend. activation_context_ should be passed
   // to backend before call to ActivateDataType.
   DCHECK(!activation_context_);
 }
 
 void NonBlockingDataTypeController::DeactivateDataType(
-    BackendDataTypeConfigurer* configurer) {
+    sync_driver::BackendDataTypeConfigurer* configurer) {
   DCHECK(CalledOnValidThread());
   DCHECK(configurer);
   DCHECK(activated_);
   configurer->DeactivateNonBlockingDataType(type());
   activated_ = false;
 }
 
 void NonBlockingDataTypeController::Stop() {
   DCHECK(CalledOnValidThread());
 
   if (state() == NOT_RUNNING)
     return;
 
   // Check preferences if datatype is not in preferred datatypes. Only call
   // DisableSync if service is ready to handle it (controller is in loaded
   // state).
-  ModelTypeSet preferred_types =
-      sync_prefs_.GetPreferredDataTypes(ModelTypeSet(type()));
+  syncer::ModelTypeSet preferred_types =
+      sync_prefs_.GetPreferredDataTypes(syncer::ModelTypeSet(type()));
   if ((state() == MODEL_LOADED || state() == RUNNING) &&
       (!sync_prefs_.IsFirstSetupComplete() || !preferred_types.Has(type()))) {
     RunOnModelThread(
         FROM_HERE,
-        base::Bind(&ModelTypeService::DisableSync,
+        base::Bind(&syncer_v2::ModelTypeService::DisableSync,
                    sync_client_->GetModelTypeServiceForType(type())));
   }
 
   state_ = NOT_RUNNING;
 }
 
 std::string NonBlockingDataTypeController::name() const {
   // For logging only.
-  return ModelTypeToString(type());
+  return syncer::ModelTypeToString(type());
 }
 
-DataTypeController::State NonBlockingDataTypeController::state() const {
+sync_driver::DataTypeController::State NonBlockingDataTypeController::state()
+    const {
   return state_;
 }
 
-std::unique_ptr<DataTypeErrorHandler>
+std::unique_ptr<syncer::DataTypeErrorHandler>
 NonBlockingDataTypeController::CreateErrorHandler() {
   DCHECK(CalledOnValidThread());
-  return base::MakeUnique<DataTypeErrorHandlerImpl>(
+  return base::MakeUnique<syncer::DataTypeErrorHandlerImpl>(
       base::ThreadTaskRunnerHandle::Get(), dump_stack_,
       base::Bind(&NonBlockingDataTypeController::ReportLoadModelError,
                  base::AsWeakPtr(this)));
 }
 
 void NonBlockingDataTypeController::ReportLoadModelError(
-    const SyncError& error) {
+    const syncer::SyncError& error) {
   DCHECK(CalledOnValidThread());
   LoadModelsDone(UNRECOVERABLE_ERROR, error);
 }
 
 void NonBlockingDataTypeController::RecordStartFailure(
     ConfigureResult result) const {
   DCHECK(CalledOnValidThread());
   UMA_HISTOGRAM_ENUMERATION("Sync.DataTypeStartFailures",
-                            ModelTypeToHistogramInt(type()), MODEL_TYPE_COUNT);
+                            ModelTypeToHistogramInt(type()),
+                            syncer::MODEL_TYPE_COUNT);
 #define PER_DATA_TYPE_MACRO(type_str)                                    \
   UMA_HISTOGRAM_ENUMERATION("Sync." type_str "ConfigureFailure", result, \
                             MAX_CONFIGURE_RESULT);
   SYNC_DATA_TYPE_HISTOGRAM(type());
 #undef PER_DATA_TYPE_MACRO
 }
 
-}  // namespace syncer
+}  // namespace sync_driver_v2