fixes for destructive track offsets of various kinds; move from jack_nframes_t -...
[ardour.git] / libs / ardour / insert.cc
index 80bc0ce862b2c40f9f78ae5bb95e1c321f9ad83b..d955588c44d216c9022cfa9d76269b28563b21ed 100644 (file)
 #include <ardour/port.h>
 #include <ardour/route.h>
 #include <ardour/ladspa_plugin.h>
+
+#ifdef VST_SUPPORT
 #include <ardour/vst_plugin.h>
+#endif
+
+#ifdef HAVE_AUDIOUNITS
+#include <ardour/audio_unit.h>
+#endif
+
 #include <ardour/audioengine.h>
 #include <ardour/session.h>
+#include <ardour/types.h>
 
 #include "i18n.h"
 
 using namespace std;
 using namespace ARDOUR;
-//using namespace sigc;
+using namespace PBD;
 
 Insert::Insert(Session& s, Placement p)
        : Redirect (s, s.next_insert_name(), p)
 {
 }
 
-
 Insert::Insert(Session& s, Placement p, int imin, int imax, int omin, int omax)
        : Redirect (s, s.next_insert_name(), p, imin, imax, omin, omax)
 {
@@ -62,12 +70,12 @@ Insert::Insert(Session& s, string name, Placement p)
 
 const string PluginInsert::port_automation_node_name = "PortAutomation";
 
-PluginInsert::PluginInsert (Session& s, Plugin& plug, Placement placement)
-       : Insert (s, plug.name(), placement)
+PluginInsert::PluginInsert (Session& s, boost::shared_ptr<Plugin> plug, Placement placement)
+       : Insert (s, plug->name(), placement)
 {
        /* the first is the master */
 
-       _plugins.push_back(&plug);
+       _plugins.push_back (plug);
 
        _plugins[0]->ParameterChanged.connect (mem_fun (*this, &PluginInsert::parameter_changed));
        
@@ -76,7 +84,7 @@ PluginInsert::PluginInsert (Session& s, Plugin& plug, Placement placement)
        save_state (_("initial state"));
 
        {
-               LockMonitor em (_session.engine().process_lock(), __LINE__, __FILE__);
+               Glib::Mutex::Lock em (_session.engine().process_lock());
                IO::MoreOutputs (output_streams ());
        }
 
@@ -97,19 +105,19 @@ PluginInsert::PluginInsert (Session& s, const XMLNode& node)
        _plugins[0]->ParameterChanged.connect (mem_fun (*this, &PluginInsert::parameter_changed));
 
        {
-               LockMonitor em (_session.engine().process_lock(), __LINE__, __FILE__);
+               Glib::Mutex::Lock em (_session.engine().process_lock());
                IO::MoreOutputs (output_streams());
        }
 }
 
 PluginInsert::PluginInsert (const PluginInsert& other)
-       : Insert (other._session, other.plugin().name(), other.placement())
+       : Insert (other._session, other.plugin()->name(), other.placement())
 {
        uint32_t count = other._plugins.size();
 
        /* make as many copies as requested */
        for (uint32_t n = 0; n < count; ++n) {
-               _plugins.push_back (plugin_factory (other.plugin()));
+               _plugins.push_back (plugin_factory (other.plugin (n)));
        }
 
 
@@ -137,7 +145,7 @@ PluginInsert::set_count (uint32_t num)
                uint32_t diff = num - _plugins.size();
 
                for (uint32_t n = 0; n < diff; ++n) {
-                       _plugins.push_back (plugin_factory (*_plugins[0]));
+                       _plugins.push_back (plugin_factory (_plugins[0]));
 
                        if (require_state) {
                                /* XXX do something */
@@ -147,9 +155,7 @@ PluginInsert::set_count (uint32_t num)
        } else if (num < _plugins.size()) {
                uint32_t diff = _plugins.size() - num;
                for (uint32_t n= 0; n < diff; ++n) {
-                       Plugin * plug = _plugins.back();
                        _plugins.pop_back();
-                       delete plug;
                }
        }
 
@@ -166,13 +172,7 @@ PluginInsert::init ()
 
 PluginInsert::~PluginInsert ()
 {
-       GoingAway (this); /* EMIT SIGNAL */
-       
-       while (!_plugins.empty()) {
-               Plugin* p = _plugins.back();
-               _plugins.pop_back();
-               delete p;
-       }
+       GoingAway (); /* EMIT SIGNAL */
 }
 
 void
@@ -194,25 +194,25 @@ PluginInsert::auto_state_changed (uint32_t which)
 uint32_t
 PluginInsert::output_streams() const
 {
-       return _plugins[0]->get_info().n_outputs * _plugins.size();
+       return _plugins[0]->get_info()->n_outputs * _plugins.size();
 }
 
 uint32_t
 PluginInsert::input_streams() const
 {
-       return _plugins[0]->get_info().n_inputs * _plugins.size();
+       return _plugins[0]->get_info()->n_inputs * _plugins.size();
 }
 
 uint32_t
 PluginInsert::natural_output_streams() const
 {
-       return _plugins[0]->get_info().n_outputs;
+       return _plugins[0]->get_info()->n_outputs;
 }
 
 uint32_t
 PluginInsert::natural_input_streams() const
 {
-       return _plugins[0]->get_info().n_inputs;
+       return _plugins[0]->get_info()->n_inputs;
 }
 
 bool
@@ -222,7 +222,7 @@ PluginInsert::is_generator() const
           a specific "instrument" flag, for example.
         */
 
-       return _plugins[0]->get_info().n_inputs == 0;
+       return _plugins[0]->get_info()->n_inputs == 0;
 }
 
 void
@@ -240,7 +240,7 @@ PluginInsert::set_automatable ()
 void
 PluginInsert::parameter_changed (uint32_t which, float val)
 {
-       vector<Plugin*>::iterator i = _plugins.begin();
+       vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin();
 
        /* don't set the first plugin, just all the slaves */
 
@@ -253,9 +253,9 @@ PluginInsert::parameter_changed (uint32_t which, float val)
 }
 
 void
-PluginInsert::set_block_size (jack_nframes_t nframes)
+PluginInsert::set_block_size (nframes_t nframes)
 {
-       for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+       for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                (*i)->set_block_size (nframes);
        }
 }
@@ -263,7 +263,7 @@ PluginInsert::set_block_size (jack_nframes_t nframes)
 void
 PluginInsert::activate ()
 {
-       for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+       for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                (*i)->activate ();
        }
 }
