refactor playlist sources to allow for MIDI and upcoming work on save/restore
[ardour.git] / libs / ardour / source_factory.cc
index c6b19c860030523156b83f0e865b581ba480df23..4d3f02b1dc68bad81516a0a40b77f624436f23bf 100644 (file)
@@ -1,5 +1,5 @@
 /*
-    Copyright (C) 2000-2006 Paul Davis 
+    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
     $Id$
 */
 
-#include <pbd/error.h>
-#include <pbd/convert.h>
-#include <pbd/pthread_utils.h>
+#ifdef WAF_BUILD
+#include "libardour-config.h"
+#endif
 
-#include <ardour/source_factory.h>
-#include <ardour/sndfilesource.h>
-#include <ardour/silentfilesource.h>
-#include <ardour/configuration.h>
-#include <ardour/smf_source.h>
+#include "pbd/boost_debug.h"
+#include "pbd/error.h"
+#include "pbd/convert.h"
+#include "pbd/pthread_utils.h"
+#include "pbd/stacktrace.h"
+
+#include "ardour/audioplaylist.h"
+#include "ardour/audio_playlist_source.h"
+#include "ardour/source_factory.h"
+#include "ardour/sndfilesource.h"
+#include "ardour/silentfilesource.h"
+#include "ardour/rc_configuration.h"
+#include "ardour/smf_source.h"
+#include "ardour/session.h"
+
+#ifdef  HAVE_COREAUDIO
+#define USE_COREAUDIO_FOR_FILES
+#endif
 
-#ifdef HAVE_COREAUDIO
-#include <ardour/coreaudiosource.h>
+#ifdef USE_COREAUDIO_FOR_FILES
+#include "ardour/coreaudiosource.h"
 #endif
 
+
 #include "i18n.h"
 
 using namespace ARDOUR;
 using namespace std;
 using namespace PBD;
 
-sigc::signal<void,boost::shared_ptr<Source> > SourceFactory::SourceCreated;
+PBD::Signal1<void,boost::shared_ptr<Source> > SourceFactory::SourceCreated;
 Glib::Cond* SourceFactory::PeaksToBuild;
-Glib::StaticMutex SourceFactory::peak_building_lock;
+Glib::StaticMutex SourceFactory::peak_building_lock = GLIBMM_STATIC_MUTEX_INIT;
 std::list<boost::weak_ptr<AudioSource> > SourceFactory::files_with_peaks;
 
