dburr/eden
1
0
Fork 0
mirror of https://git.eden-emu.dev/eden-emu/eden.git synced 2025-07-22 10:25:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rework ADSP into a wrapper for apps

Browse source
This commit is contained in:
Kelebek1 2023-08-31 15:09:15 +01:00
parent f6879dce96
commit de326e42bb
173 changed files with 1059 additions and 1265 deletions
Download patch file Download diff file Expand all files Collapse all files

30
src/audio_core/renderer/system_manager.cpp
View file

@ -3,8 +3,8 @@
#include <chrono>
#include "audio_core/adsp/adsp.h"
#include "audio_core/audio_core.h"
#include "audio_core/renderer/adsp/adsp.h"
#include "audio_core/renderer/system_manager.h"
#include "common/microprofile.h"
#include "common/thread.h"
@ -14,24 +14,21 @@
MICROPROFILE_DEFINE(Audio_RenderSystemManager, "Audio", "Render System Manager",
MP_RGB(60, 19, 97));
namespace AudioCore::AudioRenderer {
namespace AudioCore::Renderer {
SystemManager::SystemManager(Core::System& core_)
: core{core_}, adsp{core.AudioCore().GetADSP()}, mailbox{adsp.GetRenderMailbox()} {}
: core{core_}, audio_renderer{core.AudioCore().ADSP().AudioRenderer()} {}
SystemManager::~SystemManager() {
Stop();
}
bool SystemManager::InitializeUnsafe() {
void SystemManager::InitializeUnsafe() {
if (!active) {
if (adsp.Start()) {
active = true;
thread = std::jthread([this](std::stop_token stop_token) { ThreadFunc(stop_token); });
}
active = true;
audio_renderer.Start();
thread = std::jthread([this](std::stop_token stop_token) { ThreadFunc(stop_token); });
}
return adsp.GetState() == ADSP::State::Started;
}
void SystemManager::Stop() {
@ -41,7 +38,7 @@ void SystemManager::Stop() {
active = false;
thread.request_stop();
thread.join();
adsp.Stop();
audio_renderer.Stop();
}
bool SystemManager::Add(System& system_) {
@ -55,10 +52,7 @@ bool SystemManager::Add(System& system_) {
{
std::scoped_lock l{mutex1};
if (systems.empty()) {
if (!InitializeUnsafe()) {
LOG_ERROR(Service_Audio, "Failed to start the AudioRenderer SystemManager");
return false;
}
InitializeUnsafe();
}
}
@ -100,9 +94,9 @@ void SystemManager::ThreadFunc(std::stop_token stop_token) {
}
}
adsp.Signal();
adsp.Wait();
audio_renderer.Signal();
audio_renderer.Wait();
}
}
} // namespace AudioCore::AudioRenderer
} // namespace AudioCore::Renderer