X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=audio_mixer.cpp;h=e4d4cff4b86222e41d6b0d8181b8d519a1f1b6a1;hb=aa2e0a6abcf9c3b38dd1ce26b96f336e33956be8;hp=e4eb495953baaa49cd487f2b5e16960857d88efb;hpb=e65bea1cd01cba642bbff2a7f79977196b2a2b42;p=nageru

diff --git a/audio_mixer.cpp b/audio_mixer.cpp
index e4eb495..e4d4cff 100644
--- a/audio_mixer.cpp
+++ b/audio_mixer.cpp
@@ -1,19 +1,25 @@
 #include "audio_mixer.h"
 
 #include <assert.h>
-#include <endian.h>
 #include <bmusb/bmusb.h>
-#include <stdio.h>
 #include <endian.h>
-#include <cmath>
-#include <limits>
-#ifdef __SSE__
+#include <math.h>
+#ifdef __SSE2__
 #include <immintrin.h>
 #endif
+#include <stdbool.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <algorithm>
+#include <chrono>
+#include <cmath>
+#include <cstddef>
+#include <limits>
+#include <utility>
 
 #include "db.h"
 #include "flags.h"
-#include "mixer.h"
 #include "state.pb.h"
 #include "timebase.h"
 
@@ -319,6 +325,7 @@ AudioMixer::BusSettings AudioMixer::get_default_bus_settings()
 {
 	BusSettings settings;
 	settings.fader_volume_db = 0.0f;
+	settings.muted = false;
 	settings.locut_enabled = global_flags.locut_enabled;
 	for (unsigned band_index = 0; band_index < NUM_EQ_BANDS; ++band_index) {
 		settings.eq_level_db[band_index] = 0.0f;
@@ -335,6 +342,7 @@ AudioMixer::BusSettings AudioMixer::get_bus_settings(unsigned bus_index) const
 	lock_guard<timed_mutex> lock(audio_mutex);
 	BusSettings settings;
 	settings.fader_volume_db = fader_volume_db[bus_index];
+	settings.muted = mute[bus_index];
 	settings.locut_enabled = locut_enabled[bus_index];
 	for (unsigned band_index = 0; band_index < NUM_EQ_BANDS; ++band_index) {
 		settings.eq_level_db[band_index] = eq_level_db[bus_index][band_index];
@@ -350,6 +358,7 @@ void AudioMixer::set_bus_settings(unsigned bus_index, const AudioMixer::BusSetti
 {
 	lock_guard<timed_mutex> lock(audio_mutex);
 	fader_volume_db[bus_index] = settings.fader_volume_db;
+	mute[bus_index] = settings.muted;
 	locut_enabled[bus_index] = settings.locut_enabled;
 	for (unsigned band_index = 0; band_index < NUM_EQ_BANDS; ++band_index) {
 		eq_level_db[bus_index][band_index] = settings.eq_level_db[band_index];
@@ -403,7 +412,7 @@ void AudioMixer::find_sample_src_from_device(const map<DeviceSpec, vector<float>
 void AudioMixer::fill_audio_bus(const map<DeviceSpec, vector<float>> &samples_card, const InputMapping::Bus &bus, unsigned num_samples, float *output)
 {
 	if (bus.device.type == InputSourceType::SILENCE) {
-		memset(output, 0, num_samples * sizeof(*output));
+		memset(output, 0, num_samples * 2 * sizeof(*output));
 	} else {
 		assert(bus.device.type == InputSourceType::CAPTURE_CARD ||
 		       bus.device.type == InputSourceType::ALSA_INPUT);
@@ -574,13 +583,12 @@ vector<float> AudioMixer::get_output(double pts, unsigned num_samples, Resamplin
 	// (half-time of 30 seconds).
 	double target_loudness_factor, alpha;
 	double loudness_lu = r128.loudness_M() - ref_level_lufs;
-	double current_makeup_lu = to_db(final_makeup_gain);
 	target_loudness_factor = final_makeup_gain * from_db(-loudness_lu);
 
-	// If we're outside +/- 5 LU uncorrected, we don't count it as
+	// If we're outside +/- 5 LU (after correction), we don't count it as
 	// a normal signal (probably silence) and don't change the
 	// correction factor; just apply what we already have.
-	if (fabs(loudness_lu - current_makeup_lu) >= 5.0 || !final_makeup_gain_auto) {
+	if (fabs(loudness_lu) >= 5.0 || !final_makeup_gain_auto) {
 		alpha = 0.0;
 	} else {
 		// Formula adapted from
@@ -683,13 +691,14 @@ void AudioMixer::add_bus_to_master(unsigned bus_index, const vector<float> &samp
 	assert(samples_bus.size() == samples_out->size());
 	assert(samples_bus.size() % 2 == 0);
 	unsigned num_samples = samples_bus.size() / 2;
-	if (fabs(fader_volume_db[bus_index] - last_fader_volume_db[bus_index]) > 1e-3) {
+	const float new_volume_db = mute[bus_index] ? -90.0f : fader_volume_db[bus_index].load();
+	if (fabs(new_volume_db - last_fader_volume_db[bus_index]) > 1e-3) {
 		// The volume has changed; do a fade over the course of this frame.
 		// (We might have some numerical issues here, but it seems to sound OK.)
 		// For the purpose of fading here, the silence floor is set to -90 dB
 		// (the fader only goes to -84).
 		float old_volume = from_db(max<float>(last_fader_volume_db[bus_index], -90.0f));
-		float volume = from_db(max<float>(fader_volume_db[bus_index], -90.0f));
+		float volume = from_db(max<float>(new_volume_db, -90.0f));
 
 		float volume_inc = pow(volume / old_volume, 1.0 / num_samples);
 		volume = old_volume;
@@ -706,8 +715,8 @@ void AudioMixer::add_bus_to_master(unsigned bus_index, const vector<float> &samp
 				volume *= volume_inc;
 			}
 		}
-	} else {
-		float volume = from_db(fader_volume_db[bus_index]);
+	} else if (new_volume_db > -90.0f) {
+		float volume = from_db(new_volume_db);
 		if (bus_index == 0) {
 			for (unsigned i = 0; i < num_samples; ++i) {
 				(*samples_out)[i * 2 + 0] = samples_bus[i * 2 + 0] * volume;
@@ -721,13 +730,13 @@ void AudioMixer::add_bus_to_master(unsigned bus_index, const vector<float> &samp
 		}
 	}
 
-	last_fader_volume_db[bus_index] = fader_volume_db[bus_index];
+	last_fader_volume_db[bus_index] = new_volume_db;
 }
 
 void AudioMixer::measure_bus_levels(unsigned bus_index, const vector<float> &left, const vector<float> &right)
 {
 	assert(left.size() == right.size());
-	const float volume = from_db(fader_volume_db[bus_index]);
+	const float volume = mute[bus_index] ? 0.0f : from_db(fader_volume_db[bus_index]);
 	const float peak_levels[2] = {
 		find_peak(left.data(), left.size()) * volume,
 		find_peak(right.data(), right.size()) * volume
@@ -987,6 +996,12 @@ InputMapping AudioMixer::get_input_mapping() const
 	return input_mapping;
 }
 
+unsigned AudioMixer::num_buses() const
+{
+	lock_guard<timed_mutex> lock(audio_mutex);
+	return input_mapping.buses.size();
+}
+
 void AudioMixer::reset_peak(unsigned bus_index)
 {
 	lock_guard<timed_mutex> lock(audio_mutex);