diff options
Diffstat (limited to 'lib/block_produce.cpp')
| -rw-r--r-- | lib/block_produce.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/block_produce.cpp b/lib/block_produce.cpp index 9fbc468..584d3a3 100644 --- a/lib/block_produce.cpp +++ b/lib/block_produce.cpp @@ -60,7 +60,7 @@ GRAS_FORCE_INLINE void BlockActor::produce(const size_t i, const size_t items) GRAS_FORCE_INLINE void BlockActor::produce_buffer(const size_t i, const SBuffer &buffer) { - this->flush_output(i); + this->output_queues.consume(i); ASSERT((buffer.length % output_configs[i].item_size) == 0); const size_t items = buffer.length/output_configs[i].item_size; this->stats.items_produced[i] += items; |