diff options
| author | Camilo Solano <solano@ti.rwth-aachen.de> | 2014-05-06 18:38:43 +0200 |
|---|---|---|
| committer | Camilo Solano <solano@ti.rwth-aachen.de> | 2014-05-06 18:38:43 +0200 |
| commit | edd1405c7f2bcd79e8fb5aa72189e13a37c1ed02 (patch) | |
| tree | b177320d78a4fbb897d2c60daa6787078967412e /gr-zeromq/lib/pull_source_impl.cc | |
| parent | aec45a60b208d045daf766b18631159094cb1042 (diff) | |
Add vlen
Diffstat (limited to 'gr-zeromq/lib/pull_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/pull_source_impl.cc | 8 |
1 files changed, 4 insertions, 4 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; |