first part of fixing up send/return metering ; make send-controlling faders work...
[ardour.git] / libs / ardour / import.cc
index a0266521d4d117d431cd8d810858e2865f30a014..12a7db3659afc9eea456eb61da2ee18772c7c292 100644 (file)
 
 */
 
+
+#ifdef WAF_BUILD
+#include "libardour-config.h"
+#endif
+
 #include <cstdio>
 #include <cstdlib>
 #include <string>
@@ -25,6 +30,7 @@
 #include <unistd.h>
 #include <sys/stat.h>
 #include <time.h>
+#include <stdint.h>
 
 #include <sndfile.h>
 #include <samplerate.h>
 #include <boost/scoped_array.hpp>
 #include <boost/shared_array.hpp>
 
-#include <pbd/basename.h>
-#include <pbd/convert.h>
-
-#include <ardour/ardour.h>
-#include <ardour/session.h>
-#include <ardour/session_directory.h>
-#include <ardour/audio_diskstream.h>
-#include <ardour/audioengine.h>
-#include <ardour/sndfilesource.h>
-#include <ardour/sndfile_helpers.h>
-#include <ardour/audioregion.h>
-#include <ardour/region_factory.h>
-#include <ardour/source_factory.h>
-#include <ardour/resampled_source.h>
-#include <ardour/analyser.h>
-#include <ardour/smf_reader.h>
-#include <ardour/smf_source.h>
-#include <ardour/tempo.h>
+#include "pbd/basename.h"
+#include "pbd/convert.h"
+
+#include "evoral/SMF.hpp"
+
+#include "ardour/ardour.h"
+#include "ardour/session.h"
+#include "ardour/session_directory.h"
+#include "ardour/audio_diskstream.h"
+#include "ardour/audioengine.h"
+#include "ardour/sndfilesource.h"
+#include "ardour/sndfile_helpers.h"
+#include "ardour/audioregion.h"
+#include "ardour/region_factory.h"
+#include "ardour/source_factory.h"
+#include "ardour/resampled_source.h"
+#include "ardour/sndfileimportable.h"
+#include "ardour/analyser.h"
+#include "ardour/smf_source.h"
+#include "ardour/tempo.h"
+
+#ifdef HAVE_COREAUDIO
+#ifdef USE_COREAUDIO_FOR_FILE_IO
+#include "ardour/caimportable.h"
+#endif
+#endif
 
 #include "i18n.h"
 
+using namespace std;
 using namespace ARDOUR;
 using namespace PBD;
 
-static std::auto_ptr<ImportableSource>
+static boost::shared_ptr<ImportableSource>
 open_importable_source (const string& path, nframes_t samplerate, ARDOUR::SrcQuality quality)
 {
-       std::auto_ptr<ImportableSource> source(new ImportableSource(path));
+#ifdef HAVE_COREAUDIO
+#ifdef USE_COREAUDIO_FOR_FILE_IO
 
-       if (source->samplerate() == samplerate) {
-               return source;
-       }
+       /* see if we can use CoreAudio to handle the IO */
        
-       return std::auto_ptr<ImportableSource>(new ResampledImportableSource(path, samplerate, quality));
+       try { 
+               CAImportableSource* src = new CAImportableSource(path);
+               boost::shared_ptr<CAImportableSource> source (src);
+               
+               if (source->samplerate() == samplerate) {
+                       return source;
+               }
+               
+               /* rewrap as a resampled source */
+
+               return boost::shared_ptr<ImportableSource>(new ResampledImportableSource(source, samplerate, quality));
+       }
+
+       catch (...) {
+
+               /* fall back to SndFile */
+#endif 
+#endif
+
+               try { 
+                       boost::shared_ptr<SndFileImportableSource> source(new SndFileImportableSource(path));
+                       
+                       if (source->samplerate() == samplerate) {
+                               return source;
+                       }
+                       
+                       /* rewrap as a resampled source */
+                       
+                       return boost::shared_ptr<ImportableSource>(new ResampledImportableSource(source, samplerate, quality));
+               }
+               
+               catch (...) {
+                       throw; // rethrow
+               }
+               
+#ifdef HAVE_COREAUDIO          
+#ifdef USE_COREAUDIO_FOR_FILE_IO
+       }
+#endif
+#endif
 }
 
 static std::string
@@ -131,9 +184,6 @@ get_paths_for_new_sources (const bool allow_replacing, const string& import_file
 
                filepath += '/';
                filepath += get_non_existent_filename (type, allow_replacing, filepath, basename, n, channels); 
-
-               cout << "NEW SOURCE PATH: " << filepath << endl;
-
                new_paths.push_back (filepath);
        }
 
