Optimize automation-event process splitting
[ardour.git] / libs / ardour / ardour / export_graph_builder.h
index d14a00997aae806738436f852393432178ac7e97..00cf8226be184aef9cf8d8bfc2d60bbc85dcea92 100644 (file)
 namespace AudioGrapher {
        class SampleRateConverter;
        class PeakReader;
+       class LoudnessReader;
        class Normalizer;
        class Analyser;
        template <typename T> class Chunker;
        template <typename T> class SampleFormatConverter;
        template <typename T> class Interleaver;
        template <typename T> class SndfileWriter;
+       template <typename T> class CmdPipeWriter;
        template <typename T> class SilenceTrimmer;
        template <typename T> class TmpFile;
        template <typename T> class Threader;
@@ -66,15 +68,16 @@ class LIBARDOUR_API ExportGraphBuilder
        ExportGraphBuilder (Session const & session);
        ~ExportGraphBuilder ();
 
-       int process (framecnt_t frames, bool last_cycle);
-       bool process_normalize (); // returns true when finished
-       bool will_normalize() { return !normalizers.empty(); }
-       unsigned get_normalize_cycle_count() const;
+       int process (samplecnt_t samples, bool last_cycle);
+       bool post_process (); // returns true when finished
+       bool need_postprocessing () const { return !intermediates.empty(); }
+       bool realtime() const { return _realtime; }
+       unsigned get_postprocessing_cycle_count() const;
 
        void reset ();
        void cleanup (bool remove_out_files = false);
        void set_current_timespan (boost::shared_ptr<ExportTimespan> span);
-       void add_config (FileSpec const & config);
+       void add_config (FileSpec const & config, bool rt);
        void get_analysis_results (AnalysisResults& results);
 
   private:
@@ -100,7 +103,11 @@ class LIBARDOUR_API ExportGraphBuilder
                typedef boost::shared_ptr<AudioGrapher::SndfileWriter<int> >    IntWriterPtr;
                typedef boost::shared_ptr<AudioGrapher::SndfileWriter<short> >  ShortWriterPtr;
 
+               typedef boost::shared_ptr<AudioGrapher::CmdPipeWriter<Sample> > FloatPipePtr;
+
                template<typename T> void init_writer (boost::shared_ptr<AudioGrapher::SndfileWriter<T> > & writer);
+               template<typename T> void init_writer (boost::shared_ptr<AudioGrapher::CmdPipeWriter<T> > & writer);
+
                void copy_files (std::string orig_path);
 
                FileSpec               config;
@@ -113,19 +120,22 @@ class LIBARDOUR_API ExportGraphBuilder
                FloatWriterPtr float_writer;
                IntWriterPtr   int_writer;
                ShortWriterPtr short_writer;
+               FloatPipePtr   pipe_writer;
        };
 
        // sample format converter
        class SFC {
             public:
                // This constructor so that this can be constructed like a Normalizer
-               SFC (ExportGraphBuilder &, FileSpec const & new_config, framecnt_t max_frames);
+               SFC (ExportGraphBuilder &, FileSpec const & new_config, samplecnt_t max_samples);
                FloatSinkPtr sink ();
                void add_child (FileSpec const & new_config);
                void remove_children (bool remove_out_files);
                bool operator== (FileSpec const & other_config) const;
+               void set_peak (float);
 
                                                private:
+               typedef boost::shared_ptr<AudioGrapher::Chunker<float> > ChunkerPtr;
                typedef boost::shared_ptr<AudioGrapher::SampleFormatConverter<Sample> > FloatConverterPtr;
                typedef boost::shared_ptr<AudioGrapher::SampleFormatConverter<int> >   IntConverterPtr;
                typedef boost::shared_ptr<AudioGrapher::SampleFormatConverter<short> > ShortConverterPtr;
@@ -134,54 +144,60 @@ class LIBARDOUR_API ExportGraphBuilder
                boost::ptr_list<Encoder> children;
                int                data_width;
 
+               ChunkerPtr      chunker;
                AnalysisPtr     analyser;
+               bool            _analyse;
                // Only one of these should be available at a time
                FloatConverterPtr float_converter;
                IntConverterPtr int_converter;
                ShortConverterPtr short_converter;
        };
 
