From f7bbf2c1d8d780294f3e016aff239ca35eb6516e Mon Sep 17 00:00:00 2001
From: Marcus Müller <mmueller@gnuradio.org>
Date: Wed, 7 Aug 2019 21:45:12 +0200
Subject: Tree: clang-format without the include sorting
---
gr-blocks/lib/udp_source_impl.h | 79 ++++++++++++++++++++---------------------
1 file changed, 39 insertions(+), 40 deletions(-)
(limited to 'gr-blocks/lib/udp_source_impl.h')
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 */
--
cgit v1.2.3