sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-09-12 08:12:22 +01:00
Code Issues Releases Wiki Activity

preen

Browse Source
This commit is contained in:
J. Nick Koston
2025-07-06 21:01:52 -05:00
parent 71d6ba242e
commit 074fbb522c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
esphome/core/scheduler.cpp
View File

@@ -273,11 +273,11 @@ void HOT Scheduler::call() {
ESP_LOGD(TAG, "Items: count=%zu, now=%" PRIu64 " (%u, %" PRIu32 ")", this->items_.size(), now, this->millis_major_, ESP_LOGD(TAG, "Items: count=%zu, now=%" PRIu64 " (%u, %" PRIu32 ")", this->items_.size(), now, this->millis_major_,
this->last_millis_); this->last_millis_);
while (!this->empty_()) { while (!this->empty_()) {
std::unique_ptr<SchedulerItem> item;
{ {
LockGuard guard{this->lock_}; LockGuard guard{this->lock_};
auto item = std::move(this->items_[0]); item = std::move(this->items_[0]);
this->pop_raw_(); this->pop_raw_();
old_items.push_back(std::move(item));
} }
const char *name = item->get_name(); const char *name = item->get_name();
@@ -292,6 +292,8 @@ void HOT Scheduler::call() {
{ {
LockGuard guard{this->lock_}; LockGuard guard{this->lock_};
this->items_ = std::move(old_items); this->items_ = std::move(old_items);
// Rebuild heap after moving items back
std::make_heap(this->items_.begin(), this->items_.end(), SchedulerItem::cmp);
} }
} }
#endif // ESPHOME_DEBUG_SCHEDULER #endif // ESPHOME_DEBUG_SCHEDULER