| 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
|
|
|