| 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 "chrome/browser/sync/test/integration/sync_test.h" | 5 #include "chrome/browser/sync/test/integration/sync_test.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| 11 #include "base/command_line.h" | 11 #include "base/command_line.h" |
| 12 #include "base/message_loop.h" | 12 #include "base/message_loop.h" |
| 13 #include "base/path_service.h" | 13 #include "base/path_service.h" |
| 14 #include "base/strings/string_util.h" | 14 #include "base/strings/string_util.h" |
| 15 #include "base/strings/stringprintf.h" | 15 #include "base/strings/stringprintf.h" |
| 16 #include "base/strings/utf_string_conversions.h" | 16 #include "base/strings/utf_string_conversions.h" |
| 17 #include "base/synchronization/waitable_event.h" | 17 #include "base/synchronization/waitable_event.h" |
| 18 #include "base/test/test_timeouts.h" | 18 #include "base/test/test_timeouts.h" |
| 19 #include "base/threading/platform_thread.h" | 19 #include "base/threading/platform_thread.h" |
| 20 #include "base/values.h" | 20 #include "base/values.h" |
| 21 #include "chrome/browser/bookmarks/bookmark_model_factory.h" | 21 #include "chrome/browser/bookmarks/bookmark_model_factory.h" |
| 22 #include "chrome/browser/google/google_url_tracker.h" | 22 #include "chrome/browser/google/google_url_tracker.h" |
| 23 #include "chrome/browser/history/history_service_factory.h" | 23 #include "chrome/browser/history/history_service_factory.h" |
| 24 #include "chrome/browser/invalidation/invalidation_service_factory.h" | |
| 25 #include "chrome/browser/invalidation/p2p_invalidation_service.h" | |
| 26 #include "chrome/browser/lifetime/application_lifetime.h" | 24 #include "chrome/browser/lifetime/application_lifetime.h" |
| 27 #include "chrome/browser/profiles/profile.h" | 25 #include "chrome/browser/profiles/profile.h" |
| 28 #include "chrome/browser/profiles/profile_manager.h" | 26 #include "chrome/browser/profiles/profile_manager.h" |
| 29 #include "chrome/browser/search_engines/template_url_service.h" | 27 #include "chrome/browser/search_engines/template_url_service.h" |
| 30 #include "chrome/browser/search_engines/template_url_service_factory.h" | 28 #include "chrome/browser/search_engines/template_url_service_factory.h" |
| 31 #include "chrome/browser/sync/profile_sync_service_factory.h" | 29 #include "chrome/browser/sync/profile_sync_service_factory.h" |
| 32 #include "chrome/browser/sync/profile_sync_service_harness.h" | 30 #include "chrome/browser/sync/profile_sync_service_harness.h" |
| 33 #include "chrome/browser/sync/test/integration/sync_datatype_helper.h" | 31 #include "chrome/browser/sync/test/integration/sync_datatype_helper.h" |
| 34 #include "chrome/browser/ui/browser.h" | 32 #include "chrome/browser/ui/browser.h" |
| 35 #include "chrome/browser/ui/browser_finder.h" | 33 #include "chrome/browser/ui/browser_finder.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 55 #include "net/url_request/url_fetcher.h" | 53 #include "net/url_request/url_fetcher.h" |
| 56 #include "net/url_request/url_fetcher_delegate.h" | 54 #include "net/url_request/url_fetcher_delegate.h" |
| 57 #include "net/url_request/url_request_context.h" | 55 #include "net/url_request/url_request_context.h" |
| 58 #include "net/url_request/url_request_context_getter.h" | 56 #include "net/url_request/url_request_context_getter.h" |
| 59 #include "net/url_request/url_request_status.h" | 57 #include "net/url_request/url_request_status.h" |
| 60 #include "sync/engine/sync_scheduler_impl.h" | 58 #include "sync/engine/sync_scheduler_impl.h" |
| 61 #include "sync/notifier/p2p_invalidator.h" | 59 #include "sync/notifier/p2p_invalidator.h" |
| 62 #include "sync/protocol/sync.pb.h" | 60 #include "sync/protocol/sync.pb.h" |
| 63 | 61 |
| 64 using content::BrowserThread; | 62 using content::BrowserThread; |
| 65 using invalidation::InvalidationServiceFactory; | |
| 66 | 63 |
| 67 namespace switches { | 64 namespace switches { |
| 68 const char kPasswordFileForTest[] = "password-file-for-test"; | 65 const char kPasswordFileForTest[] = "password-file-for-test"; |
| 69 const char kSyncUserForTest[] = "sync-user-for-test"; | 66 const char kSyncUserForTest[] = "sync-user-for-test"; |
| 70 const char kSyncPasswordForTest[] = "sync-password-for-test"; | 67 const char kSyncPasswordForTest[] = "sync-password-for-test"; |
| 71 const char kSyncServerCommandLine[] = "sync-server-command-line"; | 68 const char kSyncServerCommandLine[] = "sync-server-command-line"; |
| 72 } | 69 } |
| 73 | 70 |
| 74 // Helper class that checks whether a sync test server is running or not. | 71 // Helper class that checks whether a sync test server is running or not. |
| 75 class SyncServerStatusChecker : public net::URLFetcherDelegate { | 72 class SyncServerStatusChecker : public net::URLFetcherDelegate { |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 192 // Stop the local sync test server. This is a no-op if one wasn't started. | 189 // Stop the local sync test server. This is a no-op if one wasn't started. |
| 193 TearDownLocalTestServer(); | 190 TearDownLocalTestServer(); |
| 194 } | 191 } |
| 195 | 192 |
| 196 void SyncTest::SetUpCommandLine(CommandLine* cl) { | 193 void SyncTest::SetUpCommandLine(CommandLine* cl) { |
| 197 AddTestSwitches(cl); | 194 AddTestSwitches(cl); |
| 198 AddOptionalTypesToCommandLine(cl); | 195 AddOptionalTypesToCommandLine(cl); |
| 199 } | 196 } |
| 200 | 197 |
| 201 void SyncTest::AddTestSwitches(CommandLine* cl) { | 198 void SyncTest::AddTestSwitches(CommandLine* cl) { |
| 199 // TODO(rsimha): Until we implement a fake Tango server against which tests |
| 200 // can run, we need to set the --sync-notification-method to "p2p". |
| 201 if (!cl->HasSwitch(switches::kSyncNotificationMethod)) |
| 202 cl->AppendSwitchASCII(switches::kSyncNotificationMethod, "p2p"); |
| 203 |
| 202 // Disable non-essential access of external network resources. | 204 // Disable non-essential access of external network resources. |
| 203 if (!cl->HasSwitch(switches::kDisableBackgroundNetworking)) | 205 if (!cl->HasSwitch(switches::kDisableBackgroundNetworking)) |
| 204 cl->AppendSwitch(switches::kDisableBackgroundNetworking); | 206 cl->AppendSwitch(switches::kDisableBackgroundNetworking); |
| 205 | 207 |
| 206 if (!cl->HasSwitch(switches::kSyncShortInitialRetryOverride)) | 208 if (!cl->HasSwitch(switches::kSyncShortInitialRetryOverride)) |
| 207 cl->AppendSwitch(switches::kSyncShortInitialRetryOverride); | 209 cl->AppendSwitch(switches::kSyncShortInitialRetryOverride); |
| 208 | 210 |
| 209 // TODO(sync): Fix enable_disable_test.cc to play nice with priority | 211 // TODO(sync): Fix enable_disable_test.cc to play nice with priority |
| 210 // preferences. | 212 // preferences. |
| 211 if (!cl->HasSwitch(switches::kDisableSyncPriorityPreferences)) | 213 if (!cl->HasSwitch(switches::kDisableSyncPriorityPreferences)) |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 297 profiles_[index] = MakeProfile( | 299 profiles_[index] = MakeProfile( |
| 298 base::StringPrintf(FILE_PATH_LITERAL("Profile%d"), index)); | 300 base::StringPrintf(FILE_PATH_LITERAL("Profile%d"), index)); |
| 299 EXPECT_FALSE(GetProfile(index) == NULL) << "Could not create Profile " | 301 EXPECT_FALSE(GetProfile(index) == NULL) << "Could not create Profile " |
| 300 << index << "."; | 302 << index << "."; |
| 301 | 303 |
| 302 browsers_[index] = new Browser(Browser::CreateParams( | 304 browsers_[index] = new Browser(Browser::CreateParams( |
| 303 GetProfile(index), chrome::HOST_DESKTOP_TYPE_NATIVE)); | 305 GetProfile(index), chrome::HOST_DESKTOP_TYPE_NATIVE)); |
| 304 EXPECT_FALSE(GetBrowser(index) == NULL) << "Could not create Browser " | 306 EXPECT_FALSE(GetBrowser(index) == NULL) << "Could not create Browser " |
| 305 << index << "."; | 307 << index << "."; |
| 306 | 308 |
| 307 invalidation::P2PInvalidationService* p2p_invalidation_service = | |
| 308 InvalidationServiceFactory::GetInstance()-> | |
| 309 BuildAndUseP2PInvalidationServiceForTest(GetProfile(index)); | |
| 310 p2p_invalidation_service->UpdateCredentials(username_, password_); | |
| 311 | |
| 312 // Make sure the ProfileSyncService has been created before creating the | 309 // Make sure the ProfileSyncService has been created before creating the |
| 313 // ProfileSyncServiceHarness - some tests expect the ProfileSyncService to | 310 // ProfileSyncServiceHarness - some tests expect the ProfileSyncService to |
| 314 // already exist. | 311 // already exist. |
| 315 ProfileSyncServiceFactory::GetForProfile(GetProfile(index)); | 312 ProfileSyncServiceFactory::GetForProfile(GetProfile(index)); |
| 316 | 313 |
| 317 clients_[index] = | 314 clients_[index] = new ProfileSyncServiceHarness(GetProfile(index), |
| 318 ProfileSyncServiceHarness::CreateForIntegrationTest( | 315 username_, |
| 319 GetProfile(index), | 316 password_); |
| 320 username_, | |
| 321 password_, | |
| 322 p2p_invalidation_service); | |
| 323 EXPECT_FALSE(GetClient(index) == NULL) << "Could not create Client " | 317 EXPECT_FALSE(GetClient(index) == NULL) << "Could not create Client " |
| 324 << index << "."; | 318 << index << "."; |
| 325 | 319 |
| 326 ui_test_utils::WaitForBookmarkModelToLoad( | 320 ui_test_utils::WaitForBookmarkModelToLoad( |
| 327 BookmarkModelFactory::GetForProfile(GetProfile(index))); | 321 BookmarkModelFactory::GetForProfile(GetProfile(index))); |
| 328 ui_test_utils::WaitForHistoryToLoad(HistoryServiceFactory::GetForProfile( | 322 ui_test_utils::WaitForHistoryToLoad(HistoryServiceFactory::GetForProfile( |
| 329 GetProfile(index), Profile::EXPLICIT_ACCESS)); | 323 GetProfile(index), Profile::EXPLICIT_ACCESS)); |
| 330 ui_test_utils::WaitForTemplateURLServiceToLoad( | 324 ui_test_utils::WaitForTemplateURLServiceToLoad( |
| 331 TemplateURLServiceFactory::GetForProfile(GetProfile(index))); | 325 TemplateURLServiceFactory::GetForProfile(GetProfile(index))); |
| 332 } | 326 } |
| (...skipping 492 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 825 | 819 |
| 826 void SyncTest::SetProxyConfig(net::URLRequestContextGetter* context_getter, | 820 void SyncTest::SetProxyConfig(net::URLRequestContextGetter* context_getter, |
| 827 const net::ProxyConfig& proxy_config) { | 821 const net::ProxyConfig& proxy_config) { |
| 828 base::WaitableEvent done(false, false); | 822 base::WaitableEvent done(false, false); |
| 829 BrowserThread::PostTask( | 823 BrowserThread::PostTask( |
| 830 BrowserThread::IO, FROM_HERE, | 824 BrowserThread::IO, FROM_HERE, |
| 831 base::Bind(&SetProxyConfigCallback, &done, | 825 base::Bind(&SetProxyConfigCallback, &done, |
| 832 make_scoped_refptr(context_getter), proxy_config)); | 826 make_scoped_refptr(context_getter), proxy_config)); |
| 833 done.Wait(); | 827 done.Wait(); |
| 834 } | 828 } |
| OLD | NEW |