#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"
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(); ) {
+
+ MidiPortInfo::iterator x = midi_port_info.find (*si);
- if (include) {
- if ((mpi.properties & include) != include) {
- /* properties do not include requested ones */
- si = ports.erase (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;
+ }
}
}
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::cycle_start (pframes_t nframes)
+PortManager::cycle_start (pframes_t nframes, Session* s)
{
Port::set_global_port_buffer_offset (0);
Port::set_cycle_samplecnt (nframes);
_cycle_ports = ports.reader ();
- // TODO parallelize
- 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) {
+ 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) {
+ 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 (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) {
+ 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) {
+ 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 (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) {
+ 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) {
+ 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);
+
+ if (p->second->sends_output()) {
- boost::shared_ptr<AudioPort> ap = boost::dynamic_pointer_cast<AudioPort> (i->second);
+ 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 = "(";
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;
}
- 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 {
- /* 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)) {
- x->second.pretty_name = value;
- }
+ /* 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)) {
+ x->second.pretty_name = value;
}
}
projects / ardour.git / blobdiff