enough with umpteen "i18n.h" files. Consolidate on pbd/i18n.h
[ardour.git] / libs / ardour / port_manager.cc
index 4e467e3008a1d092daf4fe1b26ca04baf5b4b57b..ec8e3024eafd668fc9027ead4b44c6f0eba4e795 100644 (file)
 
 */
 
+#include "pbd/convert.h"
 #include "pbd/error.h"
 
 #include "ardour/async_midi_port.h"
-#include "ardour/debug.h"
-#include "ardour/port_manager.h"
+#include "ardour/audio_backend.h"
 #include "ardour/audio_port.h"
+#include "ardour/debug.h"
 #include "ardour/midi_port.h"
 #include "ardour/midiport_manager.h"
+#include "ardour/port_manager.h"
+#include "ardour/profile.h"
+#include "ardour/session.h"
 
-#include "i18n.h"
+#include "pbd/i18n.h"
 
 using namespace ARDOUR;
 using namespace PBD;
@@ -68,24 +72,18 @@ PortManager::remove_all_ports ()
 string
 PortManager::make_port_name_relative (const string& portname) const
 {
-       if (!_impl) {
+       if (!_backend) {
                return portname;
        }
 
-       string::size_type len;
-       string::size_type n;
-       string self = _impl->my_name();
-
-       len = portname.length();
+       string::size_type colon = portname.find (':');
 
-       for (n = 0; n < len; ++n) {
-               if (portname[n] == ':') {
-                       break;
-               }
+       if (colon == string::npos) {
+               return portname;
        }
 
-       if ((n != len) && (portname.substr (0, n) == self)) {
-               return portname.substr (n+1);
+       if (portname.substr (0, colon) == _backend->my_name()) {
+               return portname.substr (colon+1);
        }
 
        return portname;
@@ -100,21 +98,38 @@ PortManager::make_port_name_non_relative (const string& portname) const
                return portname;
        }
 
-       str  = _impl->my_name();
+       str  = _backend->my_name();
        str += ':';
        str += portname;
 
        return str;
 }
 
+std::string
+PortManager::get_pretty_name_by_name(const std::string& portname) const
+{
+       PortEngine::PortHandle ph = _backend->get_port_by_name (portname);
+       if (ph) {
+               std::string value;
+               std::string type;
+               if (0 == _backend->get_port_property (ph,
+                                       "http://jackaudio.org/metadata/pretty-name",
+                                       value, type))
+               {
+                       return value;
+               }
+       }
+       return "";
+}
+
 bool
 PortManager::port_is_mine (const string& portname) const
 {
-       if (!_impl) {
+       if (!_backend) {
                return true;
        }
 
-       string self = _impl->my_name();
+       string self = _backend->my_name();
 
        if (portname.find_first_of (':') != string::npos) {
                if (portname.substr (0, self.length ()) != self) {
@@ -128,54 +143,56 @@ PortManager::port_is_mine (const string& portname) const
 bool
 PortManager::port_is_physical (const std::string& portname) const
 {
-       if (!_impl) {
+       if (!_backend) {
                return false;
        }
 
-       PortEngine::PortHandle ph = _impl->get_port_by_name (portname);
+       PortEngine::PortHandle ph = _backend->get_port_by_name (portname);
        if (!ph) {
                return false;
        }
 
-       return _impl->port_is_physical (ph);
+       return _backend->port_is_physical (ph);
 }
 
 void
 PortManager::get_physical_outputs (DataType type, std::vector<std::string>& s)
 {
-       if (!_impl) {
+       if (!_backend) {
+               s.clear ();
                return;
        }
-       _impl->get_physical_outputs (type, s);
+       _backend->get_physical_outputs (type, s);
 }
+
 void
 PortManager::get_physical_inputs (DataType type, std::vector<std::string>& s)
 {
-       if (!_impl) {
+       if (!_backend) {
+               s.clear ();
                return;
        }
 
-       _impl->get_physical_inputs (type, s);
+       _backend->get_physical_inputs (type, s);
 }
+
 ChanCount
 PortManager::n_physical_outputs () const
 {
-       if (!_impl) {
+       if (!_backend) {
                return ChanCount::ZERO;
        }
 
-       return _impl->n_physical_outputs ();
+       return _backend->n_physical_outputs ();
 }
+
 ChanCount
 PortManager::n_physical_inputs () const
 {
-       if (!_impl) {
+       if (!_backend) {
                return ChanCount::ZERO;
        }
-       return _impl->n_physical_inputs ();
+       return _backend->n_physical_inputs ();
 }
 
 /** @param name Full or short name of port
@@ -185,7 +202,7 @@ PortManager::n_physical_inputs () const
 boost::shared_ptr<Port>
 PortManager::get_port_by_name (const string& portname)
 {
-       if (!_impl) {
+       if (!_backend) {
                return boost::shared_ptr<Port>();
        }
 
@@ -204,7 +221,7 @@ PortManager::get_port_by_name (const string& portname)
                   and cheap), and if so, rename the port (which will alter
                   the port map as a side effect).
                */
-               const std::string check = make_port_name_relative (_impl->get_port_name (x->second->port_handle()));
+               const std::string check = make_port_name_relative (_backend->get_port_name (x->second->port_handle()));
                if (check != rel) {
                        x->second->set_name (check);
                }
@@ -220,7 +237,7 @@ PortManager::port_renamed (const std::string& old_relative_name, const std::stri
        RCUWriter<Ports> writer (ports);
        boost::shared_ptr<Ports> p = writer.get_copy();
        Ports::iterator x = p->find (old_relative_name);
-       
+
        if (x != p->end()) {
                boost::shared_ptr<Port> port = x->second;
                p->erase (x);
@@ -243,26 +260,28 @@ PortManager::get_ports (DataType type, PortList& pl)
 int
 PortManager::get_ports (const string& port_name_pattern, DataType type, PortFlags flags, vector<string>& s)
 {
-       if (!_impl) {
+       s.clear();
+
+       if (!_backend) {
                return 0;
        }
 
-       return _impl->get_ports (port_name_pattern, type, flags, s);
+       return _backend->get_ports (port_name_pattern, type, flags, s);
 }
 
 void
 PortManager::port_registration_failure (const std::string& portname)
 {
-       if (!_impl) {
+       if (!_backend) {
                return;
        }
 
-       string full_portname = _impl->my_name();
+       string full_portname = _backend->my_name();
        full_portname += ':';
        full_portname += portname;
 
 
-       PortEngine::PortHandle p = _impl->get_port_by_name (full_portname);
+       PortEngine::PortHandle p = _backend->get_port_by_name (full_portname);
        string reason;
 
        if (p) {
@@ -356,17 +375,51 @@ PortManager::unregister_port (boost::shared_ptr<Port> port)
 bool
 PortManager::connected (const string& port_name)
 {
-       if (!_impl) {
+       if (!_backend) {
+               return false;
+       }
+
+       PortEngine::PortHandle handle = _backend->get_port_by_name (port_name);
+
+       if (!handle) {
+               return false;
+       }
+
+       return _backend->connected (handle);
+}
+
+bool
+PortManager::physically_connected (const string& port_name)
+{
+       if (!_backend) {
                return false;
        }
 
-       PortEngine::PortHandle handle = _impl->get_port_by_name (port_name);
+       PortEngine::PortHandle handle = _backend->get_port_by_name (port_name);
 
        if (!handle) {
                return false;
        }
 
-       return _impl->connected (handle);
+       return _backend->physically_connected (handle);
+}
+
+int
+PortManager::get_connections (const string& port_name, std::vector<std::string>& s)
+{
+       if (!_backend) {
+               s.clear ();
+               return 0;
+       }
+
+       PortEngine::PortHandle handle = _backend->get_port_by_name (port_name);
+
+       if (!handle) {
+               s.clear ();
+               return 0;
+       }
+
+       return _backend->get_connections (handle, s);
 }
 
 int
@@ -385,8 +438,13 @@ PortManager::connect (const string& source, const string& destination)
        } else if (dst) {
                ret = dst->connect (s);
        } else {
-               /* neither port is known to us, and this API isn't intended for use as a general patch bay */
-               ret = -1;
+               /* neither port is known to us ...hand-off to the PortEngine
+                */
+               if (_backend) {
+                       ret = _backend->connect (s, d);
+               } else {
+                       ret = -1;
+               }
        }
 
        if (ret > 0) {
@@ -412,12 +470,17 @@ PortManager::disconnect (const string& source, const string& destination)
        boost::shared_ptr<Port> dst = get_port_by_name (d);
 
        if (src) {
-                       ret = src->disconnect (d);
+               ret = src->disconnect (d);
        } else if (dst) {
-                       ret = dst->disconnect (s);
+               ret = dst->disconnect (s);
        } else {
-               /* neither port is known to us, and this API isn't intended for use as a general patch bay */
-               ret = -1;
+               /* neither port is known to us ...hand-off to the PortEngine
+                */
+               if (_backend) {
+                       ret = _backend->disconnect (s, d);
+               } else {
+                       ret = -1;
+               }
        }
        return ret;
 }
@@ -440,7 +503,7 @@ PortManager::reestablish_ports ()
        for (i = p->begin(); i != p->end(); ++i) {
                if (i->second->reestablish ()) {
                        error << string_compose (_("Re-establising port %1 failed"), i->second->name()) << endmsg;
-                       cerr << string_compose (_("Re-establising port %1 failed"), i->second->name()) << endl;
+                       std::cerr << string_compose (_("Re-establising port %1 failed"), i->second->name()) << std::endl;
                        break;
                }
        }
@@ -459,12 +522,14 @@ PortManager::reconnect_ports ()
 {
        boost::shared_ptr<Ports> p = ports.reader ();
 
-       /* re-establish connections */
+       if (!Profile->get_trx()) {
+               /* re-establish connections */
 
-       DEBUG_TRACE (DEBUG::Ports, string_compose ("reconnect %1 ports\n", p->size()));
+               DEBUG_TRACE (DEBUG::Ports, string_compose ("reconnect %1 ports\n", p->size()));
 
-       for (Ports::iterator i = p->begin(); i != p->end(); ++i) {
-               i->second->reconnect ();
+               for (Ports::iterator i = p->begin(); i != p->end(); ++i) {
+                       i->second->reconnect ();
+               }
        }
 
        return 0;
@@ -493,7 +558,7 @@ PortManager::connect_callback (const string& a, const string& b, bool conn)
                port_b, b,
                conn
                ); /* EMIT SIGNAL */
-}      
+}
 
 void
 PortManager::registration_callback ()
@@ -506,59 +571,59 @@ PortManager::registration_callback ()
 bool
 PortManager::can_request_input_monitoring () const
 {
-       if (!_impl) {
+       if (!_backend) {
                return false;
        }
 
-       return _impl->can_monitor_input ();
+       return _backend->can_monitor_input ();
 }
+
 void
 PortManager::request_input_monitoring (const string& name, bool yn) const
 {
-       if (!_impl) {
+       if (!_backend) {
                return;
        }
 
-       PortEngine::PortHandle ph = _impl->get_port_by_name (name);
+       PortEngine::PortHandle ph = _backend->get_port_by_name (name);
 
        if (ph) {
-               _impl->request_input_monitoring (ph, yn);
+               _backend->request_input_monitoring (ph, yn);
        }
 }
+
 void
 PortManager::ensure_input_monitoring (const string& name, bool yn) const
 {
-       if (!_impl) {
+       if (!_backend) {
                return;
        }
 
-       PortEngine::PortHandle ph = _impl->get_port_by_name (name);
+       PortEngine::PortHandle ph = _backend->get_port_by_name (name);
 
        if (ph) {
-               _impl->ensure_input_monitoring (ph, yn);
+               _backend->ensure_input_monitoring (ph, yn);
        }
 }
 
 uint32_t
 PortManager::port_name_size() const
 {
-       if (!_impl) {
+       if (!_backend) {
                return 0;
        }
-       
-       return _impl->port_name_size ();
+
+       return _backend->port_name_size ();
 }
 
 string
 PortManager::my_name() const
 {
-       if (!_impl) {
+       if (!_backend) {
                return string();
        }
-       
-       return _impl->my_name();
+
+       return _backend->my_name();
 }
 
 int
@@ -601,22 +666,70 @@ PortManager::cycle_end (pframes_t nframes)
 }
 
 void
-PortManager::silence (pframes_t nframes)
+PortManager::silence (pframes_t nframes, Session *s)
 {
        for (Ports::iterator i = _cycle_ports->begin(); i != _cycle_ports->end(); ++i) {
+               if (s && i->second == s->mtc_output_port ()) {
+                       continue;
+               }
+               if (s && i->second == s->midi_clock_output_port ()) {
+                       continue;
+               }
+               if (s && i->second == s->ltc_output_port ()) {
+                       continue;
+               }
                if (i->second->sends_output()) {
                        i->second->get_buffer(nframes).silence(nframes);
                }
        }
 }
 
+void
+PortManager::silence_outputs (pframes_t nframes)
+{
+       std::vector<std::string> port_names;
+       if (get_ports("", DataType::AUDIO, IsOutput, port_names)) {
+               for (std::vector<std::string>::iterator p = port_names.begin(); p != port_names.end(); ++p) {
+                       if (!port_is_mine(*p)) {
+                               continue;
+                       }
+                       PortEngine::PortHandle ph = _backend->get_port_by_name (*p);
+                       if (!ph) {
+                               continue;
+                       }
+                       void *buf = _backend->get_buffer(ph, nframes);
+                       if (!buf) {
+                               continue;
+                       }
+                       memset (buf, 0, sizeof(float) * nframes);
+               }
+       }
+
+       if (get_ports("", DataType::MIDI, IsOutput, port_names)) {
+               for (std::vector<std::string>::iterator p = port_names.begin(); p != port_names.end(); ++p) {
+                       if (!port_is_mine(*p)) {
+                               continue;
+                       }
+                       PortEngine::PortHandle ph = _backend->get_port_by_name (*p);
+                       if (!ph) {
+                               continue;
+                       }
+                       void *buf = _backend->get_buffer(ph, nframes);
+                       if (!buf) {
+                               continue;
+                       }
+                       _backend->midi_clear (buf);
+               }
+       }
+}
+
 void
 PortManager::check_monitoring ()
 {
        for (Ports::iterator i = _cycle_ports->begin(); i != _cycle_ports->end(); ++i) {
-               
+
                bool x;
-               
+
                if (i->second->last_monitor() != (x = i->second->monitoring_input ())) {
                        i->second->set_last_monitor (x);
                        /* XXX I think this is dangerous, due to
@@ -631,14 +744,14 @@ void
 PortManager::fade_out (gain_t base_gain, gain_t gain_step, pframes_t nframes)
 {
        for (Ports::iterator i = _cycle_ports->begin(); i != _cycle_ports->end(); ++i) {
-               
+
                if (i->second->sends_output()) {
-                       
+
                        boost::shared_ptr<AudioPort> ap = boost::dynamic_pointer_cast<AudioPort> (i->second);
                        if (ap) {
                                Sample* s = ap->engine_get_whole_audio_buffer ();
                                gain_t g = base_gain;
-                               
+
                                for (pframes_t n = 0; n < nframes; ++n) {
                                        *s++ *= g;
                                        g -= gain_step;
@@ -647,3 +760,10 @@ PortManager::fade_out (gain_t base_gain, gain_t gain_step, pframes_t nframes)
                }
        }
 }
+
+PortEngine&
+PortManager::port_engine()
+{
+       assert (_backend);
+       return *_backend;
+}