11#ifndef INCLUDED_NETWORK_SOCKET_PDU_IMPL_H
12#define INCLUDED_NETWORK_SOCKET_PDU_IMPL_H
23 boost::asio::io_service d_io_service;
24 std::vector<char> d_rxbuf;
25 void run_io_service() { d_io_service.run(); }
30 boost::asio::ip::tcp::endpoint d_tcp_endpoint;
31 std::vector<tcp_connection::sptr> d_tcp_connections;
32 void handle_tcp_read(
const boost::system::error_code& error,
33 size_t bytes_transferred);
34 const bool d_tcp_no_delay;
37 std::shared_ptr<boost::asio::ip::tcp::acceptor> d_acceptor_tcp;
38 void start_tcp_accept();
41 const boost::system::error_code& error);
44 std::shared_ptr<boost::asio::ip::tcp::socket> d_tcp_socket;
48 boost::asio::ip::udp::endpoint d_udp_endpoint;
49 boost::asio::ip::udp::endpoint d_udp_endpoint_other;
50 std::shared_ptr<boost::asio::ip::udp::socket> d_udp_socket;
51 void handle_udp_read(
const boost::system::error_code& error,
52 size_t bytes_transferred);
60 bool tcp_no_delay =
false);
Definition: socket_pdu_impl.h:21
~socket_pdu_impl() override
socket_pdu_impl(std::string type, std::string addr, std::string port, int MTU=10000, bool tcp_no_delay=false)
bool stop() override
Called to disable drivers, etc for i/o devices.
Creates socket interface and translates traffic to PDUs.
Definition: socket_pdu.h:25
std::shared_ptr< tcp_connection > sptr
Definition: tcp_connection.h:40
GR_RUNTIME_API const pmt::pmt_t msg()
boost::thread thread
Definition: thread.h:36
GNU Radio logging wrapper.
Definition: basic_block.h:29
std::shared_ptr< pmt_base > pmt_t
typedef for shared pointer (transparent reference counting).
Definition: pmt.h:84