Home
last modified time | relevance | path

Searched refs:MultiVerCommitNode (Results 1 – 24 of 24) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_storage_executor.h58 int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const;
60 int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap,
61 std::vector<MultiVerCommitNode> &commits) const;
63 bool IsCommitExisted(const MultiVerCommitNode &commit, int &errCode) const;
76 …int MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commi…
93 int GetAllCommitsInTree(std::list<MultiVerCommitNode> &commits) const;
121 int CommitTransaction(const MultiVerCommitNode &multiVerCommit, bool isMerge);
139 int FillCommitByForeign(IKvDBCommit *commit, const MultiVerCommitNode &multiVerCommit,
145 int MergeOneCommit(const MultiVerCommitNode &commit);
147 int MergeCommits(const std::vector<MultiVerCommitNode> &commits);
[all …]
H A Dmulti_ver_natural_store.h85 bool IsCommitExisted(const MultiVerCommitNode &commit) const override;
87 int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &) const override;
89 int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &,
90 std::vector<MultiVerCommitNode> &) const override;
92 …int GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) const…
104 … int PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries,
107 …int MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commi…
113 …int TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, bool isSyncedI…
H A Dmulti_ver_storage_executor.cpp89 MultiVerCommitNode::LOCAL_FLAG : MultiVerCommitNode::NON_LOCAL_FLAG); in GetDeviceLatestCommit()
90 MultiVerCommitNode commit = { in GetDeviceLatestCommit()
109 std::vector<MultiVerCommitNode> &commits) const in GetCommitTree()
131 MultiVerCommitNode::LOCAL_FLAG : MultiVerCommitNode::NON_LOCAL_FLAG); in GetCommitTree()
132 MultiVerCommitNode commit = { in GetCommitTree()
150 int MultiVerStorageExecutor::GetCommitData(const MultiVerCommitNode &commit, in GetCommitData()
447 int MultiVerStorageExecutor::PutCommitData(const MultiVerCommitNode &commit, in PutCommitData()
490 int MultiVerStorageExecutor::MergeSyncCommit(const MultiVerCommitNode &commit, in MergeSyncCommit()
491 const std::vector<MultiVerCommitNode> &commits) in MergeSyncCommit()
513 int MultiVerStorageExecutor::MergeOneCommit(const MultiVerCommitNode &commit) in MergeOneCommit()
[all …]
H A Dmulti_ver_natural_store.cpp561 bool MultiVerNaturalStore::IsCommitExisted(const MultiVerCommitNode &commit) const in IsCommitExisted()
574 int MultiVerNaturalStore::GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMa… in GetDeviceLatestCommit()
587 int MultiVerNaturalStore::GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, in GetCommitTree()
588 std::vector<MultiVerCommitNode> &commits) const in GetCommitTree()
601 int MultiVerNaturalStore::GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEnt… in GetCommitData()
677 int MultiVerNaturalStore::PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVe… in PutCommitData()
691 int MultiVerNaturalStore::MergeSyncCommit(const MultiVerCommitNode &commit, in MergeSyncCommit()
692 const std::vector<MultiVerCommitNode> &commits) in MergeSyncCommit()
715 int MultiVerNaturalStore::TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &… in TransferSyncCommitDevInfo()
H A Dmulti_ver_natural_store_commit_storage.cpp249 int MultiVerNaturalStoreCommitStorage::GetAllCommitsInTree(std::list<MultiVerCommitNode> &commits) … in GetAllCommitsInTree()
276 MultiVerCommitNode commitNode; in GetAllCommitsInTree()
281 MultiVerCommitNode::LOCAL_FLAG : MultiVerCommitNode::NON_LOCAL_FLAG); in GetAllCommitsInTree()
292 commits.sort([] (const MultiVerCommitNode &thisNode, const MultiVerCommitNode &thatNode) { in GetAllCommitsInTree()
H A Dmulti_ver_natural_store_connection.h64 …int PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries);
H A Dmulti_ver_natural_store_commit_storage.h79 int GetAllCommitsInTree(std::list<MultiVerCommitNode> &commits) const override;
H A Dmulti_ver_vacuum_executor_impl.cpp64 std::list<MultiVerCommitNode> commitsInTree; in GetVacuumAbleCommits()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dmulti_ver_kvdb_sync_interface.h30 virtual bool IsCommitExisted(const MultiVerCommitNode &commit) const = 0;
33 … virtual int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const = 0;
36 virtual int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap,
37 std::vector<MultiVerCommitNode> &commits) const = 0;
40 …virtual int GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entrie…
58 …virtual int PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &…
62 …virtual int MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode…
68 virtual int TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId,
H A Dmulti_ver_def.h30 struct MultiVerCommitNode { struct
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.h37 void SetCommitMap(std::map<std::string, MultiVerCommitNode> &inMap);
39 void GetCommitMap(std::map<std::string, MultiVerCommitNode> &outMap) const;
50 std::map<std::string, MultiVerCommitNode> commitMap_;
62 void SetData(std::vector<MultiVerCommitNode> &inData);
64 void GetData(std::vector<MultiVerCommitNode> &outData) const;
81 std::vector<MultiVerCommitNode> commits_;
126 int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &);
128 …int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &, std::vector<MultiVerCommitNod…
131 std::map<std::string, MultiVerCommitNode> &commitMap);
133 …int SendAckPacket(const MultiVerSyncTaskContext *context, std::vector<MultiVerCommitNode> &commits,
H A Dcommit_history_sync.cpp238 std::map<std::string, MultiVerCommitNode> commitMap; in SyncStart()
260 std::vector<MultiVerCommitNode> commits; in RequestRecvCallback()
267 std::map<std::string, MultiVerCommitNode> commitMap; in RequestRecvCallback()
300 std::vector<MultiVerCommitNode> commits; in AckRecvCallback()
350 std::map<std::string, MultiVerCommitNode> commitMap; in RequestPacketSerialization()
398 std::map<std::string, MultiVerCommitNode> commitMap; in RequestPacketDeSerialization()
401 MultiVerCommitNode val; in RequestPacketDeSerialization()
465 std::vector<MultiVerCommitNode> commits; in AckPacketSerialization()
494 std::vector<MultiVerCommitNode> commits; in AckPacketDeSerialization()
583 std::vector<MultiVerCommitNode> &commits) in GetCommitTree()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_multi_ver_sync_db_interface.h51 bool IsCommitExisted(const MultiVerCommitNode &) const override;
53 int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &) const override;
55 int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &,
56 std::vector<MultiVerCommitNode> &) const override;
58 …int GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) const…
70 … int PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries,
73 …int MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commi…
79 …int TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, bool isSyncedI…
H A Dvirtual_multi_ver_sync_db_interface.cpp77 bool VirtualMultiVerSyncDBInterface::IsCommitExisted(const MultiVerCommitNode &commit) const in IsCommitExisted()
82 int VirtualMultiVerSyncDBInterface::GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode>… in GetDeviceLatestCommit()
87 int VirtualMultiVerSyncDBInterface::GetCommitTree(const std::map<std::string, MultiVerCommitNode> &… in GetCommitTree()
88 std::vector<MultiVerCommitNode> &outCommit) const in GetCommitTree()
93 int VirtualMultiVerSyncDBInterface::GetCommitData(const MultiVerCommitNode &commit, in GetCommitData()
124 int VirtualMultiVerSyncDBInterface::PutCommitData(const MultiVerCommitNode &commit, in PutCommitData()
130 int VirtualMultiVerSyncDBInterface::MergeSyncCommit(const MultiVerCommitNode &commit, in MergeSyncCommit()
131 const std::vector<MultiVerCommitNode> &commits) in MergeSyncCommit()
136 int VirtualMultiVerSyncDBInterface::TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std… in TransferSyncCommitDevInfo()
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp697 static MultiVerCommitNode MakeMultiVerCommitA() in MakeMultiVerCommitA()
699 MultiVerCommitNode outCommit; in MakeMultiVerCommitA()
710 static MultiVerCommitNode MakeMultiVerCommitB() in MakeMultiVerCommitB()
712 MultiVerCommitNode outCommit; in MakeMultiVerCommitB()
723 static MultiVerCommitNode MakeMultiVerCommitC() in MakeMultiVerCommitC()
725 MultiVerCommitNode outCommit; in MakeMultiVerCommitC()
736 static bool IsMultiVerCommitEqual(const MultiVerCommitNode &inCommitA, const MultiVerCommitNode &in… in IsMultiVerCommitEqual()
865 std::vector<MultiVerCommitNode> commitVec; in MakeCommitHistorySyncAckPacketA()
874 std::vector<MultiVerCommitNode> commitVec; in MakeCommitHistorySyncAckPacketB()
982 MultiVerCommitNode commitA; in IsMultiVerRequestPacketEqual()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_data_sync.h35 void SetCommit(MultiVerCommitNode &commit);
37 void GetCommit(MultiVerCommitNode &commit) const;
43 MultiVerCommitNode commit_;
90 … int PutCommitData(const MultiVerCommitNode &commit, const std::vector<MultiVerKvEntry *> &entries,
93 …int MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerCommitNode> &commi…
114 int GetValidCommit(MultiVerSyncTaskContext *context, MultiVerCommitNode &commit);
116 bool IsCommitExisted(const MultiVerCommitNode &);
120 int SendRequestPacket(const MultiVerSyncTaskContext *context, MultiVerCommitNode &commit);
125 int GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries);
H A Dmulti_ver_sync_task_context.h49 void GetCommits(std::vector<MultiVerCommitNode> &commits);
51 void SetCommits(const std::vector<MultiVerCommitNode> &commits);
53 void GetCommit(int index, MultiVerCommitNode &commit) const;
55 void SetCommit(int index, const MultiVerCommitNode &commit);
93 std::vector<MultiVerCommitNode> commits_;
H A Dmulti_ver_data_sync.cpp39 void MultiVerRequestPacket::SetCommit(MultiVerCommitNode &commit) in SetCommit()
44 void MultiVerRequestPacket::GetCommit(MultiVerCommitNode &commit) const in GetCommit()
194 MultiVerCommitNode commit; in SyncStart()
227 MultiVerCommitNode commit; in RequestRecvCallback()
308 int MultiVerDataSync::MergeSyncCommit(const MultiVerCommitNode &commit, const std::vector<MultiVerC… in MergeSyncCommit()
383 MultiVerCommitNode commit; in RequestPacketSerialization()
409 MultiVerCommitNode commit; in RequestPacketDeSerialization()
540 int MultiVerDataSync::GetValidCommit(MultiVerSyncTaskContext *context, MultiVerCommitNode &commit) in GetValidCommit()
555 MultiVerCommitNode commitItem; in GetValidCommit()
574 bool MultiVerDataSync::IsCommitExisted(const MultiVerCommitNode &commit) in IsCommitExisted()
[all …]
H A Dmulti_ver_sync_task_context.cpp122 void MultiVerSyncTaskContext::GetCommits(std::vector<MultiVerCommitNode> &commits) in GetCommits()
127 void MultiVerSyncTaskContext::SetCommits(const std::vector<MultiVerCommitNode> &commits) in SetCommits()
132 void MultiVerSyncTaskContext::GetCommit(int index, MultiVerCommitNode &commit) const in GetCommit()
137 void MultiVerSyncTaskContext::SetCommit(int index, const MultiVerCommitNode &commit) in SetCommit()
H A Dmulti_ver_sync_state_machine.cpp426 MultiVerCommitNode commit; in Finish()
430 std::vector<MultiVerCommitNode> commits; in Finish()
452 MultiVerCommitNode commit; in OneCommitSyncFinish()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Dparcel.h59 int WriteMultiVerCommit(const MultiVerCommitNode &commit);
60 uint32_t ReadMultiVerCommit(MultiVerCommitNode &commit);
61 int WriteMultiVerCommits(const std::vector<MultiVerCommitNode> &commits);
62 uint32_t ReadMultiVerCommits(std::vector<MultiVerCommitNode> &commits);
170 static uint32_t GetMultiVerCommitLen(const MultiVerCommitNode &commit);
171 static uint32_t GetMultiVerCommitsLen(const std::vector<MultiVerCommitNode> &commits);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dparcel.cpp231 int Parcel::WriteMultiVerCommit(const MultiVerCommitNode &commit) in WriteMultiVerCommit()
271 uint32_t Parcel::ReadMultiVerCommit(MultiVerCommitNode &commit) in ReadMultiVerCommit()
289 int Parcel::WriteMultiVerCommits(const std::vector<MultiVerCommitNode> &commits) in WriteMultiVerCommits()
340 uint32_t Parcel::ReadMultiVerCommits(std::vector<MultiVerCommitNode> &commits) in ReadMultiVerCommits()
354 MultiVerCommitNode commit; in ReadMultiVerCommits()
485 uint32_t Parcel::GetMultiVerCommitLen(const MultiVerCommitNode &commit) in GetMultiVerCommitLen()
500 uint32_t Parcel::GetMultiVerCommitsLen(const std::vector<MultiVerCommitNode> &commits) in GetMultiVerCommitsLen()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_transaction_data_test.cpp97 MultiVerCommitNode multiVerCommit; in RunSyncMergeForOneCommit()
108 std::vector<MultiVerCommitNode> multiVerCommits; in RunSyncMergeForOneCommit()
1020 MultiVerCommitNode multiVerCommit;
1028 std::vector<MultiVerCommitNode> multiVerCommits;
1349 static bool PutFirstSyncCommitData(MultiVerCommitNode &multiVerCommit) in PutFirstSyncCommitData()
1381 static bool PutSecondSyncCommitData(const MultiVerCommitNode &multiVerCommit, MultiVerCommitNode &n… in PutSecondSyncCommitData()
1407 std::vector<MultiVerCommitNode> multiVerCommits; in PutSecondSyncCommitData()
1488 MultiVerCommitNode commit;
1522 MultiVerCommitNode commit;
1531 MultiVerCommitNode newCommit;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dikvdb_commit_storage.h61 virtual int GetAllCommitsInTree(std::list<MultiVerCommitNode> &commits) const = 0;