plugin-pin management.. nearly there
[ardour.git] / libs / ardour / export_channel_configuration.cc
index 47bbbd276cb5f7a233c84debf3fa3b67bc780879..77b56272d69ea1a4df986583ce012b1eb00528d0 100644 (file)
 
 #include "ardour/export_channel_configuration.h"
 
-#include "ardour/export_handler.h"
-#include "ardour/export_filename.h"
-#include "ardour/export_processor.h"
-#include "ardour/export_timespan.h"
-
-#include "ardour/audio_port.h"
-#include "ardour/export_failed.h"
-#include "ardour/midi_port.h"
-#include "ardour/session.h"
-#include "ardour/audioengine.h"
-
 #include "pbd/convert.h"
+#include "pbd/enumwriter.h"
 #include "pbd/pthread_utils.h"
 
 using namespace PBD;
@@ -41,17 +31,14 @@ namespace ARDOUR
 
 /* ExportChannelConfiguration */
 
-ExportChannelConfiguration::ExportChannelConfiguration (Session & session) :
-  session (session),
-  writer_thread (*this),
-  status (session.get_export_status ()),
-  files_written (false),
-  split (false)
+ExportChannelConfiguration::ExportChannelConfiguration (Session & session)
+  : session (session)
+  , split (false)
+  , region_type (RegionExportChannelFactory::None)
 {
 
 }
 
-
 XMLNode &
 ExportChannelConfiguration::get_state ()
 {
@@ -61,6 +48,15 @@ ExportChannelConfiguration::get_state ()
        root->add_property ("split", get_split() ? "true" : "false");
        root->add_property ("channels", to_string (get_n_chans(), std::dec));
 
+       switch (region_type) {
+       case RegionExportChannelFactory::None:
+               // Do nothing
+               break;
+       default:
+               root->add_property ("region-processing", enum_2_string (region_type));
+               break;
+       }
+
        uint32_t i = 1;
        for (ExportChannelConfiguration::ChannelList::const_iterator c_it = channels.begin(); c_it != channels.end(); ++c_it) {
                channel = root->add_child ("Channel");
@@ -84,6 +80,11 @@ ExportChannelConfiguration::set_state (const XMLNode & root)
                set_split (!prop->value().compare ("true"));
        }
 
+       if ((prop = root.property ("region-processing"))) {
+               set_region_processing_type ((RegionExportChannelFactory::Type)
+                       string_2_enum (prop->value(), RegionExportChannelFactory::Type));
+       }
+
        XMLNodeList channels = root.children ("Channel");
        for (XMLNodeList::iterator it = channels.begin(); it != channels.end(); ++it) {
                ExportChannelPtr channel (new PortExportChannel ());
@@ -104,121 +105,22 @@ ExportChannelConfiguration::all_channels_have_ports () const
        return true;
 }
 
-bool
-ExportChannelConfiguration::write_files (boost::shared_ptr<ExportProcessor> new_processor)
-{
-       if (files_written || writer_thread.running) {
-               return false;
-       }
-
-       files_written = true;
-
-       if (!timespan) {
-               throw ExportFailed (X_("Programming error: No timespan registered to channel configuration when requesting files to be written"));
-       }
-
-       /* Take a local copy of the processor to be used in the thread that is created below */
-
-       processor.reset (new_processor->copy());
-
-       /* Create new thread for post processing */
-
-       pthread_create (&writer_thread.thread, 0, _write_files, &writer_thread);
-       writer_thread.running = true;
-       pthread_detach (writer_thread.thread);
-
-       return true;
-}
-
 void
-ExportChannelConfiguration::write_file ()
+ExportChannelConfiguration::configurations_for_files (std::list<boost::shared_ptr<ExportChannelConfiguration> > & configs)
 {
-       timespan->rewind ();
-       nframes_t progress = 0;
-       nframes_t timespan_length = timespan->get_length();
-
-       nframes_t frames = 2048; // TODO good block size ?
-       nframes_t frames_read = 0;
-
-       float * channel_buffer = new float [frames];
-       float * file_buffer = new float [channels.size() * frames];
-       uint32_t channel_count = channels.size();
-       uint32_t channel;
+       configs.clear ();
 
-       do {
-               if (status->aborted()) { break; }
-
-               channel = 0;
-               for (ChannelList::iterator it = channels.begin(); it != channels.end(); ++it) {
-
-                       /* Get channel data */
-
-                       frames_read = timespan->get_data (channel_buffer, frames, *it);
-
-                       /* Interleave into file buffer */
-
-                       for (uint32_t i = 0; i < frames_read; ++i) {
-                               file_buffer[channel + (channel_count * i)] = channel_buffer[i];
-                       }
-
-                       ++channel;
-               }
-
-               progress += frames_read;
-               status->progress = (float) progress / timespan_length;
-
-       } while (processor->process (file_buffer, frames_read) > 0);
-
-       delete [] channel_buffer;
-       delete [] file_buffer;
-}
-
-void *
-ExportChannelConfiguration::_write_files (void *arg)
-{
-       notify_gui_about_thread_creation (pthread_self(), "Export post-processing");
-
-       // cc can be trated like 'this'
-       WriterThread & cc (*((WriterThread *) arg));
-
-       try {
-               for (FileConfigList::iterator it = cc->file_configs.begin(); it != cc->file_configs.end(); ++it) {
-                       if (cc->status->aborted()) {
-                               break;
-                       }
-                       cc->processor->prepare (it->first, it->second, cc->channels.size(), cc->split, cc->timespan->get_start());
-                       cc->write_file (); // Writes tempfile
-                       cc->processor->prepare_post_processors ();
-                       cc->processor->write_files();
-               }
-       } catch (ExportFailed & e) {
-               cc->status->abort (true);
+       if (!split) {
+               configs.push_back (shared_from_this ());
+               return;
        }
 
-       cc.running = false;
-       cc->files_written = true;
-       cc->FilesWritten();
-
-       return 0; // avoid compiler warnings
-}
-
-void
-ExportChannelConfiguration::register_with_timespan (TimespanPtr new_timespan)
-{
-       timespan = new_timespan;
-
-       for (ChannelList::iterator it = channels.begin(); it != channels.end(); ++it) {
-               timespan->register_channel (*it);
+       for (ChannelList::const_iterator it = channels.begin (); it != channels.end (); ++it) {
+               boost::shared_ptr<ExportChannelConfiguration> config (new ExportChannelConfiguration (session));
+               config->set_name (_name);
+               config->register_channel (*it);
+               configs.push_back (config);
        }
 }
 
-void
-ExportChannelConfiguration::unregister_all ()
-{
-       timespan.reset();
-       processor.reset();
-       file_configs.clear();
-       files_written = false;
-}
-
 } // namespace ARDOUR