summaryrefslogtreecommitdiff
path: root/gr-blocks/lib/socket_pdu_impl.h
diff options
context:
space:
mode:
Diffstat (limited to 'gr-blocks/lib/socket_pdu_impl.h')
-rw-r--r--gr-blocks/lib/socket_pdu_impl.h68
1 files changed, 0 insertions, 68 deletions
diff --git a/gr-blocks/lib/socket_pdu_impl.h b/gr-blocks/lib/socket_pdu_impl.h
deleted file mode 100644
index d885c665c4..0000000000
--- a/gr-blocks/lib/socket_pdu_impl.h
+++ /dev/null
@@ -1,68 +0,0 @@
-/* -*- c++ -*- */
-/*
- * Copyright 2013 Free Software Foundation, Inc.
- *
- * This file is part of GNU Radio
- *
- * SPDX-License-Identifier: GPL-3.0-or-later
- *
- */
-
-#ifndef INCLUDED_BLOCKS_SOCKET_PDU_IMPL_H
-#define INCLUDED_BLOCKS_SOCKET_PDU_IMPL_H
-
-#include "tcp_connection.h"
-#include <gnuradio/blocks/socket_pdu.h>
-
-namespace gr {
-namespace blocks {
-
-class socket_pdu_impl : public socket_pdu
-{
-private:
- boost::asio::io_service d_io_service;
- std::vector<char> d_rxbuf;
- void run_io_service() { d_io_service.run(); }
- gr::thread::thread d_thread;
- bool d_started;
-
- // TCP specific
- boost::asio::ip::tcp::endpoint d_tcp_endpoint;
- std::vector<tcp_connection::sptr> d_tcp_connections;
- void handle_tcp_read(const boost::system::error_code& error,
- size_t bytes_transferred);
- const bool d_tcp_no_delay;
-
- // TCP server specific
- std::shared_ptr<boost::asio::ip::tcp::acceptor> d_acceptor_tcp;
- void start_tcp_accept();
- void tcp_server_send(pmt::pmt_t msg);
- void handle_tcp_accept(tcp_connection::sptr new_connection,
- const boost::system::error_code& error);
-
- // TCP client specific
- std::shared_ptr<boost::asio::ip::tcp::socket> d_tcp_socket;
- void tcp_client_send(pmt::pmt_t msg);
-
- // UDP specific
- boost::asio::ip::udp::endpoint d_udp_endpoint;
- boost::asio::ip::udp::endpoint d_udp_endpoint_other;
- std::shared_ptr<boost::asio::ip::udp::socket> d_udp_socket;
- void handle_udp_read(const boost::system::error_code& error,
- size_t bytes_transferred);
- void udp_send(pmt::pmt_t msg);
-
-public:
- socket_pdu_impl(std::string type,
- std::string addr,
- std::string port,
- int MTU = 10000,
- bool tcp_no_delay = false);
- ~socket_pdu_impl() override;
- bool stop() override;
-};
-
-} /* namespace blocks */
-} /* namespace gr */
-
-#endif /* INCLUDED_BLOCKS_SOCKET_PDU_IMPL_H */