Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.cpp135 CommitHistorySync::~CommitHistorySync() in ~CommitHistorySync()
173 uint32_t CommitHistorySync::CalculateLen(const Message *inMsg) in CalculateLen()
199 int CommitHistorySync::RegisterTransformFunc() in RegisterTransformFunc()
229 int CommitHistorySync::SyncStart(MultiVerSyncTaskContext *context) in SyncStart()
436 int CommitHistorySync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
535 bool CommitHistorySync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
546 int CommitHistorySync::Send(const DeviceID &deviceId, const Message *inMsg) in Send()
616 int CommitHistorySync::SendRequestPacket(const MultiVerSyncTaskContext *context, in SendRequestPacket()
660 int CommitHistorySync::SendAckPacket(const MultiVerSyncTaskContext *context, in SendAckPacket()
705 int CommitHistorySync::GetLocalDeviceInfo(std::string &deviceInfo) in GetLocalDeviceInfo()
[all …]
H A Dcommit_history_sync.h85 class CommitHistorySync {
87 CommitHistorySync() : storagePtr_(nullptr), communicateHandle_(nullptr) {}; in CommitHistorySync() function
88 ~CommitHistorySync();
89 DISABLE_COPY_ASSIGN_MOVE(CommitHistorySync);
H A Dsync_engine.cpp584 return CommitHistorySync::CalculateLen(inMsg); in GetMsgSize()
H A Dgeneric_syncer.cpp593 errCode = CommitHistorySync::RegisterTransformFunc(); in SyncResourceInit()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp820 uint32_t lenA = CommitHistorySync::CalculateLen(&oriMsgA);
823 int ret = CommitHistorySync::Serialization(bufferA.data(), lenA, &oriMsgA);
829 uint32_t lenB = CommitHistorySync::CalculateLen(&oriMsgB);
832 ret = CommitHistorySync::Serialization(bufferB.data(), lenB, &oriMsgB);
842 ret = CommitHistorySync::DeSerialization(bufferA.data(), lenA, &outMsgA);
855 ret = CommitHistorySync::DeSerialization(bufferB.data(), lenB, &outMsgB);
936 uint32_t lenA = CommitHistorySync::CalculateLen(&oriMsgA);
945 uint32_t lenB = CommitHistorySync::CalculateLen(&oriMsgB);
948 ret = CommitHistorySync::Serialization(bufferB.data(), lenB, &oriMsgB);
958 ret = CommitHistorySync::DeSerialization(bufferA.data(), lenA, &outMsgA);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.h133 std::unique_ptr<CommitHistorySync> commitHistorySync_;
H A Dmulti_ver_sync_state_machine.cpp73 commitHistorySync_ = std::make_unique<CommitHistorySync>(); in Initialize()