Index: sync/internal_api/write_transaction.cc |
diff --git a/sync/internal_api/write_transaction.cc b/sync/internal_api/write_transaction.cc |
deleted file mode 100644 |
index 8ae7f9bb0c7b90c1c368624c7bf6ee654de82cf7..0000000000000000000000000000000000000000 |
--- a/sync/internal_api/write_transaction.cc |
+++ /dev/null |
@@ -1,98 +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/internal_api/public/write_transaction.h" |
- |
-#include <stdint.h> |
- |
-#include "sync/syncable/directory.h" |
-#include "sync/syncable/mutable_entry.h" |
-#include "sync/syncable/syncable_write_transaction.h" |
- |
-namespace syncer { |
- |
-////////////////////////////////////////////////////////////////////////// |
-// WriteTransaction member definitions |
-WriteTransaction::WriteTransaction(const tracked_objects::Location& from_here, |
- UserShare* share) |
- : BaseTransaction(share), |
- transaction_(NULL) { |
- transaction_ = new syncable::WriteTransaction(from_here, syncable::SYNCAPI, |
- share->directory.get()); |
-} |
- |
-WriteTransaction::WriteTransaction(const tracked_objects::Location& from_here, |
- UserShare* share, |
- int64_t* new_model_version) |
- : BaseTransaction(share), transaction_(NULL) { |
- transaction_ = new syncable::WriteTransaction(from_here, |
- share->directory.get(), |
- new_model_version); |
-} |
- |
-WriteTransaction::~WriteTransaction() { |
- delete transaction_; |
-} |
- |
-syncable::BaseTransaction* WriteTransaction::GetWrappedTrans() const { |
- return transaction_; |
-} |
- |
-void WriteTransaction::SetDataTypeContext( |
- ModelType type, |
- syncer::SyncChangeProcessor::ContextRefreshStatus refresh_status, |
- const std::string& context) { |
- DCHECK(ProtocolTypes().Has(type)); |
- int field_number = GetSpecificsFieldNumberFromModelType(type); |
- sync_pb::DataTypeContext local_context; |
- GetDirectory()->GetDataTypeContext(transaction_, |
- type, |
- &local_context); |
- if (local_context.context() == context) |
- return; |
- |
- if (!local_context.has_data_type_id()) |
- local_context.set_data_type_id(field_number); |
- |
- DCHECK_EQ(field_number, local_context.data_type_id()); |
- DCHECK_GE(local_context.version(), 0); |
- local_context.set_version(local_context.version() + 1); |
- local_context.set_context(context); |
- GetDirectory()->SetDataTypeContext(transaction_, |
- type, |
- local_context); |
- if (refresh_status == syncer::SyncChangeProcessor::REFRESH_NEEDED) { |
- DVLOG(1) << "Forcing refresh of type " << ModelTypeToString(type); |
- // Clear the progress token from the progress markers. Preserve all other |
- // state, in case a GC directive was present. |
- sync_pb::DataTypeProgressMarker progress_marker; |
- GetDirectory()->GetDownloadProgress(type, &progress_marker); |
- progress_marker.clear_token(); |
- GetDirectory()->SetDownloadProgress(type, progress_marker); |
- |
- // Go through and reset the versions for all the synced entities of this |
- // data type. |
- GetDirectory()->ResetVersionsForType(transaction_, type); |
- } |
- |
- // Note that it's possible for a GetUpdatesResponse that arrives immediately |
- // after the context update to override the cleared progress markers. |
- // TODO(zea): add a flag in the directory to prevent this from happening. |
- // See crbug.com/360280 |
-} |
- |
-void WriteTransaction::UpdateEntriesMarkAttachmentAsOnServer( |
- const AttachmentId& attachment_id) { |
- syncable::Directory::Metahandles handles; |
- GetDirectory()->GetMetahandlesByAttachmentId( |
- transaction_, attachment_id.GetProto(), &handles); |
- for (syncable::Directory::Metahandles::iterator iter = handles.begin(); |
- iter != handles.end(); |
- ++iter) { |
- syncable::MutableEntry entry(transaction_, syncable::GET_BY_HANDLE, *iter); |
- entry.MarkAttachmentAsOnServer(attachment_id.GetProto()); |
- } |
-} |
- |
-} // namespace syncer |