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/tcp_server_sink_impl.h | |
parent | d71c4550e04f74b09fba0bbe8d7cd07dda68ba35 (diff) |
blocks: remove deprecated network blocks
Signed-off-by: Josh Morman <jmorman@perspectalabs.com>
Diffstat (limited to 'gr-blocks/lib/tcp_server_sink_impl.h')
-rw-r--r-- | gr-blocks/lib/tcp_server_sink_impl.h | 63 |
1 files changed, 0 insertions, 63 deletions
diff --git a/gr-blocks/lib/tcp_server_sink_impl.h b/gr-blocks/lib/tcp_server_sink_impl.h deleted file mode 100644 index b7ff7af174..0000000000 --- a/gr-blocks/lib/tcp_server_sink_impl.h +++ /dev/null @@ -1,63 +0,0 @@ -/* -*- c++ -*- */ -/* - * Copyright 2014 Free Software Foundation, Inc. - * - * This file is part of GNU Radio - * - * SPDX-License-Identifier: GPL-3.0-or-later - * - */ - -#ifndef INCLUDED_GR_TCP_SERVER_SINK_IMPL_H -#define INCLUDED_GR_TCP_SERVER_SINK_IMPL_H - -#include <gnuradio/blocks/tcp_server_sink.h> -#include <boost/asio.hpp> -#include <boost/ptr_container/ptr_vector.hpp> -#include <set> - -namespace gr { -namespace blocks { - -class tcp_server_sink_impl : public tcp_server_sink -{ -private: - const size_t d_itemsize; - - boost::asio::io_service d_io_service; - gr::thread::thread d_io_serv_thread; - boost::asio::ip::tcp::endpoint d_endpoint; - std::unique_ptr<boost::asio::ip::tcp::socket> d_socket; - std::set<std::unique_ptr<boost::asio::ip::tcp::socket>> d_sockets; - boost::asio::ip::tcp::acceptor d_acceptor; - - enum { - BUF_SIZE = 256 * 1024, - }; - std::array<uint8_t, BUF_SIZE> d_buf; - - int d_writing; - boost::condition_variable d_writing_cond; - boost::mutex d_writing_mut; - - void do_accept(const boost::system::error_code& error); - void do_write(const boost::system::error_code& error, - std::size_t len, - std::set<std::unique_ptr<boost::asio::ip::tcp::socket>>::iterator); - -public: - tcp_server_sink_impl(size_t itemsize, - const std::string& host, - int port, - bool noblock); - ~tcp_server_sink_impl() 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_TCP_SERVER_SINK_IMPL_H */ |