From 02dc3982a0125fcfb675c20bd0aa3a33459d8141 Mon Sep 17 00:00:00 2001
From: Josh Blum
Date: Sun, 16 Jun 2013 01:11:33 -0700
Subject: gras: also set num_output_items_read in post_output_buffer

---
 grextras              | 2 +-
 lib/block_produce.cpp | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/grextras b/grextras
index d859d68..0f85e8c 160000
--- a/grextras
+++ b/grextras
@@ -1 +1 @@
-Subproject commit d859d68f7d25848cb6857a275cf0a107100f6241
+Subproject commit 0f85e8c84997181c0a0dc3f5b25e7dd799997c8d
diff --git a/lib/block_produce.cpp b/lib/block_produce.cpp
index 32df6fa..8ffd9bf 100644
--- a/lib/block_produce.cpp
+++ b/lib/block_produce.cpp
@@ -50,6 +50,7 @@ void Block::post_output_buffer(const size_t which_output, const SBuffer &buffer)
     InputBufferMessage buff_msg;
     buff_msg.buffer = buffer;
     (*this)->worker->post_downstream(which_output, buff_msg);
+    data->num_output_items_read[which_output] += items;
 }
 
 GRAS_FORCE_INLINE void BlockActor::produce(const size_t i, const size_t items)
-- 
cgit