Home
last modified time | relevance | path

Searched defs:commit (Results 1 - 12 of 12) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Dmulti_ver_vacuum_executor_stub.cpp41 MultiVerCommitInfo commit; in GetVacuumAbleCommits() local
47 MultiVerCommitInfo commit; in GetVacuumAbleCommits() local
H A Ddistributeddb_storage_transaction_data_test.cpp133 IKvDBCommit *commit = nullptr; in GetCommitTimestamp() local
1488 MultiVerCommitNode commit; HWTEST_F() local
1522 MultiVerCommitNode commit; HWTEST_F() local
[all...]
H A Ddistributeddb_storage_commit_storage_test.cpp97 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 Dvirtual_multi_ver_sync_db_interface.cpp93 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 Dmulti_ver_vacuum.cpp427 const MultiVerCommitInfo &commit = commitList.front(); in DoDealCommitOfLeftOrRight() local
[all...]
H A Dmulti_ver_natural_store_commit_storage.cpp180 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 Dmulti_ver_storage_executor.cpp90 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 Dmulti_ver_natural_store.cpp601 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 Dparcel.cpp231 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 Dmulti_ver_sync_state_machine.cpp426 MultiVerCommitNode commit; in Finish() local
452 MultiVerCommitNode commit; in OneCommitSyncFinish() local
[all...]
H A Dmulti_ver_sync_task_context.cpp137 void MultiVerSyncTaskContext::SetCommit(int index, const MultiVerCommitNode &commit) in SetCommit() argument
H A Dmulti_ver_data_sync.cpp39 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...]

Completed in 12 milliseconds