diff options
| author | David Robillard <d@drobilla.net> | 2016-09-12 22:37:22 +0800 |
|---|---|---|
| committer | David Robillard <d@drobilla.net> | 2016-10-02 12:24:56 -0400 |
| commit | 9b8bce71893ef450992f82a28a6a0287c479baaf (patch) | |
| tree | 8c9c240e32f8201d2f999a2de2baaca6281783c3 /src/server/PostProcessor.cpp | |
| parent | 938456884934a74a2850c02edc17575021131709 (diff) | |
| download | ingen-9b8bce71893ef450992f82a28a6a0287c479baaf.tar.gz ingen-9b8bce71893ef450992f82a28a6a0287c479baaf.tar.bz2 ingen-9b8bce71893ef450992f82a28a6a0287c479baaf.zip | |
Add parallel graph execution
Diffstat (limited to 'src/server/PostProcessor.cpp')
| -rw-r--r-- | src/server/PostProcessor.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/server/PostProcessor.cpp b/src/server/PostProcessor.cpp index d6016105..65323f7f 100644 --- a/src/server/PostProcessor.cpp +++ b/src/server/PostProcessor.cpp @@ -1,6 +1,6 @@ /* This file is part of Ingen. - Copyright 2007-2015 David Robillard <http://drobilla.net/> + Copyright 2007-2016 David Robillard <http://drobilla.net/> Ingen is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free @@ -70,7 +70,7 @@ PostProcessor::append(RunContext& context, Event* first, Event* last) bool PostProcessor::pending() const { - return _head.load() || _engine.run_context().pending_notifications(); + return _head.load() || _engine.pending_notifications(); } void @@ -85,7 +85,7 @@ PostProcessor::process() Event* next = ev->next(); if (!next || next->time() >= end_time) { // Process audio thread notifications until end - _engine.run_context().emit_notifications(end_time); + _engine.emit_notifications(end_time); return; } @@ -95,7 +95,7 @@ PostProcessor::process() ev = next; // Process audio thread notifications up until this event's time - _engine.run_context().emit_notifications(ev->time()); + _engine.emit_notifications(ev->time()); // Post-process event ev->post_process(); @@ -109,7 +109,7 @@ PostProcessor::process() _head = ev; // Process remaining audio thread notifications until end - _engine.run_context().emit_notifications(end_time); + _engine.emit_notifications(end_time); } } // namespace Server |