diff options
Diffstat (limited to 'src/audio/backend/miniaudio_backend.cc')
| -rw-r--r-- | src/audio/backend/miniaudio_backend.cc | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/src/audio/backend/miniaudio_backend.cc b/src/audio/backend/miniaudio_backend.cc index 312d36e..8871d10 100644 --- a/src/audio/backend/miniaudio_backend.cc +++ b/src/audio/backend/miniaudio_backend.cc @@ -12,11 +12,11 @@ // Real-time peak measured at actual playback time // Updated in audio_callback when samples are read from ring buffer -volatile float MiniaudioBackend::realtime_peak_ = 0.0f; +std::atomic<float> MiniaudioBackend::realtime_peak_{0.0f}; // Smooth playback time interpolation -volatile double MiniaudioBackend::last_callback_time_ = 0.0; -volatile int64_t MiniaudioBackend::last_callback_samples_ = 0; +std::atomic<double> MiniaudioBackend::last_callback_time_{0.0}; +std::atomic<int64_t> MiniaudioBackend::last_callback_samples_{0}; // Static callback for miniaudio (C API requirement) void MiniaudioBackend::audio_callback(ma_device* pDevice, void* pOutput, @@ -148,8 +148,10 @@ void MiniaudioBackend::audio_callback(ma_device* pDevice, void* pOutput, // Update smooth playback time tracking (absolute time, no epoch needed) struct timespec ts; clock_gettime(CLOCK_MONOTONIC, &ts); - last_callback_time_ = ts.tv_sec + ts.tv_nsec / 1e9; - last_callback_samples_ = ring_buffer->get_total_read(); + last_callback_time_.store(ts.tv_sec + ts.tv_nsec / 1e9, + std::memory_order_release); + last_callback_samples_.store(ring_buffer->get_total_read(), + std::memory_order_release); #if defined(DEBUG_LOG_RING_BUFFER) if (actually_read < samples_to_read) { @@ -280,11 +282,11 @@ void MiniaudioBackend::shutdown() { } float MiniaudioBackend::get_realtime_peak() { - return realtime_peak_; + return realtime_peak_.load(std::memory_order_acquire); } void MiniaudioBackend::get_callback_state(double* out_time, - int64_t* out_samples) { - *out_time = last_callback_time_; - *out_samples = last_callback_samples_; + int64_t* out_samples) { + *out_time = last_callback_time_.load(std::memory_order_acquire); + *out_samples = last_callback_samples_.load(std::memory_order_acquire); } |
