From e49fb747ee3c9d60e583ebebcac2066a945b15ec Mon Sep 17 00:00:00 2001
From: Josh Blum
Date: Thu, 6 Jun 2013 12:02:46 -0700
Subject: gras: minor code cleanup
---
lib/block_produce.cpp | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
(limited to 'lib/block_produce.cpp')
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);
--
cgit