| 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 "sync/internal_api/sync_manager_impl.h" | 5 #include "sync/internal_api/sync_manager_impl.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/base64.h" | 9 #include "base/base64.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 313 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 324 new_routing_info, | 324 new_routing_info, |
| 325 ready_task); | 325 ready_task); |
| 326 | 326 |
| 327 scheduler_->Start(SyncScheduler::CONFIGURATION_MODE); | 327 scheduler_->Start(SyncScheduler::CONFIGURATION_MODE); |
| 328 if (!scheduler_->ScheduleConfiguration(params)) | 328 if (!scheduler_->ScheduleConfiguration(params)) |
| 329 retry_task.Run(); | 329 retry_task.Run(); |
| 330 | 330 |
| 331 } | 331 } |
| 332 | 332 |
| 333 void SyncManagerImpl::Init( | 333 void SyncManagerImpl::Init( |
| 334 const FilePath& database_location, | 334 const base::FilePath& database_location, |
| 335 const WeakHandle<JsEventHandler>& event_handler, | 335 const WeakHandle<JsEventHandler>& event_handler, |
| 336 const std::string& sync_server_and_path, | 336 const std::string& sync_server_and_path, |
| 337 int port, | 337 int port, |
| 338 bool use_ssl, | 338 bool use_ssl, |
| 339 scoped_ptr<HttpPostProviderFactory> post_factory, | 339 scoped_ptr<HttpPostProviderFactory> post_factory, |
| 340 const std::vector<ModelSafeWorker*>& workers, | 340 const std::vector<ModelSafeWorker*>& workers, |
| 341 ExtensionsActivityMonitor* extensions_activity_monitor, | 341 ExtensionsActivityMonitor* extensions_activity_monitor, |
| 342 SyncManager::ChangeDelegate* change_delegate, | 342 SyncManager::ChangeDelegate* change_delegate, |
| 343 const SyncCredentials& credentials, | 343 const SyncCredentials& credentials, |
| 344 scoped_ptr<Invalidator> invalidator, | 344 scoped_ptr<Invalidator> invalidator, |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 377 !restored_keystore_key_for_bootstrapping.empty()); | 377 !restored_keystore_key_for_bootstrapping.empty()); |
| 378 sync_encryption_handler_.reset(new SyncEncryptionHandlerImpl( | 378 sync_encryption_handler_.reset(new SyncEncryptionHandlerImpl( |
| 379 &share_, | 379 &share_, |
| 380 encryptor, | 380 encryptor, |
| 381 restored_key_for_bootstrapping, | 381 restored_key_for_bootstrapping, |
| 382 restored_keystore_key_for_bootstrapping)); | 382 restored_keystore_key_for_bootstrapping)); |
| 383 sync_encryption_handler_->AddObserver(this); | 383 sync_encryption_handler_->AddObserver(this); |
| 384 sync_encryption_handler_->AddObserver(&debug_info_event_listener_); | 384 sync_encryption_handler_->AddObserver(&debug_info_event_listener_); |
| 385 sync_encryption_handler_->AddObserver(&js_sync_encryption_handler_observer_); | 385 sync_encryption_handler_->AddObserver(&js_sync_encryption_handler_observer_); |
| 386 | 386 |
| 387 FilePath absolute_db_path(database_path_); | 387 base::FilePath absolute_db_path(database_path_); |
| 388 file_util::AbsolutePath(&absolute_db_path); | 388 file_util::AbsolutePath(&absolute_db_path); |
| 389 scoped_ptr<syncable::DirectoryBackingStore> backing_store = | 389 scoped_ptr<syncable::DirectoryBackingStore> backing_store = |
| 390 internal_components_factory->BuildDirectoryBackingStore( | 390 internal_components_factory->BuildDirectoryBackingStore( |
| 391 credentials.email, absolute_db_path).Pass(); | 391 credentials.email, absolute_db_path).Pass(); |
| 392 | 392 |
| 393 DCHECK(backing_store.get()); | 393 DCHECK(backing_store.get()); |
| 394 share_.name = credentials.email; | 394 share_.name = credentials.email; |
| 395 share_.directory.reset( | 395 share_.directory.reset( |
| 396 new syncable::Directory( | 396 new syncable::Directory( |
| 397 backing_store.release(), | 397 backing_store.release(), |
| (...skipping 986 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1384 int SyncManagerImpl::GetDefaultNudgeDelay() { | 1384 int SyncManagerImpl::GetDefaultNudgeDelay() { |
| 1385 return kDefaultNudgeDelayMilliseconds; | 1385 return kDefaultNudgeDelayMilliseconds; |
| 1386 } | 1386 } |
| 1387 | 1387 |
| 1388 // static. | 1388 // static. |
| 1389 int SyncManagerImpl::GetPreferencesNudgeDelay() { | 1389 int SyncManagerImpl::GetPreferencesNudgeDelay() { |
| 1390 return kPreferencesNudgeDelayMilliseconds; | 1390 return kPreferencesNudgeDelayMilliseconds; |
| 1391 } | 1391 } |
| 1392 | 1392 |
| 1393 } // namespace syncer | 1393 } // namespace syncer |
| OLD | NEW |