Generic audio thread generated Event sending system.

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

1 files changed, 12 insertions, 6 deletions

diff --git a/src/libs/engine/PostProcessor.cpp b/src/libs/engine/PostProcessor.cpp
index d1b09271..96aee3b1 100644
--- a/src/libs/engine/PostProcessor.cpp
+++ b/src/libs/engine/PostProcessor.cpp
@@ -36,6 +36,8 @@ PostProcessor::PostProcessor(Engine& engine, size_t queue_size)
     : _engine(engine)
 	, _max_time(0)
 	, _events(queue_size)
+	, _event_buffer_size(sizeof(SendPortValueEvent)) // FIXME: make generic
+	, _event_buffer((uint8_t*)malloc(_event_buffer_size))
 {
 }
 
@@ -43,15 +45,19 @@ PostProcessor::PostProcessor(Engine& engine, size_t queue_size)
 void
 PostProcessor::process()
 {
+	const FrameTime end_time = _max_time.get();
+
 	/* Process any audio thread generated events */
-	/* FIXME: process events from all thread if parallel */
-	/* TODO: obviously this needs work to be generic */
-	SendPortValueEvent ev(_engine, 0, NULL, false, 0, 0.0f);
-	while (_engine.audio_driver()->context().event_sink().read_control_change(ev)) {
-		ev.post_process();
+	/* FIXME: process events from all threads if parallel */
+
+	while (_engine.audio_driver()->context().event_sink().read(
+				_event_buffer_size, _event_buffer)) {
+		if (((Event*)_event_buffer)->time() > end_time)
+			break;
+		((Event*)_event_buffer)->post_process();
 	}
 
-	FrameTime end_time = _max_time.get();
+
 
 	/* Process normal events */
 	while ( ! _events.empty()) {