diff options
Diffstat (limited to 'gr-zeromq/lib/sub_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/sub_source_impl.cc | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/gr-zeromq/lib/sub_source_impl.cc b/gr-zeromq/lib/sub_source_impl.cc index f1aeb91dd0..813ff5a1c0 100644 --- a/gr-zeromq/lib/sub_source_impl.cc +++ b/gr-zeromq/lib/sub_source_impl.cc @@ -89,9 +89,12 @@ namespace gr { if(d_pass_tags){ uint64_t rcv_offset; std::vector<gr::tag_t> tags; + //int olen = buf.size(); buf = parse_tag_header(buf, rcv_offset, tags); + //std::cout << "SUB: Header Len = " << olen - buf.size() << ", data len = " << buf.size() << "\n"; for(size_t i=0; i<tags.size(); i++){ - tags[i].offset -= rcv_offset - nitems_read(0); + //std::cout << "add item tag ... (offset = " << tags[i].offset << " rcv_offset = " << rcv_offset << " nitems_read(0) = " << nitems_written(0) << "\n"; + tags[i].offset -= rcv_offset - nitems_written(0); add_item_tag(0, tags[i]); } } |