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 2025-04-09 17:36:23 +08:00
parent d802ff7c94
commit 543c19ded8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
scheduler/schedule.cpp
View File

@ -42,7 +42,7 @@ int SensorScheduler::StartSchedule(int short_addr, int &next_duration) {
if (ts_in_eigen_slice_) { if (ts_in_eigen_slice_) {
nth_eigen_slice_ = (seconds_in_current_eigen_slice_ + 2) / eigen_value_send_duration_; nth_eigen_slice_ = (seconds_in_current_eigen_slice_ + 2) / eigen_value_send_duration_;
if (nth_eigen_value_slice_ == 0 && nth_eigen_slice_ == 0) { if (nth_eigen_value_slice_ == 0) {
ClearFailureSuccessMap(); ClearFailureSuccessMap();
} }
} else { } else {
@ -210,7 +210,7 @@ long SensorScheduler::CalcNextTimestamp(int id, uint16_t short_addr) {
if (wave_slice_iter != sensor_id_nth_slice_.end()) { if (wave_slice_iter != sensor_id_nth_slice_.end()) {
if (nth_wave_slice > wave_slice_iter->second) { if (nth_wave_slice > wave_slice_iter->second) {
if (success_set_.count(short_addr) == 0 && !RetransferWave(short_addr)) { if (success_set_.count(short_addr) == 0 && !RetransferWave(short_addr)) {
zlog_warn(zct, "[Nxt] [%d] add it to patch set", short_addr); zlog_warn(zct, "[Nxt] [%d:%x] add it to patch set", id, short_addr);
patch_set_.insert(short_addr); patch_set_.insert(short_addr);
} }
} }