Use ISC license for RDFF (same idea, MIT style, just prettier).

[ardour.git] / libs / ardour / export_channel.cc

diff --git a/libs/ardour/export_channel.cc b/libs/ardour/export_channel.cc
index c612b1f6684e6af3488138d3b9bdbb1c4347a1cd..936b0f8a625f148230fe2c5ac7143186fd79e852 100644 (file)
--- a/libs/ardour/export_channel.cc
+++ b/libs/ardour/export_channel.cc
@@ -23,14 +23,28 @@
 #include "ardour/audio_track.h"
 #include "ardour/audioengine.h"
 #include "ardour/audioregion.h"
+#include "ardour/capturing_processor.h"
 #include "ardour/export_channel.h"
 #include "ardour/export_failed.h"
 #include "ardour/session.h"
 
 #include "pbd/error.h"
 
+#include "i18n.h"
+
 using namespace ARDOUR;
 
+PortExportChannel::PortExportChannel ()
+       : buffer_size(0)
+{
+}
+
+void PortExportChannel::set_max_buffer_size(framecnt_t frames)
+{
+       buffer_size = frames;
+       buffer.reset (new Sample[frames]);
+}
+
 bool
 PortExportChannel::operator< (ExportChannel const & other) const
 {
@@ -42,19 +56,29 @@ PortExportChannel::operator< (ExportChannel const & other) const
 }
 
 void
-PortExportChannel::read (Sample * data, framecnt_t frames) const
+PortExportChannel::read (Sample const *& data, framecnt_t frames) const
 {
-       memset (data, 0, frames * sizeof (float));
+       assert(buffer);
+       assert(frames <= buffer_size);
+
+       if (ports.size() == 1) {
+               data = (*ports.begin())->get_audio_buffer(frames).data();
+               return;
+       }
+       
+       memset (buffer.get(), 0, frames * sizeof (Sample));
 
        for (PortSet::const_iterator it = ports.begin(); it != ports.end(); ++it) {
                if (*it != 0) {
                        Sample* port_buffer = (*it)->get_audio_buffer(frames).data();
 
                        for (uint32_t i = 0; i < frames; ++i) {
-                               data[i] += (float) port_buffer[i];
+                               buffer[i] += (float) port_buffer[i];
                        }
                }
        }
+
+       data = buffer.get();
 }
 
 void
@@ -93,10 +117,7 @@ RegionExportChannelFactory::RegionExportChannelFactory (Session * session, Audio
   frames_per_cycle (session->engine().frames_per_cycle ()),
   buffers_up_to_date (false),
   region_start (region.position()),
-  position (region_start),
-
-  mixdown_buffer (0),
-  gain_buffer (0)
+  position (region_start)
 {
        switch (type) {
          case Raw:
@@ -105,9 +126,9 @@ RegionExportChannelFactory::RegionExportChannelFactory (Session * session, Audio
          case Fades:
                n_channels = region.n_channels();
 
-               mixdown_buffer = new Sample [frames_per_cycle];
-               gain_buffer = new Sample [frames_per_cycle];
-               memset (gain_buffer, 1.0, sizeof (Sample) * frames_per_cycle);
+               mixdown_buffer.reset (new Sample [frames_per_cycle]);
+               gain_buffer.reset (new Sample [frames_per_cycle]);
+               memset (gain_buffer.get(), 1.0, sizeof (Sample) * frames_per_cycle);
 
                break;
          case Processed:
@@ -125,8 +146,6 @@ RegionExportChannelFactory::RegionExportChannelFactory (Session * session, Audio
 
 RegionExportChannelFactory::~RegionExportChannelFactory ()
 {
-       delete[] mixdown_buffer;
-       delete[] gain_buffer;
 }
 
 ExportChannelPtr
@@ -137,7 +156,7 @@ RegionExportChannelFactory::create (uint32_t channel)
 }
 
 void
-RegionExportChannelFactory::read (uint32_t channel, Sample * data, framecnt_t frames_to_read)
+RegionExportChannelFactory::read (uint32_t channel, Sample const *& data, framecnt_t frames_to_read)
 {
        assert (channel < n_channels);
        assert (frames_to_read <= frames_per_cycle);
@@ -147,7 +166,7 @@ RegionExportChannelFactory::read (uint32_t channel, Sample * data, framecnt_t fr
                buffers_up_to_date = true;
        }
 
-       memcpy (data, buffers.get_audio (channel).data(), frames_to_read * sizeof (Sample));
+       data = buffers.get_audio (channel).data();
 }
 
 void
@@ -164,8 +183,8 @@ RegionExportChannelFactory::update_buffers (framecnt_t frames)
          case Fades:
                assert (mixdown_buffer && gain_buffer);
                for (size_t channel = 0; channel < n_channels; ++channel) {
-                       memset (mixdown_buffer, 0, sizeof (Sample) * frames);
-                       region.read_at (buffers.get_audio (channel).data(), mixdown_buffer, gain_buffer, position, frames, channel);
+                       memset (mixdown_buffer.get(), 0, sizeof (Sample) * frames);
+                       region.read_at (buffers.get_audio (channel).data(), mixdown_buffer.get(), gain_buffer.get(), position, frames, channel);
                }
                break;
          case Processed:
@@ -177,3 +196,77 @@ RegionExportChannelFactory::update_buffers (framecnt_t frames)
 
        position += frames;
 }
+
+
+RouteExportChannel::RouteExportChannel(boost::shared_ptr<CapturingProcessor> processor, size_t channel,
+                                       boost::shared_ptr<ProcessorRemover> remover)
+  : processor (processor)
+  , channel (channel)
+  , remover (remover)
+{
+}
+
+RouteExportChannel::~RouteExportChannel()
+{
+}
+
+void
+RouteExportChannel::create_from_route(std::list<ExportChannelPtr> & result, Route & route)
+{
+       boost::shared_ptr<CapturingProcessor> processor = route.add_export_point();
+       uint32_t channels = processor->input_streams().n_audio();
+
+       boost::shared_ptr<ProcessorRemover> remover (new ProcessorRemover (route, processor));
+       result.clear();
+       for (uint32_t i = 0; i < channels; ++i) {
+               result.push_back (ExportChannelPtr (new RouteExportChannel (processor, i, remover)));
+       }
+}
+
+void
+RouteExportChannel::set_max_buffer_size(framecnt_t frames)
+{
+       if (processor) {
+               processor->set_block_size (frames);
+       }
+}
+
+void
+RouteExportChannel::read (Sample const *& data, framecnt_t frames) const
+{
+       assert(processor);
+       AudioBuffer const & buffer = processor->get_capture_buffers().get_audio (channel);
+       assert (frames <= (framecnt_t) buffer.size());
+       data = buffer.data();
+}
+
+void
+RouteExportChannel::get_state (XMLNode * node) const
+{
+       // TODO
+}
+
+void
+RouteExportChannel::set_state (XMLNode * node, Session & session)
+{
+       // TODO
+}
+
+bool
+RouteExportChannel::operator< (ExportChannel const & other) const
+{
+       RouteExportChannel const * rec;
+       if ((rec = dynamic_cast<RouteExportChannel const *>(&other)) == 0) {
+               return this < &other;
+       }
+
+       if (processor.get() == rec->processor.get()) {
+               return channel < rec->channel;
+       }
+       return processor.get() < rec->processor.get();
+}
+
+RouteExportChannel::ProcessorRemover::~ProcessorRemover()
+{
+       route.remove_processor (processor);
+}