@@ -173,13 +223,10 @@ create_mono_sources_for_writing (const vector<string>& new_paths, Session& sess,
                        const DataType type = ((*i).rfind(".mid") != string::npos)
                                ? DataType::MIDI : DataType::AUDIO;
                                
-                       source = SourceFactory::createWritable (
-                                       type,
-                                       sess,
-                                       i->c_str(),
+                       source = SourceFactory::createWritable (type, sess,
+                                       i->c_str(), true,
                                        false, // destructive
-                                       samplerate
-                                       );
+                                       samplerate);
                }
                catch (const failed_constructor& err)
                {
@@ -213,7 +260,7 @@ compose_status_message (const string& path,
 }
 
 static void
-write_audio_data_to_new_files (ImportableSource* source, Session::import_status& status,
+write_audio_data_to_new_files (ImportableSource* source, Session::ImportStatus& status,
                               vector<boost::shared_ptr<Source> >& newfiles)
 {
        const nframes_t nframes = ResampledImportableSource::blocksize;
@@ -265,18 +312,19 @@ write_audio_data_to_new_files (ImportableSource* source, Session::import_status&
 }
 
 static void
-write_midi_data_to_new_files (SMFReader* source, Session::import_status& status,
-                              vector<boost::shared_ptr<Source> >& newfiles)
+write_midi_data_to_new_files (Evoral::SMF* source, Session::ImportStatus& status,
+               vector<boost::shared_ptr<Source> >& newfiles)
 {
-       MidiEvent ev(0.0, 4, NULL, true);
+       uint32_t buf_size = 4;
+       uint8_t* buf      = (uint8_t*)malloc(buf_size);
 
        status.progress = 0.0f;
 
        try {
 
        for (unsigned i = 1; i <= source->num_tracks(); ++i) {
-       
                boost::shared_ptr<SMFSource> smfs = boost::dynamic_pointer_cast<SMFSource>(newfiles[i-1]);
+               smfs->drop_model();
                
                source->seek_to_track(i);
        
@@ -285,38 +333,44 @@ write_midi_data_to_new_files (SMFReader* source, Session::import_status& status,
                uint32_t size    = 0;
                
                while (!status.cancel) {
+                       size = buf_size;
 
-                       if (source->read_event(4, ev.buffer(), &size, &delta_t) < 0)
-                               break;
+                       int ret = source->read_event(&delta_t, &size, &buf);
+                       if (size > buf_size)
+                               buf_size = size;
 
+                       if (ret < 0) { // EOT
+                               break;
+                       }
+                       
                        t += delta_t;
-                       ev.time() = (double)t / (double)source->ppqn();
-                       ev.size() = size;
 
-                       smfs->append_event_unlocked(Beats, ev);
+                       if (ret == 0) { // Meta
+                               continue;
+                       }
+
+                       smfs->append_event_unlocked_beats(Evoral::Event<double>(0,
+                                       (double)t / (double)source->ppqn(),
+                                       size,
+                                       buf));
+
                        if (status.progress < 0.99)
                                status.progress += 0.01;
                }
-                       
-               nframes_t timeline_position = 0; // FIXME: ?
-
-               // FIXME: kluuuuudge: assumes tempo never changes after start
-               const double frames_per_beat = smfs->session().tempo_map().tempo_at(
-                               timeline_position).frames_per_beat(
-                                       smfs->session().engine().frame_rate(),
-                                       smfs->session().tempo_map().meter_at(timeline_position));
-
-               smfs->update_length(0, (t * source->ppqn()) * frames_per_beat);
 
-               smfs->flush_header();
-               smfs->flush_footer();
+               const nframes64_t pos = 0;
+               const double length_beats = ceil(t / (double)source->ppqn());
+               BeatsFramesConverter converter(smfs->session(), pos);
+               smfs->update_length(pos, converter.to(length_beats));
+               smfs->end_write();
 
-               if (status.cancel)
+               if (status.cancel) {
                        break;
+               }
        }
 
        } catch (...) {
-               error << "Corrupt MIDI file " << source->filename() << endl;
+               error << "Corrupt MIDI file " << source->file_path() << endl;
        }
 }
 
@@ -327,16 +381,17 @@ remove_file_source (boost::shared_ptr<Source> source)
 }
 
 // This function is still unable to cleanly update an existing source, even though
-// it is possible to set the import_status flag accordingly. The functinality
+// it is possible to set the ImportStatus flag accordingly. The functinality
 // is disabled at the GUI until the Source implementations are able to provide
 // the necessary API.
 void
-Session::import_audiofiles (import_status& status)
+Session::import_audiofiles (ImportStatus& status)
 {
        uint32_t cnt = 1;
        typedef vector<boost::shared_ptr<Source> > Sources;
        Sources all_new_sources;
        boost::shared_ptr<AudioFileSource> afs;
+       boost::shared_ptr<SMFSource> smfs;
        uint channels = 0;
 
        status.sources.clear ();
@@ -345,44 +400,36 @@ Session::import_audiofiles (import_status& status)
                        p != status.paths.end() && !status.cancel;
                        ++p, ++cnt)
        {
-               std::auto_ptr<ImportableSource> source;
-               std::auto_ptr<SMFReader>        smf_reader;
+               boost::shared_ptr<ImportableSource> source;
+               std::auto_ptr<Evoral::SMF>          smf_reader;
+               const DataType type = ((*p).rfind(".mid") != string::npos) ? 
+                       DataType::MIDI : DataType::AUDIO;
                
-               const DataType type = ((*p).rfind(".mid") != string::npos)
-                               ? DataType::MIDI : DataType::AUDIO;
-
                if (type == DataType::AUDIO) {
-                       try
-                       {
+                       try {
                                source = open_importable_source (*p, frame_rate(), status.quality);
                                channels = source->channels();
-                       } catch (const failed_constructor& err)
-                       {
+                       } catch (const failed_constructor& err) {
                                error << string_compose(_("Import: cannot open input sound file \"%1\""), (*p)) << endmsg;
                                status.done = status.cancel = true;
                                return;
                        }
+
                } else {
-                       try
-                       {
-                               smf_reader = std::auto_ptr<SMFReader>(new SMFReader(*p));
+                       try {
+                               smf_reader = std::auto_ptr<Evoral::SMF>(new Evoral::SMF());
+                               smf_reader->open(*p);
                                channels = smf_reader->num_tracks();
-                       } catch (const SMFReader::UnsupportedTime& err) {
-                               error << _("Import: unsupported MIDI time stamp format") << endmsg;
-                               status.done = status.cancel = true;
-                               return;
                        } catch (...) {
-                               error << _("Import: error reading MIDI file") << endmsg;
+                               error << _("Import: error opening MIDI file") << endmsg;
                                status.done = status.cancel = true;
                                return;
                        }
                }
 
-               vector<string> new_paths = get_paths_for_new_sources (status.replace_existing_source,
-                                                                     *p,
-                               get_best_session_directory_for_new_source (),
-                               channels);
-               
+               vector<string> new_paths = get_paths_for_new_sources (status.replace_existing_source, *p,
+                                                                     get_best_session_directory_for_new_source (),
+                                                                     channels);
                Sources newfiles;
 
                if (status.replace_existing_source) {
@@ -403,12 +450,12 @@ Session::import_audiofiles (import_status& status)
                        }
                }
 
-               if (source.get()) { // audio
+               if (source) { // audio
                        status.doing_what = compose_status_message (*p, source->samplerate(),
-                                       frame_rate(), cnt, status.paths.size());
+                                                                   frame_rate(), cnt, status.total);
                        write_audio_data_to_new_files (source.get(), status, newfiles);
                } else if (smf_reader.get()) { // midi
-                       status.doing_what = string_compose(_("loading MIDI file %1"), *p);
+                       status.doing_what = string_compose(_("Loading MIDI file %1"), *p);
                        write_midi_data_to_new_files (smf_reader.get(), status, newfiles);
                }
        }
@@ -422,26 +469,32 @@ Session::import_audiofiles (import_status& status)
 
                /* flush the final length(s) to the header(s) */
 
-               for (Sources::iterator x = all_new_sources.begin(); x != all_new_sources.end(); ++x)
-               {
-                       cout << "NEW SOURCE: " << (*x)->path() << endl;
-
+               for (Sources::iterator x = all_new_sources.begin(); x != all_new_sources.end(); ) {
                        if ((afs = boost::dynamic_pointer_cast<AudioFileSource>(*x)) != 0) {
                                afs->update_header(0, *now, xnow);
                                afs->done_with_peakfile_writes ();
-                       }
                        
-                       /* now that there is data there, requeue the file for analysis */
+                               /* now that there is data there, requeue the file for analysis */
+                               
+                               if (Config->get_auto_analyse_audio()) {
+                                       Analyser::queue_source_for_analysis (boost::static_pointer_cast<Source>(*x), false);
+                               }
+                       }
                        
-                       Analyser::queue_source_for_analysis (boost::static_pointer_cast<Source>(*x), false);
+                       /* don't create tracks for empty MIDI sources (channels) */
+
+                       if ((smfs = boost::dynamic_pointer_cast<SMFSource>(*x)) != 0 && smfs->is_empty()) {
+                               x = all_new_sources.erase(x);
+                       } else {
+                               ++x;
+                       }
                }
 
                /* save state so that we don't lose these new Sources */
 
                save_state (_name);
 
-               std::copy (all_new_sources.begin(), all_new_sources.end(),
-                               std::back_inserter(status.sources));
+               std::copy (all_new_sources.begin(), all_new_sources.end(), std::back_inserter(status.sources));
        } else {
                // this can throw...but it seems very unlikely
                std::for_each (all_new_sources.begin(), all_new_sources.end(), remove_file_source);