Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(61)

Side by Side Diff: sync/syncable/mutable_entry.cc

Issue 1057663002: [Sync] Eliminate friends from Directory by exposing kernel via accessor (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Changes from review. Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
OLDNEW
« no previous file with comments | « sync/syncable/model_neutral_mutable_entry.cc ('k') | sync/syncable/on_disk_directory_backing_store.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698