diff options
Diffstat (limited to 'gr-blocks/lib/tcp_server_sink_impl.h')
-rw-r--r-- | gr-blocks/lib/tcp_server_sink_impl.h | 64 |
1 files changed, 33 insertions, 31 deletions
diff --git a/gr-blocks/lib/tcp_server_sink_impl.h b/gr-blocks/lib/tcp_server_sink_impl.h index db26b705fe..6c4b0f938f 100644 --- a/gr-blocks/lib/tcp_server_sink_impl.h +++ b/gr-blocks/lib/tcp_server_sink_impl.h @@ -29,45 +29,47 @@ #include <boost/ptr_container/ptr_vector.hpp> namespace gr { - namespace blocks { +namespace blocks { - class tcp_server_sink_impl : public tcp_server_sink - { - private: - size_t d_itemsize; +class tcp_server_sink_impl : public tcp_server_sink +{ +private: + 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<boost::asio::ip::tcp::socket *> d_sockets; - boost::asio::ip::tcp::acceptor d_acceptor; + 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<boost::asio::ip::tcp::socket*> d_sockets; + boost::asio::ip::tcp::acceptor d_acceptor; - boost::shared_ptr<uint8_t[]> d_buf; - enum { - BUF_SIZE = 256 * 1024, - }; + boost::shared_ptr<uint8_t[]> d_buf; + enum { + BUF_SIZE = 256 * 1024, + }; - int d_writing; - boost::condition_variable d_writing_cond; - boost::mutex d_writing_mut; + 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<boost::asio::ip::tcp::socket *>::iterator); + void do_accept(const boost::system::error_code& error); + void do_write(const boost::system::error_code& error, + std::size_t len, + std::set<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(); +public: + tcp_server_sink_impl(size_t itemsize, + const std::string& host, + int port, + bool noblock); + ~tcp_server_sink_impl(); - int work(int noutput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items); - }; + int work(int noutput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items); +}; - } /* namespace blocks */ +} /* namespace blocks */ } /* namespace gr */ #endif /* INCLUDED_GR_TCP_SERVER_SINK_IMPL_H */ |