RPCS3/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2024-11-22 10:42:36 +01:00
Code Issues Releases Wiki Activity

Savestates/SPU LLVM: Improve saving performance

Browse Source
This commit is contained in:
Eladash 2022-08-25 10:27:51 +03:00 committed by kd-11
parent 1fc0191311
commit 506b9deec5
2 changed files with 26 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Utilities/Thread.h
View File

@ -635,16 +635,16 @@ public:
// Join thread by thread_state::finished // Join thread by thread_state::finished
named_thread& operator=(thread_state s) named_thread& operator=(thread_state s)
{ {
if constexpr (std::is_assignable_v<Context&, thread_state>)
{
static_cast<Context&>(*this) = s;
}
if (s >= thread_state::aborting && thread::m_sync.fetch_op([](u64& v){ return !(v & 3) && (v |= 1); }).second) if (s >= thread_state::aborting && thread::m_sync.fetch_op([](u64& v){ return !(v & 3) && (v |= 1); }).second)
{ {
thread::m_sync.notify_one(1); thread::m_sync.notify_one(1);
} }
if constexpr (std::is_assignable_v<Context&, thread_state>)
{
static_cast<Context&>(*this) = s;
}
if (s == thread_state::finished) if (s == thread_state::finished)
{ {
// This participates in emulation stopping, use destruction-alike semantics // This participates in emulation stopping, use destruction-alike semantics

23
rpcs3/Emu/Cell/SPURecompiler.cpp
View File

@ -12,6 +12,7 @@
#include "Utilities/StrUtil.h" #include "Utilities/StrUtil.h"
#include "Utilities/JIT.h" #include "Utilities/JIT.h"
#include "util/init_mutex.hpp" #include "util/init_mutex.hpp"
#include "util/shared_ptr.hpp"
#include "SPUThread.h" #include "SPUThread.h"
#include "SPUAnalyser.h" #include "SPUAnalyser.h"
@ -10647,6 +10648,7 @@ struct spu_llvm
{ {
// Workload // Workload
lf_queue<std::pair<const u64, spu_item*>> registered; lf_queue<std::pair<const u64, spu_item*>> registered;
atomic_ptr<named_thread_group<spu_llvm_worker>> m_workers;
spu_llvm() spu_llvm()
{ {
@ -10716,7 +10718,9 @@ struct spu_llvm
u32 worker_index = 0; u32 worker_index = 0;
named_thread_group<spu_llvm_worker> workers("SPUW.", worker_count); m_workers = make_single<named_thread_group<spu_llvm_worker>>("SPUW.", worker_count);
auto workers_ptr = m_workers.load();
auto& workers = *workers_ptr;
while (thread_ctrl::state() != thread_state::aborting) while (thread_ctrl::state() != thread_state::aborting)
{ {
@ -10769,12 +10773,27 @@ struct spu_llvm
static_cast<void>(prof_mutex.init_always([&]{ samples.clear(); })); static_cast<void>(prof_mutex.init_always([&]{ samples.clear(); }));
m_workers.reset();
for (u32 i = 0; i < worker_count; i++) for (u32 i = 0; i < worker_count; i++)
{ {
(workers.begin() + i)->registered.push(0, nullptr); (workers.begin() + i)->operator=(thread_state::aborting);
} }
} }
spu_llvm& operator=(thread_state)
{
if (const auto workers = m_workers.load())
{
for (u32 i = 0; i < workers->size(); i++)
{
(workers->begin() + i)->operator=(thread_state::aborting);
}
}
return *this;
}
static constexpr auto thread_name = "SPU LLVM"sv; static constexpr auto thread_name = "SPU LLVM"sv;
}; };