Revision 6d439361 gnuradio-core/src/lib/runtime/gr_buffer.cc
| b/gnuradio-core/src/lib/runtime/gr_buffer.cc | ||
|---|---|---|
| 271 | 271 |
d_abs_read_offset += nitems; |
| 272 | 272 |
} |
| 273 | 273 |
|
| 274 |
std::vector<pmt::pmt_t> |
|
| 275 |
gr_buffer_reader::get_tags_in_range(uint64_t abs_start, |
|
| 274 |
void |
|
| 275 |
gr_buffer_reader::get_tags_in_range(std::vector<pmt::pmt_t> &v, |
|
| 276 |
uint64_t abs_start, |
|
| 276 | 277 |
uint64_t abs_end) |
| 277 | 278 |
{
|
| 278 | 279 |
gruel::scoped_lock guard(*mutex()); |
| 279 | 280 |
|
| 280 |
std::vector<pmt::pmt_t> found_items;
|
|
| 281 |
v.resize(0);
|
|
| 281 | 282 |
std::deque<pmt::pmt_t>::iterator itr = d_buffer->get_tags_begin(); |
| 282 | 283 |
|
| 283 | 284 |
uint64_t item_time; |
| ... | ... | |
| 285 | 286 |
item_time = pmt::pmt_to_uint64(pmt::pmt_tuple_ref(*itr, 0)); |
| 286 | 287 |
|
| 287 | 288 |
if((item_time >= abs_start) && (item_time <= abs_end)) {
|
| 288 |
found_items.push_back(*itr);
|
|
| 289 |
v.push_back(*itr);
|
|
| 289 | 290 |
} |
| 290 | 291 |
|
| 291 | 292 |
itr++; |
| 292 | 293 |
} |
| 293 |
|
|
| 294 |
return found_items; |
|
| 295 | 294 |
} |
| 296 | 295 |
|
| 297 | 296 |
void |
Also available in: Unified diff