sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-09-07 13:52:20 +01:00
Code Issues Releases Wiki Activity

fix churn on last itme

Browse Source
This commit is contained in:
J. Nick Koston
2025-09-02 20:07:47 -05:00
parent 979a021a27
commit 3066afef24
1 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
esphome/core/scheduler.cpp
View File

@@ -656,12 +656,23 @@ bool HOT Scheduler::cancel_item_locked_(Component *component, const char *name_c
} }
#endif /* not ESPHOME_THREAD_SINGLE */ #endif /* not ESPHOME_THREAD_SINGLE */
// Cancel items in the main heap (can't recycle immediately due to heap structure) // Cancel items in the main heap
for (auto &item : this->items_) { // Special case: if the last item in the heap matches, we can remove it immediately
if (this->matches_item_(item, component, name_cstr, type, match_retry)) { // (removing the last element doesn't break heap structure)
this->mark_item_removed_(item.get()); if (!this->items_.empty()) {
auto &last_item = this->items_.back();
if (this->matches_item_(last_item, component, name_cstr, type, match_retry)) {
this->recycle_item_(std::move(this->items_.back()));
this->items_.pop_back();
total_cancelled++; total_cancelled++;
this->to_remove_++; // Track removals for heap items }
// For other items in heap, we can only mark for removal (can't remove from middle of heap)
for (auto &item : this->items_) {
if (this->matches_item_(item, component, name_cstr, type, match_retry)) {
this->mark_item_removed_(item.get());
total_cancelled++;
this->to_remove_++; // Track removals for heap items
}
} }
} }