summaryrefslogtreecommitdiffstats
path: root/src/engine
diff options
context:
space:
mode:
Diffstat (limited to 'src/engine')
-rw-r--r--src/engine/events/CreatePortEvent.cpp39
1 files changed, 16 insertions, 23 deletions
diff --git a/src/engine/events/CreatePortEvent.cpp b/src/engine/events/CreatePortEvent.cpp
index 30b019e9..6f3f80e5 100644
--- a/src/engine/events/CreatePortEvent.cpp
+++ b/src/engine/events/CreatePortEvent.cpp
@@ -38,28 +38,28 @@ namespace Ingen {
CreatePortEvent::CreatePortEvent(Engine& engine,
- SharedPtr<Responder> responder,
- SampleCount timestamp,
- const string& path,
- const string& type,
- bool is_output,
- QueuedEventSource* source)
-: QueuedEvent(engine, responder, timestamp, true, source),
- _error(NO_ERROR),
- _path(path),
- _type(type),
- _is_output(is_output),
- _data_type(type),
- _patch(NULL),
- _patch_port(NULL),
- _driver_port(NULL)
+ SharedPtr<Responder> responder,
+ SampleCount timestamp,
+ const string& path,
+ const string& type,
+ bool is_output,
+ QueuedEventSource* source)
+ : QueuedEvent(engine, responder, timestamp, true, source)
+ , _error(NO_ERROR)
+ , _path(path)
+ , _type(type)
+ , _is_output(is_output)
+ , _data_type(type)
+ , _patch(NULL)
+ , _patch_port(NULL)
+ , _driver_port(NULL)
{
/* This is blocking because of the two different sets of Patch ports, the array used in the
* audio thread (inherited from NodeBase), and the arrays used in the pre processor thread.
* If two add port events arrive in the same cycle and the second pre processes before the
* first executes, bad things happen (ports are lost).
*
- * FIXME: fix this using RCU
+ * TODO: fix this using RCU?
*/
if (_data_type == DataType::UNKNOWN) {
@@ -77,8 +77,6 @@ CreatePortEvent::pre_process()
return;
}
- // FIXME: this is just a mess :/
-
_patch = _engine.engine_store()->find_patch(_path.parent());
if (_patch != NULL) {
@@ -104,9 +102,7 @@ CreatePortEvent::pre_process()
else
_ports_array = new Raul::Array<PortImpl*>(old_num_ports + 1, NULL);
-
_ports_array->at(_patch->num_ports()-1) = _patch_port;
- //_patch_port->add_to_store(_engine.engine_store());
_engine.engine_store()->add(_patch_port);
if (!_patch->parent()) {
@@ -135,10 +131,7 @@ CreatePortEvent::execute(ProcessContext& context)
QueuedEvent::execute(context);
if (_patch_port) {
-
_engine.maid()->push(_patch->external_ports());
- //_patch->add_port(_port);
-
_patch->external_ports(_ports_array);
}