summaryrefslogtreecommitdiffstats
path: root/src/server/LV2Node.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/LV2Node.cpp')
-rw-r--r--src/server/LV2Node.cpp37
1 files changed, 32 insertions, 5 deletions
diff --git a/src/server/LV2Node.cpp b/src/server/LV2Node.cpp
index 0ee5c500..88cfff73 100644
--- a/src/server/LV2Node.cpp
+++ b/src/server/LV2Node.cpp
@@ -387,9 +387,8 @@ LV2Node::instantiate(BufferFactory& bufs)
// FIXME: Polyphony + worker?
if (lilv_plugin_has_feature(plug, info->work_schedule)) {
_worker_iface = (LV2_Worker_Interface*)
- lilv_instance_get_extension_data(
- (LilvInstance*)(*_instances)[0].get(),
- LV2_WORKER__interface);
+ lilv_instance_get_extension_data(instance(0),
+ LV2_WORKER__interface);
}
return ret;
@@ -413,11 +412,25 @@ LV2Node::deactivate()
lilv_instance_deactivate(instance(i));
}
+LV2_Worker_Status
+LV2Node::work_respond(LV2_Worker_Respond_Handle handle,
+ uint32_t size,
+ const void* data)
+{
+ LV2Node* node = (LV2Node*)handle;
+ LV2Node::Response* r = new LV2Node::Response(size, data);
+ node->_responses.push_back(*r);
+ return LV2_WORKER_SUCCESS;
+}
+
void
-LV2Node::work(MessageContext& context, uint32_t size, const void* data)
+LV2Node::work(uint32_t size, const void* data)
{
if (_worker_iface) {
- _worker_iface->work(instance(0), NULL, NULL, size, data);
+ LV2_Handle inst = lilv_instance_get_handle(instance(0));
+ if (_worker_iface->work(inst, work_respond, this, size, data)) {
+ Raul::error(Raul::fmt("Error calling %1% work method\n") % _path);
+ }
}
}
@@ -429,6 +442,20 @@ LV2Node::process(ProcessContext& context)
for (uint32_t i = 0; i < _polyphony; ++i)
lilv_instance_run(instance(i), context.nframes());
+ if (_worker_iface) {
+ LV2_Handle inst = lilv_instance_get_handle(instance(0));
+ while (!_responses.empty()) {
+ Response& r = _responses.front();
+ _worker_iface->work_response(inst, r.size, r.data);
+ _responses.pop_front();
+ context.engine().maid()->push(&r);
+ }
+
+ if (_worker_iface->end_run) {
+ _worker_iface->end_run(inst);
+ }
+ }
+
NodeImpl::post_process(context);
}