diff options
Diffstat (limited to 'gr-zeromq/lib/pull_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/pull_source_impl.cc | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/gr-zeromq/lib/pull_source_impl.cc b/gr-zeromq/lib/pull_source_impl.cc index 96aa9d853a..87b330a862 100644 --- a/gr-zeromq/lib/pull_source_impl.cc +++ b/gr-zeromq/lib/pull_source_impl.cc @@ -90,7 +90,7 @@ namespace gr { std::vector<gr::tag_t> tags; buf = parse_tag_header(buf, rcv_offset, tags); for(size_t i=0; i<tags.size(); i++){ - tags[i].offset -= rcv_offset - nitems_read(0); + tags[i].offset -= rcv_offset - nitems_written(0); add_item_tag(0, tags[i]); } } |