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

Unified Diff: components/sync/core/shared_model_type_processor.cc

Issue 2384153004: [Sync] Merge NBDTC and subclasses into ModelTypeController. (Closed)
Patch Set: Fix bad rebase. Created 4 years, 2 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
« no previous file with comments | « components/sync/core/model_type_processor_proxy.cc ('k') | components/sync/driver/model_type_controller.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/sync/core/shared_model_type_processor.cc
diff --git a/components/sync/core/shared_model_type_processor.cc b/components/sync/core/shared_model_type_processor.cc
index 956e1ddb50079dcdee8ac8cb54fa13997af20826..53bbb84a0a5c40058242657f6209464330cd6076 100644
--- a/components/sync/core/shared_model_type_processor.cc
+++ b/components/sync/core/shared_model_type_processor.cc
@@ -13,6 +13,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/threading/thread_task_runner_handle.h"
#include "components/sync/core/activation_context.h"
+#include "components/sync/core/model_type_processor_proxy.h"
#include "components/sync/core/processor_entity_tracker.h"
#include "components/sync/engine/commit_queue.h"
#include "components/sync/protocol/proto_value_conversions.h"
@@ -20,63 +21,6 @@
namespace syncer {
-namespace {
-
-class ModelTypeProcessorProxy : public ModelTypeProcessor {
- public:
- ModelTypeProcessorProxy(
- const base::WeakPtr<ModelTypeProcessor>& processor,
- const scoped_refptr<base::SequencedTaskRunner>& processor_task_runner);
- ~ModelTypeProcessorProxy() override;
-
- void ConnectSync(std::unique_ptr<CommitQueue> worker) override;
- void DisconnectSync() override;
- void OnCommitCompleted(const sync_pb::ModelTypeState& type_state,
- const CommitResponseDataList& response_list) override;
- void OnUpdateReceived(const sync_pb::ModelTypeState& type_state,
- const UpdateResponseDataList& updates) override;
-
- private:
- base::WeakPtr<ModelTypeProcessor> processor_;
- scoped_refptr<base::SequencedTaskRunner> processor_task_runner_;
-};
-
-ModelTypeProcessorProxy::ModelTypeProcessorProxy(
- const base::WeakPtr<ModelTypeProcessor>& processor,
- const scoped_refptr<base::SequencedTaskRunner>& processor_task_runner)
- : processor_(processor), processor_task_runner_(processor_task_runner) {}
-
-ModelTypeProcessorProxy::~ModelTypeProcessorProxy() {}
-
-void ModelTypeProcessorProxy::ConnectSync(std::unique_ptr<CommitQueue> worker) {
- processor_task_runner_->PostTask(
- FROM_HERE, base::Bind(&ModelTypeProcessor::ConnectSync, processor_,
- base::Passed(std::move(worker))));
-}
-
-void ModelTypeProcessorProxy::DisconnectSync() {
- processor_task_runner_->PostTask(
- FROM_HERE, base::Bind(&ModelTypeProcessor::DisconnectSync, processor_));
-}
-
-void ModelTypeProcessorProxy::OnCommitCompleted(
- const sync_pb::ModelTypeState& type_state,
- const CommitResponseDataList& response_list) {
- processor_task_runner_->PostTask(
- FROM_HERE, base::Bind(&ModelTypeProcessor::OnCommitCompleted, processor_,
- type_state, response_list));
-}
-
-void ModelTypeProcessorProxy::OnUpdateReceived(
- const sync_pb::ModelTypeState& type_state,
- const UpdateResponseDataList& updates) {
- processor_task_runner_->PostTask(
- FROM_HERE, base::Bind(&ModelTypeProcessor::OnUpdateReceived, processor_,
- type_state, updates));
-}
-
-} // namespace
-
SharedModelTypeProcessor::SharedModelTypeProcessor(ModelType type,
ModelTypeService* service)
: type_(type),
« no previous file with comments | « components/sync/core/model_type_processor_proxy.cc ('k') | components/sync/driver/model_type_controller.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698