summaryrefslogtreecommitdiff
path: root/gnuradio-runtime/lib/gr_msg_queue.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gnuradio-runtime/lib/gr_msg_queue.cc')
-rw-r--r--gnuradio-runtime/lib/gr_msg_queue.cc6
1 files changed, 3 insertions, 3 deletions
diff --git a/gnuradio-runtime/lib/gr_msg_queue.cc b/gnuradio-runtime/lib/gr_msg_queue.cc
index 0cf0467715..03bbe046a4 100644
--- a/gnuradio-runtime/lib/gr_msg_queue.cc
+++ b/gnuradio-runtime/lib/gr_msg_queue.cc
@@ -49,7 +49,7 @@ gr_msg_queue::insert_tail(gr_message_sptr msg)
if (msg->d_next)
throw std::invalid_argument("gr_msg_queue::insert_tail: msg already in queue");
- gruel::scoped_lock guard(d_mutex);
+ gr::thread::scoped_lock guard(d_mutex);
while (full_p())
d_not_full.wait(guard);
@@ -72,7 +72,7 @@ gr_msg_queue::insert_tail(gr_message_sptr msg)
gr_message_sptr
gr_msg_queue::delete_head()
{
- gruel::scoped_lock guard(d_mutex);
+ gr::thread::scoped_lock guard(d_mutex);
gr_message_sptr m;
while ((m = d_head) == 0)
@@ -94,7 +94,7 @@ gr_msg_queue::delete_head()
gr_message_sptr
gr_msg_queue::delete_head_nowait()
{
- gruel::scoped_lock guard(d_mutex);
+ gr::thread::scoped_lock guard(d_mutex);
gr_message_sptr m;
if ((m = d_head) == 0){