-static void 
+static void
 peak_thread_work ()
 {
-       PBD::ThreadCreated (pthread_self(), string ("peakbuilder-") + to_string (pthread_self(), std::dec));
+       SessionEvent::create_per_thread_pool (X_("PeakFile Builder "), 64);
 
        while (true) {
 
                SourceFactory::peak_building_lock.lock ();
-               
+
          wait:
                if (SourceFactory::files_with_peaks.empty()) {
                        SourceFactory::PeaksToBuild->wait (SourceFactory::peak_building_lock);
@@ -60,11 +74,11 @@ peak_thread_work ()
                if (SourceFactory::files_with_peaks.empty()) {
                        goto wait;
                }
-               
+
                boost::shared_ptr<AudioSource> as (SourceFactory::files_with_peaks.front().lock());
                SourceFactory::files_with_peaks.pop_front ();
                SourceFactory::peak_building_lock.unlock ();
-               
+
                if (!as) {
                        continue;
                }
@@ -109,163 +123,246 @@ SourceFactory::setup_peakfile (boost::shared_ptr<Source> s, bool async)
 }
 
 boost::shared_ptr<Source>
-SourceFactory::createSilent (Session& s, const XMLNode& node, nframes_t nframes, float sr)
+SourceFactory::createSilent (Session& s, const XMLNode& node, framecnt_t nframes, float sr)
 {
-       boost::shared_ptr<Source> ret (new SilentFileSource (s, node, nframes, sr));
+       Source* src = new SilentFileSource (s, node, nframes, sr);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+       // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+       boost::shared_ptr<Source> ret (src);
+       // no analysis data - the file is non-existent
        SourceCreated (ret);
        return ret;
 }
 
-#ifdef USE_COREAUDIO_FOR_FILES
 boost::shared_ptr<Source>
 SourceFactory::create (Session& s, const XMLNode& node, bool defer_peaks)
 {
-       try {
-               boost::shared_ptr<Source> ret (new CoreAudioSource (s, node));
-               if (!defer_peaks) {
-                       if (setup_peakfile (ret, false)) {
+       DataType type = DataType::AUDIO;
+       const XMLProperty* prop = node.property("type");
+
+       if (prop) {
+               type = DataType (prop->value());
+       }
+
+       if (type == DataType::AUDIO) {
+
+               try {
+                       Source* src = new SndFileSource (s, node);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+                       // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+                       boost::shared_ptr<Source> ret (src);
+                       if (setup_peakfile (ret, defer_peaks)) {
                                return boost::shared_ptr<Source>();
                        }
+                       ret->check_for_analysis_data_on_disk ();
+                       SourceCreated (ret);
+                       return ret;
                }
-               SourceCreated (ret);
-               return ret;
-       } 
 
+               catch (failed_constructor& err) {
 
-       catch (failed_constructor& err) {       
+#ifdef USE_COREAUDIO_FOR_FILES
+
+                       /* this is allowed to throw */
 
-               /* this is allowed to throw */
+                       Source *src = new CoreAudioSource (s, node);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+                       // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+                       boost::shared_ptr<Source> ret (src);
 
-               boost::shared_ptr<Source> ret (new SndFileSource (s, node));
-               if (!defer_peaks) {
-                       if (setup_peakfile (ret, false)) {
+                       if (setup_peakfile (ret, defer_peaks)) {
                                return boost::shared_ptr<Source>();
                        }
+
+                       ret->check_for_analysis_data_on_disk ();
+                       SourceCreated (ret);
+                       return ret;
+#else
+                       throw; // rethrow
+#endif
                }
-               SourceCreated (ret);
-               return ret;
+
+       } else if (type == DataType::MIDI) {
+               boost::shared_ptr<SMFSource> src (new SMFSource (s, node));
+               src->load_model (true, true);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+               src->check_for_analysis_data_on_disk ();
+               SourceCreated (src);
+               return src;
        }
 
        return boost::shared_ptr<Source>();
 }
 
-#else
-
 boost::shared_ptr<Source>
-SourceFactory::create (Session& s, const XMLNode& node, bool defer_peaks)
+SourceFactory::createReadable (DataType type, Session& s, const string& path,
+                              int chn, Source::Flag flags, bool announce, bool defer_peaks)
 {
-       /* this is allowed to throw */
+       if (type == DataType::AUDIO) {
 
-       boost::shared_ptr<Source> ret (new SndFileSource (s, node));
-       
-       if (!defer_peaks) {
-               if (setup_peakfile (ret, false)) {
-                       return boost::shared_ptr<Source>();
-               }
-       }
-       
-       SourceCreated (ret);
-       return ret;
-}
+               if (!(flags & Destructive)) {
 
-#endif // USE_COREAUDIO_FOR_FILES
+                       try {
 
-boost::shared_ptr<Source>
-SourceFactory::createReadable (DataType type, Session& s, string path, int chn, AudioFileSource::Flag flags, bool announce, bool defer_peaks)
-{
-       if (type == DataType::AUDIO) {
-       
-#ifdef HAVE_COREAUDIO
-               try {
-                       boost::shared_ptr<Source> ret (new CoreAudioSource (s, path, chn, flags));
-                       if (!defer_peaks) {
-                               if (setup_peakfile (ret, false)) {
+                               Source* src = new SndFileSource (s, path, chn, flags);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+                               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+                               boost::shared_ptr<Source> ret (src);
+                               
+                               if (setup_peakfile (ret, defer_peaks)) {
                                        return boost::shared_ptr<Source>();
                                }
+
+                               ret->check_for_analysis_data_on_disk ();
+                               if (announce) {
+                                       SourceCreated (ret);
+                               }
+                               return ret;
                        }
-                       if (announce) {
-                               SourceCreated (ret);
-                       }
-                       return ret;
-               }
-               
-               catch (failed_constructor& err) {
-                       boost::shared_ptr<Source> ret (new SndFileSource (s, path, chn, flags));
-                       if (!defer_peaks) {
-                               if (setup_peakfile (ret, false)) {
+
+                       catch (failed_constructor& err) {
+#ifdef USE_COREAUDIO_FOR_FILES
+
+                               Source* src = new CoreAudioSource (s, path, chn, flags);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+                               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+                               boost::shared_ptr<Source> ret (src);
+                               if (setup_peakfile (ret, defer_peaks)) {
                                        return boost::shared_ptr<Source>();
                                }
-                       }
-                       if (announce) {
-                               SourceCreated (ret);
-                       }
-                       return ret;
-               }
-#else
-               boost::shared_ptr<Source> ret (new SndFileSource (s, path, chn, flags));
+                               ret->check_for_analysis_data_on_disk ();
+                               if (announce) {
+                                       SourceCreated (ret);
+                               }
+                               return ret;
 
-               if (!defer_peaks) {
-                       if (setup_peakfile (ret, false)) {
-                               return boost::shared_ptr<Source>();
+#else
+                               throw; // rethrow
+#endif
                        }
-               }
 
-               if (announce) {
-                       SourceCreated (ret);
+               } else {
+                       // eh?
                }
 
-               return ret;
-#endif
-               
        } else if (type == DataType::MIDI) {
-
-               // FIXME: flags?
-               boost::shared_ptr<Source> ret (new SMFSource (s, path, SMFSource::Flag(0)));
+               
+               SMFSource* src = new SMFSource (s, path, SMFSource::Flag(0));
+               src->load_model (true, true);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+               boost::shared_ptr<Source> ret (src);
 
                if (announce) {
                        SourceCreated (ret);
                }
 
                return ret;
+
        }
 
        return boost::shared_ptr<Source>();
 }
 
 boost::shared_ptr<Source>
-SourceFactory::createWritable (DataType type, Session& s, std::string path, bool destructive, nframes_t rate, bool announce, bool defer_peaks)
+SourceFactory::createWritable (DataType type, Session& s, const std::string& path, const std::string& origin,
+                              bool destructive, framecnt_t rate, bool announce, bool defer_peaks)
 {
        /* this might throw failed_constructor(), which is OK */
-       
+
        if (type == DataType::AUDIO) {
-               boost::shared_ptr<Source> ret (new SndFileSource 
-                                              (s, path, 
-                                               Config->get_native_file_data_format(),
-                                               Config->get_native_file_header_format(),
-                                               rate,
-                                               (destructive ? AudioFileSource::Flag (SndFileSource::default_writable_flags | AudioFileSource::Destructive) :
-                                                SndFileSource::default_writable_flags)));      
-
-               if (!defer_peaks) {
-                       if (setup_peakfile (ret, false)) {
-                               return boost::shared_ptr<Source>();
-                       }
+               Source* src = new SndFileSource (s, path, origin,
+                               s.config.get_native_file_data_format(),
+                               s.config.get_native_file_header_format(),
+                               rate,
+                               (destructive
+                                       ? Source::Flag (SndFileSource::default_writable_flags | Source::Destructive)
+                                : SndFileSource::default_writable_flags));
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+               boost::shared_ptr<Source> ret (src);
+
+               if (setup_peakfile (ret, defer_peaks)) {
+                       return boost::shared_ptr<Source>();
                }
+
+               // no analysis data - this is a new file
+
                if (announce) {
                        SourceCreated (ret);
                }
                return ret;
 
        } else if (type == DataType::MIDI) {
-
-               boost::shared_ptr<Source> ret (new SMFSource (s, path));
+                // XXX writable flags should belong to MidiSource too
+               boost::shared_ptr<SMFSource> src (new SMFSource (s, path, SndFileSource::default_writable_flags));
+               assert (src->writable ());
                
+               src->load_model (true, true);
+#ifdef BOOST_SP_ENABLE_DEBUG_HOOKS
+               // boost_debug_shared_ptr_mark_interesting (src, "Source");
+#endif
+
+               // no analysis data - this is a new file
+
                if (announce) {
-                       SourceCreated (ret);
+                       SourceCreated (src);
                }
-               return ret;
+               return src;
 
        }
 
        return boost::shared_ptr<Source> ();
 }
+
+boost::shared_ptr<Source>
+SourceFactory::createFromPlaylist (DataType type, Session& s, boost::shared_ptr<Playlist> p, const std::string& name,
+                                  uint32_t chn, frameoffset_t start, framecnt_t len, bool copy, bool defer_peaks)
+{
+       if (type == DataType::AUDIO) {
+               try {
+
+                       boost::shared_ptr<AudioPlaylist> ap = boost::dynamic_pointer_cast<AudioPlaylist>(p);
+                       
+                       if (ap) {
+                               
+                               if (copy) {
+                                       ap.reset (new AudioPlaylist (ap, start, len, name, true));
+                                       start = 0;
+                               }
+                               
+                               Source* src = new AudioPlaylistSource (s, name, ap, chn, start, len, Source::Flag (0));
+                               boost::shared_ptr<Source> ret (src);
+                               
+                               if (setup_peakfile (ret, defer_peaks)) {
+                                       return boost::shared_ptr<Source>();
+                               }
+                               
+                               ret->check_for_analysis_data_on_disk ();
+                               
+                               /* we never announce these sources */
+                               
+                               return ret;
+                       }
+               }
+
+               catch (failed_constructor& err) {
+                       /* relax - return at function scope */
+               }
+
+       } else if (type == DataType::MIDI) {
+
+       }
+
+       return boost::shared_ptr<Source>();
+}
+