From 585cc65be340fe1ed4c99ff397c3d71f49b621c5 Mon Sep 17 00:00:00 2001
From: Tim O'Shea <tim.oshea753@gmail.com>
Date: Fri, 26 Dec 2014 19:03:51 +0100
Subject: zmq: stream tag passing now works
---
gr-zeromq/lib/req_source_impl.cc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
(limited to 'gr-zeromq/lib/req_source_impl.cc')
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]);
}
}
--
cgit v1.2.3