summaryrefslogtreecommitdiff
path: root/lib/block_handlers.cpp
diff options
context:
space:
mode:
authorJosh Blum2012-10-04 20:09:59 -0700
committerJosh Blum2012-10-04 20:09:59 -0700
commit12170824b70fa127fe8ed0ac1b81c627c06bd851 (patch)
treecbe9c7a79c09ff23eda48ff62151924b820d27c8 /lib/block_handlers.cpp
parentd889b683cd36d5ec679fcfcc35e3ebd731846abb (diff)
parent3b26ff66074621c1fd1dc26b616ec1583c2fb024 (diff)
downloadsandhi-12170824b70fa127fe8ed0ac1b81c627c06bd851.tar.gz
sandhi-12170824b70fa127fe8ed0ac1b81c627c06bd851.tar.bz2
sandhi-12170824b70fa127fe8ed0ac1b81c627c06bd851.zip
Merge branch 'master' into port_config
Diffstat (limited to 'lib/block_handlers.cpp')
-rw-r--r--lib/block_handlers.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/block_handlers.cpp b/lib/block_handlers.cpp
index 59feecf..2e71ac1 100644
--- a/lib/block_handlers.cpp
+++ b/lib/block_handlers.cpp
@@ -130,7 +130,7 @@ void BlockActor::handle_top_thread_group(
//spawn a new thread if this block is a source
this->thread_group = message;
this->interruptible_thread.reset(); //erase old one
- if (this->get_num_inputs() == 0) //its a source
+ if (this->interruptible_work)
{
this->interruptible_thread = boost::make_shared<InterruptibleThread>(
this->thread_group, boost::bind(&BlockActor::task_work, this)