/*
- Copyright (C) 2013 Paul Davis
-
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2 of the License, or
- (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ * Copyright (C) 2013-2019 Paul Davis <paul@linuxaudiosystems.com>
+ * Copyright (C) 2015-2019 Robin Gareus <robin@gareus.org>
+ * Copyright (C) 2017-2018 Ben Loftis <ben@harrisonconsoles.com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
-*/
+#include <vector>
#ifdef COMPILER_MSVC
#include <io.h> // Microsoft's nearest equivalent to <unistd.h>
#include <glibmm/miscutils.h>
#include "pbd/error.h"
+#include "pbd/strsplit.h"
#include "ardour/async_midi_port.h"
#include "ardour/audio_backend.h"
#include "ardour/midiport_manager.h"
#include "ardour/port_manager.h"
#include "ardour/profile.h"
+#include "ardour/rt_tasklist.h"
#include "ardour/session.h"
#include "ardour/types_convert.h"
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))
- {
+ if (0 == _backend->get_port_property (ph, "http://jackaudio.org/metadata/pretty-name", value, type)) {
return value;
}
}
- return "";
+
+ return string();
}
bool
if (portname.find_first_of (':') != string::npos) {
if (portname.substr (0, self.length ()) != self) {
- return false;
- }
- }
+ return false;
+ }
+ }
- return true;
+ return true;
}
bool
void
PortManager::filter_midi_ports (vector<string>& ports, MidiPortFlags include, MidiPortFlags exclude)
{
+
if (!include && !exclude) {
return;
}
- for (vector<string>::iterator si = ports.begin(); si != ports.end(); ) {
+ {
+ Glib::Threads::Mutex::Lock lm (midi_port_info_mutex);
- PortManager::MidiPortInformation mpi = midi_port_information (*si);
+ fill_midi_port_info_locked ();
- if (mpi.pretty_name.empty()) {
- /* no information !!! */
- ++si;
- continue;
- }
+ for (vector<string>::iterator si = ports.begin(); si != ports.end(); ) {
- if (include) {
- if ((mpi.properties & include) != include) {
- /* properties do not include requested ones */
- si = ports.erase (si);
+ MidiPortInfo::iterator x = midi_port_info.find (*si);
+
+ if (x == midi_port_info.end()) {
+ ++si;
continue;
}
- }
- if (exclude) {
- if ((mpi.properties & exclude)) {
- /* properties include ones to avoid */
- si = ports.erase (si);
+ MidiPortInformation& mpi (x->second);
+
+ if (mpi.pretty_name.empty()) {
+ /* no information !!! */
+ ++si;
continue;
}
- }
- ++si;
+ if (include) {
+ if ((mpi.properties & include) != include) {
+ /* properties do not include requested ones */
+ si = ports.erase (si);
+ continue;
+ }
+ }
+
+ if (exclude) {
+ if ((mpi.properties & exclude)) {
+ /* properties include ones to avoid */
+ si = ports.erase (si);
+ continue;
+ }
+ }
+
+ ++si;
+ }
}
}
/** @param name Full or short name of port
* @return Corresponding Port or 0.
*/
-
boost::shared_ptr<Port>
PortManager::get_port_by_name (const string& portname)
{
return boost::shared_ptr<Port>();
}
- if (!port_is_mine (portname)) {
- /* not an ardour port */
-
return boost::shared_ptr<Port> ();
- }
+ if (!port_is_mine (portname)) {
+ /* not an ardour port */
+ return boost::shared_ptr<Port> ();
+ }
boost::shared_ptr<Ports> pr = ports.reader();
std::string rel = make_port_name_relative (portname);
if (x != pr->end()) {
/* its possible that the port was renamed by some 3rd party and
- we don't know about it. check for this (the check is quick
- and cheap), and if so, rename the port (which will alter
- the port map as a side effect).
- */
+ * we don't know about it. check for this (the check is quick
+ * 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 (_backend->get_port_name (x->second->port_handle()));
if (check != rel) {
x->second->set_name (check);
return x->second;
}
-
return boost::shared_ptr<Port> ();
+ return boost::shared_ptr<Port> ();
}
void
/* limit the possible flags that can be set */
- flags = PortFlags (flags & (Hidden|Shadow|IsTerminal));
+ flags = PortFlags (flags & (Hidden|Shadow|IsTerminal|TransportMasterPort));
try {
if (dtype == DataType::AUDIO) {
PortDeleter());
}
} else {
- throw PortRegistrationFailure("unable to create port (unknown type)");
+ throw PortRegistrationFailure (string_compose ("unable to create port '%1': %2", portname, _("(unknown type)")));
}
+ newport->set_buffer_size (AudioEngine::instance()->samples_per_cycle());
+
RCUWriter<Ports> writer (ports);
boost::shared_ptr<Ports> ps = writer.get_copy ();
ps->insert (make_pair (make_port_name_relative (portname), newport));
/* writer goes out of scope, forces update */
-
}
catch (PortRegistrationFailure& err) {
throw err;
} catch (std::exception& e) {
- throw PortRegistrationFailure(string_compose(
- _("unable to create port: %1"), e.what()).c_str());
+ throw PortRegistrationFailure (string_compose ("unable to create port '%1': %2", portname, e.what()).c_str());
} catch (...) {
- throw PortRegistrationFailure("unable to create port (unknown error)");
+ throw PortRegistrationFailure (string_compose ("unable to create port '%1': %2", portname, _("(unknown error)")));
}
DEBUG_TRACE (DEBUG::Ports, string_compose ("\t%2 port registration success, ports now = %1\n", ports.reader()->size(), this));
{
boost::shared_ptr<Ports> p = ports.reader ();
- if (!Profile->get_trx()) {
- /* re-establish connections */
+ /* 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;
void
PortManager::connect_callback (const string& a, const string& b, bool conn)
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, string_compose (X_("connect callback %1 + %2 connected ? %3\n"), a, b, conn));
+
boost::shared_ptr<Port> port_a;
boost::shared_ptr<Port> port_b;
Ports::iterator x;
port_b = x->second;
}
+ if (conn) {
+ if (port_a && !port_b) {
+ port_a->increment_external_connections ();
+ } else if (port_b && !port_a) {
+ port_b->increment_external_connections ();
+ }
+ } else {
+ if (port_a && !port_b) {
+ port_a->decrement_external_connections ();
+ } else if (port_b && !port_a) {
+ port_b->decrement_external_connections ();
+ }
+ }
+
PortConnectedOrDisconnected (
port_a, a,
port_b, b,
void
PortManager::registration_callback ()
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, "port registration callback\n");
+
if (!_port_remove_in_progress) {
{
int
PortManager::graph_order_callback ()
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, "graph order callback\n");
+
if (!_port_remove_in_progress) {
GraphReordered(); /* EMIT SIGNAL */
}
}
void
-PortManager::cycle_start (pframes_t nframes)
+PortManager::cycle_start (pframes_t nframes, Session* s)
{
Port::set_global_port_buffer_offset (0);
- Port::set_cycle_framecnt (nframes);
+ Port::set_cycle_samplecnt (nframes);
_cycle_ports = ports.reader ();
- for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->cycle_start (nframes);
+ /* TODO optimize
+ * - when speed == 1.0, the resampler copies data without processing
+ * it may (or may not) be more efficient to just run all in sequence.
+ *
+ * - single sequential task for 'lightweight' tasks would make sense
+ * (run it in parallel with 'heavy' resampling.
+ * * output ports (sends_output()) only set a flag
+ * * midi-ports only scale event timestamps
+ *
+ * - a threshold parallel vs searial processing may be appropriate.
+ * amount of work (how many connected ports are there, how
+ * many resamplers need to run) vs. available CPU cores and semaphore
+ * synchronization overhead.
+ *
+ * - input ports: it would make sense to resample each input only once
+ * (rather than resample into each ardour-owned input port).
+ * A single external source-port may be connected to many ardour
+ * input-ports. Currently re-sampling is per input.
+ */
+ if (s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
+ RTTaskList::TaskList tl;
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_start, p->second, nframes));
+ }
+ }
+ s->rt_tasklist()->process (tl);
+ } else {
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_start (nframes);
+ }
+ }
}
}
void
-PortManager::cycle_end (pframes_t nframes)
+PortManager::cycle_end (pframes_t nframes, Session* s)
{
- for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->cycle_end (nframes);
+ // see optimzation note in ::cycle_start()
+ if (0 && s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
+ RTTaskList::TaskList tl;
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ }
+ }
+ s->rt_tasklist()->process (tl);
+ } else {
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_end (nframes);
+ }
+ }
}
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
}
void
-PortManager::fade_out (gain_t base_gain, gain_t gain_step, pframes_t nframes)
+PortManager::cycle_end_fade_out (gain_t base_gain, gain_t gain_step, pframes_t nframes, Session* s)
{
- for (Ports::iterator i = _cycle_ports->begin(); i != _cycle_ports->end(); ++i) {
+ // see optimzation note in ::cycle_start()
+ if (0 && s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
+ RTTaskList::TaskList tl;
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ }
+ }
+ s->rt_tasklist()->process (tl);
+ } else {
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_end (nframes);
+ }
+ }
+ }
- if (i->second->sends_output()) {
+ for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
+ p->second->flush_buffers (nframes);
- boost::shared_ptr<AudioPort> ap = boost::dynamic_pointer_cast<AudioPort> (i->second);
+ if (p->second->sends_output()) {
+
+ boost::shared_ptr<AudioPort> ap = boost::dynamic_pointer_cast<AudioPort> (p->second);
if (ap) {
Sample* s = ap->engine_get_whole_audio_buffer ();
gain_t g = base_gain;
}
}
}
+ _cycle_ports.reset ();
+ /* we are done */
}
PortEngine&
X_(".*Ableton Push.*"),
X_(".*FaderPort .*"),
X_(".*FaderPort8 .*"),
+ X_(".*FaderPort16 .*"),
+ X_(".*FaderPort2 .*"),
+ X_(".*US-2400 .*"),
+ X_(".*Mackie .*"),
};
pattern = "(";
}
void
-PortManager::set_midi_port_pretty_name (string const & port, string const & pretty)
+PortManager::set_port_pretty_name (string const & port, string const & pretty)
{
{
Glib::Threads::Mutex::Lock lm (midi_port_info_mutex);
_backend->set_port_property (ph, "http://jackaudio.org/metadata/pretty-name", pretty, string());
}
+ save_midi_port_info ();
MidiPortInfoChanged (); /* EMIT SIGNAL*/
}
fill_midi_port_info_locked ();
MidiPortInfo::iterator x = midi_port_info.find (port);
+
if (x != midi_port_info.end()) {
if ((x->second.properties & flags) != flags) { // at least one missing
x->second.properties = MidiPortFlags (x->second.properties | flags);
fill_midi_port_info_locked ();
MidiPortInfo::iterator x = midi_port_info.find (port);
+
if (x != midi_port_info.end()) {
if (x->second.properties & flags) { // at least one is set
x->second.properties = MidiPortFlags (x->second.properties & ~flags);
for (MidiPortInfo::iterator i = midi_port_info.begin(); i != midi_port_info.end(); ++i) {
XMLNode* node = new XMLNode (X_("port"));
node->set_property (X_("name"), i->first);
+ node->set_property (X_("backend"), i->second.backend);
+ node->set_property (X_("pretty-name"), i->second.pretty_name);
node->set_property (X_("input"), i->second.input);
node->set_property (X_("properties"), i->second.properties);
root->add_child_nocopy (*node);
midi_port_info.clear ();
for (XMLNodeConstIterator i = tree.root()->children().begin(); i != tree.root()->children().end(); ++i) {
- MidiPortInformation mpi;
string name;
+ string backend;
+ string pretty;
+ bool input;
+ MidiPortFlags properties;
+
if (!(*i)->get_property (X_("name"), name) ||
- !(*i)->get_property (X_("input"), mpi.input) ||
- !(*i)->get_property (X_("properties"), mpi.properties)) {
+ !(*i)->get_property (X_("backend"), backend) ||
+ !(*i)->get_property (X_("pretty-name"), pretty) ||
+ !(*i)->get_property (X_("input"), input) ||
+ !(*i)->get_property (X_("properties"), properties)) {
+ /* should only affect version changes */
+ error << string_compose (_("MIDI port info file %1 contains invalid information - please remove it."), path) << endmsg;
continue;
}
+ MidiPortInformation mpi (backend, pretty, input, properties, false);
+
midi_port_info.insert (make_pair (name, mpi));
}
}
void
PortManager::fill_midi_port_info ()
{
- Glib::Threads::Mutex::Lock lm (midi_port_info_mutex);
- fill_midi_port_info_locked ();
+ {
+ Glib::Threads::Mutex::Lock lm (midi_port_info_mutex);
+ fill_midi_port_info_locked ();
+ }
+}
+
+string
+PortManager::short_port_name_from_port_name (std::string const & full_name) const
+{
+ string::size_type colon = full_name.find_first_of (':');
+ if (colon == string::npos || colon == full_name.length()) {
+ return full_name;
+ }
+ return full_name.substr (colon+1);
}
void
{
/* MIDI info mutex MUST be held */
- if (!midi_info_dirty) {
+ if (!midi_info_dirty || !_backend) {
return;
}
for (vector<string>::iterator p = ports.begin(); p != ports.end(); ++p) {
- if (port_is_mine (*p)) {
+ /* ugly hack, ideally we'd use a port-flag, or at vkbd_output_port()->name() */
+ if (port_is_mine (*p) && *p != _backend->my_name() + ":" + _("Virtual Keyboard")) {
continue;
}
if (midi_port_info.find (*p) == midi_port_info.end()) {
- MidiPortInformation mpi;
- mpi.pretty_name = *p;
- mpi.input = true;
+
+ MidiPortFlags flags (MidiPortFlags (0));
if (port_is_control_only (*p)) {
- mpi.properties = MidiPortFlags (mpi.properties | MidiPortControl);
+ flags = MidiPortControl;
}
+
+ MidiPortInformation mpi (_backend->name(), *p, true, flags, true);
+
#ifdef LINUX
- if ((*p.find (X_("Midi Through")) != string::npos ||
- (*p).find (X_("Midi-Through")) != string::npos))
- {
+ if ((*p.find (X_("Midi Through")) != string::npos || (*p).find (X_("Midi-Through")) != string::npos)) {
mpi.properties = MidiPortFlags (mpi.properties | MidiPortVirtual);
}
#endif
}
if (midi_port_info.find (*p) == midi_port_info.end()) {
- MidiPortInformation mpi;
- mpi.pretty_name = *p;
- mpi.input = false;
+
+ MidiPortFlags flags (MidiPortFlags (0));
if (port_is_control_only (*p)) {
- mpi.properties = MidiPortFlags (mpi.properties | MidiPortControl);
+ flags = MidiPortControl;
}
+
+ MidiPortInformation mpi (_backend->name(), *p, false, flags, true);
+
#ifdef LINUX
- if ((*p.find (X_("Midi Through")) != string::npos ||
- (*p).find (X_("Midi-Through")) != string::npos))
- {
+ if ((*p.find (X_("Midi Through")) != string::npos || (*p).find (X_("Midi-Through")) != string::npos)) {
mpi.properties = MidiPortFlags (mpi.properties | MidiPortVirtual);
}
#endif
}
}
- /* now push/pull pretty name information between backend and the
- * PortManager
+ /* now check with backend about which ports are present and pull
+ * pretty-name if it exists
*/
- // rg: I don't understand what this attempts to solve
- //
- // Naming ports should be left to the backend:
- // Ardour cannot associate numeric IDs with corresponding hardware.
- // (see also 7dde6c3b)
-
for (MidiPortInfo::iterator x = midi_port_info.begin(); x != midi_port_info.end(); ++x) {
+
+ if (x->second.backend != _backend->name()) {
+ /* this port (info) comes from a different
+ * backend. While there's a reasonable chance that it
+ * refers to the same physical (or virtual) endpoint, we
+ * don't allow its use with this backend.
+ */
+ x->second.exists = false;
+ continue;
+ }
+
PortEngine::PortHandle ph = _backend->get_port_by_name (x->first);
if (!ph) {
/* port info saved from some condition where this port
* existed, but no longer does (i.e. device unplugged
- * at present)
+ * at present). We don't remove it from midi_port_info.
*/
- continue;
- }
+ x->second.exists = false;
- if (!x->second.pretty_name.empty () && x->second.pretty_name != x->first) {
- /* name set in port info ... propagate */
- _backend->set_port_property (ph, "http://jackaudio.org/metadata/pretty-name", x->second.pretty_name, string());
} else {
+ x->second.exists = true;
+
/* check with backend for pre-existing pretty name */
- string value;
- string type;
- if (0 == _backend->get_port_property (ph,
- "http://jackaudio.org/metadata/pretty-name",
- value, type)) {
+
+ string value = AudioEngine::instance()->get_pretty_name_by_name (x->first);
+
+ if (!value.empty()) {
x->second.pretty_name = value;
}
}
midi_info_dirty = false;
}
+
+void
+PortManager::set_port_buffer_sizes (pframes_t n)
+{
+
+ boost::shared_ptr<Ports> all = ports.reader();
+
+ for (Ports::iterator p = all->begin(); p != all->end(); ++p) {
+ p->second->set_buffer_size (n);
+ }
+}
projects / ardour.git / blobdiff