ShuriZma
/
xenia-canary
mirror of https://github.com/xenia-canary/xenia-canary.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[Kernel/Threads] add shared version of locks to fix a crash when games try to unlock things that didn't get locked in the first place

This commit is contained in:
randprint 2020-10-20 23:24:35 -04:00
parent 0afcd8769b
commit 25894c4083
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/xenia/kernel/xboxkrnl/xboxkrnl_threading.cc
View File

@ -1175,6 +1175,7 @@ void ExInitializeReadWriteLock(pointer_t<X_ERWLOCK> lock_ptr) {
DECLARE_XBOXKRNL_EXPORT1(ExInitializeReadWriteLock, kThreading, kImplemented);
void ExAcquireReadWriteLockExclusive(pointer_t<X_ERWLOCK> lock_ptr) {
XELOGD("ExAcquireReadWriteLockExclusive"); // " lock_ptr:(%X)", lock_ptr);
auto old_irql = xeKeKfAcquireSpinLock(&lock_ptr->spin_lock);
lock_ptr->lock_count++;
xeKeKfReleaseSpinLock(&lock_ptr->spin_lock, old_irql);
@ -1189,7 +1190,43 @@ void ExAcquireReadWriteLockExclusive(pointer_t<X_ERWLOCK> lock_ptr) {
DECLARE_XBOXKRNL_EXPORT3(ExAcquireReadWriteLockExclusive, kThreading,
kImplemented, kBlocking, kSketchy);
void ExAcquireReadWriteLockShared(pointer_t<X_ERWLOCK> lock_ptr) {
XELOGD("ExAcquireReadWriteLockShared"); // lock_ptr:(:X)", lock_ptr);
auto old_irql = xeKeKfAcquireSpinLock(&lock_ptr->spin_lock);
lock_ptr->lock_count++;
xeKeKfReleaseSpinLock(&lock_ptr->spin_lock, old_irql);
if (!lock_ptr->lock_count) {
return;
}
lock_ptr->writers_waiting_count++;
xeKeWaitForSingleObject(&lock_ptr->writer_event, 0, 0, 1, nullptr);
}
DECLARE_XBOXKRNL_EXPORT3(ExAcquireReadWriteLockShared, kThreading,
kImplemented, kBlocking, kHighFrequency);
void ExTryToAcquireReadWriteLockShared(pointer_t<X_ERWLOCK> lock_ptr) {
XELOGD("ExAcquireReadWriteLockShared"); // lock_ptr:(:X)", lock_ptr);
auto old_irql = xeKeKfAcquireSpinLock(&lock_ptr->spin_lock);
lock_ptr->lock_count++;
xeKeKfReleaseSpinLock(&lock_ptr->spin_lock, old_irql);
if (!lock_ptr->lock_count) {
return;
}
lock_ptr->writers_waiting_count++;
xeKeWaitForSingleObject(&lock_ptr->writer_event, 0, 0, 1, nullptr);
}
DECLARE_XBOXKRNL_EXPORT3(ExTryToAcquireReadWriteLockShared, kThreading,
kImplemented, kBlocking, kHighFrequency);
void ExReleaseReadWriteLock(pointer_t<X_ERWLOCK> lock_ptr) {
XELOGD("ExReleaseReadWriteLock"); // lock_ptr: (:X)", lock_ptr);
auto old_irql = xeKeKfAcquireSpinLock(&lock_ptr->spin_lock);
lock_ptr->lock_count--;