closing in on pin management.
[ardour.git] / libs / ardour / plugin_insert.cc
index b490646ffcce100af8f99d89c81073f7a700d739..8aeff963fdb5b5a80c52f9056c98a485c60d5a66 100644 (file)
@@ -33,6 +33,7 @@
 #include "ardour/debug.h"
 #include "ardour/event_type_map.h"
 #include "ardour/ladspa_plugin.h"
+#include "ardour/luaproc.h"
 #include "ardour/plugin.h"
 #include "ardour/plugin_insert.h"
 
@@ -67,6 +68,11 @@ PluginInsert::PluginInsert (Session& s, boost::shared_ptr<Plugin> plug)
        : Processor (s, (plug ? plug->name() : string ("toBeRenamed")))
        , _signal_analysis_collected_nframes(0)
        , _signal_analysis_collect_nframes_max(0)
+       , _configured (false)
+       , _no_inplace (false)
+       , _strict_io (false)
+       , _custom_cfg (false)
+       , _pending_no_inplace (false)
 {
        /* the first is the master */
 
@@ -76,6 +82,10 @@ PluginInsert::PluginInsert (Session& s, boost::shared_ptr<Plugin> plug)
        }
 }
 
+PluginInsert::~PluginInsert ()
+{
+}
+
 bool
 PluginInsert::set_count (uint32_t num)
 {
@@ -112,8 +122,11 @@ PluginInsert::set_count (uint32_t num)
        return true;
 }
 
-PluginInsert::~PluginInsert ()
+
+void
+PluginInsert::set_outputs (const ChanCount& c)
 {
+       _custom_out = c;
 }
 
 void
