| OLD | NEW |
| 1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/sync/glue/bookmark_model_associator.h" | 5 #include "chrome/browser/sync/glue/bookmark_model_associator.h" |
| 6 | 6 |
| 7 #include <stack> | 7 #include <stack> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
| (...skipping 346 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 357 syncer::ReadNode sync_node(&trans); | 357 syncer::ReadNode sync_node(&trans); |
| 358 if (sync_node.InitByTagLookup(tag.c_str()) != syncer::BaseNode::INIT_OK) | 358 if (sync_node.InitByTagLookup(tag.c_str()) != syncer::BaseNode::INIT_OK) |
| 359 return false; | 359 return false; |
| 360 *sync_id = sync_node.GetId(); | 360 *sync_id = sync_node.GetId(); |
| 361 return true; | 361 return true; |
| 362 } | 362 } |
| 363 | 363 |
| 364 syncer::SyncError BookmarkModelAssociator::AssociateModels( | 364 syncer::SyncError BookmarkModelAssociator::AssociateModels( |
| 365 syncer::SyncMergeResult* local_merge_result, | 365 syncer::SyncMergeResult* local_merge_result, |
| 366 syncer::SyncMergeResult* syncer_merge_result) { | 366 syncer::SyncMergeResult* syncer_merge_result) { |
| 367 CheckModelSyncState(local_merge_result, syncer_merge_result); | 367 syncer::SyncError error = CheckModelSyncState(local_merge_result, |
| 368 syncer_merge_result); |
| 369 if (error.IsSet()) |
| 370 return error; |
| 368 | 371 |
| 369 scoped_ptr<ScopedAssociationUpdater> association_updater( | 372 scoped_ptr<ScopedAssociationUpdater> association_updater( |
| 370 new ScopedAssociationUpdater(bookmark_model_)); | 373 new ScopedAssociationUpdater(bookmark_model_)); |
| 371 DisassociateModels(); | 374 DisassociateModels(); |
| 372 | 375 |
| 373 return BuildAssociations(local_merge_result, syncer_merge_result); | 376 return BuildAssociations(local_merge_result, syncer_merge_result); |
| 374 } | 377 } |
| 375 | 378 |
| 376 syncer::SyncError BookmarkModelAssociator::BuildAssociations( | 379 syncer::SyncError BookmarkModelAssociator::BuildAssociations( |
| 377 syncer::SyncMergeResult* local_merge_result, | 380 syncer::SyncMergeResult* local_merge_result, |
| (...skipping 317 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 695 } | 698 } |
| 696 | 699 |
| 697 bool BookmarkModelAssociator::CryptoReadyIfNecessary() { | 700 bool BookmarkModelAssociator::CryptoReadyIfNecessary() { |
| 698 // We only access the cryptographer while holding a transaction. | 701 // We only access the cryptographer while holding a transaction. |
| 699 syncer::ReadTransaction trans(FROM_HERE, user_share_); | 702 syncer::ReadTransaction trans(FROM_HERE, user_share_); |
| 700 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes(); | 703 const syncer::ModelTypeSet encrypted_types = trans.GetEncryptedTypes(); |
| 701 return !encrypted_types.Has(syncer::BOOKMARKS) || | 704 return !encrypted_types.Has(syncer::BOOKMARKS) || |
| 702 trans.GetCryptographer()->is_ready(); | 705 trans.GetCryptographer()->is_ready(); |
| 703 } | 706 } |
| 704 | 707 |
| 705 void BookmarkModelAssociator::CheckModelSyncState( | 708 syncer::SyncError BookmarkModelAssociator::CheckModelSyncState( |
| 706 syncer::SyncMergeResult* local_merge_result, | 709 syncer::SyncMergeResult* local_merge_result, |
| 707 syncer::SyncMergeResult* syncer_merge_result) const { | 710 syncer::SyncMergeResult* syncer_merge_result) const { |
| 708 std::string version_str; | 711 std::string version_str; |
| 709 if (bookmark_model_->root_node()->GetMetaInfo(kBookmarkTransactionVersionKey, | 712 if (bookmark_model_->root_node()->GetMetaInfo(kBookmarkTransactionVersionKey, |
| 710 &version_str)) { | 713 &version_str)) { |
| 711 syncer::ReadTransaction trans(FROM_HERE, user_share_); | 714 syncer::ReadTransaction trans(FROM_HERE, user_share_); |
| 712 int64 native_version; | 715 int64 native_version = syncer::syncable::kInvalidTransactionVersion; |
| 713 if (!base::StringToInt64(version_str, &native_version)) | 716 if (!base::StringToInt64(version_str, &native_version)) |
| 714 return; | 717 return syncer::SyncError(); |
| 715 local_merge_result->set_pre_association_version(native_version); | 718 local_merge_result->set_pre_association_version(native_version); |
| 716 | 719 |
| 717 int64 sync_version = trans.GetModelVersion(syncer::BOOKMARKS); | 720 int64 sync_version = trans.GetModelVersion(syncer::BOOKMARKS); |
| 718 syncer_merge_result->set_pre_association_version(sync_version); | 721 syncer_merge_result->set_pre_association_version(sync_version); |
| 719 | 722 |
| 720 if (native_version != sync_version) { | 723 if (native_version != sync_version) { |
| 721 UMA_HISTOGRAM_ENUMERATION("Sync.LocalModelOutOfSync", | 724 UMA_HISTOGRAM_ENUMERATION("Sync.LocalModelOutOfSync", |
| 722 ModelTypeToHistogramInt(syncer::BOOKMARKS), | 725 ModelTypeToHistogramInt(syncer::BOOKMARKS), |
| 723 syncer::MODEL_TYPE_COUNT); | 726 syncer::MODEL_TYPE_COUNT); |
| 727 |
| 724 // Clear version on bookmark model so that we only report error once. | 728 // Clear version on bookmark model so that we only report error once. |
| 725 bookmark_model_->DeleteNodeMetaInfo(bookmark_model_->root_node(), | 729 bookmark_model_->DeleteNodeMetaInfo(bookmark_model_->root_node(), |
| 726 kBookmarkTransactionVersionKey); | 730 kBookmarkTransactionVersionKey); |
| 731 |
| 732 // If the native version is higher, there was a sync persistence failure, |
| 733 // and we need to delay association until after a GetUpdates. |
| 734 if (sync_version < native_version) { |
| 735 DVLOG(1) << "Native version (" << native_version << ") does not match " |
| 736 << "sync version (" << sync_version << ")."; |
| 737 // TODO(zea): return a persistence error here. |
| 738 } |
| 727 } | 739 } |
| 728 } | 740 } |
| 741 return syncer::SyncError(); |
| 729 } | 742 } |
| 730 | 743 |
| 731 } // namespace browser_sync | 744 } // namespace browser_sync |
| OLD | NEW |