aboutsummaryrefslogtreecommitdiffstats
path: root/blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc
diff options
context:
space:
mode:
authorJosh Morman <jmorman@gnuradio.org>2022-11-10 11:44:53 -0500
committerJosh Morman <jmorman@gnuradio.org>2022-11-10 11:44:55 -0500
commitb5b05f7c2a5e708db525fa8c3ef7ff2f1f7816d3 (patch)
tree5e202f5275b199dee99d37221c0690c63e748935 /blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc
parentfilter: pfb_arb_resampler updated to new block api and use optfir (diff)
downloadgnuradio-dev-4.0-minimal.tar.xz
gnuradio-dev-4.0-minimal.zip
global: strip down to minimal filesetdev-4.0-minimal
As a separate branch to start incorporating broader refactoring changes Signed-off-by: Josh Morman <jmorman@gnuradio.org>
Diffstat (limited to 'blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc')
-rw-r--r--blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc50
1 files changed, 0 insertions, 50 deletions
diff --git a/blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc b/blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc
deleted file mode 100644
index dd044868d..000000000
--- a/blocklib/zeromq/push_msg_sink/push_msg_sink_cpu.cc
+++ /dev/null
@@ -1,50 +0,0 @@
-/* -*- c++ -*- */
-/*
- * Copyright 2013,2014 Free Software Foundation, Inc.
- * Copyright 2022 Josh Morman
- *
- * This file is part of GNU Radio
- *
- * SPDX-License-Identifier: GPL-3.0-or-later
- *
- */
-
-#include "push_msg_sink_cpu.h"
-#include "push_msg_sink_cpu_gen.h"
-
-namespace {
-constexpr int LINGER_DEFAULT = 1000; // 1 second.
-}
-
-namespace gr {
-namespace zeromq {
-
-push_msg_sink_cpu::push_msg_sink_cpu(block_args args)
- : INHERITED_CONSTRUCTORS,
- d_timeout(args.timeout),
- d_context(1),
- d_socket(d_context, ZMQ_PUSH)
-{
-
- d_socket.set(zmq::sockopt::linger, LINGER_DEFAULT);
-
- if (args.bind) {
- d_socket.bind(args.address);
- }
- else {
- d_socket.connect(args.address);
- }
-}
-
-void push_msg_sink_cpu::handle_msg_in(pmtf::pmt msg)
-{
- std::stringbuf sb("");
- msg.serialize(sb);
- std::string s = sb.str();
- zmq::message_t zmsg(s.size());
- memcpy(zmsg.data(), s.c_str(), s.size());
- d_socket.send(zmsg, zmq::send_flags::none);
-}
-
-} // namespace zeromq
-} // namespace gr \ No newline at end of file