clean up debugging
[ardour.git] / libs / ardour / import.cc
index e05d162a568a6880f188dd36c67b7a51af944039..deba3efb05f916c1e19ba0e220fac3e4a5e393d8 100644 (file)
@@ -73,7 +73,7 @@ using namespace ARDOUR;
 using namespace PBD;
 
 static boost::shared_ptr<ImportableSource>
-open_importable_source (const string& path, nframes_t samplerate, ARDOUR::SrcQuality quality)
+open_importable_source (const string& path, framecnt_t samplerate, ARDOUR::SrcQuality quality)
 {
        /* try libsndfile first, because it can get BWF info from .wav, which ExtAudioFile cannot.
           We don't necessarily need that information in an ImportableSource, but it keeps the 
@@ -117,50 +117,62 @@ open_importable_source (const string& path, nframes_t samplerate, ARDOUR::SrcQua
 }
 
 static std::string
-get_non_existent_filename (DataType type, const bool allow_replacing, const std::string& destdir, const std::string& basename, uint channel, uint channels)
+get_non_existent_filename (HeaderFormat hf, DataType type, const bool allow_replacing, const std::string& destdir, const std::string& basename, uint channel, uint channels)
 {
        char buf[PATH_MAX+1];
        bool goodfile = false;
-       string base(basename);
-       const char* ext = (type == DataType::AUDIO) ? "wav" : "mid";
+       string base = basename;
+       string ext = native_header_format_extension (hf, type);
+        uint32_t cnt = 1;
 
        do {
 
                if (type == DataType::AUDIO && channels == 2) {
                        if (channel == 0) {
-                               snprintf (buf, sizeof(buf), "%s-L.wav", base.c_str());
+                                if (cnt == 1) {
+                                        snprintf (buf, sizeof(buf), "%s-L%s", base.c_str(), ext.c_str());
+                                } else {
+                                        snprintf (buf, sizeof(buf), "%s-%d-L%s", base.c_str(), cnt, ext.c_str());
+                                }
                        } else {
-                               snprintf (buf, sizeof(buf), "%s-R.wav", base.c_str());
+                                if (cnt == 1) {
+                                        snprintf (buf, sizeof(buf), "%s-R%s", base.c_str(), ext.c_str());
+                                } else {
+                                        snprintf (buf, sizeof(buf), "%s-%d-R%s", base.c_str(), cnt, ext.c_str());
+                                }
                        }
                } else if (channels > 1) {
-                       snprintf (buf, sizeof(buf), "%s-c%d.%s", base.c_str(), channel, ext);
+                        if (cnt == 1) {
+                                snprintf (buf, sizeof(buf), "%s-c%d%s", base.c_str(), channel, ext.c_str());
+                        } else {
+                                snprintf (buf, sizeof(buf), "%s-%d-c%d%s", base.c_str(), cnt, channel, ext.c_str());
+                        }
                } else {
-                       snprintf (buf, sizeof(buf), "%s.%s", base.c_str(), ext);
+                        if (cnt == 1) {
+                                snprintf (buf, sizeof(buf), "%s%s", base.c_str(), ext.c_str());
+                        } else {
+                                snprintf (buf, sizeof(buf), "%s-%d%s", base.c_str(), cnt, ext.c_str());
+                        }
                }
 
-
                string tempname = destdir + "/" + buf;
+                
                if (!allow_replacing && Glib::file_test (tempname, Glib::FILE_TEST_EXISTS)) {
-
-                       /* if the file already exists, we must come up with
-                        *  a new name for it.  for now we just keep appending
-                        *  _ to basename
-                        */
-
-                       base += "_";
+                        
+                        cnt++;
 
                } else {
 
                        goodfile = true;
                }
 
-       } while ( !goodfile);
+       } while (!goodfile);
 
        return buf;
 }
 
 static vector<string>
