summaryrefslogtreecommitdiff
path: root/lib/gras_impl/block_actor.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/gras_impl/block_actor.hpp')
-rw-r--r--lib/gras_impl/block_actor.hpp2
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