add initial implementation of a "shadow port" for AsyncMIDIPort.

The shadow port is a secondary port that can be used to allow others to get a copy of part, all or none of the MIDI
stream received by the owner (input) port.

1 files changed, 50 insertions, 0 deletions

diff --git a/libs/ardour/async_midi_port.cc b/libs/ardour/async_midi_port.cc
index bbcc0aab85..ff9a920c69 100644
--- a/libs/ardour/async_midi_port.cc
+++ b/libs/ardour/async_midi_port.cc
@@ -41,6 +41,30 @@ pthread_t AsyncMIDIPort::_process_thread;
 
 #define port_engine AudioEngine::instance()->port_engine()
 
+static bool
+filter_relax (MidiBuffer& in, MidiBuffer& out)
+{
+	return false;
+}
+
+static bool
+filter_copy (MidiBuffer& in, MidiBuffer& out)
+{
+	out.copy (in);
+	return false;
+}
+
+static bool
+filter_notes_only (MidiBuffer& in, MidiBuffer& out)
+{
+	for (MidiBuffer::iterator b = in.begin(); b != in.end(); ++b) {
+		if ((*b).is_note_on() || (*b).is_note_off()) {
+			out.push_back (*b);
+		}
+	}
+	return false;
+}
+
 AsyncMIDIPort::AsyncMIDIPort (string const & name, PortFlags flags)
 	: MidiPort (name, flags)
 	, MIDI::Port (name, MIDI::Port::Flags (0))
@@ -50,6 +74,7 @@ AsyncMIDIPort::AsyncMIDIPort (string const & name, PortFlags flags)
 	, output_fifo (2048)
 	, input_fifo (1024)
 	, _xthread (true)
+	, inbound_midi_filter (boost::bind (filter_notes_only, _1, _2))
 {
 }
 
@@ -145,6 +170,12 @@ AsyncMIDIPort::cycle_start (MIDI::pframes_t nframes)
 		if (!mb.empty()) {
 			_xthread.wakeup ();
 		}
+
+		if (shadow_port) {
+			inbound_midi_filter (mb, shadow_port->get_midi_buffer (nframes));
+		} else {
+			inbound_midi_filter (mb, mb);
+		}
 	}
 }
 
@@ -341,3 +372,22 @@ AsyncMIDIPort::is_process_thread()
 	return pthread_equal (pthread_self(), _process_thread);
 }
 
+int
+AsyncMIDIPort::add_shadow_port (string const & name)
+{
+	if (!ARDOUR::Port::receives_input()) {
+		return -1;
+	}
+
+	if (shadow_port) {
+		return -2;
+	}
+
+	/* shadow port is not async. */
+
+	if (!(shadow_port = boost::dynamic_pointer_cast<MidiPort> (AudioEngine::instance()->register_output_port (DataType::MIDI, name, false)))) {
+		return -3;
+	}
+
+	return 0;
+}