summaryrefslogtreecommitdiff
path: root/lib/gras_impl/block_actor.hpp
diff options
context:
space:
mode:
authorJosh Blum2013-06-06 11:55:53 -0700
committerJosh Blum2013-06-06 11:55:53 -0700
commit4f03a5c6264ba3cd888454360f4c6819fa38023d (patch)
tree080e9d41148ac911b745009c869f9da7a0475c4d /lib/gras_impl/block_actor.hpp
parent43c7ef3e7807ad3035a2882d237b0441e6102817 (diff)
downloadsandhi-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.hpp4
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);