Lines Matching refs:entry
32 using syncable::Entry;
79 syncable::MutableEntry* entry,
82 syncable::Id old_id = entry->Get(ID);
83 if (!entry->Put(ID, new_id)) {
84 Entry old_entry(trans, GET_BY_ID, new_id);
87 << " conflicts with existing entry.\n\n"
88 << *entry << "\n\n" << old_entry;
90 if (entry->Get(IS_DIR)) {
109 if (entry->Get(PREV_ID) == entry->Get(NEXT_ID) &&
110 entry->Get(PREV_ID) == old_id) {
111 // We just need a shallow update to |entry|'s fields since it is already
113 entry->Put(NEXT_ID, new_id);
114 entry->Put(PREV_ID, new_id);
116 entry->PutPredecessor(entry->Get(PREV_ID));
123 syncable::MutableEntry* entry,
126 ChangeEntryIDAndUpdateChildren(trans, entry, new_id, &children);
133 // Expected entry points of this function:
143 // 1) Client has entry for tag already, ID is server style, matches
144 // 2) Client has entry for tag already, ID is server, doesn't match.
145 // 3) Client has entry for tag already, ID is local, (never matches)
146 // 4) Client has no entry for tag
149 // work just fine. Update will end up in the proper entry, via ID lookup.
155 // this update gets targeted at the correct local entry; we expect conflict
159 syncable::Entry local_entry(trans, syncable::GET_BY_CLIENT_TAG,
178 // Target this change to the existing local entry; later,
179 // we'll change the ID of the local entry to update.id()
183 // Case 3: We have a local entry with the same client tag.
184 // We should change the ID of the local entry to the server entry.
207 // We need to check if we have an entry that didn't get its server
209 // and a local (negative) id. If we have a entry by that
216 syncable::Entry local_entry(trans, GET_BY_ID, client_item_id);
219 // the local entry.
226 // An entry should never be version 0 and SYNCED.
239 // Fallback: target an entry having the server ID, creating one if needed.
246 syncable::MutableEntry* const entry,
250 CHECK(entry->good());
251 if (!entry->Get(IS_UNAPPLIED_UPDATE))
253 syncable::Id id = entry->Get(ID);
255 if (entry->Get(IS_UNSYNCED)) {
260 if (!entry->Get(SERVER_IS_DEL)) {
261 syncable::Id new_parent = entry->Get(SERVER_PARENT_ID);
262 Entry parent(trans, GET_BY_ID, new_parent);
272 if (entry->Get(PARENT_ID) != new_parent) {
273 if (!entry->Get(IS_DEL) && !IsLegalNewParent(trans, id, new_parent)) {
279 } else if (entry->Get(IS_DIR)) {
285 VLOG(1) << "Not deleting directory; it's not empty " << *entry;
293 const sync_pb::EntitySpecifics& specifics = entry->Get(SERVER_SPECIFICS);
335 if (!entry->Get(SERVER_IS_DIR)) {
350 SyncerUtil::UpdateLocalDataFromServerData(trans, entry);
444 // We only mark the entry as unapplied if its version is greater than the
452 // Creates a new Entry iff no Entry exists with the given id.
456 syncable::MutableEntry entry(trans, syncable::GET_BY_ID, id);
457 if (!entry.good()) {
464 bool SyncerUtil::ServerAndLocalOrdersMatch(syncable::Entry* entry) {
466 syncable::Id local_up_to_date_predecessor = entry->Get(PREV_ID);
468 Entry local_prev(entry->trans(), GET_BY_ID, local_up_to_date_predecessor);
478 entry->ComputePrevIdFromServerPosition(entry->Get(SERVER_PARENT_ID));
483 bool SyncerUtil::ServerAndLocalEntriesMatch(syncable::Entry* entry) {
485 entry->Get(CTIME), ClientTimeToServerTime(entry->Get(SERVER_CTIME)))) {
489 if (entry->Get(IS_DEL) && entry->Get(SERVER_IS_DEL))
492 if (!(entry->Get(NON_UNIQUE_NAME) == entry->Get(SERVER_NON_UNIQUE_NAME))) {
497 if (entry->Get(PARENT_ID) != entry->Get(SERVER_PARENT_ID) ||
498 entry->Get(IS_DIR) != entry->Get(SERVER_IS_DIR) ||
499 entry->Get(IS_DEL) != entry->Get(SERVER_IS_DEL)) {
504 if (!ServerAndLocalOrdersMatch(entry)) {
510 if (entry->Get(SPECIFICS).SerializeAsString() !=
511 entry->Get(SERVER_SPECIFICS).SerializeAsString()) {
515 if (entry->Get(IS_DIR))
519 bool time_match = ClientAndServerTimeMatch(entry->Get(MTIME),
520 ClientTimeToServerTime(entry->Get(SERVER_MTIME)));
530 syncable::MutableEntry* entry) {
531 syncable::Id id = entry->Get(ID);
532 ChangeEntryIDAndUpdateChildren(trans, entry, trans->directory()->NextId());
533 entry->Put(BASE_VERSION, 0);
536 CopyServerFields(entry, &new_entry);
537 ClearServerData(entry);
539 VLOG(1) << "Splitting server information, local entry: " << *entry
540 << " server entry: " << new_entry;
543 // This function is called on an entry when we can update the user-facing data
548 syncable::MutableEntry* entry) {
549 DCHECK(!entry->Get(IS_UNSYNCED));
550 DCHECK(entry->Get(IS_UNAPPLIED_UPDATE));
552 VLOG(2) << "Updating entry : " << *entry;
554 entry->Put(SPECIFICS, entry->Get(SERVER_SPECIFICS));
555 entry->Put(IS_DIR, entry->Get(SERVER_IS_DIR));
559 if (entry->Get(SERVER_IS_DEL)) {
560 entry->Put(IS_DEL, true);
562 entry->Put(NON_UNIQUE_NAME, entry->Get(SERVER_NON_UNIQUE_NAME));
563 entry->Put(PARENT_ID, entry->Get(SERVER_PARENT_ID));
564 CHECK(entry->Put(IS_DEL, false));
566 entry->ComputePrevIdFromServerPosition(entry->Get(SERVER_PARENT_ID));
567 CHECK(entry->PutPredecessor(new_predecessor))
571 entry->Put(CTIME, entry->Get(SERVER_CTIME));
572 entry->Put(MTIME, entry->Get(SERVER_MTIME));
573 entry->Put(BASE_VERSION, entry->Get(SERVER_VERSION));
574 entry->Put(IS_DEL, entry->Get(SERVER_IS_DEL));
575 entry->Put(IS_UNAPPLIED_UPDATE, false);
580 syncable::Entry* entry) {
581 syncable::Id id = entry->Get(ID);
582 if (id == entry->Get(PARENT_ID)) {
583 CHECK(id.IsRoot()) << "Non-root item is self parenting." << *entry;
585 LOG(ERROR) << "Root item became unsynced " << *entry;
588 if (entry->IsRoot()) {
589 LOG(ERROR) << "Permanent item became unsynced " << *entry;
592 if (entry->Get(IS_DEL) && !entry->Get(ID).ServerKnows()) {
602 syncable::Entry* item,
615 Entry prev(trans, GET_BY_ID, prev_id);
630 syncable::Entry* item,
664 // Single transaction / entry we deal with.
666 MutableEntry entry(&trans, GET_BY_HANDLE, *it);
667 if (!entry.Get(IS_UNSYNCED) || !entry.Get(IS_DEL))
669 syncable::Id id = entry.Get(PARENT_ID);
673 entry.Put(IS_UNSYNCED, false);
676 Entry parent(&trans, GET_BY_ID, id);
687 syncable::Entry* target,
701 // Assumes we have an existing entry; check here for updates that break
725 // Then we've had an update for this entry before.
732 LOG(ERROR) << " Entry: " << *target;
758 LOG(ERROR) << " Entry: " << *target;
771 "version. A bug should be filed. Entry: " << *target <<
777 LOG(WARNING) << " Entry: " << *target;
787 // Assumes we have an existing entry; verify an update that seems to be
