summaryrefslogtreecommitdiff
path: root/lib/task_main.cpp
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/task_main.cpp
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/task_main.cpp')
-rw-r--r--lib/task_main.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/task_main.cpp b/lib/task_main.cpp
index 2178b73..cb3e0ee 100644
--- a/lib/task_main.cpp
+++ b/lib/task_main.cpp
@@ -16,8 +16,8 @@ void BlockActor::task_main(void)
//------------------------------------------------------------------
if GRAS_UNLIKELY(not this->is_work_allowed()) return;
- const size_t num_inputs = this->get_num_inputs();
- const size_t num_outputs = this->get_num_outputs();
+ const size_t num_inputs = worker->get_num_inputs();
+ const size_t num_outputs = worker->get_num_outputs();
//------------------------------------------------------------------
//-- initialize input buffers before work
@@ -109,7 +109,7 @@ void BlockActor::task_main(void)
//Post a buffer message downstream only if the produce flag was marked.
//So this explicitly after consuming the output queues so pop is called.
//This is because pop may have special hooks in it to prepare the buffer.
- if GRAS_LIKELY(data->produce_outputs[i]) this->post_downstream(i, buff_msg);
+ if GRAS_LIKELY(data->produce_outputs[i]) worker->post_downstream(i, buff_msg);
data->produce_outputs[i] = false;
}