Home
last modified time | relevance | path

Searched refs:reSendInfo (Results 1 – 2 of 2) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp220 …reSendInfo.end, reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, sequenceId, reSendInfo.packe… in ReSendData()
222 DataSyncReSendInfo dataReSendInfo = {sessionId_, sequenceId, reSendInfo.start, reSendInfo.end, in ReSendData()
223 reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, reSendInfo.packetId}; in ReSendData()
640 ReSendInfo reSendInfo; in UpdateSendInfo() local
656 …reSendInfo.start, reSendInfo.end, reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, maxSequenc… in UpdateSendInfo()
1414 errCode = SendReSendPacket(packet, context, reSendInfo.sessionId, reSendInfo.sequenceId); in ReSend()
1421 …SyncTimeRange dataTime {reSendInfo.start, reSendInfo.deleteDataStart, reSendInfo.end, reSendInfo.d… in ReSend()
1425 if (reSendInfo.end > reSendInfo.start) { in ReSend()
1621 DataSyncReSendInfo reSendInfo) in GetReSendData() argument
1721 if (GetSessionEndTimestamp() == std::max(reSendInfo.end, reSendInfo.deleteDataEnd) || in FillRequestReSendPacket()
[all …]
H A Dsingle_ver_data_sync.h135 int32_t ReSend(SingleVerSyncTaskContext *context, DataSyncReSendInfo reSendInfo);
224 DataSyncReSendInfo reSendInfo);
231 DataSyncReSendInfo reSendInfo, SyncEntry &syncData, int sendCode);