Index: chrome/browser/sync/glue/sync_backend_host.cc |
diff --git a/chrome/browser/sync/glue/sync_backend_host.cc b/chrome/browser/sync/glue/sync_backend_host.cc |
index 50fc35cf4dcfb94846fd6fa0492bdf8648bc30ca..9d57a8f9d60335e533eb311fd06749d78c473214 100644 |
--- a/chrome/browser/sync/glue/sync_backend_host.cc |
+++ b/chrome/browser/sync/glue/sync_backend_host.cc |
@@ -66,9 +66,6 @@ SyncBackendHost::SyncBackendHost(Profile* profile) |
sync_data_folder_path_( |
profile_->GetPath().Append(kSyncDataFolderName)), |
last_auth_error_(AuthError::None()), |
- using_new_syncer_thread_( |
- CommandLine::ForCurrentProcess()->HasSwitch( |
- switches::kNewSyncerThread)), |
syncapi_initialized_(false) { |
} |
@@ -78,9 +75,6 @@ SyncBackendHost::SyncBackendHost() |
profile_(NULL), |
frontend_(NULL), |
last_auth_error_(AuthError::None()), |
- using_new_syncer_thread_( |
- CommandLine::ForCurrentProcess()->HasSwitch( |
- switches::kNewSyncerThread)), |
syncapi_initialized_(false) { |
} |
@@ -409,16 +403,7 @@ void SyncBackendHost::ConfigureDataTypes( |
®istrar_.routing_info)); |
} |
- // If we're doing the first configure (at startup) this is redundant as the |
- // syncer thread always must start in config mode. |
- if (using_new_syncer_thread_) { |
- core_thread_.message_loop()->PostTask( |
- FROM_HERE, |
- NewRunnableMethod(core_.get(), |
- &SyncBackendHost::Core::DoStartConfigurationMode)); |
- } else { |
- FinishConfigureDataTypesOnFrontendLoop(); |
- } |
+ FinishConfigureDataTypesOnFrontendLoop(); |
} |
void SyncBackendHost::FinishConfigureDataTypesOnFrontendLoop() { |
@@ -433,15 +418,11 @@ void SyncBackendHost::FinishConfigureDataTypesOnFrontendLoop() { |
// downloading updates for newly added data types. Once this is |
// complete, the configure_state_.ready_task_ is run via an |
// OnInitializationComplete notification. |
- bool request_nudge = false; |
+ |
if (pending_config_mode_state_->deleted_type) { |
- if (using_new_syncer_thread_) { |
- core_thread_.message_loop()->PostTask(FROM_HERE, |
- NewRunnableMethod(core_.get(), |
- &SyncBackendHost::Core::DeferNudgeForCleanup)); |
- } else { |
- request_nudge = true; |
- } |
+ core_thread_.message_loop()->PostTask(FROM_HERE, |
+ NewRunnableMethod(core_.get(), |
+ &SyncBackendHost::Core::DeferNudgeForCleanup)); |
} |
if (pending_config_mode_state_->added_types.none() && |
@@ -464,17 +445,14 @@ void SyncBackendHost::FinishConfigureDataTypesOnFrontendLoop() { |
pending_config_mode_state_->ready_task->Run(); |
} else { |
pending_download_state_.reset(pending_config_mode_state_.release()); |
- if (using_new_syncer_thread_) { |
- RequestConfig(pending_download_state_->added_types); |
- } else { |
- request_nudge = true; |
- } |
- } |
- // TODO(tim): Remove this when we get rid of the old syncer thread. |
- if (request_nudge) { |
- CHECK(!using_new_syncer_thread_); |
- RequestNudge(FROM_HERE); |
+ syncable::ModelTypeBitSet types_copy(pending_download_state_->added_types); |
+ if (IsNigoriEnabled()) |
+ types_copy.set(syncable::NIGORI); |
+ core_thread_.message_loop()->PostTask(FROM_HERE, |
+ NewRunnableMethod(core_.get(), |
+ &SyncBackendHost::Core::DoRequestConfig, |
+ types_copy)); |
} |
pending_config_mode_state_.reset(); |
@@ -499,17 +477,6 @@ void SyncBackendHost::RequestNudge(const tracked_objects::Location& location) { |
location)); |
} |
-void SyncBackendHost::RequestConfig( |
- const syncable::ModelTypeBitSet& added_types) { |
- DCHECK(core_->syncapi()); |
- |
- syncable::ModelTypeBitSet types_copy(added_types); |
- if (IsNigoriEnabled()) |
- types_copy.set(syncable::NIGORI); |
- |
- core_->syncapi()->RequestConfig(types_copy); |
-} |
- |
void SyncBackendHost::ActivateDataType( |
DataTypeController* data_type_controller, |
ChangeProcessor* change_processor) { |
@@ -541,20 +508,6 @@ void SyncBackendHost::DeactivateDataType( |
DCHECK_EQ(erased, 1U); |
} |
-bool SyncBackendHost::RequestPause() { |
- DCHECK(!using_new_syncer_thread_); |
- core_thread_.message_loop()->PostTask(FROM_HERE, |
- NewRunnableMethod(core_.get(), &SyncBackendHost::Core::DoRequestPause)); |
- return true; |
-} |
- |
-bool SyncBackendHost::RequestResume() { |
- DCHECK(!using_new_syncer_thread_); |
- core_thread_.message_loop()->PostTask(FROM_HERE, |
- NewRunnableMethod(core_.get(), &SyncBackendHost::Core::DoRequestResume)); |
- return true; |
-} |
- |
bool SyncBackendHost::RequestClearServerData() { |
core_thread_.message_loop()->PostTask(FROM_HERE, |
NewRunnableMethod(core_.get(), |
@@ -565,20 +518,6 @@ bool SyncBackendHost::RequestClearServerData() { |
SyncBackendHost::Core::~Core() { |
} |
-void SyncBackendHost::Core::NotifyPaused() { |
- DCHECK(!host_ || !host_->using_new_syncer_thread_); |
- NotificationService::current()->Notify(NotificationType::SYNC_PAUSED, |
- NotificationService::AllSources(), |
- NotificationService::NoDetails()); |
-} |
- |
-void SyncBackendHost::Core::NotifyResumed() { |
- DCHECK(!host_ || !host_->using_new_syncer_thread_); |
- NotificationService::current()->Notify(NotificationType::SYNC_RESUMED, |
- NotificationService::AllSources(), |
- NotificationService::NoDetails()); |
-} |
- |
void SyncBackendHost::Core::NotifyPassphraseRequired(bool for_decryption) { |
if (!host_ || !host_->frontend_) |
return; |
@@ -832,6 +771,11 @@ void SyncBackendHost::Core::DoEncryptDataTypes( |
syncapi_->EncryptDataTypes(encrypted_types); |
} |
+void SyncBackendHost::Core::DoRequestConfig( |
+ const syncable::ModelTypeBitSet& added_types) { |
+ syncapi_->RequestConfig(added_types); |
+} |
+ |
UIModelWorker* SyncBackendHost::ui_worker() { |
ModelSafeWorker* w = registrar_.workers[GROUP_UI]; |
if (w == NULL) |
@@ -949,7 +893,6 @@ void SyncBackendHost::Core::HandleSyncCycleCompletedOnFrontendLoop( |
} |
if (!found_all_added) { |
CHECK(false); |
- DCHECK(!host_->using_new_syncer_thread_); |
} else { |
host_->pending_download_state_->ready_task->Run(); |
host_->pending_download_state_.reset(); |
@@ -1027,18 +970,6 @@ void SyncBackendHost::Core::OnPassphraseAccepted( |
bootstrap_token)); |
} |
-void SyncBackendHost::Core::OnPaused() { |
- host_->frontend_loop_->PostTask( |
- FROM_HERE, |
- NewRunnableMethod(this, &Core::NotifyPaused)); |
-} |
- |
-void SyncBackendHost::Core::OnResumed() { |
- host_->frontend_loop_->PostTask( |
- FROM_HERE, |
- NewRunnableMethod(this, &Core::NotifyResumed)); |
-} |
- |
void SyncBackendHost::Core::OnStopSyncingPermanently() { |
host_->frontend_loop_->PostTask(FROM_HERE, NewRunnableMethod(this, |
&Core::HandleStopSyncingPermanentlyOnFrontendLoop)); |
@@ -1130,14 +1061,6 @@ void SyncBackendHost::Core::DoRequestClearServerData() { |
syncapi_->RequestClearServerData(); |
} |
-void SyncBackendHost::Core::DoRequestResume() { |
- syncapi_->RequestResume(); |
-} |
- |
-void SyncBackendHost::Core::DoRequestPause() { |
- syncapi()->RequestPause(); |
-} |
- |
void SyncBackendHost::Core::SaveChanges() { |
syncapi_->SaveChanges(); |
} |
@@ -1213,11 +1136,6 @@ void SyncBackendHost::Core::DoProcessMessage( |
syncapi_->GetJsBackend()->ProcessMessage(name, args, sender); |
} |
-void SyncBackendHost::Core::DoStartConfigurationMode() { |
- syncapi_->StartConfigurationMode(NewCallback(this, |
- &SyncBackendHost::Core::FinishConfigureDataTypes)); |
-} |
- |
void SyncBackendHost::Core::DeferNudgeForCleanup() { |
DCHECK_EQ(MessageLoop::current(), host_->core_thread_.message_loop()); |
deferred_nudge_for_cleanup_requested_ = true; |