summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/server/InputPort.cpp18
1 files changed, 11 insertions, 7 deletions
diff --git a/src/server/InputPort.cpp b/src/server/InputPort.cpp
index 01a5c414..4a1c9d25 100644
--- a/src/server/InputPort.cpp
+++ b/src/server/InputPort.cpp
@@ -178,12 +178,6 @@ InputPort::pre_process(Context& context)
if (_set_by_user)
return;
- uint32_t max_num_srcs = 0;
- for (Connections::iterator c = _connections.begin(); c != _connections.end(); ++c)
- max_num_srcs += (*c)->src_port()->poly();
-
- boost::intrusive_ptr<Buffer> srcs[max_num_srcs];
-
if (_connections.empty()) {
for (uint32_t v = 0; v < _poly; ++v) {
buffer(v)->prepare_read(context);
@@ -194,10 +188,20 @@ InputPort::pre_process(Context& context)
_buffers->at(v)->prepare_read(context);
}
} else {
+ uint32_t max_num_srcs = 0;
+ for (Connections::const_iterator c = _connections.begin();
+ c != _connections.end(); ++c) {
+ max_num_srcs += (*c)->src_port()->poly();
+ }
+
+ boost::intrusive_ptr<Buffer> srcs[max_num_srcs];
+
for (uint32_t v = 0; v < _poly; ++v) {
uint32_t num_srcs = 0;
- for (Connections::iterator c = _connections.begin(); c != _connections.end(); ++c)
+ for (Connections::const_iterator c = _connections.begin();
+ c != _connections.end(); ++c) {
(*c)->get_sources(context, v, srcs, max_num_srcs, num_srcs);
+ }
mix(context, buffer(v).get(), srcs, num_srcs);
buffer(v)->prepare_read(context);