Diamond75/Panda3DS
1
0
Fork 0
mirror of https://github.com/wheremyfoodat/Panda3DS.git synced 2025-04-12 09:09:47 +12:00
Code Issues Projects Releases Packages Wiki Activity Actions

Reschedule threads on event signal (Required for FE:A FMV)

Browse source
This commit is contained in:
wheremyfoodat 2023-04-24 00:53:46 +03:00
parent 8cfb038226
commit 3ed3729bb4
1 changed files with 34 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

56
src/core/kernel/events.cpp
View file

@ -33,33 +33,45 @@ bool Kernel::signalEvent(Handle handle) {
event->fired = false; event->fired = false;
} }
// Wake up every single thread in the waitlist using a bit scanning algorithm // Check if there's any thread waiting on this event
while (event->waitlist != 0) { if (event->waitlist != 0) {
const uint index = std::countr_zero(event->waitlist); // Get one of the set bits to see which thread is waiting // Wake up every single thread in the waitlist using a bit scanning algorithm
event->waitlist ^= (1ull << index); // Remove thread from waitlist by toggling its bit while (event->waitlist != 0) {
const uint index = std::countr_zero(event->waitlist); // Get one of the set bits to see which thread is waiting
event->waitlist ^= (1ull << index); // Remove thread from waitlist by toggling its bit
// Get the thread we'll be signalling // Get the thread we'll be signalling
Thread& t = threads[index]; Thread& t = threads[index];
switch (t.status) { switch (t.status) {
case ThreadStatus::WaitSync1: case ThreadStatus::WaitSync1:
t.status = ThreadStatus::Ready; t.status = ThreadStatus::Ready;
break; break;
case ThreadStatus::WaitSyncAny: case ThreadStatus::WaitSyncAny:
t.status = ThreadStatus::Ready; t.status = ThreadStatus::Ready;
// Get the index of the event in the object's waitlist, write it to r1 // Get the index of the event in the object's waitlist, write it to r1
for (size_t i = 0; i < t.waitList.size(); i++) { for (size_t i = 0; i < t.waitList.size(); i++) {
if (t.waitList[i] == handle) { if (t.waitList[i] == handle) {
t.gprs[1] = i; t.gprs[1] = i;
break; break;
}
} }
} break;
break;
case ThreadStatus::WaitSyncAll: case ThreadStatus::WaitSyncAll:
Helpers::panic("SignalEvent: Thread on WaitSyncAll"); Helpers::panic("SignalEvent: Thread on WaitSyncAll");
break; break;
}
} }
// One-shot events get cleared once they are acquired by some thread
if (event->resetType == ResetType::OneShot)
event->fired = false;
// We must reschedule our threads if we signalled one. Some games such as FE: Awakening rely on this
// If this does not happen, we can have phenomena such as a thread waiting up a higher priority thread,
// and the higher priority thread just never running
rescheduleThreads();
} }
return true; return true;