Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(791)

Unified Diff: sync/internal_api/debug_info_event_listener.cc

Issue 2130453004: [Sync] Move //sync to //components/sync. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: sync/internal_api/debug_info_event_listener.cc
diff --git a/sync/internal_api/debug_info_event_listener.cc b/sync/internal_api/debug_info_event_listener.cc
deleted file mode 100644
index 8c73f21a809868c056037d4acbc0f74e754d36a1..0000000000000000000000000000000000000000
--- a/sync/internal_api/debug_info_event_listener.cc
+++ /dev/null
@@ -1,259 +0,0 @@
-// Copyright (c) 2012 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "sync/internal_api/debug_info_event_listener.h"
-
-#include <stddef.h>
-
-#include "sync/util/cryptographer.h"
-
-namespace syncer {
-
-using sessions::SyncSessionSnapshot;
-
-DebugInfoEventListener::DebugInfoEventListener()
- : events_dropped_(false),
- cryptographer_has_pending_keys_(false),
- cryptographer_ready_(false),
- weak_ptr_factory_(this) {
-}
-
-DebugInfoEventListener::~DebugInfoEventListener() {
-}
-
-void DebugInfoEventListener::OnSyncCycleCompleted(
- const SyncSessionSnapshot& snapshot) {
- DCHECK(thread_checker_.CalledOnValidThread());
- sync_pb::DebugEventInfo event_info;
- sync_pb::SyncCycleCompletedEventInfo* sync_completed_event_info =
- event_info.mutable_sync_cycle_completed_event_info();
-
- sync_completed_event_info->set_num_encryption_conflicts(
- snapshot.num_encryption_conflicts());
- sync_completed_event_info->set_num_hierarchy_conflicts(
- snapshot.num_hierarchy_conflicts());
- sync_completed_event_info->set_num_server_conflicts(
- snapshot.num_server_conflicts());
-
- sync_completed_event_info->set_num_updates_downloaded(
- snapshot.model_neutral_state().num_updates_downloaded_total);
- sync_completed_event_info->set_num_reflected_updates_downloaded(
- snapshot.model_neutral_state().num_reflected_updates_downloaded_total);
- sync_completed_event_info->mutable_caller_info()->set_source(
- snapshot.legacy_updates_source());
- sync_completed_event_info->mutable_caller_info()->set_notifications_enabled(
- snapshot.notifications_enabled());
-
- AddEventToQueue(event_info);
-}
-
-void DebugInfoEventListener::OnInitializationComplete(
- const WeakHandle<JsBackend>& js_backend,
- const WeakHandle<DataTypeDebugInfoListener>& debug_listener,
- bool success, ModelTypeSet restored_types) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::INITIALIZATION_COMPLETE);
-}
-
-void DebugInfoEventListener::OnConnectionStatusChange(
- ConnectionStatus status) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::CONNECTION_STATUS_CHANGE);
-}
-
-void DebugInfoEventListener::OnPassphraseRequired(
- PassphraseRequiredReason reason,
- const sync_pb::EncryptedData& pending_keys) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::PASSPHRASE_REQUIRED);
-}
-
-void DebugInfoEventListener::OnPassphraseAccepted() {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::PASSPHRASE_ACCEPTED);
-}
-
-void DebugInfoEventListener::OnBootstrapTokenUpdated(
- const std::string& bootstrap_token, BootstrapTokenType type) {
- DCHECK(thread_checker_.CalledOnValidThread());
- if (type == PASSPHRASE_BOOTSTRAP_TOKEN) {
- CreateAndAddEvent(sync_pb::SyncEnums::BOOTSTRAP_TOKEN_UPDATED);
- return;
- }
- DCHECK_EQ(type, KEYSTORE_BOOTSTRAP_TOKEN);
- CreateAndAddEvent(sync_pb::SyncEnums::KEYSTORE_TOKEN_UPDATED);
-}
-
-void DebugInfoEventListener::OnEncryptedTypesChanged(
- ModelTypeSet encrypted_types,
- bool encrypt_everything) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::ENCRYPTED_TYPES_CHANGED);
-}
-
-void DebugInfoEventListener::OnEncryptionComplete() {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::ENCRYPTION_COMPLETE);
-}
-
-void DebugInfoEventListener::OnCryptographerStateChanged(
- Cryptographer* cryptographer) {
- DCHECK(thread_checker_.CalledOnValidThread());
- cryptographer_has_pending_keys_ = cryptographer->has_pending_keys();
- cryptographer_ready_ = cryptographer->is_ready();
-}
-
-void DebugInfoEventListener::OnPassphraseTypeChanged(
- PassphraseType type,
- base::Time explicit_passphrase_time) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::PASSPHRASE_TYPE_CHANGED);
-}
-
-void DebugInfoEventListener::OnLocalSetPassphraseEncryption(
- const SyncEncryptionHandler::NigoriState& nigori_state) {
-}
-
-void DebugInfoEventListener::OnActionableError(
- const SyncProtocolError& sync_error) {
- DCHECK(thread_checker_.CalledOnValidThread());
- CreateAndAddEvent(sync_pb::SyncEnums::ACTIONABLE_ERROR);
-}
-
-void DebugInfoEventListener::OnMigrationRequested(ModelTypeSet types) {}
-
-void DebugInfoEventListener::OnProtocolEvent(const ProtocolEvent& event) {}
-
-void DebugInfoEventListener::OnNudgeFromDatatype(ModelType datatype) {
- DCHECK(thread_checker_.CalledOnValidThread());
- sync_pb::DebugEventInfo event_info;
- event_info.set_nudging_datatype(
- GetSpecificsFieldNumberFromModelType(datatype));
- AddEventToQueue(event_info);
-}
-
-void DebugInfoEventListener::GetDebugInfo(sync_pb::DebugInfo* debug_info) {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_LE(events_.size(), kMaxEntries);
-
- for (DebugEventInfoQueue::const_iterator iter = events_.begin();
- iter != events_.end();
- ++iter) {
- sync_pb::DebugEventInfo* event_info = debug_info->add_events();
- event_info->CopyFrom(*iter);
- }
-
- debug_info->set_events_dropped(events_dropped_);
- debug_info->set_cryptographer_ready(cryptographer_ready_);
- debug_info->set_cryptographer_has_pending_keys(
- cryptographer_has_pending_keys_);
-}
-
-void DebugInfoEventListener::ClearDebugInfo() {
- DCHECK(thread_checker_.CalledOnValidThread());
- DCHECK_LE(events_.size(), kMaxEntries);
-
- events_.clear();
- events_dropped_ = false;
-}
-
-base::WeakPtr<DataTypeDebugInfoListener> DebugInfoEventListener::GetWeakPtr() {
- DCHECK(thread_checker_.CalledOnValidThread());
- return weak_ptr_factory_.GetWeakPtr();
-}
-
-void DebugInfoEventListener::OnDataTypeConfigureComplete(
- const std::vector<DataTypeConfigurationStats>& configuration_stats) {
- DCHECK(thread_checker_.CalledOnValidThread());
-
- for (size_t i = 0; i < configuration_stats.size(); ++i) {
- DCHECK(ProtocolTypes().Has(configuration_stats[i].model_type));
- const DataTypeAssociationStats& association_stats =
- configuration_stats[i].association_stats;
-
- sync_pb::DebugEventInfo association_event;
- sync_pb::DatatypeAssociationStats* datatype_stats =
- association_event.mutable_datatype_association_stats();
- datatype_stats->set_data_type_id(
- GetSpecificsFieldNumberFromModelType(
- configuration_stats[i].model_type));
- datatype_stats->set_num_local_items_before_association(
- association_stats.num_local_items_before_association);
- datatype_stats->set_num_sync_items_before_association(
- association_stats.num_sync_items_before_association);
- datatype_stats->set_num_local_items_after_association(
- association_stats.num_local_items_after_association);
- datatype_stats->set_num_sync_items_after_association(
- association_stats.num_sync_items_after_association);
- datatype_stats->set_num_local_items_added(
- association_stats.num_local_items_added);
- datatype_stats->set_num_local_items_deleted(
- association_stats.num_local_items_deleted);
- datatype_stats->set_num_local_items_modified(
- association_stats.num_local_items_modified);
- datatype_stats->set_num_sync_items_added(
- association_stats.num_sync_items_added);
- datatype_stats->set_num_sync_items_deleted(
- association_stats.num_sync_items_deleted);
- datatype_stats->set_num_sync_items_modified(
- association_stats.num_sync_items_modified);
- datatype_stats->set_local_version_pre_association(
- association_stats.local_version_pre_association);
- datatype_stats->set_sync_version_pre_association(
- association_stats.sync_version_pre_association);
- datatype_stats->set_had_error(association_stats.had_error);
- datatype_stats->set_association_wait_time_for_same_priority_us(
- association_stats.association_wait_time.InMicroseconds());
- datatype_stats->set_association_time_us(
- association_stats.association_time.InMicroseconds());
- datatype_stats->set_download_wait_time_us(
- configuration_stats[i].download_wait_time.InMicroseconds());
- datatype_stats->set_download_time_us(
- configuration_stats[i].download_time.InMicroseconds());
- datatype_stats->set_association_wait_time_for_high_priority_us(
- configuration_stats[i].association_wait_time_for_high_priority
- .InMicroseconds());
-
- for (ModelTypeSet::Iterator it =
- configuration_stats[i].high_priority_types_configured_before
- .First();
- it.Good(); it.Inc()) {
- datatype_stats->add_high_priority_type_configured_before(
- GetSpecificsFieldNumberFromModelType(it.Get()));
- }
-
- for (ModelTypeSet::Iterator it =
- configuration_stats[i].same_priority_types_configured_before
- .First();
- it.Good(); it.Inc()) {
- datatype_stats->add_same_priority_type_configured_before(
- GetSpecificsFieldNumberFromModelType(it.Get()));
- }
-
- AddEventToQueue(association_event);
- }
-}
-
-void DebugInfoEventListener::CreateAndAddEvent(
- sync_pb::SyncEnums::SingletonDebugEventType type) {
- DCHECK(thread_checker_.CalledOnValidThread());
- sync_pb::DebugEventInfo event_info;
- event_info.set_singleton_event(type);
- AddEventToQueue(event_info);
-}
-
-void DebugInfoEventListener::AddEventToQueue(
- const sync_pb::DebugEventInfo& event_info) {
- DCHECK(thread_checker_.CalledOnValidThread());
- if (events_.size() >= kMaxEntries) {
- DVLOG(1) << "DebugInfoEventListener::AddEventToQueue Dropping an old event "
- << "because of full queue";
-
- events_.pop_front();
- events_dropped_ = true;
- }
- events_.push_back(event_info);
-}
-
-} // namespace syncer
« no previous file with comments | « sync/internal_api/debug_info_event_listener.h ('k') | sync/internal_api/debug_info_event_listener_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698