add new sigc++2 directory
[ardour.git] / libs / ardour / panner.cc
index 4984e13fa9da7ac2d3acf25a42ea6781684f175b..ac8e4d05e32b81783cf0178107c5c0b04ed8013b 100644 (file)
     along with this program; if not, write to the Free Software
     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 
-    $Id$
 */
 
+#define __STDC_FORMAT_MACROS 1
+#include <inttypes.h>
+
 #include <cmath>
 #include <cerrno>
 #include <fstream>
 #include <pbd/error.h>
 #include <pbd/failed_constructor.h>
 #include <pbd/xml++.h>
+#include <pbd/enumwriter.h>
 
 #include <ardour/session.h>
 #include <ardour/panner.h>
 #include <ardour/utils.h>
 
-#include <ardour/mix.h>
+#include <ardour/runtime_functions.h>
+#include <ardour/buffer_set.h>
 
 #include "i18n.h"
 
@@ -65,12 +69,16 @@ static double direct_pan_to_control (pan_t val) {
        return val;
 }
 
-StreamPanner::StreamPanner (Panner& p)
-       : parent (p),
-         _control (*this)
+StreamPanner::StreamPanner (Panner& p, Parameter param)
+       : parent (p)
+       , _control (new PanControllable(p.session(), X_("panner"), *this, param))
 {
+       assert(param.type() != NullAutomation);
+
        _muted = false;
 
+       parent.session().add_controllable (_control);
+
        x = 0.5;
        y = 0.5;
        z = 0.5;
@@ -126,7 +134,7 @@ StreamPanner::set_position (float xpos, bool link_call)
                x = xpos;
                update ();
                Changed ();
-               _control.Changed ();
+               _control->Changed ();
        }
 }
 
@@ -183,8 +191,8 @@ StreamPanner::add_state (XMLNode& node)
 
 /*---------------------------------------------------------------------- */
 
-BaseStereoPanner::BaseStereoPanner (Panner& p)
-       : StreamPanner (p), _automation (0.0, 1.0, 0.5)
+BaseStereoPanner::BaseStereoPanner (Panner& p, Parameter param)
+       : StreamPanner (p, param)
 {
 }
 
@@ -192,81 +200,16 @@ BaseStereoPanner::~BaseStereoPanner ()
 {
 }
 
-void
-BaseStereoPanner::snapshot (jack_nframes_t now)
-{
-       if (_automation.automation_state() == Write || _automation.automation_state() == Touch) {
-               _automation.rt_add (now, x);
-       }
-}
-
-void
-BaseStereoPanner::transport_stopped (jack_nframes_t frame)
-{
-       _automation.reposition_for_rt_add (frame);
-
-       if (_automation.automation_state() != Off) {
-               
-               if (_automation.automation_write()) {
-                       _automation.save_state (_("automation write pass"));
-               }
-
-               set_position (_automation.eval (frame));
-       }
-}
-
-void
-BaseStereoPanner::set_automation_style (AutoStyle style)
-{
-       _automation.set_automation_style (style);
-}
-
-void
-BaseStereoPanner::set_automation_state (AutoState state)
-{
-       if (state != _automation.automation_state()) {
-
-               _automation.set_automation_state (state);
-               
-               if (state != Off) {
-                       set_position (_automation.eval (parent.session().transport_frame()));
-               }
-       }
-}
-
-int
-BaseStereoPanner::save (ostream& out) const
-{
-       LocaleGuard lg (X_("POSIX"));
-
-       /* force a single format for numeric data to ease session interchange
-          across national boundaries.
-       */
-
-       out << "begin" << endl;
-
-       for (AutomationList::const_iterator i = _automation.const_begin(); i != _automation.const_end(); ++i) {
-               out << '\t' << (jack_nframes_t) floor ((*i)->when) << ' ' << (*i)->value << endl;
-               if (!out) {
-                       error << string_compose (_("error writing pan automation file (%s)"), strerror (errno)) << endmsg;
-                       return -1;
-               }
-       }
-       out << "end" << endl;
-
-       return 0;
-}
-                               
 int
 BaseStereoPanner::load (istream& in, string path, uint32_t& linecnt)
 {
        char line[128];
        LocaleGuard lg (X_("POSIX"));
        
-       _automation.clear ();
+       _control->list()->clear ();
 
        while (in.getline (line, sizeof (line), '\n')) {
-               jack_nframes_t when;
+               nframes_t when;
                double value;
 
                ++linecnt;
@@ -280,20 +223,21 @@ BaseStereoPanner::load (istream& in, string path, uint32_t& linecnt)
                        continue;
                }
 
-               _automation.add (when, value, true);
+               _control->list()->fast_simple_add (when, value);
        }
 
        /* now that we are done loading */
 
-       _automation.save_state (_("loaded from disk"));
-       _automation.StateChanged (Change (0));
+       _control->list()->StateChanged ();
 
        return 0;
 }
 
 void
-BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_nframes_t nframes)
+BaseStereoPanner::distribute (AudioBuffer& srcbuf, BufferSet& obufs, gain_t gain_coeff, nframes_t nframes)
 {
+       assert(obufs.count().n_audio() == 2);
+
        pan_t delta;
        Sample* dst;
        pan_t pan;
@@ -301,17 +245,19 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
        if (_muted) {
                return;
        }
+       
+       Sample* const src = srcbuf.data();
 
        /* LEFT */
 
-       dst = obufs[0];
+       dst = obufs.get_audio(0).data();
 
        if (fabsf ((delta = (left - desired_left))) > 0.002) { // about 1 degree of arc 
                
                /* interpolate over 64 frames or nframes, whichever is smaller */
                
-               jack_nframes_t limit = min ((jack_nframes_t)64, nframes);
-               jack_nframes_t n;
+               nframes_t limit = min ((nframes_t)64, nframes);
+               nframes_t n;
 
                delta = -(delta / (float) (limit));
                
@@ -323,7 +269,7 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
                
                pan = left * gain_coeff;
 
-               Session::mix_buffers_with_gain(dst+n,src+n,nframes-n,pan);
+               mix_buffers_with_gain (dst+n,src+n,nframes-n,pan);
                
        } else {
                
@@ -334,7 +280,7 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
                        
                        if (pan != 0.0f) {
                                
-                               Session::mix_buffers_with_gain(dst,src,nframes,pan);
+                               mix_buffers_with_gain(dst,src,nframes,pan);
 
                                /* mark that we wrote into the buffer */
 
@@ -344,7 +290,7 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
                        
                } else {
                        
-                       Session::mix_buffers_no_gain(dst,src,nframes);
+                       mix_buffers_no_gain(dst,src,nframes);
                        
                        /* mark that we wrote into the buffer */
                        
@@ -354,14 +300,14 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
 
        /* RIGHT */
 
-       dst = obufs[1];
+       dst = obufs.get_audio(1).data();
        
        if (fabsf ((delta = (right - desired_right))) > 0.002) { // about 1 degree of arc 
                
                /* interpolate over 64 frames or nframes, whichever is smaller */
                
-               jack_nframes_t limit = min ((jack_nframes_t)64, nframes);
-               jack_nframes_t n;
+               nframes_t limit = min ((nframes_t)64, nframes);
+               nframes_t n;
 
                delta = -(delta / (float) (limit));
 
@@ -373,7 +319,7 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
                
                pan = right * gain_coeff;
                
-               Session::mix_buffers_with_gain(dst+n,src+n,nframes-n,pan);
+               mix_buffers_with_gain(dst+n,src+n,nframes-n,pan);
                
                /* XXX it would be nice to mark the buffer as written to */
 
@@ -386,14 +332,14 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
                        
                        if (pan != 0.0f) {
                                
-                               Session::mix_buffers_with_gain(dst,src,nframes,pan);
+                               mix_buffers_with_gain(dst,src,nframes,pan);
                                
                                /* XXX it would be nice to mark the buffer as written to */
                        }
                        
                } else {
                        
-                       Session::mix_buffers_no_gain(dst,src,nframes);
+                       mix_buffers_no_gain(dst,src,nframes);
                        
                        /* XXX it would be nice to mark the buffer as written to */
                }
@@ -402,8 +348,8 @@ BaseStereoPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, ja
 
 /*---------------------------------------------------------------------- */
 
-EqualPowerStereoPanner::EqualPowerStereoPanner (Panner& p)
-       : BaseStereoPanner (p)
+EqualPowerStereoPanner::EqualPowerStereoPanner (Panner& p, Parameter param)
+       : BaseStereoPanner (p, param)
 {
        update ();
 
@@ -442,30 +388,36 @@ EqualPowerStereoPanner::update ()
        desired_right = panR * (scale * panR + 1.0f - scale);
 
        effective_x = x;
+       _control->set_value(x);
 }
 
 void
-EqualPowerStereoPanner::distribute_automated (Sample* src, Sample** obufs, 
-                                             jack_nframes_t start, jack_nframes_t end, jack_nframes_t nframes,
+EqualPowerStereoPanner::distribute_automated (AudioBuffer& srcbuf, BufferSet& obufs, 
+                                             nframes_t start, nframes_t end, nframes_t nframes,
                                              pan_t** buffers)
 {
+       assert(obufs.count().n_audio() == 2);
+
        Sample* dst;
        pan_t* pbuf;
+       Sample* const src = srcbuf.data();
 
        /* fetch positional data */
 
-       if (!_automation.rt_safe_get_vector (start, end, buffers[0], nframes)) {
+       if (!_control->list()->curve().rt_safe_get_vector (start, end, buffers[0], nframes)) {
                /* fallback */
                if (!_muted) {
-                       distribute (src, obufs, 1.0, nframes);
+                       distribute (srcbuf, obufs, 1.0, nframes);
                }
                return;
        }
 
        /* store effective pan position. do this even if we are muted */
 
-       if (nframes > 0) 
+       if (nframes > 0) {
                effective_x = buffers[0][nframes-1];
+               _control->set_value(effective_x); // signal, update UI
+       }
 
        if (_muted) {
                return;
@@ -478,7 +430,7 @@ EqualPowerStereoPanner::distribute_automated (Sample* src, Sample** obufs,
        const float pan_law_attenuation = -3.0f;
        const float scale = 2.0f - 4.0f * powf (10.0f,pan_law_attenuation/20.0f);
 
-       for (jack_nframes_t n = 0; n < nframes; ++n) {
+       for (nframes_t n = 0; n < nframes; ++n) {
 
                float panR = buffers[0][n];
                float panL = 1 - panR;
@@ -489,31 +441,31 @@ EqualPowerStereoPanner::distribute_automated (Sample* src, Sample** obufs,
 
        /* LEFT */
 
-       dst = obufs[0];
+       dst = obufs.get_audio(0).data();
        pbuf = buffers[0];
        
-       for (jack_nframes_t n = 0; n < nframes; ++n) {
+       for (nframes_t n = 0; n < nframes; ++n) {
                dst[n] += src[n] * pbuf[n];
        }       
 
-        /* XXX it would be nice to mark the buffer as written to */
+       /* XXX it would be nice to mark the buffer as written to */
 
        /* RIGHT */
 
-       dst = obufs[1];
+       dst = obufs.get_audio(1).data();
        pbuf = buffers[1];
 
-       for (jack_nframes_t n = 0; n < nframes; ++n) {
+       for (nframes_t n = 0; n < nframes; ++n) {
                dst[n] += src[n] * pbuf[n];
        }       
        
-        /* XXX it would be nice to mark the buffer as written to */
+       /* XXX it would be nice to mark the buffer as written to */
 }
 
 StreamPanner*
-EqualPowerStereoPanner::factory (Panner& parent)
+EqualPowerStereoPanner::factory (Panner& parent, Parameter param)
 {
-       return new EqualPowerStereoPanner (parent);
+       return new EqualPowerStereoPanner (parent, param);
 }
 
 XMLNode&
@@ -529,21 +481,18 @@ EqualPowerStereoPanner::state (bool full_state)
        char buf[64];
        LocaleGuard lg (X_("POSIX"));
 
-       snprintf (buf, sizeof (buf), "%f", x); 
+       snprintf (buf, sizeof (buf), "%.12g", x); 
        root->add_property (X_("x"), buf);
        root->add_property (X_("type"), EqualPowerStereoPanner::name);
-       if (full_state) {
-               snprintf (buf, sizeof (buf), "0x%x", _automation.automation_state()); 
-       } else {
-               /* never store automation states other than off in a template */
-               snprintf (buf, sizeof (buf), "0x%x", ARDOUR::Off); 
-       }
-       root->add_property (X_("automation-state"), buf);
-       snprintf (buf, sizeof (buf), "0x%x", _automation.automation_style()); 
-       root->add_property (X_("automation-style"), buf);
+
+       XMLNode* autonode = new XMLNode (X_("Automation"));
+       autonode->add_child_nocopy (_control->list()->state (full_state));
+       root->add_child_nocopy (*autonode);
 
        StreamPanner::add_state (*root);
 
+       root->add_child_nocopy (_control->get_state ());
+
        return *root;
 }
 
@@ -551,7 +500,6 @@ int
 EqualPowerStereoPanner::set_state (const XMLNode& node)
 {
        const XMLProperty* prop;
-       int x;
        float pos;
        LocaleGuard lg (X_("POSIX"));
 
@@ -560,29 +508,32 @@ EqualPowerStereoPanner::set_state (const XMLNode& node)
                set_position (pos, true);
        } 
 
-       if ((prop = node.property (X_("automation-state")))) {
-               sscanf (prop->value().c_str(), "0x%x", &x);
-               _automation.set_automation_state ((AutoState) x);
+       StreamPanner::set_state (node);
 
-               if (x != Off) {
-                       set_position (_automation.eval (parent.session().transport_frame()));
-               }
-       }
+       for (XMLNodeConstIterator iter = node.children().begin(); iter != node.children().end(); ++iter) {
 
-       if ((prop = node.property (X_("automation-style")))) {
-               sscanf (prop->value().c_str(), "0x%x", &x);
-               _automation.set_automation_style ((AutoStyle) x);
+               if ((*iter)->name() == X_("controllable")) {
+                       if ((prop = (*iter)->property("name")) != 0 && prop->value() == "panner") {
+                               _control->set_state (**iter);
+                       }
+
+               } else if ((*iter)->name() == X_("Automation")) {
+
+                       _control->list()->set_state (*((*iter)->children().front()));
+
+                       if (_control->list()->automation_state() != Off) {
+                               set_position (_control->list()->eval (parent.session().transport_frame()));
+                       }
+               }
        }
 
-       StreamPanner::set_state (node);
-       
        return 0;
 }
 
 /*----------------------------------------------------------------------*/
 
-Multi2dPanner::Multi2dPanner (Panner& p)
-       : StreamPanner (p), _automation (0.0, 1.0, 0.5) // XXX useless
+Multi2dPanner::Multi2dPanner (Panner& p, Parameter param)
+       : StreamPanner (p, param)
 {
        update ();
 }
@@ -591,30 +542,6 @@ Multi2dPanner::~Multi2dPanner ()
 {
 }
 
-void
-Multi2dPanner::snapshot (jack_nframes_t now)
-{
-       // how?
-}
-
-void
-Multi2dPanner::transport_stopped (jack_nframes_t frame)
-{
-       //what?
-}
-
-void
-Multi2dPanner::set_automation_style (AutoStyle style)
-{
-       //what?
-}
-
-void
-Multi2dPanner::set_automation_state (AutoState state)
-{
-       // what?
-}
-
 void
 Multi2dPanner::update ()
 {
@@ -645,10 +572,11 @@ Multi2dPanner::update ()
        }
 
        effective_x = x;
+       _control->set_value(x);
 }
 
 void
-Multi2dPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_nframes_t nframes)
+Multi2dPanner::distribute (AudioBuffer& srcbuf, BufferSet& obufs, gain_t gain_coeff, nframes_t nframes)
 {
        Sample* dst;
        pan_t pan;
@@ -658,19 +586,21 @@ Multi2dPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_
        if (_muted) {
                return;
        }
+       
+       Sample* const src = srcbuf.data();
 
 
        for (n = 0, o = parent.outputs.begin(); o != parent.outputs.end(); ++o, ++n) {
 
-               dst = obufs[n];
+               dst = obufs.get_audio(n).data();
        
 #ifdef CAN_INTERP
                if (fabsf ((delta = (left_interp - desired_left))) > 0.002) { // about 1 degree of arc 
                        
                        /* interpolate over 64 frames or nframes, whichever is smaller */
                        
-                       jack_nframes_t limit = min ((jack_nframes_t)64, nframes);
-                       jack_nframes_t n;
+                       nframes_t limit = min ((nframes_t)64, nframes);
+                       nframes_t n;
                        
                        delta = -(delta / (float) (limit));
                
@@ -681,10 +611,7 @@ Multi2dPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_
                        }
                        
                        pan = left * gain_coeff;
-                       
-                       for (; n < nframes; ++n) {
-                               dst[n] += src[n] * pan;
-                       }
+                       mix_buffers_with_gain(dst+n,src+n,nframes-n,pan);
                        
                } else {
 
@@ -694,20 +621,10 @@ Multi2dPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_
                        if ((pan *= gain_coeff) != 1.0f) {
                                
                                if (pan != 0.0f) {
-                                       
-                                       for (jack_nframes_t n = 0; n < nframes; ++n) {
-                                               dst[n] += src[n] * pan;
-                                       }      
-                                       
+                                       mix_buffers_with_gain(dst,src,nframes,pan);
                                } 
-
-                               
                        } else {
-                               
-                               for (jack_nframes_t n = 0; n < nframes; ++n) {
-                                       dst[n] += src[n];
-                               }      
-
+                                       mix_buffers_no_gain(dst,src,nframes);
                        }
 #endif
 #ifdef CAN_INTERP
@@ -719,8 +636,8 @@ Multi2dPanner::distribute (Sample* src, Sample** obufs, gain_t gain_coeff, jack_
 }
 
 void
-Multi2dPanner::distribute_automated (Sample* src, Sample** obufs, 
-                                    jack_nframes_t start, jack_nframes_t end, jack_nframes_t nframes,
+Multi2dPanner::distribute_automated (AudioBuffer& src, BufferSet& obufs, 
+                                    nframes_t start, nframes_t end, nframes_t nframes,
                                     pan_t** buffers)
 {
        if (_muted) {
@@ -733,9 +650,9 @@ Multi2dPanner::distribute_automated (Sample* src, Sample** obufs,
 }
 
 StreamPanner*
-Multi2dPanner::factory (Panner& p)
+Multi2dPanner::factory (Panner& p, Parameter param)
 {
-       return new Multi2dPanner (p);
+       return new Multi2dPanner (p, param);
 }
 
 int
@@ -744,12 +661,6 @@ Multi2dPanner::load (istream& in, string path, uint32_t& linecnt)
        return 0;
 }
 
-int
-Multi2dPanner::save (ostream& out) const
-{
-       return 0;
-}
-
 XMLNode&
 Multi2dPanner::get_state (void)
 {
@@ -763,12 +674,14 @@ Multi2dPanner::state (bool full_state)
        char buf[64];
        LocaleGuard lg (X_("POSIX"));
 
-       snprintf (buf, sizeof (buf), "%f", x); 
+       snprintf (buf, sizeof (buf), "%.12g", x); 
        root->add_property (X_("x"), buf);
-       snprintf (buf, sizeof (buf), "%f", y); 
+       snprintf (buf, sizeof (buf), "%.12g", y); 
        root->add_property (X_("y"), buf);
        root->add_property (X_("type"), Multi2dPanner::name);
 
+       /* XXX no meaningful automation yet */
+
        return *root;
 }
 
@@ -806,6 +719,7 @@ Panner::Panner (string name, Session& s)
        : _session (s)
 {
        set_name (name);
+
        _linked = false;
        _link_direction = SameDirection;
        _bypassed = false;
@@ -835,17 +749,6 @@ Panner::set_link_direction (LinkDirection ld)
        }
 }
 
-void
-Panner::set_name (string str)
-{
-       automation_path = _session.automation_dir();
-       automation_path += _session.snap_name();
-       automation_path += "-pan-";
-       automation_path += legalize_for_path (str);
-       automation_path += ".automation";
-}
-
-
 void
 Panner::set_bypassed (bool yn)
 {
@@ -862,7 +765,6 @@ Panner::reset (uint32_t nouts, uint32_t npans)
        uint32_t n;
        bool changed = false;
 
-
        if (nouts < 2 || (nouts == outputs.size() && npans == size())) {
                return;
        } 
@@ -898,7 +800,7 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                outputs.push_back (Output (1.0, 0));
 
                for (n = 0; n < npans; ++n) {
-                       push_back (new EqualPowerStereoPanner (*this));
+                       push_back (new EqualPowerStereoPanner (*this, Parameter(PanAutomation, n)));
                }
                break;
 
@@ -908,7 +810,7 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                outputs.push_back (Output  (1.0, 1.0));
 
                for (n = 0; n < npans; ++n) {
-                       push_back (new Multi2dPanner (*this));
+                       push_back (new Multi2dPanner (*this, Parameter(PanAutomation, n)));
                }
 
                break; 
@@ -920,7 +822,7 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                outputs.push_back (Output  (0, 1.0));
 
                for (n = 0; n < npans; ++n) {
-                       push_back (new Multi2dPanner (*this));
+                       push_back (new Multi2dPanner (*this, Parameter(PanAutomation, n)));
                }
 
                break;  
@@ -933,7 +835,7 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                outputs.push_back (Output  (0.5, 0.75));
 
                for (n = 0; n < npans; ++n) {
-                       push_back (new Multi2dPanner (*this));
+                       push_back (new Multi2dPanner (*this, Parameter(PanAutomation, n)));
                }
 
                break;
@@ -945,7 +847,7 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                }
 
                for (n = 0; n < npans; ++n) {
-                       push_back (new Multi2dPanner (*this));
+                       push_back (new Multi2dPanner (*this, Parameter(PanAutomation, n)));
                }
 
                break;
@@ -973,10 +875,10 @@ Panner::reset (uint32_t nouts, uint32_t npans)
                if (changed || ((left == 0.5) && (right == 0.5))) {
                
                        front()->set_position (0.0);
-                       front()->automation().reset_default (0.0);
+                       front()->pan_control()->list()->reset_default (0.0);
                        
                        back()->set_position (1.0);
-                       back()->automation().reset_default (1.0);
+                       back()->pan_control()->list()->reset_default (1.0);
                        
                        changed = true;
                }
@@ -1015,7 +917,7 @@ void
 Panner::set_automation_style (AutoStyle style)
 {
        for (vector<StreamPanner*>::iterator i = begin(); i != end(); ++i) {
-               (*i)->set_automation_style (style);
+               (*i)->pan_control()->list()->set_automation_style (style);
        }
        _session.set_dirty ();
 }      
@@ -1024,7 +926,7 @@ void
 Panner::set_automation_state (AutoState state)
 {
        for (vector<StreamPanner*>::iterator i = begin(); i != end(); ++i) {
-               (*i)->set_automation_state (state);
+               (*i)->pan_control()->list()->set_automation_state (state);
        }
        _session.set_dirty ();
 }      
@@ -1033,7 +935,7 @@ AutoState
 Panner::automation_state () const
 {
        if (!empty()) {
-               return front()->automation().automation_state ();
+               return front()->pan_control()->list()->automation_state ();
        } else {
                return Off;
        }
@@ -1043,25 +945,27 @@ AutoStyle
 Panner::automation_style () const
 {
        if (!empty()) {
-               return front()->automation().automation_style ();
+               return front()->pan_control()->list()->automation_style ();
        } else {
                return Absolute;
        }
 }
 
 void
-Panner::transport_stopped (jack_nframes_t frame)
+Panner::transport_stopped (nframes_t frame)
 {
        for (vector<StreamPanner*>::iterator i = begin(); i != end(); ++i) {
-               (*i)->transport_stopped (frame);
+               (*i)->pan_control()->list()->reposition_for_rt_add (frame);
        }
 }      
 
 void
-Panner::snapshot (jack_nframes_t now)
+Panner::snapshot (nframes_t now)
 {
        for (vector<StreamPanner*>::iterator i = begin(); i != end(); ++i) {
-               (*i)->snapshot (now);
+               boost::shared_ptr<AutomationList> list = (*i)->pan_control()->list();
+               if (list->automation_write())
+                       list->rt_add(now, (*i)->pan_control()->get_value());
        }
 }      
 
@@ -1069,111 +973,15 @@ void
 Panner::clear_automation ()
 {
        for (vector<StreamPanner*>::iterator i = begin(); i != end(); ++i) {
-               (*i)->automation().clear ();
+               (*i)->pan_control()->list()->clear ();
        }
        _session.set_dirty ();
 }      
 
-int
-Panner::save () const
-{
-       ofstream out (automation_path.c_str());
-       
-       if (!out) {
-               error << string_compose (_("cannot open pan automation file \"%1\" for saving (%s)"), automation_path, strerror (errno))
-                     << endmsg;
-               return -1;
-       }
-
-       out << X_("version ") << current_automation_version_number << endl;
-
-       for (vector<StreamPanner*>::const_iterator i = begin(); i != end(); ++i) {
-               if ((*i)->save (out)) {
-                       return -1;
-               }
-       }
-
-       return 0;
-}
-
-int
-Panner::load ()
-{
-       char line[128];
-       uint32_t linecnt = 0;
-       float version;
-       iterator sp;
-       LocaleGuard lg (X_("POSIX"));
-
-       if (automation_path.length() == 0) {
-               return 0;
-       }
-       
-       if (access (automation_path.c_str(), F_OK)) {
-               return 0;
-       }
-
-       ifstream in (automation_path.c_str());
-
-       if (!in) {
-               error << string_compose (_("cannot open pan automation file %1 (%2)"),
-                                 automation_path, strerror (errno))
-                     << endmsg;
-               return -1;
-       }
-
-       sp = begin();
-
-       while (in.getline (line, sizeof(line), '\n')) {
-
-               if (++linecnt == 1) {
-                       if (memcmp (line, X_("version"), 7) == 0) {
-                               if (sscanf (line, "version %f", &version) != 1) {
-                                       error << string_compose(_("badly formed version number in pan automation event file \"%1\""), automation_path) << endmsg;
-                                       return -1;
-                               }
-                       } else {
-                               error << string_compose(_("no version information in pan automation event file \"%1\" (first line = %2)"), 
-                                                automation_path, line) << endmsg;
-                               return -1;
-                       }
-
-                       if (version != current_automation_version_number) {
-                               error << string_compose(_("mismatched pan automation event file version (%1)"), version) << endmsg;
-                               return -1;
-                       }
-
-                       continue;
-               }
-
-               if (strlen (line) == 0 || line[0] == '#') {
-                       continue;
-               }
-
-               if (strcmp (line, "begin") == 0) {
-                       
-                       if (sp == end()) {
-                               error << string_compose (_("too many panner states found in pan automation file %1"),
-                                                 automation_path)
-                                     << endmsg;
-                               return -1;
-                       }
-
-                       if ((*sp)->load (in, automation_path, linecnt)) {
-                               return -1;
-                       }
-                       
-                       ++sp;
-               }
-       }
-
-       return 0;
-}
-
 struct PanPlugins {
     string name;
     uint32_t nouts;
-    StreamPanner* (*factory)(Panner&);
+    StreamPanner* (*factory)(Panner&, Parameter);
 };
 
 PanPlugins pan_plugins[] = {
@@ -1194,30 +1002,23 @@ Panner::state (bool full)
        XMLNode* root = new XMLNode (X_("Panner"));
        char buf[32];
 
-       for (iterator p = begin(); p != end(); ++p) {
-               root->add_child_nocopy ((*p)->state (full));
-       }
-
        root->add_property (X_("linked"), (_linked ? "yes" : "no"));
-       snprintf (buf, sizeof (buf), "%d", _link_direction);
-       root->add_property (X_("link_direction"), buf);
+       root->add_property (X_("link_direction"), enum_2_string (_link_direction));
        root->add_property (X_("bypassed"), (bypassed() ? "yes" : "no"));
 
        /* add each output */
 
        for (vector<Panner::Output>::iterator o = outputs.begin(); o != outputs.end(); ++o) {
                XMLNode* onode = new XMLNode (X_("Output"));
-               snprintf (buf, sizeof (buf), "%f", (*o).x);
+               snprintf (buf, sizeof (buf), "%.12g", (*o).x);
                onode->add_property (X_("x"), buf);
-               snprintf (buf, sizeof (buf), "%f", (*o).y);
+               snprintf (buf, sizeof (buf), "%.12g", (*o).y);
                onode->add_property (X_("y"), buf);
                root->add_child_nocopy (*onode);
        }
 
-       if (full) {
-               if (save () == 0) {
-                       root->add_property (X_("automation"), Glib::path_get_basename (automation_path));
-               }
+       for (vector<StreamPanner*>::const_iterator i = begin(); i != end(); ++i) {
+               root->add_child_nocopy ((*i)->state (full));
        }
 
        return *root;
@@ -1246,8 +1047,8 @@ Panner::set_state (const XMLNode& node)
        }
 
        if ((prop = node.property (X_("link_direction"))) != 0) {
-               sscanf (prop->value().c_str(), "%d", &i);
-               set_link_direction ((LinkDirection) (i));
+               LinkDirection ld; /* here to provide type information */
+               set_link_direction (LinkDirection (string_2_enum (prop->value(), ld)));
        }
 
        nlist = node.children();
@@ -1258,10 +1059,10 @@ Panner::set_state (const XMLNode& node)
                        float x, y;
                        
                        prop = (*niter)->property (X_("x"));
-                       sscanf (prop->value().c_str(), "%f", &x);
+                       sscanf (prop->value().c_str(), "%g", &x);
                        
                        prop = (*niter)->property (X_("y"));
-                       sscanf (prop->value().c_str(), "%f", &y);
+                       sscanf (prop->value().c_str(), "%g", &y);
                        
                        outputs.push_back (Output (x, y));
                }
@@ -1282,7 +1083,7 @@ Panner::set_state (const XMLNode& node)
                                                   assumption, but its still an assumption.
                                                */
                                                
-                                               sp = pan_plugins[i].factory (*this);
+                                               sp = pan_plugins[i].factory (*this, Parameter(PanAutomation, 0));
                                                
                                                if (sp->set_state (**niter) == 0) {
                                                        push_back (sp);
@@ -1308,7 +1109,7 @@ Panner::set_state (const XMLNode& node)
                }       
        }
 
-       /* don't try to load automation if it wasn't marked as existing */
+       /* don't try to do old-school automation loading if it wasn't marked as existing */
 
        if ((prop = node.property (X_("automation")))) {
 
@@ -1327,7 +1128,7 @@ bool
 Panner::touching () const
 {
        for (vector<StreamPanner*>::const_iterator i = begin(); i != end(); ++i) {
-               if ((*i)->automation().touching ()) {
+               if ((*i)->pan_control()->list()->touching ()) {
                        return true;
                }
        }
@@ -1477,3 +1278,212 @@ Panner::set_position (float xpos, float ypos, float zpos, StreamPanner& orig)
                }
        }
 }
+
+void
+Panner::distribute_no_automation (BufferSet& inbufs, BufferSet& outbufs, nframes_t nframes, nframes_t offset, gain_t gain_coeff)
+{
+       if (outbufs.count().n_audio() == 0) {
+               // Don't want to lose audio...
+               assert(inbufs.count().n_audio() == 0);
+               return;
+       }
+
+       // We shouldn't be called in the first place...
+       assert(!bypassed());
+       assert(!empty());
+
+       
+       if (outbufs.count().n_audio() == 1) {
+
+               AudioBuffer& dst = outbufs.get_audio(0);
+
+               if (gain_coeff == 0.0f) {
+
+                       /* only one output, and gain was zero, so make it silent */
+
+                       dst.silence(offset);
+                       
+               } else if (gain_coeff == 1.0f){
+
+                       /* mix all buffers into the output */
+
+                       // copy the first
+                       dst.read_from(inbufs.get_audio(0), nframes, offset);
+                       
+                       // accumulate starting with the second
+                       BufferSet::audio_iterator i = inbufs.audio_begin();
+                       for (++i; i != inbufs.audio_end(); ++i) {
+                               dst.accumulate_from(*i, nframes, offset);
+                       }
+
+               } else {
+
+                       /* mix all buffers into the output, scaling them all by the gain */
+
+                       // copy the first
+                       dst.read_from(inbufs.get_audio(0), nframes, offset);
+                       
+                       // accumulate (with gain) starting with the second
+                       BufferSet::audio_iterator i = inbufs.audio_begin();
+                       for (++i; i != inbufs.audio_end(); ++i) {
+                               dst.accumulate_with_gain_from(*i, nframes, offset, gain_coeff);
+                       }
+
+               }
+
+               return;
+       }
+       
+       /* the terrible silence ... */
+       for (BufferSet::audio_iterator i = outbufs.audio_begin(); i != outbufs.audio_end(); ++i) {
+               i->silence(nframes, offset);
+       }
+
+       BufferSet::audio_iterator i = inbufs.audio_begin();
+
+       for (iterator pan = begin(); pan != end() && i != inbufs.audio_end(); ++pan, ++i) {
+               (*pan)->distribute (*i, outbufs, gain_coeff, nframes);
+       }
+}
+
+void
+Panner::distribute (BufferSet& inbufs, BufferSet& outbufs, nframes_t start_frame, nframes_t end_frame, nframes_t nframes, nframes_t offset)
+{      
+       if (outbufs.count().n_audio() == 0) {
+               // Failing to deliver audio we were asked to deliver is a bug
+               assert(inbufs.count().n_audio() == 0);
+               return;
+       }
+
+       // We shouldn't be called in the first place...
+       assert(!bypassed());
+       assert(!empty());
+
+       // If we shouldn't play automation defer to distribute_no_automation
+       if ( !( automation_state() & Play ||
+                        ((automation_state() & Touch) && !touching()) ) ) {
+
+               // Speed quietning
+               gain_t gain_coeff = 1.0;
+               if (fabsf(_session.transport_speed()) > 1.5f) {
+                       gain_coeff = speed_quietning;
+               }
+
+               distribute_no_automation(inbufs, outbufs, nframes, offset, gain_coeff);
+               return;
+       }
+
+       // Otherwise.. let the automation flow, baby
+       
+       if (outbufs.count().n_audio() == 1) {
+
+               AudioBuffer& dst = outbufs.get_audio(0);
+
+               // FIXME: apply gain automation?
+
+               // copy the first
+               dst.read_from(inbufs.get_audio(0), nframes, offset);
+
+               // accumulate starting with the second
+               BufferSet::audio_iterator i = inbufs.audio_begin();
+               for (++i; i != inbufs.audio_end(); ++i) {
+                       dst.accumulate_from(*i, nframes, offset);
+               }
+
+               return;
+       }
+
+       // More than 1 output, we should have 1 panner for each input
+       assert(size() == inbufs.count().n_audio());
+       
+       /* the terrible silence ... */
+       for (BufferSet::audio_iterator i = outbufs.audio_begin(); i != outbufs.audio_end(); ++i) {
+               i->silence(nframes, offset);
+       }
+
+       BufferSet::audio_iterator i = inbufs.audio_begin();
+       for (iterator pan = begin(); pan != end(); ++pan, ++i) {
+               (*pan)->distribute_automated (*i, outbufs, start_frame, end_frame, nframes, _session.pan_automation_buffer());
+       }
+}
+
+/* old school automation handling */
+
+void
+Panner::set_name (string str)
+{
+       automation_path = _session.automation_dir();
+       automation_path += _session.snap_name();
+       automation_path += "-pan-";
+       automation_path += legalize_for_path (str);
+       automation_path += ".automation";
+}
+
+int
+Panner::load ()
+{
+       char line[128];
+       uint32_t linecnt = 0;
+       float version;
+       iterator sp;
+       LocaleGuard lg (X_("POSIX"));
+
+       if (automation_path.length() == 0) {
+               return 0;
+       }
+       
+       if (access (automation_path.c_str(), F_OK)) {
+               return 0;
+       }
+
+       ifstream in (automation_path.c_str());
+
+       if (!in) {
+               error << string_compose (_("cannot open pan automation file %1 (%2)"),
+                                 automation_path, strerror (errno))
+                     << endmsg;
+               return -1;
+       }
+
+       sp = begin();
+
+       while (in.getline (line, sizeof(line), '\n')) {
+
+               if (++linecnt == 1) {
+                       if (memcmp (line, X_("version"), 7) == 0) {
+                               if (sscanf (line, "version %f", &version) != 1) {
+                                       error << string_compose(_("badly formed version number in pan automation event file \"%1\""), automation_path) << endmsg;
+                                       return -1;
+                               }
+                       } else {
+                               error << string_compose(_("no version information in pan automation event file \"%1\" (first line = %2)"), 
+                                                automation_path, line) << endmsg;
+                               return -1;
+                       }
+
+                       continue;
+               }
+
+               if (strlen (line) == 0 || line[0] == '#') {
+                       continue;
+               }
+
+               if (strcmp (line, "begin") == 0) {
+                       
+                       if (sp == end()) {
+                               error << string_compose (_("too many panner states found in pan automation file %1"),
+                                                 automation_path)
+                                     << endmsg;
+                               return -1;
+                       }
+
+                       if ((*sp)->load (in, automation_path, linecnt)) {
+                               return -1;
+                       }
+                       
+                       ++sp;
+               }
+       }
+
+       return 0;
+}