Merge branch 'master' into windows
[ardour.git] / libs / surfaces / generic_midi / generic_midi_control_protocol.cc
index 6b8e321112db4c422fb76fa49bea1cacc72746b7..e0b06a936984ead8f1c10da783f41bb77839ff32 100644 (file)
 #include "pbd/xml++.h"
 
 #include "midi++/port.h"
-#include "midi++/manager.h"
 
+#include "ardour/audioengine.h"
 #include "ardour/filesystem_paths.h"
 #include "ardour/session.h"
 #include "ardour/route.h"
 #include "ardour/midi_ui.h"
 #include "ardour/rc_configuration.h"
+#include "ardour/midiport_manager.h"
 
 #include "generic_midi_control_protocol.h"
 #include "midicontrollable.h"
@@ -59,8 +60,8 @@ GenericMidiControlProtocol::GenericMidiControlProtocol (Session& s)
        , _threshold (10)
        , gui (0)
 {
-       _input_port = MIDI::Manager::instance()->midi_input_port ();
-       _output_port = MIDI::Manager::instance()->midi_output_port ();
+       _input_port = s.midi_input_port ();
+       _output_port = s.midi_output_port ();
 
        do_feedback = false;
        _feedback_interval = 10000; // microseconds
@@ -106,7 +107,7 @@ static const char * const midimap_env_variable_name = "ARDOUR_MIDIMAPS_PATH";
 static const char* const midi_map_dir_name = "midi_maps";
 static const char* const midi_map_suffix = ".map";
 
-static std::string
+Searchpath
 system_midi_map_search_path ()
 {
        bool midimap_path_defined = false;
@@ -116,16 +117,9 @@ system_midi_map_search_path ()
                return spath_env;
        }
 
-       SearchPath spath (ardour_data_search_path());
+       Searchpath spath (ardour_data_search_path());
        spath.add_subdirectory_to_paths(midi_map_dir_name);
-
-       // just return the first directory in the search path that exists
-       for (SearchPath::const_iterator i = spath.begin(); i != spath.end(); ++i) {
-               if (Glib::file_test (*i, Glib::FILE_TEST_EXISTS)) {
-                       return *i;
-               }
-       }
-       return std::string();
+       return spath;
 }
 
 static std::string
@@ -135,7 +129,7 @@ user_midi_map_directory ()
 }
 
 static bool
