/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
H A D | multi_ver_natural_store_commit_storage.h | 46 IKvDBCommit *GetCommit(const CommitID &commitId, int &errCode) const override; 49 int RemoveCommit(const CommitID &commitId) override; 53 int SetHeader(const CommitID &commitId) override; 54 CommitID GetHeader(int &errCode) const override; 56 bool CommitExist(const CommitID &commitId, int &errCode) const override; 62 int GetCommitTree(const std::map<DeviceID, CommitID> &latestCommits, 82 static void TransferCommitIDToKey(const CommitID &commitID, Key &key); 89 static void TransferCommitIDToValue(const CommitID &commitID, Value &value); 98 const std::map<CommitID, IKvDBCommit *> &allCommits, std::stack<CommitID> &commitStack); 102 int GetAllCommits(std::map<CommitID, IKvDBCommit *> &commits, CommitID &headerId) const; [all …]
|
H A D | multi_ver_commit.h | 37 CommitID GetCommitId() const override; 38 void SetCommitId(const CommitID &id) override; 40 CommitID GetLeftParentId() const override; 41 void SetLeftParentId(const CommitID &id) override; 43 CommitID GetRightParentId() const override; 44 void SetRightParentId(const CommitID &id) override; 62 CommitID commitID_; 63 CommitID leftParentID_; 64 CommitID rightParentID_;
|
H A D | multi_ver_natural_store_commit_storage.cpp | 252 CommitID headerId; in GetAllCommitsInTree() 415 CommitID headerCommitID; in GetHeader() 492 CommitID headerId; in GetLatestCommits() 540 const map<CommitID, IKvDBCommit *> &allCommits, const map<DeviceID, CommitID> &latestCommits, in GetLocalVersionThredForLatestCommits() argument 556 const std::map<CommitID, IKvDBCommit *> &allCommits, std::stack<CommitID> &commitStack) in AddParentsToStack() argument 584 CommitID header; in GetCommitTree() 717 CommitID commitID; in TransferValueToCommit() 718 CommitID leftParentID; in TransferValueToCommit() 719 CommitID rightParentID; in TransferValueToCommit() 770 CommitID &headerId) const in GetAllCommits() [all …]
|
H A D | multi_ver_storage_executor.h | 78 int GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDiffData &data) const; 112 int UpdateTrimedFlag(const CommitID &commit); 131 void CommitNotifiedData(const CommitID &commitId); 133 int GetParentCommitId(const CommitID &commitId, CommitID &parentId, Version &curVersion) const; 135 int AllocNewCommitId(CommitID &commitId) const; 137 …int FillAndCommitLogEntry(const Version &versionInfo, CommitID &commitId, uint64_t timestamp) cons… 140 const Version &versionInfo, const CommitID &commitId, bool isMerge) const; 143 CommitID &commitId, bool isMerge, Timestamp ×tamp) const;
|
H A D | multi_ver_commit.cpp | 41 CommitID MultiVerCommit::GetCommitId() const in GetCommitId() 46 void MultiVerCommit::SetCommitId(const CommitID &id) in SetCommitId() 52 CommitID MultiVerCommit::GetLeftParentId() const in GetLeftParentId() 57 void MultiVerCommit::SetLeftParentId(const CommitID &id) in SetLeftParentId() 63 CommitID MultiVerCommit::GetRightParentId() const in GetRightParentId() 68 void MultiVerCommit::SetRightParentId(const CommitID &id) in SetRightParentId()
|
H A D | multi_ver_natural_store_commit_notify_data.h | 28 MultiVerNaturalStoreCommitNotifyData(MultiVerNaturalStore *db, const CommitID &startCommitID, 29 const CommitID &endCommitID, Version curVersion); 49 CommitID startCommitID_; 50 CommitID endCommitID_;
|
H A D | multi_ver_storage_executor.cpp | 115 std::map<DeviceID, CommitID> latestCommits; in GetCommitTree() 157 CommitID commitId = commit.commitId; in GetCommitData() 586 int MultiVerStorageExecutor::GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDif… in GetDiffEntries() 853 CommitID commitId; in CommitTransaction() 958 CommitID commitId = commitStorage_->GetHeader(errCode); in InitCurrentReadVersion() 1123 CommitID startId; in CommitNotifiedData() 1143 int MultiVerStorageExecutor::GetParentCommitId(const CommitID &commitId, CommitID &parentId, Versio… in GetParentCommitId() 1190 CommitID header = commitStorage_->GetHeader(errCode); in FillAndCommitLogEntry() 1225 CommitID header = commitStorage_->GetHeader(errCode); in FillCommitByForeign() 1300 CommitID commitId; in CommitTransaction() [all …]
|
H A D | multi_ver_natural_store_commit_notify_data.cpp | 23 const CommitID &startCommitID, const CommitID &endCommitID, Version curVersion) in MultiVerNaturalStoreCommitNotifyData()
|
H A D | multi_ver_natural_store.h | 121 int GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDiffData &data) const;
|
H A D | multi_ver_natural_store.cpp | 835 int MultiVerNaturalStore::GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDiffDa… in GetDiffEntries() 890 CommitID headerId = commitHistory_->GetHeader(errCode); in CompareVerDataAndLog()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | ikvdb_commit.h | 28 virtual CommitID GetCommitId() const = 0; 29 virtual void SetCommitId(const CommitID &id) = 0; 30 virtual CommitID GetLeftParentId() const = 0; 31 virtual void SetLeftParentId(const CommitID &id) = 0; 32 virtual CommitID GetRightParentId() const = 0; 33 virtual void SetRightParentId(const CommitID &id) = 0;
|
H A D | ikvdb_commit_storage.h | 45 virtual IKvDBCommit *GetCommit(const CommitID &commitId, int &errCode) const = 0; 47 virtual int RemoveCommit(const CommitID &commitId) = 0; 49 virtual int SetHeader(const CommitID &commitId) = 0; 50 virtual CommitID GetHeader(int &errCode) const = 0; 51 virtual bool CommitExist(const CommitID &commitId, int &errCode) const = 0; 53 virtual int GetCommitTree(const std::map<DeviceID, CommitID> &latestCommits,
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_commit_storage_test.cpp | 87 string TransCommitIDToStr(const CommitID &inputCommitID) in TransCommitIDToStr() 101 CommitID commitID = commit->GetCommitId(); in CompareCommitWithExpectation() 104 CommitID leftCommitID = commit->GetLeftParentId(); in CompareCommitWithExpectation() 107 CommitID rightCommitID = commit->GetRightParentId(); in CompareCommitWithExpectation() 126 CommitID TransStrToCommitID(const string &commitIDStr) in TransStrToCommitID() 128 CommitID commitID; in TransStrToCommitID() 145 CommitID commitID = TransStrToCommitID(commitInfo.commitID); in InsertCommitToCommitStorage() 163 CommitID commitID = TransStrToCommitID(inputCommitID); in DeleteCommit() 189 CommitID header = TransStrToCommitID(inputHeader); in SetCommitStorageHeader() 197 CommitID header = g_commitStorage->GetHeader(errCode); in TestCommitStorageHeader() [all …]
|
H A D | distributeddb_storage_transaction_data_test.cpp | 125 static uint64_t GetCommitTimestamp(const CommitID& commitId) in GetCommitTimestamp() 132 CommitID newCommitId; in GetCommitTimestamp() 173 CommitID commitId; in GetMaxTimestamp() 1337 CommitID commitId; 1436 CommitID commitId;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | multi_ver_def.h | 26 using CommitID = std::vector<uint8_t>; variable
|