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/pub_sink_impl.cc | |
| parent | c1f42c12af1b4deedf7d72c477b40d4cc369ee41 (diff) | |
zmq: stream tag passing now works
Diffstat (limited to 'gr-zeromq/lib/pub_sink_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/pub_sink_impl.cc | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/gr-zeromq/lib/pub_sink_impl.cc b/gr-zeromq/lib/pub_sink_impl.cc index 6804c1d9ce..5afcb722b1 100644 --- a/gr-zeromq/lib/pub_sink_impl.cc +++ b/gr-zeromq/lib/pub_sink_impl.cc @@ -81,6 +81,7 @@ namespace gr { // create message copy and send zmq::message_t msg(header.length() + d_itemsize*d_vlen*noutput_items); + //std::cout << "PUB: Header Len: " << header.length() << ", Data Length: " << d_itemsize*d_vlen*noutput_items << "\n"; if(d_pass_tags) memcpy((void*) msg.data(), header.c_str(), header.length() ); memcpy((uint8_t *)msg.data() + header.length(), in, d_itemsize*d_vlen*noutput_items); |