allow to query export profile type
[ardour.git] / libs / ardour / export_graph_builder.cc
index d23763a5677fc728b8d31a3b413aad53c71b6b9a..96b0853122b807efcbbd92995cc31f1445a169e4 100644 (file)
 #include "audiographer/general/normalizer.h"
 #include "audiographer/general/analyser.h"
 #include "audiographer/general/peak_reader.h"
+#include "audiographer/general/loudness_reader.h"
 #include "audiographer/general/sample_format_converter.h"
 #include "audiographer/general/sr_converter.h"
 #include "audiographer/general/silence_trimmer.h"
 #include "audiographer/general/threader.h"
 #include "audiographer/sndfile/tmp_file.h"
+#include "audiographer/sndfile/tmp_file_rt.h"
+#include "audiographer/sndfile/tmp_file_sync.h"
 #include "audiographer/sndfile/sndfile_writer.h"
 
 #include "ardour/audioengine.h"
@@ -112,6 +115,7 @@ ExportGraphBuilder::reset ()
        channels.clear ();
        normalizers.clear ();
        analysis_map.clear();
+       _realtime = false;
 }
 
 void
@@ -132,7 +136,7 @@ ExportGraphBuilder::set_current_timespan (boost::shared_ptr<ExportTimespan> span
 }
 
 void
-ExportGraphBuilder::add_config (FileSpec const & config)
+ExportGraphBuilder::add_config (FileSpec const & config, bool rt)
 {
        ExportChannelConfiguration::ChannelList const & channels =
                config.channel_config->get_channels();
@@ -141,6 +145,8 @@ ExportGraphBuilder::add_config (FileSpec const & config)
                (*it)->set_max_buffer_size(process_buffer_frames);
        }
 
+       _realtime = rt;
+
        // If the sample rate is "session rate", change it to the real value.
        // However, we need to copy it to not change the config which is saved...
        FileSpec new_config (config);
@@ -316,6 +322,8 @@ ExportGraphBuilder::SFC::SFC (ExportGraphBuilder &parent, FileSpec const & new_c
                analyser.reset (new Analyser (config.format->sample_rate(), channels, max_frames,
                                        (framecnt_t) ceil (duration * config.format->sample_rate () / (double) sample_rate)));
                chunker->add_output (analyser);
+
+               config.filename->set_channel_config (config.channel_config);
                parent.add_analyser (config.filename->get_path (config.format), analyser);
        }
 
@@ -405,8 +413,10 @@ ExportGraphBuilder::SFC::operator== (FileSpec const & other_config) const
 
 /* Normalizer */
 
-ExportGraphBuilder::Normalizer::Normalizer (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t /*max_frames*/)
+ExportGraphBuilder::Normalizer::Normalizer (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t max_frames)
        : parent (parent)
