diff options
Diffstat (limited to 'src/server/GraphImpl.cpp')
-rw-r--r-- | src/server/GraphImpl.cpp | 22 |
1 files changed, 19 insertions, 3 deletions
diff --git a/src/server/GraphImpl.cpp b/src/server/GraphImpl.cpp index 2bb99dc8..a8a44cf1 100644 --- a/src/server/GraphImpl.cpp +++ b/src/server/GraphImpl.cpp @@ -143,21 +143,37 @@ GraphImpl::apply_internal_poly(ProcessContext& context, } void +GraphImpl::pre_process(ProcessContext& context) +{ + // Mix down input ports and connect buffers + for (uint32_t i = 0; i < num_ports(); ++i) { + PortImpl* const port = _ports->at(i); + port->pre_process(context); + port->pre_run(context); + port->connect_buffers(); + } +} + +void GraphImpl::process(ProcessContext& context) { if (!_process) return; - BlockImpl::pre_process(context); + pre_process(context); + run(context); + post_process(context); +} +void +GraphImpl::run(ProcessContext& context) +{ if (_compiled_graph && _compiled_graph->size() > 0) { // Run all blocks for (size_t i = 0; i < _compiled_graph->size(); ++i) { (*_compiled_graph)[i].block()->process(context); } } - - BlockImpl::post_process(context); } void |