Home
last modified time | relevance | path

Searched refs:MultiVerDataSync (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_data_sync.cpp94 MultiVerDataSync::~MultiVerDataSync() in ~MultiVerDataSync()
132 uint32_t MultiVerDataSync::CalculateLen(const Message *inMsg) in CalculateLen()
156 int MultiVerDataSync::RegisterTransformFunc() in RegisterTransformFunc()
184 int MultiVerDataSync::SyncStart(MultiVerSyncTaskContext *context) in SyncStart()
313 void MultiVerDataSync::ReleaseKvEntry(const MultiVerKvEntry *entry) in ReleaseKvEntry()
318 void MultiVerDataSync::SendFinishedRequest(const MultiVerSyncTaskContext *context) in SendFinishedRequest()
438 int MultiVerDataSync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
529 bool MultiVerDataSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
574 bool MultiVerDataSync::IsCommitExisted(const MultiVerCommitNode &commit) in IsCommitExisted()
579 int MultiVerDataSync::Send(const DeviceID &deviceId, const Message *inMsg) in Send()
[all …]
H A Dmulti_ver_data_sync.h66 class MultiVerDataSync {
68 MultiVerDataSync() : storagePtr_(nullptr), communicateHandle_(nullptr) {}; in MultiVerDataSync() function
69 ~MultiVerDataSync();
70 DISABLE_COPY_ASSIGN_MOVE(MultiVerDataSync);
H A Dmulti_ver_sync_state_machine.h134 std::unique_ptr<MultiVerDataSync> multiVerDataSync_;
H A Dmulti_ver_sync_state_machine.cpp74 multiVerDataSync_ = std::make_unique<MultiVerDataSync>(); in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp1019 uint32_t lenA = MultiVerDataSync::CalculateLen(&oriMsgA);
1022 int ret = MultiVerDataSync::Serialization(bufferA.data(), lenA, &oriMsgA);
1028 uint32_t lenB = MultiVerDataSync::CalculateLen(&oriMsgB);
1031 ret = MultiVerDataSync::Serialization(bufferB.data(), lenB, &oriMsgB);
1041 ret = MultiVerDataSync::DeSerialization(bufferA.data(), lenA, &outMsgA);
1054 ret = MultiVerDataSync::DeSerialization(bufferB.data(), lenB, &outMsgB);
1127 uint32_t lenA = MultiVerDataSync::CalculateLen(&oriMsgA);
1136 uint32_t lenB = MultiVerDataSync::CalculateLen(&oriMsgB);
1139 ret = MultiVerDataSync::Serialization(bufferB.data(), lenB, &oriMsgB);
1149 ret = MultiVerDataSync::DeSerialization(bufferA.data(), lenA, &outMsgA);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_engine.cpp586 return MultiVerDataSync::CalculateLen(inMsg); in GetMsgSize()
H A Dgeneric_syncer.cpp598 errCode = MultiVerDataSync::RegisterTransformFunc(); in SyncResourceInit()