From 5197311dd22744b784ff9ae2cd965a26ef04f4a4 Mon Sep 17 00:00:00 2001
From: Bastian Bloessl <bloessl@ccs-labs.org>
Date: Thu, 28 Apr 2016 15:33:14 +0200
Subject: runtime: delete blocking wait for message
this is always bad practice
---
gnuradio-runtime/lib/basic_block.cc | 23 -----------------------
1 file changed, 23 deletions(-)
(limited to 'gnuradio-runtime/lib/basic_block.cc')
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
@@ -227,29 +227,6 @@ namespace gr {
return m;
}
- 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)
{
--
cgit v1.2.3