major redesign of MIDI port heirarchy and management (part 2)
[ardour.git] / libs / surfaces / generic_midi / generic_midi_control_protocol.cc
index d6a75f66f900fad49bb76795d092ed2090379d81..2820b069dc7af246917dd417ce851e3478e262c1 100644 (file)
@@ -24,7 +24,6 @@
 
 #include <glibmm/fileutils.h>
 #include <glibmm/miscutils.h>
-#include <glibmm/thread.h>
 
 #include "pbd/controllable_descriptor.h"
 #include "pbd/error.h"
 #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"
@@ -60,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 = AudioEngine::instance()->midi_input_port ();
+       _output_port = AudioEngine::instance()->midi_output_port ();
 
        do_feedback = false;
        _feedback_interval = 10000; // microseconds
@@ -107,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;
@@ -119,14 +119,7 @@ system_midi_map_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
@@ -186,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;
@@ -213,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()) {
@@ -286,7 +279,7 @@ GenericMidiControlProtocol::_send_feedback ()
           first on to ALSA.
        */
 
-       Glib::Mutex::Lock lm (controllables_lock, Glib::TRY_LOCK);
+       Glib::Threads::Mutex::Lock lm (controllables_lock, Glib::Threads::TRY_LOCK);
        if (!lm.locked ()) {
                return;
        }
@@ -306,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(); ) {
@@ -320,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(); ) {
@@ -346,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;
@@ -366,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;
 
@@ -390,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
@@ -417,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);
@@ -437,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
@@ -480,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);
@@ -489,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
@@ -497,7 +492,7 @@ GenericMidiControlProtocol::get_state ()
                   file.
                */
 
-               if ((*i)->learned()) {
+               if ((*i)->get_controllable() && (*i)->learned()) {
                        children->add_child_nocopy ((*i)->get_state());
                }
        }
@@ -526,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) {
@@ -666,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);
                                }
 
@@ -749,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;
@@ -764,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);
@@ -887,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;
@@ -983,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;