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/copy_impl.cc | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/copy_impl.cc')
| -rw-r--r-- | gr-blocks/lib/copy_impl.cc | 112 |
1 files changed, 48 insertions, 64 deletions
diff --git a/gr-blocks/lib/copy_impl.cc b/gr-blocks/lib/copy_impl.cc index acac576075..c377e57b1e 100644 --- a/gr-blocks/lib/copy_impl.cc +++ b/gr-blocks/lib/copy_impl.cc @@ -29,88 +29,72 @@ #include <string.h> namespace gr { - namespace blocks { +namespace blocks { - copy::sptr - copy::make(size_t itemsize) - { - return gnuradio::get_initial_sptr - (new copy_impl(itemsize)); - } +copy::sptr copy::make(size_t itemsize) +{ + return gnuradio::get_initial_sptr(new copy_impl(itemsize)); +} - copy_impl::copy_impl(size_t itemsize) - : block("copy", - io_signature::make(1, -1, itemsize), - io_signature::make(1, -1, itemsize)), - d_itemsize(itemsize), - d_enabled(true) - { - message_port_register_in(pmt::mp("en")); - set_msg_handler(pmt::mp("en"), - boost::bind(©_impl::handle_enable, this, _1)); - } +copy_impl::copy_impl(size_t itemsize) + : block("copy", + io_signature::make(1, -1, itemsize), + io_signature::make(1, -1, itemsize)), + d_itemsize(itemsize), + d_enabled(true) +{ + message_port_register_in(pmt::mp("en")); + set_msg_handler(pmt::mp("en"), boost::bind(©_impl::handle_enable, this, _1)); +} - copy_impl::~copy_impl() - { - } +copy_impl::~copy_impl() {} - void - copy_impl::handle_enable(pmt::pmt_t msg) - { - if(pmt::is_bool(msg)) { +void copy_impl::handle_enable(pmt::pmt_t msg) +{ + if (pmt::is_bool(msg)) { bool en = pmt::to_bool(msg); d_enabled = en; - } } +} - void - copy_impl::forecast(int noutput_items, gr_vector_int &ninput_items_required) - { - unsigned ninputs = ninput_items_required.size(); - for (unsigned i = 0; i < ninputs; i++) - ninput_items_required[i] = noutput_items; - } +void copy_impl::forecast(int noutput_items, gr_vector_int& ninput_items_required) +{ + unsigned ninputs = ninput_items_required.size(); + for (unsigned i = 0; i < ninputs; i++) + ninput_items_required[i] = noutput_items; +} - bool - copy_impl::check_topology(int ninputs, int noutputs) - { - return ninputs == noutputs; - } +bool copy_impl::check_topology(int ninputs, int noutputs) { return ninputs == noutputs; } - int - copy_impl::general_work(int noutput_items, - gr_vector_int &ninput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items) - { - const uint8_t **in = (const uint8_t**)&input_items[0]; - uint8_t **out = (uint8_t**)&output_items[0]; +int copy_impl::general_work(int noutput_items, + gr_vector_int& ninput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items) +{ + const uint8_t** in = (const uint8_t**)&input_items[0]; + uint8_t** out = (uint8_t**)&output_items[0]; - int n = 0; - if(d_enabled) { + int n = 0; + if (d_enabled) { int ninputs = input_items.size(); - for(int i = 0; i < ninputs; i++) { - memcpy(out[i], in[i], noutput_items*d_itemsize); + for (int i = 0; i < ninputs; i++) { + memcpy(out[i], in[i], noutput_items * d_itemsize); } n = noutput_items; - } - - consume_each(noutput_items); - return n; } + consume_each(noutput_items); + return n; +} - void - copy_impl::setup_rpc() - { + +void copy_impl::setup_rpc() +{ #ifdef GR_CTRLPORT - add_rpc_variable( - rpcbasic_sptr(new rpcbasic_register_handler<copy>( - alias(), "en", - "", "Enable", - RPC_PRIVLVL_MIN, DISPNULL))); + add_rpc_variable(rpcbasic_sptr(new rpcbasic_register_handler<copy>( + alias(), "en", "", "Enable", RPC_PRIVLVL_MIN, DISPNULL))); #endif /* GR_CTRLPORT */ - } +} - } /* namespace blocks */ +} /* namespace blocks */ } /* namespace gr */ |