| 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 "sync/syncable/mutable_entry.h" | 5 #include "sync/syncable/mutable_entry.h" |
| 6 | 6 |
| 7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
| 8 #include "sync/internal_api/public/base/unique_position.h" | 8 #include "sync/internal_api/public/base/unique_position.h" |
| 9 #include "sync/syncable/directory.h" | 9 #include "sync/syncable/directory.h" |
| 10 #include "sync/syncable/scoped_kernel_lock.h" | 10 #include "sync/syncable/scoped_kernel_lock.h" |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 | 21 |
| 22 void MutableEntry::Init(WriteTransaction* trans, | 22 void MutableEntry::Init(WriteTransaction* trans, |
| 23 ModelType model_type, | 23 ModelType model_type, |
| 24 const Id& parent_id, | 24 const Id& parent_id, |
| 25 const string& name) { | 25 const string& name) { |
| 26 scoped_ptr<EntryKernel> kernel(new EntryKernel); | 26 scoped_ptr<EntryKernel> kernel(new EntryKernel); |
| 27 kernel_ = NULL; | 27 kernel_ = NULL; |
| 28 | 28 |
| 29 kernel->put(ID, trans->directory_->NextId()); | 29 kernel->put(ID, trans->directory_->NextId()); |
| 30 kernel->put(META_HANDLE, trans->directory_->NextMetahandle()); | 30 kernel->put(META_HANDLE, trans->directory_->NextMetahandle()); |
| 31 kernel->mark_dirty(&trans->directory_->kernel_->dirty_metahandles); | 31 kernel->mark_dirty(&trans->directory_->kernel()->dirty_metahandles); |
| 32 kernel->put(NON_UNIQUE_NAME, name); | 32 kernel->put(NON_UNIQUE_NAME, name); |
| 33 const base::Time& now = base::Time::Now(); | 33 const base::Time& now = base::Time::Now(); |
| 34 kernel->put(CTIME, now); | 34 kernel->put(CTIME, now); |
| 35 kernel->put(MTIME, now); | 35 kernel->put(MTIME, now); |
| 36 // We match the database defaults here | 36 // We match the database defaults here |
| 37 kernel->put(BASE_VERSION, CHANGES_VERSION); | 37 kernel->put(BASE_VERSION, CHANGES_VERSION); |
| 38 | 38 |
| 39 if (!parent_id.IsNull()) { | 39 if (!parent_id.IsNull()) { |
| 40 kernel->put(PARENT_ID, parent_id); | 40 kernel->put(PARENT_ID, parent_id); |
| 41 } | 41 } |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 119 : ModelNeutralMutableEntry(trans, GET_TYPE_ROOT, type), | 119 : ModelNeutralMutableEntry(trans, GET_TYPE_ROOT, type), |
| 120 write_transaction_(trans) { | 120 write_transaction_(trans) { |
| 121 } | 121 } |
| 122 | 122 |
| 123 void MutableEntry::PutLocalExternalId(int64 value) { | 123 void MutableEntry::PutLocalExternalId(int64 value) { |
| 124 DCHECK(kernel_); | 124 DCHECK(kernel_); |
| 125 write_transaction()->TrackChangesTo(kernel_); | 125 write_transaction()->TrackChangesTo(kernel_); |
| 126 if (kernel_->ref(LOCAL_EXTERNAL_ID) != value) { | 126 if (kernel_->ref(LOCAL_EXTERNAL_ID) != value) { |
| 127 ScopedKernelLock lock(dir()); | 127 ScopedKernelLock lock(dir()); |
| 128 kernel_->put(LOCAL_EXTERNAL_ID, value); | 128 kernel_->put(LOCAL_EXTERNAL_ID, value); |
| 129 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 129 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 130 } | 130 } |
| 131 } | 131 } |
| 132 | 132 |
| 133 void MutableEntry::PutMtime(base::Time value) { | 133 void MutableEntry::PutMtime(base::Time value) { |
| 134 DCHECK(kernel_); | 134 DCHECK(kernel_); |
| 135 write_transaction()->TrackChangesTo(kernel_); | 135 write_transaction()->TrackChangesTo(kernel_); |
| 136 if (kernel_->ref(MTIME) != value) { | 136 if (kernel_->ref(MTIME) != value) { |
| 137 kernel_->put(MTIME, value); | 137 kernel_->put(MTIME, value); |
| 138 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 138 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 139 } | 139 } |
| 140 } | 140 } |
| 141 | 141 |
| 142 void MutableEntry::PutCtime(base::Time value) { | 142 void MutableEntry::PutCtime(base::Time value) { |
| 143 DCHECK(kernel_); | 143 DCHECK(kernel_); |
| 144 write_transaction()->TrackChangesTo(kernel_); | 144 write_transaction()->TrackChangesTo(kernel_); |
| 145 if (kernel_->ref(CTIME) != value) { | 145 if (kernel_->ref(CTIME) != value) { |
| 146 kernel_->put(CTIME, value); | 146 kernel_->put(CTIME, value); |
| 147 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 147 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 148 } | 148 } |
| 149 } | 149 } |
| 150 | 150 |
| 151 void MutableEntry::PutParentId(const Id& value) { | 151 void MutableEntry::PutParentId(const Id& value) { |
| 152 DCHECK(kernel_); | 152 DCHECK(kernel_); |
| 153 write_transaction()->TrackChangesTo(kernel_); | 153 write_transaction()->TrackChangesTo(kernel_); |
| 154 if (kernel_->ref(PARENT_ID) != value) { | 154 if (kernel_->ref(PARENT_ID) != value) { |
| 155 PutParentIdPropertyOnly(value); | 155 PutParentIdPropertyOnly(value); |
| 156 if (!GetIsDel()) { | 156 if (!GetIsDel()) { |
| 157 if (!PutPredecessor(Id())) { | 157 if (!PutPredecessor(Id())) { |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 192 if (!GetId().ServerKnows() && !GetSyncing()) { | 192 if (!GetId().ServerKnows() && !GetSyncing()) { |
| 193 PutIsUnsynced(false); | 193 PutIsUnsynced(false); |
| 194 } | 194 } |
| 195 } | 195 } |
| 196 | 196 |
| 197 { | 197 { |
| 198 ScopedKernelLock lock(dir()); | 198 ScopedKernelLock lock(dir()); |
| 199 // Some indices don't include deleted items and must be updated | 199 // Some indices don't include deleted items and must be updated |
| 200 // upon a value change. | 200 // upon a value change. |
| 201 ScopedParentChildIndexUpdater updater(lock, kernel_, | 201 ScopedParentChildIndexUpdater updater(lock, kernel_, |
| 202 &dir()->kernel_->parent_child_index); | 202 &dir()->kernel()->parent_child_index); |
| 203 | 203 |
| 204 kernel_->put(IS_DEL, value); | 204 kernel_->put(IS_DEL, value); |
| 205 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 205 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 206 } | 206 } |
| 207 } | 207 } |
| 208 | 208 |
| 209 void MutableEntry::PutNonUniqueName(const std::string& value) { | 209 void MutableEntry::PutNonUniqueName(const std::string& value) { |
| 210 DCHECK(kernel_); | 210 DCHECK(kernel_); |
| 211 write_transaction()->TrackChangesTo(kernel_); | 211 write_transaction()->TrackChangesTo(kernel_); |
| 212 | 212 |
| 213 if (kernel_->ref(NON_UNIQUE_NAME) != value) { | 213 if (kernel_->ref(NON_UNIQUE_NAME) != value) { |
| 214 kernel_->put(NON_UNIQUE_NAME, value); | 214 kernel_->put(NON_UNIQUE_NAME, value); |
| 215 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 215 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 216 } | 216 } |
| 217 } | 217 } |
| 218 | 218 |
| 219 void MutableEntry::PutSpecifics(const sync_pb::EntitySpecifics& value) { | 219 void MutableEntry::PutSpecifics(const sync_pb::EntitySpecifics& value) { |
| 220 DCHECK(kernel_); | 220 DCHECK(kernel_); |
| 221 CHECK(!value.password().has_client_only_encrypted_data()); | 221 CHECK(!value.password().has_client_only_encrypted_data()); |
| 222 write_transaction()->TrackChangesTo(kernel_); | 222 write_transaction()->TrackChangesTo(kernel_); |
| 223 // TODO(ncarter): This is unfortunately heavyweight. Can we do | 223 // TODO(ncarter): This is unfortunately heavyweight. Can we do |
| 224 // better? | 224 // better? |
| 225 if (kernel_->ref(SPECIFICS).SerializeAsString() != | 225 if (kernel_->ref(SPECIFICS).SerializeAsString() != |
| 226 value.SerializeAsString()) { | 226 value.SerializeAsString()) { |
| 227 kernel_->put(SPECIFICS, value); | 227 kernel_->put(SPECIFICS, value); |
| 228 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 228 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 229 } | 229 } |
| 230 } | 230 } |
| 231 | 231 |
| 232 void MutableEntry::PutUniquePosition(const UniquePosition& value) { | 232 void MutableEntry::PutUniquePosition(const UniquePosition& value) { |
| 233 DCHECK(kernel_); | 233 DCHECK(kernel_); |
| 234 write_transaction()->TrackChangesTo(kernel_); | 234 write_transaction()->TrackChangesTo(kernel_); |
| 235 if(!kernel_->ref(UNIQUE_POSITION).Equals(value)) { | 235 if(!kernel_->ref(UNIQUE_POSITION).Equals(value)) { |
| 236 // We should never overwrite a valid position with an invalid one. | 236 // We should never overwrite a valid position with an invalid one. |
| 237 DCHECK(value.IsValid()); | 237 DCHECK(value.IsValid()); |
| 238 ScopedKernelLock lock(dir()); | 238 ScopedKernelLock lock(dir()); |
| 239 ScopedParentChildIndexUpdater updater( | 239 ScopedParentChildIndexUpdater updater( |
| 240 lock, kernel_, &dir()->kernel_->parent_child_index); | 240 lock, kernel_, &dir()->kernel()->parent_child_index); |
| 241 kernel_->put(UNIQUE_POSITION, value); | 241 kernel_->put(UNIQUE_POSITION, value); |
| 242 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 242 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 243 } | 243 } |
| 244 } | 244 } |
| 245 | 245 |
| 246 bool MutableEntry::PutPredecessor(const Id& predecessor_id) { | 246 bool MutableEntry::PutPredecessor(const Id& predecessor_id) { |
| 247 if (predecessor_id.IsNull()) { | 247 if (predecessor_id.IsNull()) { |
| 248 dir()->PutPredecessor(kernel_, NULL); | 248 dir()->PutPredecessor(kernel_, NULL); |
| 249 } else { | 249 } else { |
| 250 MutableEntry predecessor(write_transaction(), GET_BY_ID, predecessor_id); | 250 MutableEntry predecessor(write_transaction(), GET_BY_ID, predecessor_id); |
| 251 if (!predecessor.good()) | 251 if (!predecessor.good()) |
| 252 return false; | 252 return false; |
| 253 dir()->PutPredecessor(kernel_, predecessor.kernel_); | 253 dir()->PutPredecessor(kernel_, predecessor.kernel_); |
| 254 } | 254 } |
| 255 return true; | 255 return true; |
| 256 } | 256 } |
| 257 | 257 |
| 258 void MutableEntry::PutAttachmentMetadata( | 258 void MutableEntry::PutAttachmentMetadata( |
| 259 const sync_pb::AttachmentMetadata& attachment_metadata) { | 259 const sync_pb::AttachmentMetadata& attachment_metadata) { |
| 260 DCHECK(kernel_); | 260 DCHECK(kernel_); |
| 261 write_transaction()->TrackChangesTo(kernel_); | 261 write_transaction()->TrackChangesTo(kernel_); |
| 262 if (kernel_->ref(ATTACHMENT_METADATA).SerializeAsString() != | 262 if (kernel_->ref(ATTACHMENT_METADATA).SerializeAsString() != |
| 263 attachment_metadata.SerializeAsString()) { | 263 attachment_metadata.SerializeAsString()) { |
| 264 dir()->UpdateAttachmentIndex(GetMetahandle(), | 264 dir()->UpdateAttachmentIndex(GetMetahandle(), |
| 265 kernel_->ref(ATTACHMENT_METADATA), | 265 kernel_->ref(ATTACHMENT_METADATA), |
| 266 attachment_metadata); | 266 attachment_metadata); |
| 267 kernel_->put(ATTACHMENT_METADATA, attachment_metadata); | 267 kernel_->put(ATTACHMENT_METADATA, attachment_metadata); |
| 268 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 268 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 269 } | 269 } |
| 270 } | 270 } |
| 271 | 271 |
| 272 void MutableEntry::MarkAttachmentAsOnServer( | 272 void MutableEntry::MarkAttachmentAsOnServer( |
| 273 const sync_pb::AttachmentIdProto& attachment_id) { | 273 const sync_pb::AttachmentIdProto& attachment_id) { |
| 274 DCHECK(kernel_); | 274 DCHECK(kernel_); |
| 275 DCHECK(!attachment_id.unique_id().empty()); | 275 DCHECK(!attachment_id.unique_id().empty()); |
| 276 write_transaction()->TrackChangesTo(kernel_); | 276 write_transaction()->TrackChangesTo(kernel_); |
| 277 sync_pb::AttachmentMetadata& attachment_metadata = | 277 sync_pb::AttachmentMetadata& attachment_metadata = |
| 278 kernel_->mutable_ref(ATTACHMENT_METADATA); | 278 kernel_->mutable_ref(ATTACHMENT_METADATA); |
| 279 for (int i = 0; i < attachment_metadata.record_size(); ++i) { | 279 for (int i = 0; i < attachment_metadata.record_size(); ++i) { |
| 280 sync_pb::AttachmentMetadataRecord* record = | 280 sync_pb::AttachmentMetadataRecord* record = |
| 281 attachment_metadata.mutable_record(i); | 281 attachment_metadata.mutable_record(i); |
| 282 if (record->id().unique_id() != attachment_id.unique_id()) | 282 if (record->id().unique_id() != attachment_id.unique_id()) |
| 283 continue; | 283 continue; |
| 284 record->set_is_on_server(true); | 284 record->set_is_on_server(true); |
| 285 } | 285 } |
| 286 kernel_->mark_dirty(&dir()->kernel_->dirty_metahandles); | 286 kernel_->mark_dirty(&dir()->kernel()->dirty_metahandles); |
| 287 MarkForSyncing(this); | 287 MarkForSyncing(this); |
| 288 } | 288 } |
| 289 | 289 |
| 290 // This function sets only the flags needed to get this entry to sync. | 290 // This function sets only the flags needed to get this entry to sync. |
| 291 bool MarkForSyncing(MutableEntry* e) { | 291 bool MarkForSyncing(MutableEntry* e) { |
| 292 DCHECK_NE(static_cast<MutableEntry*>(NULL), e); | 292 DCHECK_NE(static_cast<MutableEntry*>(NULL), e); |
| 293 DCHECK(!e->IsRoot()) << "We shouldn't mark a permanent object for syncing."; | 293 DCHECK(!e->IsRoot()) << "We shouldn't mark a permanent object for syncing."; |
| 294 if (!(e->PutIsUnsynced(true))) | 294 if (!(e->PutIsUnsynced(true))) |
| 295 return false; | 295 return false; |
| 296 if (e->GetSyncing()) | 296 if (e->GetSyncing()) |
| 297 e->PutDirtySync(true); | 297 e->PutDirtySync(true); |
| 298 return true; | 298 return true; |
| 299 } | 299 } |
| 300 | 300 |
| 301 } // namespace syncable | 301 } // namespace syncable |
| 302 } // namespace syncer | 302 } // namespace syncer |
| OLD | NEW |