Move panner bypass state up to the PannerShell so that it is preserved even when...
[ardour.git] / libs / ardour / delivery.cc
index 56057ca7cc4bafa4d9f2a69a6bffa5fe0efcf053..e7d435bacfd5470705bee37666707bfa4521d45e 100644 (file)
@@ -27,6 +27,7 @@
 #include "ardour/debug.h"
 #include "ardour/delivery.h"
 #include "ardour/audio_buffer.h"
+#include "ardour/audio_port.h"
 #include "ardour/amp.h"
 #include "ardour/buffer_set.h"
 #include "ardour/configuration.h"
@@ -52,18 +53,21 @@ bool                          Delivery::panners_legal = false;
 
 /* deliver to an existing IO object */
 
-Delivery::Delivery (Session& s, boost::shared_ptr<IO> io, boost::shared_ptr<Pannable> pannable, 
+Delivery::Delivery (Session& s, boost::shared_ptr<IO> io, boost::shared_ptr<Pannable> pannable,
                     boost::shared_ptr<MuteMaster> mm, const string& name, Role r)
        : IOProcessor(s, boost::shared_ptr<IO>(), (role_requires_output_ports (r) ? io : boost::shared_ptr<IO>()), name)
        , _role (r)
        , _output_buffers (new BufferSet())
        , _current_gain (1.0)
-       , _output_offset (0)
        , _no_outs_cuz_we_no_monitor (false)
        , _mute_master (mm)
        , no_panner_reset (false)
+        , scnt (0)
 {
-       _panshell = boost::shared_ptr<PannerShell>(new PannerShell (_name, _session, pannable));
+       if (pannable) {
+               _panshell = boost::shared_ptr<PannerShell>(new PannerShell (_name, _session, pannable));
+       }
+
        _display_to_user = false;
 
        if (_output) {
@@ -80,12 +84,15 @@ Delivery::Delivery (Session& s, boost::shared_ptr<Pannable> pannable, boost::sha
        , _role (r)
        , _output_buffers (new BufferSet())
        , _current_gain (1.0)
-       , _output_offset (0)
        , _no_outs_cuz_we_no_monitor (false)
        , _mute_master (mm)
        , no_panner_reset (false)
+        , scnt (0)
 {
-       _panshell = boost::shared_ptr<PannerShell>(new PannerShell (_name, _session, pannable));
+       if (pannable) {
+               _panshell = boost::shared_ptr<PannerShell>(new PannerShell (_name, _session, pannable));
+       }
+
        _display_to_user = false;
 
        if (_output) {
@@ -98,7 +105,7 @@ Delivery::Delivery (Session& s, boost::shared_ptr<Pannable> pannable, boost::sha
 
 Delivery::~Delivery()
 {
-       DEBUG_TRACE (DEBUG::Destruction, string_compose ("delivery %1 destructor\n", _name));        
+       DEBUG_TRACE (DEBUG::Destruction, string_compose ("delivery %1 destructor\n", _name));
        delete _output_buffers;
 }
 
@@ -122,16 +129,9 @@ Delivery::display_name () const
 void
 Delivery::cycle_start (pframes_t /*nframes*/)
 {
-       _output_offset = 0;
        _no_outs_cuz_we_no_monitor = false;
 }
 
-void
-Delivery::increment_output_offset (framecnt_t n)
-{
-       _output_offset += n;
-}
-
 bool
 Delivery::can_support_io_configuration (const ChanCount& in, ChanCount& out) const
 {
@@ -220,7 +220,7 @@ Delivery::configure_io (ChanCount in, ChanCount out)
                }
 
        }
-       
+
        if (!Processor::configure_io (in, out)) {
                return false;
        }
@@ -233,8 +233,6 @@ Delivery::configure_io (ChanCount in, ChanCount out)
 void
 Delivery::run (BufferSet& bufs, framepos_t start_frame, framepos_t end_frame, pframes_t nframes, bool result_required)
 {
-        boost::shared_ptr<Panner> panner;
-
        assert (_output);
 
        PortSet& ports (_output->ports());
@@ -253,7 +251,7 @@ Delivery::run (BufferSet& bufs, framepos_t start_frame, framepos_t end_frame, pf
           processing pathway that wants to use this->output_buffers() for some reason.
        */
 
-       output_buffers().get_jack_port_addresses (ports, nframes, _output_offset);
+       output_buffers().get_jack_port_addresses (ports, nframes);
 
        // this Delivery processor is not a derived type, and thus we assume
        // we really can modify the buffers passed in (it is almost certainly
@@ -276,6 +274,7 @@ Delivery::run (BufferSet& bufs, framepos_t start_frame, framepos_t end_frame, pf
 
                _output->silence (nframes);
                if (result_required) {
+                       bufs.set_count (output_buffers().count ());
                        Amp::apply_simple_gain (bufs, nframes, 0.0);
                }
                goto out;
@@ -286,31 +285,45 @@ Delivery::run (BufferSet& bufs, framepos_t start_frame, framepos_t end_frame, pf
                Amp::apply_simple_gain (bufs, nframes, tgain);
        }
 
-        panner = _panshell->panner();
+#if 0
+        if (_session.transport_rolling()) {
+                cerr << name() << " first value written : " << scnt << endl;
+                for (BufferSet::audio_iterator b = bufs.audio_begin(); b != bufs.audio_end(); ++b) {
+                        Sample* p = b->data ();
+                        float s = (float) scnt;
+                        for (pframes_t n = 0; n < nframes; ++n) {
+                                p[n] =  s * 0.001;
+                                s += 1.0;
+                        }
+                }
+                scnt += nframes;
+        }
+#endif
 
-       if (panner && !panner->bypassed()) {
+       if (_panshell && !_panshell->bypassed()) {
 
                // Use the panner to distribute audio to output port buffers
 
                _panshell->run (bufs, output_buffers(), start_frame, end_frame, nframes);
 
-               if (result_required) {
-                       bufs.read_from (output_buffers (), nframes);
-               }
 
        } else {
 
                // Do a 1:1 copy of data to output ports
 
                if (bufs.count().n_audio() > 0 && ports.count().n_audio () > 0) {
-                       _output->copy_to_outputs (bufs, DataType::AUDIO, nframes, _output_offset);
+                       _output->copy_to_outputs (bufs, DataType::AUDIO, nframes, 0);
                 }
 
                if (bufs.count().n_midi() > 0 && ports.count().n_midi () > 0) {
-                       _output->copy_to_outputs (bufs, DataType::MIDI, nframes, _output_offset);
+                       _output->copy_to_outputs (bufs, DataType::MIDI, nframes, 0);
                }
        }
 
+        if (result_required) {
+                bufs.read_from (output_buffers (), nframes);
+        }
+
   out:
        _active = _pending_active;
 }
@@ -329,7 +342,10 @@ Delivery::state (bool full_state)
        }
 
        node.add_property("role", enum_2_string(_role));
-       node.add_child_nocopy (_panshell->state (full_state));
+
+       if (_panshell) {
+               node.add_child_nocopy (_panshell->get_state ());
+       }
 
        return node;
 }
@@ -350,9 +366,9 @@ Delivery::set_state (const XMLNode& node, int version)
                // std::cerr << this << ' ' << _name << " NO ROLE INFO\n";
        }
 
-       XMLNode* pan_node = node.child (X_("Panner"));
+       XMLNode* pan_node = node.child (X_("PannerShell"));
 
-       if (pan_node) {
+       if (pan_node && _panshell) {
                _panshell->set_state (*pan_node, version);
        }
 
@@ -362,13 +378,16 @@ Delivery::set_state (const XMLNode& node, int version)
 }
 
 void
-Delivery::reset_panner ()
+Delivery::unpan ()
 {
-        if (_role == Listen) {
-                /* monitor out gets no panner */
-                return;
-        }
+       /* caller must hold process lock */
+
+       _panshell.reset ();
+}
 
+void
+Delivery::reset_panner ()
+{
        if (panners_legal) {
                if (!no_panner_reset) {
 
@@ -380,11 +399,13 @@ Delivery::reset_panner ()
                                ntargets = _configured_output.n_audio();
                        }
 
-                       _panshell->configure_io (ChanCount (DataType::AUDIO, pans_required()), ChanCount (DataType::AUDIO, ntargets));
-
-                        if (_role == Main) {
-                                _panshell->pannable()->set_panner (_panshell->panner());
-                        }
+                       if (_panshell) {
+                               _panshell->configure_io (ChanCount (DataType::AUDIO, pans_required()), ChanCount (DataType::AUDIO, ntargets));
+                               
+                               if (_role == Main) {
+                                       _panshell->pannable()->set_panner (_panshell->panner());
+                               }
+                       }
                }
 
        } else {
@@ -404,11 +425,13 @@ Delivery::panners_became_legal ()
                ntargets = _configured_output.n_audio();
        }
 
-       _panshell->configure_io (ChanCount (DataType::AUDIO, pans_required()), ChanCount (DataType::AUDIO, ntargets));
-
-        if (_role == Main) {
-                _panshell->pannable()->set_panner (_panshell->panner());
-        }
+       if (_panshell) {
+               _panshell->configure_io (ChanCount (DataType::AUDIO, pans_required()), ChanCount (DataType::AUDIO, ntargets));
+               
+               if (_role == Main) {
+                       _panshell->pannable()->set_panner (_panshell->panner());
+               }
+       }
 
        panner_legal_c.disconnect ();
        return 0;
@@ -448,9 +471,9 @@ Delivery::flush_buffers (framecnt_t nframes, framepos_t time)
        /* io_lock, not taken: function must be called from Session::process() calltree */
 
        PortSet& ports (_output->ports());
-        
+
        for (PortSet::iterator i = ports.begin(); i != ports.end(); ++i) {
-               (*i).flush_buffers (nframes, time, _output_offset);
+               (*i).flush_buffers (nframes, time);
        }
 }
 
@@ -458,17 +481,32 @@ void
 Delivery::transport_stopped (framepos_t now)
 {
         Processor::transport_stopped (now);
-        _panshell->pannable()->transport_stopped (now);
+
+       if (_panshell) {
+               _panshell->pannable()->transport_stopped (now);
+       }
 
         if (_output) {
                 PortSet& ports (_output->ports());
-                
+
                 for (PortSet::iterator i = ports.begin(); i != ports.end(); ++i) {
                         (*i).transport_stopped ();
                 }
         }
 }
 
+void
+Delivery::realtime_locate ()
+{
+        if (_output) {
+                PortSet& ports (_output->ports());
+
+                for (PortSet::iterator i = ports.begin(); i != ports.end(); ++i) {
+                        (*i).realtime_locate ();
+                }
+        }
+}
+
 gain_t
 Delivery::target_gain ()
 {
@@ -487,7 +525,7 @@ Delivery::target_gain ()
        }
 
         MuteMaster::MutePoint mp = MuteMaster::Main; // stupid gcc uninit warning
-        
+
         switch (_role) {
         case Main:
                 mp = MuteMaster::Main;
@@ -507,17 +545,17 @@ Delivery::target_gain ()
         }
 
         gain_t desired_gain = _mute_master->mute_gain_at (mp);
-        
+
         if (_role == Listen && _session.monitor_out() && !_session.listening()) {
-                
+
                 /* nobody is soloed, and this delivery is a listen-send to the
                    control/monitor/listen bus, we should be silent since
                    it gets its signal from the master out.
                 */
-                
+
                 desired_gain = 0.0;
-                
-        } 
+
+        }
 
        return desired_gain;
 }
@@ -552,5 +590,10 @@ Delivery::output_changed (IOChange change, void* /*src*/)
 boost::shared_ptr<Panner>
 Delivery::panner () const
 {
-        return _panshell->panner();
+       if (_panshell) {
+               return _panshell->panner();
+       } else {
+               return boost::shared_ptr<Panner>();
+       }
 }
+