Adding mutex protection around adding and getting tags from buffers.

1 files changed, 3 insertions, 0 deletions

diff --git a/gnuradio-core/src/lib/runtime/gr_buffer.cc b/gnuradio-core/src/lib/runtime/gr_buffer.cc
index 862d92b81..1d67470ec 100644
--- a/gnuradio-core/src/lib/runtime/gr_buffer.cc
+++ b/gnuradio-core/src/lib/runtime/gr_buffer.cc
@@ -219,6 +219,7 @@ gr_buffer::drop_reader (gr_buffer_reader *reader)
 void
 gr_buffer::add_item_tag(const pmt::pmt_t &tag)
 {
+  gruel::scoped_lock guard(*mutex());
   d_item_tags.push_back(tag);
 }
 
@@ -267,6 +268,8 @@ std::vector<pmt::pmt_t>
 gr_buffer_reader::get_tags_in_range(uint64_t abs_start,
 				    uint64_t abs_end)
 {
+  gruel::scoped_lock guard(*mutex());
+
   std::vector<pmt::pmt_t> found_items;
   std::deque<pmt::pmt_t>::iterator itr = d_buffer->get_tags_begin();