summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/server/events/SetPortValue.cpp56
-rw-r--r--src/server/events/SetPortValue.hpp1
2 files changed, 25 insertions, 32 deletions
diff --git a/src/server/events/SetPortValue.cpp b/src/server/events/SetPortValue.cpp
index 31152e01..e2abcb17 100644
--- a/src/server/events/SetPortValue.cpp
+++ b/src/server/events/SetPortValue.cpp
@@ -43,7 +43,6 @@ SetPortValue::SetPortValue(Engine& engine,
PortImpl* port,
const Raul::Atom& value)
: Event(engine, client, id, timestamp)
- , _queued(false)
, _port_path(port->path())
, _value(value)
, _port(port)
@@ -57,16 +56,11 @@ SetPortValue::~SetPortValue()
bool
SetPortValue::pre_process()
{
- if (_queued && !_port) {
- _port = _engine.engine_store()->find_port(_port_path);
+ if (_port->is_output()) {
+ return Event::pre_process_done(DIRECTION_MISMATCH);
}
- if (!_port) {
- return Event::pre_process_done(PORT_NOT_FOUND);
- }
-
- // Port is a message context port, set its value and
- // call the plugin's message run function once
+ // Port is on a message context node, set value and run
if (_port->parent_node()->context() == Context::MESSAGE) {
apply(_engine.message_context());
_engine.message_context().run(
@@ -89,7 +83,7 @@ SetPortValue::execute(ProcessContext& context)
{
assert(_time >= context.start() && _time <= context.end());
- if (_port && _port->parent_node()->context() == Context::MESSAGE)
+ if (_port->parent_node()->context() == Context::MESSAGE)
return;
apply(context);
@@ -99,33 +93,33 @@ SetPortValue::execute(ProcessContext& context)
void
SetPortValue::apply(Context& context)
{
- uint32_t start = context.start();
- if (_status == SUCCESS && !_port)
- _port = _engine.engine_store()->find_port(_port_path);
+ if (_status) {
+ return;
+ }
Ingen::Shared::URIs& uris = _engine.world()->uris();
+ Buffer* const buf = _port->buffer(0).get();
- if (!_port) {
- if (_status == SUCCESS)
- _status = PORT_NOT_FOUND;
- /*} else if (_port->buffer(0)->capacity() < _data_size) {
- _status = NO_SPACE;*/
- } else {
- Buffer* const buf = _port->buffer(0).get();
- AudioBuffer* const abuf = dynamic_cast<AudioBuffer*>(buf);
- if (abuf) {
- if (_value.type() != uris.forge.Float) {
- _status = TYPE_MISMATCH;
- return;
- }
-
- for (uint32_t v = 0; v < _port->poly(); ++v) {
- ((AudioBuffer*)_port->buffer(v).get())->set_value(
- _value.get_float(), start, _time);
- }
+ AudioBuffer* const abuf = dynamic_cast<AudioBuffer*>(buf);
+ if (abuf) {
+ if (_value.type() != uris.forge.Float) {
+ _status = TYPE_MISMATCH;
return;
}
+ for (uint32_t v = 0; v < _port->poly(); ++v) {
+ ((AudioBuffer*)_port->buffer(v).get())->set_value(
+ _value.get_float(), context.start(), _time);
+ }
+ } else if (buf->type() == uris.atom_Sequence) {
+ buf->prepare_write(context); // FIXME: incorrect
+ if (!buf->append_event(_time - context.start(),
+ _value.size(),
+ _value.type(),
+ (const uint8_t*)_value.get_body())) {
+ Raul::warn(Raul::fmt("Error writing to port %1%\n") % _port_path);
+ }
+ } else {
Raul::warn(Raul::fmt("Unknown value type %1%\n") % _value.type());
}
}
diff --git a/src/server/events/SetPortValue.hpp b/src/server/events/SetPortValue.hpp
index 569023c5..e328ff9e 100644
--- a/src/server/events/SetPortValue.hpp
+++ b/src/server/events/SetPortValue.hpp
@@ -58,7 +58,6 @@ public:
private:
void apply(Context& context);
- bool _queued;
const Raul::Path _port_path;
const Raul::Atom _value;
PortImpl* _port;