-       class Normalizer {
+       class Intermediate {
                                                public:
-               Normalizer (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t max_frames);
+               Intermediate (ExportGraphBuilder & parent, FileSpec const & new_config, samplecnt_t max_samples);
                FloatSinkPtr sink ();
                void add_child (FileSpec const & new_config);
                void remove_children (bool remove_out_files);
                bool operator== (FileSpec const & other_config) const;
 
-               unsigned get_normalize_cycle_count() const;
+               unsigned get_postprocessing_cycle_count() const;
 
                /// Returns true when finished
                bool process ();
 
                                                private:
                typedef boost::shared_ptr<AudioGrapher::PeakReader> PeakReaderPtr;
+               typedef boost::shared_ptr<AudioGrapher::LoudnessReader> LoudnessReaderPtr;
                typedef boost::shared_ptr<AudioGrapher::Normalizer> NormalizerPtr;
                typedef boost::shared_ptr<AudioGrapher::TmpFile<Sample> > TmpFilePtr;
                typedef boost::shared_ptr<AudioGrapher::Threader<Sample> > ThreaderPtr;
                typedef boost::shared_ptr<AudioGrapher::AllocatingProcessContext<Sample> > BufferPtr;
 
-               void start_post_processing();
+               void prepare_post_processing ();
+               void start_post_processing ();
 
                ExportGraphBuilder & parent;
 
                FileSpec        config;
-               framecnt_t      max_frames_out;
-
+               samplecnt_t      max_samples_out;
+               bool            use_loudness;
+               bool            use_peak;
                BufferPtr       buffer;
                PeakReaderPtr   peak_reader;
                TmpFilePtr      tmp_file;
                NormalizerPtr   normalizer;
                ThreaderPtr     threader;
+               LoudnessReaderPtr    loudness_reader;
                boost::ptr_list<SFC> children;
 
-               PBD::ScopedConnection post_processing_connection;
+               PBD::ScopedConnectionList post_processing_connection;
        };
 
        // sample rate converter
        class SRC {
             public:
-               SRC (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t max_frames);
+               SRC (ExportGraphBuilder & parent, FileSpec const & new_config, samplecnt_t max_samples);
                FloatSinkPtr sink ();
                void add_child (FileSpec const & new_config);
                void remove_children (bool remove_out_files);
@@ -197,15 +213,15 @@ class LIBARDOUR_API ExportGraphBuilder
                ExportGraphBuilder &  parent;
                FileSpec              config;
                boost::ptr_list<SFC>  children;
-               boost::ptr_list<Normalizer> normalized_children;
+               boost::ptr_list<Intermediate> intermediate_children;
                SRConverterPtr        converter;
-               framecnt_t            max_frames_out;
+               samplecnt_t            max_samples_out;
        };
 
        // Silence trimmer + adder
        class SilenceHandler {
            public:
-               SilenceHandler (ExportGraphBuilder & parent, FileSpec const & new_config, framecnt_t max_frames);
+               SilenceHandler (ExportGraphBuilder & parent, FileSpec const & new_config, samplecnt_t max_samples);
                FloatSinkPtr sink ();
                void add_child (FileSpec const & new_config);
                void remove_children (bool remove_out_files);
@@ -218,7 +234,7 @@ class LIBARDOUR_API ExportGraphBuilder
                FileSpec             config;
                boost::ptr_list<SRC> children;
                SilenceTrimmerPtr    silence_trimmer;
-               framecnt_t           max_frames_in;
+               samplecnt_t           max_samples_in;
        };
 
        // channel configuration
@@ -238,7 +254,7 @@ class LIBARDOUR_API ExportGraphBuilder
                boost::ptr_list<SilenceHandler> children;
                InterleaverPtr            interleaver;
                ChunkerPtr                chunker;
-               framecnt_t                max_frames_out;
+               samplecnt_t                max_samples_out;
        };
 
        Session const & session;
@@ -251,12 +267,14 @@ class LIBARDOUR_API ExportGraphBuilder
        // The sources of all data, each channel is read only once
        ChannelMap channels;
 
-       framecnt_t process_buffer_frames;
+       samplecnt_t process_buffer_samples;
 
-       std::list<Normalizer *> normalizers;
+       std::list<Intermediate *> intermediates;
 
        AnalysisMap analysis_map;
 
+       bool _realtime;
+
        Glib::ThreadPool thread_pool;
 };