diff options
Diffstat (limited to 'src/audio_core/stream.cpp')
| -rw-r--r-- | src/audio_core/stream.cpp | 23 |
1 files changed, 18 insertions, 5 deletions
diff --git a/src/audio_core/stream.cpp b/src/audio_core/stream.cpp index ca7cfb030..dfc4805d9 100644 --- a/src/audio_core/stream.cpp +++ b/src/audio_core/stream.cpp | |||
| @@ -59,11 +59,20 @@ Stream::State Stream::GetState() const { | |||
| 59 | return state; | 59 | return state; |
| 60 | } | 60 | } |
| 61 | 61 | ||
| 62 | s64 Stream::GetBufferReleaseCycles(const Buffer& buffer) const { | 62 | s64 Stream::GetBufferReleaseNS(const Buffer& buffer) const { |
| 63 | const std::size_t num_samples{buffer.GetSamples().size() / GetNumChannels()}; | 63 | const std::size_t num_samples{buffer.GetSamples().size() / GetNumChannels()}; |
| 64 | const auto us = | 64 | const auto ns = |
| 65 | std::chrono::microseconds((static_cast<u64>(num_samples) * 1000000) / sample_rate); | 65 | std::chrono::nanoseconds((static_cast<u64>(num_samples) * 1000000000ULL) / sample_rate); |
| 66 | return Core::Timing::usToCycles(us); | 66 | return ns.count(); |
| 67 | } | ||
| 68 | |||
| 69 | s64 Stream::GetBufferReleaseNSHostTiming(const Buffer& buffer) const { | ||
| 70 | const std::size_t num_samples{buffer.GetSamples().size() / GetNumChannels()}; | ||
| 71 | /// DSP signals before playing the last sample, in HLE we emulate this in this way | ||
| 72 | s64 base_samples = std::max<s64>(static_cast<s64>(num_samples) - 1, 0); | ||
| 73 | const auto ns = | ||
| 74 | std::chrono::nanoseconds((static_cast<u64>(base_samples) * 1000000000ULL) / sample_rate); | ||
| 75 | return ns.count(); | ||
| 67 | } | 76 | } |
| 68 | 77 | ||
| 69 | static void VolumeAdjustSamples(std::vector<s16>& samples, float game_volume) { | 78 | static void VolumeAdjustSamples(std::vector<s16>& samples, float game_volume) { |
| @@ -105,7 +114,11 @@ void Stream::PlayNextBuffer() { | |||
| 105 | 114 | ||
| 106 | sink_stream.EnqueueSamples(GetNumChannels(), active_buffer->GetSamples()); | 115 | sink_stream.EnqueueSamples(GetNumChannels(), active_buffer->GetSamples()); |
| 107 | 116 | ||
| 108 | core_timing.ScheduleEvent(GetBufferReleaseCycles(*active_buffer), release_event, {}); | 117 | if (core_timing.IsHostTiming()) { |
| 118 | core_timing.ScheduleEvent(GetBufferReleaseNSHostTiming(*active_buffer), release_event, {}); | ||
| 119 | } else { | ||
| 120 | core_timing.ScheduleEvent(GetBufferReleaseNS(*active_buffer), release_event, {}); | ||
| 121 | } | ||
| 109 | } | 122 | } |
| 110 | 123 | ||
| 111 | void Stream::ReleaseActiveBuffer() { | 124 | void Stream::ReleaseActiveBuffer() { |