mirror/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-02-11 06:40:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Savestates: Fix deadlock on savestate load

Browse Source
This commit is contained in:
Eladash 2023-03-11 11:51:30 +02:00 committed by Ivan
parent a41d2e43fd
commit 0beda6fa89
3 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
rpcs3/Emu/Cell/lv2/lv2.cpp
View File

@ -1218,7 +1218,7 @@ static std::deque<std::pair<u64, class cpu_thread*>> g_waiting;
// Threads which must call lv2_obj::sleep before the scheduler starts
static std::deque<class cpu_thread*> g_to_sleep;
static atomic_t<bool> g_scheduler_ready = false;
static atomic_t<u64> s_yield_frequency = 0;
static atomic_t<u64> s_max_allowed_yield_tsc = 0;
static u64 s_last_yield_tsc = 0;
@ -1596,6 +1596,7 @@ bool lv2_obj::awake_unlocked(cpu_thread* cpu, s32 prio)
void lv2_obj::cleanup()
{
g_ppu = nullptr;
g_scheduler_ready = false;
g_to_sleep.clear();
g_waiting.clear();
g_pending = 0;
@ -1606,7 +1607,7 @@ void lv2_obj::schedule_all(u64 current_time)
{
usz notify_later_idx = 0;
if (!g_pending && g_to_sleep.empty())
if (!g_pending && g_scheduler_ready)
{
auto target = +g_ppu;
@ -1727,6 +1728,12 @@ void lv2_obj::schedule_all(u64 current_time)
}
}
void lv2_obj::make_scheduler_ready()
{
g_scheduler_ready.release(true);
lv2_obj::awake_all();
}
ppu_thread_status lv2_obj::ppu_state(ppu_thread* ppu, bool lock_idm, bool lock_lv2)
{
std::optional<reader_lock> opt_lock[2];

2
rpcs3/Emu/Cell/lv2/sys_sync.h
View File

@ -242,6 +242,8 @@ public:
g_to_awake.clear();
}
static void make_scheduler_ready();
static ppu_thread_status ppu_state(ppu_thread* ppu, bool lock_idm = true, bool lock_lv2 = true);
static inline void append(cpu_thread* const thread)

2
rpcs3/Emu/System.cpp
View File

@ -2249,7 +2249,7 @@ void Emulator::FinalizeRunRequest()
idm::select<named_thread<spu_thread>>(on_select);
lv2_obj::awake_all();
lv2_obj::make_scheduler_ready();
m_state.compare_and_swap_test(system_state::starting, system_state::running);
}