X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=mixer.h;h=ffae67a6e398687640c155ae12d8dd81c33f11e0;hb=8fe6a683cb5bc9f04555c8cb9257f33c4d356ded;hp=07a31e959fe5a21e2b268ed7f4aad11e0ac2e90a;hpb=b22d8d6b38d060ccc5dfa591712211caf9ca3968;p=nageru diff --git a/mixer.h b/mixer.h index 07a31e9..ffae67a 100644 --- a/mixer.h +++ b/mixer.h @@ -34,6 +34,7 @@ #include "timebase.h" #include "stereocompressor.h" #include "filter.h" +#include "input_state.h" class H264Encoder; class QSurface; @@ -102,7 +103,7 @@ public: typedef std::function audio_level_callback_t; + float gain_staging_db, float final_makeup_gain_db)> audio_level_callback_t; void set_audio_level_callback(audio_level_callback_t callback) { audio_level_callback = callback; @@ -168,18 +169,39 @@ public: compressor_enabled = enabled; } - void reset_meters(); + void set_gain_staging_db(float gain_db) + { + std::unique_lock lock(compressor_mutex); + level_compressor_enabled = false; + gain_staging_db = gain_db; + } - struct BufferedFrame { - RefCountedFrame frame; - unsigned field_number; - }; + void set_gain_staging_auto(bool enabled) + { + std::unique_lock lock(compressor_mutex); + level_compressor_enabled = enabled; + } - BufferedFrame get_buffered_frame(int card, int history_pos) + void set_final_makeup_gain_db(float gain_db) { - return buffered_frames[card][history_pos]; + std::unique_lock lock(compressor_mutex); + final_makeup_gain_auto = false; + final_makeup_gain = pow(10.0f, gain_db / 20.0f); } + void set_final_makeup_gain_auto(bool enabled) + { + std::unique_lock lock(compressor_mutex); + final_makeup_gain_auto = enabled; + } + + void schedule_cut() + { + should_cut = true; + } + + void reset_meters(); + private: void bm_frame(unsigned card_index, uint16_t timecode, FrameAllocator::Frame video_frame, size_t video_offset, uint16_t video_format, @@ -237,12 +259,7 @@ private: }; CaptureCard cards[MAX_CARDS]; // protected by - // For each card, the last three frames (or fields), with 0 being the - // most recent one. Note that we only need the actual history if we have - // interlaced output (for deinterlacing), so if we detect progressive input, - // we immediately clear out all history and all entries will point to the same - // frame. - BufferedFrame buffered_frames[MAX_CARDS][FRAME_HISTORY_LENGTH]; + InputState input_state; class OutputChannel { public: @@ -266,10 +283,11 @@ private: std::thread mixer_thread; std::thread audio_thread; std::atomic should_quit{false}; + std::atomic should_cut{false}; audio_level_callback_t audio_level_callback = nullptr; - std::mutex r128_mutex; - Ebu_r128_proc r128; // Under r128_mutex. + std::mutex compressor_mutex; + Ebu_r128_proc r128; // Under compressor_mutex. Resampler peak_resampler; std::atomic peak{0.0f}; @@ -278,10 +296,12 @@ private: std::atomic locut_cutoff_hz; // First compressor; takes us up to about -12 dBFS. - StereoCompressor level_compressor; - float last_gain_staging_db = 0.0f; + StereoCompressor level_compressor; // Under compressor_mutex. Used to set/override gain_staging_db if . + float gain_staging_db = 0.0f; // Under compressor_mutex. + bool level_compressor_enabled = true; // Under compressor_mutex. - static constexpr float ref_level_dbfs = -14.0f; + static constexpr float ref_level_dbfs = -14.0f; // Chosen so that we end up around 0 LU in practice. + static constexpr float ref_level_lufs = -23.0f; // 0 LU, more or less by definition. StereoCompressor limiter; std::atomic limiter_threshold_dbfs{ref_level_dbfs + 4.0f}; // 4 dB. @@ -290,6 +310,9 @@ private: std::atomic compressor_threshold_dbfs{ref_level_dbfs - 12.0f}; // -12 dB. std::atomic compressor_enabled{true}; + double final_makeup_gain = 1.0; // Under compressor_mutex. Read/write by the user. Note: Not in dB, we want the numeric precision so that we can change it slowly. + bool final_makeup_gain_auto = true; // Under compressor_mutex. + std::unique_ptr alsa; struct AudioTask {