| Index: components/sync/driver/glue/sync_backend_host_core.cc
|
| diff --git a/components/sync/driver/glue/sync_backend_host_core.cc b/components/sync/driver/glue/sync_backend_host_core.cc
|
| index f069467b4d9fc0750612bacdf37edeec5bfc998c..c6e25019f7646de035b1cbefd7022f9a7cbf4e77 100644
|
| --- a/components/sync/driver/glue/sync_backend_host_core.cc
|
| +++ b/components/sync/driver/glue/sync_backend_host_core.cc
|
| @@ -53,31 +53,28 @@ void BindFetcherToDataTracker(net::URLFetcher* fetcher) {
|
|
|
| } // namespace
|
|
|
| -namespace browser_sync {
|
| +namespace syncer {
|
|
|
| DoInitializeOptions::DoInitializeOptions(
|
| base::MessageLoop* sync_loop,
|
| SyncBackendRegistrar* registrar,
|
| - const std::vector<scoped_refptr<syncer::ModelSafeWorker>>& workers,
|
| - const scoped_refptr<syncer::ExtensionsActivity>& extensions_activity,
|
| - const syncer::WeakHandle<syncer::JsEventHandler>& event_handler,
|
| + const std::vector<scoped_refptr<ModelSafeWorker>>& workers,
|
| + const scoped_refptr<ExtensionsActivity>& extensions_activity,
|
| + const WeakHandle<JsEventHandler>& event_handler,
|
| const GURL& service_url,
|
| const std::string& sync_user_agent,
|
| - std::unique_ptr<syncer::HttpPostProviderFactory> http_bridge_factory,
|
| - const syncer::SyncCredentials& credentials,
|
| + std::unique_ptr<HttpPostProviderFactory> http_bridge_factory,
|
| + const SyncCredentials& credentials,
|
| const std::string& invalidator_client_id,
|
| - std::unique_ptr<syncer::SyncManagerFactory> sync_manager_factory,
|
| + std::unique_ptr<SyncManagerFactory> sync_manager_factory,
|
| bool delete_sync_data_folder,
|
| const std::string& restored_key_for_bootstrapping,
|
| const std::string& restored_keystore_key_for_bootstrapping,
|
| - std::unique_ptr<syncer::InternalComponentsFactory>
|
| - internal_components_factory,
|
| - const syncer::WeakHandle<syncer::UnrecoverableErrorHandler>&
|
| - unrecoverable_error_handler,
|
| + std::unique_ptr<InternalComponentsFactory> internal_components_factory,
|
| + const WeakHandle<UnrecoverableErrorHandler>& unrecoverable_error_handler,
|
| const base::Closure& report_unrecoverable_error_function,
|
| - std::unique_ptr<syncer::SyncEncryptionHandler::NigoriState>
|
| - saved_nigori_state,
|
| - const std::map<syncer::ModelType, int64_t>& invalidation_versions)
|
| + std::unique_ptr<SyncEncryptionHandler::NigoriState> saved_nigori_state,
|
| + const std::map<ModelType, int64_t>& invalidation_versions)
|
| : sync_loop(sync_loop),
|
| registrar(registrar),
|
| workers(workers),
|
| @@ -130,7 +127,7 @@ SyncBackendHostCore::~SyncBackendHostCore() {
|
| }
|
|
|
| void SyncBackendHostCore::OnSyncCycleCompleted(
|
| - const syncer::SyncCycleSnapshot& snapshot) {
|
| + const SyncCycleSnapshot& snapshot) {
|
| if (!sync_loop_)
|
| return;
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| @@ -140,21 +137,20 @@ void SyncBackendHostCore::OnSyncCycleCompleted(
|
| snapshot);
|
| }
|
|
|
| -void SyncBackendHostCore::DoRefreshTypes(syncer::ModelTypeSet types) {
|
| +void SyncBackendHostCore::DoRefreshTypes(ModelTypeSet types) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| sync_manager_->RefreshTypes(types);
|
| }
|
|
|
| void SyncBackendHostCore::OnInitializationComplete(
|
| - const syncer::WeakHandle<syncer::JsBackend>& js_backend,
|
| - const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>&
|
| - debug_info_listener,
|
| + const WeakHandle<JsBackend>& js_backend,
|
| + const WeakHandle<DataTypeDebugInfoListener>& debug_info_listener,
|
| bool success,
|
| - const syncer::ModelTypeSet restored_types) {
|
| + const ModelTypeSet restored_types) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
|
|
| if (!success) {
|
| - DoDestroySyncManager(syncer::STOP_SYNC);
|
| + DoDestroySyncManager(STOP_SYNC);
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::HandleInitializationFailureOnFrontendLoop);
|
| return;
|
| @@ -185,31 +181,29 @@ void SyncBackendHostCore::OnInitializationComplete(
|
| // all control types have already completed their initial sync.
|
| registrar_->SetInitialTypes(restored_types);
|
|
|
| - syncer::ConfigureReason reason =
|
| - restored_types.Empty() ? syncer::CONFIGURE_REASON_NEW_CLIENT
|
| - : syncer::CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE;
|
| + ConfigureReason reason = restored_types.Empty()
|
| + ? CONFIGURE_REASON_NEW_CLIENT
|
| + : CONFIGURE_REASON_NEWLY_ENABLED_DATA_TYPE;
|
|
|
| - syncer::ModelTypeSet new_control_types = registrar_->ConfigureDataTypes(
|
| - syncer::ControlTypes(), syncer::ModelTypeSet());
|
| - syncer::ModelSafeRoutingInfo routing_info;
|
| + ModelTypeSet new_control_types =
|
| + registrar_->ConfigureDataTypes(ControlTypes(), ModelTypeSet());
|
| + ModelSafeRoutingInfo routing_info;
|
| registrar_->GetModelSafeRoutingInfo(&routing_info);
|
| - SDVLOG(1) << "Control Types "
|
| - << syncer::ModelTypeSetToString(new_control_types)
|
| + SDVLOG(1) << "Control Types " << ModelTypeSetToString(new_control_types)
|
| << " added; calling ConfigureSyncer";
|
|
|
| - syncer::ModelTypeSet types_to_purge = syncer::Difference(
|
| - syncer::ModelTypeSet::All(), GetRoutingInfoTypes(routing_info));
|
| + ModelTypeSet types_to_purge =
|
| + Difference(ModelTypeSet::All(), GetRoutingInfoTypes(routing_info));
|
|
|
| sync_manager_->ConfigureSyncer(
|
| - reason, new_control_types, types_to_purge, syncer::ModelTypeSet(),
|
| - syncer::ModelTypeSet(), routing_info,
|
| + reason, new_control_types, types_to_purge, ModelTypeSet(), ModelTypeSet(),
|
| + routing_info,
|
| base::Bind(&SyncBackendHostCore::DoInitialProcessControlTypes,
|
| weak_ptr_factory_.GetWeakPtr()),
|
| base::Closure());
|
| }
|
|
|
| -void SyncBackendHostCore::OnConnectionStatusChange(
|
| - syncer::ConnectionStatus status) {
|
| +void SyncBackendHostCore::OnConnectionStatusChange(ConnectionStatus status) {
|
| if (!sync_loop_)
|
| return;
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| @@ -219,7 +213,7 @@ void SyncBackendHostCore::OnConnectionStatusChange(
|
| }
|
|
|
| void SyncBackendHostCore::OnPassphraseRequired(
|
| - syncer::PassphraseRequiredReason reason,
|
| + PassphraseRequiredReason reason,
|
| const sync_pb::EncryptedData& pending_keys) {
|
| if (!sync_loop_)
|
| return;
|
| @@ -237,7 +231,7 @@ void SyncBackendHostCore::OnPassphraseAccepted() {
|
|
|
| void SyncBackendHostCore::OnBootstrapTokenUpdated(
|
| const std::string& bootstrap_token,
|
| - syncer::BootstrapTokenType type) {
|
| + BootstrapTokenType type) {
|
| if (!sync_loop_)
|
| return;
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| @@ -245,9 +239,8 @@ void SyncBackendHostCore::OnBootstrapTokenUpdated(
|
| bootstrap_token, type);
|
| }
|
|
|
| -void SyncBackendHostCore::OnEncryptedTypesChanged(
|
| - syncer::ModelTypeSet encrypted_types,
|
| - bool encrypt_everything) {
|
| +void SyncBackendHostCore::OnEncryptedTypesChanged(ModelTypeSet encrypted_types,
|
| + bool encrypt_everything) {
|
| if (!sync_loop_)
|
| return;
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| @@ -265,11 +258,11 @@ void SyncBackendHostCore::OnEncryptionComplete() {
|
| }
|
|
|
| void SyncBackendHostCore::OnCryptographerStateChanged(
|
| - syncer::Cryptographer* cryptographer) {
|
| + Cryptographer* cryptographer) {
|
| // Do nothing.
|
| }
|
|
|
| -void SyncBackendHostCore::OnPassphraseTypeChanged(syncer::PassphraseType type,
|
| +void SyncBackendHostCore::OnPassphraseTypeChanged(PassphraseType type,
|
| base::Time passphrase_time) {
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::HandlePassphraseTypeChangedOnFrontendLoop,
|
| @@ -277,7 +270,7 @@ void SyncBackendHostCore::OnPassphraseTypeChanged(syncer::PassphraseType type,
|
| }
|
|
|
| void SyncBackendHostCore::OnLocalSetPassphraseEncryption(
|
| - const syncer::SyncEncryptionHandler::NigoriState& nigori_state) {
|
| + const SyncEncryptionHandler::NigoriState& nigori_state) {
|
| host_.Call(
|
| FROM_HERE,
|
| &SyncBackendHostImpl::HandleLocalSetPassphraseEncryptionOnFrontendLoop,
|
| @@ -285,8 +278,8 @@ void SyncBackendHostCore::OnLocalSetPassphraseEncryption(
|
| }
|
|
|
| void SyncBackendHostCore::OnCommitCountersUpdated(
|
| - syncer::ModelType type,
|
| - const syncer::CommitCounters& counters) {
|
| + ModelType type,
|
| + const CommitCounters& counters) {
|
| host_.Call(
|
| FROM_HERE,
|
| &SyncBackendHostImpl::HandleDirectoryCommitCountersUpdatedOnFrontendLoop,
|
| @@ -294,8 +287,8 @@ void SyncBackendHostCore::OnCommitCountersUpdated(
|
| }
|
|
|
| void SyncBackendHostCore::OnUpdateCountersUpdated(
|
| - syncer::ModelType type,
|
| - const syncer::UpdateCounters& counters) {
|
| + ModelType type,
|
| + const UpdateCounters& counters) {
|
| host_.Call(
|
| FROM_HERE,
|
| &SyncBackendHostImpl::HandleDirectoryUpdateCountersUpdatedOnFrontendLoop,
|
| @@ -303,8 +296,8 @@ void SyncBackendHostCore::OnUpdateCountersUpdated(
|
| }
|
|
|
| void SyncBackendHostCore::OnStatusCountersUpdated(
|
| - syncer::ModelType type,
|
| - const syncer::StatusCounters& counters) {
|
| + ModelType type,
|
| + const StatusCounters& counters) {
|
| host_.Call(
|
| FROM_HERE,
|
| &SyncBackendHostImpl::HandleDirectoryStatusCountersUpdatedOnFrontendLoop,
|
| @@ -312,7 +305,7 @@ void SyncBackendHostCore::OnStatusCountersUpdated(
|
| }
|
|
|
| void SyncBackendHostCore::OnActionableError(
|
| - const syncer::SyncProtocolError& sync_error) {
|
| + const SyncProtocolError& sync_error) {
|
| if (!sync_loop_)
|
| return;
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| @@ -321,53 +314,52 @@ void SyncBackendHostCore::OnActionableError(
|
| sync_error);
|
| }
|
|
|
| -void SyncBackendHostCore::OnMigrationRequested(syncer::ModelTypeSet types) {
|
| +void SyncBackendHostCore::OnMigrationRequested(ModelTypeSet types) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::HandleMigrationRequestedOnFrontendLoop,
|
| types);
|
| }
|
|
|
| -void SyncBackendHostCore::OnProtocolEvent(const syncer::ProtocolEvent& event) {
|
| +void SyncBackendHostCore::OnProtocolEvent(const ProtocolEvent& event) {
|
| if (forward_protocol_events_) {
|
| - std::unique_ptr<syncer::ProtocolEvent> event_clone(event.Clone());
|
| + std::unique_ptr<ProtocolEvent> event_clone(event.Clone());
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::HandleProtocolEventOnFrontendLoop,
|
| base::Passed(std::move(event_clone)));
|
| }
|
| }
|
|
|
| -void SyncBackendHostCore::DoOnInvalidatorStateChange(
|
| - syncer::InvalidatorState state) {
|
| +void SyncBackendHostCore::DoOnInvalidatorStateChange(InvalidatorState state) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| - sync_manager_->SetInvalidatorEnabled(state == syncer::INVALIDATIONS_ENABLED);
|
| + sync_manager_->SetInvalidatorEnabled(state == INVALIDATIONS_ENABLED);
|
| }
|
|
|
| void SyncBackendHostCore::DoOnIncomingInvalidation(
|
| - const syncer::ObjectIdInvalidationMap& invalidation_map) {
|
| + const ObjectIdInvalidationMap& invalidation_map) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
|
|
| - syncer::ObjectIdSet ids = invalidation_map.GetObjectIds();
|
| + ObjectIdSet ids = invalidation_map.GetObjectIds();
|
| for (const invalidation::ObjectId& object_id : ids) {
|
| - syncer::ModelType type;
|
| + ModelType type;
|
| if (!NotificationTypeToRealModelType(object_id.name(), &type)) {
|
| DLOG(WARNING) << "Notification has invalid id: "
|
| - << syncer::ObjectIdToString(object_id);
|
| + << ObjectIdToString(object_id);
|
| } else {
|
| - syncer::SingleObjectInvalidationSet invalidation_set =
|
| + SingleObjectInvalidationSet invalidation_set =
|
| invalidation_map.ForObject(object_id);
|
| - for (syncer::Invalidation invalidation : invalidation_set) {
|
| + for (Invalidation invalidation : invalidation_set) {
|
| auto last_invalidation = last_invalidation_versions_.find(type);
|
| if (!invalidation.is_unknown_version() &&
|
| last_invalidation != last_invalidation_versions_.end() &&
|
| invalidation.version() <= last_invalidation->second) {
|
| DVLOG(1) << "Ignoring redundant invalidation for "
|
| - << syncer::ModelTypeToString(type) << " with version "
|
| + << ModelTypeToString(type) << " with version "
|
| << invalidation.version() << ", last seen version was "
|
| << last_invalidation->second;
|
| continue;
|
| }
|
| - std::unique_ptr<syncer::InvalidationInterface> inv_adapter(
|
| + std::unique_ptr<InvalidationInterface> inv_adapter(
|
| new InvalidationAdapter(invalidation));
|
| sync_manager_->OnIncomingInvalidation(type, std::move(inv_adapter));
|
| if (!invalidation.is_unknown_version())
|
| @@ -413,7 +405,7 @@ void SyncBackendHostCore::DoInitialize(
|
| sync_manager_ = options->sync_manager_factory->CreateSyncManager(name_);
|
| sync_manager_->AddObserver(this);
|
|
|
| - syncer::SyncManager::InitArgs args;
|
| + SyncManager::InitArgs args;
|
| args.database_location = sync_data_folder_path_;
|
| args.event_handler = options->event_handler;
|
| args.service_url = options->service_url;
|
| @@ -438,7 +430,7 @@ void SyncBackendHostCore::DoInitialize(
|
| }
|
|
|
| void SyncBackendHostCore::DoUpdateCredentials(
|
| - const syncer::SyncCredentials& credentials) {
|
| + const SyncCredentials& credentials) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| // UpdateCredentials can be called during backend initialization, possibly
|
| // when backend initialization has failed but hasn't notified the UI thread
|
| @@ -450,7 +442,7 @@ void SyncBackendHostCore::DoUpdateCredentials(
|
| }
|
|
|
| void SyncBackendHostCore::DoStartSyncing(
|
| - const syncer::ModelSafeRoutingInfo& routing_info,
|
| + const ModelSafeRoutingInfo& routing_info,
|
| base::Time last_poll_time) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| sync_manager_->StartSyncingNormally(routing_info, last_poll_time);
|
| @@ -483,7 +475,7 @@ void SyncBackendHostCore::DoInitialProcessControlTypes() {
|
| return;
|
| }
|
|
|
| - if (!sync_manager_->InitialSyncEndedTypes().HasAll(syncer::ControlTypes())) {
|
| + if (!sync_manager_->InitialSyncEndedTypes().HasAll(ControlTypes())) {
|
| LOG(ERROR) << "Failed to download control types";
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::HandleInitializationFailureOnFrontendLoop);
|
| @@ -532,21 +524,21 @@ void SyncBackendHostCore::ShutdownOnUIThread() {
|
| release_request_context_signal_.Signal();
|
| }
|
|
|
| -void SyncBackendHostCore::DoShutdown(syncer::ShutdownReason reason) {
|
| +void SyncBackendHostCore::DoShutdown(ShutdownReason reason) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
|
|
| DoDestroySyncManager(reason);
|
|
|
| registrar_ = NULL;
|
|
|
| - if (reason == syncer::DISABLE_SYNC)
|
| + if (reason == DISABLE_SYNC)
|
| DeleteSyncDataFolder();
|
|
|
| host_.Reset();
|
| weak_ptr_factory_.InvalidateWeakPtrs();
|
| }
|
|
|
| -void SyncBackendHostCore::DoDestroySyncManager(syncer::ShutdownReason reason) {
|
| +void SyncBackendHostCore::DoDestroySyncManager(ShutdownReason reason) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| if (sync_manager_) {
|
| DisableDirectoryTypeDebugInfoForwarding();
|
| @@ -558,11 +550,10 @@ void SyncBackendHostCore::DoDestroySyncManager(syncer::ShutdownReason reason) {
|
| }
|
|
|
| void SyncBackendHostCore::DoConfigureSyncer(
|
| - syncer::ConfigureReason reason,
|
| + ConfigureReason reason,
|
| const DoConfigureSyncerTypes& config_types,
|
| - const syncer::ModelSafeRoutingInfo routing_info,
|
| - const base::Callback<void(syncer::ModelTypeSet, syncer::ModelTypeSet)>&
|
| - ready_task,
|
| + const ModelSafeRoutingInfo routing_info,
|
| + const base::Callback<void(ModelTypeSet, ModelTypeSet)>& ready_task,
|
| const base::Closure& retry_callback) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| DCHECK(!ready_task.is_null());
|
| @@ -580,20 +571,19 @@ void SyncBackendHostCore::DoConfigureSyncer(
|
| }
|
|
|
| void SyncBackendHostCore::DoFinishConfigureDataTypes(
|
| - syncer::ModelTypeSet types_to_config,
|
| - const base::Callback<void(syncer::ModelTypeSet, syncer::ModelTypeSet)>&
|
| - ready_task) {
|
| + ModelTypeSet types_to_config,
|
| + const base::Callback<void(ModelTypeSet, ModelTypeSet)>& ready_task) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
|
|
| // Update the enabled types for the bridge and sync manager.
|
| - syncer::ModelSafeRoutingInfo routing_info;
|
| + ModelSafeRoutingInfo routing_info;
|
| registrar_->GetModelSafeRoutingInfo(&routing_info);
|
| - syncer::ModelTypeSet enabled_types = GetRoutingInfoTypes(routing_info);
|
| - enabled_types.RemoveAll(syncer::ProxyTypes());
|
| + ModelTypeSet enabled_types = GetRoutingInfoTypes(routing_info);
|
| + enabled_types.RemoveAll(ProxyTypes());
|
|
|
| - const syncer::ModelTypeSet failed_configuration_types =
|
| + const ModelTypeSet failed_configuration_types =
|
| Difference(types_to_config, sync_manager_->InitialSyncEndedTypes());
|
| - const syncer::ModelTypeSet succeeded_configuration_types =
|
| + const ModelTypeSet succeeded_configuration_types =
|
| Difference(types_to_config, failed_configuration_types);
|
| host_.Call(FROM_HERE,
|
| &SyncBackendHostImpl::FinishConfigureDataTypesOnFrontendLoop,
|
| @@ -615,7 +605,7 @@ void SyncBackendHostCore::SendBufferedProtocolEventsAndEnableForwarding() {
|
| if (sync_manager_) {
|
| // Grab our own copy of the buffered events.
|
| // The buffer is not modified by this operation.
|
| - std::vector<std::unique_ptr<syncer::ProtocolEvent>> buffered_events =
|
| + std::vector<std::unique_ptr<ProtocolEvent>> buffered_events =
|
| sync_manager_->GetBufferedProtocolEvents();
|
|
|
| // Send them all over the fence to the host.
|
| @@ -679,9 +669,9 @@ void SyncBackendHostCore::SaveChanges() {
|
| }
|
|
|
| void SyncBackendHostCore::DoClearServerData(
|
| - const syncer::SyncManager::ClearServerDataCallback& frontend_callback) {
|
| + const SyncManager::ClearServerDataCallback& frontend_callback) {
|
| DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread());
|
| - const syncer::SyncManager::ClearServerDataCallback callback =
|
| + const SyncManager::ClearServerDataCallback callback =
|
| base::Bind(&SyncBackendHostCore::ClearServerDataDone,
|
| weak_ptr_factory_.GetWeakPtr(), frontend_callback);
|
| sync_manager_->ClearServerData(callback);
|
| @@ -700,4 +690,4 @@ void SyncBackendHostCore::ClearServerDataDone(
|
| frontend_callback);
|
| }
|
|
|
| -} // namespace browser_sync
|
| +} // namespace syncer
|
|
|