Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_message_schedule.cpp150 uint64_t packetId = 0; in GetMsgFromMap() local
151 if (GetPacketId(msg, packetId) != E_OK) { in GetMsgFromMap()
160 if (packetId < revisePacketId) { in GetMsgFromMap()
169 if (packetId < finishedPacketId_) { in GetMsgFromMap()
301 uint64_t packetId = 0; in UpdateMsgMapIfNeed() local
302 if (GetPacketId(msg, packetId) != E_OK) { in UpdateMsgMapIfNeed()
325 (packetId != 0) && (packetId < cachePacketId)) { in UpdateMsgMapIfNeed()
327 packetId, cachePacketId, label_.c_str(), STR_MASK(deviceId_)); in UpdateMsgMapIfNeed()
336 packetId, label_.c_str(), STR_MASK(deviceId_)); in UpdateMsgMapIfNeed()
340 int SingleVerDataMessageSchedule::GetPacketId(const Message *msg, uint64_t &packetId) in GetPacketId() argument
[all …]
H A Dsingle_ver_data_packet.cpp141 uint64_t packetId = 0; in GetPacketId() local
146 return packetId; in GetPacketId()
398 uint64_t packetId = 0; in GetPacketId() local
401 packetId = DataAckReserve[ACK_PACKET_RESERVED_INDEX_PACKETID]; in GetPacketId()
405 if (packetId > MAX_PACKETID) { in GetPacketId()
408 return packetId; in GetPacketId()
411 bool DataAckPacket::IsPacketIdValid(uint64_t packetId) in IsPacketIdValid() argument
413 return (packetId > 0); in IsPacketIdValid()
H A Dsingle_ver_data_sync.cpp220 …endInfo.end, reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, sequenceId, reSendInfo.packetId, in ReSendData()
223 reSendInfo.deleteBeginTime, reSendInfo.deleteEndTime, reSendInfo.packetId}; in ReSendData()
645 reSendInfo.packetId = context->GetPacketId(); in UpdateSendInfo()
657 reSendInfo.packetId, windowSize_, isAllDataHasSent_, label_.c_str(), STR_MASK(deviceId_)); in UpdateSendInfo()
1170 uint64_t originalPacketId = reSendMap_[sequenceId].packetId; in AckPacketIdCheck()
1171 if (DataAckPacket::IsPacketIdValid(packetId) && packetId != originalPacketId) { in AckPacketIdCheck()
1172 … LOGE("[DataSync] packetId[%" PRIu64 "] is not match with original[%" PRIu64 "]", packetId, in AckPacketIdCheck()
1603 uint64_t packetId = 0; in SetAckPacket() local
1607 if (version > SOFTWARE_VERSION_RELEASE_2_0 && packetId > 0) { in SetAckPacket()
1608 reserved.push_back(packetId); in SetAckPacket()
[all …]
H A Dsingle_ver_data_message_schedule.h55 int GetPacketId(const Message *msg, uint64_t &packetId);
H A Dsingle_ver_data_sync.h40 uint64_t packetId = 0; member
50 uint64_t packetId = 0; member
H A Dsingle_ver_data_packet.h177 static bool IsPacketIdValid(uint64_t packetId);