diff options
| author | Josh Blum | 2012-11-17 16:59:46 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-11-17 16:59:46 -0800 |
| commit | eecfc6800e08bf3eec1c8fd93e8b07baf06230b3 (patch) | |
| tree | 0f34714429bcf884138919d9330940a32d3e8751 /lib/gras_impl/block_actor.hpp | |
| parent | 692c629daa1d265ed6e2c845013c8cf6bec09f78 (diff) | |
| download | sandhi-eecfc6800e08bf3eec1c8fd93e8b07baf06230b3.tar.gz sandhi-eecfc6800e08bf3eec1c8fd93e8b07baf06230b3.tar.bz2 sandhi-eecfc6800e08bf3eec1c8fd93e8b07baf06230b3.zip | |
added common flush code, flush before produce_buffer
Diffstat (limited to 'lib/gras_impl/block_actor.hpp')
| -rw-r--r-- | lib/gras_impl/block_actor.hpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 6e2903b..7c53a08 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -93,6 +93,7 @@ struct BlockActor : Apology::Worker void produce(const size_t index, const size_t items); void consume(const size_t index, const size_t items); void produce_buffer(const size_t index, const SBuffer &buffer); + void flush_output(const size_t index); GRAS_FORCE_INLINE bool any_inputs_done(void) { |