diff options
| author | Josh Blum | 2013-06-06 12:02:46 -0700 |
|---|---|---|
| committer | Josh Blum | 2013-06-06 12:02:46 -0700 |
| commit | e49fb747ee3c9d60e583ebebcac2066a945b15ec (patch) | |
| tree | c234c04e5e65ce9406aa0f8c14ae07b8f63b29c9 /lib | |
| parent | 4f03a5c6264ba3cd888454360f4c6819fa38023d (diff) | |
| download | sandhi-e49fb747ee3c9d60e583ebebcac2066a945b15ec.tar.gz sandhi-e49fb747ee3c9d60e583ebebcac2066a945b15ec.tar.bz2 sandhi-e49fb747ee3c9d60e583ebebcac2066a945b15ec.zip | |
gras: minor code cleanup
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/block_produce.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/lib/block_produce.cpp b/lib/block_produce.cpp index 5b94dc2..c47fec5 100644 --- a/lib/block_produce.cpp +++ b/lib/block_produce.cpp @@ -42,10 +42,11 @@ void Block::pop_output_buffer(const size_t which_output, const size_t num_bytes) void Block::post_output_buffer(const size_t which_output, const SBuffer &buffer) { - (*this)->block_data->output_queues.consume(which_output); - ASSERT((buffer.length % (*this)->block_data->output_configs[which_output].item_size) == 0); - const size_t items = buffer.length/(*this)->block_data->output_configs[which_output].item_size; - (*this)->block_data->stats.items_produced[which_output] += items; + boost::shared_ptr<BlockData> &data = (*this)->block_data; + data->output_queues.consume(which_output); + ASSERT((buffer.length % data->output_configs[which_output].item_size) == 0); + const size_t items = buffer.length/data->output_configs[which_output].item_size; + data->stats.items_produced[which_output] += items; InputBufferMessage buff_msg; buff_msg.buffer = buffer; (*this)->worker->post_downstream(which_output, buff_msg); |