@@ -132,12 +145,29 @@ PluginInsert::control_list_automation_state_changed (Evoral::Parameter which, Au
 
 ChanCount
 PluginInsert::output_streams() const
+{
+       assert (_configured);
+       return _configured_out;
+}
+
+ChanCount
+PluginInsert::input_streams() const
+{
+       assert (_configured);
+       return _configured_in;
+}
+
+ChanCount
+PluginInsert::internal_output_streams() const
 {
        assert (!_plugins.empty());
 
        PluginInfoPtr info = _plugins.front()->get_info();
 
-       if (info->reconfigurable_io()) {
+       if (_match.strict_io) {
+               return _configured_in; // XXX
+       }
+       else if (info->reconfigurable_io()) {
                ChanCount out = _plugins.front()->output_streams ();
                // DEBUG_TRACE (DEBUG::Processors, string_compose ("Plugin insert, reconfigur(able) output streams = %1\n", out));
                return out;
@@ -151,7 +181,7 @@ PluginInsert::output_streams() const
 }
 
 ChanCount
-PluginInsert::input_streams() const
+PluginInsert::internal_input_streams() const
 {
        assert (!_plugins.empty());
 
@@ -167,7 +197,7 @@ PluginInsert::input_streams() const
        }
 
        DEBUG_TRACE (DEBUG::Processors, string_compose ("Plugin insert, input streams = %1, match using %2\n", in, _match.method));
-       
+
        if (_match.method == Split) {
 
                /* we are splitting 1 processor input to multiple plugin inputs,
@@ -188,7 +218,7 @@ PluginInsert::input_streams() const
                return in;
 
        } else {
-               
+
                for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
                        in.set (*t, in.get (*t) * _plugins.size ());
                }
@@ -250,7 +280,9 @@ PluginInsert::create_automatable_parameters ()
 
                        can_automate (param);
                        boost::shared_ptr<AutomationList> list(new AutomationList(param, desc));
-                       add_control (boost::shared_ptr<AutomationControl> (new PluginControl(this, param, desc, list)));
+                       boost::shared_ptr<AutomationControl> c (new PluginControl(this, param, desc, list));
+                       add_control (c);
+                       _plugins.front()->set_automation_control (i->id(), c);
                } else if (i->type() == PluginPropertyAutomation) {
                        Evoral::Parameter param(*i);
                        const ParameterDescriptor& desc = _plugins.front()->get_property_descriptor(param.id());
@@ -264,26 +296,53 @@ PluginInsert::create_automatable_parameters ()
                }
        }
 }
-
+/** Called when something outside of this host has modified a plugin
+ * parameter. Responsible for propagating the change to two places:
+ *
+ *   1) anything listening to the Control itself
+ *   2) any replicated plugins that make up this PluginInsert.
+ *
+ * The PluginInsert is connected to the ParameterChangedExternally signal for
+ * the first (primary) plugin, and here broadcasts that change to any others.
+ *
+ * XXX We should probably drop this whole replication idea (Paul, October 2015)
+ * since it isn't used by sensible plugin APIs (AU, LV2).
+ */
 void
-PluginInsert::parameter_changed (uint32_t which, float val)
+PluginInsert::parameter_changed_externally (uint32_t which, float val)
 {
        boost::shared_ptr<AutomationControl> ac = automation_control (Evoral::Parameter (PluginAutomation, 0, which));
 
-       if (ac) {
-               ac->set_value (val);
-                
-                Plugins::iterator i = _plugins.begin();
-                
-                /* don't set the first plugin, just all the slaves */
-                
-                if (i != _plugins.end()) {
-                        ++i;
-                        for (; i != _plugins.end(); ++i) {
-                                (*i)->set_parameter (which, val);
-                        }
-                }
-        }
+       /* First propagation: alter the underlying value of the control,
+        * without telling the plugin(s) that own/use it to set it.
+        */
+
+       if (!ac) {
+               return;
+       }
+
+       boost::shared_ptr<PluginControl> pc = boost::dynamic_pointer_cast<PluginControl> (ac);
+
+       if (pc) {
+               pc->catch_up_with_external_value (val);
+       }
+
+       /* Second propagation: tell all plugins except the first to
+          update the value of this parameter. For sane plugin APIs,
+          there are no other plugins, so this is a no-op in those
+          cases.
+       */
+
+       Plugins::iterator i = _plugins.begin();
+
+       /* don't set the first plugin, just all the slaves */
+
+       if (i != _plugins.end()) {
+               ++i;
+               for (; i != _plugins.end(); ++i) {
+                       (*i)->set_parameter (which, val);
+               }
+       }
 }
 
 int
@@ -329,6 +388,12 @@ PluginInsert::flush ()
 void
 PluginInsert::connect_and_run (BufferSet& bufs, pframes_t nframes, framecnt_t offset, bool with_auto, framepos_t now)
 {
+       PinMappings in_map (_in_map);
+       PinMappings out_map (_out_map);
+
+       // TODO auto-detect (if PinMappings are not identity maps)
+       _no_inplace = _pending_no_inplace || _plugins.front()->inplace_broken ();
+
        // Calculate if, and how many frames we need to collect for analysis
        framecnt_t collect_signal_nframes = (_signal_analysis_collect_nframes_max -
                                             _signal_analysis_collected_nframes);
@@ -336,28 +401,31 @@ PluginInsert::connect_and_run (BufferSet& bufs, pframes_t nframes, framecnt_t of
                collect_signal_nframes = nframes;
        }
 
-       ChanCount const in_streams = input_streams ();
-       ChanCount const out_streams = output_streams ();
 
-       ChanMapping in_map (in_streams);
-       ChanMapping out_map (out_streams);
-       bool valid;
        if (_match.method == Split) {
+
+               assert (in_map.size () == 1);
+               ChanCount const in_streams = internal_input_streams ();
+               // TODO - inplace & analysis only
+               // for no-inplace the buffer is copied anyway..
                /* fix the input mapping so that we have maps for each of the plugin's inputs */
-               in_map = ChanMapping (natural_input_streams ());
 
                /* copy the first stream's buffer contents to the others */
                /* XXX: audio only */
-               uint32_t first_idx = in_map.get (DataType::AUDIO, 0, &valid);
+               bool valid;
+               uint32_t first_idx = in_map[0].get (DataType::AUDIO, 0, &valid);
                if (valid) {
                        for (uint32_t i = in_streams.n_audio(); i < natural_input_streams().n_audio(); ++i) {
-                               bufs.get_audio(in_map.get (DataType::AUDIO, i, &valid)).read_from(bufs.get_audio(first_idx), nframes, offset, offset);
+                               uint32_t idx = in_map[0].get (DataType::AUDIO, i, &valid);
+                               if (valid) {
+                                       bufs.get_audio(idx).read_from(bufs.get_audio(first_idx), nframes, offset, offset);
+                               }
                        }
                }
        }
 
-       bufs.set_count(ChanCount::max(bufs.count(), in_streams));
-       bufs.set_count(ChanCount::max(bufs.count(), out_streams));
+       bufs.set_count(ChanCount::max(bufs.count(), _configured_in));
+       bufs.set_count(ChanCount::max(bufs.count(), _configured_out));
 
        /* Note that we've already required that plugins
           be able to handle in-place processing.
@@ -378,7 +446,16 @@ PluginInsert::connect_and_run (BufferSet& bufs, pframes_t nframes, framecnt_t of
                                const float val = c->list()->rt_safe_eval (now, valid);
 
                                if (valid) {
-                                       c->set_value(val);
+                                       /* This is the ONLY place where we are
+                                        *  allowed to call
+                                        *  AutomationControl::set_value_unchecked(). We
+                                        *  know that the control is in
+                                        *  automation playback mode, so no
+                                        *  check on writable() is required
+                                        *  (which must be done in AutomationControl::set_value()
+                                        *
+                                        */
+                                       c->set_value_unchecked(val);
                                }
 
                        }
@@ -388,12 +465,12 @@ PluginInsert::connect_and_run (BufferSet& bufs, pframes_t nframes, framecnt_t of
        if (collect_signal_nframes > 0) {
                // collect input
                //std::cerr << "collect input, bufs " << bufs.count().n_audio() << " count,  " << bufs.available().n_audio() << " available" << std::endl;
-               //std::cerr << "               streams " << input_streams().n_audio() << std::endl;
+               //std::cerr << "               streams " << internal_input_streams().n_audio() << std::endl;
                //std::cerr << "filling buffer with " << collect_signal_nframes << " frames at " << _signal_analysis_collected_nframes << std::endl;
 
-               _signal_analysis_inputs.set_count(input_streams());
+               _signal_analysis_inputs.set_count(internal_input_streams());
 
-               for (uint32_t i = 0; i < input_streams().n_audio(); ++i) {
+               for (uint32_t i = 0; i < internal_input_streams().n_audio(); ++i) {
                        _signal_analysis_inputs.get_audio(i).read_from(
                                bufs.get_audio(i),
                                collect_signal_nframes,
@@ -402,22 +479,97 @@ PluginInsert::connect_and_run (BufferSet& bufs, pframes_t nframes, framecnt_t of
 
        }
 
-       for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
-               (*i)->connect_and_run(bufs, in_map, out_map, nframes, offset);
+       if (_no_inplace) {
+               BufferSet& inplace_bufs  = _session.get_noinplace_buffers();
+               ARDOUR::ChanMapping used_outputs;
+
+               uint32_t pc = 0;
+               for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i, ++pc) {
+
+                       ARDOUR::ChanMapping i_in_map (natural_input_streams());
+                       ARDOUR::ChanMapping i_out_map;
+                       ARDOUR::ChanCount mapped;
+                       ARDOUR::ChanCount backmap;
+
+                       // map inputs sequentially
+                       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                               for (uint32_t in = 0; in < natural_input_streams().get (*t); ++in) {
+                                       bool valid;
+                                       uint32_t in_idx = in_map[pc].get (*t, in, &valid);
+                                       uint32_t m = mapped.get (*t);
+                                       if (valid) {
+                                               inplace_bufs.get (*t, m).read_from (bufs.get (*t, in_idx), nframes, offset, offset);
+                                       } else {
+                                               inplace_bufs.get (*t, m).silence (nframes, offset);
+                                       }
+                                       mapped.set (*t, m + 1);
+                               }
+                       }
+
+                       // TODO use map_offset_to()  instead ??
+                       backmap = mapped;
+
+                       // map outputs
+                       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                               for (uint32_t out = 0; out < natural_output_streams().get (*t); ++out) {
+                                       uint32_t m = mapped.get (*t);
+                                       inplace_bufs.get (*t, m).silence (nframes, offset);
+                                       i_out_map.set (*t, out, m);
+                                       mapped.set (*t, m + 1);
+                               }
+                       }
+
+                       if ((*i)->connect_and_run(inplace_bufs, i_in_map, i_out_map, nframes, offset)) {
+                               deactivate ();
+                       }
+
+
+                       // copy back outputs
+                       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                               for (uint32_t out = 0; out < natural_output_streams().get (*t); ++out) {
+                                       uint32_t m = backmap.get (*t);
+                                       bool valid;
+                                       uint32_t out_idx = out_map[pc].get (*t, out, &valid);
+                                       if (valid) {
+                                               bufs.get (*t, out_idx).read_from (inplace_bufs.get (*t, m), nframes, offset, offset);
+                                               used_outputs.set (*t, out_idx, 1); // mark as used
+                                       }
+                                       backmap.set (*t, m + 1);
+                               }
+                       }
+               }
+               /* all instances have completed, now clear outputs that have not been written to.
+                * (except midi bypass)
+                */
+               if (bufs.count().n_midi() == 1 && natural_output_streams().get(DataType::MIDI) == 0) {
+                       used_outputs.set (DataType::MIDI, 0, 1); // Midi bypass.
+               }
                for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
-                       in_map.offset_to(*t, natural_input_streams().get(*t));
-                       out_map.offset_to(*t, natural_output_streams().get(*t));
+                       for (uint32_t out = 0; out < bufs.count().get (*t); ++out) {
+                               bool valid;
+                               used_outputs.get (*t, out, &valid);
+                               if (valid) { continue; }
+                               bufs.get (*t, out).silence (nframes, offset);
+                       }
+               }
+
+       } else {
+               uint32_t pc = 0;
+               for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i, ++pc) {
+                       if ((*i)->connect_and_run(bufs, in_map[pc], out_map[pc], nframes, offset)) {
+                               deactivate ();
+                       }
                }
        }
 
        if (collect_signal_nframes > 0) {
                // collect output
                //std::cerr << "       output, bufs " << bufs.count().n_audio() << " count,  " << bufs.available().n_audio() << " available" << std::endl;
-               //std::cerr << "               streams " << output_streams().n_audio() << std::endl;
+               //std::cerr << "               streams " << internal_output_streams().n_audio() << std::endl;
 
-               _signal_analysis_outputs.set_count(output_streams());
+               _signal_analysis_outputs.set_count(internal_output_streams());
 
-               for (uint32_t i = 0; i < output_streams().n_audio(); ++i) {
+               for (uint32_t i = 0; i < internal_output_streams().n_audio(); ++i) {
                        _signal_analysis_outputs.get_audio(i).read_from(
                                bufs.get_audio(i),
                                collect_signal_nframes,
@@ -445,13 +597,8 @@ PluginInsert::silence (framecnt_t nframes)
                return;
        }
 
-       ChanMapping in_map(input_streams());
-       ChanMapping out_map(output_streams());
-
-       if (_match.method == Split) {
-               /* fix the input mapping so that we have maps for each of the plugin's inputs */
-               in_map = ChanMapping (natural_input_streams ());
-       }
+       ChanMapping in_map (natural_input_streams ());
+       ChanMapping out_map (natural_output_streams ());
 
        for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                (*i)->connect_and_run (_session.get_scratch_buffers ((*i)->get_info()->n_inputs, true), in_map, out_map, nframes, 0);
@@ -506,41 +653,6 @@ PluginInsert::run (BufferSet& bufs, framepos_t start_frame, framepos_t /*end_fra
 
 }
 
-void
-PluginInsert::set_parameter (Evoral::Parameter param, float val)
-{
-       if (param.type() != PluginAutomation) {
-               return;
-       }
-
-       /* the others will be set from the event triggered by this */
-
-       _plugins[0]->set_parameter (param.id(), val);
-
-       boost::shared_ptr<AutomationControl> ac
-                       = boost::dynamic_pointer_cast<AutomationControl>(control(param));
-
-       if (ac) {
-               ac->set_value(val);
-       } else {
-               warning << "set_parameter called for nonexistant parameter "
-                       << EventTypeMap::instance().to_symbol(param) << endmsg;
-       }
-
-       _session.set_dirty();
-}
-
-float
-PluginInsert::get_parameter (Evoral::Parameter param)
-{
-       if (param.type() != PluginAutomation) {
-               return 0.0;
-       } else {
-               assert (!_plugins.empty ());
-               return _plugins[0]->get_parameter (param.id());
-       }
-}
-
 void
 PluginInsert::automation_run (BufferSet& bufs, framepos_t start, pframes_t nframes)
 {
@@ -556,7 +668,7 @@ PluginInsert::automation_run (BufferSet& bufs, framepos_t start, pframes_t nfram
                return;
        }
 
-       if (!find_next_event (now, end, next_event) || requires_fixed_sized_buffers()) {
+       if (!find_next_event (now, end, next_event) || _plugins.front()->requires_fixed_sized_buffers()) {
 
                /* no events have a time within the relevant range */
 
@@ -659,7 +771,7 @@ PluginInsert::reset_parameters_to_default ()
                        continue;
                }
 
-               ac->set_value (dflt);
+               ac->set_value (dflt, Controllable::NoGroup);
        }
        return all;
 }
@@ -668,6 +780,7 @@ boost::shared_ptr<Plugin>
 PluginInsert::plugin_factory (boost::shared_ptr<Plugin> other)
 {
        boost::shared_ptr<LadspaPlugin> lp;
+       boost::shared_ptr<LuaProc> lua;
 #ifdef LV2_SUPPORT
        boost::shared_ptr<LV2Plugin> lv2p;
 #endif
@@ -683,6 +796,8 @@ PluginInsert::plugin_factory (boost::shared_ptr<Plugin> other)
 
        if ((lp = boost::dynamic_pointer_cast<LadspaPlugin> (other)) != 0) {
                return boost::shared_ptr<Plugin> (new LadspaPlugin (*lp));
+       } else if ((lua = boost::dynamic_pointer_cast<LuaProc> (other)) != 0) {
+               return boost::shared_ptr<Plugin> (new LuaProc (*lua));
 #ifdef LV2_SUPPORT
        } else if ((lv2p = boost::dynamic_pointer_cast<LV2Plugin> (other)) != 0) {
                return boost::shared_ptr<Plugin> (new LV2Plugin (*lv2p));
@@ -708,43 +823,121 @@ PluginInsert::plugin_factory (boost::shared_ptr<Plugin> other)
        return boost::shared_ptr<Plugin> ((Plugin*) 0);
 }
 
+void
+PluginInsert::set_input_map (uint32_t num, ChanMapping m) {
+       if (num < _in_map.size()) {
+               bool changed = _in_map[num] != m;
+               _in_map[num] = m;
+               if (changed) {
+                       PluginMapChanged (); /* EMIT SIGNAL */
+               }
+       }
+}
+
+void
+PluginInsert::set_output_map (uint32_t num, ChanMapping m) {
+       if (num < _out_map.size()) {
+               bool changed = _out_map[num] != m;
+               _out_map[num] = m;
+               if (changed) {
+                       PluginMapChanged (); /* EMIT SIGNAL */
+               }
+       }
+}
+
 bool
 PluginInsert::configure_io (ChanCount in, ChanCount out)
 {
        Match old_match = _match;
-       ChanCount old_in = input_streams ();
-       ChanCount old_out = output_streams ();
+       ChanCount old_in;
+       ChanCount old_out;
+
+       if (_configured) {
+               old_in = _configured_in;
+               old_out = _configured_out;
+       } else {
+               old_in = internal_input_streams ();
+               old_out = internal_output_streams ();
+       }
+
+       _configured_in = in;
+       _configured_out = out;
+
+       /* TODO use "custom config"
+        * allow user to edit/override output ports, handle strict i/o.
+        *
+        * configuration should only applied here.
+        */
 
        /* set the matching method and number of plugins that we will use to meet this configuration */
        _match = private_can_support_io_configuration (in, out);
        if (set_count (_match.plugins) == false) {
-               return false;
-       }
-
-       if (  (old_match.method != _match.method && (old_match.method == Split || _match.method == Split))
-                       || old_in != in
-                       || old_out != out
-                       )
-       {
                PluginIoReConfigure (); /* EMIT SIGNAL */
+               _configured = false;
+               return false;
        }
 
        /* configure plugins */
        switch (_match.method) {
        case Split:
        case Hide:
-               if (_plugins.front()->configure_io (_plugins.front()->get_info()->n_inputs, out)) {
+               if (_plugins.front()->configure_io (_plugins.front()->get_info()->n_inputs, out) == false) {
+                       PluginIoReConfigure (); /* EMIT SIGNAL */
+                       _configured = false;
                        return false;
                }
                break;
 
        default:
                if (_plugins.front()->configure_io (in, out) == false) {
+                       PluginIoReConfigure (); /* EMIT SIGNAL */
+                       _configured = false;
                        return false;
                }
                break;
        }
 
+       if (old_in == in && old_out == out
+                       && old_match.method == _match.method
+                       && _in_map.size() == _out_map.size()
+                       && _in_map.size() == get_count ()
+                ) {
+               /* If the configuraton has not changed AND there is a custom map,
+                * keep the custom map.
+                */
+               // TODO: check if it's valid..
+       } else {
+               /* generate a new mapping */
+               uint32_t pc = 0;
+               _in_map.clear ();
+               _out_map.clear ();
+               for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i, ++pc) {
+                       if (_match.method == Split) {
+                               /* TODO see PluginInsert::connect_and_run, channel replication */
+                               _in_map[pc] = ChanMapping (max (natural_input_streams (), in));
+                       } else {
+                               _in_map[pc] = ChanMapping (min (natural_input_streams (), in));
+                       }
+                       _out_map[pc] = ChanMapping (min (natural_output_streams(), out));
+
+                       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                               _in_map[pc].offset_to(*t, pc * natural_input_streams().get(*t));
+                               _out_map[pc].offset_to(*t, pc * natural_output_streams().get(*t));
+                       }
+               }
+               //TODO if changed:
+               //PluginMapChanged (); /* EMIT SIGNAL */
+       }
+
+
+       if (  (old_match.method != _match.method && (old_match.method == Split || _match.method == Split))
+                       || old_in != in
+                       || old_out != out
+                       )
+       {
+               PluginIoReConfigure (); /* EMIT SIGNAL */
+       }
+
        // we don't know the analysis window size, so we must work with the
        // current buffer size here. each request for data fills in these
        // buffers and the analyser makes sure it gets enough data for the
@@ -757,6 +950,7 @@ PluginInsert::configure_io (ChanCount in, ChanCount out)
 
        // std::cerr << "set counts to i" << in.n_audio() << "/o" << out.n_audio() << std::endl;
 
+       _configured = true;
        return Processor::configure_io (in, out);
 }
 
@@ -785,6 +979,11 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
                return Match();
        }
 
+       if (_custom_cfg && !_strict_io) {
+               out = _custom_out;
+               return Match (ExactMatch, get_count(), false, true); // XXX
+       }
+
        PluginInfoPtr info = _plugins.front()->get_info();
        ChanCount in; in += inx;
        midi_bypass.reset();
@@ -796,6 +995,11 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
                        return Match (Impossible, 0);
                }
 
+               if (_strict_io && in.n_audio() < out.n_audio()) {
+                       DEBUG_TRACE (DEBUG::Processors, string_compose ("hiding output ports of reconfigurable %1\n", name()));
+                       out.set (DataType::AUDIO, in.get (DataType::AUDIO));
+               }
+
                return Match (Delegate, 1);
        }
 
@@ -819,6 +1023,53 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
                }
        }
 
