From edd1405c7f2bcd79e8fb5aa72189e13a37c1ed02 Mon Sep 17 00:00:00 2001
From: Camilo Solano <solano@ti.rwth-aachen.de>
Date: Tue, 6 May 2014 18:38:43 +0200
Subject: Add vlen
---
gr-zeromq/lib/pull_source_impl.cc | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
(limited to 'gr-zeromq/lib/pull_source_impl.cc')
diff --git a/gr-zeromq/lib/pull_source_impl.cc b/gr-zeromq/lib/pull_source_impl.cc
index d5b815ecce..9b9e50a38f 100644
--- a/gr-zeromq/lib/pull_source_impl.cc
+++ b/gr-zeromq/lib/pull_source_impl.cc
@@ -31,16 +31,16 @@ namespace gr {
namespace zeromq {
pull_source::sptr
- pull_source::make(size_t itemsize, char *address, float timeout)
+ pull_source::make(size_t itemsize, size_t vlen, char *address, float timeout)
{
return gnuradio::get_initial_sptr
- (new pull_source_impl(itemsize, address, timeout));
+ (new pull_source_impl(itemsize, vlen, address, timeout));
}
- pull_source_impl::pull_source_impl(size_t itemsize, char *address, float timeout)
+ pull_source_impl::pull_source_impl(size_t itemsize, size_t vlen, char *address, float timeout)
: gr::sync_block("pull_source",
gr::io_signature::make(0, 0, 0),
- gr::io_signature::make(1, 1, itemsize)),
+ gr::io_signature::make(1, 1, itemsize * vlen)),
d_itemsize(itemsize)
{
d_timeout = timeout >= 0 ? (int)(timeout*1e6) : 0;
--
cgit v1.2.3