Add option to limit automatable control parmaters

[ardour.git] / libs / ardour / control_protocol_manager.cc

diff --git a/libs/ardour/control_protocol_manager.cc b/libs/ardour/control_protocol_manager.cc
index 014c2209d68801cb5a205230e8c926bb9ca041ff..048ff3f7d5dac16bc7fca17fbe7ea96dad430610 100644 (file)
--- a/libs/ardour/control_protocol_manager.cc
+++ b/libs/ardour/control_protocol_manager.cc
@@ -32,7 +32,8 @@
 #include "ardour/control_protocol_manager.h"
 
 #include "ardour/search_paths.h"
-
+#include "ardour/selection.h"
+#include "ardour/session.h"
 
 using namespace ARDOUR;
 using namespace std;
@@ -42,7 +43,7 @@ using namespace PBD;
 
 ControlProtocolManager* ControlProtocolManager::_instance = 0;
 const string ControlProtocolManager::state_node_name = X_("ControlProtocols");
-
+PBD::Signal1<void,StripableNotificationListPtr> ControlProtocolManager::StripableSelectionChanged;
 
 ControlProtocolInfo::~ControlProtocolInfo ()
 {
@@ -65,7 +66,7 @@ ControlProtocolManager::ControlProtocolManager ()
 
 ControlProtocolManager::~ControlProtocolManager()
 {
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::WriterLock lm (protocols_lock);
 
        for (list<ControlProtocol*>::iterator i = control_protocols.begin(); i != control_protocols.end(); ++i) {
                delete (*i);
@@ -75,6 +76,7 @@ ControlProtocolManager::~ControlProtocolManager()
 
 
        for (list<ControlProtocolInfo*>::iterator p = control_protocol_info.begin(); p != control_protocol_info.end(); ++p) {
+               (*p)->protocol = 0; // protocol was already destroyed above.
                delete (*p);
        }
 
@@ -86,8 +88,12 @@ ControlProtocolManager::set_session (Session* s)
 {
        SessionHandlePtr::set_session (s);
 
-       if (_session) {
-               Glib::Threads::Mutex::Lock lm (protocols_lock);
+       if (!_session) {
+               return;
+       }
+
+       {
+               Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
 
                for (list<ControlProtocolInfo*>::iterator i = control_protocol_info.begin(); i != control_protocol_info.end(); ++i) {
                        if ((*i)->requested || (*i)->mandatory) {
@@ -95,6 +101,21 @@ ControlProtocolManager::set_session (Session* s)
                        }
                }
        }
+
+       CoreSelection::StripableAutomationControls sac;
+       _session->selection().get_stripables (sac);
+
+       if (!sac.empty()) {
+               StripableNotificationListPtr v (new StripableNotificationList);
+               for (CoreSelection::StripableAutomationControls::iterator i = sac.begin(); i != sac.end(); ++i) {
+                       if ((*i).stripable) {
+                               v->push_back (boost::weak_ptr<Stripable> ((*i).stripable));
+                       }
+               }
+               if (!v->empty()) {
+                       StripableSelectionChanged (v); /* EMIT SIGNAL */
+               }
+       }
 }
 
 int
@@ -158,7 +179,7 @@ ControlProtocolManager::drop_protocols ()
         * before the process cycle stops and ports vanish.
         */
 
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::WriterLock lm (protocols_lock);
 
        for (list<ControlProtocol*>::iterator p = control_protocols.begin(); p != control_protocols.end(); ++p) {
                delete *p;
@@ -245,7 +266,8 @@ ControlProtocolManager::teardown (ControlProtocolInfo& cpi, bool lock_required)
        cpi.descriptor->destroy (cpi.descriptor, cpi.protocol);
 
        if (lock_required) {
-               Glib::Threads::Mutex::Lock lm (protocols_lock);
+               /* the lock is required when the protocol is torn down by a user from the GUI. */
+               Glib::Threads::RWLock::WriterLock lm (protocols_lock);
                list<ControlProtocol*>::iterator p = find (control_protocols.begin(), control_protocols.end(), cpi.protocol);
                if (p != control_protocols.end()) {
                        control_protocols.erase (p);
@@ -263,8 +285,6 @@ ControlProtocolManager::teardown (ControlProtocolInfo& cpi, bool lock_required)
 
        cpi.protocol = 0;
 
-       delete cpi.state;
-       cpi.state = 0;
        delete (Glib::Module*) cpi.descriptor->module;
        /* cpi->descriptor is now inaccessible since dlclose() or equivalent
         * has been performed, and the descriptor is (or could be) a static
@@ -284,7 +304,7 @@ ControlProtocolManager::load_mandatory_protocols ()
                return;
        }
 
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
 
        for (list<ControlProtocolInfo*>::iterator i = control_protocol_info.begin(); i != control_protocol_info.end(); ++i) {
                if ((*i)->mandatory && ((*i)->protocol == 0)) {
@@ -432,12 +452,12 @@ ControlProtocolManager::cpi_by_name (string name)
 }
 
 int
-ControlProtocolManager::set_state (const XMLNode& node, int /*version*/)
+ControlProtocolManager::set_state (const XMLNode& node, int session_specific_state /* here: not version */)
 {
        XMLNodeList clist;
        XMLNodeConstIterator citer;
 
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::WriterLock lm (protocols_lock);
 
        clist = node.children();
 
@@ -456,22 +476,28 @@ ControlProtocolManager::set_state (const XMLNode& node, int /*version*/)
                        ControlProtocolInfo* cpi = cpi_by_name (name);
 
                        if (cpi) {
-                               delete cpi->state;
-                               cpi->state = new XMLNode (**citer);
-
+#ifndef NDEBUG
                                std::cerr << "protocol " << name << " active ? " << active << std::endl;
+#endif
 
                                if (active) {
+                                       delete cpi->state;
+                                       cpi->state = new XMLNode (**citer);
+                                       cpi->state->set_property (X_("session-state"), session_specific_state ? true : false);
                                        if (_session) {
                                                instantiate (*cpi);
                                        } else {
                                                cpi->requested = true;
                                        }
                                } else {
+                                       if (!cpi->state) {
+                                               cpi->state = new XMLNode (**citer);
+                                               cpi->state->set_property (X_("active"), false);
+                                               cpi->state->set_property (X_("session-state"), session_specific_state ? true : false);
+                                       }
+                                       cpi->requested = false;
                                        if (_session) {
                                                teardown (*cpi, false);
-                                       } else {
-                                               cpi->requested = false;
                                        }
                                }
                        } else {
@@ -487,13 +513,15 @@ XMLNode&
 ControlProtocolManager::get_state ()
 {
        XMLNode* root = new XMLNode (state_node_name);
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
 
        for (list<ControlProtocolInfo*>::iterator i = control_protocol_info.begin(); i != control_protocol_info.end(); ++i) {
 
                if ((*i)->protocol) {
                        XMLNode& child_state ((*i)->protocol->get_state());
                        child_state.set_property (X_("active"), true);
+                       delete ((*i)->state);
+                       (*i)->state = new XMLNode (child_state);
                        root->add_child_nocopy (child_state);
                } else if ((*i)->state) {
                        XMLNode* child_state = new XMLNode (*(*i)->state);
@@ -525,7 +553,7 @@ ControlProtocolManager::instance ()
 void
 ControlProtocolManager::midi_connectivity_established ()
 {
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
 
        for (list<ControlProtocol*>::iterator p = control_protocols.begin(); p != control_protocols.end(); ++p) {
                (*p)->midi_connectivity_established ();
@@ -535,7 +563,7 @@ ControlProtocolManager::midi_connectivity_established ()
 void
 ControlProtocolManager::register_request_buffer_factories ()
 {
-       Glib::Threads::Mutex::Lock lm (protocols_lock);
+       Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
 
        for (list<ControlProtocolInfo*>::iterator i = control_protocol_info.begin(); i != control_protocol_info.end(); ++i) {
 
@@ -549,3 +577,26 @@ ControlProtocolManager::register_request_buffer_factories ()
                }
        }
 }
+
+void
+ControlProtocolManager::stripable_selection_changed (StripableNotificationListPtr sp)
+{
+       /* this sets up the (static) data structures owned by ControlProtocol
+          that are "shared" across all control protocols.
+       */
+
+       DEBUG_TRACE (DEBUG::Selection, string_compose ("Surface manager: selection changed, now %1 stripables\n", sp ? sp->size() : -1));
+       StripableSelectionChanged (sp); /* EMIT SIGNAL */
+
+       /* now give each protocol the chance to respond to the selection change
+        */
+
+       {
+               Glib::Threads::RWLock::ReaderLock lm (protocols_lock);
+
+               for (list<ControlProtocol*>::iterator p = control_protocols.begin(); p != control_protocols.end(); ++p) {
+                       DEBUG_TRACE (DEBUG::Selection, string_compose ("selection change notification for surface \"%1\"\n", (*p)->name()));
+                       (*p)->stripable_selection_changed ();
+               }
+       }
+}