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.h | |
| 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.h')
| -rw-r--r-- | gr-blocks/lib/udp_source_impl.h | 75 |
1 files changed, 0 insertions, 75 deletions
diff --git a/gr-blocks/lib/udp_source_impl.h b/gr-blocks/lib/udp_source_impl.h deleted file mode 100644 index a2dc2dc9dc..0000000000 --- a/gr-blocks/lib/udp_source_impl.h +++ /dev/null @@ -1,75 +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 - * - */ - -#ifndef INCLUDED_GR_UDP_SOURCE_IMPL_H -#define INCLUDED_GR_UDP_SOURCE_IMPL_H - -#include <gnuradio/blocks/udp_source.h> -#include <gnuradio/thread/thread.h> -#include <boost/asio.hpp> -#include <boost/format.hpp> -#include <cstddef> -#include <memory> - -namespace gr { -namespace blocks { - -class udp_source_impl : public udp_source -{ -private: - const size_t d_itemsize; - int d_payload_size; // maximum transmission unit (packet length) - const bool d_eof; // look for an EOF signal - bool d_connected; // are we connected? - std::vector<char> d_rxbuf; // get UDP buffer items - std::vector<char> d_residbuf; // hold buffer between calls - std::ptrdiff_t - d_residual; // hold information about number of bytes stored in residbuf - size_t d_sent; // track how much of d_residbuf we've outputted - - static const int - BUF_SIZE_PAYLOADS; //!< The d_residbuf size in multiples of d_payload_size - - std::string d_host; - unsigned short d_port; - - std::unique_ptr<boost::asio::ip::udp::socket> d_socket; - boost::asio::ip::udp::endpoint d_endpoint; - boost::asio::ip::udp::endpoint d_endpoint_rcvd; - boost::asio::io_service d_io_service; - - gr::thread::condition_variable d_cond_wait; - gr::thread::mutex d_udp_mutex; - gr::thread::thread d_udp_thread; - - void start_receive(); - void handle_read(const boost::system::error_code& error, size_t bytes_transferred); - void run_io_service() { d_io_service.run(); } - -public: - udp_source_impl( - size_t itemsize, const std::string& host, int port, int payload_size, bool eof); - ~udp_source_impl() override; - - void connect(const std::string& host, int port) override; - void disconnect() override; - - int payload_size() override { return d_payload_size; } - int get_port() override; - - int work(int noutput_items, - gr_vector_const_void_star& input_items, - gr_vector_void_star& output_items) override; -}; - -} /* namespace blocks */ -} /* namespace gr */ - -#endif /* INCLUDED_GR_UDP_SOURCE_H */ |