mirror of
https://github.com/dolphin-emu/dolphin.git
synced 2026-01-30 11:03:31 +00:00
a14c88ba67
Yellow squiggly lines begone! Done automatically on .cpp files through `run-clang-tidy`, with manual corrections to the mistakes. If an import is directly used, but is technically unnecessary since it's recursively imported by something else, it is *not* removed. The tool doesn't touch .h files, so I did some of them by hand while fixing errors due to old recursive imports. Not everything is removed, but the cleanup should be substantial enough. Because this done on Linux, code that isn't used on it is mostly untouched. (Hopefully no open PR is depending on these imports...)
149 lines
3.5 KiB
C++
149 lines
3.5 KiB
C++
// Copyright 2017 Dolphin Emulator Project
|
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
|
|
#include "AudioCommon/CubebStream.h"
|
|
|
|
#include <cubeb/cubeb.h>
|
|
|
|
#include "AudioCommon/CubebUtils.h"
|
|
#include "Common/CommonTypes.h"
|
|
#include "Common/Logging/Log.h"
|
|
#include "Core/Config/MainSettings.h"
|
|
|
|
#ifdef _WIN32
|
|
#include <Objbase.h>
|
|
#endif
|
|
|
|
// ~10 ms - needs to be at least 240 for surround
|
|
constexpr u32 BUFFER_SAMPLES = 512;
|
|
|
|
long CubebStream::DataCallback(cubeb_stream* stream, void* user_data, const void* /*input_buffer*/,
|
|
void* output_buffer, long num_frames)
|
|
{
|
|
const auto* const self = static_cast<CubebStream*>(user_data);
|
|
|
|
if (self->m_stereo)
|
|
self->m_mixer->Mix(static_cast<short*>(output_buffer), num_frames);
|
|
else
|
|
self->m_mixer->MixSurround(static_cast<float*>(output_buffer), num_frames);
|
|
|
|
return num_frames;
|
|
}
|
|
|
|
void CubebStream::StateCallback(cubeb_stream* stream, void* user_data, cubeb_state state)
|
|
{
|
|
}
|
|
|
|
CubebStream::CubebStream()
|
|
#ifdef _WIN32
|
|
: m_work_queue("Cubeb Worker")
|
|
{
|
|
m_work_queue.PushBlocking([this] {
|
|
auto const result = CoInitializeEx(nullptr, COINIT_MULTITHREADED | COINIT_DISABLE_OLE1DDE);
|
|
m_coinit_success = result == S_OK;
|
|
m_should_couninit = result == S_OK || result == S_FALSE;
|
|
});
|
|
}
|
|
#else
|
|
= default;
|
|
#endif
|
|
|
|
bool CubebStream::Init()
|
|
{
|
|
bool return_value = false;
|
|
|
|
#ifdef _WIN32
|
|
if (!m_coinit_success)
|
|
return false;
|
|
m_work_queue.PushBlocking([this, &return_value] {
|
|
#endif
|
|
m_ctx = CubebUtils::GetContext();
|
|
if (m_ctx)
|
|
{
|
|
m_stereo = !Config::ShouldUseDPL2Decoder();
|
|
|
|
cubeb_stream_params params{};
|
|
params.rate = m_mixer->GetSampleRate();
|
|
if (m_stereo)
|
|
{
|
|
params.channels = 2;
|
|
params.format = CUBEB_SAMPLE_S16NE;
|
|
params.layout = CUBEB_LAYOUT_STEREO;
|
|
}
|
|
else
|
|
{
|
|
params.channels = 6;
|
|
params.format = CUBEB_SAMPLE_FLOAT32NE;
|
|
params.layout = CUBEB_LAYOUT_3F2_LFE;
|
|
}
|
|
|
|
u32 minimum_latency = 0;
|
|
if (cubeb_get_min_latency(m_ctx.get(), ¶ms, &minimum_latency) != CUBEB_OK)
|
|
ERROR_LOG_FMT(AUDIO, "Error getting minimum latency");
|
|
INFO_LOG_FMT(AUDIO, "Minimum latency: {} frames", minimum_latency);
|
|
|
|
return_value =
|
|
cubeb_stream_init(m_ctx.get(), &m_stream, "Dolphin Audio Output", nullptr, nullptr,
|
|
nullptr, ¶ms, std::max(BUFFER_SAMPLES, minimum_latency),
|
|
DataCallback, StateCallback, this) == CUBEB_OK;
|
|
}
|
|
|
|
#ifdef _WIN32
|
|
});
|
|
#endif
|
|
|
|
return return_value;
|
|
}
|
|
|
|
bool CubebStream::SetRunning(bool running)
|
|
{
|
|
bool return_value = false;
|
|
|
|
#ifdef _WIN32
|
|
if (!m_coinit_success)
|
|
return false;
|
|
m_work_queue.PushBlocking([this, running, &return_value] {
|
|
#endif
|
|
if (running)
|
|
return_value = cubeb_stream_start(m_stream) == CUBEB_OK;
|
|
else
|
|
return_value = cubeb_stream_stop(m_stream) == CUBEB_OK;
|
|
#ifdef _WIN32
|
|
});
|
|
#endif
|
|
|
|
return return_value;
|
|
}
|
|
|
|
CubebStream::~CubebStream()
|
|
{
|
|
#ifdef _WIN32
|
|
m_work_queue.PushBlocking([this] {
|
|
#endif
|
|
cubeb_stream_stop(m_stream);
|
|
cubeb_stream_destroy(m_stream);
|
|
#ifdef _WIN32
|
|
if (m_should_couninit)
|
|
{
|
|
m_should_couninit = false;
|
|
CoUninitialize();
|
|
}
|
|
m_coinit_success = false;
|
|
});
|
|
#endif
|
|
m_ctx.reset();
|
|
}
|
|
|
|
void CubebStream::SetVolume(int volume)
|
|
{
|
|
#ifdef _WIN32
|
|
if (!m_coinit_success)
|
|
return;
|
|
m_work_queue.PushBlocking([this, volume] {
|
|
#endif
|
|
cubeb_stream_set_volume(m_stream, volume / 100.0f);
|
|
#ifdef _WIN32
|
|
});
|
|
#endif
|
|
}
|