backend for auditioning midi-files:
authorRobin Gareus <robin@gareus.org>
Wed, 22 Jan 2014 14:25:39 +0000 (15:25 +0100)
committerRobin Gareus <robin@gareus.org>
Wed, 22 Jan 2014 14:30:18 +0000 (15:30 +0100)
* "downgrade" auditioner from AudioTrack to Track.
* add relevant methods from both AudioTrack and MidiTrack.

libs/ardour/ardour/audio_diskstream.h
libs/ardour/ardour/auditioner.h
libs/ardour/ardour/midi_diskstream.h
libs/ardour/auditioner.cc

index 5a856e9b364615b4b6a76ce041c682d1258f49de..3a5dc2ad91a4af0d04489924a3b268192694e555 100644 (file)
@@ -146,10 +146,8 @@ class AudioDiskstream : public Diskstream
 
   protected:
        friend class Auditioner;
-       int  seek (framepos_t which_sample, bool complete_refill = false);
-
-  protected:
        friend class AudioTrack;
+       int  seek (framepos_t which_sample, bool complete_refill = false);
 
         int  process (BufferSet&, framepos_t transport_frame, pframes_t nframes, framecnt_t &, bool need_disk_signal);
         frameoffset_t calculate_playback_distance (pframes_t nframes);
index 7e772fe194dd8df866a613e440be3387baa40e55..696dd1fb8ed947874f2405e35f3a07afd83e7c86 100644 (file)
 
 #include "ardour/ardour.h"
 #include "ardour/audio_track.h"