+       , use_loudness (false)
+       , use_peak (false)
 {
        std::string tmpfile_path = parent.session.session_directory().export_path();
        tmpfile_path = Glib::build_filename(tmpfile_path, "XXXXXX");
@@ -417,29 +427,54 @@ ExportGraphBuilder::Normalizer::Normalizer (ExportGraphBuilder & parent, FileSpe
        config = new_config;
        uint32_t const channels = config.channel_config->get_n_chans();
        max_frames_out = 4086 - (4086 % channels); // TODO good chunk size
+       use_loudness = config.format->normalize_loudness ();
+       use_peak = config.format->normalize ();
 
        buffer.reset (new AllocatingProcessContext<Sample> (max_frames_out, channels));
-       peak_reader.reset (new PeakReader ());
-       normalizer.reset (new AudioGrapher::Normalizer (config.format->normalize_target()));
-       threader.reset (new Threader<Sample> (parent.thread_pool));
 
+       if (use_peak) {
+               peak_reader.reset (new PeakReader ());
+       }
+       if (use_loudness) {
+               loudness_reader.reset (new LoudnessReader (config.format->sample_rate(), channels, max_frames));
+       }
+
+       normalizer.reset (new AudioGrapher::Normalizer (use_loudness ? 0.0 : config.format->normalize_dbfs()));
+       threader.reset (new Threader<Sample> (parent.thread_pool));
        normalizer->alloc_buffer (max_frames_out);
        normalizer->add_output (threader);
 
        int format = ExportFormatBase::F_RAW | ExportFormatBase::SF_Float;
-       tmp_file.reset (new TmpFile<float> (&tmpfile_path_buf[0], format, channels, config.format->sample_rate()));
+
+       if (parent._realtime) {
+               tmp_file.reset (new TmpFileRt<float> (&tmpfile_path_buf[0], format, channels, config.format->sample_rate()));
+       } else {
+               tmp_file.reset (new TmpFileSync<float> (&tmpfile_path_buf[0], format, channels, config.format->sample_rate()));
+       }
+
        tmp_file->FileWritten.connect_same_thread (post_processing_connection,
+                                                  boost::bind (&Normalizer::prepare_post_processing, this));
+       tmp_file->FileFlushed.connect_same_thread (post_processing_connection,
                                                   boost::bind (&Normalizer::start_post_processing, this));
 
        add_child (new_config);
 
-       peak_reader->add_output (tmp_file);
+       if (use_loudness) {
+               loudness_reader->add_output (tmp_file);
+       } else if (use_peak) {
+               peak_reader->add_output (tmp_file);
+       }
 }
 
 ExportGraphBuilder::FloatSinkPtr
 ExportGraphBuilder::Normalizer::sink ()
 {
-       return peak_reader;
+       if (use_loudness) {
+               return loudness_reader;
+       } else if (use_peak) {
+               return peak_reader;
+       }
+       return tmp_file;
 }
 
 void
@@ -471,7 +506,13 @@ bool
 ExportGraphBuilder::Normalizer::operator== (FileSpec const & other_config) const
 {
        return config.format->normalize() == other_config.format->normalize() &&
-               config.format->normalize_target() == other_config.format->normalize_target();
+               config.format->normalize_loudness () == other_config.format->normalize_loudness() &&
+               (
+                (!config.format->normalize_loudness () && config.format->normalize_dbfs() == other_config.format->normalize_dbfs())
+                ||
+                // FIXME: allow simultaneous export of two formats with different loundness normalization settings
+                (config.format->normalize_loudness () /* lufs/dbtp is a result option, not an instantaion option */)
+               );
 }
 
 unsigned
@@ -489,17 +530,37 @@ ExportGraphBuilder::Normalizer::process()
 }
 
 void
-ExportGraphBuilder::Normalizer::start_post_processing()
-{
-       const float gain = normalizer->set_peak (peak_reader->get_peak());
-       for (boost::ptr_list<SFC>::iterator i = children.begin(); i != children.end(); ++i) {
-               (*i).set_peak (gain);
+ExportGraphBuilder::Normalizer::prepare_post_processing()
+{
+       // called in sync rt-context
+       float gain;
+       if (use_loudness) {
+               gain = normalizer->set_peak (loudness_reader->get_peak (config.format->normalize_lufs (), config.format->normalize_dbtp ()));
+       } else if (use_peak) {
+               gain = normalizer->set_peak (peak_reader->get_peak());
+       } else {
+               gain = normalizer->set_peak (0.0);
+       }
+       if (use_loudness || use_peak) {
+               // push info to analyzers
+               for (boost::ptr_list<SFC>::iterator i = children.begin(); i != children.end(); ++i) {
+                       (*i).set_peak (gain);
+               }
        }
-       tmp_file->seek (0, SEEK_SET);
        tmp_file->add_output (normalizer);
        parent.normalizers.push_back (this);
 }
 
+void
+ExportGraphBuilder::Normalizer::start_post_processing()
+{
+       // called in disk-thread (when exporting in realtime)
+       tmp_file->seek (0, SEEK_SET);
+       if (!AudioEngine::instance()->freewheeling ()) {
+               AudioEngine::instance()->freewheel (true);
+       }
+}
+
 /* SRC */
 
 ExportGraphBuilder::SRC::SRC (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t max_frames)
@@ -523,7 +584,7 @@ ExportGraphBuilder::SRC::sink ()
 void
 ExportGraphBuilder::SRC::add_child (FileSpec const & new_config)
 {
-       if (new_config.format->normalize()) {
+       if (new_config.format->normalize() || parent._realtime) {
                add_child_to_list (new_config, normalized_children);
        } else {
                add_child_to_list (new_config, children);
@@ -580,8 +641,12 @@ ExportGraphBuilder::SilenceHandler::SilenceHandler (ExportGraphBuilder & parent,
        max_frames_in = max_frames;
        framecnt_t sample_rate = parent.session.nominal_frame_rate();
 
+#ifdef MIXBUS
+       silence_trimmer.reset (new SilenceTrimmer<Sample>(max_frames_in, -90));
+#else
        // TODO silence-threshold should be per export-preset, with Config->get_silence_threshold being the default
        silence_trimmer.reset (new SilenceTrimmer<Sample>(max_frames_in, Config->get_export_silence_threshold ()));
+#endif
        silence_trimmer->set_trim_beginning (config.format->trim_beginning());
        silence_trimmer->set_trim_end (config.format->trim_end());