The-Homebrew-Cloud/skyline
2
0
Fork 0
mirror of https://github.com/skyline-emu/skyline.git synced 2024-11-06 01:05:07 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix WaitForAddress timeout mutex deadlock

Browse Source 
Calling `WaitSchedule` inside the block where `syncWaiterMutex` is locked causes a race with other threads which lock the core mutex and `syncWaiterMutex` together. This commit moves the `WaitSchedule` outside the block while simply setting a flag to wait later similar to `ConditionVariableWait`'s timeout case.

Co-authored-by: Billy Laws <blaws05@gmail.com>
This commit is contained in:
PixelyIon 2022-11-27 21:52:04 +05:30 committed by Mark Collins
parent 4df3c98225
commit 626008d8e2
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/src/main/cpp/skyline/kernel/types/KProcess.cpp
View File

@ -425,6 +425,7 @@ namespace skyline::kernel::type {
} }
if (timeout > 0 && !state.scheduler->TimedWaitSchedule(std::chrono::nanoseconds(timeout))) { if (timeout > 0 && !state.scheduler->TimedWaitSchedule(std::chrono::nanoseconds(timeout))) {
bool shouldWait{false};
{ {
std::scoped_lock lock{syncWaiterMutex}; std::scoped_lock lock{syncWaiterMutex};
auto queue{syncWaiters.equal_range(address)}; auto queue{syncWaiters.equal_range(address)};
@ -434,10 +435,15 @@ namespace skyline::kernel::type {
// We need to update the boolean flag denoting that there are no more threads waiting on this address // We need to update the boolean flag denoting that there are no more threads waiting on this address
__atomic_store_n(address, false, __ATOMIC_SEQ_CST); __atomic_store_n(address, false, __ATOMIC_SEQ_CST);
} else { } else {
// If we didn't find the thread in the queue then it must have been signalled already and we should just wait
shouldWait = true;
}
}
if (shouldWait) {
state.scheduler->WaitSchedule(false); state.scheduler->WaitSchedule(false);
return {}; return {};
} }
}
state.scheduler->InsertThread(state.thread); state.scheduler->InsertThread(state.thread);
state.scheduler->WaitSchedule(false); state.scheduler->WaitSchedule(false);