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/req_source_impl.cc | |
| parent | c1f42c12af1b4deedf7d72c477b40d4cc369ee41 (diff) | |
zmq: stream tag passing now works
Diffstat (limited to 'gr-zeromq/lib/req_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/req_source_impl.cc | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/gr-zeromq/lib/req_source_impl.cc b/gr-zeromq/lib/req_source_impl.cc index 6e2ad3daf4..5c5071e15e 100644 --- a/gr-zeromq/lib/req_source_impl.cc +++ b/gr-zeromq/lib/req_source_impl.cc @@ -98,7 +98,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]); } } |