summaryrefslogtreecommitdiff
path: root/gr-zeromq/lib
diff options
context:
space:
mode:
Diffstat (limited to 'gr-zeromq/lib')
-rw-r--r--gr-zeromq/lib/CMakeLists.txt2
-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 */