diff options
| author | Josh Blum | 2013-03-16 04:18:37 -0700 |
|---|---|---|
| committer | Josh Blum | 2013-03-16 04:18:37 -0700 |
| commit | cebd974738fea792f70bca8ab0bb1d73e2116d81 (patch) | |
| tree | fe53f1ce5795385ac257430912ae2d9bc4129120 /lib/gras_impl/block_actor.hpp | |
| parent | 7cc848c9e69dd3c1f70e2872f1a4fb2043c94e66 (diff) | |
| download | sandhi-cebd974738fea792f70bca8ab0bb1d73e2116d81.tar.gz sandhi-cebd974738fea792f70bca8ab0bb1d73e2116d81.tar.bz2 sandhi-cebd974738fea792f70bca8ab0bb1d73e2116d81.zip | |
gras: added num_read count for pop msg to fix #53
Diffstat (limited to 'lib/gras_impl/block_actor.hpp')
| -rw-r--r-- | lib/gras_impl/block_actor.hpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 5e08687..935c87d 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -101,6 +101,7 @@ struct BlockActor : Apology::Worker void output_fail(const size_t index); void sort_tags(const size_t index); void trim_tags(const size_t index); + void trim_msgs(const size_t index); void produce(const size_t index, const size_t items); void consume(const size_t index, const size_t items); void produce_buffer(const size_t index, const SBuffer &buffer); @@ -154,6 +155,7 @@ struct BlockActor : Apology::Worker //tag tracking std::vector<bool> input_tags_changed; std::vector<std::vector<Tag> > input_tags; + std::vector<size_t> num_input_msgs_read; std::vector<std::vector<PMCC> > input_msgs; //interruptible thread stuff |