summaryrefslogtreecommitdiff
path: root/gr-blocks/lib/pdu_set_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gr-blocks/lib/pdu_set_impl.cc')
-rw-r--r--gr-blocks/lib/pdu_set_impl.cc52
1 files changed, 0 insertions, 52 deletions
diff --git a/gr-blocks/lib/pdu_set_impl.cc b/gr-blocks/lib/pdu_set_impl.cc
deleted file mode 100644
index 70a8487720..0000000000
--- a/gr-blocks/lib/pdu_set_impl.cc
+++ /dev/null
@@ -1,52 +0,0 @@
-/* -*- c++ -*- */
-/*
- * Copyright 2013 Free Software Foundation, Inc.
- *
- * This file is part of GNU Radio
- *
- * SPDX-License-Identifier: GPL-3.0-or-later
- *
- */
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include "pdu_set_impl.h"
-#include <gnuradio/blocks/pdu.h>
-#include <gnuradio/io_signature.h>
-
-namespace gr {
-namespace blocks {
-
-pdu_set::sptr pdu_set::make(pmt::pmt_t k, pmt::pmt_t v)
-{
- return gnuradio::make_block_sptr<pdu_set_impl>(k, v);
-}
-
-pdu_set_impl::pdu_set_impl(pmt::pmt_t k, pmt::pmt_t v)
- : block("pdu_set", io_signature::make(0, 0, 0), io_signature::make(0, 0, 0)),
- d_k(k),
- d_v(v)
-{
- message_port_register_out(pdu::pdu_port_id());
- message_port_register_in(pdu::pdu_port_id());
- set_msg_handler(pdu::pdu_port_id(),
- [this](pmt::pmt_t msg) { this->handle_msg(msg); });
-}
-
-void pdu_set_impl::handle_msg(pmt::pmt_t pdu)
-{
- // add the field and publish
- pmt::pmt_t meta = pmt::car(pdu);
- if (pmt::is_null(meta)) {
- meta = pmt::make_dict();
- } else if (!pmt::is_dict(meta)) {
- throw std::runtime_error("pdu_set received non PDU input");
- }
- meta = pmt::dict_add(meta, d_k, d_v);
- message_port_pub(pdu::pdu_port_id(), pmt::cons(meta, pmt::cdr(pdu)));
-}
-
-} /* namespace blocks */
-} /* namespace gr */