[Commit-gnuradio] [gnuradio] 12/18: runtime: tpb, don't check msg queue

[git]

This is an automated email from the git hooks/post-receive script.

jcorgan pushed a commit to branch next
in repository gnuradio.

commit 567f18f7cc750ffcfa6085548fe1a3fe2274c4b6
Author: Bastian Bloessl <address@hidden>
Date:   Wed May 4 07:23:54 2016 +0200

    runtime: tpb, don't check msg queue
---
 gnuradio-runtime/lib/tpb_thread_body.cc | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/gnuradio-runtime/lib/tpb_thread_body.cc 
b/gnuradio-runtime/lib/tpb_thread_body.cc
index d49c088..610a13c 100644
--- a/gnuradio-runtime/lib/tpb_thread_body.cc
+++ b/gnuradio-runtime/lib/tpb_thread_body.cc
@@ -155,10 +155,7 @@ namespace gr {
       {
         gr::thread::scoped_lock guard(d->d_tpb.mutex);
         while(!d->d_tpb.input_changed) {
-          // wait for input or message
-          if(!d->d_tpb.input_changed && block->empty_handled_p()) {
-            d->d_tpb.input_cond.wait(guard);
-          }
+          d->d_tpb.input_cond.wait(guard);
         }
       }
       break;
@@ -168,7 +165,7 @@ namespace gr {
         gr::thread::scoped_lock guard(d->d_tpb.mutex);
         while(!d->d_tpb.output_changed) {
           // wait for output room or message
-          while(!d->d_tpb.output_changed && block->empty_handled_p())
+          while(!d->d_tpb.output_changed)
             d->d_tpb.output_cond.wait(guard);
 
           // handle all pending messages