-get_paths_for_new_sources (const bool allow_replacing, const string& import_file_path, const string& session_dir, uint channels)
+get_paths_for_new_sources (HeaderFormat hf, const bool allow_replacing, const string& import_file_path, const string& session_dir, uint channels)
 {
        vector<string> new_paths;
        const string basename = basename_nosuffix (import_file_path);
@@ -169,14 +181,13 @@ get_paths_for_new_sources (const bool allow_replacing, const string& import_file
 
        for (uint n = 0; n < channels; ++n) {
 
-               const DataType type = (import_file_path.rfind(".mid") != string::npos)
-                               ? DataType::MIDI : DataType::AUDIO;
+               const DataType type = SMFSource::safe_midi_file_extension (import_file_path) ? DataType::MIDI : DataType::AUDIO;
 
                std::string filepath = (type == DataType::MIDI)
                                ? sdir.midi_path().to_string() : sdir.sound_path().to_string();
 
-               filepath += '/';
-               filepath += get_non_existent_filename (type, allow_replacing, filepath, basename, n, channels);
+                filepath = Glib::build_filename (filepath, 
+                                                 get_non_existent_filename (hf, type, allow_replacing, filepath, basename, n, channels));
                new_paths.push_back (filepath);
        }
 
@@ -203,27 +214,27 @@ map_existing_mono_sources (const vector<string>& new_paths, Session& /*sess*/,
 }
 
 static bool
-create_mono_sources_for_writing (const vector<string>& new_paths, Session& sess,
-                                uint samplerate, vector<boost::shared_ptr<Source> >& newfiles,
+create_mono_sources_for_writing (const string& origin,
+                                 const vector<string>& new_paths, 
+                                 Session& sess, uint samplerate, 
+                                 vector<boost::shared_ptr<Source> >& newfiles,
                                 framepos_t timeline_position)
 {
-       for (vector<string>::const_iterator i = new_paths.begin(); i != new_paths.end(); ++i)
-       {
-               boost::shared_ptr<Source> source;
+       for (vector<string>::const_iterator i = new_paths.begin(); i != new_paths.end(); ++i) {
 
-               try
-               {
-                       const DataType type = ((*i).rfind(".mid") != string::npos)
-                               ? DataType::MIDI : DataType::AUDIO;
+               boost::shared_ptr<Source> source;
 
+               try {
+                       const DataType type = SMFSource::safe_midi_file_extension (*i) ? DataType::MIDI : DataType::AUDIO;
 
                        source = SourceFactory::createWritable (type, sess,
-                                       i->c_str(),
-                                       false, // destructive
-                                       samplerate);
+                                                                i->c_str(),
+                                                                origin,
+                                                                false, // destructive
+                                                                samplerate);
                }
-               catch (const failed_constructor& err)
-               {
+
+               catch (const failed_constructor& err) {
                        error << string_compose (_("Unable to create file %1 during import"), *i) << endmsg;
                        return false;
                }
@@ -242,31 +253,28 @@ create_mono_sources_for_writing (const vector<string>& new_paths, Session& sess,
        return true;
 }
 
-static Glib::ustring
+static string
 compose_status_message (const string& path,
                        uint file_samplerate,
                        uint session_samplerate,
-                       uint current_file,
-                       uint total_files)
+                       uint /* current_file */,
+                       uint /* total_files */)
 {
        if (file_samplerate != session_samplerate) {
-               return string_compose (_("resampling %1 from %2kHz to %3kHz\n(%4 of %5)"),
+               return string_compose (_("Resampling %1 from %2kHz to %3kHz"),
                                       Glib::path_get_basename (path),
                                       file_samplerate/1000.0f,
-                                      session_samplerate/1000.0f,
-                                      current_file, total_files);
+                                      session_samplerate/1000.0f);
        }
-
-       return string_compose (_("copying %1\n(%2 of %3)"),
-                              Glib::path_get_basename (path),
-                              current_file, total_files);
+       
+       return string_compose (_("Copying %1"), Glib::path_get_basename (path));
 }
 
 static void
 write_audio_data_to_new_files (ImportableSource* source, ImportStatus& status,
                               vector<boost::shared_ptr<Source> >& newfiles)
 {
-       const nframes_t nframes = ResampledImportableSource::blocksize;
+       const framecnt_t nframes = ResampledImportableSource::blocksize;
        boost::shared_ptr<AudioFileSource> afs;
        uint channels = source->channels();
 
@@ -277,25 +285,71 @@ write_audio_data_to_new_files (ImportableSource* source, ImportStatus& status,
                channel_data.push_back(boost::shared_array<Sample>(new Sample[nframes]));
        }
 
-       uint read_count = 0;
+       float gain = 1;
+
+       boost::shared_ptr<AudioSource> s = boost::dynamic_pointer_cast<AudioSource> (newfiles[0]);
+       assert (s);
+
        status.progress = 0.0f;
+       float progress_multiplier = 1;
+       float progress_base = 0;
+
+       if (!source->clamped_at_unity() && s->clamped_at_unity()) {
+
+               /* The source we are importing from can return sample values with a magnitude greater than 1,
+                  and the file we are writing the imported data to cannot handle such values.  Compute the gain
+                  factor required to normalize the input sources to have a magnitude of less than 1.
+               */
+               
+               float peak = 0;
+               uint read_count = 0;
+               
+               while (!status.cancel) {
+                       framecnt_t const nread = source->read (data.get(), nframes);
+                       if (nread == 0) {
+                               break;
+                       }
+
+                       peak = compute_peak (data.get(), nread, peak);
+
+                       read_count += nread;
+                       status.progress = 0.5 * read_count / (source->ratio() * source->length() * channels);
+               }
+
+               if (peak >= 1) {
+                       /* we are out of range: compute a gain to fix it */
+                       gain = (1 - FLT_EPSILON) / peak;
+               }
+               
+               source->seek (0);
+               progress_multiplier = 0.5;
+               progress_base = 0.5;
+       }
+
+       uint read_count = 0;
 
        while (!status.cancel) {
 
-               nframes_t nread, nfread;
+               framecnt_t nread, nfread;
                uint x;
                uint chn;
 
                if ((nread = source->read (data.get(), nframes)) == 0) {
                        break;
                }
+
+               if (gain != 1) {
+                       /* here is the gain fix for out-of-range sample values that we computed earlier */
+                       apply_gain_to_buffer (data.get(), nread, gain);
+               }
+               
                nfread = nread / channels;
 
                /* de-interleave */
 
                for (chn = 0; chn < channels; ++chn) {
 
-                       nframes_t n;
+                       framecnt_t n;
                        for (x = chn, n = 0; n < nfread; x += channels, ++n) {
                                channel_data[chn][n] = (Sample) data[x];
                        }
@@ -310,7 +364,7 @@ write_audio_data_to_new_files (ImportableSource* source, ImportStatus& status,
                }
 
                read_count += nread;
-               status.progress = read_count / (source->ratio () * source->length() * channels);
+               status.progress = progress_base + progress_multiplier * read_count / (source->ratio () * source->length() * channels);
        }
 }
 
@@ -337,9 +391,12 @@ write_midi_data_to_new_files (Evoral::SMF* source, ImportStatus& status,
                 bool first = true;
 
                while (!status.cancel) {
-                       size = buf_size;
+                        gint ignored; // imported files either don't have NoteID's or
+                                      // we ignore them.
 
-                       int ret = source->read_event(&delta_t, &size, &buf);
+                       size = buf_size;
+                        
+                       int ret = source->read_event(&delta_t, &size, &buf, &ignored);
                        if (size > buf_size)
                                buf_size = size;
 
@@ -367,7 +424,7 @@ write_midi_data_to_new_files (Evoral::SMF* source, ImportStatus& status,
                                status.progress += 0.01;
                }
 
-               const nframes64_t pos = 0;
+               const framepos_t pos = 0;
                const double length_beats = ceil(t / (double)source->ppqn());
                BeatsFramesConverter converter(smfs->session().tempo_map(), pos);
                smfs->update_length(pos, converter.to(length_beats));
@@ -396,7 +453,6 @@ remove_file_source (boost::shared_ptr<Source> source)
 void
 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;
@@ -405,14 +461,13 @@ Session::import_audiofiles (ImportStatus& status)
 
        status.sources.clear ();
 
-       for (vector<Glib::ustring>::iterator p = status.paths.begin();
-                       p != status.paths.end() && !status.cancel;
-                       ++p, ++cnt)
+       for (vector<string>::iterator p = status.paths.begin();
+            p != status.paths.end() && !status.cancel;
+            ++p)
        {
                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 = SMFSource::safe_midi_file_extension (*p) ? DataType::MIDI : DataType::AUDIO;
 
                if (type == DataType::AUDIO) {
                        try {
@@ -436,7 +491,8 @@ Session::import_audiofiles (ImportStatus& status)
                        }
                }
 
-               vector<string> new_paths = get_paths_for_new_sources (status.replace_existing_source, *p,
+               vector<string> new_paths = get_paths_for_new_sources (config.get_native_file_header_format(),
+                                                                      status.replace_existing_source, *p,
                                                                      get_best_session_directory_for_new_source (),
                                                                      channels);
                Sources newfiles;
@@ -446,7 +502,7 @@ Session::import_audiofiles (ImportStatus& status)
                        fatal << "THIS IS NOT IMPLEMENTED YET, IT SHOULD NEVER GET CALLED!!! DYING!" << endmsg;
                        status.cancel = !map_existing_mono_sources (new_paths, *this, frame_rate(), newfiles, this);
                } else {
-                        status.cancel = !create_mono_sources_for_writing (new_paths, *this, frame_rate(), newfiles, natural_position);
+                        status.cancel = !create_mono_sources_for_writing (*p, new_paths, *this, frame_rate(), newfiles, natural_position);
                }
 
                // copy on cancel/failure so that any files that were created will be removed below
@@ -464,12 +520,15 @@ Session::import_audiofiles (ImportStatus& status)
 
                if (source) { // audio
                        status.doing_what = compose_status_message (*p, source->samplerate(),
-                                                                   frame_rate(), cnt, status.total);
+                                                                   frame_rate(), status.current, 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);
                        write_midi_data_to_new_files (smf_reader.get(), status, newfiles);
                }
+
+               ++status.current;
+               status.progress = 0;
        }
 
        if (!status.cancel) {