/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | multi_ver_vacuum_executor_stub.cpp | 41 MultiVerCommitInfo commit; in GetVacuumAbleCommits() local 47 MultiVerCommitInfo commit; in GetVacuumAbleCommits() local
|
H A D | distributeddb_storage_transaction_data_test.cpp | 133 IKvDBCommit *commit = nullptr; in GetCommitTimestamp() local 1488 MultiVerCommitNode commit; HWTEST_F() local 1522 MultiVerCommitNode commit; HWTEST_F() local [all...] |
H A D | distributeddb_storage_commit_storage_test.cpp | 97 void CompareCommitWithExpectation(const IKvDBCommit *commit, const CommitInfo &commitInfo) in CompareCommitWithExpectation() argument 139 IKvDBCommit *commit = g_commitStorage->AllocCommit(result); in InsertCommitToCommitStorage() local 172 IKvDBCommit *commit = g_commitStorage->GetCommit(inputCommitID, result); TestCommit() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | virtual_multi_ver_sync_db_interface.cpp | 93 int VirtualMultiVerSyncDBInterface::GetCommitData(const MultiVerCommitNode &commit, in GetCommitData() argument 124 int VirtualMultiVerSyncDBInterface::PutCommitData(const MultiVerCommitNode &commit, in PutCommitData() argument 130 int VirtualMultiVerSyncDBInterface::MergeSyncCommit(const MultiVerCommitNode &commit, in MergeSyncCommit() argument 136 int VirtualMultiVerSyncDBInterface::TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, in TransferSyncCommitDevInfo() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
H A D | multi_ver_vacuum.cpp | 427 const MultiVerCommitInfo &commit = commitList.front(); in DoDealCommitOfLeftOrRight() local [all...] |
H A D | multi_ver_natural_store_commit_storage.cpp | 180 auto commit = new (std::nothrow) MultiVerCommit(); in AllocCommit() local 209 IKvDBCommit *commit = AllocCommit(errCode); GetCommit() local 353 IKvDBCommit *commit = GetCommit(commitId, errCode); RemoveCommit() local 441 IKvDBCommit *commit = GetCommit(commitId, errCode); CommitExist() local 555 AddParentsToStack(const IKvDBCommit *commit, const std::map<CommitID, IKvDBCommit *> &allCommits, std::stack<CommitID> &commitStack) AddParentsToStack() argument 657 TransferCommitToValue(const IKvDBCommit &commit, Value &value) TransferCommitToValue() argument 705 TransferValueToCommit(const Value &value, IKvDBCommit &commit) TransferValueToCommit() argument 798 IKvDBCommit *commit = new (std::nothrow) MultiVerCommit(); GetAllCommits() local [all...] |
H A D | multi_ver_storage_executor.cpp | 90 MultiVerCommitNode commit = { in GetDeviceLatestCommit() local 132 MultiVerCommitNode commit = { in GetCommitTree() local 150 int MultiVerStorageExecutor::GetCommitData(const MultiVerCommitNode &commit, in GetCommitData() argument 196 IsCommitExisted(const MultiVerCommitNode &commit, int &errCode) const IsCommitExisted() argument 391 ReInitTransactionVersion(const MultiVerCommitNode &commit) ReInitTransactionVersion() argument 447 PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries, const std::string &deviceName) PutCommitData() argument 490 MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) MergeSyncCommit() argument 513 MergeOneCommit(const MultiVerCommitNode &commit) MergeOneCommit() argument 966 IKvDBCommit *commit = commitStorage_->GetCommit(commitId, errCode); InitCurrentReadVersion() local 1102 auto commit = commitStorage_->GetCommit(commitItem.commitId, errCode); GetResolvedConflictEntries() local 1149 IKvDBCommit *commit = commitStorage_->GetCommit(commitId, errCode); GetParentCommitId() local 1178 IKvDBCommit *commit = commitStorage_->AllocCommit(errCode); FillAndCommitLogEntry() local 1216 FillCommitByForeign(IKvDBCommit *commit, const MultiVerCommitNode &multiVerCommit, const Version &versionInfo, const CommitID &commitId, bool isMerge) const FillCommitByForeign() argument 1260 IKvDBCommit *commit = commitStorage_->AllocCommit(errCode); FillAndCommitLogEntry() local 1497 UpdateTrimedFlag(const CommitID &commit) UpdateTrimedFlag() argument [all...] |
H A D | multi_ver_natural_store.cpp | 601 int MultiVerNaturalStore::GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) const in GetCommitData() argument 677 int MultiVerNaturalStore::PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries, in PutCommitData() argument 691 int MultiVerNaturalStore::MergeSyncCommit(const MultiVerCommitNode &commit, in MergeSyncCommit() argument 715 int MultiVerNaturalStore::TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, in TransferSyncCommitDevInfo() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | parcel.cpp | 231 int Parcel::WriteMultiVerCommit(const MultiVerCommitNode &commit) in WriteMultiVerCommit() argument 271 uint32_t Parcel::ReadMultiVerCommit(MultiVerCommitNode &commit) in ReadMultiVerCommit() argument 354 MultiVerCommitNode commit; ReadMultiVerCommits() local 485 GetMultiVerCommitLen(const MultiVerCommitNode &commit) GetMultiVerCommitLen() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
H A D | multi_ver_sync_state_machine.cpp | 426 MultiVerCommitNode commit; in Finish() local 452 MultiVerCommitNode commit; in OneCommitSyncFinish() local [all...] |
H A D | multi_ver_sync_task_context.cpp | 137 void MultiVerSyncTaskContext::SetCommit(int index, const MultiVerCommitNode &commit) in SetCommit() argument
|
H A D | multi_ver_data_sync.cpp | 39 void MultiVerRequestPacket::SetCommit(MultiVerCommitNode &commit) in SetCommit() argument 194 MultiVerCommitNode commit; in SyncStart() local 227 MultiVerCommitNode commit; in RequestRecvCallback() local 302 PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries, const std::string &deviceName) PutCommitData() argument 308 MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) MergeSyncCommit() argument 383 MultiVerCommitNode commit; RequestPacketSerialization() local 409 MultiVerCommitNode commit; RequestPacketDeSerialization() local 540 GetValidCommit(MultiVerSyncTaskContext *context, MultiVerCommitNode &commit) GetValidCommit() argument 574 IsCommitExisted(const MultiVerCommitNode &commit) IsCommitExisted() argument 589 SendRequestPacket(const MultiVerSyncTaskContext *context, MultiVerCommitNode &commit) SendRequestPacket() argument 683 GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) GetCommitData() argument [all...] |