| Index: sync/syncable/mutable_entry.cc
|
| diff --git a/sync/syncable/mutable_entry.cc b/sync/syncable/mutable_entry.cc
|
| deleted file mode 100644
|
| index 160a6dfbf034fd9554cf86a722d1c10199f3f9c5..0000000000000000000000000000000000000000
|
| --- a/sync/syncable/mutable_entry.cc
|
| +++ /dev/null
|
| @@ -1,322 +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/syncable/mutable_entry.h"
|
| -
|
| -#include <stdint.h>
|
| -
|
| -#include <memory>
|
| -
|
| -#include "sync/internal_api/public/base/unique_position.h"
|
| -#include "sync/syncable/directory.h"
|
| -#include "sync/syncable/scoped_kernel_lock.h"
|
| -#include "sync/syncable/scoped_parent_child_index_updater.h"
|
| -#include "sync/syncable/syncable-inl.h"
|
| -#include "sync/syncable/syncable_changes_version.h"
|
| -#include "sync/syncable/syncable_util.h"
|
| -#include "sync/syncable/syncable_write_transaction.h"
|
| -
|
| -using std::string;
|
| -
|
| -namespace syncer {
|
| -namespace syncable {
|
| -
|
| -void MutableEntry::Init(WriteTransaction* trans,
|
| - ModelType model_type,
|
| - const Id& parent_id,
|
| - const string& name) {
|
| - std::unique_ptr<EntryKernel> kernel(new EntryKernel);
|
| - kernel_ = NULL;
|
| -
|
| - kernel->put(ID, trans->directory_->NextId());
|
| - kernel->put(META_HANDLE, trans->directory_->NextMetahandle());
|
| - kernel->mark_dirty(&trans->directory_->kernel()->dirty_metahandles);
|
| - kernel->put(NON_UNIQUE_NAME, name);
|
| - const base::Time& now = base::Time::Now();
|
| - kernel->put(CTIME, now);
|
| - kernel->put(MTIME, now);
|
| - // We match the database defaults here
|
| - kernel->put(BASE_VERSION, CHANGES_VERSION);
|
| -
|
| - if (!parent_id.IsNull()) {
|
| - kernel->put(PARENT_ID, parent_id);
|
| - }
|
| -
|
| - // Normally the SPECIFICS setting code is wrapped in logic to deal with
|
| - // unknown fields and encryption. Since all we want to do here is ensure that
|
| - // GetModelType() returns a correct value from the very beginning, these
|
| - // few lines are sufficient.
|
| - sync_pb::EntitySpecifics specifics;
|
| - AddDefaultFieldValue(model_type, &specifics);
|
| - kernel->put(SPECIFICS, specifics);
|
| -
|
| - // Because this entry is new, it was originally deleted.
|
| - kernel->put(IS_DEL, true);
|
| - trans->TrackChangesTo(kernel.get());
|
| - kernel->put(IS_DEL, false);
|
| -
|
| - // Now swap the pointers.
|
| - kernel_ = kernel.release();
|
| -}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans,
|
| - Create,
|
| - ModelType model_type,
|
| - const string& name)
|
| - : ModelNeutralMutableEntry(trans), write_transaction_(trans) {
|
| - Init(trans, model_type, Id(), name);
|
| - // We need to have a valid position ready before we can index the item.
|
| - DCHECK_NE(BOOKMARKS, model_type);
|
| - DCHECK(!ShouldMaintainPosition());
|
| -
|
| - bool result = trans->directory()->InsertEntry(trans, kernel_);
|
| - DCHECK(result);
|
| -}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans,
|
| - Create,
|
| - ModelType model_type,
|
| - const Id& parent_id,
|
| - const string& name)
|
| - : ModelNeutralMutableEntry(trans), write_transaction_(trans) {
|
| - Init(trans, model_type, parent_id, name);
|
| - // We need to have a valid position ready before we can index the item.
|
| - if (model_type == BOOKMARKS) {
|
| - // Base the tag off of our cache-guid and local "c-" style ID.
|
| - std::string unique_tag = syncable::GenerateSyncableBookmarkHash(
|
| - trans->directory()->cache_guid(), GetId().GetServerId());
|
| - kernel_->put(UNIQUE_BOOKMARK_TAG, unique_tag);
|
| - kernel_->put(UNIQUE_POSITION, UniquePosition::InitialPosition(unique_tag));
|
| - } else {
|
| - DCHECK(!ShouldMaintainPosition());
|
| - }
|
| -
|
| - bool result = trans->directory()->InsertEntry(trans, kernel_);
|
| - DCHECK(result);
|
| -}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans, CreateNewUpdateItem,
|
| - const Id& id)
|
| - : ModelNeutralMutableEntry(trans, CREATE_NEW_UPDATE_ITEM, id),
|
| - write_transaction_(trans) {}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans, GetById, const Id& id)
|
| - : ModelNeutralMutableEntry(trans, GET_BY_ID, id),
|
| - write_transaction_(trans) {
|
| -}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans,
|
| - GetByHandle,
|
| - int64_t metahandle)
|
| - : ModelNeutralMutableEntry(trans, GET_BY_HANDLE, metahandle),
|
| - write_transaction_(trans) {}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans, GetByClientTag,
|
| - const std::string& tag)
|
| - : ModelNeutralMutableEntry(trans, GET_BY_CLIENT_TAG, tag),
|
| - write_transaction_(trans) {
|
| -}
|
| -
|
| -MutableEntry::MutableEntry(WriteTransaction* trans, GetTypeRoot, ModelType type)
|
| - : ModelNeutralMutableEntry(trans, GET_TYPE_ROOT, type),
|
| - write_transaction_(trans) {
|
| -}
|
| -
|
| -void MutableEntry::PutLocalExternalId(int64_t value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(LOCAL_EXTERNAL_ID) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - ScopedKernelLock lock(dir());
|
| - kernel_->put(LOCAL_EXTERNAL_ID, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutMtime(base::Time value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(MTIME) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - kernel_->put(MTIME, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutCtime(base::Time value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(CTIME) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - kernel_->put(CTIME, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutParentId(const Id& value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(PARENT_ID) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - PutParentIdPropertyOnly(value);
|
| - if (!GetIsDel()) {
|
| - if (!PutPredecessor(Id())) {
|
| - // TODO(lipalani) : Propagate the error to caller. crbug.com/100444.
|
| - NOTREACHED();
|
| - }
|
| - }
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutIsDir(bool value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(IS_DIR) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - kernel_->put(IS_DIR, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutIsDel(bool value) {
|
| - DCHECK(kernel_);
|
| - if (value == kernel_->ref(IS_DEL)) {
|
| - return;
|
| - }
|
| -
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - if (value) {
|
| - // If the server never knew about this item and it's deleted then we don't
|
| - // need to keep it around. Unsetting IS_UNSYNCED will:
|
| - // - Ensure that the item is never committed to the server.
|
| - // - Allow any items with the same UNIQUE_CLIENT_TAG created on other
|
| - // clients to override this entry.
|
| - // - Let us delete this entry permanently when we next restart sync - see
|
| - // DirectoryBackingStore::SafeToPurgeOnLoading.
|
| - // This will avoid crbug.com/125381.
|
| - // Note: do not unset IsUnsynced if the syncer has started but not yet
|
| - // finished committing this entity.
|
| - if (!GetId().ServerKnows() && !GetSyncing()) {
|
| - PutIsUnsynced(false);
|
| - }
|
| - }
|
| -
|
| - {
|
| - ScopedKernelLock lock(dir());
|
| - // Some indices don't include deleted items and must be updated
|
| - // upon a value change.
|
| - ScopedParentChildIndexUpdater updater(lock, kernel_,
|
| - &dir()->kernel()->parent_child_index);
|
| -
|
| - kernel_->put(IS_DEL, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutNonUniqueName(const std::string& value) {
|
| - DCHECK(kernel_);
|
| - if (kernel_->ref(NON_UNIQUE_NAME) != value) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - kernel_->put(NON_UNIQUE_NAME, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutSpecifics(const sync_pb::EntitySpecifics& value) {
|
| - DCHECK(kernel_);
|
| - CHECK(!value.password().has_client_only_encrypted_data());
|
| - // TODO(ncarter): This is unfortunately heavyweight. Can we do
|
| - // better?
|
| - const std::string& serialized_value = value.SerializeAsString();
|
| - if (serialized_value != kernel_->ref(SPECIFICS).SerializeAsString()) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - // Check for potential sharing - SPECIFICS is often
|
| - // copied from SERVER_SPECIFICS.
|
| - if (serialized_value ==
|
| - kernel_->ref(SERVER_SPECIFICS).SerializeAsString()) {
|
| - kernel_->copy(SERVER_SPECIFICS, SPECIFICS);
|
| - } else {
|
| - kernel_->put(SPECIFICS, value);
|
| - }
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::PutUniquePosition(const UniquePosition& value) {
|
| - DCHECK(kernel_);
|
| - if (!kernel_->ref(UNIQUE_POSITION).Equals(value)) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - // We should never overwrite a valid position with an invalid one.
|
| - DCHECK(value.IsValid());
|
| - ScopedKernelLock lock(dir());
|
| - ScopedParentChildIndexUpdater updater(
|
| - lock, kernel_, &dir()->kernel()->parent_child_index);
|
| - kernel_->put(UNIQUE_POSITION, value);
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -bool MutableEntry::PutPredecessor(const Id& predecessor_id) {
|
| - if (predecessor_id.IsNull()) {
|
| - dir()->PutPredecessor(kernel_, NULL);
|
| - } else {
|
| - MutableEntry predecessor(write_transaction(), GET_BY_ID, predecessor_id);
|
| - if (!predecessor.good())
|
| - return false;
|
| - dir()->PutPredecessor(kernel_, predecessor.kernel_);
|
| - // No need to make the entry dirty here because setting the predecessor
|
| - // results in PutUniquePosition call (which might or might not make the
|
| - // entry dirty).
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -void MutableEntry::PutAttachmentMetadata(
|
| - const sync_pb::AttachmentMetadata& value) {
|
| - DCHECK(kernel_);
|
| - const std::string& serialized_value = value.SerializeAsString();
|
| - if (serialized_value !=
|
| - kernel_->ref(ATTACHMENT_METADATA).SerializeAsString()) {
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - dir()->UpdateAttachmentIndex(GetMetahandle(),
|
| - kernel_->ref(ATTACHMENT_METADATA), value);
|
| - // Check for potential sharing - ATTACHMENT_METADATA is often
|
| - // copied from SERVER_ATTACHMENT_METADATA.
|
| - if (serialized_value ==
|
| - kernel_->ref(SERVER_ATTACHMENT_METADATA).SerializeAsString()) {
|
| - kernel_->copy(SERVER_ATTACHMENT_METADATA, ATTACHMENT_METADATA);
|
| - } else {
|
| - kernel_->put(ATTACHMENT_METADATA, value);
|
| - }
|
| - MarkDirty();
|
| - }
|
| -}
|
| -
|
| -void MutableEntry::MarkAttachmentAsOnServer(
|
| - const sync_pb::AttachmentIdProto& attachment_id) {
|
| - DCHECK(kernel_);
|
| - DCHECK(!attachment_id.unique_id().empty());
|
| - write_transaction()->TrackChangesTo(kernel_);
|
| - sync_pb::AttachmentMetadata attachment_metadata =
|
| - kernel_->ref(ATTACHMENT_METADATA);
|
| - for (int i = 0; i < attachment_metadata.record_size(); ++i) {
|
| - sync_pb::AttachmentMetadataRecord* record =
|
| - attachment_metadata.mutable_record(i);
|
| - if (record->id().unique_id() != attachment_id.unique_id())
|
| - continue;
|
| - record->set_is_on_server(true);
|
| - }
|
| - kernel_->put(ATTACHMENT_METADATA, attachment_metadata);
|
| - MarkDirty();
|
| - MarkForSyncing(this);
|
| -}
|
| -
|
| -// This function sets only the flags needed to get this entry to sync.
|
| -bool MarkForSyncing(MutableEntry* e) {
|
| - DCHECK_NE(static_cast<MutableEntry*>(NULL), e);
|
| - DCHECK(!e->IsRoot()) << "We shouldn't mark a permanent object for syncing.";
|
| - if (!(e->PutIsUnsynced(true)))
|
| - return false;
|
| - if (e->GetSyncing())
|
| - e->PutDirtySync(true);
|
| - return true;
|
| -}
|
| -
|
| -} // namespace syncable
|
| -} // namespace syncer
|
|
|