| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_multi_ver_sync_db_interface.cpp | 130 MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) MergeSyncCommit() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | parcel.cpp | 289 int Parcel::WriteMultiVerCommits(const std::vector<MultiVerCommitNode> &commits) in WriteMultiVerCommits() argument
340 uint32_t Parcel::ReadMultiVerCommits(std::vector<MultiVerCommitNode> &commits) in ReadMultiVerCommits() argument
500 uint32_t Parcel::GetMultiVerCommitsLen(const std::vector<MultiVerCommitNode> &commits) in GetMultiVerCommitsLen() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 430 std::vector<MultiVerCommitNode> commits; in Finish() local
|
| H A D | multi_ver_sync_task_context.cpp | 122 void MultiVerSyncTaskContext::GetCommits(std::vector<MultiVerCommitNode> &commits) in GetCommits() argument
127 void MultiVerSyncTaskContext::SetCommits(const std::vector<MultiVerCommitNode> &commits) in SetCommits() argument
|
| H A D | multi_ver_data_sync.cpp | 308 int MultiVerDataSync::MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) in MergeSyncCommit() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 260 std::vector<MultiVerCommitNode> commits; in RequestRecvCallback() local
300 std::vector<MultiVerCommitNode> commits; in AckRecvCallback() local
465 std::vector<MultiVerCommitNode> commits; AckPacketSerialization() local
494 std::vector<MultiVerCommitNode> commits; AckPacketDeSerialization() local
582 GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, std::vector<MultiVerCommitNode> &commits) GetCommitTree() argument
660 SendAckPacket(const MultiVerSyncTaskContext *context, std::vector<MultiVerCommitNode> &commits, int ackCode, const Message *message) SendAckPacket() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_natural_store_commit_storage.cpp | 491 map<CommitID, IKvDBCommit *> commits; GetLatestCommits() local
769 GetAllCommits(map<CommitID, IKvDBCommit *> &commits, CommitID &headerId) const GetAllCommits() argument
858 RefreshCommitTree(std::list<IKvDBCommit *> &commits) RefreshCommitTree() argument
868 std::map<CommitID, IKvDBCommit *> commits; GetMaxCommitVersion() local
[all...] |
| H A D | multi_ver_storage_executor.cpp | 537 int MultiVerStorageExecutor::MergeCommits(const std::vector<MultiVerCommitNode> &commits) in MergeCommits() argument
490 MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) MergeSyncCommit() argument
[all...] |
| H A D | multi_ver_natural_store.cpp | 691 MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commits) MergeSyncCommit() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_commit_storage_test.cpp | 804 list<IKvDBCommit *> commits; in HWTEST_F() local
|