diff options
| author | Josh Blum | 2013-04-27 13:05:09 -0700 |
|---|---|---|
| committer | Josh Blum | 2013-04-27 13:05:09 -0700 |
| commit | 2464a5780736b71c23cc46d031a62ff30e35d969 (patch) | |
| tree | d6f2a0e66a06b81219f3a6006bf5f1bae8f8c16b /lib/block_produce.cpp | |
| parent | cf930158eabb585552c9b2691370c5ceb7fc6d76 (diff) | |
| download | sandhi-2464a5780736b71c23cc46d031a62ff30e35d969.tar.gz sandhi-2464a5780736b71c23cc46d031a62ff30e35d969.tar.bz2 sandhi-2464a5780736b71c23cc46d031a62ff30e35d969.zip | |
gras: moved flush output to consume function in output queues
This cleans up some code in block actor.
The message sending code is now in task_main,
and the consume routine is now the shared one.
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; |