Index: sync/syncable/directory.h |
diff --git a/sync/syncable/directory.h b/sync/syncable/directory.h |
deleted file mode 100644 |
index bdbfe95c6fa3f2b6504f5637ca9721bf0581b19b..0000000000000000000000000000000000000000 |
--- a/sync/syncable/directory.h |
+++ /dev/null |
@@ -1,662 +0,0 @@ |
-// Copyright 2013 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#ifndef SYNC_SYNCABLE_DIRECTORY_H_ |
-#define SYNC_SYNCABLE_DIRECTORY_H_ |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include <deque> |
-#include <set> |
-#include <string> |
-#include <unordered_map> |
-#include <vector> |
- |
-#include "base/callback.h" |
-#include "base/containers/hash_tables.h" |
-#include "base/files/file_util.h" |
-#include "base/gtest_prod_util.h" |
-#include "base/macros.h" |
-#include "base/values.h" |
-#include "sync/api/attachments/attachment_id.h" |
-#include "sync/base/sync_export.h" |
-#include "sync/internal_api/public/util/weak_handle.h" |
-#include "sync/syncable/dir_open_result.h" |
-#include "sync/syncable/entry.h" |
-#include "sync/syncable/entry_kernel.h" |
-#include "sync/syncable/metahandle_set.h" |
-#include "sync/syncable/parent_child_index.h" |
-#include "sync/syncable/syncable_delete_journal.h" |
- |
-namespace syncer { |
- |
-class Cryptographer; |
-class TestUserShare; |
-class UnrecoverableErrorHandler; |
- |
-namespace syncable { |
- |
-class BaseTransaction; |
-class BaseWriteTransaction; |
-class DirectoryChangeDelegate; |
-class DirectoryBackingStore; |
-class NigoriHandler; |
-class ScopedKernelLock; |
-class TransactionObserver; |
-class WriteTransaction; |
- |
-enum InvariantCheckLevel { |
- OFF = 0, // No checking. |
- VERIFY_CHANGES = 1, // Checks only mutated entries. Does not check |
- // hierarchy. |
- FULL_DB_VERIFICATION = 2 // Check every entry. This can be expensive. |
-}; |
- |
-// Directory stores and manages EntryKernels. |
-// |
-// This class is tightly coupled to several other classes via Directory::Kernel. |
-// Although Directory's kernel_ is exposed via public accessor it should be |
-// treated as pseudo-private. |
-class SYNC_EXPORT Directory { |
- public: |
- typedef std::vector<int64_t> Metahandles; |
- |
- typedef std::unordered_map<int64_t, EntryKernel*> MetahandlesMap; |
- typedef std::unordered_map<std::string, EntryKernel*> IdsMap; |
- typedef std::unordered_map<std::string, EntryKernel*> TagsMap; |
- typedef std::string AttachmentIdUniqueId; |
- typedef std::unordered_map<AttachmentIdUniqueId, MetahandleSet> |
- IndexByAttachmentId; |
- |
- static const base::FilePath::CharType kSyncDatabaseFilename[]; |
- |
- // The dirty/clean state of kernel fields backed by the share_info table. |
- // This is public so it can be used in SaveChangesSnapshot for persistence. |
- enum KernelShareInfoStatus { |
- KERNEL_SHARE_INFO_INVALID, |
- KERNEL_SHARE_INFO_VALID, |
- KERNEL_SHARE_INFO_DIRTY |
- }; |
- |
- // Various data that the Directory::Kernel we are backing (persisting data |
- // for) needs saved across runs of the application. |
- struct SYNC_EXPORT PersistedKernelInfo { |
- PersistedKernelInfo(); |
- ~PersistedKernelInfo(); |
- |
- // Set the |download_progress| entry for the given model to a |
- // "first sync" start point. When such a value is sent to the server, |
- // a full download of all objects of the model will be initiated. |
- void ResetDownloadProgress(ModelType model_type); |
- |
- // Whether a valid progress marker exists for |model_type|. |
- bool HasEmptyDownloadProgress(ModelType model_type); |
- |
- // Last sync timestamp fetched from the server. |
- sync_pb::DataTypeProgressMarker download_progress[MODEL_TYPE_COUNT]; |
- // Sync-side transaction version per data type. Monotonically incremented |
- // when updating native model. A copy is also saved in native model. |
- // Later out-of-sync models can be detected and fixed by comparing |
- // transaction versions of sync model and native model. |
- // TODO(hatiaol): implement detection and fixing of out-of-sync models. |
- // Bug 154858. |
- int64_t transaction_version[MODEL_TYPE_COUNT]; |
- // The store birthday we were given by the server. Contents are opaque to |
- // the client. |
- std::string store_birthday; |
- // The serialized bag of chips we were given by the server. Contents are |
- // opaque to the client. This is the serialization of a message of type |
- // ChipBag defined in sync.proto. It can contains NULL characters. |
- std::string bag_of_chips; |
- // The per-datatype context. |
- sync_pb::DataTypeContext datatype_context[MODEL_TYPE_COUNT]; |
- }; |
- |
- // What the Directory needs on initialization to create itself and its Kernel. |
- // Filled by DirectoryBackingStore::Load. |
- struct KernelLoadInfo { |
- PersistedKernelInfo kernel_info; |
- std::string cache_guid; // Created on first initialization, never changes. |
- int64_t max_metahandle; // Computed (using sql MAX aggregate) on init. |
- KernelLoadInfo() : max_metahandle(0) { |
- } |
- }; |
- |
- // When the Directory is told to SaveChanges, a SaveChangesSnapshot is |
- // constructed and forms a consistent snapshot of what needs to be sent to |
- // the backing store. |
- struct SYNC_EXPORT SaveChangesSnapshot { |
- SaveChangesSnapshot(); |
- ~SaveChangesSnapshot(); |
- |
- // Returns true if this snapshot has any unsaved metahandle changes. |
- bool HasUnsavedMetahandleChanges() const; |
- |
- KernelShareInfoStatus kernel_info_status; |
- PersistedKernelInfo kernel_info; |
- EntryKernelSet dirty_metas; |
- MetahandleSet metahandles_to_purge; |
- EntryKernelSet delete_journals; |
- MetahandleSet delete_journals_to_purge; |
- }; |
- |
- struct Kernel { |
- // |delegate| must not be NULL. |transaction_observer| must be |
- // initialized. |
- Kernel(const std::string& name, const KernelLoadInfo& info, |
- DirectoryChangeDelegate* delegate, |
- const WeakHandle<TransactionObserver>& transaction_observer); |
- |
- ~Kernel(); |
- |
- // Implements ReadTransaction / WriteTransaction using a simple lock. |
- base::Lock transaction_mutex; |
- |
- // Protected by transaction_mutex. Used by WriteTransactions. |
- int64_t next_write_transaction_id; |
- |
- // The name of this directory. |
- std::string const name; |
- |
- // Protects all members below. |
- // The mutex effectively protects all the indices, but not the |
- // entries themselves. So once a pointer to an entry is pulled |
- // from the index, the mutex can be unlocked and entry read or written. |
- // |
- // Never hold the mutex and do anything with the database or any |
- // other buffered IO. Violating this rule will result in deadlock. |
- mutable base::Lock mutex; |
- |
- // Entries indexed by metahandle. This container is considered to be the |
- // owner of all EntryKernels, which may be referened by the other |
- // containers. If you remove an EntryKernel from this map, you probably |
- // want to remove it from all other containers and delete it, too. |
- MetahandlesMap metahandles_map; |
- |
- // Entries indexed by id |
- IdsMap ids_map; |
- |
- // Entries indexed by server tag. |
- // This map does not include any entries with non-existent server tags. |
- TagsMap server_tags_map; |
- |
- // Entries indexed by client tag. |
- // This map does not include any entries with non-existent client tags. |
- // IS_DEL items are included. |
- TagsMap client_tags_map; |
- |
- // Contains non-deleted items, indexed according to parent and position |
- // within parent. Protected by the ScopedKernelLock. |
- ParentChildIndex parent_child_index; |
- |
- // This index keeps track of which metahandles refer to a given attachment. |
- // Think of it as the inverse of EntryKernel's AttachmentMetadata Records. |
- // |
- // Because entries can be undeleted (e.g. PutIsDel(false)), entries should |
- // not removed from the index until they are actually deleted from memory. |
- // |
- // All access should go through IsAttachmentLinked, |
- // RemoveFromAttachmentIndex, AddToAttachmentIndex, and |
- // UpdateAttachmentIndex methods to avoid iterator invalidation errors. |
- IndexByAttachmentId index_by_attachment_id; |
- |
- // 3 in-memory indices on bits used extremely frequently by the syncer. |
- // |unapplied_update_metahandles| is keyed by the server model type. |
- MetahandleSet unapplied_update_metahandles[MODEL_TYPE_COUNT]; |
- MetahandleSet unsynced_metahandles; |
- // Contains metahandles that are most likely dirty (though not |
- // necessarily). Dirtyness is confirmed in TakeSnapshotForSaveChanges(). |
- MetahandleSet dirty_metahandles; |
- |
- // When a purge takes place, we remove items from all our indices and stash |
- // them in here so that SaveChanges can persist their permanent deletion. |
- MetahandleSet metahandles_to_purge; |
- |
- KernelShareInfoStatus info_status; |
- |
- // These 3 members are backed in the share_info table, and |
- // their state is marked by the flag above. |
- |
- // A structure containing the Directory state that is written back into the |
- // database on SaveChanges. |
- PersistedKernelInfo persisted_info; |
- |
- // A unique identifier for this account's cache db, used to generate |
- // unique server IDs. No need to lock, only written at init time. |
- const std::string cache_guid; |
- |
- // It doesn't make sense for two threads to run SaveChanges at the same |
- // time; this mutex protects that activity. |
- base::Lock save_changes_mutex; |
- |
- // The next metahandle is protected by kernel mutex. |
- int64_t next_metahandle; |
- |
- // The delegate for directory change events. Must not be NULL. |
- DirectoryChangeDelegate* const delegate; |
- |
- // The transaction observer. |
- const WeakHandle<TransactionObserver> transaction_observer; |
- }; |
- |
- // Does not take ownership of |encryptor|. |
- // |report_unrecoverable_error_function| may be NULL. |
- // Takes ownership of |store|. |
- Directory( |
- DirectoryBackingStore* store, |
- const WeakHandle<UnrecoverableErrorHandler>& unrecoverable_error_handler, |
- const base::Closure& report_unrecoverable_error_function, |
- NigoriHandler* nigori_handler, |
- Cryptographer* cryptographer); |
- virtual ~Directory(); |
- |
- // Does not take ownership of |delegate|, which must not be NULL. |
- // Starts sending events to |delegate| if the returned result is |
- // OPENED. Note that events to |delegate| may be sent from *any* |
- // thread. |transaction_observer| must be initialized. |
- DirOpenResult Open(const std::string& name, |
- DirectoryChangeDelegate* delegate, |
- const WeakHandle<TransactionObserver>& |
- transaction_observer); |
- |
- int64_t NextMetahandle(); |
- // Generates next client ID based on a randomly generated GUID. |
- syncable::Id NextId(); |
- |
- bool good() const { return NULL != kernel_; } |
- |
- // The download progress is an opaque token provided by the sync server |
- // to indicate the continuation state of the next GetUpdates operation. |
- void GetDownloadProgress( |
- ModelType type, |
- sync_pb::DataTypeProgressMarker* value_out) const; |
- void GetDownloadProgressAsString( |
- ModelType type, |
- std::string* value_out) const; |
- void SetDownloadProgress( |
- ModelType type, |
- const sync_pb::DataTypeProgressMarker& value); |
- bool HasEmptyDownloadProgress(ModelType type) const; |
- |
- // Gets the total number of entries in the directory. |
- size_t GetEntriesCount() const; |
- |
- // Gets/Increments transaction version of a model type. Must be called when |
- // holding kernel mutex. |
- int64_t GetTransactionVersion(ModelType type) const; |
- void IncrementTransactionVersion(ModelType type); |
- |
- // Getter/setters for the per datatype context. |
- void GetDataTypeContext(BaseTransaction* trans, |
- ModelType type, |
- sync_pb::DataTypeContext* context) const; |
- void SetDataTypeContext(BaseWriteTransaction* trans, |
- ModelType type, |
- const sync_pb::DataTypeContext& context); |
- |
- // Returns types for which the initial sync has ended. |
- ModelTypeSet InitialSyncEndedTypes(); |
- |
- // Returns true if the initial sync for |type| has completed. |
- bool InitialSyncEndedForType(ModelType type); |
- bool InitialSyncEndedForType(BaseTransaction* trans, ModelType type); |
- |
- // Marks the |type| as having its intial sync complete. |
- // This applies only to types with implicitly created root folders. |
- void MarkInitialSyncEndedForType(BaseWriteTransaction* trans, ModelType type); |
- |
- // (Account) Store birthday is opaque to the client, so we keep it in the |
- // format it is in the proto buffer in case we switch to a binary birthday |
- // later. |
- std::string store_birthday() const; |
- void set_store_birthday(const std::string& store_birthday); |
- |
- // (Account) Bag of chip is an opaque state used by the server to track the |
- // client. |
- std::string bag_of_chips() const; |
- void set_bag_of_chips(const std::string& bag_of_chips); |
- |
- // Unique to each account / client pair. |
- std::string cache_guid() const; |
- |
- // Returns a pointer to our Nigori node handler. |
- NigoriHandler* GetNigoriHandler(); |
- |
- // Returns a pointer to our cryptographer. Does not transfer ownership. |
- // Not thread safe, so should only be accessed while holding a transaction. |
- Cryptographer* GetCryptographer(const BaseTransaction* trans); |
- |
- // Called to immediately report an unrecoverable error (but don't |
- // propagate it up). |
- void ReportUnrecoverableError(); |
- |
- // Called to set the unrecoverable error on the directory and to propagate |
- // the error to upper layers. |
- void OnUnrecoverableError(const BaseTransaction* trans, |
- const tracked_objects::Location& location, |
- const std::string & message); |
- |
- DeleteJournal* delete_journal(); |
- |
- // Returns the child meta handles (even those for deleted/unlinked |
- // nodes) for given parent id. Clears |result| if there are no |
- // children. |
- bool GetChildHandlesById(BaseTransaction*, const Id& parent_id, |
- Metahandles* result); |
- |
- // Counts all items under the given node, including the node itself. |
- int GetTotalNodeCount(BaseTransaction*, EntryKernel* kernel_) const; |
- |
- // Returns this item's position within its parent folder. |
- // The left-most item is 0, second left-most is 1, etc. |
- int GetPositionIndex(BaseTransaction*, EntryKernel* kernel_) const; |
- |
- // Returns true iff |id| has children. |
- bool HasChildren(BaseTransaction* trans, const Id& id); |
- |
- // Find the first child in the positional ordering under a parent, |
- // and fill in |*first_child_id| with its id. Fills in a root Id if |
- // parent has no children. Returns true if the first child was |
- // successfully found, or false if an error was encountered. |
- Id GetFirstChildId(BaseTransaction* trans, const EntryKernel* parent); |
- |
- // These functions allow one to fetch the next or previous item under |
- // the same folder. Returns the "root" ID if there is no predecessor |
- // or successor. |
- // |
- // TODO(rlarocque): These functions are used mainly for tree traversal. We |
- // should replace these with an iterator API. See crbug.com/178275. |
- syncable::Id GetPredecessorId(EntryKernel* e); |
- syncable::Id GetSuccessorId(EntryKernel* e); |
- |
- // Places |e| as a successor to |predecessor|. If |predecessor| is NULL, |
- // |e| will be placed as the left-most item in its folder. |
- // |
- // Both |e| and |predecessor| must be valid entries under the same parent. |
- // |
- // TODO(rlarocque): This function includes limited support for placing items |
- // with valid positions (ie. Bookmarks) as siblings of items that have no set |
- // ordering (ie. Autofill items). This support is required only for tests, |
- // and should be removed. See crbug.com/178282. |
- void PutPredecessor(EntryKernel* e, EntryKernel* predecessor); |
- |
- // SaveChanges works by taking a consistent snapshot of the current Directory |
- // state and indices (by deep copy) under a ReadTransaction, passing this |
- // snapshot to the backing store under no transaction, and finally cleaning |
- // up by either purging entries no longer needed (this part done under a |
- // WriteTransaction) or rolling back the dirty bits. It also uses |
- // internal locking to enforce SaveChanges operations are mutually exclusive. |
- // |
- // WARNING: THIS METHOD PERFORMS SYNCHRONOUS I/O VIA SQLITE. |
- bool SaveChanges(); |
- |
- // Returns the number of entities with the unsynced bit set. |
- int64_t unsynced_entity_count() const; |
- |
- // Get GetUnsyncedMetaHandles should only be called after SaveChanges and |
- // before any new entries have been created. The intention is that the |
- // syncer should call it from its PerformSyncQueries member. |
- void GetUnsyncedMetaHandles(BaseTransaction* trans, |
- Metahandles* result); |
- |
- // Returns whether or not this |type| has unapplied updates. |
- bool TypeHasUnappliedUpdates(ModelType type); |
- |
- // Get all the metahandles for unapplied updates for a given set of |
- // server types. |
- void GetUnappliedUpdateMetaHandles(BaseTransaction* trans, |
- FullModelTypeSet server_types, |
- std::vector<int64_t>* result); |
- |
- // Get all the metahandles of entries of |type|. |
- void GetMetaHandlesOfType(BaseTransaction* trans, |
- ModelType type, |
- Metahandles* result); |
- |
- // Get metahandle counts for various criteria to show on the |
- // about:sync page. The information is computed on the fly |
- // each time. If this results in a significant performance hit, |
- // additional data structures can be added to cache results. |
- void CollectMetaHandleCounts(std::vector<int>* num_entries_by_type, |
- std::vector<int>* num_to_delete_entries_by_type); |
- |
- // Returns a ListValue serialization of all nodes for the given type. |
- std::unique_ptr<base::ListValue> GetNodeDetailsForType(BaseTransaction* trans, |
- ModelType type); |
- |
- // Sets the level of invariant checking performed after transactions. |
- void SetInvariantCheckLevel(InvariantCheckLevel check_level); |
- |
- // Checks tree metadata consistency following a transaction. It is intended |
- // to provide a reasonable tradeoff between performance and comprehensiveness |
- // and may be used in release code. |
- bool CheckInvariantsOnTransactionClose( |
- syncable::BaseTransaction* trans, |
- const MetahandleSet& modified_handles); |
- |
- // Forces a full check of the directory. This operation may be slow and |
- // should not be invoked outside of tests. |
- bool FullyCheckTreeInvariants(BaseTransaction *trans); |
- |
- // Purges data associated with any entries whose ModelType or ServerModelType |
- // is found in |disabled_types|, from sync directory _both_ in memory and on |
- // disk. Only valid, "real" model types are allowed in |disabled_types| (see |
- // model_type.h for definitions). |
- // 1. Data associated with |types_to_journal| is saved in the delete journal |
- // to help prevent back-from-dead problem due to offline delete in the next |
- // sync session. |types_to_journal| must be a subset of |disabled_types|. |
- // 2. Data associated with |types_to_unapply| is reset to an "unapplied" |
- // state, wherein all local data is deleted and IS_UNAPPLIED is set to true. |
- // This is useful when there's no benefit in discarding the currently |
- // downloaded state, such as when there are cryptographer errors. |
- // |types_to_unapply| must be a subset of |disabled_types|. |
- // 3. All other data is purged entirely. |
- // Note: "Purge" is just meant to distinguish from "deleting" entries, which |
- // means something different in the syncable namespace. |
- // WARNING! This can be real slow, as it iterates over all entries. |
- // WARNING! Performs synchronous I/O. |
- // Returns: true on success, false if an error was encountered. |
- virtual bool PurgeEntriesWithTypeIn(ModelTypeSet disabled_types, |
- ModelTypeSet types_to_journal, |
- ModelTypeSet types_to_unapply); |
- |
- // Resets the base_versions and server_versions of all synced entities |
- // associated with |type| to 1. |
- // WARNING! This can be slow, as it iterates over all entries for a type. |
- bool ResetVersionsForType(BaseWriteTransaction* trans, ModelType type); |
- |
- // Returns true iff the attachment identified by |attachment_id_proto| is |
- // linked to an entry. |
- // |
- // An attachment linked to a deleted entry is still considered linked if the |
- // entry hasn't yet been purged. |
- bool IsAttachmentLinked( |
- const sync_pb::AttachmentIdProto& attachment_id_proto) const; |
- |
- // Given attachment id return metahandles to all entries that reference this |
- // attachment. |
- void GetMetahandlesByAttachmentId( |
- BaseTransaction* trans, |
- const sync_pb::AttachmentIdProto& attachment_id_proto, |
- Metahandles* result); |
- |
- // Change entry to not dirty. Used in special case when we don't want to |
- // persist modified entry on disk. e.g. SyncBackupManager uses this to |
- // preserve sync preferences in DB on disk. |
- void UnmarkDirtyEntry(WriteTransaction* trans, Entry* entry); |
- |
- // Clears |ids| and fills it with the ids of attachments that need to be |
- // uploaded to the sync server. |
- void GetAttachmentIdsToUpload(BaseTransaction* trans, |
- ModelType type, |
- AttachmentIdList* ids); |
- |
- // For new entry creation only. |
- bool InsertEntry(BaseWriteTransaction* trans, EntryKernel* entry); |
- |
- // Update the attachment index for |metahandle| removing it from the index |
- // under |old_metadata| entries and add it under |new_metadata| entries. |
- void UpdateAttachmentIndex(const int64_t metahandle, |
- const sync_pb::AttachmentMetadata& old_metadata, |
- const sync_pb::AttachmentMetadata& new_metadata); |
- |
- virtual EntryKernel* GetEntryById(const Id& id); |
- virtual EntryKernel* GetEntryByClientTag(const std::string& tag); |
- EntryKernel* GetEntryByServerTag(const std::string& tag); |
- |
- virtual EntryKernel* GetEntryByHandle(int64_t handle); |
- |
- bool ReindexId(BaseWriteTransaction* trans, EntryKernel* const entry, |
- const Id& new_id); |
- |
- bool ReindexParentId(BaseWriteTransaction* trans, EntryKernel* const entry, |
- const Id& new_parent_id); |
- |
- // Accessors for the underlying Kernel. Although these are public methods, the |
- // number of classes that call these should be limited. |
- Kernel* kernel(); |
- const Kernel* kernel() const; |
- |
- private: |
- friend class SyncableDirectoryTest; |
- friend class syncer::TestUserShare; |
- FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, ManageDeleteJournals); |
- FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, |
- TakeSnapshotGetsAllDirtyHandlesTest); |
- FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, |
- TakeSnapshotGetsOnlyDirtyHandlesTest); |
- FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, |
- TakeSnapshotGetsMetahandlesToPurge); |
- FRIEND_TEST_ALL_PREFIXES(SyncableDirectoryTest, CatastrophicError); |
- |
- // You'll notice that some of the methods below are private overloads of the |
- // public ones declared above. The general pattern is that the public overload |
- // constructs a ScopedKernelLock before calling the corresponding private |
- // overload with the held ScopedKernelLock. |
- |
- virtual EntryKernel* GetEntryByHandle(const ScopedKernelLock& lock, |
- int64_t metahandle); |
- |
- virtual EntryKernel* GetEntryById(const ScopedKernelLock& lock, const Id& id); |
- |
- bool InsertEntry(const ScopedKernelLock& lock, |
- BaseWriteTransaction* trans, |
- EntryKernel* entry); |
- |
- // Remove each of |metahandle|'s attachment ids from index_by_attachment_id. |
- void RemoveFromAttachmentIndex( |
- const ScopedKernelLock& lock, |
- const int64_t metahandle, |
- const sync_pb::AttachmentMetadata& attachment_metadata); |
- |
- // Add each of |metahandle|'s attachment ids to the index_by_attachment_id. |
- void AddToAttachmentIndex( |
- const ScopedKernelLock& lock, |
- const int64_t metahandle, |
- const sync_pb::AttachmentMetadata& attachment_metadata); |
- |
- void ClearDirtyMetahandles(const ScopedKernelLock& lock); |
- |
- DirOpenResult OpenImpl( |
- const std::string& name, |
- DirectoryChangeDelegate* delegate, |
- const WeakHandle<TransactionObserver>& transaction_observer); |
- |
- // A helper that implements the logic of checking tree invariants. |
- bool CheckTreeInvariants(syncable::BaseTransaction* trans, |
- const MetahandleSet& handles); |
- |
- // Helper to prime metahandles_map, ids_map, parent_child_index, |
- // unsynced_metahandles, unapplied_update_metahandles, server_tags_map and |
- // client_tags_map from metahandles_index. The input |handles_map| will be |
- // cleared during the initialization process. |
- void InitializeIndices(MetahandlesMap* handles_map); |
- |
- // Constructs a consistent snapshot of the current Directory state and |
- // indices (by deep copy) under a ReadTransaction for use in |snapshot|. |
- // See SaveChanges() for more information. |
- void TakeSnapshotForSaveChanges(SaveChangesSnapshot* snapshot); |
- |
- // Purges from memory any unused, safe to remove entries that were |
- // successfully deleted on disk as a result of the SaveChanges that processed |
- // |snapshot|. See SaveChanges() for more information. |
- bool VacuumAfterSaveChanges(const SaveChangesSnapshot& snapshot); |
- |
- // Rolls back dirty bits in the event that the SaveChanges that |
- // processed |snapshot| failed, for example, due to no disk space. |
- void HandleSaveChangesFailure(const SaveChangesSnapshot& snapshot); |
- |
- // Used by CheckTreeInvariants. |
- void GetAllMetaHandles(BaseTransaction* trans, MetahandleSet* result); |
- |
- // Used by VacuumAfterSaveChanges. |
- bool SafeToPurgeFromMemory(WriteTransaction* trans, |
- const EntryKernel* const entry) const; |
- // A helper used by GetTotalNodeCount. |
- void GetChildSetForKernel( |
- BaseTransaction*, |
- EntryKernel* kernel_, |
- std::deque<const OrderedChildSet*>* child_sets) const; |
- |
- // Append the handles of the children of |parent_id| to |result|. |
- void AppendChildHandles(const ScopedKernelLock& lock, |
- const Id& parent_id, |
- Directory::Metahandles* result); |
- |
- // Helper methods used by PurgeDisabledTypes. |
- void UnapplyEntry(EntryKernel* entry); |
- void DeleteEntry(const ScopedKernelLock& lock, |
- bool save_to_journal, |
- EntryKernel* entry, |
- EntryKernelSet* entries_to_journal); |
- |
- // A private version of the public GetMetaHandlesOfType for when you already |
- // have a ScopedKernelLock. |
- void GetMetaHandlesOfType(const ScopedKernelLock& lock, |
- BaseTransaction* trans, |
- ModelType type, |
- std::vector<int64_t>* result); |
- |
- // Invoked by DirectoryBackingStore when a catastrophic database error is |
- // detected. |
- void OnCatastrophicError(); |
- |
- // Stops sending events to the delegate and the transaction |
- // observer. |
- void Close(); |
- |
- // Returns true if the directory had encountered an unrecoverable error. |
- // Note: Any function in |Directory| that can be called without holding a |
- // transaction need to check if the Directory already has an unrecoverable |
- // error on it. |
- bool unrecoverable_error_set(const BaseTransaction* trans) const; |
- |
- Kernel* kernel_; |
- |
- std::unique_ptr<DirectoryBackingStore> store_; |
- |
- const WeakHandle<UnrecoverableErrorHandler> unrecoverable_error_handler_; |
- base::Closure report_unrecoverable_error_function_; |
- bool unrecoverable_error_set_; |
- |
- // Not owned. |
- NigoriHandler* const nigori_handler_; |
- Cryptographer* const cryptographer_; |
- |
- InvariantCheckLevel invariant_check_level_; |
- |
- // Maintain deleted entries not in |kernel_| until it's verified that they |
- // are deleted in native models as well. |
- std::unique_ptr<DeleteJournal> delete_journal_; |
- |
- base::WeakPtrFactory<Directory> weak_ptr_factory_; |
- |
- DISALLOW_COPY_AND_ASSIGN(Directory); |
-}; |
- |
-} // namespace syncable |
-} // namespace syncer |
- |
-#endif // SYNC_SYNCABLE_DIRECTORY_H_ |