diff options
author | rlarocque@chromium.org <rlarocque@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-17 23:21:59 +0000 |
---|---|---|
committer | rlarocque@chromium.org <rlarocque@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-17 23:21:59 +0000 |
commit | 2fdf6199cda564079bf743bf98e6c7b8205fc9c4 (patch) | |
tree | 26cb5feaaf3800771b98355450d0a1e37bb0753c /sync/engine/process_updates_util.cc | |
parent | 0e416c45ad5b75728e696b73651f444135c9748f (diff) | |
download | chromium_src-2fdf6199cda564079bf743bf98e6c7b8205fc9c4.zip chromium_src-2fdf6199cda564079bf743bf98e6c7b8205fc9c4.tar.gz chromium_src-2fdf6199cda564079bf743bf98e6c7b8205fc9c4.tar.bz2 |
sync: Introduce ModelTypeRegistry and helpers
Introduce the ModelTypeRegistry class and use it to manage the creation
of UpdateHandlers and CommitContributors. The ModelTypeRegistry also
gets some help from the newly introduced UpdaterList and CommitterList
classes.
This lets us move the verbose iteration logic out of the code that's
focused on building and executing commits and updates, which should make
those functions easier to read. It gives us more freedom to experiment
with other ways to manage the lists of commit contributors and update
handlers, should we choose to do so. It prevents us from leaking the
set of enabled types through the per-type maps.
This patch is one of the last in the stack related to building a
per-type abstraction into the sync engine, and also one of the first
steps towards implementing run-time enable and disable logic for the
new-style sync types.
BUG=278484
Review URL: https://codereview.chromium.org/93433006
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@245654 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'sync/engine/process_updates_util.cc')
-rw-r--r-- | sync/engine/process_updates_util.cc | 86 |
1 files changed, 30 insertions, 56 deletions
diff --git a/sync/engine/process_updates_util.cc b/sync/engine/process_updates_util.cc index 49e40b3..b2cab4a 100644 --- a/sync/engine/process_updates_util.cc +++ b/sync/engine/process_updates_util.cc @@ -6,6 +6,7 @@ #include "base/location.h" #include "sync/engine/syncer_proto_util.h" +#include "sync/engine/syncer_types.h" #include "sync/engine/syncer_util.h" #include "sync/syncable/directory.h" #include "sync/syncable/model_neutral_mutable_entry.h" @@ -74,58 +75,6 @@ bool UpdateContainsNewVersion(syncable::BaseTransaction *trans, return existing_version < update.version(); } -} // namespace - -void PartitionUpdatesByType( - const sync_pb::GetUpdatesResponse& updates, - ModelTypeSet requested_types, - TypeSyncEntityMap* updates_by_type) { - int update_count = updates.entries().size(); - for (ModelTypeSet::Iterator it = requested_types.First(); - it.Good(); it.Inc()) { - updates_by_type->insert(std::make_pair(it.Get(), SyncEntityList())); - } - for (int i = 0; i < update_count; ++i) { - const sync_pb::SyncEntity& update = updates.entries(i); - ModelType type = GetModelType(update); - if (!IsRealDataType(type)) { - NOTREACHED() << "Received update with invalid type."; - continue; - } - - TypeSyncEntityMap::iterator it = updates_by_type->find(type); - if (it == updates_by_type->end()) { - DLOG(WARNING) << "Skipping update for unexpected type " - << ModelTypeToString(type); - continue; - } - - it->second.push_back(&update); - } -} - -void ProcessDownloadedUpdates( - syncable::Directory* dir, - syncable::ModelNeutralWriteTransaction* trans, - ModelType type, - const SyncEntityList& applicable_updates, - sessions::StatusController* status) { - for (SyncEntityList::const_iterator update_it = applicable_updates.begin(); - update_it != applicable_updates.end(); ++update_it) { - DCHECK_EQ(type, GetModelType(**update_it)); - if (!UpdateContainsNewVersion(trans, **update_it)) - status->increment_num_reflected_updates_downloaded_by(1); - if ((*update_it)->deleted()) - status->increment_num_tombstone_updates_downloaded_by(1); - VerifyResult verify_result = VerifyUpdate(trans, **update_it, type); - if (verify_result != VERIFY_SUCCESS && verify_result != VERIFY_UNDELETE) - continue; - ProcessUpdate(**update_it, dir->GetCryptographer(trans), trans); - } -} - -namespace { - // In the event that IDs match, but tags differ AttemptReuniteClient tag // will have refused to unify the update. // We should not attempt to apply it at all since it violates consistency @@ -141,8 +90,10 @@ VerifyResult VerifyTagConsistency( return VERIFY_UNDECIDED; } -} // namespace - +// Checks whether or not an update is fit for processing. +// +// The answer may be "no" if the update appears invalid, or it's not releveant +// (ie. a delete for an item we've never heard of), or other reasons. VerifyResult VerifyUpdate( syncable::ModelNeutralWriteTransaction* trans, const sync_pb::SyncEntity& entry, @@ -201,7 +152,6 @@ VerifyResult VerifyUpdate( return result; // This might be VERIFY_SUCCESS as well } -namespace { // Returns true if the entry is still ok to process. bool ReverifyEntry(syncable::ModelNeutralWriteTransaction* trans, const sync_pb::SyncEntity& entry, @@ -218,9 +168,11 @@ bool ReverifyEntry(syncable::ModelNeutralWriteTransaction* trans, model_type, same_id); } -} // namespace // Process a single update. Will avoid touching global state. +// +// If the update passes a series of checks, this function will copy +// the SyncEntity's data into the SERVER side of the syncable::Directory. void ProcessUpdate( const sync_pb::SyncEntity& update, const Cryptographer* cryptographer, @@ -326,4 +278,26 @@ void ProcessUpdate( return; } +} // namespace + +void ProcessDownloadedUpdates( + syncable::Directory* dir, + syncable::ModelNeutralWriteTransaction* trans, + ModelType type, + const SyncEntityList& applicable_updates, + sessions::StatusController* status) { + for (SyncEntityList::const_iterator update_it = applicable_updates.begin(); + update_it != applicable_updates.end(); ++update_it) { + DCHECK_EQ(type, GetModelType(**update_it)); + if (!UpdateContainsNewVersion(trans, **update_it)) + status->increment_num_reflected_updates_downloaded_by(1); + if ((*update_it)->deleted()) + status->increment_num_tombstone_updates_downloaded_by(1); + VerifyResult verify_result = VerifyUpdate(trans, **update_it, type); + if (verify_result != VERIFY_SUCCESS && verify_result != VERIFY_UNDELETE) + continue; + ProcessUpdate(**update_it, dir->GetCryptographer(trans), trans); + } +} + } // namespace syncer |