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/udp_source_impl.h | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/udp_source_impl.h')
| -rw-r--r-- | gr-blocks/lib/udp_source_impl.h | 79 |
1 files changed, 39 insertions, 40 deletions
diff --git a/gr-blocks/lib/udp_source_impl.h b/gr-blocks/lib/udp_source_impl.h index 5b4b6996ab..a1f0b3b06d 100644 --- a/gr-blocks/lib/udp_source_impl.h +++ b/gr-blocks/lib/udp_source_impl.h @@ -29,57 +29,56 @@ #include <gnuradio/thread/thread.h> namespace gr { - namespace blocks { +namespace blocks { - class udp_source_impl : public udp_source - { - private: - size_t d_itemsize; - int d_payload_size; // maximum transmission unit (packet length) - bool d_eof; // look for an EOF signal - bool d_connected; // are we connected? - char *d_rxbuf; // get UDP buffer items - char *d_residbuf; // hold buffer between calls - ssize_t d_residual; // hold information about number of bytes stored in residbuf - ssize_t d_sent; // track how much of d_residbuf we've outputted +class udp_source_impl : public udp_source +{ +private: + size_t d_itemsize; + int d_payload_size; // maximum transmission unit (packet length) + bool d_eof; // look for an EOF signal + bool d_connected; // are we connected? + char* d_rxbuf; // get UDP buffer items + char* d_residbuf; // hold buffer between calls + ssize_t d_residual; // hold information about number of bytes stored in residbuf + ssize_t d_sent; // track how much of d_residbuf we've outputted - static const int BUF_SIZE_PAYLOADS; //!< The d_residbuf size in multiples of d_payload_size + static const int + BUF_SIZE_PAYLOADS; //!< The d_residbuf size in multiples of d_payload_size - std::string d_host; - unsigned short d_port; + std::string d_host; + unsigned short d_port; - boost::asio::ip::udp::socket *d_socket; - boost::asio::ip::udp::endpoint d_endpoint; - boost::asio::ip::udp::endpoint d_endpoint_rcvd; - boost::asio::io_service d_io_service; + boost::asio::ip::udp::socket* d_socket; + boost::asio::ip::udp::endpoint d_endpoint; + boost::asio::ip::udp::endpoint d_endpoint_rcvd; + boost::asio::io_service d_io_service; - gr::thread::condition_variable d_cond_wait; - gr::thread::mutex d_udp_mutex; - gr::thread::thread d_udp_thread; + gr::thread::condition_variable d_cond_wait; + gr::thread::mutex d_udp_mutex; + gr::thread::thread d_udp_thread; - void start_receive(); - void handle_read(const boost::system::error_code& error, - size_t bytes_transferred); - void run_io_service() { d_io_service.run(); } + void start_receive(); + void handle_read(const boost::system::error_code& error, size_t bytes_transferred); + void run_io_service() { d_io_service.run(); } - public: - udp_source_impl(size_t itemsize, - const std::string &host, int port, - int payload_size, bool eof); - ~udp_source_impl(); +public: + udp_source_impl( + size_t itemsize, const std::string& host, int port, int payload_size, bool eof); + ~udp_source_impl(); - void connect(const std::string &host, int port); - void disconnect(); + void connect(const std::string& host, int port); + void disconnect(); - int payload_size() { return d_payload_size; } - int get_port(); + int payload_size() { return d_payload_size; } + int get_port(); - 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_UDP_SOURCE_H */ |