+       /* replicate no-input generators with strict i/o */
+       if (no_inputs && _strict_io) {
+               uint32_t f             = 0;
+               bool     can_replicate = true;
+
+               for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                       uint32_t nout = outputs.get (*t);
+                       uint32_t nwant = in.get (*t);
+                       if (nout > nwant) {
+                               can_replicate = false;
+                               break;
+                       }
+                       if (nout == nwant) {
+                               continue;
+                       }
+
+                       if (f == 0 && nwant % nout == 0) {
+                               f = nwant / nout;
+                       }
+
+                       if (f * nout != nwant) {
+                               can_replicate = false;
+                               break;
+                       }
+               }
+
+               if (can_replicate && f > 1) {
+                       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+                               out.set (*t, outputs.get(*t) * f);
+                       }
+                       out += midi_bypass;
+                       return Match (Replicate, f);
+               }
+       }
+
+       if ((no_inputs || inputs == in) && _strict_io) {
+               /* special case synths and generators */
+               if (in.n_audio () == 0 && in.n_midi () > 0 && outputs.n_audio () > 0) {
+                       // TODO limit the audio-channel count to track output
+                       out = outputs + midi_bypass;
+                       return Match (ExactMatch, 1);
+               } else {
+                       out = in + midi_bypass;
+                       return Match (ExactMatch, 1, true);
+               }
+       }
+
        if (no_inputs) {
                /* no inputs so we can take any input configuration since we throw it away */
                out = outputs + midi_bypass;
@@ -836,7 +1087,7 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
           We allow replication only for plugins with either zero or 1 inputs and outputs
           for every valid data type.
        */
-       
+
        uint32_t f             = 0;
        bool     can_replicate = true;
        for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
@@ -866,6 +1117,7 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
        }
 
        if (can_replicate) {
+               assert (f > 1);
                for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
                        out.set (*t, outputs.get(*t) * f);
                }
