| 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 "build/build_config.h" | 5 #include "build/build_config.h" |
| 6 | 6 |
| 7 #include "chrome/browser/sync/glue/sync_backend_host.h" | 7 #include "chrome/browser/sync/glue/sync_backend_host.h" |
| 8 | 8 |
| 9 #include <algorithm> | 9 #include <algorithm> |
| 10 #include <map> | 10 #include <map> |
| (...skipping 305 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 316 | 316 |
| 317 namespace { | 317 namespace { |
| 318 | 318 |
| 319 // Parses the given command line for notifier options. | 319 // Parses the given command line for notifier options. |
| 320 notifier::NotifierOptions ParseNotifierOptions( | 320 notifier::NotifierOptions ParseNotifierOptions( |
| 321 const CommandLine& command_line, | 321 const CommandLine& command_line, |
| 322 const scoped_refptr<net::URLRequestContextGetter>& | 322 const scoped_refptr<net::URLRequestContextGetter>& |
| 323 request_context_getter) { | 323 request_context_getter) { |
| 324 notifier::NotifierOptions notifier_options; | 324 notifier::NotifierOptions notifier_options; |
| 325 notifier_options.request_context_getter = request_context_getter; | 325 notifier_options.request_context_getter = request_context_getter; |
| 326 if (command_line.HasSwitch(switches::kSyncEnableOAuth2Token)) |
| 327 notifier_options.auth_mechanism = "X-OAUTH2"; |
| 326 | 328 |
| 327 if (command_line.HasSwitch(switches::kSyncNotificationHostPort)) { | 329 if (command_line.HasSwitch(switches::kSyncNotificationHostPort)) { |
| 328 notifier_options.xmpp_host_port = | 330 notifier_options.xmpp_host_port = |
| 329 net::HostPortPair::FromString( | 331 net::HostPortPair::FromString( |
| 330 command_line.GetSwitchValueASCII( | 332 command_line.GetSwitchValueASCII( |
| 331 switches::kSyncNotificationHostPort)); | 333 switches::kSyncNotificationHostPort)); |
| 332 DVLOG(1) << "Using " << notifier_options.xmpp_host_port.ToString() | 334 DVLOG(1) << "Using " << notifier_options.xmpp_host_port.ToString() |
| 333 << " for test sync notification server."; | 335 << " for test sync notification server."; |
| 334 } | 336 } |
| 335 | 337 |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 473 NetworkTimeTracker::BuildNotifierUpdateCallback()), | 475 NetworkTimeTracker::BuildNotifierUpdateCallback()), |
| 474 credentials, | 476 credentials, |
| 475 android_invalidator_bridge_.get(), | 477 android_invalidator_bridge_.get(), |
| 476 &invalidator_factory_, | 478 &invalidator_factory_, |
| 477 sync_manager_factory, | 479 sync_manager_factory, |
| 478 delete_sync_data_folder, | 480 delete_sync_data_folder, |
| 479 sync_prefs_->GetEncryptionBootstrapToken(), | 481 sync_prefs_->GetEncryptionBootstrapToken(), |
| 480 sync_prefs_->GetKeystoreEncryptionBootstrapToken(), | 482 sync_prefs_->GetKeystoreEncryptionBootstrapToken(), |
| 481 new InternalComponentsFactoryImpl(factory_switches), | 483 new InternalComponentsFactoryImpl(factory_switches), |
| 482 unrecoverable_error_handler, | 484 unrecoverable_error_handler, |
| 483 report_unrecoverable_error_function)); | 485 report_unrecoverable_error_function, |
| 486 cl->HasSwitch(switches::kSyncEnableOAuth2Token))); |
| 484 } | 487 } |
| 485 | 488 |
| 486 void SyncBackendHost::UpdateCredentials(const SyncCredentials& credentials) { | 489 void SyncBackendHost::UpdateCredentials(const SyncCredentials& credentials) { |
| 487 DCHECK(sync_thread_.IsRunning()); | 490 DCHECK(sync_thread_.IsRunning()); |
| 488 sync_thread_.message_loop()->PostTask(FROM_HERE, | 491 sync_thread_.message_loop()->PostTask(FROM_HERE, |
| 489 base::Bind(&SyncBackendHost::Core::DoUpdateCredentials, core_.get(), | 492 base::Bind(&SyncBackendHost::Core::DoUpdateCredentials, core_.get(), |
| 490 credentials)); | 493 credentials)); |
| 491 } | 494 } |
| 492 | 495 |
| 493 void SyncBackendHost::UpdateRegisteredInvalidationIds( | 496 void SyncBackendHost::UpdateRegisteredInvalidationIds( |
| (...skipping 463 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 957 const syncer::SyncCredentials& credentials, | 960 const syncer::SyncCredentials& credentials, |
| 958 AndroidInvalidatorBridge* android_invalidator_bridge, | 961 AndroidInvalidatorBridge* android_invalidator_bridge, |
| 959 syncer::InvalidatorFactory* invalidator_factory, | 962 syncer::InvalidatorFactory* invalidator_factory, |
| 960 syncer::SyncManagerFactory* sync_manager_factory, | 963 syncer::SyncManagerFactory* sync_manager_factory, |
| 961 bool delete_sync_data_folder, | 964 bool delete_sync_data_folder, |
| 962 const std::string& restored_key_for_bootstrapping, | 965 const std::string& restored_key_for_bootstrapping, |
| 963 const std::string& restored_keystore_key_for_bootstrapping, | 966 const std::string& restored_keystore_key_for_bootstrapping, |
| 964 InternalComponentsFactory* internal_components_factory, | 967 InternalComponentsFactory* internal_components_factory, |
| 965 syncer::UnrecoverableErrorHandler* unrecoverable_error_handler, | 968 syncer::UnrecoverableErrorHandler* unrecoverable_error_handler, |
| 966 syncer::ReportUnrecoverableErrorFunction | 969 syncer::ReportUnrecoverableErrorFunction |
| 967 report_unrecoverable_error_function) | 970 report_unrecoverable_error_function, |
| 971 bool use_oauth2_token) |
| 968 : sync_loop(sync_loop), | 972 : sync_loop(sync_loop), |
| 969 registrar(registrar), | 973 registrar(registrar), |
| 970 routing_info(routing_info), | 974 routing_info(routing_info), |
| 971 workers(workers), | 975 workers(workers), |
| 972 extensions_activity_monitor(extensions_activity_monitor), | 976 extensions_activity_monitor(extensions_activity_monitor), |
| 973 event_handler(event_handler), | 977 event_handler(event_handler), |
| 974 service_url(service_url), | 978 service_url(service_url), |
| 975 make_http_bridge_factory_fn(make_http_bridge_factory_fn), | 979 make_http_bridge_factory_fn(make_http_bridge_factory_fn), |
| 976 credentials(credentials), | 980 credentials(credentials), |
| 977 android_invalidator_bridge(android_invalidator_bridge), | 981 android_invalidator_bridge(android_invalidator_bridge), |
| 978 invalidator_factory(invalidator_factory), | 982 invalidator_factory(invalidator_factory), |
| 979 sync_manager_factory(sync_manager_factory), | 983 sync_manager_factory(sync_manager_factory), |
| 980 delete_sync_data_folder(delete_sync_data_folder), | 984 delete_sync_data_folder(delete_sync_data_folder), |
| 981 restored_key_for_bootstrapping(restored_key_for_bootstrapping), | 985 restored_key_for_bootstrapping(restored_key_for_bootstrapping), |
| 982 restored_keystore_key_for_bootstrapping( | 986 restored_keystore_key_for_bootstrapping( |
| 983 restored_keystore_key_for_bootstrapping), | 987 restored_keystore_key_for_bootstrapping), |
| 984 internal_components_factory(internal_components_factory), | 988 internal_components_factory(internal_components_factory), |
| 985 unrecoverable_error_handler(unrecoverable_error_handler), | 989 unrecoverable_error_handler(unrecoverable_error_handler), |
| 986 report_unrecoverable_error_function( | 990 report_unrecoverable_error_function( |
| 987 report_unrecoverable_error_function) { | 991 report_unrecoverable_error_function), |
| 992 use_oauth2_token(use_oauth2_token) { |
| 988 } | 993 } |
| 989 | 994 |
| 990 SyncBackendHost::DoInitializeOptions::~DoInitializeOptions() {} | 995 SyncBackendHost::DoInitializeOptions::~DoInitializeOptions() {} |
| 991 | 996 |
| 992 SyncBackendHost::Core::Core(const std::string& name, | 997 SyncBackendHost::Core::Core(const std::string& name, |
| 993 const base::FilePath& sync_data_folder_path, | 998 const base::FilePath& sync_data_folder_path, |
| 994 const base::WeakPtr<SyncBackendHost>& backend) | 999 const base::WeakPtr<SyncBackendHost>& backend) |
| 995 : name_(name), | 1000 : name_(name), |
| 996 sync_data_folder_path_(sync_data_folder_path), | 1001 sync_data_folder_path_(sync_data_folder_path), |
| 997 host_(backend), | 1002 host_(backend), |
| (...skipping 256 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1254 scoped_ptr<syncer::Invalidator>( | 1259 scoped_ptr<syncer::Invalidator>( |
| 1255 options.invalidator_factory->CreateInvalidator()), | 1260 options.invalidator_factory->CreateInvalidator()), |
| 1256 #endif | 1261 #endif |
| 1257 options.invalidator_factory->GetInvalidatorClientId(), | 1262 options.invalidator_factory->GetInvalidatorClientId(), |
| 1258 options.restored_key_for_bootstrapping, | 1263 options.restored_key_for_bootstrapping, |
| 1259 options.restored_keystore_key_for_bootstrapping, | 1264 options.restored_keystore_key_for_bootstrapping, |
| 1260 scoped_ptr<InternalComponentsFactory>( | 1265 scoped_ptr<InternalComponentsFactory>( |
| 1261 options.internal_components_factory), | 1266 options.internal_components_factory), |
| 1262 &encryptor_, | 1267 &encryptor_, |
| 1263 options.unrecoverable_error_handler, | 1268 options.unrecoverable_error_handler, |
| 1264 options.report_unrecoverable_error_function); | 1269 options.report_unrecoverable_error_function, |
| 1270 options.use_oauth2_token); |
| 1265 | 1271 |
| 1266 // |sync_manager_| may end up being NULL here in tests (in | 1272 // |sync_manager_| may end up being NULL here in tests (in |
| 1267 // synchronous initialization mode). | 1273 // synchronous initialization mode). |
| 1268 // | 1274 // |
| 1269 // TODO(akalin): Fix this behavior (see http://crbug.com/140354). | 1275 // TODO(akalin): Fix this behavior (see http://crbug.com/140354). |
| 1270 if (sync_manager_) { | 1276 if (sync_manager_) { |
| 1271 sync_manager_->RegisterInvalidationHandler(this); | 1277 sync_manager_->RegisterInvalidationHandler(this); |
| 1272 registered_as_invalidation_handler_ = true; | 1278 registered_as_invalidation_handler_ = true; |
| 1273 | 1279 |
| 1274 // Now check the command line to see if we need to simulate an | 1280 // Now check the command line to see if we need to simulate an |
| (...skipping 445 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1720 DVLOG(1) << "Connection status changed: " | 1726 DVLOG(1) << "Connection status changed: " |
| 1721 << syncer::ConnectionStatusToString(status); | 1727 << syncer::ConnectionStatusToString(status); |
| 1722 frontend_->OnConnectionStatusChange(status); | 1728 frontend_->OnConnectionStatusChange(status); |
| 1723 } | 1729 } |
| 1724 | 1730 |
| 1725 #undef SDVLOG | 1731 #undef SDVLOG |
| 1726 | 1732 |
| 1727 #undef SLOG | 1733 #undef SLOG |
| 1728 | 1734 |
| 1729 } // namespace browser_sync | 1735 } // namespace browser_sync |
| OLD | NEW |