@@ -271,13 +271,13 @@ PluginInsert::activate ()
 void
 PluginInsert::deactivate ()
 {
-       for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+       for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                (*i)->deactivate ();
        }
 }
 
 void
-PluginInsert::connect_and_run (vector<Sample*>& bufs, uint32_t nbufs, jack_nframes_t nframes, jack_nframes_t offset, bool with_auto, jack_nframes_t now)
+PluginInsert::connect_and_run (vector<Sample*>& bufs, uint32_t nbufs, nframes_t nframes, nframes_t offset, bool with_auto, nframes_t now)
 {
        int32_t in_index = 0;
        int32_t out_index = 0;
@@ -309,7 +309,7 @@ PluginInsert::connect_and_run (vector<Sample*>& bufs, uint32_t nbufs, jack_nfram
                }
        }
 
-       for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+       for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                (*i)->connect_and_run (bufs, nbufs, in_index, out_index, nframes, offset);
        }
 
@@ -317,24 +317,24 @@ PluginInsert::connect_and_run (vector<Sample*>& bufs, uint32_t nbufs, jack_nfram
 }
 
 void
-PluginInsert::automation_snapshot (jack_nframes_t now)
+PluginInsert::automation_snapshot (nframes_t now)
 {
        map<uint32_t,AutomationList*>::iterator li;
-
+       
        for (li = parameter_automation.begin(); li != parameter_automation.end(); ++li) {
                
-               AutomationList& alist (*((*li).second));
-               if (alist.automation_write ()) {
+               AutomationList *alist = ((*li).second);
+               if (alist != 0 && alist->automation_write ()) {
                        
                        float val = _plugins[0]->get_parameter ((*li).first);
-                       alist.rt_add (now, val);
+                       alist->rt_add (now, val);
                        last_automation_snapshot = now;
                }
        }
 }
 
 void
-PluginInsert::transport_stopped (jack_nframes_t now)
+PluginInsert::transport_stopped (nframes_t now)
 {
        map<uint32_t,AutomationList*>::iterator li;
 
@@ -349,7 +349,7 @@ PluginInsert::transport_stopped (jack_nframes_t now)
 }
 
 void
-PluginInsert::silence (jack_nframes_t nframes, jack_nframes_t offset)
+PluginInsert::silence (nframes_t nframes, nframes_t offset)
 {
        int32_t in_index = 0;
        int32_t out_index = 0;
@@ -357,15 +357,15 @@ PluginInsert::silence (jack_nframes_t nframes, jack_nframes_t offset)
        uint32_t n;
 
        if (active()) {
-               for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
-                       n = (*i) -> get_info().n_inputs;
+               for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+                       n = (*i) -> get_info()->n_inputs;
                        (*i)->connect_and_run (_session.get_silent_buffers (n), n, in_index, out_index, nframes, offset);
                }
        }
 }
        
 void
