diff options
Diffstat (limited to 'gr-zeromq/lib')
-rw-r--r-- | gr-zeromq/lib/CMakeLists.txt | 2 | ||||
-rw-r--r-- | gr-zeromq/lib/req_source_impl.cc (renamed from gr-zeromq/lib/source_reqrep_impl.cc) | 16 | ||||
-rw-r--r-- | gr-zeromq/lib/req_source_impl.h (renamed from gr-zeromq/lib/source_reqrep_impl.h) | 14 |
3 files changed, 16 insertions, 16 deletions
diff --git a/gr-zeromq/lib/CMakeLists.txt b/gr-zeromq/lib/CMakeLists.txt index 5e3c170609..95ecc70845 100644 --- a/gr-zeromq/lib/CMakeLists.txt +++ b/gr-zeromq/lib/CMakeLists.txt @@ -42,8 +42,8 @@ list(APPEND zeromq_sources pull_source_impl.cc push_sink_impl.cc rep_sink_impl.cc + req_source_impl.cc sink_reqrep_nopoll_impl.cc - source_reqrep_impl.cc source_reqrep_nopoll_impl.cc ) diff --git a/gr-zeromq/lib/source_reqrep_impl.cc b/gr-zeromq/lib/req_source_impl.cc index c6aee7cdd2..ffe31f9953 100644 --- a/gr-zeromq/lib/source_reqrep_impl.cc +++ b/gr-zeromq/lib/req_source_impl.cc @@ -25,20 +25,20 @@ #endif #include <gnuradio/io_signature.h> -#include "source_reqrep_impl.h" +#include "req_source_impl.h" namespace gr { namespace zeromq { - source_reqrep::sptr - source_reqrep::make(size_t itemsize, size_t vlen, char *address) + req_source::sptr + req_source::make(size_t itemsize, size_t vlen, char *address) { return gnuradio::get_initial_sptr - (new source_reqrep_impl(itemsize, vlen, address)); + (new req_source_impl(itemsize, vlen, address)); } - source_reqrep_impl::source_reqrep_impl(size_t itemsize, size_t vlen, char *address) - : gr::sync_block("source_reqrep", + req_source_impl::req_source_impl(size_t itemsize, size_t vlen, char *address) + : gr::sync_block("req_source", gr::io_signature::make(0, 0, 0), gr::io_signature::make(1, 1, itemsize * vlen)), d_itemsize(itemsize) @@ -48,14 +48,14 @@ namespace gr { d_socket->connect (address); } - source_reqrep_impl::~source_reqrep_impl() + req_source_impl::~req_source_impl() { delete d_socket; delete d_context; } int - source_reqrep_impl::work(int noutput_items, + req_source_impl::work(int noutput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items) { diff --git a/gr-zeromq/lib/source_reqrep_impl.h b/gr-zeromq/lib/req_source_impl.h index 544549f6ce..6c87b48bca 100644 --- a/gr-zeromq/lib/source_reqrep_impl.h +++ b/gr-zeromq/lib/req_source_impl.h @@ -20,16 +20,16 @@ * Boston, MA 02110-1301, USA. */ -#ifndef INCLUDED_ZMQBLOCKS_SOURCE_REQREP_IMPL_H -#define INCLUDED_ZMQBLOCKS_SOURCE_REQREP_IMPL_H +#ifndef INCLUDED_ZMQBLOCKS_REQ_SOURCE_IMPL_H +#define INCLUDED_ZMQBLOCKS_REQ_SOURCE_IMPL_H -#include <gnuradio/zeromq/source_reqrep.h> +#include <gnuradio/zeromq/req_source.h> #include <zmq.hpp> namespace gr { namespace zeromq { - class source_reqrep_impl : public source_reqrep + class req_source_impl : public req_source { private: size_t d_itemsize; @@ -37,8 +37,8 @@ namespace gr { zmq::socket_t *d_socket; public: - source_reqrep_impl(size_t itemsize, size_t vlen, char *address); - ~source_reqrep_impl(); + req_source_impl(size_t itemsize, size_t vlen, char *address); + ~req_source_impl(); int work(int noutput_items, gr_vector_const_void_star &input_items, @@ -48,4 +48,4 @@ namespace gr { } // namespace zeromq } // namespace gr -#endif /* INCLUDED_ZMQBLOCKS_SOURCE_REQREP_IMPL_H */ +#endif /* INCLUDED_ZMQBLOCKS_REQ_SOURCE_IMPL_H */ |