From: eb <eb@221aa14e-8319-0410-a670-987f0aec2ac5>
Date: Wed, 25 Mar 2009 22:29:21 +0000 (+0000)
Subject: Add check for interruption to gr_tpb_thread_body to ensure that
X-Git-Url: https://git.gag.com/?a=commitdiff_plain;h=d0dc3ffdc43630abd1cf800cb6f3b9195770fd4d;p=debian%2Fgnuradio

Add check for interruption to gr_tpb_thread_body to ensure that
threads stop quickly.



git-svn-id: http://gnuradio.org/svn/gnuradio/trunk@10686 221aa14e-8319-0410-a670-987f0aec2ac5
---

diff --git a/gnuradio-core/src/lib/runtime/gr_tpb_thread_body.cc b/gnuradio-core/src/lib/runtime/gr_tpb_thread_body.cc
index f61e1724..e3abf6d8 100644
--- a/gnuradio-core/src/lib/runtime/gr_tpb_thread_body.cc
+++ b/gnuradio-core/src/lib/runtime/gr_tpb_thread_body.cc
@@ -23,6 +23,7 @@
 #endif
 #include <gr_tpb_thread_body.h>
 #include <iostream>
+#include <boost/thread.hpp>
 
 gr_tpb_thread_body::gr_tpb_thread_body(gr_block_sptr block)
   : d_exec(block)
@@ -33,6 +34,8 @@ gr_tpb_thread_body::gr_tpb_thread_body(gr_block_sptr block)
   gr_block_executor::state s;
 
   while (1){
+    boost::this_thread::interruption_point();
+
     d->d_tpb.clear_changed();
     s = d_exec.run_one_iteration();