From 316068a647c9003a4d02fe1d265de72a39eda831 Mon Sep 17 00:00:00 2001 From: pandx Date: Tue, 1 Apr 2025 14:44:44 +0800 Subject: [PATCH] add wave missed schedule. --- scheduler/schedule.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/scheduler/schedule.cpp b/scheduler/schedule.cpp index c80bb3c..545fa7e 100644 --- a/scheduler/schedule.cpp +++ b/scheduler/schedule.cpp @@ -203,13 +203,14 @@ long SensorScheduler::CalcNextTimestamp(int id, uint16_t short_addr) { } } - if (send_wave_ts == 0) { + if (!MissedWave(short_addr) && send_wave_ts == 0 && success_set_.count(short_addr) == 0) { // add for patch wave int nth_wave_slice = nth_eigen_value_slice_ * wave_slice_num_per_eigen_interval_ + nth_wave_slice_ + 1; auto wave_slice_iter = sensor_id_nth_slice_.find(id); if (wave_slice_iter != sensor_id_nth_slice_.end()) { if (nth_wave_slice > wave_slice_iter->second) { if (success_set_.count(short_addr) == 0 && !RetransferWave(short_addr)) { + zlog_warn(zct, "[Nxt] [%d] add it to patch set", short_addr); patch_set_.insert(short_addr); } }