Home
last modified time | relevance | path

Searched refs:ackPacket (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.cpp424 ReTimeSyncIfNeed(ackPacket); in RequestRecv()
665 ackPacket.GetSourceTimeEnd(), ackPacket.GetTargetTimeEnd(), ackPacket.GetSourceTimeBegin(), in BuildAckPacket()
667 return ackPacket; in BuildAckPacket()
680 static_cast<TimeOffset>(ackPacket.GetSourceTimeBegin() - ackPacket.GetTargetTimeBegin()); in ReTimeSyncIfNeed()
712 ackPacket.GetResponseLocalOffset(); in CheckReTimeSyncIfNeedWithHighVersion()
726 ackPacket.GetSourceTimeEnd(), in SaveOffsetWithAck()
727 ackPacket.GetTargetTimeEnd(), in SaveOffsetWithAck()
728 ackPacket.GetSourceTimeBegin(), in SaveOffsetWithAck()
729 ackPacket.GetTargetTimeBegin(), in SaveOffsetWithAck()
732 ackPacket.GetRequestLocalOffset(), in SaveOffsetWithAck()
[all …]
H A Dability_sync.cpp453 AbilitySyncAckPacket ackPacket; in RequestRecv() local
1016 AbilitySyncAckPacket &ackPacket) const in SetAbilityAckBodyInfo()
1024 ackPacket.SetSecFlag(option.securityFlag); in SetAbilityAckBodyInfo()
1038 ackPacket.SetDbCreateTime(dbCreateTime); in SetAbilityAckBodyInfo()
1039 ackPacket.SetDbAbility(dbAbility); in SetAbilityAckBodyInfo()
1045 ackPacket.SetAckCode(ackCode); in SetAbilityAckBodyInfo()
1046 ackPacket.SetSchemaVersion(schemaVersion); in SetAbilityAckBodyInfo()
1142 AbilitySyncAckPacket ackPacket; in HandleRequestRecv() local
1155 AbilitySyncAckPacket &ackPacket) in SendAck() argument
1174 AbilitySyncAckPacket ackPacket; in SendAckWithEmptySchema() local
[all …]
H A Dability_sync.h226 AbilitySyncAckPacket &ackPacket) const;
228 static void SetAbilityAckSchemaInfo(AbilitySyncAckPacket &ackPacket, const ISchema &schemaObj);
230 …static void SetAbilityAckSyncOpinionInfo(AbilitySyncAckPacket &ackPacket, SyncOpinion localOpinion…
241 AbilitySyncAckPacket &ackPacket);
245 int SendAck(const Message *inMsg, const AbilitySyncAckPacket &ackPacket, bool isAckNotify);
H A Dtime_sync.h138 void ReTimeSyncIfNeed(const TimeSyncPacket &ackPacket);
142 …ckReTimeSyncIfNeedWithHighVersion(TimeOffset timeOffsetIgnoreRtt, const TimeSyncPacket &ackPacket);
144 int SaveOffsetWithAck(const TimeSyncPacket &ackPacket);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h220 …void SetAckPacket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, const DataRequestPa…
H A Dsingle_ver_data_sync.cpp1586 void SingleVerDataSync::SetAckPacket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, in SetAckPacket() argument
1592 ackPacket.SetRecvCode(recvCode); in SetAckPacket()
1595 ackPacket.SetData(maxSendDataTime + 1); // + 1 to next start in SetAckPacket()
1599 ackPacket.SetData(mark); in SetAckPacket()
1616 ackPacket.SetReserved(reserved); in SetAckPacket()
1617 ackPacket.SetVersion(version); in SetAckPacket()