[Commit-gnuradio] [gnuradio] 14/18: runtime: scheduler: check for messages at start of iteration

[git]

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

jcorgan pushed a commit to branch next
in repository gnuradio.

commit e497220ea7fad4f7adcf02aabdf1c04123517da1
Author: Bastian Bloessl <address@hidden>
Date:   Wed Jun 29 09:09:10 2016 +0200

    runtime: scheduler: check for messages at start of iteration
---
 gnuradio-runtime/lib/tpb_thread_body.cc | 19 -------------------
 1 file changed, 19 deletions(-)

diff --git a/gnuradio-runtime/lib/tpb_thread_body.cc 
b/gnuradio-runtime/lib/tpb_thread_body.cc
index bba213f..1e6d82a 100644
--- a/gnuradio-runtime/lib/tpb_thread_body.cc
+++ b/gnuradio-runtime/lib/tpb_thread_body.cc
@@ -168,25 +168,6 @@ namespace gr {
           // wait for output room or message
           while(!d->d_tpb.output_changed)
             d->d_tpb.output_cond.wait(guard);
-
-          // handle all pending messages
-          BOOST_FOREACH(basic_block::msg_queue_map_t::value_type &i, 
block->msg_queue) {
-            if(block->has_msg_handler(i.first)) {
-                while((msg = block->delete_head_nowait(i.first))) {
-                  guard.unlock();                      // release lock while 
processing msg
-                  block->dispatch_msg(i.first, msg);
-                  guard.lock();
-                }
-            }
-            else {
-                // leave msg in queue if no handler is defined
-                // start dropping if we have too many
-                if(block->nmsgs(i.first) > max_nmsgs){
-                  GR_LOG_WARN(LOG,"asynchronous message buffer overflowing, 
dropping message");
-                  msg = block->delete_head_nowait(i.first);
-                }
-            }
-          }
         }
       }
       break;