diff options
-rw-r--r-- | gnuradio-runtime/include/gnuradio/basic_block.h | 7 | ||||
-rw-r--r-- | gnuradio-runtime/lib/basic_block.cc | 23 |
2 files changed, 0 insertions, 30 deletions
diff --git a/gnuradio-runtime/include/gnuradio/basic_block.h b/gnuradio-runtime/include/gnuradio/basic_block.h index 25d9fb5a78..fa454c95ed 100644 --- a/gnuradio-runtime/include/gnuradio/basic_block.h +++ b/gnuradio-runtime/include/gnuradio/basic_block.h @@ -252,13 +252,6 @@ namespace gr { */ pmt::pmt_t delete_head_nowait( pmt::pmt_t which_port); - /*! - * \param[in] which_port The message port from which to get the message. - * \param[in] millisec Optional timeout value (0=no timeout). - * \returns returns pmt at head of queue or pmt::pmt_t() if empty. - */ - pmt::pmt_t delete_head_blocking(pmt::pmt_t which_port, unsigned int millisec = 0); - msg_queue_t::iterator get_iterator(pmt::pmt_t which_port) { return msg_queue[which_port].begin(); } diff --git a/gnuradio-runtime/lib/basic_block.cc b/gnuradio-runtime/lib/basic_block.cc index 082d0753c8..89aa9b8671 100644 --- a/gnuradio-runtime/lib/basic_block.cc +++ b/gnuradio-runtime/lib/basic_block.cc @@ -228,29 +228,6 @@ namespace gr { } pmt::pmt_t - basic_block::delete_head_blocking(pmt::pmt_t which_port, unsigned int millisec) - { - gr::thread::scoped_lock guard(mutex); - - if (millisec) { - boost::system_time const timeout = boost::get_system_time() + boost::posix_time::milliseconds(millisec); - while (empty_p(which_port)) { - if (!msg_queue_ready[which_port]->timed_wait(guard, timeout)) { - return pmt::pmt_t(); - } - } - } else { - while(empty_p(which_port)) { - msg_queue_ready[which_port]->wait(guard); - } - } - - pmt::pmt_t m(msg_queue[which_port].front()); - msg_queue[which_port].pop_front(); - return m; - } - - pmt::pmt_t basic_block::message_subscribers(pmt::pmt_t port) { return pmt::dict_ref(d_message_subscribers,port,pmt::PMT_NIL); |