2 Copyright (C) 2008 Paul Davis
5 This program is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 2 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 #include "ardour/export_channel_configuration.h"
23 #include "ardour/export_handler.h"
24 #include "ardour/export_filename.h"
25 #include "ardour/export_processor.h"
26 #include "ardour/export_timespan.h"
28 #include "ardour/audio_port.h"
29 #include "ardour/export_failed.h"
30 #include "ardour/midi_port.h"
31 #include "ardour/session.h"
32 #include "ardour/audioengine.h"
34 #include "pbd/convert.h"
35 #include "pbd/pthread_utils.h"
40 /* ExportChannelConfiguration */
42 ExportChannelConfiguration::ExportChannelConfiguration (Session & session) :
44 writer_thread (*this),
45 status (session.get_export_status ()),
46 files_written (false),
54 ExportChannelConfiguration::get_state ()
56 XMLNode * root = new XMLNode ("ExportChannelConfiguration");
59 root->add_property ("split", get_split() ? "true" : "false");
60 root->add_property ("channels", to_string (get_n_chans(), std::dec));
63 for (ExportChannelConfiguration::ChannelList::const_iterator c_it = channels.begin(); c_it != channels.end(); ++c_it) {
64 channel = root->add_child ("Channel");
65 if (!channel) { continue; }
67 channel->add_property ("number", to_string (i, std::dec));
68 (*c_it)->get_state (channel);
77 ExportChannelConfiguration::set_state (const XMLNode & root)
79 XMLProperty const * prop;
81 if ((prop = root.property ("split"))) {
82 set_split (!prop->value().compare ("true"));
85 XMLNodeList channels = root.children ("Channel");
86 for (XMLNodeList::iterator it = channels.begin(); it != channels.end(); ++it) {
87 ExportChannelPtr channel (new PortExportChannel ());
88 channel->set_state (*it, session);
89 register_channel (channel);
96 ExportChannelConfiguration::all_channels_have_ports () const
98 for (ChannelList::const_iterator it = channels.begin(); it != channels.end(); ++it) {
99 if ((*it)->empty ()) { return false; }
106 ExportChannelConfiguration::write_files (boost::shared_ptr<ExportProcessor> new_processor)
108 if (files_written || writer_thread.running) {
112 files_written = true;
115 throw ExportFailed (X_("Programming error: No timespan registered to channel configuration when requesting files to be written"));
118 /* Take a local copy of the processor to be used in the thread that is created below */
120 processor.reset (new_processor->copy());
122 /* Create new thread for post processing */
124 pthread_create (&writer_thread.thread, 0, _write_files, &writer_thread);
125 writer_thread.running = true;
126 pthread_detach (writer_thread.thread);
132 ExportChannelConfiguration::write_file ()
135 nframes_t progress = 0;
136 nframes_t timespan_length = timespan->get_length();
138 nframes_t frames = 2048; // TODO good block size ?
139 nframes_t frames_read = 0;
141 float * channel_buffer = new float [frames];
142 float * file_buffer = new float [channels.size() * frames];
143 uint32_t channel_count = channels.size();
147 if (status->aborted()) { break; }
150 for (ChannelList::iterator it = channels.begin(); it != channels.end(); ++it) {
152 /* Get channel data */
154 frames_read = timespan->get_data (channel_buffer, frames, *it);
156 /* Interleave into file buffer */
158 for (uint32_t i = 0; i < frames_read; ++i) {
159 file_buffer[channel + (channel_count * i)] = channel_buffer[i];
165 progress += frames_read;
166 status->progress = (float) progress / timespan_length;
168 } while (processor->process (file_buffer, frames_read) > 0);
170 delete [] channel_buffer;
171 delete [] file_buffer;
175 ExportChannelConfiguration::_write_files (void *arg)
177 notify_gui_about_thread_creation (pthread_self(), "Export post-processing");
179 // cc can be trated like 'this'
180 WriterThread & cc (*((WriterThread *) arg));
183 for (FileConfigList::iterator it = cc->file_configs.begin(); it != cc->file_configs.end(); ++it) {
184 if (cc->status->aborted()) {
187 cc->processor->prepare (it->first, it->second, cc->channels.size(), cc->split, cc->timespan->get_start());
188 cc->write_file (); // Writes tempfile
189 cc->processor->prepare_post_processors ();
190 cc->processor->write_files();
192 } catch (ExportFailed & e) {
193 cc->status->abort (true);
197 cc->files_written = true;
200 return 0; // avoid compiler warnings
204 ExportChannelConfiguration::register_with_timespan (TimespanPtr new_timespan)
206 timespan = new_timespan;
208 for (ChannelList::iterator it = channels.begin(); it != channels.end(); ++it) {
209 timespan->register_channel (*it);
214 ExportChannelConfiguration::unregister_all ()
218 file_configs.clear();
219 files_written = false;
222 } // namespace ARDOUR