We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b5693f2 commit 265615eCopy full SHA for 265615e
1 file changed
core/timermanager.cpp
@@ -95,6 +95,7 @@ uint64_t TimerManager::process_timers()
95
cur_timer = this->timer_queue.top();
96
} // ] mtx scope
97
while (cur_timer->timeout_ns <= time_now) {
98
+ this->timer_queue.remove_by_id(cur_timer->id);
99
uint64_t timeout_ns = cur_timer->timeout_ns;
100
timer_cb cb = cur_timer->cb;
101
@@ -105,11 +106,7 @@ uint64_t TimerManager::process_timers()
105
106
if (timeout_ns_new <= time_now)
107
timeout_ns_new = time_now + cur_timer->interval_ns;
108
cur_timer->timeout_ns = timeout_ns_new;
- this->timer_queue.remove_by_id(cur_timer->id);
109
this->timer_queue.push(cur_timer);
110
- } else {
111
- // remove one-shot timers from queue
112
- this->timer_queue.pop();
113
}
114
115
this->cb_active = true;
0 commit comments