8 files changed, 20 insertions, 20 deletions
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;
diff --git a/gr-zeromq/lib/pull_source_impl.h b/gr-zeromq/lib/pull_source_impl.h
index ff15e1968b..3e56bdc4c5 100644
--- a/gr-zeromq/lib/pull_source_impl.h
+++ b/gr-zeromq/lib/pull_source_impl.h
@@ -38,7 +38,7 @@ namespace gr {
       zmq::socket_t   *d_socket;
 
     public:
-      pull_source_impl(size_t itemsize, char *address, float timeout);
+      pull_source_impl(size_t itemsize, size_t vlen, char *address, float timeout);
       ~pull_source_impl();
 
       int work(int noutput_items,
diff --git a/gr-zeromq/lib/push_sink_impl.cc b/gr-zeromq/lib/push_sink_impl.cc
index 461ed6f24a..43ccd9dbca 100644
--- a/gr-zeromq/lib/push_sink_impl.cc
+++ b/gr-zeromq/lib/push_sink_impl.cc
@@ -31,15 +31,15 @@ namespace gr {
   namespace zeromq {
 
     push_sink::sptr
-    push_sink::make(size_t itemsize, char *address, bool blocking)
+    push_sink::make(size_t itemsize, size_t vlen, char *address, bool blocking)
     {
       return gnuradio::get_initial_sptr
-        (new push_sink_impl(itemsize, address, blocking));
+        (new push_sink_impl(itemsize, vlen, address, blocking));
     }
 
-    push_sink_impl::push_sink_impl(size_t itemsize, char *address, bool blocking)
+    push_sink_impl::push_sink_impl(size_t itemsize, size_t vlen, char *address, bool blocking)
       : gr::sync_block("push_sink",
-                       gr::io_signature::make(1, 1, itemsize),
+                       gr::io_signature::make(1, 1, itemsize * vlen),
                        gr::io_signature::make(0, 0, 0)),
         d_itemsize(itemsize)
     {
diff --git a/gr-zeromq/lib/push_sink_impl.h b/gr-zeromq/lib/push_sink_impl.h
index 010261817d..77f1f60c8d 100644
--- a/gr-zeromq/lib/push_sink_impl.h
+++ b/gr-zeromq/lib/push_sink_impl.h
@@ -38,7 +38,7 @@ namespace gr {
       zmq::socket_t   *d_socket;
 
     public:
-      push_sink_impl(size_t itemsize, char *address, bool blocking);
+      push_sink_impl(size_t itemsize, size_t vlen, char *address, bool blocking);
       ~push_sink_impl();
 
       int work(int noutput_items,
diff --git a/gr-zeromq/lib/rep_sink_impl.cc b/gr-zeromq/lib/rep_sink_impl.cc
index abd4e6d5a7..38bb7d779e 100644
--- a/gr-zeromq/lib/rep_sink_impl.cc
+++ b/gr-zeromq/lib/rep_sink_impl.cc
@@ -31,15 +31,15 @@ namespace gr {
   namespace zeromq {
 
     rep_sink::sptr
-    rep_sink::make(size_t itemsize, char *address, float timeout, bool blocking)
+    rep_sink::make(size_t itemsize, size_t vlen, char *address, float timeout, bool blocking)
     {
       return gnuradio::get_initial_sptr
-        (new rep_sink_impl(itemsize, address, timeout, blocking));
+        (new rep_sink_impl(itemsize, vlen, address, timeout, blocking));
     }
 
-    rep_sink_impl::rep_sink_impl(size_t itemsize, char *address, float timeout, bool blocking)
+    rep_sink_impl::rep_sink_impl(size_t itemsize, size_t vlen, char *address, float timeout, bool blocking)
       : gr::sync_block("rep_sink",
-		       gr::io_signature::make(1, 1, itemsize),
+		       gr::io_signature::make(1, 1, itemsize * vlen),
 		       gr::io_signature::make(0, 0, 0)),
         d_itemsize(itemsize), d_blocking(blocking)
     {
diff --git a/gr-zeromq/lib/rep_sink_impl.h b/gr-zeromq/lib/rep_sink_impl.h
index ad2db2a081..0996d53616 100644
--- a/gr-zeromq/lib/rep_sink_impl.h
+++ b/gr-zeromq/lib/rep_sink_impl.h
@@ -39,7 +39,7 @@ namespace gr {
       bool            d_blocking;
 
     public:
-      rep_sink_impl(size_t itemsize, char *address, float timeout, bool blocking);
+      rep_sink_impl(size_t itemsize, size_t vlen, char *address, float timeout, bool blocking);
       ~rep_sink_impl();
 
       int work(int noutput_items,
diff --git a/gr-zeromq/lib/source_reqrep_impl.cc b/gr-zeromq/lib/source_reqrep_impl.cc
index 1674955ddb..c6aee7cdd2 100644
--- a/gr-zeromq/lib/source_reqrep_impl.cc
+++ b/gr-zeromq/lib/source_reqrep_impl.cc
@@ -31,16 +31,16 @@ namespace gr {
   namespace zeromq {
 
     source_reqrep::sptr
-    source_reqrep::make(size_t itemsize, char *address)
+    source_reqrep::make(size_t itemsize, size_t vlen, char *address)
     {
       return gnuradio::get_initial_sptr
-        (new source_reqrep_impl(itemsize, address));
+        (new source_reqrep_impl(itemsize, vlen, address));
     }
 
-    source_reqrep_impl::source_reqrep_impl(size_t itemsize, char *address)
+    source_reqrep_impl::source_reqrep_impl(size_t itemsize, size_t vlen, char *address)
       : gr::sync_block("source_reqrep",
 		       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_context = new zmq::context_t(1);
diff --git a/gr-zeromq/lib/source_reqrep_impl.h b/gr-zeromq/lib/source_reqrep_impl.h
index a1e3bc6438..544549f6ce 100644
--- a/gr-zeromq/lib/source_reqrep_impl.h
+++ b/gr-zeromq/lib/source_reqrep_impl.h
@@ -37,7 +37,7 @@ namespace gr {
       zmq::socket_t   *d_socket;
 
     public:
-      source_reqrep_impl(size_t itemsize, char *address);
+      source_reqrep_impl(size_t itemsize, size_t vlen, char *address);
       ~source_reqrep_impl();
 
       int work(int noutput_items,