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 "components/sync/driver/glue/sync_backend_host_core.h" | 5 #include "components/sync/driver/glue/sync_backend_host_core.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
11 #include "base/location.h" | 11 #include "base/location.h" |
12 #include "base/memory/ptr_util.h" | 12 #include "base/memory/ptr_util.h" |
13 #include "base/single_thread_task_runner.h" | 13 #include "base/single_thread_task_runner.h" |
| 14 #include "base/trace_event/memory_dump_manager.h" |
14 #include "components/data_use_measurement/core/data_use_user_data.h" | 15 #include "components/data_use_measurement/core/data_use_user_data.h" |
15 #include "components/invalidation/public/invalidation_util.h" | 16 #include "components/invalidation/public/invalidation_util.h" |
16 #include "components/invalidation/public/object_id_invalidation_map.h" | 17 #include "components/invalidation/public/object_id_invalidation_map.h" |
17 #include "components/sync/base/invalidation_adapter.h" | 18 #include "components/sync/base/invalidation_adapter.h" |
18 #include "components/sync/device_info/local_device_info_provider_impl.h" | 19 #include "components/sync/device_info/local_device_info_provider_impl.h" |
19 #include "components/sync/driver/glue/sync_backend_registrar.h" | 20 #include "components/sync/driver/glue/sync_backend_registrar.h" |
20 #include "components/sync/engine/cycle/commit_counters.h" | 21 #include "components/sync/engine/cycle/commit_counters.h" |
21 #include "components/sync/engine/cycle/status_counters.h" | 22 #include "components/sync/engine/cycle/status_counters.h" |
22 #include "components/sync/engine/cycle/sync_cycle_snapshot.h" | 23 #include "components/sync/engine/cycle/sync_cycle_snapshot.h" |
23 #include "components/sync/engine/cycle/update_counters.h" | 24 #include "components/sync/engine/cycle/update_counters.h" |
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
117 forward_protocol_events_(false), | 118 forward_protocol_events_(false), |
118 forward_type_info_(false), | 119 forward_type_info_(false), |
119 weak_ptr_factory_(this) { | 120 weak_ptr_factory_(this) { |
120 DCHECK(backend.get()); | 121 DCHECK(backend.get()); |
121 } | 122 } |
122 | 123 |
123 SyncBackendHostCore::~SyncBackendHostCore() { | 124 SyncBackendHostCore::~SyncBackendHostCore() { |
124 DCHECK(!sync_manager_.get()); | 125 DCHECK(!sync_manager_.get()); |
125 } | 126 } |
126 | 127 |
| 128 bool SyncBackendHostCore::OnMemoryDump( |
| 129 const base::trace_event::MemoryDumpArgs& args, |
| 130 base::trace_event::ProcessMemoryDump* pmd) { |
| 131 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); |
| 132 if (!sync_manager_) |
| 133 return false; |
| 134 sync_manager_->OnMemoryDump(pmd); |
| 135 return true; |
| 136 } |
| 137 |
127 void SyncBackendHostCore::OnSyncCycleCompleted( | 138 void SyncBackendHostCore::OnSyncCycleCompleted( |
128 const SyncCycleSnapshot& snapshot) { | 139 const SyncCycleSnapshot& snapshot) { |
129 if (!sync_loop_) | 140 if (!sync_loop_) |
130 return; | 141 return; |
131 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); | 142 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); |
132 | 143 |
133 host_.Call(FROM_HERE, | 144 host_.Call(FROM_HERE, |
134 &SyncBackendHostImpl::HandleSyncCycleCompletedOnFrontendLoop, | 145 &SyncBackendHostImpl::HandleSyncCycleCompletedOnFrontendLoop, |
135 snapshot); | 146 snapshot); |
136 } | 147 } |
(...skipping 281 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
418 options->restored_keystore_key_for_bootstrapping; | 429 options->restored_keystore_key_for_bootstrapping; |
419 args.engine_components_factory = | 430 args.engine_components_factory = |
420 std::move(options->engine_components_factory); | 431 std::move(options->engine_components_factory); |
421 args.encryptor = &encryptor_; | 432 args.encryptor = &encryptor_; |
422 args.unrecoverable_error_handler = options->unrecoverable_error_handler; | 433 args.unrecoverable_error_handler = options->unrecoverable_error_handler; |
423 args.report_unrecoverable_error_function = | 434 args.report_unrecoverable_error_function = |
424 options->report_unrecoverable_error_function; | 435 options->report_unrecoverable_error_function; |
425 args.cancelation_signal = &stop_syncing_signal_; | 436 args.cancelation_signal = &stop_syncing_signal_; |
426 args.saved_nigori_state = std::move(options->saved_nigori_state); | 437 args.saved_nigori_state = std::move(options->saved_nigori_state); |
427 sync_manager_->Init(&args); | 438 sync_manager_->Init(&args); |
| 439 base::trace_event::MemoryDumpManager::GetInstance()->RegisterDumpProvider( |
| 440 this, "SyncDirectory", sync_loop_->task_runner()); |
428 } | 441 } |
429 | 442 |
430 void SyncBackendHostCore::DoUpdateCredentials( | 443 void SyncBackendHostCore::DoUpdateCredentials( |
431 const SyncCredentials& credentials) { | 444 const SyncCredentials& credentials) { |
432 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); | 445 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); |
433 // UpdateCredentials can be called during backend initialization, possibly | 446 // UpdateCredentials can be called during backend initialization, possibly |
434 // when backend initialization has failed but hasn't notified the UI thread | 447 // when backend initialization has failed but hasn't notified the UI thread |
435 // yet. In that case, the sync manager may have been destroyed on the sync | 448 // yet. In that case, the sync manager may have been destroyed on the sync |
436 // thread before this task was executed, so we do nothing. | 449 // thread before this task was executed, so we do nothing. |
437 if (sync_manager_) { | 450 if (sync_manager_) { |
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
531 | 544 |
532 if (reason == DISABLE_SYNC) | 545 if (reason == DISABLE_SYNC) |
533 DeleteSyncDataFolder(); | 546 DeleteSyncDataFolder(); |
534 | 547 |
535 host_.Reset(); | 548 host_.Reset(); |
536 weak_ptr_factory_.InvalidateWeakPtrs(); | 549 weak_ptr_factory_.InvalidateWeakPtrs(); |
537 } | 550 } |
538 | 551 |
539 void SyncBackendHostCore::DoDestroySyncManager(ShutdownReason reason) { | 552 void SyncBackendHostCore::DoDestroySyncManager(ShutdownReason reason) { |
540 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); | 553 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); |
| 554 base::trace_event::MemoryDumpManager::GetInstance()->UnregisterDumpProvider( |
| 555 this); |
541 if (sync_manager_) { | 556 if (sync_manager_) { |
542 DisableDirectoryTypeDebugInfoForwarding(); | 557 DisableDirectoryTypeDebugInfoForwarding(); |
543 save_changes_timer_.reset(); | 558 save_changes_timer_.reset(); |
544 sync_manager_->RemoveObserver(this); | 559 sync_manager_->RemoveObserver(this); |
545 sync_manager_->ShutdownOnSyncThread(reason); | 560 sync_manager_->ShutdownOnSyncThread(reason); |
546 sync_manager_.reset(); | 561 sync_manager_.reset(); |
547 } | 562 } |
548 } | 563 } |
549 | 564 |
550 void SyncBackendHostCore::DoConfigureSyncer( | 565 void SyncBackendHostCore::DoConfigureSyncer( |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
682 } | 697 } |
683 | 698 |
684 void SyncBackendHostCore::ClearServerDataDone( | 699 void SyncBackendHostCore::ClearServerDataDone( |
685 const base::Closure& frontend_callback) { | 700 const base::Closure& frontend_callback) { |
686 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); | 701 DCHECK(sync_loop_->task_runner()->BelongsToCurrentThread()); |
687 host_.Call(FROM_HERE, &SyncBackendHostImpl::ClearServerDataDoneOnFrontendLoop, | 702 host_.Call(FROM_HERE, &SyncBackendHostImpl::ClearServerDataDoneOnFrontendLoop, |
688 frontend_callback); | 703 frontend_callback); |
689 } | 704 } |
690 | 705 |
691 } // namespace syncer | 706 } // namespace syncer |
OLD | NEW |