mirrors/Ryujinx
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Check that the mutex address matches before waking a waiting thread

Browse source
This commit is contained in:
gdkchan 2018-04-21 14:15:36 -03:00
parent 3fae7e30e7
commit babfcde885
1 changed files with 30 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
Ryujinx.Core/OsHle/Kernel/SvcThreadSync.cs
View file

@ -187,31 +187,41 @@ namespace Ryujinx.Core.OsHle.Kernel
return false;
}
KThread OwnerThread = CurrThread.NextMutexThread;
CurrThread.NextMutexThread = null;
if (OwnerThread != null)
lock (CurrThread)
{
int HasListeners = OwnerThread.NextMutexThread != null ? MutexHasListenersMask : 0;
//This is the new thread that will not own the mutex.
//If no threads are waiting for the lock, then it should be null.
KThread OwnerThread = CurrThread.NextMutexThread;
Process.Memory.WriteInt32(MutexAddress, HasListeners | OwnerThread.WaitHandle);
while (OwnerThread?.NextMutexThread != null && OwnerThread.MutexAddress != MutexAddress)
{
OwnerThread = OwnerThread.NextMutexThread;
}
OwnerThread.WaitHandle = 0;
OwnerThread.MutexAddress = 0;
OwnerThread.CondVarAddress = 0;
CurrThread.NextMutexThread = null;
OwnerThread.ResetPriority();
if (OwnerThread != null)
{
int HasListeners = OwnerThread.NextMutexThread != null ? MutexHasListenersMask : 0;
Process.Scheduler.WakeUp(OwnerThread);
Process.Memory.WriteInt32(MutexAddress, HasListeners | OwnerThread.WaitHandle);
return true;
}
else
{
Process.Memory.WriteInt32(MutexAddress, 0);
OwnerThread.WaitHandle = 0;
OwnerThread.MutexAddress = 0;
OwnerThread.CondVarAddress = 0;
return false;
OwnerThread.ResetPriority();
Process.Scheduler.WakeUp(OwnerThread);
return true;
}
else
{
Process.Memory.WriteInt32(MutexAddress, 0);
return false;
}
}
}
@ -246,6 +256,8 @@ namespace Ryujinx.Core.OsHle.Kernel
DoInsert &= CurrThread != WaitThread;
}
//Only insert if the node doesn't already exist in the list.
//This prevents circular references.
if (DoInsert)
{
if (WaitThread.NextCondVarThread != null)