From cebd974738fea792f70bca8ab0bb1d73e2116d81 Mon Sep 17 00:00:00 2001
From: Josh Blum
Date: Sat, 16 Mar 2013 04:18:37 -0700
Subject: gras: added num_read count for pop msg to fix #53

---
 lib/block.cpp | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'lib/block.cpp')

diff --git a/lib/block.cpp b/lib/block.cpp
index 9bf3b9c..d2f0a0d 100644
--- a/lib/block.cpp
+++ b/lib/block.cpp
@@ -181,9 +181,9 @@ void Block::post_output_msg(const size_t which_output, const PMCC &msg)
 PMCC Block::pop_input_msg(const size_t which_input)
 {
     std::vector<PMCC> &input_msgs = (*this)->block->input_msgs[which_input];
-    if (input_msgs.empty()) return PMCC();
-    PMCC p = input_msgs.front();
-    input_msgs.erase(input_msgs.begin());
+    size_t &num_read = (*this)->block->num_input_msgs_read[which_input];
+    if (num_read >= input_msgs.size()) return PMCC();
+    PMCC p = input_msgs[num_read++];
     (*this)->block->stats.msgs_consumed[which_input]++;
     return p;
 }
-- 
cgit