diff options
| author | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-26 19:03:51 +0100 |
|---|---|---|
| committer | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-26 19:05:08 +0100 |
| commit | 585cc65be340fe1ed4c99ff397c3d71f49b621c5 (patch) | |
| tree | 604b62f2edcad8a554005b29c59191fc4a1d3451 /gr-zeromq/lib/sub_source_impl.cc | |
| parent | c1f42c12af1b4deedf7d72c477b40d4cc369ee41 (diff) | |
zmq: stream tag passing now works
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]); } } |