Not for review: Support sync init with missing or corrupt store

chrome/browser/sync/test_profile_sync_service.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/sync/test_profile_sync_service.h"
 
 #include "chrome/browser/signin/signin_manager.h"
 #include "chrome/browser/sync/abstract_profile_sync_service_test.h"
 #include "chrome/browser/sync/glue/data_type_controller.h"
 #include "chrome/browser/sync/glue/sync_backend_host.h"
 #include "chrome/browser/sync/profile_sync_components_factory.h"
 #include "chrome/browser/sync/test/test_http_bridge_factory.h"
 #include "chrome/common/chrome_notification_types.h"
 #include "sync/internal_api/user_share.h"
 #include "sync/js/js_reply_handler.h"
 #include "sync/protocol/encryption.pb.h"
 #include "sync/sessions/session_state.h"
 #include "sync/syncable/syncable.h"
 
+#include "chrome/browser/sync/glue/sync_backend_registrar.h"
+
 using browser_sync::ModelSafeRoutingInfo;
 using browser_sync::sessions::ErrorCounters;
 using browser_sync::sessions::SyncSourceInfo;
 using browser_sync::sessions::SyncerStatus;
 using browser_sync::sessions::SyncSessionSnapshot;
 using syncable::Directory;
 using syncable::ModelType;
 using sync_api::UserShare;
 
 namespace browser_sync {
 
 SyncBackendHostForProfileSyncTest::SyncBackendHostForProfileSyncTest(
     Profile* profile,
     const base::WeakPtr<SyncPrefs>& sync_prefs,
     const base::WeakPtr<InvalidatorStorage>& invalidator_storage,
-    bool set_initial_sync_ended_on_init,
     bool synchronous_init,
-    bool fail_initial_download,
+    bool fail_all_downloads,
     bool use_real_database)
     : browser_sync::SyncBackendHost(
         profile->GetDebugName(), profile, sync_prefs, invalidator_storage),
       synchronous_init_(synchronous_init),
-      fail_initial_download_(fail_initial_download),
+      fail_all_downloads_(fail_all_downloads),
       use_real_database_(use_real_database) {}
 
 SyncBackendHostForProfileSyncTest::~SyncBackendHostForProfileSyncTest() {}
 
-void SyncBackendHostForProfileSyncTest::
-    SimulateSyncCycleCompletedInitialSyncEnded(
-    const tracked_objects::Location& location) {
-  syncable::ModelTypeSet sync_ended;
-  if (!fail_initial_download_)
-    sync_ended = syncable::ModelTypeSet::All();
-  syncable::ModelTypePayloadMap download_progress_markers;
-  HandleSyncCycleCompletedOnFrontendLoop(SyncSessionSnapshot(
-      SyncerStatus(), ErrorCounters(), 0, false,
-      sync_ended, download_progress_markers, false, false, 0, 0, 0, 0,
-      SyncSourceInfo(), false, 0, base::Time::Now(), false));
-}
-
 namespace {
 
 sync_api::HttpPostProviderFactory* MakeTestHttpBridgeFactory() {
   return new browser_sync::TestHttpBridgeFactory();
 }
 
 }  // namespace
 
 void SyncBackendHostForProfileSyncTest::InitCore(
     const DoInitializeOptions& options) {
@@ skipping 11 matching lines @@
   if (synchronous_init_) {
     // The SyncBackend posts a task to the current loop when
     // initialization completes.
     MessageLoop::current()->Run();
   }
 }
 
 void SyncBackendHostForProfileSyncTest::StartConfiguration(
     const base::Closure& callback) {
   SyncBackendHost::FinishConfigureDataTypesOnFrontendLoop();
-  if (IsDownloadingNigoriForTest()) {
-    syncable::ModelTypeSet sync_ended;
 
-    if (!fail_initial_download_)
-      sync_ended.Put(syncable::NIGORI);
+  if (!fail_all_downloads_ && pending_download_state_.get()) {
+    // Give the SBH the callback it is waiting for.
     syncable::ModelTypePayloadMap download_progress_markers;
     HandleSyncCycleCompletedOnFrontendLoop(SyncSessionSnapshot(
         SyncerStatus(), ErrorCounters(), 0, false,
-        sync_ended, download_progress_markers, false, false, 0, 0, 0, 0,
+        pending_download_state_->types_to_add,
+        download_progress_markers, false, false, 0, 0, 0, 0,
         SyncSourceInfo(), false, 0, base::Time::Now(), false));
   }
 }
 
 void SyncBackendHostForProfileSyncTest::SetHistoryServiceExpectations(
     ProfileMock* profile) {
   EXPECT_CALL(*profile, GetHistoryService(testing::_)).
       WillOnce(testing::Return((HistoryService*)NULL));
 }
 
@@ skipping 18 matching lines @@
     const base::Closure& callback)
     : ProfileSyncService(factory,
                          profile,
                          signin,
                          behavior),
       synchronous_backend_initialization_(
           synchronous_backend_initialization),
       synchronous_sync_configuration_(false),
       callback_(callback),
       set_initial_sync_ended_on_init_(true),
-      fail_initial_download_(false),
+      fail_all_downloads_(false),
       use_real_database_(false) {
   SetSyncSetupCompleted();
 }
 
 TestProfileSyncService::~TestProfileSyncService() {
 }
 
 void TestProfileSyncService::SetInitialSyncEndedForAllTypes() {
   UserShare* user_share = GetUserShare();
   Directory* directory = user_share->directory.get();
@@ skipping 59 matching lines @@
     MessageLoop::current()->Quit();
   }
 }
 
 void TestProfileSyncService::dont_set_initial_sync_ended_on_init() {
   set_initial_sync_ended_on_init_ = false;
 }
 void TestProfileSyncService::set_synchronous_sync_configuration() {
   synchronous_sync_configuration_ = true;
 }
-void TestProfileSyncService::fail_initial_download() {
-  fail_initial_download_ = true;
+void TestProfileSyncService::fail_all_downloads() {
+  fail_all_downloads_ = true;
 }
 void TestProfileSyncService::set_use_real_database() {
   use_real_database_ = true;
 }
 
 void TestProfileSyncService::CreateBackend() {
   backend_.reset(new browser_sync::SyncBackendHostForProfileSyncTest(
       profile(),
       sync_prefs_.AsWeakPtr(),
       invalidator_storage_.AsWeakPtr(),
-      set_initial_sync_ended_on_init_,
       synchronous_backend_initialization_,
-      fail_initial_download_,
+      fail_all_downloads_,
       use_real_database_));
 }