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

Unified Diff: sync/engine/all_status.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
« no previous file with comments | « sync/engine/all_status.h ('k') | sync/engine/apply_control_data_updates.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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
« no previous file with comments | « sync/engine/all_status.h ('k') | sync/engine/apply_control_data_updates.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698