diff options
| author | Marcus Müller <mmueller@gnuradio.org> | 2019-08-07 21:45:12 +0200 |
|---|---|---|
| committer | Marcus Müller <marcus@hostalia.de> | 2019-08-09 23:04:28 +0200 |
| commit | f7bbf2c1d8d780294f3e016aff239ca35eb6516e (patch) | |
| tree | e09ab6112e02b2215b2d59ac24d3d6ea2edac745 /gr-blocks/lib/socket_pdu_impl.h | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/socket_pdu_impl.h')
| -rw-r--r-- | gr-blocks/lib/socket_pdu_impl.h | 75 |
1 files changed, 41 insertions, 34 deletions
diff --git a/gr-blocks/lib/socket_pdu_impl.h b/gr-blocks/lib/socket_pdu_impl.h index ad42996cd1..c05ef7bbc9 100644 --- a/gr-blocks/lib/socket_pdu_impl.h +++ b/gr-blocks/lib/socket_pdu_impl.h @@ -27,47 +27,54 @@ #include "tcp_connection.h" namespace gr { - namespace blocks { +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; +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); - bool d_tcp_no_delay; + // 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); + bool d_tcp_no_delay; - // TCP server specific - boost::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 server specific + boost::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 - boost::shared_ptr<boost::asio::ip::tcp::socket> d_tcp_socket; - void tcp_client_send(pmt::pmt_t msg); + // TCP client specific + boost::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; - boost::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); + // UDP specific + boost::asio::ip::udp::endpoint d_udp_endpoint; + boost::asio::ip::udp::endpoint d_udp_endpoint_other; + boost::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(); - bool stop(); - }; +public: + socket_pdu_impl(std::string type, + std::string addr, + std::string port, + int MTU = 10000, + bool tcp_no_delay = false); + ~socket_pdu_impl(); + bool stop(); +}; - } /* namespace blocks */ +} /* namespace blocks */ } /* namespace gr */ #endif /* INCLUDED_BLOCKS_SOCKET_PDU_IMPL_H */ |