| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/prefs/pref_member.h" | 5 #include "base/prefs/pref_member.h" |
| 6 #include "base/prefs/pref_service.h" | 6 #include "base/prefs/pref_service.h" |
| 7 #include "base/run_loop.h" | 7 #include "base/run_loop.h" |
| 8 #include "chrome/browser/sync/profile_sync_service.h" | 8 #include "chrome/browser/sync/profile_sync_service.h" |
| 9 #include "chrome/browser/sync/test/integration/bookmarks_helper.h" | 9 #include "chrome/browser/sync/test/integration/bookmarks_helper.h" |
| 10 #include "chrome/browser/sync/test/integration/passwords_helper.h" | 10 #include "chrome/browser/sync/test/integration/passwords_helper.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 virtual bool IsExitConditionSatisfied() OVERRIDE { | 30 virtual bool IsExitConditionSatisfied() OVERRIDE { |
| 31 return !service()->setup_in_progress() && | 31 return !service()->setup_in_progress() && |
| 32 !service()->HasSyncSetupCompleted(); | 32 !service()->HasSyncSetupCompleted(); |
| 33 } | 33 } |
| 34 | 34 |
| 35 virtual std::string GetDebugMessage() const OVERRIDE { | 35 virtual std::string GetDebugMessage() const OVERRIDE { |
| 36 return "Sync Disabled"; | 36 return "Sync Disabled"; |
| 37 } | 37 } |
| 38 }; | 38 }; |
| 39 | 39 |
| 40 class TypeDisabledChecker : public SingleClientStatusChangeChecker { | |
| 41 public: | |
| 42 explicit TypeDisabledChecker(ProfileSyncService* service, | |
| 43 syncer::ModelType type) | |
| 44 : SingleClientStatusChangeChecker(service), type_(type) {} | |
| 45 | |
| 46 virtual bool IsExitConditionSatisfied() OVERRIDE { | |
| 47 return !service()->GetActiveDataTypes().Has(type_); | |
| 48 } | |
| 49 | |
| 50 virtual std::string GetDebugMessage() const OVERRIDE { | |
| 51 return "Type disabled"; | |
| 52 } | |
| 53 private: | |
| 54 syncer::ModelType type_; | |
| 55 }; | |
| 56 | |
| 57 bool AwaitSyncDisabled(ProfileSyncService* service) { | 40 bool AwaitSyncDisabled(ProfileSyncService* service) { |
| 58 SyncDisabledChecker checker(service); | 41 SyncDisabledChecker checker(service); |
| 59 checker.Wait(); | 42 checker.Wait(); |
| 60 return !checker.TimedOut(); | 43 return !checker.TimedOut(); |
| 61 } | 44 } |
| 62 | 45 |
| 63 bool AwaitTypeDisabled(ProfileSyncService* service, | |
| 64 syncer::ModelType type) { | |
| 65 TypeDisabledChecker checker(service, type); | |
| 66 checker.Wait(); | |
| 67 return !checker.TimedOut(); | |
| 68 } | |
| 69 | |
| 70 class SyncErrorTest : public SyncTest { | 46 class SyncErrorTest : public SyncTest { |
| 71 public: | 47 public: |
| 72 SyncErrorTest() : SyncTest(SINGLE_CLIENT) {} | 48 SyncErrorTest() : SyncTest(SINGLE_CLIENT) {} |
| 73 virtual ~SyncErrorTest() {} | 49 virtual ~SyncErrorTest() {} |
| 74 | 50 |
| 75 private: | 51 private: |
| 76 DISALLOW_COPY_AND_ASSIGN(SyncErrorTest); | 52 DISALLOW_COPY_AND_ASSIGN(SyncErrorTest); |
| 77 }; | 53 }; |
| 78 | 54 |
| 79 // TODO(pvalenzuela): Remove this class when all tests here are converted to | 55 // TODO(pvalenzuela): Remove this class when all tests here are converted to |
| (...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 220 | 196 |
| 221 IN_PROC_BROWSER_TEST_F(LegacySyncErrorTest, DisableDatatypeWhileRunning) { | 197 IN_PROC_BROWSER_TEST_F(LegacySyncErrorTest, DisableDatatypeWhileRunning) { |
| 222 ASSERT_TRUE(SetupSync()) << "SetupSync() failed."; | 198 ASSERT_TRUE(SetupSync()) << "SetupSync() failed."; |
| 223 syncer::ModelTypeSet synced_datatypes = | 199 syncer::ModelTypeSet synced_datatypes = |
| 224 GetSyncService((0))->GetActiveDataTypes(); | 200 GetSyncService((0))->GetActiveDataTypes(); |
| 225 ASSERT_TRUE(synced_datatypes.Has(syncer::TYPED_URLS)); | 201 ASSERT_TRUE(synced_datatypes.Has(syncer::TYPED_URLS)); |
| 226 ASSERT_TRUE(synced_datatypes.Has(syncer::SESSIONS)); | 202 ASSERT_TRUE(synced_datatypes.Has(syncer::SESSIONS)); |
| 227 GetProfile(0)->GetPrefs()->SetBoolean( | 203 GetProfile(0)->GetPrefs()->SetBoolean( |
| 228 prefs::kSavingBrowserHistoryDisabled, true); | 204 prefs::kSavingBrowserHistoryDisabled, true); |
| 229 | 205 |
| 230 // Wait for reconfigurations. | 206 // Flush any tasks posted by observers of the pref change. |
| 231 ASSERT_TRUE(AwaitTypeDisabled(GetSyncService(0), syncer::TYPED_URLS)); | 207 base::RunLoop().RunUntilIdle(); |
| 232 ASSERT_TRUE(AwaitTypeDisabled(GetSyncService(0), syncer::SESSIONS)); | 208 |
| 209 synced_datatypes = GetSyncService((0))->GetActiveDataTypes(); |
| 210 ASSERT_FALSE(synced_datatypes.Has(syncer::TYPED_URLS)); |
| 211 ASSERT_FALSE(synced_datatypes.Has(syncer::SESSIONS)); |
| 233 | 212 |
| 234 const BookmarkNode* node1 = AddFolder(0, 0, "title1"); | 213 const BookmarkNode* node1 = AddFolder(0, 0, "title1"); |
| 235 SetTitle(0, node1, "new_title1"); | 214 SetTitle(0, node1, "new_title1"); |
| 236 ASSERT_TRUE(AwaitCommitActivityCompletion(GetSyncService((0)))); | 215 ASSERT_TRUE(AwaitCommitActivityCompletion(GetSyncService((0)))); |
| 237 // TODO(lipalani)" Verify initial sync ended for typed url is false. | 216 // TODO(lipalani)" Verify initial sync ended for typed url is false. |
| 238 } | 217 } |
| 239 | 218 |
| 240 } // namespace | 219 } // namespace |
| OLD | NEW |