|
|
@@ -103,7 +103,14 @@ void Stream::PlayNextBuffer(std::chrono::nanoseconds ns_late) {
|
|
|
|
|
|
sink_stream.EnqueueSamples(GetNumChannels(), active_buffer->GetSamples());
|
|
|
|
|
|
- core_timing.ScheduleEvent(GetBufferReleaseNS(*active_buffer) - ns_late, release_event, {});
|
|
|
+ const auto buffer_release_ns = GetBufferReleaseNS(*active_buffer);
|
|
|
+
|
|
|
+ // If ns_late is higher than the update rate ignore the delay
|
|
|
+ if (ns_late > buffer_release_ns) {
|
|
|
+ ns_late = {};
|
|
|
+ }
|
|
|
+
|
|
|
+ core_timing.ScheduleEvent(buffer_release_ns - ns_late, release_event, {});
|
|
|
}
|
|
|
|
|
|
void Stream::ReleaseActiveBuffer(std::chrono::nanoseconds ns_late) {
|