Index: chrome/browser/sync/sessions/session_state.cc |
diff --git a/chrome/browser/sync/sessions/session_state.cc b/chrome/browser/sync/sessions/session_state.cc |
deleted file mode 100644 |
index c9fd8135a9822b5062de20de0e592424f3194b6f..0000000000000000000000000000000000000000 |
--- a/chrome/browser/sync/sessions/session_state.cc |
+++ /dev/null |
@@ -1,324 +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 "chrome/browser/sync/sessions/session_state.h" |
- |
-#include <map> |
-#include <set> |
-#include <string> |
-#include <utility> |
-#include <vector> |
- |
-#include "base/base64.h" |
-#include "base/json/json_writer.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/values.h" |
-#include "chrome/browser/sync/protocol/proto_enum_conversions.h" |
- |
-using std::set; |
-using std::vector; |
- |
-namespace browser_sync { |
-namespace sessions { |
- |
-SyncSourceInfo::SyncSourceInfo() |
- : updates_source(sync_pb::GetUpdatesCallerInfo::UNKNOWN) {} |
- |
-SyncSourceInfo::SyncSourceInfo( |
- const syncable::ModelTypePayloadMap& t) |
- : updates_source(sync_pb::GetUpdatesCallerInfo::UNKNOWN), types(t) {} |
- |
-SyncSourceInfo::SyncSourceInfo( |
- const sync_pb::GetUpdatesCallerInfo::GetUpdatesSource& u, |
- const syncable::ModelTypePayloadMap& t) |
- : updates_source(u), types(t) {} |
- |
-SyncSourceInfo::~SyncSourceInfo() {} |
- |
-DictionaryValue* SyncSourceInfo::ToValue() const { |
- DictionaryValue* value = new DictionaryValue(); |
- value->SetString("updatesSource", |
- GetUpdatesSourceString(updates_source)); |
- value->Set("types", syncable::ModelTypePayloadMapToValue(types)); |
- return value; |
-} |
- |
-SyncerStatus::SyncerStatus() |
- : invalid_store(false), |
- num_successful_commits(0), |
- num_successful_bookmark_commits(0), |
- num_updates_downloaded_total(0), |
- num_tombstone_updates_downloaded_total(0), |
- num_local_overwrites(0), |
- num_server_overwrites(0) { |
-} |
- |
-SyncerStatus::~SyncerStatus() { |
-} |
- |
-DictionaryValue* SyncerStatus::ToValue() const { |
- DictionaryValue* value = new DictionaryValue(); |
- value->SetBoolean("invalidStore", invalid_store); |
- value->SetInteger("numSuccessfulCommits", num_successful_commits); |
- value->SetInteger("numSuccessfulBookmarkCommits", |
- num_successful_bookmark_commits); |
- value->SetInteger("numUpdatesDownloadedTotal", |
- num_updates_downloaded_total); |
- value->SetInteger("numTombstoneUpdatesDownloadedTotal", |
- num_tombstone_updates_downloaded_total); |
- value->SetInteger("numLocalOverwrites", num_local_overwrites); |
- value->SetInteger("numServerOverwrites", num_server_overwrites); |
- return value; |
-} |
- |
-DictionaryValue* DownloadProgressMarkersToValue( |
- const std::string |
- (&download_progress_markers)[syncable::MODEL_TYPE_COUNT]) { |
- DictionaryValue* value = new DictionaryValue(); |
- for (int i = syncable::FIRST_REAL_MODEL_TYPE; |
- i < syncable::MODEL_TYPE_COUNT; ++i) { |
- // TODO(akalin): Unpack the value into a protobuf. |
- std::string base64_marker; |
- bool encoded = |
- base::Base64Encode(download_progress_markers[i], &base64_marker); |
- DCHECK(encoded); |
- value->SetString( |
- syncable::ModelTypeToString(syncable::ModelTypeFromInt(i)), |
- base64_marker); |
- } |
- return value; |
-} |
- |
-ErrorCounters::ErrorCounters() |
- : last_download_updates_result(UNSET), |
- last_post_commit_result(UNSET), |
- last_process_commit_response_result(UNSET) { |
-} |
- |
-SyncSessionSnapshot::SyncSessionSnapshot( |
- const SyncerStatus& syncer_status, |
- const ErrorCounters& errors, |
- int64 num_server_changes_remaining, |
- bool is_share_usable, |
- syncable::ModelTypeSet initial_sync_ended, |
- const std::string |
- (&download_progress_markers)[syncable::MODEL_TYPE_COUNT], |
- bool more_to_sync, |
- bool is_silenced, |
- int64 unsynced_count, |
- int num_encryption_conflicts, |
- int num_hierarchy_conflicts, |
- int num_simple_conflicts, |
- int num_server_conflicts, |
- bool did_commit_items, |
- const SyncSourceInfo& source, |
- size_t num_entries, |
- base::Time sync_start_time, |
- bool retry_scheduled) |
- : syncer_status(syncer_status), |
- errors(errors), |
- num_server_changes_remaining(num_server_changes_remaining), |
- is_share_usable(is_share_usable), |
- initial_sync_ended(initial_sync_ended), |
- download_progress_markers(), |
- has_more_to_sync(more_to_sync), |
- is_silenced(is_silenced), |
- unsynced_count(unsynced_count), |
- num_encryption_conflicts(num_encryption_conflicts), |
- num_hierarchy_conflicts(num_hierarchy_conflicts), |
- num_simple_conflicts(num_simple_conflicts), |
- num_server_conflicts(num_server_conflicts), |
- did_commit_items(did_commit_items), |
- source(source), |
- num_entries(num_entries), |
- sync_start_time(sync_start_time), |
- retry_scheduled(retry_scheduled) { |
- for (int i = syncable::FIRST_REAL_MODEL_TYPE; |
- i < syncable::MODEL_TYPE_COUNT; ++i) { |
- const_cast<std::string&>(this->download_progress_markers[i]).assign( |
- download_progress_markers[i]); |
- } |
-} |
- |
-SyncSessionSnapshot::~SyncSessionSnapshot() {} |
- |
-DictionaryValue* SyncSessionSnapshot::ToValue() const { |
- DictionaryValue* value = new DictionaryValue(); |
- value->Set("syncerStatus", syncer_status.ToValue()); |
- // We don't care too much if we lose precision here. |
- value->SetInteger("numServerChangesRemaining", |
- static_cast<int>(num_server_changes_remaining)); |
- value->SetBoolean("isShareUsable", is_share_usable); |
- value->Set("initialSyncEnded", |
- syncable::ModelTypeSetToValue(initial_sync_ended)); |
- value->Set("downloadProgressMarkers", |
- DownloadProgressMarkersToValue(download_progress_markers)); |
- value->SetBoolean("hasMoreToSync", has_more_to_sync); |
- value->SetBoolean("isSilenced", is_silenced); |
- // We don't care too much if we lose precision here, also. |
- value->SetInteger("unsyncedCount", |
- static_cast<int>(unsynced_count)); |
- value->SetInteger("numEncryptionConflicts", |
- num_encryption_conflicts); |
- value->SetInteger("numHierarchyConflicts", |
- num_hierarchy_conflicts); |
- value->SetInteger("numSimpleConflicts", |
- num_simple_conflicts); |
- value->SetInteger("numServerConflicts", |
- num_server_conflicts); |
- value->SetBoolean("didCommitItems", did_commit_items); |
- value->SetInteger("numEntries", num_entries); |
- value->Set("source", source.ToValue()); |
- return value; |
-} |
- |
-std::string SyncSessionSnapshot::ToString() const { |
- scoped_ptr<DictionaryValue> value(ToValue()); |
- std::string json; |
- base::JSONWriter::Write(value.get(), true, &json); |
- return json; |
-} |
- |
-ConflictProgress::ConflictProgress(bool* dirty_flag) |
- : num_server_conflicting_items(0), num_hierarchy_conflicting_items(0), |
- num_encryption_conflicting_items(0), dirty_(dirty_flag) { |
-} |
- |
-ConflictProgress::~ConflictProgress() { |
-} |
- |
-bool ConflictProgress::HasSimpleConflictItem(const syncable::Id& id) const { |
- return simple_conflicting_item_ids_.count(id) > 0; |
-} |
- |
-std::set<syncable::Id>::const_iterator |
-ConflictProgress::SimpleConflictingItemsBegin() const { |
- return simple_conflicting_item_ids_.begin(); |
-} |
-std::set<syncable::Id>::const_iterator |
-ConflictProgress::SimpleConflictingItemsEnd() const { |
- return simple_conflicting_item_ids_.end(); |
-} |
- |
-void ConflictProgress::AddSimpleConflictingItemById( |
- const syncable::Id& the_id) { |
- std::pair<std::set<syncable::Id>::iterator, bool> ret = |
- simple_conflicting_item_ids_.insert(the_id); |
- if (ret.second) |
- *dirty_ = true; |
-} |
- |
-void ConflictProgress::EraseSimpleConflictingItemById( |
- const syncable::Id& the_id) { |
- int items_erased = simple_conflicting_item_ids_.erase(the_id); |
- if (items_erased != 0) |
- *dirty_ = true; |
-} |
- |
-void ConflictProgress::AddEncryptionConflictingItemById( |
- const syncable::Id& the_id) { |
- std::pair<std::set<syncable::Id>::iterator, bool> ret = |
- unresolvable_conflicting_item_ids_.insert(the_id); |
- if (ret.second) { |
- num_encryption_conflicting_items++; |
- *dirty_ = true; |
- } |
-} |
- |
-void ConflictProgress::AddHierarchyConflictingItemById( |
- const syncable::Id& the_id) { |
- std::pair<std::set<syncable::Id>::iterator, bool> ret = |
- unresolvable_conflicting_item_ids_.insert(the_id); |
- if (ret.second) { |
- num_hierarchy_conflicting_items++; |
- *dirty_ = true; |
- } |
-} |
- |
-void ConflictProgress::AddServerConflictingItemById( |
- const syncable::Id& the_id) { |
- std::pair<std::set<syncable::Id>::iterator, bool> ret = |
- unresolvable_conflicting_item_ids_.insert(the_id); |
- if (ret.second) { |
- num_server_conflicting_items++; |
- *dirty_ = true; |
- } |
-} |
- |
-UpdateProgress::UpdateProgress() {} |
- |
-UpdateProgress::~UpdateProgress() {} |
- |
-void UpdateProgress::AddVerifyResult(const VerifyResult& verify_result, |
- const sync_pb::SyncEntity& entity) { |
- verified_updates_.push_back(std::make_pair(verify_result, entity)); |
-} |
- |
-void UpdateProgress::AddAppliedUpdate(const UpdateAttemptResponse& response, |
- const syncable::Id& id) { |
- applied_updates_.push_back(std::make_pair(response, id)); |
-} |
- |
-std::vector<AppliedUpdate>::iterator UpdateProgress::AppliedUpdatesBegin() { |
- return applied_updates_.begin(); |
-} |
- |
-std::vector<VerifiedUpdate>::const_iterator |
-UpdateProgress::VerifiedUpdatesBegin() const { |
- return verified_updates_.begin(); |
-} |
- |
-std::vector<AppliedUpdate>::const_iterator |
-UpdateProgress::AppliedUpdatesEnd() const { |
- return applied_updates_.end(); |
-} |
- |
-std::vector<VerifiedUpdate>::const_iterator |
-UpdateProgress::VerifiedUpdatesEnd() const { |
- return verified_updates_.end(); |
-} |
- |
-int UpdateProgress::SuccessfullyAppliedUpdateCount() const { |
- int count = 0; |
- for (std::vector<AppliedUpdate>::const_iterator it = |
- applied_updates_.begin(); |
- it != applied_updates_.end(); |
- ++it) { |
- if (it->first == SUCCESS) |
- count++; |
- } |
- return count; |
-} |
- |
-// Returns true if at least one update application failed due to a conflict |
-// during this sync cycle. |
-bool UpdateProgress::HasConflictingUpdates() const { |
- std::vector<AppliedUpdate>::const_iterator it; |
- for (it = applied_updates_.begin(); it != applied_updates_.end(); ++it) { |
- if (it->first != SUCCESS) { |
- return true; |
- } |
- } |
- return false; |
-} |
- |
-AllModelTypeState::AllModelTypeState(bool* dirty_flag) |
- : unsynced_handles(dirty_flag), |
- syncer_status(dirty_flag), |
- error(dirty_flag), |
- num_server_changes_remaining(dirty_flag, 0), |
- commit_set(ModelSafeRoutingInfo()) { |
-} |
- |
-AllModelTypeState::~AllModelTypeState() {} |
- |
-PerModelSafeGroupState::PerModelSafeGroupState(bool* dirty_flag) |
- : conflict_progress(dirty_flag) { |
-} |
- |
-PerModelSafeGroupState::~PerModelSafeGroupState() { |
-} |
- |
-} // namespace sessions |
-} // namespace browser_sync |