Aphcity/suyu
1
0
Fork 0
forked from suyu/suyu
Code Pull requests Activity Actions

Merge pull request #10221 from Kelebek1/partial_dsp_revert

Browse source 
Add a 5ms tiemout to the DSP processing wait
This commit is contained in:
bunnei 2023-05-25 21:34:50 -07:00 committed by GitHub
commit 83b502c08c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 12 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/audio_core/renderer/adsp/audio_renderer.cpp
View file

@ -154,6 +154,11 @@ void AudioRenderer::ThreadFunc() {
return; return;
case RenderMessage::AudioRenderer_Render: { case RenderMessage::AudioRenderer_Render: {
if (system.IsShuttingDown()) [[unlikely]] {
std::this_thread::sleep_for(std::chrono::milliseconds(5));
mailbox->ADSPSendMessage(RenderMessage::AudioRenderer_RenderResponse);
continue;
}
std::array<bool, MaxRendererSessions> buffers_reset{}; std::array<bool, MaxRendererSessions> buffers_reset{};
std::array<u64, MaxRendererSessions> render_times_taken{}; std::array<u64, MaxRendererSessions> render_times_taken{};
const auto start_time{system.CoreTiming().GetClockTicks()}; const auto start_time{system.CoreTiming().GetClockTicks()};

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

@ -27,7 +27,7 @@ bool SystemManager::InitializeUnsafe() {
if (!active) { if (!active) {
if (adsp.Start()) { if (adsp.Start()) {
active = true; active = true;
thread = std::jthread([this](std::stop_token stop_token) { ThreadFunc(); }); thread = std::jthread([this](std::stop_token stop_token) { ThreadFunc(stop_token); });
} }
} }
@ -39,8 +39,7 @@ void SystemManager::Stop() {
return; return;
} }
active = false; active = false;
update.store(true); thread.request_stop();
update.notify_all();
thread.join(); thread.join();
adsp.Stop(); adsp.Stop();
} }
@ -85,12 +84,12 @@ bool SystemManager::Remove(System& system_) {
return true; return true;
} }
void SystemManager::ThreadFunc() { void SystemManager::ThreadFunc(std::stop_token stop_token) {
static constexpr char name[]{"AudioRenderSystemManager"}; static constexpr char name[]{"AudioRenderSystemManager"};
MicroProfileOnThreadCreate(name); MicroProfileOnThreadCreate(name);
Common::SetCurrentThreadName(name); Common::SetCurrentThreadName(name);
Common::SetCurrentThreadPriority(Common::ThreadPriority::High); Common::SetCurrentThreadPriority(Common::ThreadPriority::High);
while (active) { while (active && !stop_token.stop_requested()) {
{ {
std::scoped_lock l{mutex1}; std::scoped_lock l{mutex1};

10
src/audio_core/renderer/system_manager.h
View file

@ -66,13 +66,7 @@ private:
/** /**
* Main thread responsible for command generation. * Main thread responsible for command generation.
*/ */
void ThreadFunc(); void ThreadFunc(std::stop_token stop_token);
enum class StreamState {
Filling,
Steady,
Draining,
};
/// Core system /// Core system
Core::System& core; Core::System& core;
@ -90,8 +84,6 @@ private:
ADSP::ADSP& adsp; ADSP::ADSP& adsp;
/// AudioRenderer mailbox for communication /// AudioRenderer mailbox for communication
ADSP::AudioRenderer_Mailbox* mailbox{}; ADSP::AudioRenderer_Mailbox* mailbox{};
/// Atomic for main thread to wait on
std::atomic<bool> update{};
}; };
} // namespace AudioCore::AudioRenderer } // namespace AudioCore::AudioRenderer

4
src/audio_core/sink/sink_stream.cpp
View file

@ -271,8 +271,8 @@ u64 SinkStream::GetExpectedPlayedSampleCount() {
void SinkStream::WaitFreeSpace() { void SinkStream::WaitFreeSpace() {
std::unique_lock lk{release_mutex}; std::unique_lock lk{release_mutex};
release_cv.wait( release_cv.wait_for(lk, std::chrono::milliseconds(5),
lk, [this]() { return queued_buffers < max_queue_size || system.IsShuttingDown(); }); [this]() { return queued_buffers < max_queue_size; });
} }
} // namespace AudioCore::Sink } // namespace AudioCore::Sink