/* Copyright (C) 2000-2006 Paul Davis This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "ardour_ui.h" #include "editor.h" #include "sfdb_ui.h" #include "editing.h" #include "audio_time_axis.h" #include "utils.h" #include "gui_thread.h" #include "i18n.h" using namespace std; using namespace ARDOUR; using namespace PBD; using namespace sigc; using namespace Gtk; using namespace Gtkmm2ext; using namespace Editing; using Glib::ustring; /* Functions supporting the incorporation of external (non-captured) audio material into ardour */ void Editor::add_external_audio_action (ImportMode mode_hint) { if (session == 0) { MessageDialog msg (_("You can't import or embed an audiofile until you have a session loaded.")); msg.run (); return; } if (sfbrowser == 0) { sfbrowser = new SoundFileOmega (*this, _("Add existing audio"), session, 0, true, mode_hint); } else { sfbrowser->set_mode (mode_hint); } external_audio_dialog (); } void Editor::external_audio_dialog () { vector paths; uint32_t track_cnt; if (session == 0) { MessageDialog msg (_("You can't import or embed an audiofile until you have a session loaded.")); msg.run (); return; } track_cnt = 0; for (TrackSelection::iterator x = selection->tracks.begin(); x != selection->tracks.end(); ++x) { AudioTimeAxisView* atv = dynamic_cast(*x); if (!atv) { continue; } else if (atv->is_audio_track()) { track_cnt++; } } if (sfbrowser == 0) { sfbrowser = new SoundFileOmega (*this, _("Add existing audio"), session, track_cnt, true); } else { sfbrowser->reset (track_cnt); } sfbrowser->show_all (); bool keepRunning; do { keepRunning = false; int response = sfbrowser->run (); switch (response) { case RESPONSE_APPLY: // leave the dialog open break; case RESPONSE_OK: sfbrowser->hide (); break; default: // cancel from the browser - we are done sfbrowser->hide (); return; } /* lets do it */ paths = sfbrowser->get_paths (); ImportPosition pos = sfbrowser->get_position (); ImportMode mode = sfbrowser->get_mode (); ImportDisposition chns = sfbrowser->get_channel_disposition (); nframes64_t where; switch (pos) { case ImportAtEditPoint: where = get_preferred_edit_position (); break; case ImportAtTimestamp: where = -1; break; case ImportAtPlayhead: where = playhead_cursor->current_frame; break; case ImportAtStart: where = session->current_start_frame(); break; } SrcQuality quality = sfbrowser->get_src_quality(); if (sfbrowser->copy_files_btn.get_active()) { do_import (paths, chns, mode, quality, where); } else { do_embed (paths, chns, mode, where); } if (response == RESPONSE_APPLY) { sfbrowser->clear_selection (); keepRunning = true; } } while (keepRunning); } typedef std::map > AudioSourceList; /** * Updating is still disabled, see note in libs/ardour/import.cc Session::import_audiofiles() * * all_or_nothing: * true = show "Update", "Import" and "Skip" * false = show "Import", and "Cancel" * * Returns: * 0 To update an existing source of the same name * 1 To import/embed the file normally (make sure the new name will be unique) * 2 If the user wants to skip this file **/ int Editor::check_whether_and_how_to_import(string path, bool all_or_nothing) { string wave_name (Glib::path_get_basename(path)); AudioSourceList all_sources = session->get_audio_sources(); bool wave_name_exists = false; for (AudioSourceList::iterator i = all_sources.begin(); i != all_sources.end(); ++i) { boost::shared_ptr afs = boost::dynamic_pointer_cast(i->second); string tmp (Glib::path_get_basename (afs->path())); if (tmp == wave_name) { wave_name_exists = true; break; } } int function = 1; if (wave_name_exists) { string message; if (all_or_nothing) { // updating is still disabled //message = string_compose(_("The session already contains a source file named %1. Do you want to update that file (and thus all regions using the file) or import this file as a new file?"),wave_name); message = string_compose(_("The session already contains a source file named %1. This file will be imported as a new file, please confirm."),wave_name); } else { message = string_compose(_("A source file %1 already exists. This operation will not update that source but import the file %2 as a new source, please confirm."), wave_name, wave_name); } MessageDialog dialog(message, false,Gtk::MESSAGE_QUESTION, Gtk::BUTTONS_NONE, true); if (all_or_nothing) { // disabled //dialog.add_button("Update", 0); dialog.add_button("Import", 1); dialog.add_button("Skip", 2); } else { dialog.add_button("Import", 1); dialog.add_button("Cancel", 2); } //dialog.add_button("Skip all", 4); // All or rest? dialog.show(); function = dialog.run (); dialog.hide(); } return function; } boost::shared_ptr Editor::get_nth_selected_audio_track (int nth) const { AudioTimeAxisView* atv; TrackSelection::iterator x; for (x = selection->tracks.begin(); nth > 0 && x != selection->tracks.end(); ++x) { atv = dynamic_cast(*x); if (!atv) { continue; } else if (atv->is_audio_track()) { --nth; } } if (x == selection->tracks.end()) { atv = dynamic_cast(selection->tracks.back()); } else { atv = dynamic_cast(*x); } if (!atv || !atv->is_audio_track()) { return boost::shared_ptr(); } return atv->audio_track(); } void Editor::do_import (vector paths, ImportDisposition chns, ImportMode mode, SrcQuality quality, nframes64_t& pos) { //this is where an import "starts" so initialize the count here ... the rest gets initialized in import_sndfiles() import_status.count = 0; boost::shared_ptr track; vector to_import; int nth = 0; if (interthread_progress_window == 0) { build_interthread_progress_window (); } if (chns == Editing::ImportMergeFiles) { /* create 1 region from all paths, add to 1 track, ignore "track" */ bool cancel = false; for (vector::iterator a = paths.begin(); a != paths.end(); ++a) { int check = check_whether_and_how_to_import(*a, false); if (check == 2) { cancel = true; break; } } if (!cancel) { import_sndfiles (paths, mode, quality, pos, 1, 1, track, false, paths.size()); } } else { bool replace = false; bool ok = true; vector::size_type total = paths.size(); for (vector::iterator a = paths.begin(); a != paths.end() && ok; ++a) { int check = check_whether_and_how_to_import (*a, true); switch (check) { case 2: // user said skip continue; case 0: fatal << "Updating existing sources should be disabled!" << endmsg; /* NOTREACHED*/ break; case 1: replace = false; break; default: fatal << "Illegal return " << check << " from check_whether_and_how_to_import()!" << endmsg; /* NOTREACHED*/ } switch (chns) { case Editing::ImportDistinctFiles: to_import.clear (); to_import.push_back (*a); if (mode == Editing::ImportToTrack) { track = get_nth_selected_audio_track (nth++); } ok = (import_sndfiles (to_import, mode, quality, pos, 1, -1, track, replace, total) == 0); break; case Editing::ImportDistinctChannels: to_import.clear (); to_import.push_back (*a); ok = (import_sndfiles (to_import, mode, quality, pos, -1, -1, track, replace, total) == 0); break; case Editing::ImportSerializeFiles: to_import.clear (); to_import.push_back (*a); ok = (import_sndfiles (to_import, mode, quality, pos, 1, 1, track, replace, total) == 0); break; case Editing::ImportMergeFiles: // Not entered, handled in earlier if() branch break; } } } interthread_progress_window->hide_all (); } void Editor::do_embed (vector paths, ImportDisposition chns, ImportMode mode, nframes64_t& pos) { boost::shared_ptr track; bool check_sample_rate = true; bool ok = false; vector to_embed; bool multi = paths.size() > 1; int nth = 0; switch (chns) { case Editing::ImportDistinctFiles: for (vector::iterator a = paths.begin(); a != paths.end(); ++a) { to_embed.clear (); to_embed.push_back (*a); if (mode == Editing::ImportToTrack) { track = get_nth_selected_audio_track (nth++); } if (embed_sndfiles (to_embed, multi, check_sample_rate, mode, pos, 1, -1, track) < -1) { goto out; } } break; case Editing::ImportDistinctChannels: for (vector::iterator a = paths.begin(); a != paths.end(); ++a) { to_embed.clear (); to_embed.push_back (*a); if (embed_sndfiles (to_embed, multi, check_sample_rate, mode, pos, -1, -1, track) < -1) { goto out; } } break; case Editing::ImportMergeFiles: if (embed_sndfiles (paths, multi, check_sample_rate, mode, pos, 1, 1, track) < -1) { goto out; } break; case Editing::ImportSerializeFiles: for (vector::iterator a = paths.begin(); a != paths.end(); ++a) { to_embed.clear (); to_embed.push_back (*a); if (embed_sndfiles (to_embed, multi, check_sample_rate, mode, pos, 1, 1, track) < -1) { goto out; } } break; } ok = true; out: if (ok) { session->save_state (""); } } int Editor::import_sndfiles (vector paths, ImportMode mode, SrcQuality quality, nframes64_t& pos, int target_regions, int target_tracks, boost::shared_ptr& track, bool replace, uint32_t total) { interthread_progress_window->set_title (string_compose (_("Importing %1"), paths.front())); interthread_progress_window->set_position (Gtk::WIN_POS_MOUSE); interthread_progress_bar.set_fraction (0.0f); interthread_cancel_label.set_text (_("Cancel Import")); current_interthread_info = &import_status; import_status.paths = paths; import_status.done = false; import_status.cancel = false; import_status.freeze = false; import_status.done = 0.0; import_status.quality = quality; import_status.replace_existing_source = replace; import_status.total = total; import_status.mode = mode; import_status.pos = pos; import_status.target_tracks = target_tracks; import_status.target_regions = target_regions; import_status.track = track; import_status.replace = replace; interthread_progress_connection = Glib::signal_timeout().connect (bind (mem_fun(*this, &Editor::import_progress_timeout), (gpointer) 0), 500); track_canvas->get_window()->set_cursor (Gdk::Cursor (Gdk::WATCH)); gdk_flush (); /* start import thread for this spec. this will ultimately call Session::import_audiofile() which, if successful, will add the files as regions to the region list. its up to us (the GUI) to direct additional steps after that. */ pthread_create_and_store ("import", &import_status.thread, 0, _import_thread, this); pthread_detach (import_status.thread); while (!import_status.done && !import_status.cancel) { gtk_main_iteration (); } interthread_progress_window->hide (); import_status.done = true; interthread_progress_connection.disconnect (); if (!import_status.cancel && !import_status.sources.empty()) { if (add_sources (import_status.paths, import_status.sources, import_status.pos, import_status.mode, import_status.target_regions, import_status.target_tracks, track, false) == 0) { session->save_state (""); } /* update position from results */ pos = import_status.pos; } track_canvas->get_window()->set_cursor (*current_canvas_cursor); return 0; } int Editor::embed_sndfiles (vector paths, bool multifile, bool& check_sample_rate, ImportMode mode, nframes64_t& pos, int target_regions, int target_tracks, boost::shared_ptr& track) { boost::shared_ptr source; SourceList sources; string linked_path; SoundFileInfo finfo; int ret = 0; Glib::ustring path_to_use; track_canvas->get_window()->set_cursor (Gdk::Cursor (Gdk::WATCH)); gdk_flush (); for (vector::iterator p = paths.begin(); p != paths.end(); ++p) { ustring path = *p; /* lets see if we can link it into the session */ linked_path = Glib::build_filename (session->sound_dir(), Glib::path_get_basename (path)); path_to_use = path; if (link (path.c_str(), linked_path.c_str()) == 0) { /* there are many reasons why link(2) might have failed. but if it succeeds, we now have a link in the session sound dir that will protect against unlinking of the original path. nice. */ path = linked_path; path_to_use = Glib::path_get_basename (linked_path); } else { /* one possible reason is that its already linked */ if (errno == EEXIST) { struct stat sb; if (stat (linked_path.c_str(), &sb) == 0) { if (sb.st_nlink > 1) { // its a hard link, assume its the one we want path = linked_path; path_to_use = Glib::path_get_basename (linked_path); } } } } /* note that we temporarily truncated _id at the colon */ string error_msg; if (!AudioFileSource::get_soundfile_info (path, finfo, error_msg)) { error << string_compose(_("Editor: cannot open file \"%1\", (%2)"), path, error_msg ) << endmsg; goto out; } if (check_sample_rate && (finfo.samplerate != (int) session->frame_rate())) { vector choices; if (multifile) { choices.push_back (_("Cancel entire import")); choices.push_back (_("Don't embed it")); choices.push_back (_("Embed all without questions")); Gtkmm2ext::Choice rate_choice ( string_compose (_("%1\nThis audiofile's sample rate doesn't match the session sample rate!"), short_path (path, 40)), choices, false); int resx = rate_choice.run (); switch (resx) { case 0: /* stop a multi-file import */ ret = -2; goto out; case 1: /* don't embed this one */ ret = -1; goto out; case 2: /* do it, and the rest without asking */ check_sample_rate = false; break; case 3: /* do it */ break; default: ret = -2; goto out; } } else { choices.push_back (_("Cancel")); choices.push_back (_("Embed it anyway")); Gtkmm2ext::Choice rate_choice ( string_compose (_("%1\nThis audiofile's sample rate doesn't match the session sample rate!"), path), choices, false); int resx = rate_choice.run (); switch (resx) { case 0: /* don't import */ ret = -1; goto out; case 1: /* do it */ break; default: ret = -2; goto out; } } } track_canvas->get_window()->set_cursor (Gdk::Cursor (Gdk::WATCH)); for (int n = 0; n < finfo.channels; ++n) { try { /* check if we have this thing embedded already */ boost::shared_ptr s; if ((s = session->source_by_path_and_channel (path, n)) == 0) { source = boost::dynamic_pointer_cast (SourceFactory::createReadable (*session, path_to_use, n, (mode == ImportAsTapeTrack ? AudioFileSource::Destructive : AudioFileSource::Flag (0)), true, true)); } else { source = boost::dynamic_pointer_cast (s); } sources.push_back(source); } catch (failed_constructor& err) { error << string_compose(_("could not open %1"), path) << endmsg; goto out; } ARDOUR_UI::instance()->flush_pending (); } } if (sources.empty()) { goto out; } ret = add_sources (paths, sources, pos, mode, target_regions, target_tracks, track, true); out: track_canvas->get_window()->set_cursor (*current_canvas_cursor); return ret; } int Editor::add_sources (vector paths, SourceList& sources, nframes64_t& pos, ImportMode mode, int target_regions, int target_tracks, boost::shared_ptr& track, bool add_channel_suffix) { vector > regions; ustring region_name; uint32_t input_chan = 0; uint32_t output_chan = 0; bool use_timestamp; use_timestamp = (pos == -1); if (use_timestamp) { if (sources[0]->natural_position() != 0) { pos = sources[0]->natural_position(); } else { pos = get_preferred_edit_position (); } } if (target_regions == 1) { /* take all the sources we have and package them up as a region */ region_name = region_name_from_path (paths.front(), (sources.size() > 1), false); boost::shared_ptr ar = boost::dynamic_pointer_cast (RegionFactory::create (sources, 0, sources[0]->length(), region_name, 0, Region::Flag (Region::DefaultFlags|Region::WholeFile|Region::External))); if (use_timestamp) { ar->special_set_position(sources[0]->natural_position()); } regions.push_back (ar); } else if (target_regions == -1 || target_regions > 1) { /* take each source and create a region for each one */ SourceList just_one; SourceList::iterator x; uint32_t n; for (n = 0, x = sources.begin(); x != sources.end(); ++x, ++n) { just_one.clear (); just_one.push_back (*x); boost::shared_ptr afs = boost::dynamic_pointer_cast (*x); region_name = region_name_from_path (afs->path(), false, true, sources.size(), n); boost::shared_ptr ar = boost::dynamic_pointer_cast (RegionFactory::create (just_one, 0, (*x)->length(), region_name, 0, Region::Flag (Region::DefaultFlags|Region::WholeFile|Region::External))); if (use_timestamp) { ar->special_set_position((*x)->natural_position()); } regions.push_back (ar); } } if (target_regions == 1) { input_chan = regions.front()->n_channels(); } else { if (target_tracks == 1) { input_chan = regions.size(); } else { input_chan = 1; } } if (Config->get_output_auto_connect() & AutoConnectMaster) { output_chan = (session->master_out() ? session->master_out()->n_inputs() : input_chan); } else { output_chan = input_chan; } int n = 0; for (vector >::iterator r = regions.begin(); r != regions.end(); ++r, ++n) { finish_bringing_in_audio (*r, input_chan, output_chan, pos, mode, track); if (target_tracks != 1) { track.reset (); } else { pos += (*r)->length(); } } /* setup peak file building in another thread */ for (SourceList::iterator x = sources.begin(); x != sources.end(); ++x) { SourceFactory::setup_peakfile (*x, true); } return 0; } int Editor::finish_bringing_in_audio (boost::shared_ptr region, uint32_t in_chans, uint32_t out_chans, nframes64_t& pos, ImportMode mode, boost::shared_ptr& existing_track) { switch (mode) { case ImportAsRegion: /* relax, its been done */ break; case ImportToTrack: { if (!existing_track) { existing_track = get_nth_selected_audio_track (0); if (!existing_track) { return -1; } } boost::shared_ptr playlist = existing_track->diskstream()->playlist(); boost::shared_ptr copy (boost::dynamic_pointer_cast (RegionFactory::create (region))); begin_reversible_command (_("insert sndfile")); XMLNode &before = playlist->get_state(); playlist->add_region (copy, pos); session->add_command (new MementoCommand(*playlist, &before, &playlist->get_state())); commit_reversible_command (); break; } case ImportAsTrack: { if (!existing_track) { list > at (session->new_audio_track (in_chans, out_chans, Normal, 1)); if (at.empty()) { return -1; } existing_track = at.front(); existing_track->set_name (region->name(), this); } boost::shared_ptr copy (boost::dynamic_pointer_cast (RegionFactory::create (region))); existing_track->diskstream()->playlist()->add_region (copy, pos); break; } case ImportAsTapeTrack: { list > at (session->new_audio_track (in_chans, out_chans, Destructive)); if (!at.empty()) { boost::shared_ptr copy (boost::dynamic_pointer_cast (RegionFactory::create (region))); at.front()->set_name (basename_nosuffix (copy->name()), this); at.front()->diskstream()->playlist()->add_region (copy, pos); } break; } } return 0; } void * Editor::_import_thread (void *arg) { PBD::notify_gui_about_thread_creation (pthread_self(), X_("Import")); Editor *ed = (Editor *) arg; return ed->import_thread (); } void * Editor::import_thread () { session->import_audiofiles (import_status); pthread_exit_pbd (0); /*NOTREACHED*/ return 0; } gint Editor::import_progress_timeout (void *arg) { bool reset = false; if (!interthread_progress_window->is_visible()) { interthread_progress_window->show_all (); reset = true; } interthread_progress_label.set_text (import_status.doing_what); if (import_status.freeze) { interthread_cancel_button.set_sensitive(false); } else { interthread_cancel_button.set_sensitive(true); } if (import_status.doing_what == "building peak files") { interthread_progress_bar.pulse (); return FALSE; } else { float val = import_status.progress; interthread_progress_bar.set_fraction (min (max (0.0f, val), 1.0f)); } if (reset) { /* the window is now visible, speed up the updates */ interthread_progress_connection.disconnect (); interthread_progress_connection = Glib::signal_timeout().connect (bind (mem_fun(*this, &Editor::import_progress_timeout), (gpointer) 0), 100); return false; } else { return !(import_status.done || import_status.cancel); } }