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 |