-midi_map_filter (const string &str, void */*arg*/)
+midi_map_filter (const string &str, void/*arg*/)
 {
        return (str.length() > strlen(midi_map_suffix) &&
                str.find (midi_map_suffix) == (str.length() - strlen (midi_map_suffix)));
@@ -146,7 +140,7 @@ GenericMidiControlProtocol::reload_maps ()
 {
        vector<string *> *midi_maps;
        PathScanner scanner;
-       SearchPath spath (system_midi_map_search_path());
+       Searchpath spath (system_midi_map_search_path());
        spath += user_midi_map_directory ();
 
        midi_maps = scanner (spath.to_string(), midi_map_filter, 0, false, true);
@@ -185,8 +179,8 @@ GenericMidiControlProtocol::reload_maps ()
 void
 GenericMidiControlProtocol::drop_all ()
 {
-       Glib::Mutex::Lock lm (pending_lock);
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm (pending_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
 
        for (MIDIControllables::iterator i = controllables.begin(); i != controllables.end(); ++i) {
                delete *i;
@@ -212,7 +206,7 @@ GenericMidiControlProtocol::drop_all ()
 void
 GenericMidiControlProtocol::drop_bindings ()
 {
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
 
        for (MIDIControllables::iterator i = controllables.begin(); i != controllables.end(); ) {
                if (!(*i)->learned()) {
@@ -284,6 +278,12 @@ GenericMidiControlProtocol::_send_feedback ()
           in a single jack_midi_event_write then some bridges will only pass the
           first on to ALSA.
        */
+
+       Glib::Threads::Mutex::Lock lm (controllables_lock, Glib::Threads::TRY_LOCK);
+       if (!lm.locked ()) {
+               return;
+       }
+       
        for (MIDIControllables::iterator r = controllables.begin(); r != controllables.end(); ++r) {
                MIDI::byte* end = (*r)->write_feedback (buf, bsize);
                if (end != buf) {
@@ -299,7 +299,7 @@ GenericMidiControlProtocol::start_learning (Controllable* c)
                return false;
        }
 
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
 
        MIDIControllables::iterator tmp;
        for (MIDIControllables::iterator i = controllables.begin(); i != controllables.end(); ) {
@@ -313,7 +313,7 @@ GenericMidiControlProtocol::start_learning (Controllable* c)
        }
 
        {
-               Glib::Mutex::Lock lm (pending_lock);
+               Glib::Threads::Mutex::Lock lm (pending_lock);
                
                MIDIPendingControllables::iterator ptmp;
                for (MIDIPendingControllables::iterator i = pending_controllables.begin(); i != pending_controllables.end(); ) {
@@ -339,11 +339,11 @@ GenericMidiControlProtocol::start_learning (Controllable* c)
        }
 
        if (!mc) {
-               mc = new MIDIControllable (this, *_input_port, *c, false);
+               mc = new MIDIControllable (this, *_input_port->parser(), *c, false);
        }
        
        {
-               Glib::Mutex::Lock lm (pending_lock);
+               Glib::Threads::Mutex::Lock lm (pending_lock);
 
                MIDIPendingControllable* element = new MIDIPendingControllable;
                element->first = mc;
@@ -359,8 +359,8 @@ GenericMidiControlProtocol::start_learning (Controllable* c)
 void
 GenericMidiControlProtocol::learning_stopped (MIDIControllable* mc)
 {
-       Glib::Mutex::Lock lm (pending_lock);
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm (pending_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
        
        MIDIPendingControllables::iterator tmp;
 
@@ -383,8 +383,8 @@ GenericMidiControlProtocol::learning_stopped (MIDIControllable* mc)
 void
 GenericMidiControlProtocol::stop_learning (Controllable* c)
 {
-       Glib::Mutex::Lock lm (pending_lock);
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm (pending_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
        MIDIControllable* dptr = 0;
 
        /* learning timed out, and we've been told to consider this attempt to learn to be cancelled. find the
@@ -410,7 +410,7 @@ void
 GenericMidiControlProtocol::delete_binding (PBD::Controllable* control)
 {
        if (control != 0) {
-               Glib::Mutex::Lock lm2 (controllables_lock);
+               Glib::Threads::Mutex::Lock lm2 (controllables_lock);
                
                for (MIDIControllables::iterator iter = controllables.begin(); iter != controllables.end();) {
                        MIDIControllable* existingBinding = (*iter);
@@ -430,13 +430,13 @@ void
 GenericMidiControlProtocol::create_binding (PBD::Controllable* control, int pos, int control_number)
 {
        if (control != NULL) {
-               Glib::Mutex::Lock lm2 (controllables_lock);
+               Glib::Threads::Mutex::Lock lm2 (controllables_lock);
                
                MIDI::channel_t channel = (pos & 0xf);
                MIDI::byte value = control_number;
                
                // Create a MIDIControllable
-               MIDIControllable* mc = new MIDIControllable (this, *_input_port, *control, false);
+               MIDIControllable* mc = new MIDIControllable (this, *_input_port->parser(), *control, false);
 
                // Remove any old binding for this midi channel/type/value pair
                // Note:  can't use delete_binding() here because we don't know the specific controllable we want to remove, only the midi information
@@ -473,6 +473,8 @@ GenericMidiControlProtocol::get_state ()
        node->add_property (X_("feedback"), do_feedback ? "1" : "0");
        snprintf (buf, sizeof (buf), "%" PRIu64, _feedback_interval);
        node->add_property (X_("feedback_interval"), buf);
+       snprintf (buf, sizeof (buf), "%d", _threshold);
+       node->add_property (X_("threshold"), buf);
 
        if (!_current_binding.empty()) {
                node->add_property ("binding", _current_binding);
@@ -482,7 +484,7 @@ GenericMidiControlProtocol::get_state ()
 
        node->add_child_nocopy (*children);
 
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
        for (MIDIControllables::iterator i = controllables.begin(); i != controllables.end(); ++i) {
 
                /* we don't care about bindings that come from a bindings map, because
@@ -490,7 +492,7 @@ GenericMidiControlProtocol::get_state ()
                   file.
                */
 
-               if ((*i)->learned()) {
+               if ((*i)->get_controllable() && (*i)->learned()) {
                        children->add_child_nocopy ((*i)->get_state());
                }
        }
@@ -519,49 +521,60 @@ GenericMidiControlProtocol::set_state (const XMLNode& node, int version)
                _feedback_interval = 10000;
        }
 
+       if ((prop = node.property ("threshold")) != 0) {
+               if (sscanf (prop->value().c_str(), "%d", &_threshold) != 1) {
+                       _threshold = 10;
+               }
+       } else {
+               _threshold = 10;
+       }
+
        boost::shared_ptr<Controllable> c;
        
        {
-               Glib::Mutex::Lock lm (pending_lock);
+               Glib::Threads::Mutex::Lock lm (pending_lock);
                for (MIDIPendingControllables::iterator i = pending_controllables.begin(); i != pending_controllables.end(); ++i) {
                        delete *i;
                }
                pending_controllables.clear ();
        }
 
+       /* Load up specific bindings from the
+        * <Controls><MidiControllable>...</MidiControllable><Controls> section
+        */
+
        {
-               Glib::Mutex::Lock lm2 (controllables_lock);
+               Glib::Threads::Mutex::Lock lm2 (controllables_lock);
                controllables.clear ();
                nlist = node.children(); // "Controls"
-               
-               if (nlist.empty()) {
-                       return 0;
-               }
-               
-               nlist = nlist.front()->children ();
-               
-               for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
-                       
-                       if ((prop = (*niter)->property ("id")) != 0) {
 
-                               ID id = prop->value ();
-                               Controllable* c = Controllable::by_id (id);
+               if (!nlist.empty()) {
+                       nlist = nlist.front()->children(); // "MIDIControllable" ...
 
-                               if (c) {
-                                       MIDIControllable* mc = new MIDIControllable (this, *_input_port, *c, false);
-                                        
-                                       if (mc->set_state (**niter, version) == 0) {
-                                               controllables.push_back (mc);
-                                       }
+                       if (!nlist.empty()) {
+                               for (niter = nlist.begin(); niter != nlist.end(); ++niter) {
                                        
-                               } else {
-                                       warning << string_compose (
-                                               _("Generic MIDI control: controllable %1 not found in session (ignored)"),
-                                               id) << endmsg;
+                                       if ((prop = (*niter)->property ("id")) != 0) {
+                                               
+                                               ID id = prop->value ();
+                                               Controllable* c = Controllable::by_id (id);
+                                               
+                                               if (c) {
+                                                       MIDIControllable* mc = new MIDIControllable (this, *_input_port->parser(), *c, false);
+                                                       
+                                                       if (mc->set_state (**niter, version) == 0) {
+                                                               controllables.push_back (mc);
+                                                       }
+                                                       
+                                               } else {
+                                                       warning << string_compose (
+                                                               _("Generic MIDI control: controllable %1 not found in session (ignored)"),
+                                                               id) << endmsg;
+                                               }
+                                       }
                                }
                        }
                }
-
        }
 
        if ((prop = node.property ("binding")) != 0) {
@@ -638,7 +651,7 @@ GenericMidiControlProtocol::load_bindings (const string& xmlpath)
                                _current_bank = 0;
                        }
 
-                       if ((prop = (*citer)->property ("motorised")) != 0) {
+                       if ((prop = (*citer)->property ("motorised")) != 0 || ((prop = (*citer)->property ("motorized")) != 0)) {
                                _motorised = string_is_affirmative (prop->value ());
                        } else {
                                _motorised = false;
@@ -659,7 +672,7 @@ GenericMidiControlProtocol::load_bindings (const string& xmlpath)
                                /* controllable */
                                
                                if ((mc = create_binding (*child)) != 0) {
-                                       Glib::Mutex::Lock lm2 (controllables_lock);
+                                       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
                                        controllables.push_back (mc);
                                }
 
@@ -742,7 +755,7 @@ GenericMidiControlProtocol::create_binding (const XMLNode& node)
        prop = node.property (X_("uri"));
        uri = prop->value();
 
-       MIDIControllable* mc = new MIDIControllable (this, *_input_port, momentary);
+       MIDIControllable* mc = new MIDIControllable (this, *_input_port->parser(), momentary);
 
        if (mc->init (uri)) {
                delete mc;
@@ -757,7 +770,7 @@ GenericMidiControlProtocol::create_binding (const XMLNode& node)
 void
 GenericMidiControlProtocol::reset_controllables ()
 {
-       Glib::Mutex::Lock lm2 (controllables_lock);
+       Glib::Threads::Mutex::Lock lm2 (controllables_lock);
 
        for (MIDIControllables::iterator iter = controllables.begin(); iter != controllables.end(); ) {
                MIDIControllable* existingBinding = (*iter);
@@ -778,10 +791,7 @@ GenericMidiControlProtocol::reset_controllables ()
                         * binding" (or "lazy binding") if/when any data arrives.
                         */
 
-                       boost::shared_ptr<Controllable> c = session->controllable_by_descriptor (desc);
-                       if (c) {
-                               existingBinding->set_controllable (c.get());
-                       } 
+                       existingBinding->lookup_controllable ();
                }
 
                iter = next;
@@ -883,7 +893,7 @@ GenericMidiControlProtocol::create_function (const XMLNode& node)
 
        prop = node.property (X_("function"));
        
-       MIDIFunction* mf = new MIDIFunction (*_input_port);
+       MIDIFunction* mf = new MIDIFunction (*_input_port->parser());
        
        if (mf->setup (*this, prop->value(), argument, data, data_size)) {
                delete mf;
@@ -979,7 +989,7 @@ GenericMidiControlProtocol::create_action (const XMLNode& node)
 
        prop = node.property (X_("action"));
        
-       MIDIAction* ma = new MIDIAction (*_input_port);
+       MIDIAction* ma = new MIDIAction (*_input_port->parser());
         
        if (ma->init (*this, prop->value(), data, data_size)) {
                delete ma;