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

Unified Diff: sync/internal_api/shared_model_type_processor.cc

Issue 1671773002: [Sync] USS: Rename SharedModelTypeProcessor::Start and related methods. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@smtp
Patch Set: Rebase. Created 4 years, 10 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: sync/internal_api/shared_model_type_processor.cc
diff --git a/sync/internal_api/shared_model_type_processor.cc b/sync/internal_api/shared_model_type_processor.cc
index 4b6b983a9c5e7e21181459f82dd03ea9b7b78d06..83a6a51dc0f2a84ad3a2c9ca9b159bb89d84918a 100644
--- a/sync/internal_api/shared_model_type_processor.cc
+++ b/sync/internal_api/shared_model_type_processor.cc
@@ -25,7 +25,7 @@ class ModelTypeProcessorProxy : public ModelTypeProcessor {
const scoped_refptr<base::SequencedTaskRunner>& processor_task_runner);
~ModelTypeProcessorProxy() override;
- void OnConnect(scoped_ptr<CommitQueue> worker) override;
+ void ConnectSync(scoped_ptr<CommitQueue> worker) override;
void OnCommitCompleted(const sync_pb::DataTypeState& type_state,
const CommitResponseDataList& response_list) override;
void OnUpdateReceived(const sync_pb::DataTypeState& type_state,
@@ -44,9 +44,9 @@ ModelTypeProcessorProxy::ModelTypeProcessorProxy(
ModelTypeProcessorProxy::~ModelTypeProcessorProxy() {}
-void ModelTypeProcessorProxy::OnConnect(scoped_ptr<CommitQueue> worker) {
+void ModelTypeProcessorProxy::ConnectSync(scoped_ptr<CommitQueue> worker) {
processor_task_runner_->PostTask(
- FROM_HERE, base::Bind(&ModelTypeProcessor::OnConnect, processor_,
+ FROM_HERE, base::Bind(&ModelTypeProcessor::ConnectSync, processor_,
base::Passed(std::move(worker))));
}
@@ -81,17 +81,17 @@ SharedModelTypeProcessor::SharedModelTypeProcessor(syncer::ModelType type,
SharedModelTypeProcessor::~SharedModelTypeProcessor() {}
-void SharedModelTypeProcessor::Start(StartCallback start_callback) {
+void SharedModelTypeProcessor::OnSyncStarting(StartCallback start_callback) {
DCHECK(CalledOnValidThread());
DCHECK(start_callback_.is_null());
DCHECK(!IsConnected());
- DVLOG(1) << "Starting " << ModelTypeToString(type_);
+ DVLOG(1) << "Sync is starting for " << ModelTypeToString(type_);
start_callback_ = start_callback;
if (is_metadata_loaded_) {
- // The metadata was already loaded, so finish starting immediately.
- FinishStart();
+ // The metadata was already loaded, so we are ready to connect.
+ ReadyToConnect();
}
}
@@ -121,12 +121,12 @@ void SharedModelTypeProcessor::OnMetadataLoaded(
is_metadata_loaded_ = true;
if (!start_callback_.is_null()) {
- // If Start() was already called, finish starting.
- FinishStart();
+ // If OnSyncStarting() was already called, we are now ready to connect.
+ ReadyToConnect();
}
}
-void SharedModelTypeProcessor::FinishStart() {
+void SharedModelTypeProcessor::ReadyToConnect() {
DCHECK(CalledOnValidThread());
DCHECK(is_metadata_loaded_);
DCHECK(!start_callback_.is_null());
@@ -168,11 +168,11 @@ void SharedModelTypeProcessor::Disable() {
service_->clear_change_processor();
}
-void SharedModelTypeProcessor::Stop() {
+void SharedModelTypeProcessor::DisconnectSync() {
DCHECK(CalledOnValidThread());
DCHECK(IsConnected());
- DVLOG(1) << "Stopping " << ModelTypeToString(type_);
+ DVLOG(1) << "Disconnecting sync for " << ModelTypeToString(type_);
weak_ptr_factory_for_sync_.InvalidateWeakPtrs();
worker_.reset();
@@ -185,7 +185,7 @@ SharedModelTypeProcessor::AsWeakPtrForUI() {
return weak_ptr_factory_for_ui_.GetWeakPtr();
}
-void SharedModelTypeProcessor::OnConnect(scoped_ptr<CommitQueue> worker) {
+void SharedModelTypeProcessor::ConnectSync(scoped_ptr<CommitQueue> worker) {
DCHECK(CalledOnValidThread());
DVLOG(1) << "Successfully connected " << ModelTypeToString(type_);
« no previous file with comments | « sync/internal_api/public/shared_model_type_processor.h ('k') | sync/internal_api/shared_model_type_processor_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698