| Index: sync/engine/syncer_util.cc
|
| diff --git a/sync/engine/syncer_util.cc b/sync/engine/syncer_util.cc
|
| deleted file mode 100644
|
| index bb0588505f39d2ad4cbbff37bb7ac386d312a50a..0000000000000000000000000000000000000000
|
| --- a/sync/engine/syncer_util.cc
|
| +++ /dev/null
|
| @@ -1,667 +0,0 @@
|
| -// Copyright 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/syncer_util.h"
|
| -
|
| -#include <stdint.h>
|
| -
|
| -#include <algorithm>
|
| -#include <set>
|
| -#include <string>
|
| -#include <vector>
|
| -
|
| -#include "base/base64.h"
|
| -#include "base/location.h"
|
| -#include "base/metrics/histogram.h"
|
| -#include "base/rand_util.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "sync/engine/conflict_resolver.h"
|
| -#include "sync/engine/syncer_proto_util.h"
|
| -#include "sync/engine/syncer_types.h"
|
| -#include "sync/internal_api/public/base/attachment_id_proto.h"
|
| -#include "sync/internal_api/public/base/model_type.h"
|
| -#include "sync/internal_api/public/base/unique_position.h"
|
| -#include "sync/protocol/bookmark_specifics.pb.h"
|
| -#include "sync/protocol/password_specifics.pb.h"
|
| -#include "sync/protocol/sync.pb.h"
|
| -#include "sync/syncable/directory.h"
|
| -#include "sync/syncable/entry.h"
|
| -#include "sync/syncable/model_neutral_mutable_entry.h"
|
| -#include "sync/syncable/mutable_entry.h"
|
| -#include "sync/syncable/syncable_changes_version.h"
|
| -#include "sync/syncable/syncable_model_neutral_write_transaction.h"
|
| -#include "sync/syncable/syncable_proto_util.h"
|
| -#include "sync/syncable/syncable_read_transaction.h"
|
| -#include "sync/syncable/syncable_util.h"
|
| -#include "sync/syncable/syncable_write_transaction.h"
|
| -#include "sync/util/cryptographer.h"
|
| -#include "sync/util/time.h"
|
| -
|
| -namespace syncer {
|
| -
|
| -using syncable::CHANGES_VERSION;
|
| -using syncable::Directory;
|
| -using syncable::Entry;
|
| -using syncable::GET_BY_HANDLE;
|
| -using syncable::GET_BY_ID;
|
| -using syncable::ID;
|
| -using syncable::Id;
|
| -
|
| -syncable::Id FindLocalIdToUpdate(
|
| - syncable::BaseTransaction* trans,
|
| - const sync_pb::SyncEntity& update) {
|
| - // Expected entry points of this function:
|
| - // SyncEntity has NOT been applied to SERVER fields.
|
| - // SyncEntity has NOT been applied to LOCAL fields.
|
| - // DB has not yet been modified, no entries created for this update.
|
| -
|
| - const std::string& client_id = trans->directory()->cache_guid();
|
| - const syncable::Id& update_id = SyncableIdFromProto(update.id_string());
|
| -
|
| - if (update.has_client_defined_unique_tag() &&
|
| - !update.client_defined_unique_tag().empty()) {
|
| - // When a server sends down a client tag, the following cases can occur:
|
| - // 1) Client has entry for tag already, ID is server style, matches
|
| - // 2) Client has entry for tag already, ID is server, doesn't match.
|
| - // 3) Client has entry for tag already, ID is local, (never matches)
|
| - // 4) Client has no entry for tag
|
| -
|
| - // Case 1, we don't have to do anything since the update will
|
| - // work just fine. Update will end up in the proper entry, via ID lookup.
|
| - // Case 2 - Happens very rarely due to lax enforcement of client tags
|
| - // on the server, if two clients commit the same tag at the same time.
|
| - // When this happens, we pick the lexically-least ID and ignore all other
|
| - // items.
|
| - // Case 3 - We need to replace the local ID with the server ID so that
|
| - // this update gets targeted at the correct local entry; we expect conflict
|
| - // resolution to occur.
|
| - // Case 4 - Perfect. Same as case 1.
|
| -
|
| - syncable::Entry local_entry(trans, syncable::GET_BY_CLIENT_TAG,
|
| - update.client_defined_unique_tag());
|
| -
|
| - // The SyncAPI equivalent of this function will return !good if IS_DEL.
|
| - // The syncable version will return good even if IS_DEL.
|
| - // TODO(chron): Unit test the case with IS_DEL and make sure.
|
| - if (local_entry.good()) {
|
| - if (local_entry.GetId().ServerKnows()) {
|
| - if (local_entry.GetId() != update_id) {
|
| - // Case 2.
|
| - LOG(WARNING) << "Duplicated client tag.";
|
| - if (local_entry.GetId() < update_id) {
|
| - // Signal an error; drop this update on the floor. Note that
|
| - // we don't server delete the item, because we don't allow it to
|
| - // exist locally at all. So the item will remain orphaned on
|
| - // the server, and we won't pay attention to it.
|
| - return syncable::Id();
|
| - }
|
| - }
|
| - // Target this change to the existing local entry; later,
|
| - // we'll change the ID of the local entry to update_id
|
| - // if needed.
|
| - return local_entry.GetId();
|
| - } else {
|
| - // Case 3: We have a local entry with the same client tag.
|
| - // We should change the ID of the local entry to the server entry.
|
| - // This will result in an server ID with base version == 0, but that's
|
| - // a legal state for an item with a client tag. By changing the ID,
|
| - // update will now be applied to local_entry.
|
| - DCHECK(0 == local_entry.GetBaseVersion() ||
|
| - CHANGES_VERSION == local_entry.GetBaseVersion());
|
| - return local_entry.GetId();
|
| - }
|
| - }
|
| - } else if (update.has_originator_cache_guid() &&
|
| - update.originator_cache_guid() == client_id) {
|
| - // If a commit succeeds, but the response does not come back fast enough
|
| - // then the syncer might assume that it was never committed.
|
| - // The server will track the client that sent up the original commit and
|
| - // return this in a get updates response. When this matches a local
|
| - // uncommitted item, we must mutate our local item and version to pick up
|
| - // the committed version of the same item whose commit response was lost.
|
| - // There is however still a race condition if the server has not
|
| - // completed the commit by the time the syncer tries to get updates
|
| - // again. To mitigate this, we need to have the server time out in
|
| - // a reasonable span, our commit batches have to be small enough
|
| - // to process within our HTTP response "assumed alive" time.
|
| -
|
| - // We need to check if we have an entry that didn't get its server
|
| - // id updated correctly. The server sends down a client ID
|
| - // and a local (negative) id. If we have a entry by that
|
| - // description, we should update the ID and version to the
|
| - // server side ones to avoid multiple copies of the same thing.
|
| -
|
| - syncable::Id client_item_id = syncable::Id::CreateFromClientString(
|
| - update.originator_client_item_id());
|
| - DCHECK(!client_item_id.ServerKnows());
|
| - syncable::Entry local_entry(trans, GET_BY_ID, client_item_id);
|
| -
|
| - // If it exists, then our local client lost a commit response. Use
|
| - // the local entry.
|
| - if (local_entry.good() && !local_entry.GetIsDel()) {
|
| - int64_t old_version = local_entry.GetBaseVersion();
|
| - int64_t new_version = update.version();
|
| - DCHECK_LE(old_version, 0);
|
| - DCHECK_GT(new_version, 0);
|
| - // Otherwise setting the base version could cause a consistency failure.
|
| - // An entry should never be version 0 and SYNCED.
|
| - DCHECK(local_entry.GetIsUnsynced());
|
| -
|
| - // Just a quick sanity check.
|
| - DCHECK(!local_entry.GetId().ServerKnows());
|
| -
|
| - DVLOG(1) << "Reuniting lost commit response IDs. server id: "
|
| - << update_id << " local id: " << local_entry.GetId()
|
| - << " new version: " << new_version;
|
| -
|
| - return local_entry.GetId();
|
| - }
|
| - } else if (update.has_server_defined_unique_tag() &&
|
| - !update.server_defined_unique_tag().empty()) {
|
| - // The client creates type root folders with a local ID on demand when a
|
| - // progress marker for the given type is initially set.
|
| - // The server might also attempt to send a type root folder for the same
|
| - // type (during the transition period until support for root folders is
|
| - // removed for new client versions).
|
| - // TODO(stanisc): crbug.com/438313: remove this once the transition to
|
| - // implicit root folders on the server is done.
|
| - syncable::Entry local_entry(trans, syncable::GET_BY_SERVER_TAG,
|
| - update.server_defined_unique_tag());
|
| - if (local_entry.good() && !local_entry.GetId().ServerKnows()) {
|
| - DCHECK(local_entry.GetId() != update_id);
|
| - return local_entry.GetId();
|
| - }
|
| - }
|
| -
|
| - // Fallback: target an entry having the server ID, creating one if needed.
|
| - return update_id;
|
| -}
|
| -
|
| -UpdateAttemptResponse AttemptToUpdateEntry(
|
| - syncable::WriteTransaction* const trans,
|
| - syncable::MutableEntry* const entry,
|
| - Cryptographer* cryptographer) {
|
| - CHECK(entry->good());
|
| - if (!entry->GetIsUnappliedUpdate())
|
| - return SUCCESS; // No work to do.
|
| - syncable::Id id = entry->GetId();
|
| - const sync_pb::EntitySpecifics& specifics = entry->GetServerSpecifics();
|
| - ModelType type = GetModelTypeFromSpecifics(specifics);
|
| -
|
| - // Only apply updates that we can decrypt. If we can't decrypt the update, it
|
| - // is likely because the passphrase has not arrived yet. Because the
|
| - // passphrase may not arrive within this GetUpdates, we can't just return
|
| - // conflict, else we try to perform normal conflict resolution prematurely or
|
| - // the syncer may get stuck. As such, we return CONFLICT_ENCRYPTION, which is
|
| - // treated as an unresolvable conflict. See the description in syncer_types.h.
|
| - // This prevents any unsynced changes from commiting and postpones conflict
|
| - // resolution until all data can be decrypted.
|
| - if (specifics.has_encrypted() &&
|
| - !cryptographer->CanDecrypt(specifics.encrypted())) {
|
| - // We can't decrypt this node yet.
|
| - DVLOG(1) << "Received an undecryptable "
|
| - << ModelTypeToString(entry->GetServerModelType())
|
| - << " update, returning conflict_encryption.";
|
| - return CONFLICT_ENCRYPTION;
|
| - } else if (specifics.has_password() &&
|
| - entry->GetUniqueServerTag().empty()) {
|
| - // Passwords use their own legacy encryption scheme.
|
| - const sync_pb::PasswordSpecifics& password = specifics.password();
|
| - if (!cryptographer->CanDecrypt(password.encrypted())) {
|
| - DVLOG(1) << "Received an undecryptable password update, returning "
|
| - << "conflict_encryption.";
|
| - return CONFLICT_ENCRYPTION;
|
| - }
|
| - }
|
| -
|
| - if (!entry->GetServerIsDel()) {
|
| - syncable::Id new_parent = entry->GetServerParentId();
|
| - if (!new_parent.IsNull()) {
|
| - // Perform this step only if the parent is specified.
|
| - // The unset parent means that the implicit type root would be used.
|
| - Entry parent(trans, GET_BY_ID, new_parent);
|
| - // A note on non-directory parents:
|
| - // We catch most unfixable tree invariant errors at update receipt time,
|
| - // however we deal with this case here because we may receive the child
|
| - // first then the illegal parent. Instead of dealing with it twice in
|
| - // different ways we deal with it once here to reduce the amount of code
|
| - // and potential errors.
|
| - if (!parent.good() || parent.GetIsDel() || !parent.GetIsDir()) {
|
| - DVLOG(1) << "Entry has bad parent, returning conflict_hierarchy.";
|
| - return CONFLICT_HIERARCHY;
|
| - }
|
| - if (entry->GetParentId() != new_parent) {
|
| - if (!entry->GetIsDel() && !IsLegalNewParent(trans, id, new_parent)) {
|
| - DVLOG(1) << "Not updating item " << id
|
| - << ", illegal new parent (would cause loop).";
|
| - return CONFLICT_HIERARCHY;
|
| - }
|
| - }
|
| - } else {
|
| - // new_parent is unset.
|
| - DCHECK(IsTypeWithClientGeneratedRoot(type));
|
| - }
|
| - } else if (entry->GetIsDir()) {
|
| - Directory::Metahandles handles;
|
| - trans->directory()->GetChildHandlesById(trans, id, &handles);
|
| - if (!handles.empty()) {
|
| - // If we have still-existing children, then we need to deal with
|
| - // them before we can process this change.
|
| - DVLOG(1) << "Not deleting directory; it's not empty " << *entry;
|
| - return CONFLICT_HIERARCHY;
|
| - }
|
| - }
|
| -
|
| - if (entry->GetIsUnsynced()) {
|
| - DVLOG(1) << "Skipping update, returning conflict for: " << id
|
| - << " ; it's unsynced.";
|
| - return CONFLICT_SIMPLE;
|
| - }
|
| -
|
| - if (specifics.has_encrypted()) {
|
| - DVLOG(2) << "Received a decryptable "
|
| - << ModelTypeToString(entry->GetServerModelType())
|
| - << " update, applying normally.";
|
| - } else {
|
| - DVLOG(2) << "Received an unencrypted "
|
| - << ModelTypeToString(entry->GetServerModelType())
|
| - << " update, applying normally.";
|
| - }
|
| -
|
| - UpdateLocalDataFromServerData(trans, entry);
|
| -
|
| - return SUCCESS;
|
| -}
|
| -
|
| -std::string GetUniqueBookmarkTagFromUpdate(const sync_pb::SyncEntity& update) {
|
| - if (!update.has_originator_cache_guid() ||
|
| - !update.has_originator_client_item_id()) {
|
| - LOG(ERROR) << "Update is missing requirements for bookmark position."
|
| - << " This is a server bug.";
|
| - return UniquePosition::RandomSuffix();
|
| - }
|
| -
|
| - return syncable::GenerateSyncableBookmarkHash(
|
| - update.originator_cache_guid(), update.originator_client_item_id());
|
| -}
|
| -
|
| -UniquePosition GetUpdatePosition(const sync_pb::SyncEntity& update,
|
| - const std::string& suffix) {
|
| - DCHECK(UniquePosition::IsValidSuffix(suffix));
|
| - if (!(SyncerProtoUtil::ShouldMaintainPosition(update))) {
|
| - return UniquePosition::CreateInvalid();
|
| - } else if (update.has_unique_position()) {
|
| - UniquePosition proto_position =
|
| - UniquePosition::FromProto(update.unique_position());
|
| - if (proto_position.IsValid()) {
|
| - return proto_position;
|
| - }
|
| - }
|
| -
|
| - // Now, there are two cases hit here.
|
| - // 1. Did not receive unique_position for this update.
|
| - // 2. Received unique_position, but it is invalid(ex. empty).
|
| - // And we will create a valid position for this two cases.
|
| - if (update.has_position_in_parent()) {
|
| - return UniquePosition::FromInt64(update.position_in_parent(), suffix);
|
| - } else {
|
| - LOG(ERROR) << "No position information in update. This is a server bug.";
|
| - return UniquePosition::FromInt64(0, suffix);
|
| - }
|
| -}
|
| -
|
| -namespace {
|
| -
|
| -// Helper to synthesize a new-style sync_pb::EntitySpecifics for use locally,
|
| -// when the server speaks only the old sync_pb::SyncEntity_BookmarkData-based
|
| -// protocol.
|
| -void UpdateBookmarkSpecifics(const std::string& singleton_tag,
|
| - const std::string& url,
|
| - const std::string& favicon_bytes,
|
| - syncable::ModelNeutralMutableEntry* local_entry) {
|
| - // In the new-style protocol, the server no longer sends bookmark info for
|
| - // the "google_chrome" folder. Mimic that here.
|
| - if (singleton_tag == "google_chrome")
|
| - return;
|
| - sync_pb::EntitySpecifics pb;
|
| - sync_pb::BookmarkSpecifics* bookmark = pb.mutable_bookmark();
|
| - if (!url.empty())
|
| - bookmark->set_url(url);
|
| - if (!favicon_bytes.empty())
|
| - bookmark->set_favicon(favicon_bytes);
|
| - local_entry->PutServerSpecifics(pb);
|
| -}
|
| -
|
| -void UpdateBookmarkPositioning(
|
| - const sync_pb::SyncEntity& update,
|
| - syncable::ModelNeutralMutableEntry* local_entry) {
|
| - // Update our unique bookmark tag. In many cases this will be identical to
|
| - // the tag we already have. However, clients that have recently upgraded to
|
| - // versions that support unique positions will have incorrect tags. See the
|
| - // v86 migration logic in directory_backing_store.cc for more information.
|
| - //
|
| - // Both the old and new values are unique to this element. Applying this
|
| - // update will not risk the creation of conflicting unique tags.
|
| - std::string bookmark_tag = GetUniqueBookmarkTagFromUpdate(update);
|
| - if (UniquePosition::IsValidSuffix(bookmark_tag)) {
|
| - local_entry->PutUniqueBookmarkTag(bookmark_tag);
|
| - }
|
| -
|
| - // Update our position.
|
| - UniquePosition update_pos =
|
| - GetUpdatePosition(update, local_entry->GetUniqueBookmarkTag());
|
| - if (update_pos.IsValid()) {
|
| - local_entry->PutServerUniquePosition(update_pos);
|
| - }
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -void UpdateServerFieldsFromUpdate(
|
| - syncable::ModelNeutralMutableEntry* target,
|
| - const sync_pb::SyncEntity& update,
|
| - const std::string& name) {
|
| - if (update.deleted()) {
|
| - if (target->GetServerIsDel()) {
|
| - // If we already think the item is server-deleted, we're done.
|
| - // Skipping these cases prevents our committed deletions from coming
|
| - // back and overriding subsequent undeletions. For non-deleted items,
|
| - // the version number check has a similar effect.
|
| - return;
|
| - }
|
| - // Mark entry as unapplied update first to ensure journaling the deletion.
|
| - target->PutIsUnappliedUpdate(true);
|
| - // The server returns very lightweight replies for deletions, so we don't
|
| - // clobber a bunch of fields on delete.
|
| - target->PutServerIsDel(true);
|
| - if (!target->GetUniqueClientTag().empty()) {
|
| - // Items identified by the client unique tag are undeletable; when
|
| - // they're deleted, they go back to version 0.
|
| - target->PutServerVersion(0);
|
| - } else {
|
| - // Otherwise, fake a server version by bumping the local number.
|
| - target->PutServerVersion(
|
| - std::max(target->GetServerVersion(), target->GetBaseVersion()) + 1);
|
| - }
|
| - return;
|
| - }
|
| -
|
| - DCHECK_EQ(target->GetId(), SyncableIdFromProto(update.id_string()))
|
| - << "ID Changing not supported here";
|
| - if (SyncerProtoUtil::ShouldMaintainHierarchy(update)) {
|
| - target->PutServerParentId(SyncableIdFromProto(update.parent_id_string()));
|
| - } else {
|
| - target->PutServerParentId(syncable::Id());
|
| - }
|
| - target->PutServerNonUniqueName(name);
|
| - target->PutServerVersion(update.version());
|
| - target->PutServerCtime(ProtoTimeToTime(update.ctime()));
|
| - target->PutServerMtime(ProtoTimeToTime(update.mtime()));
|
| - target->PutServerIsDir(IsFolder(update));
|
| - if (update.has_server_defined_unique_tag()) {
|
| - const std::string& tag = update.server_defined_unique_tag();
|
| - target->PutUniqueServerTag(tag);
|
| - }
|
| - if (update.has_client_defined_unique_tag()) {
|
| - const std::string& tag = update.client_defined_unique_tag();
|
| - target->PutUniqueClientTag(tag);
|
| - }
|
| - // Store the datatype-specific part as a protobuf.
|
| - if (update.has_specifics()) {
|
| - DCHECK_NE(GetModelType(update), UNSPECIFIED)
|
| - << "Storing unrecognized datatype in sync database.";
|
| - target->PutServerSpecifics(update.specifics());
|
| - } else if (update.has_bookmarkdata()) {
|
| - // Legacy protocol response for bookmark data.
|
| - const sync_pb::SyncEntity::BookmarkData& bookmark = update.bookmarkdata();
|
| - UpdateBookmarkSpecifics(update.server_defined_unique_tag(),
|
| - bookmark.bookmark_url(),
|
| - bookmark.bookmark_favicon(),
|
| - target);
|
| - }
|
| - target->PutServerAttachmentMetadata(
|
| - CreateAttachmentMetadata(update.attachment_id()));
|
| - if (SyncerProtoUtil::ShouldMaintainPosition(update)) {
|
| - UpdateBookmarkPositioning(update, target);
|
| - }
|
| -
|
| - // We only mark the entry as unapplied if its version is greater than the
|
| - // local data. If we're processing the update that corresponds to one of our
|
| - // commit we don't apply it as time differences may occur.
|
| - if (update.version() > target->GetBaseVersion()) {
|
| - target->PutIsUnappliedUpdate(true);
|
| - }
|
| - DCHECK(!update.deleted());
|
| - target->PutServerIsDel(false);
|
| -}
|
| -
|
| -// Creates a new Entry iff no Entry exists with the given id.
|
| -void CreateNewEntry(syncable::ModelNeutralWriteTransaction *trans,
|
| - const syncable::Id& id) {
|
| - syncable::Entry entry(trans, GET_BY_ID, id);
|
| - if (!entry.good()) {
|
| - syncable::ModelNeutralMutableEntry new_entry(
|
| - trans,
|
| - syncable::CREATE_NEW_UPDATE_ITEM,
|
| - id);
|
| - }
|
| -}
|
| -
|
| -// This function is called on an entry when we can update the user-facing data
|
| -// from the server data.
|
| -void UpdateLocalDataFromServerData(
|
| - syncable::WriteTransaction* trans,
|
| - syncable::MutableEntry* entry) {
|
| - DCHECK(!entry->GetIsUnsynced());
|
| - DCHECK(entry->GetIsUnappliedUpdate());
|
| -
|
| - DVLOG(2) << "Updating entry : " << *entry;
|
| - // Start by setting the properties that determine the model_type.
|
| - entry->PutSpecifics(entry->GetServerSpecifics());
|
| - // Clear the previous server specifics now that we're applying successfully.
|
| - entry->PutBaseServerSpecifics(sync_pb::EntitySpecifics());
|
| - entry->PutIsDir(entry->GetServerIsDir());
|
| - // This strange dance around the IS_DEL flag avoids problems when setting
|
| - // the name.
|
| - // TODO(chron): Is this still an issue? Unit test this codepath.
|
| - if (entry->GetServerIsDel()) {
|
| - entry->PutIsDel(true);
|
| - } else {
|
| - entry->PutNonUniqueName(entry->GetServerNonUniqueName());
|
| - entry->PutParentId(entry->GetServerParentId());
|
| - entry->PutUniquePosition(entry->GetServerUniquePosition());
|
| - entry->PutIsDel(false);
|
| - }
|
| -
|
| - entry->PutCtime(entry->GetServerCtime());
|
| - entry->PutMtime(entry->GetServerMtime());
|
| - entry->PutBaseVersion(entry->GetServerVersion());
|
| - entry->PutIsDel(entry->GetServerIsDel());
|
| - entry->PutIsUnappliedUpdate(false);
|
| - entry->PutAttachmentMetadata(entry->GetServerAttachmentMetadata());
|
| -}
|
| -
|
| -VerifyCommitResult ValidateCommitEntry(syncable::Entry* entry) {
|
| - syncable::Id id = entry->GetId();
|
| - if (id == entry->GetParentId()) {
|
| - CHECK(id.IsRoot()) << "Non-root item is self parenting." << *entry;
|
| - // If the root becomes unsynced it can cause us problems.
|
| - LOG(ERROR) << "Root item became unsynced " << *entry;
|
| - return VERIFY_UNSYNCABLE;
|
| - }
|
| - if (entry->IsRoot()) {
|
| - LOG(ERROR) << "Permanent item became unsynced " << *entry;
|
| - return VERIFY_UNSYNCABLE;
|
| - }
|
| - if (entry->GetIsDel() && !entry->GetId().ServerKnows()) {
|
| - // Drop deleted uncommitted entries.
|
| - return VERIFY_UNSYNCABLE;
|
| - }
|
| - return VERIFY_OK;
|
| -}
|
| -
|
| -void MarkDeletedChildrenSynced(
|
| - syncable::Directory* dir,
|
| - syncable::BaseWriteTransaction* trans,
|
| - std::set<syncable::Id>* deleted_folders) {
|
| - // There's two options here.
|
| - // 1. Scan deleted unsynced entries looking up their pre-delete tree for any
|
| - // of the deleted folders.
|
| - // 2. Take each folder and do a tree walk of all entries underneath it.
|
| - // #2 has a lower big O cost, but writing code to limit the time spent inside
|
| - // the transaction during each step is simpler with 1. Changing this decision
|
| - // may be sensible if this code shows up in profiling.
|
| - if (deleted_folders->empty())
|
| - return;
|
| - Directory::Metahandles handles;
|
| - dir->GetUnsyncedMetaHandles(trans, &handles);
|
| - if (handles.empty())
|
| - return;
|
| - Directory::Metahandles::iterator it;
|
| - for (it = handles.begin() ; it != handles.end() ; ++it) {
|
| - syncable::ModelNeutralMutableEntry entry(trans, GET_BY_HANDLE, *it);
|
| - if (!entry.GetIsUnsynced() || !entry.GetIsDel())
|
| - continue;
|
| - syncable::Id id = entry.GetParentId();
|
| - while (id != trans->root_id()) {
|
| - if (deleted_folders->find(id) != deleted_folders->end()) {
|
| - // We've synced the deletion of this deleted entries parent.
|
| - entry.PutIsUnsynced(false);
|
| - break;
|
| - }
|
| - Entry parent(trans, GET_BY_ID, id);
|
| - if (!parent.good() || !parent.GetIsDel())
|
| - break;
|
| - id = parent.GetParentId();
|
| - }
|
| - }
|
| -}
|
| -
|
| -VerifyResult VerifyNewEntry(
|
| - const sync_pb::SyncEntity& update,
|
| - syncable::Entry* target,
|
| - const bool deleted) {
|
| - if (target->good()) {
|
| - // Not a new update.
|
| - return VERIFY_UNDECIDED;
|
| - }
|
| - if (deleted) {
|
| - // Deletion of an item we've never seen can be ignored.
|
| - return VERIFY_SKIP;
|
| - }
|
| -
|
| - return VERIFY_SUCCESS;
|
| -}
|
| -
|
| -// Assumes we have an existing entry; check here for updates that break
|
| -// consistency rules.
|
| -VerifyResult VerifyUpdateConsistency(
|
| - syncable::ModelNeutralWriteTransaction* trans,
|
| - const sync_pb::SyncEntity& update,
|
| - const bool deleted,
|
| - const bool is_directory,
|
| - ModelType model_type,
|
| - syncable::ModelNeutralMutableEntry* target) {
|
| -
|
| - CHECK(target->good());
|
| - const syncable::Id& update_id = SyncableIdFromProto(update.id_string());
|
| -
|
| - // If the update is a delete, we don't really need to worry at this stage.
|
| - if (deleted)
|
| - return VERIFY_SUCCESS;
|
| -
|
| - if (model_type == UNSPECIFIED) {
|
| - // This update is to an item of a datatype we don't recognize. The server
|
| - // shouldn't have sent it to us. Throw it on the ground.
|
| - return VERIFY_SKIP;
|
| - }
|
| -
|
| - if (target->GetServerVersion() > 0) {
|
| - // Then we've had an update for this entry before.
|
| - if (is_directory != target->GetServerIsDir() ||
|
| - model_type != target->GetServerModelType()) {
|
| - if (target->GetIsDel()) { // If we've deleted the item, we don't care.
|
| - return VERIFY_SKIP;
|
| - } else {
|
| - LOG(ERROR) << "Server update doesn't agree with previous updates. ";
|
| - LOG(ERROR) << " Entry: " << *target;
|
| - LOG(ERROR) << " Update: "
|
| - << SyncerProtoUtil::SyncEntityDebugString(update);
|
| - return VERIFY_FAIL;
|
| - }
|
| - }
|
| -
|
| - if (!deleted && (target->GetId() == update_id) &&
|
| - (target->GetServerIsDel() ||
|
| - (!target->GetIsUnsynced() && target->GetIsDel() &&
|
| - target->GetBaseVersion() > 0))) {
|
| - // An undelete. The latter case in the above condition is for
|
| - // when the server does not give us an update following the
|
| - // commit of a delete, before undeleting.
|
| - // Undeletion is common for items that reuse the client-unique tag.
|
| - VerifyResult result = VerifyUndelete(trans, update, target);
|
| - if (VERIFY_UNDECIDED != result)
|
| - return result;
|
| - }
|
| - }
|
| - if (target->GetBaseVersion() > 0) {
|
| - // We've committed this update in the past.
|
| - if (is_directory != target->GetIsDir() ||
|
| - model_type != target->GetModelType()) {
|
| - LOG(ERROR) << "Server update doesn't agree with committed item. ";
|
| - LOG(ERROR) << " Entry: " << *target;
|
| - LOG(ERROR) << " Update: "
|
| - << SyncerProtoUtil::SyncEntityDebugString(update);
|
| - return VERIFY_FAIL;
|
| - }
|
| - if (target->GetId() == update_id) {
|
| - if (target->GetServerVersion() > update.version()) {
|
| - LOG(WARNING) << "We've already seen a more recent version.";
|
| - LOG(WARNING) << " Entry: " << *target;
|
| - LOG(WARNING) << " Update: "
|
| - << SyncerProtoUtil::SyncEntityDebugString(update);
|
| - return VERIFY_SKIP;
|
| - }
|
| - }
|
| - }
|
| - return VERIFY_SUCCESS;
|
| -}
|
| -
|
| -// Assumes we have an existing entry; verify an update that seems to be
|
| -// expressing an 'undelete'
|
| -VerifyResult VerifyUndelete(syncable::ModelNeutralWriteTransaction* trans,
|
| - const sync_pb::SyncEntity& update,
|
| - syncable::ModelNeutralMutableEntry* target) {
|
| - // TODO(nick): We hit this path for items deleted items that the server
|
| - // tells us to re-create; only deleted items with positive base versions
|
| - // will hit this path. However, it's not clear how such an undeletion
|
| - // would actually succeed on the server; in the protocol, a base
|
| - // version of 0 is required to undelete an object. This codepath
|
| - // should be deprecated in favor of client-tag style undeletion
|
| - // (where items go to version 0 when they're deleted), or else
|
| - // removed entirely (if this type of undeletion is indeed impossible).
|
| - CHECK(target->good());
|
| - DVLOG(1) << "Server update is attempting undelete. " << *target
|
| - << "Update:" << SyncerProtoUtil::SyncEntityDebugString(update);
|
| - // Move the old one aside and start over. It's too tricky to get the old one
|
| - // back into a state that would pass CheckTreeInvariants().
|
| - if (target->GetIsDel()) {
|
| - if (target->GetUniqueClientTag().empty())
|
| - LOG(WARNING) << "Doing move-aside undeletion on client-tagged item.";
|
| - target->PutId(trans->directory()->NextId());
|
| - target->PutUniqueClientTag(std::string());
|
| - target->PutBaseVersion(CHANGES_VERSION);
|
| - target->PutServerVersion(0);
|
| - return VERIFY_SUCCESS;
|
| - }
|
| - if (update.version() < target->GetServerVersion()) {
|
| - LOG(WARNING) << "Update older than current server version for "
|
| - << *target << " Update:"
|
| - << SyncerProtoUtil::SyncEntityDebugString(update);
|
| - return VERIFY_SUCCESS; // Expected in new sync protocol.
|
| - }
|
| - return VERIFY_UNDECIDED;
|
| -}
|
| -
|
| -} // namespace syncer
|
|
|