Partial support for message/value ports and the message context.

This use case now works:
 - Add an event input and the "print" plugin from imum.lv2 to ingen
 - Connect the event input to the input of "print"
 - Hook Ingen up to JACK and play some MIDI events
   (or get events to the print plugin from anywhere else)
 - The "print" plugin will print the received events to the console
   in the message context (i.e. the audio thread is realtime safe)


git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@2281 a436a847-0d15-0410-975c-d299462d15a1

1 files changed, 13 insertions, 10 deletions

diff --git a/src/engine/PatchImpl.cpp b/src/engine/PatchImpl.cpp
index 6388f648..6958c8b5 100644
--- a/src/engine/PatchImpl.cpp
+++ b/src/engine/PatchImpl.cpp
@@ -144,19 +144,22 @@ PatchImpl::process(ProcessContext& context)
 
 	NodeBase::pre_process(context);
 
-	/*if (_ports)
-		for (size_t i=0; i < _ports->size(); ++i)
-			if (_ports->at(i)->is_input() && _ports->at(i)->type() == PortType::MIDI)
-				cerr << _ports->at(i)->path() << " "
-					<< _ports->at(i)->buffer(0) << " # events: "
-					<< ((MidiBuffer*)_ports->at(i)->buffer(0))->event_count() << endl;*/
-
-	/* Run */
+	// Run all nodes
 	if (_compiled_patch && _compiled_patch->size() > 0) {
-		if (_engine.process_slaves().size() > 0)
+		if (_engine.process_slaves().size() > 0) {
 			process_parallel(context);
-		else
+		} else {
 			process_single(context);
+		}
+	}
+
+	// Queue any cross-context connections
+	for (Connections::iterator i = _connections.begin(); i != _connections.end(); ++i) {
+		ConnectionImpl* const c = (ConnectionImpl*)i->get();
+		if (c->src_port()->context() == Context::AUDIO &&
+				c->dst_port()->context() == Context::MESSAGE) {
+			c->queue(context);
+		}
 	}
 
 	NodeBase::post_process(context);