archive/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-07-03 13:31:27 +12:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

vm: Fix writer lock leak

Browse source
This commit is contained in:
Eladash 2024-03-27 10:36:00 +02:00 • committed by Elad Ashkenazi
parent 4594c912a6
commit 8588b2b11a
3 changed files with 22 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

6
rpcs3/Emu/Cell/PPUThread.cpp
View file

@ -3376,6 +3376,8 @@ static bool ppu_store_reservation(ppu_thread& ppu, u32 addr, u64 reg_value)
//auto& cline_data = vm::_ref<spu_rdata_t>(addr); //auto& cline_data = vm::_ref<spu_rdata_t>(addr);
data += 0; data += 0;
auto range_lock = vm::alloc_range_lock();
{
rsx::reservation_lock rsx_lock(addr, 128); rsx::reservation_lock rsx_lock(addr, 128);
auto& super_data = *vm::get_super_ptr<spu_rdata_t>(addr); auto& super_data = *vm::get_super_ptr<spu_rdata_t>(addr);
@ -3383,7 +3385,7 @@ static bool ppu_store_reservation(ppu_thread& ppu, u32 addr, u64 reg_value)
{ {
// Full lock (heavyweight) // Full lock (heavyweight)
// TODO: vm::check_addr // TODO: vm::check_addr
vm::writer_lock lock(addr); vm::writer_lock lock(addr, range_lock);
if (cmp_rdata(ppu.rdata, super_data)) if (cmp_rdata(ppu.rdata, super_data))
{ {
@ -3395,6 +3397,8 @@ static bool ppu_store_reservation(ppu_thread& ppu, u32 addr, u64 reg_value)
res -= 64; res -= 64;
return false; return false;
}(); }();
}
vm::free_range_lock(range_lock);
return success; return success;
} }

5
rpcs3/Emu/Cell/SPUThread.cpp
View file

@ -448,11 +448,6 @@ namespace vm
{ {
if (range_lock) if (range_lock)
{ {
if (!*range_lock)
{
return;
}
g_range_lock_bits[1] &= ~(1ull << (range_lock - g_range_lock_set)); g_range_lock_bits[1] &= ~(1ull << (range_lock - g_range_lock_set));
range_lock->release(0); range_lock->release(0);
return; return;

6
rpcs3/Emu/Memory/vm.cpp
View file

@ -473,13 +473,13 @@ namespace vm
} }
} }
bool to_prepare_memory = addr >= 0x10000; bool to_prepare_memory = true;
for (u64 i = 0;; i++) for (u64 i = 0;; i++)
{ {
auto& bits = get_range_lock_bits(true); auto& bits = get_range_lock_bits(true);
if (!range_lock || addr < 0x10000) if (!range_lock)
{ {
if (!bits && bits.compare_and_swap_test(0, u64{umax})) if (!bits && bits.compare_and_swap_test(0, u64{umax}))
{ {
@ -521,7 +521,7 @@ namespace vm
} }
} }
if (addr >= 0x10000) if (range_lock)
{ {
perf_meter<"SUSPEND"_u64> perf0; perf_meter<"SUSPEND"_u64> perf0;