summaryrefslogtreecommitdiff
path: root/gnuradio-runtime/lib/gr_buffer.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gnuradio-runtime/lib/gr_buffer.cc')
-rw-r--r--gnuradio-runtime/lib/gr_buffer.cc14
1 files changed, 7 insertions, 7 deletions
diff --git a/gnuradio-runtime/lib/gr_buffer.cc b/gnuradio-runtime/lib/gr_buffer.cc
index 369959d65f..bdce5b4036 100644
--- a/gnuradio-runtime/lib/gr_buffer.cc
+++ b/gnuradio-runtime/lib/gr_buffer.cc
@@ -185,7 +185,7 @@ gr_buffer::write_pointer ()
void
gr_buffer::update_write_pointer (int nitems)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
d_write_index = index_add (d_write_index, nitems);
d_abs_write_offset += nitems;
}
@@ -193,7 +193,7 @@ gr_buffer::update_write_pointer (int nitems)
void
gr_buffer::set_done (bool done)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
d_done = done;
}
@@ -229,14 +229,14 @@ gr_buffer::drop_reader (gr_buffer_reader *reader)
void
gr_buffer::add_item_tag(const gr_tag_t &tag)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
d_item_tags.push_back(tag);
}
void
gr_buffer::remove_item_tag(const gr_tag_t &tag)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
for (std::deque<gr_tag_t>::iterator it = d_item_tags.begin(); it != d_item_tags.end(); ++it) {
if (*it == tag) {
d_item_tags.erase(it);
@@ -256,7 +256,7 @@ gr_buffer::prune_tags(uint64_t max_time)
If this function is used elsewhere, remember to lock the
buffer's mutex al la the scoped_lock line below.
*/
- //gruel::scoped_lock guard(*mutex());
+ //gr::thread::scoped_lock guard(*mutex());
std::deque<gr_tag_t>::iterator itr = d_item_tags.begin();
uint64_t item_time;
@@ -313,7 +313,7 @@ gr_buffer_reader::read_pointer ()
void
gr_buffer_reader::update_read_pointer (int nitems)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
d_read_index = d_buffer->index_add (d_read_index, nitems);
d_abs_read_offset += nitems;
}
@@ -323,7 +323,7 @@ gr_buffer_reader::get_tags_in_range(std::vector<gr_tag_t> &v,
uint64_t abs_start,
uint64_t abs_end)
{
- gruel::scoped_lock guard(*mutex());
+ gr::thread::scoped_lock guard(*mutex());
v.resize(0);
std::deque<gr_tag_t>::iterator itr = d_buffer->get_tags_begin();