| 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_);
|
|
|
|
|