diff options
author | Josh Blum | 2013-06-06 11:55:53 -0700 |
---|---|---|
committer | Josh Blum | 2013-06-06 11:55:53 -0700 |
commit | 4f03a5c6264ba3cd888454360f4c6819fa38023d (patch) | |
tree | 080e9d41148ac911b745009c869f9da7a0475c4d /lib/gras_impl/block_actor.hpp | |
parent | 43c7ef3e7807ad3035a2882d237b0441e6102817 (diff) | |
download | sandhi-4f03a5c6264ba3cd888454360f4c6819fa38023d.tar.gz sandhi-4f03a5c6264ba3cd888454360f4c6819fa38023d.tar.bz2 sandhi-4f03a5c6264ba3cd888454360f4c6819fa38023d.zip |
gras: changes for actor in worker Apology commit
Diffstat (limited to 'lib/gras_impl/block_actor.hpp')
-rw-r--r-- | lib/gras_impl/block_actor.hpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 7ee9e9b..360c352 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -14,7 +14,7 @@ namespace gras { -struct BlockActor : Apology::Worker +struct BlockActor : Theron::Actor { BlockActor(const ThreadPool &tp = ThreadPool()); ~BlockActor(void); @@ -23,6 +23,7 @@ struct BlockActor : Apology::Worker ThreadPool thread_pool; Token prio_token; boost::shared_ptr<BlockData> data; + Apology::Worker *worker; //do it here so we can match w/ the handler declarations void register_handlers(void) @@ -95,7 +96,6 @@ struct BlockActor : Apology::Worker 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); void task_kicker(void); void update_input_avail(const size_t index); bool is_input_done(const size_t index); |