+#include "ardour/midi_region.h"
+
+#include "ardour/audio_diskstream.h"
+#include "ardour/midi_diskstream.h"
 
 namespace ARDOUR {
 
@@ -33,14 +37,14 @@ class Session;
 class AudioRegion;
 class AudioPlaylist;
 
-class Auditioner : public AudioTrack
+class Auditioner : public Track
 {
   public:
        Auditioner (Session&);
        ~Auditioner ();
 
        int init ();
-        int connect ();
+       int connect ();
 
        void audition_region (boost::shared_ptr<Region>);
 
@@ -63,11 +67,52 @@ class Auditioner : public AudioTrack
        virtual ChanCount input_streams () const;
 
        frameoffset_t seek_frame() const { return _seeking ? _seek_frame : -1;}
-       void seek_response(frameoffset_t pos) { _seek_complete = true; if (_seeking) { current_frame = pos; _seek_complete = true;} }
+       void seek_response(frameoffset_t pos) {
+               _seek_complete = true;
+               if (_seeking) { current_frame = pos; _seek_complete = true;}
+       }
+
        PBD::Signal2<void, ARDOUR::framecnt_t, ARDOUR::framecnt_t> AuditionProgress;
 
+       /* Track */
+       int roll (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler);
+       DataType data_type () const;
+
+       int roll_audio (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler);
+       int roll_midi (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler);
+
+       boost::shared_ptr<Diskstream> create_diskstream ();
+       void set_diskstream (boost::shared_ptr<Diskstream> ds);
+
+       /* fake track */
+       void set_state_part_two () {}
+       int set_state (const XMLNode&, int) { return 0; }
+       bool bounceable (boost::shared_ptr<Processor>, bool) const { return false; }
+       void freeze_me (InterThreadInfo&) {}
+       void unfreeze () {}
+
+       boost::shared_ptr<Region> bounce (InterThreadInfo&)
+               { return boost::shared_ptr<Region> (); }
+
+       boost::shared_ptr<Region> bounce_range (framepos_t, framepos_t, InterThreadInfo&, boost::shared_ptr<Processor>, bool)
+               { return boost::shared_ptr<Region> (); }
+
+       int export_stuff (BufferSet&, framepos_t, framecnt_t, boost::shared_ptr<Processor>, bool, bool)
+               { return -1; }
+
+       boost::shared_ptr<Diskstream> diskstream_factory (XMLNode const &)
+               { return boost::shared_ptr<Diskstream> (); }
+
+       boost::shared_ptr<AudioDiskstream> audio_diskstream() const
+               { return boost::dynamic_pointer_cast<AudioDiskstream> (_diskstream); }
+
+       boost::shared_ptr<MidiDiskstream> midi_diskstream() const
+               { return boost::dynamic_pointer_cast<MidiDiskstream> (_diskstream); }
+
+
   private:
        boost::shared_ptr<AudioRegion> the_region;
+       boost::shared_ptr<MidiRegion> midi_region;
        framepos_t current_frame;
        mutable gint _auditioning;
        Glib::Threads::Mutex lock;
@@ -76,6 +121,12 @@ class Auditioner : public AudioTrack
        bool _seeking;
        bool _seek_complete;
        bool via_monitor;
+       bool _midi_audition;
+       bool _synth_added;
+
+       boost::shared_ptr<Diskstream> _diskstream_audio;
+       boost::shared_ptr<Diskstream> _diskstream_midi;
+       boost::shared_ptr<Processor> asynth;
 
        void drop_ports ();
        static void *_drop_ports (void *);
index b1c126b339ff8ba0c10af87c1514215eb15854d9..c2c3f5801f6fcdecaddab892a71bbdea12d20902 100644 (file)
@@ -118,11 +118,10 @@ class MidiDiskstream : public Diskstream
 
        static void set_readahead_frames (framecnt_t frames_ahead) { midi_readahead = frames_ahead; }
 
-  protected:
-       int seek (framepos_t which_sample, bool complete_refill = false);
-
   protected:
        friend class MidiTrack;
+       friend class Auditioner;
+       int seek (framepos_t which_sample, bool complete_refill = false);
 
         int  process (BufferSet&, framepos_t transport_frame, pframes_t nframes, framecnt_t &, bool need_diskstream);
         frameoffset_t calculate_playback_distance (pframes_t nframes);
index 75a40f142db7a7bd30292ef7302662ff671b9245..a0789b3034e98a7f1feeea77f6e128107b463250 100644 (file)
 
 #include "pbd/error.h"
 
-#include "ardour/audio_diskstream.h"
+#include "ardour/amp.h"
 #include "ardour/audioregion.h"
 #include "ardour/audioengine.h"
-#include "ardour/delivery.h"
-#include "ardour/route.h"
-#include "ardour/session.h"
-#include "ardour/auditioner.h"
 #include "ardour/audioplaylist.h"
+#include "ardour/auditioner.h"
 #include "ardour/audio_port.h"
 #include "ardour/data_type.h"
+#include "ardour/delivery.h"
+#include "ardour/plugin.h"
 #include "ardour/region_factory.h"
+#include "ardour/route.h"
+#include "ardour/session.h"
 
 using namespace std;
 using namespace ARDOUR;
@@ -40,31 +41,38 @@ using namespace PBD;
 #include "i18n.h"
 
 Auditioner::Auditioner (Session& s)
-       : AudioTrack (s, "auditioner", Route::Auditioner)
-        , current_frame (0)
-        , _auditioning (0)
-        , length (0)
-        , _seek_frame (-1)
-        , _seeking (false)
-        , _seek_complete (false)
-        , via_monitor (false)
+       : Track (s, "auditioner", Route::Auditioner)
+       , current_frame (0)
+       , _auditioning (0)
+       , length (0)
+       , _seek_frame (-1)
+       , _seeking (false)
+       , _seek_complete (false)
+       , via_monitor (false)
+       , _midi_audition (false)
+       , _synth_added (false)
 {
 }
 
 int
 Auditioner::init ()
 {
-        if (Track::init ()) {
-                return -1;
-        }
-       
+       if (Track::init ()) {
+               return -1;
+       }
+
        if (connect ()) {
                return -1;
        }
 
+       _output->add_port ("Midiaudition", this, DataType::MIDI);
+       boost::shared_ptr<Plugin> p = find_plugin (_session, "https://community.ardour.org/node/7596", ARDOUR::LV2);
+       assert(p);
+       asynth = boost::shared_ptr<Processor> (new PluginInsert (_session, p));
+
        _output->changed.connect_same_thread (*this, boost::bind (&Auditioner::output_changed, this, _1, _2));
 
-        return 0;
+       return 0;
 }
 
 Auditioner::~Auditioner ()
@@ -149,9 +157,138 @@ Auditioner::connect ()
        return 0;
 }
 
+
+DataType
+Auditioner::data_type () const {
+       if (_midi_audition) {
+               return DataType::MIDI;
+       } else {
+               return DataType::AUDIO;
+       }
+}
+
+boost::shared_ptr<Diskstream>
+Auditioner::create_diskstream () {
+
+       {
+               AudioDiskstream::Flag dflags = AudioDiskstream::Flag (0);
+               dflags = AudioDiskstream::Flag (dflags | AudioDiskstream::Hidden);
+               _diskstream_audio = boost::shared_ptr<AudioDiskstream> (new AudioDiskstream (_session, name(), dflags));
+       }
+
+       {
+               MidiDiskstream::Flag dflags = MidiDiskstream::Flag (0);
+               dflags = MidiDiskstream::Flag (dflags | MidiDiskstream::Hidden);
+               _diskstream_midi = boost::shared_ptr<Diskstream> (new MidiDiskstream (_session, name(), dflags));
+               _diskstream_midi->do_refill_with_alloc ();
+               _diskstream_midi->playlist()->set_orig_track_id (id());
+       }
+
+       return _diskstream_audio;
+}
+
+int
+Auditioner::roll (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler) {
+       if (_midi_audition) {
+               return roll_midi(nframes, start_frame, end_frame, declick, need_butler);
+       } else {
+               return roll_audio(nframes, start_frame, end_frame, declick, need_butler);
+       }
+}
+
+int
+Auditioner::roll_midi (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler)
+{
+       Glib::Threads::RWLock::ReaderLock lm (_processor_lock, Glib::Threads::TRY_LOCK);
+       if (!lm.locked()) {
+               return 0;
+       }
+
+       assert(_active);
+
+       framecnt_t playback_distance = nframes;
+       boost::shared_ptr<MidiDiskstream> diskstream = midi_diskstream();
+       BufferSet& bufs = _session.get_route_buffers (n_process_buffers());
+
+       _silent = false;
+       MidiBuffer& mbuf (bufs.get_midi (0));
+       diskstream->get_playback (mbuf, nframes);
+
+       ChanCount cnt (DataType::MIDI, 1);
+       cnt.set (DataType::AUDIO, bufs.count().n_audio());
+       bufs.set_count (cnt);
+
+       process_output_buffers (bufs, start_frame, end_frame, nframes,
+                               declick, (!diskstream->record_enabled() && !_session.transport_stopped()));
+
+       for (ProcessorList::iterator i = _processors.begin(); i != _processors.end(); ++i) {
+               boost::shared_ptr<Delivery> d = boost::dynamic_pointer_cast<Delivery> (*i);
+               if (d) {
+                       d->flush_buffers (nframes);
+               }
+       }
+
+       need_butler = diskstream->commit (playback_distance);
+       return 0;
+}
+
+
+int
+Auditioner::roll_audio (pframes_t nframes, framepos_t start_frame, framepos_t end_frame, int declick, bool& need_butler) {
+       Glib::Threads::RWLock::ReaderLock lm (_processor_lock, Glib::Threads::TRY_LOCK);
+       if (!lm.locked()) {
+               return 0;
+       }
+
+       assert(n_outputs().n_total() > 0);
+       assert(_active);
+
+       int dret;
+       framecnt_t playback_distance;
+       framepos_t transport_frame = _session.transport_frame();
+       boost::shared_ptr<AudioDiskstream> diskstream = audio_diskstream();
+       BufferSet& bufs = _session.get_route_buffers (n_process_buffers ());
+
+       _silent = false;
+       _amp->apply_gain_automation(false);
+
+       if ((dret = diskstream->process (bufs, transport_frame, nframes, playback_distance, (monitoring_state() == MonitoringDisk))) != 0) {
+               need_butler = diskstream->commit (playback_distance);
+               silence (nframes);
+               return dret;
+       }
+
+       process_output_buffers (bufs, start_frame, end_frame, nframes, declick, (!diskstream->record_enabled() && _session.transport_rolling()));
+       need_butler = diskstream->commit (playback_distance);
+       return 0;
+}
+
+void
+Auditioner::set_diskstream (boost::shared_ptr<Diskstream> ds)
+{
+       Track::set_diskstream (ds);
+
+       _diskstream->set_track (this);
+       _diskstream->set_destructive (_mode == Destructive);
+       _diskstream->set_non_layered (_mode == NonLayered);
+       _diskstream->set_record_enabled (false);
+       _diskstream->request_input_monitoring (false);
+
+       DiskstreamChanged (); /* EMIT SIGNAL */
+}
+
 AudioPlaylist&
 Auditioner::prepare_playlist ()
 {
+       // used by CrossfadeEditor::audition()
+
+       _midi_audition = false;
+       set_diskstream(_diskstream_audio);
+       if (_synth_added) {
+               remove_processor(asynth);
+               _synth_added = false;
+       }
+
        // FIXME auditioner is still audio-only
        boost::shared_ptr<AudioPlaylist> apl = boost::dynamic_pointer_cast<AudioPlaylist>(_diskstream->playlist());
        assert(apl);
@@ -170,48 +307,100 @@ Auditioner::audition_region (boost::shared_ptr<Region> region)
                cancel_audition ();
        }
 
-       if (boost::dynamic_pointer_cast<AudioRegion>(region) == 0) {
-               error << _("Auditioning of non-audio regions not yet supported") << endmsg;
-               return;
-       }
-
        Glib::Threads::Mutex::Lock lm (lock);
 
-       /* copy it */
+       if (boost::dynamic_pointer_cast<AudioRegion>(region) != 0) {
 
-       boost::shared_ptr<AudioRegion> the_region (boost::dynamic_pointer_cast<AudioRegion> (RegionFactory::create (region)));
-       the_region->set_position (0);
+               _midi_audition = false;
+               set_diskstream(_diskstream_audio);
+               if (_synth_added) {
+                       remove_processor(asynth);
+                       _synth_added = false;
+               }
+               midi_region.reset();
 
-       _diskstream->playlist()->drop_regions ();
-       _diskstream->playlist()->add_region (the_region, 0, 1);
+               /* copy it */
+               the_region = boost::dynamic_pointer_cast<AudioRegion> (RegionFactory::create (region));
+               the_region->set_position (0);
 
-       if (_diskstream->n_channels().n_audio() < the_region->n_channels()) {
-               audio_diskstream()->add_channel (the_region->n_channels() - _diskstream->n_channels().n_audio());
-       } else if (_diskstream->n_channels().n_audio() > the_region->n_channels()) {
-               audio_diskstream()->remove_channel (_diskstream->n_channels().n_audio() - the_region->n_channels());
-       }
+               _diskstream->playlist()->drop_regions ();
+               _diskstream->playlist()->add_region (the_region, 0, 1);
 
-        ProcessorStreams ps;
-       {
-               Glib::Threads::Mutex::Lock lm (AudioEngine::instance()->process_lock ());
+               if (_diskstream->n_channels().n_audio() < the_region->n_channels()) {
+                       audio_diskstream()->add_channel (the_region->n_channels() - _diskstream->n_channels().n_audio());
+               } else if (_diskstream->n_channels().n_audio() > the_region->n_channels()) {
+                       audio_diskstream()->remove_channel (_diskstream->n_channels().n_audio() - the_region->n_channels());
+               }
+
+               ProcessorStreams ps;
+               {
+                       Glib::Threads::Mutex::Lock lm (AudioEngine::instance()->process_lock ());
 
-               if (configure_processors (&ps)) {
-                       error << string_compose (_("Cannot setup auditioner processing flow for %1 channels"),
-                                                _diskstream->n_channels()) << endmsg;
-                       return;
+                       if (configure_processors (&ps)) {
+                               error << string_compose (_("Cannot setup auditioner processing flow for %1 channels"),
+                                                        _diskstream->n_channels()) << endmsg;
+                               return;
+                       }
                }
+
+       } else if (boost::dynamic_pointer_cast<MidiRegion>(region)) {
+               _midi_audition = true;
+               set_diskstream(_diskstream_midi);
+               the_region.reset();
+
+               /* copy it */
+               midi_region = (boost::dynamic_pointer_cast<MidiRegion> (RegionFactory::create (region)));
+               midi_region->set_position (0);
+
+               _diskstream->playlist()->drop_regions ();
+               _diskstream->playlist()->add_region (midi_region, 0, 1);
+               midi_diskstream()->reset_tracker();
+
+               ProcessorStreams ps;
+
+               if (!_synth_added) {
+                       int rv = add_processor_by_index(asynth, PreFader, &ps, true);
+                       if (rv) {
+                               error << _("Failed to load synth for MIDI-Audition.") << endmsg;
+                       } else {
+                               _synth_added = true;
+                       }
+               } else {
+                       // TODO -- queue midi-panic // reset synth -> all notes off
+                       //  here or in first cycle..
+               }
+
+               {
+                       Glib::Threads::Mutex::Lock lm (AudioEngine::instance()->process_lock ());
+
+                       if (configure_processors (&ps)) {
+                               error << string_compose (_("Cannot setup auditioner processing flow for %1 channels"),
+                                                        _diskstream->n_channels()) << endmsg;
+                               return;
+                       }
+               }
+
+       } else {
+               error << _("Auditioning of regions other than Audio or Midi is not supported.") << endmsg;
+               return;
        }
 
        /* force a panner reset now that we have all channels */
-
        _main_outs->reset_panner();
 
        _seek_frame = -1;
        _seeking = false;
-       length = the_region->length();
 
        int dir;
-       framecnt_t offset = the_region->sync_offset (dir);
+       framecnt_t offset;
+
+       if (_midi_audition) {
+               length = midi_region->length();
+               offset = midi_region->sync_offset (dir);
+       } else {
+               length = the_region->length();
+               offset = the_region->sync_offset (dir);
+       }
 
        /* can't audition from a negative sync point */
 
@@ -249,6 +438,7 @@ Auditioner::play_audition (framecnt_t nframes)
                _seek_complete = false;
                _seeking = false;
                _seek_frame = -1;
+               midi_diskstream()->reset_tracker();
        }
 
        if(!_seeking) {
@@ -270,6 +460,7 @@ Auditioner::play_audition (framecnt_t nframes)
                _seek_complete = false;
                _seeking = true;
                need_butler = true;
+               // TODO -- send midi-panic. -> all notes off
        }
 
        if (!_seeking) {
@@ -325,15 +516,19 @@ Auditioner::output_changed (IOChange change, void* /*src*/)
 ChanCount
 Auditioner::input_streams () const
 {
-        /* auditioner never has any inputs - its channel configuration
-           depends solely on the region we are auditioning.
-        */
+       /* auditioner never has any inputs - its channel configuration
+                depends solely on the region we are auditioning.
+                */
 
-        if (audio_diskstream()) {
-                return audio_diskstream()->n_channels();
-        }
+       if (!_midi_audition && audio_diskstream()) {
+               return audio_diskstream()->n_channels();
+       }
+       if (_midi_audition && midi_diskstream()) {
+               ChanCount cnt (DataType::MIDI, 1);
+               return cnt;
+       }
 
-        return ChanCount ();
+       return ChanCount ();
 }
 
 MonitorState