zhangsheng/WLG
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add codes.

Browse Source
This commit is contained in:
pandx 2026-02-09 10:44:02 +08:00
parent 50eb148a30
commit 3411823f8a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
scheduler/schedule.cpp
View File

@ -1102,6 +1102,7 @@ int SensorScheduler::CancelUpgradeSensor(std::vector<uint16_t> short_addr_list)
}
int SensorScheduler::UpgradeResult(uint16_t short_addr, int result) {
zlog_info(zbt, "[%x] upgrade result:%d", short_addr, result);
int id = 0;
auto iter = short_addr_map_.find(short_addr);
if (iter == short_addr_map_.end()) {
@ -1129,7 +1130,7 @@ int SensorScheduler::UpgradeResult(uint16_t short_addr, int result) {
}
} else {
auto upgrade_iter = upgrade_.find(id);
if (upgrade_iter->second.try_times >= wave_resend_num_) {
if (upgrade_iter->second.try_times >= 10 /*wave_resend_num_*/) {
zlog_warn(zbt, "[%d] short addr:%x upgrade %d time failure", id, short_addr, wave_resend_num_);
upgrade_list_.erase(short_addr);
upgrade_.erase(id);
@ -1152,6 +1153,7 @@ int SensorScheduler::UpgradeResult(uint16_t short_addr, int result) {
void SensorScheduler::UpdateUpgradeInfo(int id) {
auto upgrade_iter = upgrade_.find(id);
upgrade_iter->second.try_times++;
zlog_debug(zbt, "[%d] try_times:%d", id, upgrade_iter->second.try_times);
long ts = GetLocalTs();
upgrade_iter->second.try_world_time1.push_back(GetUTCTime(ts));
UpgradeCfg::WriteCfg(upgrade_);