| 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" |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 98 base::WaitableEvent* done, | 98 base::WaitableEvent* done, |
| 99 net::URLRequestContextGetter* url_request_context_getter, | 99 net::URLRequestContextGetter* url_request_context_getter, |
| 100 const net::ProxyConfig& proxy_config) { | 100 const net::ProxyConfig& proxy_config) { |
| 101 net::ProxyService* proxy_service = | 101 net::ProxyService* proxy_service = |
| 102 url_request_context_getter->GetURLRequestContext()->proxy_service(); | 102 url_request_context_getter->GetURLRequestContext()->proxy_service(); |
| 103 proxy_service->ResetConfigService( | 103 proxy_service->ResetConfigService( |
| 104 new net::ProxyConfigServiceFixed(proxy_config)); | 104 new net::ProxyConfigServiceFixed(proxy_config)); |
| 105 done->Signal(); | 105 done->Signal(); |
| 106 } | 106 } |
| 107 | 107 |
| 108 BrowserContextKeyedService* BuildP2PInvalidationService( |
| 109 content::BrowserContext* context) { |
| 110 Profile* profile = static_cast<Profile*>(context); |
| 111 return new invalidation::P2PInvalidationService(profile); |
| 112 } |
| 113 |
| 108 SyncTest::SyncTest(TestType test_type) | 114 SyncTest::SyncTest(TestType test_type) |
| 109 : test_type_(test_type), | 115 : test_type_(test_type), |
| 110 server_type_(SERVER_TYPE_UNDECIDED), | 116 server_type_(SERVER_TYPE_UNDECIDED), |
| 111 num_clients_(-1), | 117 num_clients_(-1), |
| 112 use_verifier_(true), | 118 use_verifier_(true), |
| 113 notifications_enabled_(true), | 119 notifications_enabled_(true), |
| 114 test_server_handle_(base::kNullProcessHandle) { | 120 test_server_handle_(base::kNullProcessHandle) { |
| 115 sync_datatype_helper::AssociateWithTest(this); | 121 sync_datatype_helper::AssociateWithTest(this); |
| 116 switch (test_type_) { | 122 switch (test_type_) { |
| 117 case SINGLE_CLIENT: { | 123 case SINGLE_CLIENT: { |
| (...skipping 189 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 307 base::StringPrintf(FILE_PATH_LITERAL("Profile%d"), index)); | 313 base::StringPrintf(FILE_PATH_LITERAL("Profile%d"), index)); |
| 308 EXPECT_FALSE(GetProfile(index) == NULL) << "Could not create Profile " | 314 EXPECT_FALSE(GetProfile(index) == NULL) << "Could not create Profile " |
| 309 << index << "."; | 315 << index << "."; |
| 310 | 316 |
| 311 browsers_[index] = new Browser(Browser::CreateParams( | 317 browsers_[index] = new Browser(Browser::CreateParams( |
| 312 GetProfile(index), chrome::GetActiveDesktop())); | 318 GetProfile(index), chrome::GetActiveDesktop())); |
| 313 EXPECT_FALSE(GetBrowser(index) == NULL) << "Could not create Browser " | 319 EXPECT_FALSE(GetBrowser(index) == NULL) << "Could not create Browser " |
| 314 << index << "."; | 320 << index << "."; |
| 315 | 321 |
| 316 invalidation::P2PInvalidationService* p2p_invalidation_service = | 322 invalidation::P2PInvalidationService* p2p_invalidation_service = |
| 317 InvalidationServiceFactory::GetInstance()-> | 323 static_cast<invalidation::P2PInvalidationService*>( |
| 318 BuildAndUseP2PInvalidationServiceForTest(GetProfile(index)); | 324 InvalidationServiceFactory::GetInstance()->SetTestingFactoryAndUse( |
| 325 GetProfile(index), BuildP2PInvalidationService)); |
| 319 p2p_invalidation_service->UpdateCredentials(username_, password_); | 326 p2p_invalidation_service->UpdateCredentials(username_, password_); |
| 320 | 327 |
| 321 // Make sure the ProfileSyncService has been created before creating the | 328 // Make sure the ProfileSyncService has been created before creating the |
| 322 // ProfileSyncServiceHarness - some tests expect the ProfileSyncService to | 329 // ProfileSyncServiceHarness - some tests expect the ProfileSyncService to |
| 323 // already exist. | 330 // already exist. |
| 324 ProfileSyncService* profile_sync_service = | 331 ProfileSyncService* profile_sync_service = |
| 325 ProfileSyncServiceFactory::GetForProfile(GetProfile(index)); | 332 ProfileSyncServiceFactory::GetForProfile(GetProfile(index)); |
| 326 | 333 |
| 327 if (server_type_ == IN_PROCESS_FAKE_SERVER) { | 334 if (server_type_ == IN_PROCESS_FAKE_SERVER) { |
| 328 // TODO(pvalenzuela): Run the fake server via EmbeddedTestServer. | 335 // TODO(pvalenzuela): Run the fake server via EmbeddedTestServer. |
| (...skipping 536 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 865 BrowserThread::IO, FROM_HERE, | 872 BrowserThread::IO, FROM_HERE, |
| 866 base::Bind(&SetProxyConfigCallback, &done, | 873 base::Bind(&SetProxyConfigCallback, &done, |
| 867 make_scoped_refptr(context_getter), proxy_config)); | 874 make_scoped_refptr(context_getter), proxy_config)); |
| 868 done.Wait(); | 875 done.Wait(); |
| 869 } | 876 } |
| 870 | 877 |
| 871 void SyncTest::UseFakeServer() { | 878 void SyncTest::UseFakeServer() { |
| 872 DCHECK_EQ(SERVER_TYPE_UNDECIDED, server_type_); | 879 DCHECK_EQ(SERVER_TYPE_UNDECIDED, server_type_); |
| 873 server_type_ = IN_PROCESS_FAKE_SERVER; | 880 server_type_ = IN_PROCESS_FAKE_SERVER; |
| 874 } | 881 } |
| OLD | NEW |