prepare displaying peakfile queue-len
authorRobin Gareus <robin@gareus.org>
Tue, 15 Sep 2015 15:42:59 +0000 (17:42 +0200)
committerRobin Gareus <robin@gareus.org>
Tue, 15 Sep 2015 15:50:27 +0000 (17:50 +0200)
libs/ardour/ardour/source_factory.h
libs/ardour/source_factory.cc

index 614fdce7b19deeda12d905cb8122af47a307c2e6..a41cd36258f57f5f5c80904afb2dede456d207dd 100644 (file)
@@ -68,6 +68,7 @@ class LIBARDOUR_API SourceFactory {
         static Glib::Threads::Mutex                      peak_building_lock;
        static std::list< boost::weak_ptr<AudioSource> > files_with_peaks;
 
+       static int peak_work_queue_length ();
        static int setup_peakfile (boost::shared_ptr<Source>, bool async);
 };
 
index 4b4a3cba33301cc0c7b878b9621e1531ef7018e5..7ef7ae12d1b64944354ace0356bd57771d7bd898 100644 (file)
@@ -32,6 +32,7 @@
 #include "ardour/audio_playlist_source.h"
 #include "ardour/midi_playlist.h"
 #include "ardour/midi_playlist_source.h"
+#include "ardour/source.h"
 #include "ardour/source_factory.h"
 #include "ardour/sndfilesource.h"
 #include "ardour/silentfilesource.h"
@@ -54,6 +55,8 @@ Glib::Threads::Cond SourceFactory::PeaksToBuild;
 Glib::Threads::Mutex SourceFactory::peak_building_lock;
 std::list<boost::weak_ptr<AudioSource> > SourceFactory::files_with_peaks;
 
+static int active_threads = 0;
+
 static void
 peak_thread_work ()
 {
@@ -74,6 +77,7 @@ peak_thread_work ()
 
                boost::shared_ptr<AudioSource> as (SourceFactory::files_with_peaks.front().lock());
                SourceFactory::files_with_peaks.pop_front ();
+               ++active_threads;
                SourceFactory::peak_building_lock.unlock ();
 
                if (!as) {
@@ -81,9 +85,20 @@ peak_thread_work ()
                }
 
                as->setup_peakfile ();
+               SourceFactory::peak_building_lock.lock ();
+               --active_threads;
+               SourceFactory::peak_building_lock.unlock ();
        }
 }
 
+int
+SourceFactory::peak_work_queue_length ()
+{
+       // ideally we'd loop over the queue and check for duplicates
+       // and existing valid peak-files..
+       return SourceFactory::files_with_peaks.size () + active_threads;
+}
+
 void
 SourceFactory::init ()
 {
@@ -99,7 +114,8 @@ SourceFactory::setup_peakfile (boost::shared_ptr<Source> s, bool async)
 
        if (as) {
 
-               if (async) {
+               // immediately set 'peakfile-path' for empty and NoPeakFile sources
+               if (async && !as->empty() && !(as->flags() & Source::NoPeakFile)) {
 
                        Glib::Threads::Mutex::Lock lm (peak_building_lock);
                        files_with_peaks.push_back (boost::weak_ptr<AudioSource> (as));