| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/glue/sync_backend_host_impl.h" | 5 #include "chrome/browser/sync/glue/sync_backend_host_impl.h" |
| 6 | 6 |
| 7 #include <cstddef> | 7 #include <cstddef> |
| 8 | 8 |
| 9 #include "base/files/file_util.h" | 9 #include "base/files/file_util.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| 11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 12 #include "base/message_loop/message_loop.h" | 12 #include "base/message_loop/message_loop.h" |
| 13 #include "base/synchronization/waitable_event.h" | 13 #include "base/synchronization/waitable_event.h" |
| 14 #include "base/test/test_timeouts.h" | 14 #include "base/test/test_timeouts.h" |
| 15 #include "base/time/time.h" |
| 15 #include "chrome/browser/chrome_notification_types.h" | 16 #include "chrome/browser/chrome_notification_types.h" |
| 16 #include "chrome/browser/invalidation/profile_invalidation_provider_factory.h" | 17 #include "chrome/browser/invalidation/profile_invalidation_provider_factory.h" |
| 18 #include "chrome/browser/sync/profile_sync_test_util.h" |
| 17 #include "chrome/test/base/testing_browser_process.h" | 19 #include "chrome/test/base/testing_browser_process.h" |
| 18 #include "chrome/test/base/testing_profile.h" | 20 #include "chrome/test/base/testing_profile.h" |
| 19 #include "chrome/test/base/testing_profile_manager.h" | 21 #include "chrome/test/base/testing_profile_manager.h" |
| 20 #include "components/invalidation/impl/invalidator_storage.h" | 22 #include "components/invalidation/impl/invalidator_storage.h" |
| 21 #include "components/invalidation/impl/profile_invalidation_provider.h" | 23 #include "components/invalidation/impl/profile_invalidation_provider.h" |
| 22 #include "components/invalidation/public/invalidator_state.h" | 24 #include "components/invalidation/public/invalidator_state.h" |
| 23 #include "components/invalidation/public/object_id_invalidation_map.h" | 25 #include "components/invalidation/public/object_id_invalidation_map.h" |
| 24 #include "components/sync_driver/device_info.h" | 26 #include "components/sync_driver/device_info.h" |
| 25 #include "components/sync_driver/fake_sync_client.h" | 27 #include "components/sync_driver/fake_sync_client.h" |
| 26 #include "components/sync_driver/sync_frontend.h" | 28 #include "components/sync_driver/sync_frontend.h" |
| 27 #include "components/sync_driver/sync_prefs.h" | 29 #include "components/sync_driver/sync_prefs.h" |
| 28 #include "components/syncable_prefs/pref_service_syncable.h" | 30 #include "components/syncable_prefs/pref_service_syncable.h" |
| 29 #include "content/public/browser/notification_service.h" | 31 #include "content/public/browser/notification_service.h" |
| 30 #include "content/public/test/test_browser_thread_bundle.h" | 32 #include "content/public/test/test_browser_thread_bundle.h" |
| 31 #include "content/public/test/test_utils.h" | 33 #include "content/public/test/test_utils.h" |
| 32 #include "google/cacheinvalidation/include/types.h" | 34 #include "google/cacheinvalidation/include/types.h" |
| 33 #include "google_apis/gaia/gaia_constants.h" | 35 #include "google_apis/gaia/gaia_constants.h" |
| 34 #include "net/url_request/test_url_fetcher_factory.h" | 36 #include "net/url_request/test_url_fetcher_factory.h" |
| 37 #include "net/url_request/url_request_context_getter.h" |
| 35 #include "sync/internal_api/public/base/model_type.h" | 38 #include "sync/internal_api/public/base/model_type.h" |
| 36 #include "sync/internal_api/public/engine/model_safe_worker.h" | 39 #include "sync/internal_api/public/engine/model_safe_worker.h" |
| 37 #include "sync/internal_api/public/engine/passive_model_worker.h" | 40 #include "sync/internal_api/public/engine/passive_model_worker.h" |
| 38 #include "sync/internal_api/public/http_bridge_network_resources.h" | 41 #include "sync/internal_api/public/http_bridge_network_resources.h" |
| 39 #include "sync/internal_api/public/network_resources.h" | 42 #include "sync/internal_api/public/network_resources.h" |
| 40 #include "sync/internal_api/public/sessions/commit_counters.h" | 43 #include "sync/internal_api/public/sessions/commit_counters.h" |
| 41 #include "sync/internal_api/public/sessions/status_counters.h" | 44 #include "sync/internal_api/public/sessions/status_counters.h" |
| 42 #include "sync/internal_api/public/sessions/update_counters.h" | 45 #include "sync/internal_api/public/sessions/update_counters.h" |
| 43 #include "sync/internal_api/public/sync_manager_factory.h" | 46 #include "sync/internal_api/public/sync_manager_factory.h" |
| 44 #include "sync/internal_api/public/test/fake_sync_manager.h" | 47 #include "sync/internal_api/public/test/fake_sync_manager.h" |
| (...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 220 base::RunLoop().RunUntilIdle(); | 223 base::RunLoop().RunUntilIdle(); |
| 221 content::RunAllPendingInMessageLoop(BrowserThread::IO); | 224 content::RunAllPendingInMessageLoop(BrowserThread::IO); |
| 222 // Pump any messages posted by the IO thread. | 225 // Pump any messages posted by the IO thread. |
| 223 base::RunLoop().RunUntilIdle(); | 226 base::RunLoop().RunUntilIdle(); |
| 224 } | 227 } |
| 225 | 228 |
| 226 // Synchronously initializes the backend. | 229 // Synchronously initializes the backend. |
| 227 void InitializeBackend(bool expect_success) { | 230 void InitializeBackend(bool expect_success) { |
| 228 EXPECT_CALL(mock_frontend_, OnBackendInitialized(_, _, _, expect_success)). | 231 EXPECT_CALL(mock_frontend_, OnBackendInitialized(_, _, _, expect_success)). |
| 229 WillOnce(InvokeWithoutArgs(QuitMessageLoop)); | 232 WillOnce(InvokeWithoutArgs(QuitMessageLoop)); |
| 233 SyncBackendHost::HttpPostProviderFactoryGetter |
| 234 http_post_provider_factory_getter = |
| 235 base::Bind(&syncer::NetworkResources::GetHttpPostProviderFactory, |
| 236 base::Unretained(network_resources_.get()), |
| 237 make_scoped_refptr(profile_->GetRequestContext()), |
| 238 base::Bind(&EmptyNetworkTimeUpdate)); |
| 230 backend_->Initialize( | 239 backend_->Initialize( |
| 231 &mock_frontend_, scoped_ptr<base::Thread>(), | 240 &mock_frontend_, scoped_ptr<base::Thread>(), |
| 232 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::DB), | 241 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::DB), |
| 233 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE), | 242 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE), |
| 234 syncer::WeakHandle<syncer::JsEventHandler>(), GURL(std::string()), | 243 syncer::WeakHandle<syncer::JsEventHandler>(), GURL(std::string()), |
| 235 std::string(), credentials_, true, fake_manager_factory_.Pass(), | 244 std::string(), credentials_, true, fake_manager_factory_.Pass(), |
| 236 MakeWeakHandle(test_unrecoverable_error_handler_.GetWeakPtr()), | 245 MakeWeakHandle(test_unrecoverable_error_handler_.GetWeakPtr()), |
| 237 base::Closure(), network_resources_.get(), saved_nigori_state_.Pass()); | 246 base::Closure(), http_post_provider_factory_getter, |
| 247 saved_nigori_state_.Pass()); |
| 238 base::RunLoop run_loop; | 248 base::RunLoop run_loop; |
| 239 BrowserThread::PostDelayedTask(BrowserThread::UI, FROM_HERE, | 249 BrowserThread::PostDelayedTask(BrowserThread::UI, FROM_HERE, |
| 240 run_loop.QuitClosure(), | 250 run_loop.QuitClosure(), |
| 241 TestTimeouts::action_timeout()); | 251 TestTimeouts::action_timeout()); |
| 242 run_loop.Run(); | 252 run_loop.Run(); |
| 243 // |fake_manager_factory_|'s fake_manager() is set on the sync | 253 // |fake_manager_factory_|'s fake_manager() is set on the sync |
| 244 // thread, but we can rely on the message loop barriers to | 254 // thread, but we can rely on the message loop barriers to |
| 245 // guarantee that we see the updated value. | 255 // guarantee that we see the updated value. |
| 246 DCHECK(fake_manager_); | 256 DCHECK(fake_manager_); |
| 247 } | 257 } |
| (...skipping 634 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 882 EXPECT_EQ(invalidation_versions.size(), | 892 EXPECT_EQ(invalidation_versions.size(), |
| 883 persisted_invalidation_versions.size()); | 893 persisted_invalidation_versions.size()); |
| 884 for (auto iter : persisted_invalidation_versions) { | 894 for (auto iter : persisted_invalidation_versions) { |
| 885 EXPECT_EQ(invalidation_versions[iter.first], iter.second); | 895 EXPECT_EQ(invalidation_versions[iter.first], iter.second); |
| 886 } | 896 } |
| 887 } | 897 } |
| 888 | 898 |
| 889 } // namespace | 899 } // namespace |
| 890 | 900 |
| 891 } // namespace browser_sync | 901 } // namespace browser_sync |
| OLD | NEW |