@@ -881,8 +1133,8 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
           plugin inputs?  Let me count the ways ...
        */
 
-       bool can_split = true;
-       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+       bool can_split = !_strict_io; // XXX
+       for (DataType::iterator t = DataType::begin(); t != DataType::end() && can_split; ++t) {
 
                bool const can_split_type = (in.get (*t) == 1 && inputs.get (*t) > 1);
                bool const nothing_to_do_for_type = (in.get (*t) == 0 && inputs.get (*t) == 0);
@@ -904,8 +1156,8 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
        bool could_hide = false;
        bool cannot_hide = false;
        ChanCount hide_channels;
-       
-       for (DataType::iterator t = DataType::begin(); t != DataType::end(); ++t) {
+
+       for (DataType::iterator t = DataType::begin(); t != DataType::end() && !cannot_hide; ++t) {
                if (inputs.get(*t) > in.get(*t)) {
                        /* there is potential to hide, since the plugin has more inputs of type t than the insert */
                        hide_channels.set (*t, inputs.get(*t) - in.get(*t));
@@ -917,11 +1169,17 @@ PluginInsert::private_can_support_io_configuration (ChanCount const & inx, ChanC
        }
 
        if (could_hide && !cannot_hide) {
-               out = outputs + midi_bypass;
-               return Match (Hide, 1, hide_channels);
+               if (_strict_io) {
+                       outputs = inputs;
+                       return Match (Hide, 1, true, false, hide_channels);
+               } else {
+                       out = outputs + midi_bypass;
+                       return Match (Hide, 1, false, false, hide_channels);
+               }
        }
 
        midi_bypass.reset();
+       // TODO make it possible :)
        return Match (Impossible, 0);
 }
 
@@ -939,6 +1197,15 @@ PluginInsert::state (bool full)
        node.add_property("type", _plugins[0]->state_node_name());
        node.add_property("unique-id", _plugins[0]->unique_id());
        node.add_property("count", string_compose("%1", _plugins.size()));
+
+       /* remember actual i/o configuration (for later placeholder
+        * in case the plugin goes missing) */
+       node.add_child_nocopy (* _configured_in.state (X_("ConfiguredInput")));
+       node.add_child_nocopy (* _configured_out.state (X_("ConfiguredOutput")));
+
+       // TODO save channel-maps,  _custom_cfg & _custom_out
+
+       _plugins[0]->set_insert_id(this->id());
        node.add_child_nocopy (_plugins[0]->get_state());
 
        for (Controls::iterator c = controls().begin(); c != controls().end(); ++c) {
@@ -962,8 +1229,20 @@ PluginInsert::set_control_ids (const XMLNode& node, int version)
                if ((*iter)->name() == Controllable::xml_node_name) {
                        const XMLProperty* prop;
 
-                       if ((prop = (*iter)->property (X_("parameter"))) != 0) {
-                               uint32_t p = atoi (prop->value());
+                       uint32_t p = (uint32_t)-1;
+#ifdef LV2_SUPPORT
+                       if ((prop = (*iter)->property (X_("symbol"))) != 0) {
+                               boost::shared_ptr<LV2Plugin> lv2plugin = boost::dynamic_pointer_cast<LV2Plugin> (_plugins[0]);
+                               if (lv2plugin) {
+                                       p = lv2plugin->port_index(prop->value().c_str());
+                               }
+                       }
+#endif
+                       if (p == (uint32_t)-1 && (prop = (*iter)->property (X_("parameter"))) != 0) {
+                               p = atoi (prop->value());
+                       }
+
+                       if (p != (uint32_t)-1) {
 
                                /* this may create the new controllable */
 
@@ -1007,6 +1286,8 @@ PluginInsert::set_state(const XMLNode& node, int version)
                type = ARDOUR::LXVST;
        } else if (prop->value() == X_("audiounit")) {
                type = ARDOUR::AudioUnit;
+       } else if (prop->value() == X_("luaproc")) {
+               type = ARDOUR::Lua;
        } else {
                error << string_compose (_("unknown plugin type %1 in plugin insert state"),
                                  prop->value())
@@ -1068,6 +1349,15 @@ PluginInsert::set_state(const XMLNode& node, int version)
                return -1;
        }
 
+       if (type == ARDOUR::Lua) {
+               XMLNode *ls = node.child (plugin->state_node_name().c_str());
+               // we need to load the script to set the name and parameters.
+               boost::shared_ptr<LuaProc> lp = boost::dynamic_pointer_cast<LuaProc>(plugin);
+               if (ls && lp) {
+                       lp->set_script_from_state (*ls);
+               }
+       }
+
        // The name of the PluginInsert comes from the plugin, nothing else
        _name = plugin->get_info()->name;
 
@@ -1101,6 +1391,13 @@ PluginInsert::set_state(const XMLNode& node, int version)
 
        Processor::set_state (node, version);
 
+       PBD::ID new_id = this->id();
+       PBD::ID old_id = this->id();
+
+       if ((prop = node.property ("id")) != 0) {
+               old_id = prop->value ();
+       }
+
        for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
 
                /* find the node with the type-specific node name ("lv2", "ladspa", etc)
@@ -1110,7 +1407,27 @@ PluginInsert::set_state(const XMLNode& node, int version)
                if ((*niter)->name() == plugin->state_node_name()) {
 
                        for (Plugins::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+                               /* Plugin state can include external files which are named after the ID.
+                                *
+                                * If regenerate_xml_or_string_ids() is set, the ID will already have
+                                * been changed, so we need to use the old ID from the XML to load the
+                                * state and then update the ID.
+                                *
+                                * When copying a plugin-state, route_ui takes care of of updating the ID,
+                                * but we need to call set_insert_id() to clear the cached plugin-state
+                                * and force a change.
+                                */
+                               if (!regenerate_xml_or_string_ids ()) {
+                                       (*i)->set_insert_id (new_id);
+                               } else {
+                                       (*i)->set_insert_id (old_id);
+                               }
+
                                (*i)->set_state (**niter, version);
+
+                               if (regenerate_xml_or_string_ids ()) {
+                                       (*i)->set_insert_id (new_id);
+                               }
                        }
 
                        break;
@@ -1154,6 +1471,13 @@ PluginInsert::update_id (PBD::ID id)
        }
 }
 
+void
+PluginInsert::set_state_dir (const std::string& d)
+{
+       // state() only saves the state of the first plugin
+       _plugins[0]->set_state_dir (d);
+}
+
 void
 PluginInsert::set_parameter_state_2X (const XMLNode& node, int version)
 {
@@ -1289,7 +1613,21 @@ PluginInsert::PluginControl::PluginControl (PluginInsert*                     p,
 
 /** @param val `user' value */
 void
-PluginInsert::PluginControl::set_value (double user_val)
+PluginInsert::PluginControl::set_value (double user_val, PBD::Controllable::GroupControlDisposition group_override)
+{
+       if (writable()) {
+               _set_value (user_val, group_override);
+       }
+}
+void
+PluginInsert::PluginControl::set_value_unchecked (double user_val)
+{
+       /* used only by automation playback */
+       _set_value (user_val, Controllable::NoGroup);
+}
+
+void
+PluginInsert::PluginControl::_set_value (double user_val, PBD::Controllable::GroupControlDisposition group_override)
 {
        /* FIXME: probably should be taking out some lock here.. */
 
@@ -1302,7 +1640,13 @@ PluginInsert::PluginControl::set_value (double user_val)
                iasp->set_parameter (_list->parameter().id(), user_val);
        }
 
-       AutomationControl::set_value (user_val);
+       AutomationControl::set_value (user_val, group_override);
+}
+
+void
+PluginInsert::PluginControl::catch_up_with_external_value (double user_val)
+{
+       AutomationControl::set_value (user_val, Controllable::NoGroup);
 }
 
 XMLNode&
@@ -1313,6 +1657,12 @@ PluginInsert::PluginControl::get_state ()
        XMLNode& node (AutomationControl::get_state());
        ss << parameter().id();
        node.add_property (X_("parameter"), ss.str());
+#ifdef LV2_SUPPORT
+       boost::shared_ptr<LV2Plugin> lv2plugin = boost::dynamic_pointer_cast<LV2Plugin> (_plugin->_plugins[0]);
+       if (lv2plugin) {
+               node.add_property (X_("symbol"), lv2plugin->port_symbol (parameter().id()));
+       }
+#endif
 
        return node;
 }
@@ -1321,8 +1671,13 @@ PluginInsert::PluginControl::get_state ()
 double
 PluginInsert::PluginControl::get_value () const
 {
-       /* FIXME: probably should be taking out some lock here.. */
-       return _plugin->get_parameter (_list->parameter());
+       boost::shared_ptr<Plugin> plugin = _plugin->plugin (0);
+
+       if (!plugin) {
+               return 0.0;
+       }
+
+       return plugin->get_parameter (_list->parameter().id());
 }
 
 PluginInsert::PluginPropertyControl::PluginPropertyControl (PluginInsert*                     p,
@@ -1343,7 +1698,15 @@ PluginInsert::PluginPropertyControl::PluginPropertyControl (PluginInsert*
 }
 
 void
-PluginInsert::PluginPropertyControl::set_value (double user_val)
+PluginInsert::PluginPropertyControl::set_value (double user_val, PBD::Controllable::GroupControlDisposition /* group_override*/)
+{
+       if (writable()) {
+               set_value_unchecked (user_val);
+       }
+}
+
+void
+PluginInsert::PluginPropertyControl::set_value_unchecked (double user_val)
 {
        /* Old numeric set_value(), coerce to appropriate datatype if possible.
           This is lossy, but better than nothing until Ardour's automation system
@@ -1359,7 +1722,7 @@ PluginInsert::PluginPropertyControl::set_value (double user_val)
        }
 
        _value = value;
-       AutomationControl::set_value(user_val);
+       AutomationControl::set_value (user_val, Controllable::NoGroup);
 }
 
 XMLNode&
@@ -1387,6 +1750,7 @@ PluginInsert::get_impulse_analysis_plugin()
        boost::shared_ptr<Plugin> ret;
        if (_impulseAnalysisPlugin.expired()) {
                ret = plugin_factory(_plugins[0]);
+               ret->configure_io (internal_input_streams (), internal_output_streams ());
                _impulseAnalysisPlugin = ret;
        } else {
                ret = _impulseAnalysisPlugin.lock();
@@ -1400,8 +1764,8 @@ PluginInsert::collect_signal_for_analysis (framecnt_t nframes)
 {
        // called from outside the audio thread, so this should be safe
        // only do audio as analysis is (currently) only for audio plugins
-       _signal_analysis_inputs.ensure_buffers(  DataType::AUDIO, input_streams().n_audio(),  nframes);
-       _signal_analysis_outputs.ensure_buffers( DataType::AUDIO, output_streams().n_audio(), nframes);
+       _signal_analysis_inputs.ensure_buffers(  DataType::AUDIO, internal_input_streams().n_audio(),  nframes);
+       _signal_analysis_outputs.ensure_buffers( DataType::AUDIO, internal_output_streams().n_audio(), nframes);
 
        _signal_analysis_collected_nframes   = 0;
        _signal_analysis_collect_nframes_max = nframes;
@@ -1412,12 +1776,12 @@ void
 PluginInsert::add_plugin (boost::shared_ptr<Plugin> plugin)
 {
        plugin->set_insert_id (this->id());
-       
+
        if (_plugins.empty()) {
-                /* first (and probably only) plugin instance - connect to relevant signals 
+                /* first (and probably only) plugin instance - connect to relevant signals
                  */
 
-               plugin->ParameterChanged.connect_same_thread (*this, boost::bind (&PluginInsert::parameter_changed, this, _1, _2));
+               plugin->ParameterChangedExternally.connect_same_thread (*this, boost::bind (&PluginInsert::parameter_changed_externally, this, _1, _2));
                 plugin->StartTouch.connect_same_thread (*this, boost::bind (&PluginInsert::start_touch, this, _1));
                 plugin->EndTouch.connect_same_thread (*this, boost::bind (&PluginInsert::end_touch, this, _1));
        }