| OLD | NEW |
| (Empty) |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef SYNC_SYNCABLE_SYNCABLE_DELETE_JOURNAL_H_ | |
| 6 #define SYNC_SYNCABLE_SYNCABLE_DELETE_JOURNAL_H_ | |
| 7 | |
| 8 #include <stddef.h> | |
| 9 | |
| 10 #include <set> | |
| 11 | |
| 12 #include "base/gtest_prod_util.h" | |
| 13 #include "base/macros.h" | |
| 14 #include "base/synchronization/lock.h" | |
| 15 #include "sync/base/sync_export.h" | |
| 16 #include "sync/syncable/metahandle_set.h" | |
| 17 #include "sync/syncable/syncable-inl.h" | |
| 18 | |
| 19 namespace syncer { | |
| 20 namespace syncable { | |
| 21 | |
| 22 class BaseTransaction; | |
| 23 struct EntryKernel; | |
| 24 | |
| 25 typedef std::set<const EntryKernel*, LessField<IdField, ID> > JournalIndex; | |
| 26 | |
| 27 // DeleteJournal manages deleted entries that are not in sync directory until | |
| 28 // it's safe to drop them after the deletion is confirmed with native models. | |
| 29 // DeleteJournal is thread-safe and can be accessed on any thread. Has to hold | |
| 30 // a valid transaction object when calling methods of DeleteJournal, thus each | |
| 31 // method requires a non-null |trans| parameter. | |
| 32 class SYNC_EXPORT DeleteJournal { | |
| 33 public: | |
| 34 // Initialize |delete_journals_| using |intitial_journal|, whose content is | |
| 35 // destroyed during initialization. | |
| 36 explicit DeleteJournal(JournalIndex* initial_journal); | |
| 37 ~DeleteJournal(); | |
| 38 | |
| 39 // For testing only. | |
| 40 size_t GetDeleteJournalSize(BaseTransaction* trans) const; | |
| 41 | |
| 42 // Add/remove |entry| to/from |delete_journals_| according to its | |
| 43 // SERVER_IS_DEL field and |was_deleted|. Called on sync thread. | |
| 44 void UpdateDeleteJournalForServerDelete(BaseTransaction* trans, | |
| 45 bool was_deleted, | |
| 46 const EntryKernel& entry); | |
| 47 | |
| 48 // Return entries of specified type in |delete_journals_|. This should be | |
| 49 // called ONCE in model association. |deleted_entries| can be used to | |
| 50 // detect deleted sync data that's not persisted in native model to | |
| 51 // prevent back-from-dead problem. |deleted_entries| are only valid during | |
| 52 // lifetime of |trans|. |type| is added to |passive_delete_journal_types_| to | |
| 53 // enable periodically saving/clearing of delete journals of |type| because | |
| 54 // new journals added later are not needed until next model association. | |
| 55 // Can be called on any thread. | |
| 56 void GetDeleteJournals(BaseTransaction* trans, ModelType type, | |
| 57 EntryKernelSet* deleted_entries); | |
| 58 | |
| 59 // Purge entries of specified type in |delete_journals_| if their handles are | |
| 60 // in |to_purge|. This should be called after model association and | |
| 61 // |to_purge| should contain handles of the entries whose deletions are | |
| 62 // confirmed in native model. Can be called on any thread. | |
| 63 void PurgeDeleteJournals(BaseTransaction* trans, | |
| 64 const MetahandleSet& to_purge); | |
| 65 | |
| 66 // Move entries in |delete_journals_| whose types are in | |
| 67 // |passive_delete_journal_types_| to |journal_entries|. Move handles in | |
| 68 // |delete_journals_to_purge_| to |journals_to_purge|. Called on sync thread. | |
| 69 void TakeSnapshotAndClear(BaseTransaction* trans, | |
| 70 EntryKernelSet* journal_entries, | |
| 71 MetahandleSet* journals_to_purge); | |
| 72 | |
| 73 // Add |entries| to |delete_journals_| regardless of their SERVER_IS_DEL | |
| 74 // value. This is used to: | |
| 75 // * restore delete journals from snapshot if snapshot failed to save. | |
| 76 // * batch add entries of a data type with unrecoverable error to delete | |
| 77 // journal before purging them. | |
| 78 // Called on sync thread. | |
| 79 void AddJournalBatch(BaseTransaction* trans, const EntryKernelSet& entries); | |
| 80 | |
| 81 // Return true if delete journals of |type| are maintained. | |
| 82 static bool IsDeleteJournalEnabled(ModelType type); | |
| 83 | |
| 84 private: | |
| 85 FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, ManageDeleteJournals); | |
| 86 | |
| 87 // Contains deleted entries that may not be persisted in native models. And | |
| 88 // in case of unrecoverable error, all purged entries are moved here for | |
| 89 // bookkeeping to prevent back-from-dead entries that are deleted elsewhere | |
| 90 // when sync's down. | |
| 91 JournalIndex delete_journals_; | |
| 92 | |
| 93 // Contains meta handles of deleted entries that have been persisted or | |
| 94 // undeleted, thus can be removed from database. | |
| 95 MetahandleSet delete_journals_to_purge_; | |
| 96 | |
| 97 // Delete journals of these types can be cleared from memory after being | |
| 98 // saved to database. | |
| 99 ModelTypeSet passive_delete_journal_types_; | |
| 100 | |
| 101 DISALLOW_COPY_AND_ASSIGN(DeleteJournal); | |
| 102 }; | |
| 103 | |
| 104 } // namespace syncable | |
| 105 } // namespace syncer | |
| 106 | |
| 107 #endif // SYNC_SYNCABLE_SYNCABLE_DELETE_JOURNAL_H_ | |
| OLD | NEW |