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/sub_source_impl.cc | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
(limited to 'gr-zeromq/lib/sub_source_impl.cc')
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]);
}
}
--
cgit v1.2.3