timer: return remaining microseconds on timer_remove

This commit is contained in:
Matheus
2024-05-29 10:59:23 -03:00
parent 35eca115f5
commit f434a4d341
2 changed files with 15 additions and 3 deletions
+1 -1
View File
@@ -31,7 +31,7 @@ void timer_resume(timer_t *timer);
void timer_stop(timer_t *timer); void timer_stop(timer_t *timer);
void timer_isr(timer_t *timer, context_t *context); void timer_isr(timer_t *timer, context_t *context);
void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg, time_t us, bool repeating); void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg, time_t us, bool repeating);
void timer_remove(timer_t *timer, timerentry_t *entry); uintmax_t timer_remove(timer_t *timer, timerentry_t *entry);
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)());
#endif #endif
+14 -2
View File
@@ -10,12 +10,14 @@ static void insert(timer_t *timer, timerentry_t *entry, time_t us) {
entry->next = NULL; entry->next = NULL;
timer->queue = entry; timer->queue = entry;
} else if (timer->queue->absolutetick > entry->absolutetick) { // if the current entry should be put before all the others in the queue } else if (timer->queue->absolutetick > entry->absolutetick) { // if the current entry should be put before all the others in the queue
__assert(entry->next == NULL);
entry->next = timer->queue; entry->next = timer->queue;
timer->queue = entry; timer->queue = entry;
} else { } else {
timerentry_t *search = timer->queue; timerentry_t *search = timer->queue;
while (search) { while (search) {
__assert(search != entry);
if (search->next == NULL) { // if last entry in the queue if (search->next == NULL) { // if last entry in the queue
entry->next = NULL; entry->next = NULL;
search->next = entry; search->next = entry;
@@ -35,6 +37,7 @@ static void timercheck(timer_t *timer) {
while (timer->queue && timer->queue->absolutetick == timer->tickcurrent) { while (timer->queue && timer->queue->absolutetick == timer->tickcurrent) {
timerentry_t *entry = timer->queue; timerentry_t *entry = timer->queue;
timer->queue = timer->queue->next; timer->queue = timer->queue->next;
entry->next = NULL;
if (entry->repeatus) if (entry->repeatus)
insert(timer, entry, entry->repeatus); insert(timer, entry, entry->repeatus);
@@ -45,6 +48,8 @@ static void timercheck(timer_t *timer) {
} }
} }
// TODO if an entry is removed and the timer still fires,
// it will skip forwards in time which is bad BAD
void timer_isr(timer_t *timer, context_t *context) { void timer_isr(timer_t *timer, context_t *context) {
spinlock_acquire(&timer->lock); spinlock_acquire(&timer->lock);
@@ -53,6 +58,7 @@ void timer_isr(timer_t *timer, context_t *context) {
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;
oldentry->next = NULL;
if (oldentry->repeatus) if (oldentry->repeatus)
insert(timer, oldentry, oldentry->repeatus); insert(timer, oldentry, oldentry->repeatus);
@@ -109,7 +115,6 @@ void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg,
entry->fn = fn; entry->fn = fn;
entry->arg = arg; entry->arg = arg;
entry->fired = false; entry->fired = false;
insert(timer, entry, us); insert(timer, entry, us);
if (timer->running) { if (timer->running) {
@@ -121,12 +126,14 @@ void timer_insert(timer_t *timer, timerentry_t *entry, dpcfn_t fn, dpcarg_t arg,
interrupt_loweripl(oldipl); interrupt_loweripl(oldipl);
} }
void timer_remove(timer_t *timer, timerentry_t *entry) { uintmax_t timer_remove(timer_t *timer, timerentry_t *entry) {
timer_stop(timer); timer_stop(timer);
long oldipl = interrupt_raiseipl(IPL_TIMER); long oldipl = interrupt_raiseipl(IPL_TIMER);
spinlock_acquire(&timer->lock); spinlock_acquire(&timer->lock);
uintmax_t timeremaining = 0;
// if it had already fired by the time the lock was reached // if it had already fired by the time the lock was reached
if (entry->fired == true) if (entry->fired == true)
goto cleanup; goto cleanup;
@@ -146,11 +153,16 @@ void timer_remove(timer_t *timer, timerentry_t *entry) {
else else
prev->next = iterator->next; prev->next = iterator->next;
iterator->next = NULL;
// ALWAYS round up the time remaining
timeremaining = ROUND_UP(iterator->absolutetick - timer->tickcurrent, timer->ticksperus) / timer->ticksperus;
cleanup: cleanup:
spinlock_release(&timer->lock); spinlock_release(&timer->lock);
interrupt_loweripl(oldipl); interrupt_loweripl(oldipl);
timer_resume(timer); timer_resume(timer);
return timeremaining;
} }
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)()) {