Home
last modified time | relevance | path

Searched refs:DataAckPacket (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_packet.cpp356 void DataAckPacket::SetData(uint64_t data) in SetData()
361 uint64_t DataAckPacket::GetData() const in GetData()
366 void DataAckPacket::SetRecvCode(int32_t errorCode) in SetRecvCode()
371 int32_t DataAckPacket::GetRecvCode() const in GetRecvCode()
376 void DataAckPacket::SetVersion(uint32_t version) in SetVersion()
381 uint32_t DataAckPacket::GetVersion() const in GetVersion()
386 void DataAckPacket::SetReserved(std::vector<uint64_t> &reserved) in SetReserved()
391 std::vector<uint64_t> DataAckPacket::GetReserved() const in GetReserved()
396 uint64_t DataAckPacket::GetPacketId() const in GetPacketId()
411 bool DataAckPacket::IsPacketIdValid(uint64_t packetId) in IsPacketIdValid()
[all …]
H A Dsingle_ver_data_packet.h154 class DataAckPacket {
156 DataAckPacket() {}; in DataAckPacket() function
157 virtual ~DataAckPacket() {}; in ~DataAckPacket()
H A Dsingle_ver_serialize_manager.h70 static int AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet);
72 static int AckPacketSyncerPartDeSerializationV1(Parcel &parcel, DataAckPacket &packet);
H A Dsingle_ver_serialize_manager.cpp305 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); in AckPacketCalculateLen()
330 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); in AckPacketSerialization()
344 …erSerializeManager::AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet) in AckPacketSyncerPartSerializationV1()
496 DataAckPacket packet; in AckPacketDeSerialization()
519 int SingleVerSerializeManager::AckPacketSyncerPartDeSerializationV1(Parcel &parcel, DataAckPacket &… in AckPacketSyncerPartDeSerializationV1()
H A Dsingle_ver_data_sync.cpp160 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in TryContinueSync()
1133 DataAckPacket ack; in SendDataAck()
1162 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in AckPacketIdCheck()
1171 if (DataAckPacket::IsPacketIdValid(packetId) && packetId != originalPacketId) { in AckPacketIdCheck()
1186 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in AckRecv()
1248 DataAckPacket ack; in SendSaveDataNotifyPacket()
1366 DataAckPacket ack; in SendResetWatchDogPacket()
1586 void SingleVerDataSync::SetAckPacket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, in SetAckPacket()
H A Dsingle_ver_data_sync.h220 …void SetAckPacket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, const DataRequestPa…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp724 DataAckPacket packet;
762 auto outPacket = outMsg.GetObject<DataAckPacket>();
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp760 auto *packet = inMsg->GetObject<DataAckPacket>(); in RegOnDispatchWithDelayAck()
777 auto *packet = inMsg->GetObject<DataAckPacket>(); in RegOnDispatchWithOffline()
H A Ddistributeddb_mock_sync_module_test.cpp781 DataAckPacket packet;