diff options
| author | Josh Morman <jmorman@perspectalabs.com> | 2021-03-25 10:43:14 -0400 |
|---|---|---|
| committer | mormj <34754695+mormj@users.noreply.github.com> | 2021-04-21 14:02:57 -0400 |
| commit | 50c48b3321d59ff6fa296d672a723787f32e5345 (patch) | |
| tree | 1f086658b3d4392caa98b99d466fead77c05e981 /gr-blocks/lib/udp_source_impl.cc | |
| parent | d71c4550e04f74b09fba0bbe8d7cd07dda68ba35 (diff) | |
blocks: remove deprecated network blocks
Signed-off-by: Josh Morman <jmorman@perspectalabs.com>
Diffstat (limited to 'gr-blocks/lib/udp_source_impl.cc')
| -rw-r--r-- | gr-blocks/lib/udp_source_impl.cc | 200 |
1 files changed, 0 insertions, 200 deletions
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 */ |