From 50c48b3321d59ff6fa296d672a723787f32e5345 Mon Sep 17 00:00:00 2001
From: Josh Morman <jmorman@perspectalabs.com>
Date: Thu, 25 Mar 2021 10:43:14 -0400
Subject: blocks: remove deprecated network blocks
Signed-off-by: Josh Morman <jmorman@perspectalabs.com>
---
gr-blocks/lib/udp_source_impl.cc | 200 ---------------------------------------
1 file changed, 200 deletions(-)
delete mode 100644 gr-blocks/lib/udp_source_impl.cc
(limited to 'gr-blocks/lib/udp_source_impl.cc')
diff --git a/gr-blocks/lib/udp_source_impl.cc b/gr-blocks/lib/udp_source_impl.cc
deleted file mode 100644
index 11765de504..0000000000
--- a/gr-blocks/lib/udp_source_impl.cc
+++ /dev/null
@@ -1,200 +0,0 @@
-/* -*- c++ -*- */
-/*
- * Copyright 2007-2010,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 "udp_source_impl.h"
-#include <gnuradio/io_signature.h>
-#include <gnuradio/math.h>
-#include <gnuradio/prefs.h>
-#include <cstddef>
-#include <cstring>
-#include <memory>
-
-namespace gr {
-namespace blocks {
-
-const int udp_source_impl::BUF_SIZE_PAYLOADS =
- gr::prefs::singleton()->get_long("udp_blocks", "buf_size_payloads", 50);
-
-udp_source::sptr udp_source::make(
- size_t itemsize, const std::string& ipaddr, int port, int payload_size, bool eof)
-{
- return gnuradio::make_block_sptr<udp_source_impl>(
- itemsize, ipaddr, port, payload_size, eof);
-}
-
-udp_source_impl::udp_source_impl(
- size_t itemsize, const std::string& host, int port, int payload_size, bool eof)
- : sync_block(
- "udp_source", io_signature::make(0, 0, 0), io_signature::make(1, 1, itemsize)),
- d_itemsize(itemsize),
- d_payload_size(payload_size),
- d_eof(eof),
- d_connected(false),
- d_rxbuf(4 * payload_size),
- d_residbuf(BUF_SIZE_PAYLOADS * payload_size),
- d_residual(0),
- d_sent(0)
-{
- connect(host, port);
-}
-
-udp_source_impl::~udp_source_impl()
-{
- if (d_connected)
- disconnect();
-}
-
-void udp_source_impl::connect(const std::string& host, int port)
-{
- if (d_connected)
- disconnect();
-
- d_host = host;
- d_port = static_cast<unsigned short>(port);
-
- std::string s_port;
- s_port = (boost::format("%d") % d_port).str();
-
- if (!host.empty()) {
- boost::asio::ip::udp::resolver resolver(d_io_service);
- boost::asio::ip::udp::resolver::query query(
- d_host, s_port, boost::asio::ip::resolver_query_base::passive);
- d_endpoint = *resolver.resolve(query);
-
- d_socket = std::make_unique<boost::asio::ip::udp::socket>(d_io_service);
- d_socket->open(d_endpoint.protocol());
-
- boost::asio::socket_base::reuse_address roption(true);
- d_socket->set_option(roption);
-
- d_socket->bind(d_endpoint);
-
- start_receive();
- d_udp_thread =
- gr::thread::thread(boost::bind(&udp_source_impl::run_io_service, this));
- d_connected = true;
- }
-}
-
-void udp_source_impl::disconnect()
-{
- gr::thread::scoped_lock lock(d_setlock);
-
- if (!d_connected)
- return;
-
- d_io_service.reset();
- d_io_service.stop();
- d_udp_thread.join();
-
- d_socket->close();
- d_socket.reset();
-
- d_connected = false;
-}
-
-// Return port number of d_socket
-int udp_source_impl::get_port(void)
-{
- // return d_endpoint.port();
- return d_socket->local_endpoint().port();
-}
-
-void udp_source_impl::start_receive()
-{
- d_socket->async_receive_from(
- boost::asio::buffer((void*)d_rxbuf.data(), d_payload_size),
- d_endpoint_rcvd,
- boost::bind(&udp_source_impl::handle_read,
- this,
- boost::asio::placeholders::error,
- boost::asio::placeholders::bytes_transferred));
-}
-
-void udp_source_impl::handle_read(const boost::system::error_code& error,
- size_t bytes_transferred)
-{
- if (!error) {
- {
- boost::lock_guard<gr::thread::mutex> lock(d_udp_mutex);
- if (d_eof && (bytes_transferred == 0)) {
- // If we are using EOF notification, test for it and don't
- // add anything to the output.
- d_residual = WORK_DONE;
- d_cond_wait.notify_one();
- return;
- } else {
- // Make sure we never go beyond the boundary of the
- // residual buffer. This will just drop the last bit of
- // data in the buffer if we've run out of room.
- if ((int)(d_residual + bytes_transferred) >=
- (BUF_SIZE_PAYLOADS * d_payload_size)) {
- GR_LOG_WARN(d_logger, "Too much data; dropping packet.");
- } else {
- // otherwise, copy received data into local buffer for
- // copying later.
- memcpy(d_residbuf.data() + d_residual,
- d_rxbuf.data(),
- bytes_transferred);
- d_residual += bytes_transferred;
- }
- }
- d_cond_wait.notify_one();
- }
- }
- start_receive();
-}
-
-int udp_source_impl::work(int noutput_items,
- gr_vector_const_void_star& input_items,
- gr_vector_void_star& output_items)
-{
- gr::thread::scoped_lock l(d_setlock);
-
- char* out = (char*)output_items[0];
-
- // Use async receive_from to get data from UDP buffer and wait
- // on a conditional signal before proceeding. We use this
- // because the conditional wait is interruptible while a
- // synchronous receive_from is not.
- boost::unique_lock<boost::mutex> lock(d_udp_mutex);
-
- // use timed_wait to avoid permanent blocking in the work function
- d_cond_wait.timed_wait(lock, boost::posix_time::milliseconds(10));
-
- if (d_residual < 0) {
- return d_residual;
- }
-
- const std::ptrdiff_t bytes_left_in_buffer = d_residual - d_sent;
- auto bytes_to_send =
- std::min<std::ptrdiff_t>(d_itemsize * noutput_items, bytes_left_in_buffer);
-
- // Copy the received data in the residual buffer to the output stream
- memcpy(out, d_residbuf.data() + d_sent, bytes_to_send);
-
- // Keep track of where we are if we don't have enough output
- // space to send all the data in the residbuf.
- if (bytes_to_send == bytes_left_in_buffer) {
- d_residual = 0;
- d_sent = 0;
- } else {
- d_sent += bytes_to_send;
- }
-
- return bytes_to_send / d_itemsize;
-}
-
-} /* namespace blocks */
-} /* namespace gr */
--
cgit v1.2.3