| 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 "base/command_line.h" | 7 #include "base/command_line.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "chrome/browser/browser_process.h" | 9 #include "chrome/browser/browser_process.h" |
| 10 #include "chrome/browser/chrome_notification_types.h" | 10 #include "chrome/browser/chrome_notification_types.h" |
| (...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 128 CommandLine* cl = CommandLine::ForCurrentProcess(); | 128 CommandLine* cl = CommandLine::ForCurrentProcess(); |
| 129 if (cl->HasSwitch(switches::kSyncShortInitialRetryOverride)) { | 129 if (cl->HasSwitch(switches::kSyncShortInitialRetryOverride)) { |
| 130 factory_switches.backoff_override = | 130 factory_switches.backoff_override = |
| 131 InternalComponentsFactory::BACKOFF_SHORT_INITIAL_RETRY_OVERRIDE; | 131 InternalComponentsFactory::BACKOFF_SHORT_INITIAL_RETRY_OVERRIDE; |
| 132 } | 132 } |
| 133 if (cl->HasSwitch(switches::kSyncEnableGetUpdateAvoidance)) { | 133 if (cl->HasSwitch(switches::kSyncEnableGetUpdateAvoidance)) { |
| 134 factory_switches.pre_commit_updates_policy = | 134 factory_switches.pre_commit_updates_policy = |
| 135 InternalComponentsFactory::FORCE_ENABLE_PRE_COMMIT_UPDATE_AVOIDANCE; | 135 InternalComponentsFactory::FORCE_ENABLE_PRE_COMMIT_UPDATE_AVOIDANCE; |
| 136 } | 136 } |
| 137 | 137 |
| 138 SigninClient* signin_client = | |
| 139 ChromeSigninClientFactory::GetForProfile(profile_); | |
| 140 DCHECK(signin_client); | |
| 141 std::string signin_scoped_device_id = | |
| 142 signin_client->GetSigninScopedDeviceId(); | |
| 143 | |
| 144 scoped_ptr<DoInitializeOptions> init_opts(new DoInitializeOptions( | 138 scoped_ptr<DoInitializeOptions> init_opts(new DoInitializeOptions( |
| 145 registrar_->sync_thread()->message_loop(), | 139 registrar_->sync_thread()->message_loop(), |
| 146 registrar_.get(), | 140 registrar_.get(), |
| 147 routing_info, | 141 routing_info, |
| 148 workers, | 142 workers, |
| 149 extensions_activity_monitor_.GetExtensionsActivity(), | 143 extensions_activity_monitor_.GetExtensionsActivity(), |
| 150 event_handler, | 144 event_handler, |
| 151 sync_service_url, | 145 sync_service_url, |
| 152 network_resources->GetHttpPostProviderFactory( | 146 network_resources->GetHttpPostProviderFactory( |
| 153 make_scoped_refptr(profile_->GetRequestContext()), | 147 make_scoped_refptr(profile_->GetRequestContext()), |
| 154 base::Bind(&UpdateNetworkTime), | 148 base::Bind(&UpdateNetworkTime), |
| 155 core_->GetRequestContextCancelationSignal()), | 149 core_->GetRequestContextCancelationSignal()), |
| 156 credentials, | 150 credentials, |
| 157 invalidator_ ? invalidator_->GetInvalidatorClientId() : "", | 151 invalidator_ ? invalidator_->GetInvalidatorClientId() : "", |
| 158 sync_manager_factory.Pass(), | 152 sync_manager_factory.Pass(), |
| 159 delete_sync_data_folder, | 153 delete_sync_data_folder, |
| 160 sync_prefs_->GetEncryptionBootstrapToken(), | 154 sync_prefs_->GetEncryptionBootstrapToken(), |
| 161 sync_prefs_->GetKeystoreEncryptionBootstrapToken(), | 155 sync_prefs_->GetKeystoreEncryptionBootstrapToken(), |
| 162 scoped_ptr<InternalComponentsFactory>( | 156 scoped_ptr<InternalComponentsFactory>( |
| 163 new syncer::InternalComponentsFactoryImpl(factory_switches)).Pass(), | 157 new syncer::InternalComponentsFactoryImpl(factory_switches)).Pass(), |
| 164 unrecoverable_error_handler.Pass(), | 158 unrecoverable_error_handler.Pass(), |
| 165 report_unrecoverable_error_function, | 159 report_unrecoverable_error_function)); |
| 166 signin_scoped_device_id)); | |
| 167 InitCore(init_opts.Pass()); | 160 InitCore(init_opts.Pass()); |
| 168 } | 161 } |
| 169 | 162 |
| 170 void SyncBackendHostImpl::UpdateCredentials( | 163 void SyncBackendHostImpl::UpdateCredentials( |
| 171 const syncer::SyncCredentials& credentials) { | 164 const syncer::SyncCredentials& credentials) { |
| 172 DCHECK(registrar_->sync_thread()->IsRunning()); | 165 DCHECK(registrar_->sync_thread()->IsRunning()); |
| 173 registrar_->sync_thread()->message_loop()->PostTask(FROM_HERE, | 166 registrar_->sync_thread()->message_loop()->PostTask(FROM_HERE, |
| 174 base::Bind(&SyncBackendHostCore::DoUpdateCredentials, | 167 base::Bind(&SyncBackendHostCore::DoUpdateCredentials, |
| 175 core_.get(), | 168 core_.get(), |
| 176 credentials)); | 169 credentials)); |
| (...skipping 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 507 void SyncBackendHostImpl::GetModelSafeRoutingInfo( | 500 void SyncBackendHostImpl::GetModelSafeRoutingInfo( |
| 508 syncer::ModelSafeRoutingInfo* out) const { | 501 syncer::ModelSafeRoutingInfo* out) const { |
| 509 if (initialized()) { | 502 if (initialized()) { |
| 510 CHECK(registrar_.get()); | 503 CHECK(registrar_.get()); |
| 511 registrar_->GetModelSafeRoutingInfo(out); | 504 registrar_->GetModelSafeRoutingInfo(out); |
| 512 } else { | 505 } else { |
| 513 NOTREACHED(); | 506 NOTREACHED(); |
| 514 } | 507 } |
| 515 } | 508 } |
| 516 | 509 |
| 517 SyncedDeviceTracker* SyncBackendHostImpl::GetSyncedDeviceTracker() const { | |
| 518 if (!initialized()) | |
| 519 return NULL; | |
| 520 return core_->synced_device_tracker(); | |
| 521 } | |
| 522 | |
| 523 void SyncBackendHostImpl::RequestBufferedProtocolEventsAndEnableForwarding() { | 510 void SyncBackendHostImpl::RequestBufferedProtocolEventsAndEnableForwarding() { |
| 524 registrar_->sync_thread()->message_loop()->PostTask( | 511 registrar_->sync_thread()->message_loop()->PostTask( |
| 525 FROM_HERE, | 512 FROM_HERE, |
| 526 base::Bind( | 513 base::Bind( |
| 527 &SyncBackendHostCore::SendBufferedProtocolEventsAndEnableForwarding, | 514 &SyncBackendHostCore::SendBufferedProtocolEventsAndEnableForwarding, |
| 528 core_)); | 515 core_)); |
| 529 } | 516 } |
| 530 | 517 |
| 531 void SyncBackendHostImpl::DisableProtocolEventForwarding() { | 518 void SyncBackendHostImpl::DisableProtocolEventForwarding() { |
| 532 registrar_->sync_thread()->message_loop()->PostTask( | 519 registrar_->sync_thread()->message_loop()->PostTask( |
| (...skipping 351 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 884 | 871 |
| 885 base::MessageLoop* SyncBackendHostImpl::GetSyncLoopForTesting() { | 872 base::MessageLoop* SyncBackendHostImpl::GetSyncLoopForTesting() { |
| 886 return registrar_->sync_thread()->message_loop(); | 873 return registrar_->sync_thread()->message_loop(); |
| 887 } | 874 } |
| 888 | 875 |
| 889 } // namespace browser_sync | 876 } // namespace browser_sync |
| 890 | 877 |
| 891 #undef SDVLOG | 878 #undef SDVLOG |
| 892 | 879 |
| 893 #undef SLOG | 880 #undef SLOG |
| OLD | NEW |