diff options
author | Josh Blum | 2013-01-31 22:38:27 -0800 |
---|---|---|
committer | Josh Blum | 2013-01-31 22:38:27 -0800 |
commit | 6943a8555fb59004e9197513c5bcb23792c1a1e9 (patch) | |
tree | 885fbfcf11be3ce6dd59937ebff61e9697b86ebd | |
parent | e21fdd0deb76471fa35c95bdc5c78a5ce85f7602 (diff) | |
download | sandhi-6943a8555fb59004e9197513c5bcb23792c1a1e9.tar.gz sandhi-6943a8555fb59004e9197513c5bcb23792c1a1e9.tar.bz2 sandhi-6943a8555fb59004e9197513c5bcb23792c1a1e9.zip |
gras: why/how did this link on the other machine
-rw-r--r-- | lib/block_task.cpp | 10 | ||||
-rw-r--r-- | lib/gras_impl/block_actor.hpp | 11 |
2 files changed, 10 insertions, 11 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index 3d8bca1..af8f101 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -96,16 +96,6 @@ void BlockActor::output_fail(const size_t i) this->output_queues.fail(i); } -GRAS_FORCE_INLINE bool BlockActor::is_work_allowed(void) -{ - return ( - this->block_state == BLOCK_STATE_LIVE and - this->input_queues.all_ready() and - this->inputs_available.any() and - this->output_queues.all_ready() - ); -} - void BlockActor::handle_task(void) { //------------------------------------------------------------------ diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 7e9dd6b..5ca5cb0 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -96,7 +96,6 @@ struct BlockActor : Apology::Worker void consume(const size_t index, const size_t items); void produce_buffer(const size_t index, const SBuffer &buffer); void flush_output(const size_t index); - bool is_work_allowed(void); GRAS_FORCE_INLINE void task_kicker(void) { @@ -109,6 +108,16 @@ struct BlockActor : Apology::Worker return this->inputs_done[i] and not available; } + GRAS_FORCE_INLINE bool is_work_allowed(void) + { + return ( + this->block_state == BLOCK_STATE_LIVE and + this->input_queues.all_ready() and + this->inputs_available.any() and + this->output_queues.all_ready() + ); + } + //per port properties std::vector<size_t> input_items_sizes; std::vector<size_t> output_items_sizes; |