Index: sync/engine/all_status.cc |
diff --git a/sync/engine/all_status.cc b/sync/engine/all_status.cc |
deleted file mode 100644 |
index 10b54e0ff241c6987ea3593e1cb7f2d605fce94b..0000000000000000000000000000000000000000 |
--- a/sync/engine/all_status.cc |
+++ /dev/null |
@@ -1,194 +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/engine/all_status.h" |
- |
-#include <algorithm> |
- |
-#include "base/logging.h" |
-#include "sync/engine/net/server_connection_manager.h" |
-#include "sync/engine/sync_cycle_event.h" |
-#include "sync/internal_api/public/base/model_type.h" |
- |
-namespace syncer { |
- |
-AllStatus::AllStatus() { |
- status_.notifications_enabled = false; |
- status_.cryptographer_ready = false; |
- status_.crypto_has_pending_keys = false; |
-} |
- |
-AllStatus::~AllStatus() { |
-} |
- |
-SyncStatus AllStatus::CreateBlankStatus() const { |
- // Status is initialized with the previous status value. Variables |
- // whose values accumulate (e.g. lifetime counters like updates_received) |
- // are not to be cleared here. |
- SyncStatus status = status_; |
- status.encryption_conflicts = 0; |
- status.hierarchy_conflicts = 0; |
- status.server_conflicts = 0; |
- status.committed_count = 0; |
- return status; |
-} |
- |
-SyncStatus AllStatus::CalcSyncing(const SyncCycleEvent &event) const { |
- SyncStatus status = CreateBlankStatus(); |
- const sessions::SyncSessionSnapshot& snapshot = event.snapshot; |
- status.encryption_conflicts = snapshot.num_encryption_conflicts(); |
- status.hierarchy_conflicts = snapshot.num_hierarchy_conflicts(); |
- status.server_conflicts = snapshot.num_server_conflicts(); |
- status.committed_count = |
- snapshot.model_neutral_state().num_successful_commits; |
- |
- if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_BEGIN) { |
- status.syncing = true; |
- } else if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_ENDED) { |
- status.syncing = false; |
- } |
- |
- status.num_entries_by_type = snapshot.num_entries_by_type(); |
- status.num_to_delete_entries_by_type = |
- snapshot.num_to_delete_entries_by_type(); |
- |
- // Accumulate update count only once per session to avoid double-counting. |
- if (event.what_happened == SyncCycleEvent::SYNC_CYCLE_ENDED) { |
- status.updates_received += |
- snapshot.model_neutral_state().num_updates_downloaded_total; |
- status.tombstone_updates_received += |
- snapshot.model_neutral_state().num_tombstone_updates_downloaded_total; |
- status.reflected_updates_received += |
- snapshot.model_neutral_state().num_reflected_updates_downloaded_total; |
- status.num_commits_total += |
- snapshot.model_neutral_state().num_successful_commits; |
- status.num_local_overwrites_total += |
- snapshot.model_neutral_state().num_local_overwrites; |
- status.num_server_overwrites_total += |
- snapshot.model_neutral_state().num_server_overwrites; |
- } |
- return status; |
-} |
- |
-void AllStatus::OnSyncCycleEvent(const SyncCycleEvent& event) { |
- ScopedStatusLock lock(this); |
- switch (event.what_happened) { |
- case SyncCycleEvent::SYNC_CYCLE_BEGIN: |
- case SyncCycleEvent::STATUS_CHANGED: |
- case SyncCycleEvent::SYNC_CYCLE_ENDED: |
- status_ = CalcSyncing(event); |
- break; |
- default: |
- LOG(ERROR) << "Unrecognized Syncer Event: " << event.what_happened; |
- break; |
- } |
-} |
- |
-void AllStatus::OnActionableError( |
- const SyncProtocolError& sync_protocol_error) { |
- ScopedStatusLock lock(this); |
- status_ = CreateBlankStatus(); |
- status_.sync_protocol_error = sync_protocol_error; |
-} |
- |
-void AllStatus::OnRetryTimeChanged(base::Time retry_time) { |
- ScopedStatusLock lock(this); |
- status_.retry_time = retry_time; |
-} |
- |
-void AllStatus::OnThrottledTypesChanged(ModelTypeSet throttled_types) { |
- ScopedStatusLock lock(this); |
- status_.throttled_types = throttled_types; |
-} |
- |
-void AllStatus::OnMigrationRequested(ModelTypeSet) {} |
- |
-void AllStatus::OnProtocolEvent(const ProtocolEvent&) {} |
- |
-SyncStatus AllStatus::status() const { |
- base::AutoLock lock(mutex_); |
- return status_; |
-} |
- |
-void AllStatus::SetNotificationsEnabled(bool notifications_enabled) { |
- ScopedStatusLock lock(this); |
- status_.notifications_enabled = notifications_enabled; |
-} |
- |
-void AllStatus::IncrementNotificationsReceived() { |
- ScopedStatusLock lock(this); |
- ++status_.notifications_received; |
-} |
- |
-void AllStatus::SetEncryptedTypes(ModelTypeSet types) { |
- ScopedStatusLock lock(this); |
- status_.encrypted_types = types; |
-} |
- |
-void AllStatus::SetCryptographerReady(bool ready) { |
- ScopedStatusLock lock(this); |
- status_.cryptographer_ready = ready; |
-} |
- |
-void AllStatus::SetCryptoHasPendingKeys(bool has_pending_keys) { |
- ScopedStatusLock lock(this); |
- status_.crypto_has_pending_keys = has_pending_keys; |
-} |
- |
-void AllStatus::SetPassphraseType(PassphraseType type) { |
- ScopedStatusLock lock(this); |
- status_.passphrase_type = type; |
-} |
- |
-void AllStatus::SetHasKeystoreKey(bool has_keystore_key) { |
- ScopedStatusLock lock(this); |
- status_.has_keystore_key = has_keystore_key; |
-} |
- |
-void AllStatus::SetKeystoreMigrationTime(const base::Time& migration_time) { |
- ScopedStatusLock lock(this); |
- status_.keystore_migration_time = migration_time; |
-} |
- |
-void AllStatus::SetSyncId(const std::string& sync_id) { |
- ScopedStatusLock lock(this); |
- status_.sync_id = sync_id; |
-} |
- |
-void AllStatus::SetInvalidatorClientId( |
- const std::string& invalidator_client_id) { |
- ScopedStatusLock lock(this); |
- status_.invalidator_client_id = invalidator_client_id; |
-} |
- |
-void AllStatus::IncrementNudgeCounter(NudgeSource source) { |
- ScopedStatusLock lock(this); |
- switch (source) { |
- case NUDGE_SOURCE_LOCAL_REFRESH: |
- status_.nudge_source_local_refresh++; |
- return; |
- case NUDGE_SOURCE_LOCAL: |
- status_.nudge_source_local++; |
- return; |
- case NUDGE_SOURCE_NOTIFICATION: |
- status_.nudge_source_notification++; |
- return; |
- case NUDGE_SOURCE_UNKNOWN: |
- break; |
- } |
- // If we're here, the source is most likely |
- // NUDGE_SOURCE_UNKNOWN. That shouldn't happen. |
- NOTREACHED(); |
-} |
- |
-ScopedStatusLock::ScopedStatusLock(AllStatus* allstatus) |
- : allstatus_(allstatus) { |
- allstatus->mutex_.Acquire(); |
-} |
- |
-ScopedStatusLock::~ScopedStatusLock() { |
- allstatus_->mutex_.Release(); |
-} |
- |
-} // namespace syncer |