Searched refs:commitMap (Results 1 – 7 of 7) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 239 int errCode = GetDeviceLatestCommit(commitMap); in SyncStart()
248 return SendRequestPacket(context, commitMap); in SyncStart()
268 packet->GetCommitMap(commitMap); in RequestRecvCallback()
274 errCode = GetCommitTree(commitMap, commits); in RequestRecvCallback()
286 if (commitMap.empty()) { in RequestRecvCallback()
351 packet->GetCommitMap(commitMap); in RequestPacketSerialization()
358 for (auto &iter : commitMap) { in RequestPacketSerialization()
404 commitMap[key] = val; in RequestPacketDeSerialization()
425 packet->SetCommitMap(commitMap); in RequestPacketDeSerialization()
594 for (const auto &item : commitMap) { in GetCommitTree()
[all …]
|
| H A D | commit_history_sync.h | 131 std::map<std::string, MultiVerCommitNode> &commitMap);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | multi_ver_kvdb_sync_interface.h | 33 … virtual int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const = 0;
36 virtual int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap,
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_storage_executor.h | 58 int GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const;
60 int GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap,
|
| H A D | multi_ver_natural_store.cpp | 574 …iVerNaturalStore::GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const in GetDeviceLatestCommit()
582 errCode = handle->GetDeviceLatestCommit(commitMap); in GetDeviceLatestCommit()
587 int MultiVerNaturalStore::GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, in GetCommitTree() argument
596 errCode = handle->GetCommitTree(commitMap, commits); in GetCommitTree()
|
| H A D | multi_ver_storage_executor.cpp | 75 …rStorageExecutor::GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const in GetDeviceLatestCommit()
102 commitMap.insert(std::make_pair(latestCommit.first, std::move(commit))); in GetDeviceLatestCommit()
108 … MultiVerStorageExecutor::GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, in GetCommitTree() argument
116 for (auto &latestCommit : commitMap) { in GetCommitTree()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_multi_ver_p2p_sync_test.cpp | 751 std::map<std::string, MultiVerCommitNode> commitMap; in MakeCommitHistorySyncRequestPacketA() local
752 commitMap[string("A")] = MakeMultiVerCommitA(); in MakeCommitHistorySyncRequestPacketA()
753 commitMap[string("C")] = MakeMultiVerCommitC(); in MakeCommitHistorySyncRequestPacketA()
754 inPacket.SetCommitMap(commitMap); in MakeCommitHistorySyncRequestPacketA()
759 std::map<std::string, MultiVerCommitNode> commitMap; in MakeCommitHistorySyncRequestPacketB() local
760 commitMap[string("B")] = MakeMultiVerCommitB(); in MakeCommitHistorySyncRequestPacketB()
761 commitMap[string("C")] = MakeMultiVerCommitC(); in MakeCommitHistorySyncRequestPacketB()
762 commitMap[string("BB")] = MakeMultiVerCommitB(); in MakeCommitHistorySyncRequestPacketB()
763 inPacket.SetCommitMap(commitMap); in MakeCommitHistorySyncRequestPacketB()
|