-PluginInsert::run (vector<Sample *>& bufs, uint32_t nbufs, jack_nframes_t nframes, jack_nframes_t offset)
+PluginInsert::run (vector<Sample *>& bufs, uint32_t nbufs, nframes_t nframes, nframes_t offset)
 {
        if (active()) {
 
@@ -375,8 +375,8 @@ PluginInsert::run (vector<Sample *>& bufs, uint32_t nbufs, jack_nframes_t nframe
                        connect_and_run (bufs, nbufs, nframes, offset, false);
                }
        } else {
-               uint32_t in = _plugins[0]->get_info().n_inputs;
-               uint32_t out = _plugins[0]->get_info().n_outputs;
+               uint32_t in = _plugins[0]->get_info()->n_inputs;
+               uint32_t out = _plugins[0]->get_info()->n_outputs;
 
                if (out > in) {
 
@@ -404,13 +404,13 @@ PluginInsert::set_parameter (uint32_t port, float val)
 }
 
 void
-PluginInsert::automation_run (vector<Sample *>& bufs, uint32_t nbufs, jack_nframes_t nframes, jack_nframes_t offset)
+PluginInsert::automation_run (vector<Sample *>& bufs, uint32_t nbufs, nframes_t nframes, nframes_t offset)
 {
        ControlEvent next_event (0, 0.0f);
-       jack_nframes_t now = _session.transport_frame ();
-       jack_nframes_t end = now + nframes;
+       nframes_t now = _session.transport_frame ();
+       nframes_t end = now + nframes;
 
-       TentativeLockMonitor lm (_automation_lock, __LINE__, __FILE__);
+       Glib::Mutex::Lock lm (_automation_lock, Glib::TRY_LOCK);
 
        if (!lm.locked()) {
                connect_and_run (bufs, nbufs, nframes, offset, false);
@@ -427,7 +427,7 @@ PluginInsert::automation_run (vector<Sample *>& bufs, uint32_t nbufs, jack_nfram
        
        while (nframes) {
 
-               jack_nframes_t cnt = min (((jack_nframes_t) floor (next_event.when) - now), nframes);
+               nframes_t cnt = min (((nframes_t) floor (next_event.when) - now), nframes);
   
                connect_and_run (bufs, nbufs, cnt, offset, true, now);
                
@@ -506,33 +506,40 @@ PluginInsert::protect_automation ()
        }
 }
 
-Plugin*
-PluginInsert::plugin_factory (Plugin& other)
+boost::shared_ptr<Plugin>
+PluginInsert::plugin_factory (boost::shared_ptr<Plugin> other)
 {
-       LadspaPlugin* lp;
+       boost::shared_ptr<LadspaPlugin> lp;
 #ifdef VST_SUPPORT
-       VSTPlugin* vp;
+       boost::shared_ptr<VSTPlugin> vp;
+#endif
+#ifdef HAVE_AUDIOUNITS
+       boost::shared_ptr<AUPlugin> ap;
 #endif
 
-       if ((lp = dynamic_cast<LadspaPlugin*> (&other)) != 0) {
-               return new LadspaPlugin (*lp);
+       if ((lp = boost::dynamic_pointer_cast<LadspaPlugin> (other)) != 0) {
+               return boost::shared_ptr<Plugin> (new LadspaPlugin (*lp));
 #ifdef VST_SUPPORT
-       } else if ((vp = dynamic_cast<VSTPlugin*> (&other)) != 0) {
-               return new VSTPlugin (*vp);
+       } else if ((vp = boost::dynamic_pointer_cast<VSTPlugin> (other)) != 0) {
+               return boost::shared_ptr<Plugin> (new VSTPlugin (*vp));
+#endif
+#ifdef HAVE_AUDIOUNITS
+       } else if ((ap = boost::dynamic_pointer_cast<AUPlugin> (other)) != 0) {
+               return boost::shared_ptr<Plugin> (new AUPlugin (*ap));
 #endif
        }
 
-       fatal << compose (_("programming error: %1"),
+       fatal << string_compose (_("programming error: %1"),
                          X_("unknown plugin type in PluginInsert::plugin_factory"))
              << endmsg;
        /*NOTREACHED*/
-       return 0;
+       return boost::shared_ptr<Plugin> ((Plugin*) 0);
 }
 
 int32_t
 PluginInsert::compute_output_streams (int32_t cnt) const
 {
-       return _plugins[0]->get_info().n_outputs * cnt;
+       return _plugins[0]->get_info()->n_outputs * cnt;
 }
 
 int32_t
@@ -544,8 +551,8 @@ PluginInsert::configure_io (int32_t magic, int32_t in, int32_t out)
 int32_t 
 PluginInsert::can_support_input_configuration (int32_t in) const
 {
-       int32_t outputs = _plugins[0]->get_info().n_outputs;
-       int32_t inputs = _plugins[0]->get_info().n_inputs;
+       int32_t outputs = _plugins[0]->get_info()->n_outputs;
+       int32_t inputs = _plugins[0]->get_info()->n_inputs;
 
        if (inputs == 0) {
 
@@ -597,7 +604,12 @@ PluginInsert::state (bool full)
        node->add_property ("type", _plugins[0]->state_node_name());
        snprintf(buf, sizeof(buf), "%s", _plugins[0]->name());
        node->add_property("id", string(buf));
-       node->add_property("count", compose("%1", _plugins.size()));
+       if (_plugins[0]->state_node_name() == "ladspa") {
+               char buf[32];
+               snprintf (buf, sizeof (buf), "%ld", _plugins[0]->get_info()->unique_id); 
+               node->add_property("unique-id", string(buf));
+       }
+       node->add_property("count", string_compose("%1", _plugins.size()));
        node->add_child_nocopy (_plugins[0]->get_state());
 
        /* add port automation state */
@@ -632,7 +644,8 @@ PluginInsert::set_state(const XMLNode& node)
        XMLNodeIterator niter;
        XMLPropertyList plist;
        const XMLProperty *prop;
-       PluginInfo::Type type;
+       long unique = 0;
+       ARDOUR::PluginType type;
 
        if ((prop = node.property ("type")) == 0) {
                error << _("XML node describing insert is missing the `type' field") << endmsg;
@@ -640,25 +653,36 @@ PluginInsert::set_state(const XMLNode& node)
        }
 
        if (prop->value() == X_("ladspa") || prop->value() == X_("Ladspa")) { /* handle old school sessions */
-               type = PluginInfo::LADSPA;
+               type = ARDOUR::LADSPA;
        } else if (prop->value() == X_("vst")) {
-               type = PluginInfo::VST;
+               type = ARDOUR::VST;
        } else {
-               error << compose (_("unknown plugin type %1 in plugin insert state"),
+               error << string_compose (_("unknown plugin type %1 in plugin insert state"),
                                  prop->value())
                      << endmsg;
                return -1;
        }
 
+       prop = node.property ("unique-id");
+       if (prop != 0) {
+               unique = atol(prop->value().c_str());
+       }
+
        if ((prop = node.property ("id")) == 0) {
                error << _("XML node describing insert is missing the `id' field") << endmsg;
                return -1;
        }
 
-       Plugin* plugin;
+       boost::shared_ptr<Plugin> plugin;
        
-       if ((plugin = find_plugin (_session, prop->value(), type)) == 0) {
-               error << compose(_("Found a reference to a plugin (\"%1\") that is unknown.\n"
+       if (unique != 0) {
+               plugin = find_plugin (_session, "", unique, type);      
+       } else {
+               plugin = find_plugin (_session, prop->value(), 0, type);        
+       }
+
+       if (plugin == 0) {
+               error << string_compose(_("Found a reference to a plugin (\"%1\") that is unknown.\n"
                                   "Perhaps it was removed or moved since it was last used."), prop->value()) 
                      << endmsg;
                return -1;
@@ -675,13 +699,13 @@ PluginInsert::set_state(const XMLNode& node)
                _plugins.push_back (plugin);
                
                for (uint32_t n=1; n < count; ++n) {
-                       _plugins.push_back (plugin_factory (*plugin));
+                       _plugins.push_back (plugin_factory (plugin));
                }
        }
        
        for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
                if ((*niter)->name() == plugin->state_node_name()) {
-                       for (vector<Plugin*>::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
+                       for (vector<boost::shared_ptr<Plugin> >::iterator i = _plugins.begin(); i != _plugins.end(); ++i) {
                                (*i)->set_state (**niter);
                        }
                        break;
@@ -701,7 +725,7 @@ PluginInsert::set_state(const XMLNode& node)
        }
 
        if (niter == nlist.end()) {
-               error << compose(_("XML node describing a plugin insert is missing the `%1' information"), plugin->state_node_name()) << endmsg;
+               error << string_compose(_("XML node describing a plugin insert is missing the `%1' information"), plugin->state_node_name()) << endmsg;
                return -1;
        }
        
@@ -748,9 +772,11 @@ PluginInsert::set_state(const XMLNode& node)
        } 
 
        if (niter == nlist.end()) {
-               warning << compose(_("XML node describing a port automation is missing the `%1' information"), port_automation_node_name) << endmsg;
+               warning << string_compose(_("XML node describing a port automation is missing the `%1' information"), port_automation_node_name) << endmsg;
        }
        
+       // The name of the PluginInsert comes from the plugin, nothing else
+       set_name(plugin->get_info()->name,this);
        
        return 0;
 }
@@ -761,19 +787,7 @@ PluginInsert::describe_parameter (uint32_t what)
        return _plugins[0]->describe_parameter (what);
 }
 
-void
-PluginInsert::reset_midi_control (MIDI::Port* port, bool on)
-{
-       _plugins[0]->reset_midi_control (port, on);
-}
-
-void
-PluginInsert::send_all_midi_feedback ()
-{
-       _plugins[0]->send_all_midi_feedback();
-}
-
-jack_nframes_t 
+nframes_t 
 PluginInsert::latency() 
 {
        return _plugins[0]->latency ();
@@ -808,6 +822,35 @@ PluginInsert::state_factory (std::string why) const
        return state;
 }
 
+ARDOUR::PluginType
+PluginInsert::type ()
+{
+       boost::shared_ptr<LadspaPlugin> lp;
+#ifdef VST_SUPPORT
+       boost::shared_ptr<VSTPlugin> vp;
+#endif
+#ifdef HAVE_AUDIOUNITS
+       boost::shared_ptr<AUPlugin> ap;
+#endif
+       
+       PluginPtr other = plugin ();
+
+       if ((lp = boost::dynamic_pointer_cast<LadspaPlugin> (other)) != 0) {
+               return ARDOUR::LADSPA;
+#ifdef VST_SUPPORT
+       } else if ((vp = boost::dynamic_pointer_cast<VSTPlugin> (other)) != 0) {
+               return ARDOUR::VST;
+#endif
+#ifdef HAVE_AUDIOUNITS
+       } else if ((ap = boost::dynamic_pointer_cast<AUPlugin> (other)) != 0) {
+               return ARDOUR::AudioUnit;
+#endif
+       } else {
+               /* NOT REACHED */
+               return (ARDOUR::PluginType) 0;
+       }
+}
+
 /***************************************************************
  Port inserts: send output to a port, pick up input at a port
  ***************************************************************/
@@ -854,11 +897,11 @@ PortInsert::PortInsert (Session& s, const XMLNode& node)
 
 PortInsert::~PortInsert ()
 {
-       GoingAway (this);
+       GoingAway ();
 }
 
 void
-PortInsert::run (vector<Sample *>& bufs, uint32_t nbufs, jack_nframes_t nframes, jack_nframes_t offset)
+PortInsert::run (vector<Sample *>& bufs, uint32_t nbufs, nframes_t nframes, nframes_t offset)
 {
        if (n_outputs() == 0) {
                return;
@@ -878,6 +921,7 @@ PortInsert::run (vector<Sample *>& bufs, uint32_t nbufs, jack_nframes_t nframes,
 
        for (o = _outputs.begin(), n = 0; o != _outputs.end(); ++o, ++n) {
                memcpy ((*o)->get_buffer (nframes) + offset, bufs[min(nbufs,n)], sizeof (Sample) * nframes);
+               (*o)->mark_silence (false);
        }
        
        /* collect input */
@@ -937,7 +981,7 @@ PortInsert::set_state(const XMLNode& node)
        return 0;
 }
 
-jack_nframes_t 
+nframes_t 
 PortInsert::latency() 
 {
        /* because we deliver and collect within the same cycle,
@@ -1024,3 +1068,4 @@ PortInsert::input_streams() const
 {
        return n_outputs ();
 }
+