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 |