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

Refactor ExAcquireReadWriteLockShared to remove duplicate code.

This commit is contained in:
Fisherman166 2020-05-26 09:20:15 -07:00
parent a679073ec6
commit b72be80b88
1 changed files with 13 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/core/kernel/exports/EmuKrnlEx.cpp
View File

@ -181,40 +181,22 @@ XBSYSAPI EXPORTNUM(13) xboxkrnl::VOID NTAPI xboxkrnl::ExAcquireReadWriteLockShar
LOG_FUNC_ONE_ARG(ReadWriteLock); LOG_FUNC_ONE_ARG(ReadWriteLock);
bool interrupt_mode = DisableInterrupts(); bool interrupt_mode = DisableInterrupts();
bool must_wait_on_active_write = ReadWriteLock->ReadersEntryCount == 0;
bool must_wait_on_queued_write = (ReadWriteLock->ReadersEntryCount != 0) && (ReadWriteLock->WritersWaitingCount != 0);
bool must_wait = must_wait_on_active_write || must_wait_on_queued_write;
ReadWriteLock->LockCount++; ReadWriteLock->LockCount++;
if (ReadWriteLock->LockCount != 0) { if ((ReadWriteLock->LockCount != 0) && must_wait) {
if (ReadWriteLock->ReadersEntryCount == 0) { ReadWriteLock->ReadersWaitingCount++;
ReadWriteLock->ReadersWaitingCount++; RestoreInterruptMode(interrupt_mode);
RestoreInterruptMode(interrupt_mode);
#if 0 //FIXME - Enable once KeReleaseSempahore is implemented (used in ExFreeReadWriteLock for Sharedlocks). #if 0 //FIXME - Enable once KeReleaseSempahore is implemented (used in ExFreeReadWriteLock for Sharedlocks).
KeWaitForSingleObject( KeWaitForSingleObject(
&ReadWriteLock->ReaderSemaphore, &ReadWriteLock->ReaderSemaphore,
Executive, Executive,
0, 0,
0, 0,
0 0
); );
#endif #endif
}
else {
if (ReadWriteLock->WritersWaitingCount == 0) {
ReadWriteLock->ReadersEntryCount++;
RestoreInterruptMode(interrupt_mode);
}
else {
ReadWriteLock->ReadersWaitingCount++;
RestoreInterruptMode(interrupt_mode);
#if 0 //FIXME - Enable once KeReleaseSempahore is implemented (used in ExFreeReadWriteLock for Sharedlocks).
KeWaitForSingleObject(
&ReadWriteLock->ReaderSemaphore,
Executive,
0,
0,
0
);
#endif
}
}
} }
else { else {
ReadWriteLock->ReadersEntryCount++; ReadWriteLock->ReadersEntryCount++;