timer: fix an issue related to removing entries

This commit is contained in:
Matheus
2024-03-30 18:38:46 -03:00
parent de3226d23b
commit 84c20586c2
2 changed files with 13 additions and 7 deletions
+1
View File
@@ -14,6 +14,7 @@ typedef struct timerentry_t {
dpcfn_t fn; dpcfn_t fn;
dpcarg_t arg; dpcarg_t arg;
dpc_t dpc; dpc_t dpc;
bool fired;
} timerentry_t; } timerentry_t;
typedef struct { typedef struct {
+12 -7
View File
@@ -47,12 +47,15 @@ void timer_isr(timer_t *timer, context_t *context) {
spinlock_acquire(&timer->lock); spinlock_acquire(&timer->lock);
__assert(timer->queue); __assert(timer->queue);
timer->tickcurrent = timer->queue->absolutetick; timer->tickcurrent = timer->queue->absolutetick;
timerentry_t *oldentry = timer->queue; timerentry_t *oldentry = timer->queue;
timer->queue = timer->queue->next; timer->queue = timer->queue->next;
if (oldentry->repeatus) if (oldentry->repeatus)
insert(timer, oldentry, oldentry->repeatus); insert(timer, oldentry, oldentry->repeatus);
else
oldentry->fired = true;
dpc_enqueue(&oldentry->dpc, oldentry->fn, oldentry->arg); dpc_enqueue(&oldentry->dpc, oldentry->fn, oldentry->arg);
@@ -102,6 +105,7 @@ void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg,
entry->repeatus = repeating ? us : 0; entry->repeatus = repeating ? us : 0;
entry->fn = fn; entry->fn = fn;
entry->arg = arg; entry->arg = arg;
entry->fired = false;
insert(timer, entry, us); insert(timer, entry, us);
@@ -115,11 +119,14 @@ void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg,
} }
void timer_remove(timer_t *timer, timerentry_t *entry) { void timer_remove(timer_t *timer, timerentry_t *entry) {
timer_stop(timer);
long oldipl = interrupt_raiseipl(IPL_TIMER); long oldipl = interrupt_raiseipl(IPL_TIMER);
spinlock_acquire(&timer->lock); spinlock_acquire(&timer->lock);
if (timer->running) // if it had already fired by the time the lock was reached
timer->tickcurrent += timer->stop(timer); if (entry->fired == true)
goto cleanup;
timerentry_t *iterator = timer->queue; timerentry_t *iterator = timer->queue;
timerentry_t *prev = NULL; timerentry_t *prev = NULL;
@@ -136,13 +143,11 @@ void timer_remove(timer_t *timer, timerentry_t *entry) {
else else
prev->next = iterator->next; prev->next = iterator->next;
if (timer->running) { cleanup:
timercheck(timer);
timer->arm(timer->queue->absolutetick - timer->tickcurrent);
}
spinlock_release(&timer->lock); spinlock_release(&timer->lock);
interrupt_loweripl(oldipl); interrupt_loweripl(oldipl);
timer_resume(timer);
} }
timer_t *timer_new(time_t ticksperus, void (*arm)(time_t), time_t (*stop)()) { timer_t *timer_new(time_t ticksperus, void (*arm)(time_t), time_t (*stop)()) {