Index: components/sync/driver/proxy_data_type_controller.cc |
diff --git a/components/sync/driver/proxy_data_type_controller.cc b/components/sync/driver/proxy_data_type_controller.cc |
index ed3e29cc507e1b881fb3e335d514747f340f52ce..44aef53949b15b5752bde550cbddc4db09d86254 100644 |
--- a/components/sync/driver/proxy_data_type_controller.cc |
+++ b/components/sync/driver/proxy_data_type_controller.cc |
@@ -4,21 +4,15 @@ |
#include "components/sync/driver/proxy_data_type_controller.h" |
-#include "base/bind.h" |
-#include "base/bind_helpers.h" |
#include "base/memory/ptr_util.h" |
#include "base/values.h" |
#include "components/sync/api/sync_merge_result.h" |
namespace sync_driver { |
-ProxyDataTypeController::ProxyDataTypeController( |
- const scoped_refptr<base::SingleThreadTaskRunner>& ui_thread, |
- syncer::ModelType type) |
- : DataTypeController(ui_thread, base::Closure()), |
- state_(NOT_RUNNING), |
- type_(type) { |
- DCHECK(syncer::ProxyTypes().Has(type_)); |
+ProxyDataTypeController::ProxyDataTypeController(syncer::ModelType type) |
+ : DataTypeController(type, base::Closure()), state_(NOT_RUNNING) { |
+ DCHECK(syncer::ProxyTypes().Has(type)); |
} |
ProxyDataTypeController::~ProxyDataTypeController() {} |
@@ -29,6 +23,7 @@ bool ProxyDataTypeController::ShouldLoadModelBeforeConfigure() const { |
void ProxyDataTypeController::LoadModels( |
const ModelLoadCallback& model_load_callback) { |
+ DCHECK(CalledOnValidThread()); |
state_ = MODEL_LOADED; |
model_load_callback.Run(type(), syncer::SyncError()); |
} |
@@ -38,8 +33,9 @@ void ProxyDataTypeController::RegisterWithBackend( |
void ProxyDataTypeController::StartAssociating( |
const StartCallback& start_callback) { |
- syncer::SyncMergeResult local_merge_result(type_); |
- syncer::SyncMergeResult syncer_merge_result(type_); |
+ DCHECK(CalledOnValidThread()); |
+ syncer::SyncMergeResult local_merge_result(type()); |
+ syncer::SyncMergeResult syncer_merge_result(type()); |
state_ = RUNNING; |
start_callback.Run(DataTypeController::OK, local_merge_result, |
syncer_merge_result); |
@@ -49,11 +45,6 @@ void ProxyDataTypeController::Stop() { |
state_ = NOT_RUNNING; |
} |
-syncer::ModelType ProxyDataTypeController::type() const { |
- DCHECK(syncer::ProxyTypes().Has(type_)); |
- return type_; |
-} |
- |
std::string ProxyDataTypeController::name() const { |
// For logging only. |
return syncer::ModelTypeToString(type()); |
@@ -63,11 +54,6 @@ DataTypeController::State ProxyDataTypeController::state() const { |
return state_; |
} |
-void ProxyDataTypeController::OnSingleDataTypeUnrecoverableError( |
- const syncer::SyncError& error) { |
- NOTIMPLEMENTED(); |
-} |
- |
void ProxyDataTypeController::ActivateDataType( |
BackendDataTypeConfigurer* configurer) {} |
@@ -75,7 +61,13 @@ void ProxyDataTypeController::DeactivateDataType( |
BackendDataTypeConfigurer* configurer) {} |
void ProxyDataTypeController::GetAllNodes(const AllNodesCallback& callback) { |
- callback.Run(type(), base::WrapUnique(new base::ListValue())); |
+ callback.Run(type(), base::MakeUnique<base::ListValue>()); |
+} |
+ |
+std::unique_ptr<syncer::DataTypeErrorHandler> |
+ProxyDataTypeController::CreateErrorHandler() { |
+ NOTREACHED(); |
+ return nullptr; |
} |
} // namespace sync_driver |