Timers: Immediately signal the timer if it was started with an initial value of 0.
This commit is contained in:
parent
e594e63bb5
commit
029a11030e
2 changed files with 31 additions and 16 deletions
|
@ -52,10 +52,15 @@ void Timer::Set(s64 initial, s64 interval) {
|
||||||
initial_delay = initial;
|
initial_delay = initial;
|
||||||
interval_delay = interval;
|
interval_delay = interval;
|
||||||
|
|
||||||
|
if (initial == 0) {
|
||||||
|
// Immediately invoke the callback
|
||||||
|
Signal(0);
|
||||||
|
} else {
|
||||||
u64 initial_microseconds = initial / 1000;
|
u64 initial_microseconds = initial / 1000;
|
||||||
CoreTiming::ScheduleEvent(usToCycles(initial_microseconds), timer_callback_event_type,
|
CoreTiming::ScheduleEvent(usToCycles(initial_microseconds), timer_callback_event_type,
|
||||||
callback_handle);
|
callback_handle);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void Timer::Cancel() {
|
void Timer::Cancel() {
|
||||||
CoreTiming::UnscheduleEvent(timer_callback_event_type, callback_handle);
|
CoreTiming::UnscheduleEvent(timer_callback_event_type, callback_handle);
|
||||||
|
@ -72,6 +77,20 @@ void Timer::WakeupAllWaitingThreads() {
|
||||||
signaled = false;
|
signaled = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void Timer::Signal(int cycles_late) {
|
||||||
|
LOG_TRACE(Kernel, "Timer %08" PRIx64 " fired", timer_handle);
|
||||||
|
|
||||||
|
// Resume all waiting threads
|
||||||
|
WakeupAllWaitingThreads();
|
||||||
|
|
||||||
|
if (interval_delay != 0) {
|
||||||
|
// Reschedule the timer with the interval delay
|
||||||
|
u64 interval_microseconds = interval_delay / 1000;
|
||||||
|
CoreTiming::ScheduleEvent(usToCycles(interval_microseconds) - cycles_late,
|
||||||
|
timer_callback_event_type, callback_handle);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// The timer callback event, called when a timer is fired
|
/// The timer callback event, called when a timer is fired
|
||||||
static void TimerCallback(u64 timer_handle, int cycles_late) {
|
static void TimerCallback(u64 timer_handle, int cycles_late) {
|
||||||
SharedPtr<Timer> timer =
|
SharedPtr<Timer> timer =
|
||||||
|
@ -82,19 +101,7 @@ static void TimerCallback(u64 timer_handle, int cycles_late) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
LOG_TRACE(Kernel, "Timer %08" PRIx64 " fired", timer_handle);
|
timer->Signal(cycles_late);
|
||||||
|
|
||||||
timer->signaled = true;
|
|
||||||
|
|
||||||
// Resume all waiting threads
|
|
||||||
timer->WakeupAllWaitingThreads();
|
|
||||||
|
|
||||||
if (timer->interval_delay != 0) {
|
|
||||||
// Reschedule the timer with the interval delay
|
|
||||||
u64 interval_microseconds = timer->interval_delay / 1000;
|
|
||||||
CoreTiming::ScheduleEvent(usToCycles(interval_microseconds) - cycles_late,
|
|
||||||
timer_callback_event_type, timer_handle);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void TimersInit() {
|
void TimersInit() {
|
||||||
|
|
|
@ -54,6 +54,14 @@ public:
|
||||||
void Cancel();
|
void Cancel();
|
||||||
void Clear();
|
void Clear();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Signals the timer, waking up any waiting threads and rescheduling it
|
||||||
|
* for the next interval.
|
||||||
|
* This method should not be called from outside the timer callback handler,
|
||||||
|
* lest multiple callback events get scheduled.
|
||||||
|
*/
|
||||||
|
void Signal(int cycles_late);
|
||||||
|
|
||||||
private:
|
private:
|
||||||
Timer();
|
Timer();
|
||||||
~Timer() override;
|
~Timer() override;
|
||||||
|
|
Loading…
Reference in a new issue