Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(469)

Unified Diff: components/sync/driver/proxy_data_type_controller.cc

Issue 2289143003: [Sync] Convert DTCs to be not RefCounted and NonThreadSafe. (Closed)
Patch Set: Rebase. Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « components/sync/driver/proxy_data_type_controller.h ('k') | components/sync/driver/shared_change_processor.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698