From fb1b7b78687da3653c0461394cee7135e701bfd5 Mon Sep 17 00:00:00 2001 From: Martin Braun Date: Wed, 25 Apr 2018 15:09:27 -0700 Subject: ad936x: De-boostify ad936x_manager, minor cleanup - Remove all use of boost::bind and boost::function - Demote some log messages to DEBUG - Change some formatting to match coding guidelines - B2xx/E310: Match changes in loopback function --- .../lib/include/uhdlib/usrp/common/ad9361_ctrl.hpp | 2 +- .../include/uhdlib/usrp/common/ad936x_manager.hpp | 5 +- host/lib/usrp/b200/b200_impl.cpp | 13 +-- host/lib/usrp/common/ad936x_manager.cpp | 118 +++++++++++++-------- host/lib/usrp/e300/e300_impl.cpp | 13 +-- 5 files changed, 94 insertions(+), 57 deletions(-) (limited to 'host') diff --git a/host/lib/include/uhdlib/usrp/common/ad9361_ctrl.hpp b/host/lib/include/uhdlib/usrp/common/ad9361_ctrl.hpp index b9e81074b..1acbe6463 100644 --- a/host/lib/include/uhdlib/usrp/common/ad9361_ctrl.hpp +++ b/host/lib/include/uhdlib/usrp/common/ad9361_ctrl.hpp @@ -42,7 +42,7 @@ class ad9361_ctrl : public boost::noncopyable public: typedef boost::shared_ptr sptr; - virtual ~ad9361_ctrl(void) {}; + virtual ~ad9361_ctrl(void) {} //! make a new codec control object static sptr make_spi( diff --git a/host/lib/include/uhdlib/usrp/common/ad936x_manager.hpp b/host/lib/include/uhdlib/usrp/common/ad936x_manager.hpp index 7934b1050..7abbe69ed 100644 --- a/host/lib/include/uhdlib/usrp/common/ad936x_manager.hpp +++ b/host/lib/include/uhdlib/usrp/common/ad936x_manager.hpp @@ -16,6 +16,7 @@ #include #include #include +#include namespace uhd { namespace usrp { @@ -71,8 +72,8 @@ public: * \throws a uhd::runtime_error if the loopback value didn't match. */ virtual void loopback_self_test( - boost::function poker_functor, - boost::function peeker_functor + std::function poker_functor, + std::function peeker_functor ) = 0; /*! Determine a tick rate that will work with a given sampling rate diff --git a/host/lib/usrp/b200/b200_impl.cpp b/host/lib/usrp/b200/b200_impl.cpp index c432ad905..fe3b21aee 100644 --- a/host/lib/usrp/b200/b200_impl.cpp +++ b/host/lib/usrp/b200/b200_impl.cpp @@ -615,13 +615,14 @@ b200_impl::b200_impl(const uhd::device_addr_t& device_addr, usb_device_handle::s this->setup_radio(i); //now test each radio module's connection to the codec interface - for(radio_perifs_t &perif: _radio_perifs) - { + for (radio_perifs_t &perif : _radio_perifs) { _codec_mgr->loopback_self_test( - boost::bind( - &radio_ctrl_core_3000::poke32, perif.ctrl, TOREG(SR_CODEC_IDLE), _1 - ), - boost::bind(&radio_ctrl_core_3000::peek64, perif.ctrl, RB64_CODEC_READBACK) + [&perif](const uint32_t value){ + perif.ctrl->poke32(TOREG(SR_CODEC_IDLE), value); + }, + [&perif](){ + return perif.ctrl->peek64(RB64_CODEC_READBACK); + } ); } diff --git a/host/lib/usrp/common/ad936x_manager.cpp b/host/lib/usrp/common/ad936x_manager.cpp index 9d07350ea..fa964c66c 100644 --- a/host/lib/usrp/common/ad936x_manager.cpp +++ b/host/lib/usrp/common/ad936x_manager.cpp @@ -8,7 +8,9 @@ #include #include #include -#include +#include +#include +#include using namespace uhd; using namespace uhd::usrp; @@ -28,7 +30,7 @@ const bool ad936x_manager::DEFAULT_AGC_ENABLE = false; class ad936x_manager_impl : public ad936x_manager { - public: +public: /************************************************************************ * Structor ***********************************************************************/ @@ -55,7 +57,7 @@ class ad936x_manager_impl : public ad936x_manager ***********************************************************************/ void init_codec() { - for(const std::string &rx_fe: _rx_frontends) { + for (const std::string &rx_fe : _rx_frontends) { _codec_ctrl->set_gain(rx_fe, DEFAULT_GAIN); _codec_ctrl->set_bw_filter(rx_fe, DEFAULT_BANDWIDTH); _codec_ctrl->tune(rx_fe, DEFAULT_FREQ); @@ -63,7 +65,7 @@ class ad936x_manager_impl : public ad936x_manager _codec_ctrl->set_iq_balance_auto(rx_fe, DEFAULT_AUTO_IQ_BALANCE); _codec_ctrl->set_agc(rx_fe, DEFAULT_AGC_ENABLE); } - for(const std::string &tx_fe: _tx_frontends) { + for (const std::string &tx_fe : _tx_frontends) { _codec_ctrl->set_gain(tx_fe, DEFAULT_GAIN); _codec_ctrl->set_bw_filter(tx_fe, DEFAULT_BANDWIDTH); _codec_ctrl->tune(tx_fe, DEFAULT_FREQ); @@ -82,12 +84,12 @@ class ad936x_manager_impl : public ad936x_manager // worst case conditions to stress the interface. // void loopback_self_test( - boost::function poker_functor, - boost::function peeker_functor + std::function poker_functor, + std::function peeker_functor ) { // Put AD936x in loopback mode _codec_ctrl->data_port_loopback(true); - UHD_LOGGER_INFO("AD936X") << "Performing CODEC loopback test... "; + UHD_LOGGER_DEBUG("AD936X") << "Performing CODEC loopback test... "; size_t hash = size_t(time(NULL)); // Allow some time for AD936x to enter loopback mode. @@ -96,10 +98,10 @@ class ad936x_manager_impl : public ad936x_manager // when leaving the TX or RX states. That works out to ~75us at the // minimum clock rate of 5 MHz, which lines up with test results. // Sleeping 1ms is far more than enough. - boost::this_thread::sleep(boost::posix_time::milliseconds(1)); + std::this_thread::sleep_for(std::chrono::milliseconds(1)); - for (size_t i = 0; i < 100; i++) - { + constexpr size_t NUM_LOOPBACK_ITERS = 100; + for (size_t i = 0; i < NUM_LOOPBACK_ITERS; i++) { // Create test word boost::hash_combine(hash, i); const uint32_t word32 = uint32_t(hash) & 0xfff0fff0; @@ -107,20 +109,22 @@ class ad936x_manager_impl : public ad936x_manager // Write test word to codec_idle idle register (on TX side) poker_functor(word32); - // Read back values - TX is lower 32-bits and RX is upper 32-bits + // Read back values const uint64_t rb_word64 = peeker_functor(); const uint32_t rb_tx = uint32_t(rb_word64 >> 32); const uint32_t rb_rx = uint32_t(rb_word64 & 0xffffffff); // Compare TX and RX values to test word - bool test_fail = word32 != rb_tx or word32 != rb_rx; - if(test_fail) - { - UHD_LOGGER_INFO("AD936X") << "CODEC loopback test failed"; + const bool test_fail = word32 != rb_tx or word32 != rb_rx; + if (test_fail) { + UHD_LOGGER_ERROR("AD936X") + << "CODEC loopback test failed! " + << boost::format("Expected: 0x%08X Received (TX/RX): 0x%08X/0x%08X") + % word32 % rb_tx % rb_rx; throw uhd::runtime_error("CODEC loopback test failed."); } } - UHD_LOGGER_INFO("AD936X") << "CODEC loopback test passed"; + UHD_LOGGER_DEBUG("AD936X") << "CODEC loopback test passed."; // Zero out the idle data. poker_functor(0); @@ -192,28 +196,36 @@ class ad936x_manager_impl : public ad936x_manager return true; } - void populate_frontend_subtree(uhd::property_tree::sptr subtree, const std::string &key, uhd::direction_t dir) - { + void populate_frontend_subtree( + uhd::property_tree::sptr subtree, + const std::string &key, + uhd::direction_t dir + ) { subtree->create("name").set("FE-"+key); // Sensors subtree->create("sensors/temp") - .set_publisher(boost::bind(&ad9361_ctrl::get_temperature, _codec_ctrl)) + .set_publisher([this](){ + return this->_codec_ctrl->get_temperature(); + }) ; if (dir == RX_DIRECTION) { subtree->create("sensors/rssi") - .set_publisher(boost::bind(&ad9361_ctrl::get_rssi, _codec_ctrl, key)) + .set_publisher([this, key](){ + return this->_codec_ctrl->get_rssi(key); + }) ; } // Gains - for(const std::string &name: ad9361_ctrl::get_gain_names(key)) - { + for (const std::string &name : ad9361_ctrl::get_gain_names(key)) { subtree->create(uhd::fs_path("gains") / name / "range") .set(ad9361_ctrl::get_gain_range(key)); subtree->create(uhd::fs_path("gains") / name / "value") .set(ad936x_manager::DEFAULT_GAIN) - .set_coercer(boost::bind(&ad9361_ctrl::set_gain, _codec_ctrl, key, _1)) + .set_coercer([this, key](const double gain){ + return this->_codec_ctrl->set_gain(key, gain); + }) ; } @@ -225,19 +237,29 @@ class ad936x_manager_impl : public ad936x_manager // Analog Bandwidths subtree->create("bandwidth/value") .set(ad936x_manager::DEFAULT_BANDWIDTH) - .set_coercer(boost::bind(&ad9361_ctrl::set_bw_filter, _codec_ctrl, key, _1)) + .set_coercer([this, key](const double bw){ + return this->_codec_ctrl->set_bw_filter(key, bw); + }) ; subtree->create("bandwidth/range") - .set_publisher(boost::bind(&ad9361_ctrl::get_bw_filter_range, key)) + .set_publisher([key](){ + return ad9361_ctrl::get_bw_filter_range(key); + }) ; // LO Tuning subtree->create("freq/range") - .set_publisher(boost::bind(&ad9361_ctrl::get_rf_freq_range)) + .set_publisher([](){ + return ad9361_ctrl::get_rf_freq_range(); + }) ; subtree->create("freq/value") - .set_publisher(boost::bind(&ad9361_ctrl::get_freq, _codec_ctrl, key)) - .set_coercer(boost::bind(&ad9361_ctrl::tune, _codec_ctrl, key, _1)) + .set_publisher([this, key](){ + return this->_codec_ctrl->get_freq(key); + }) + .set_coercer([this, key](const double freq){ + return this->_codec_ctrl->tune(key, freq); + }) ; // Frontend corrections @@ -245,36 +267,50 @@ class ad936x_manager_impl : public ad936x_manager { subtree->create("dc_offset/enable" ) .set(ad936x_manager::DEFAULT_AUTO_DC_OFFSET) - .add_coerced_subscriber(boost::bind(&ad9361_ctrl::set_dc_offset_auto, _codec_ctrl, key, _1)) + .add_coerced_subscriber([this, key](const bool enable){ + this->_codec_ctrl->set_dc_offset_auto(key, enable); + }) ; subtree->create("iq_balance/enable" ) .set(ad936x_manager::DEFAULT_AUTO_IQ_BALANCE) - .add_coerced_subscriber(boost::bind(&ad9361_ctrl::set_iq_balance_auto, _codec_ctrl, key, _1)) + .add_coerced_subscriber([this, key](const bool enable){ + this->_codec_ctrl->set_iq_balance_auto(key, enable); + }) ; // AGC setup - const std::list mode_strings = boost::assign::list_of("slow")("fast"); + const std::list mode_strings{"slow", "fast"}; subtree->create("gain/agc/enable") .set(DEFAULT_AGC_ENABLE) - .add_coerced_subscriber(boost::bind((&ad9361_ctrl::set_agc), _codec_ctrl, key, _1)) + .add_coerced_subscriber([this, key](const bool enable){ + this->_codec_ctrl->set_agc(key, enable); + }) ; subtree->create("gain/agc/mode/value") - .add_coerced_subscriber(boost::bind((&ad9361_ctrl::set_agc_mode), _codec_ctrl, key, _1)).set(mode_strings.front()) + .add_coerced_subscriber([this, key](const std::string& value){ + this->_codec_ctrl->set_agc_mode(key, value); + }) + .set(mode_strings.front()) ; - subtree->create< std::list >("gain/agc/mode/options") + subtree->create>("gain/agc/mode/options") .set(mode_strings) ; } // Frontend filters - for(const std::string &filter_name: _codec_ctrl->get_filter_names(key)) { - subtree->create(uhd::fs_path("filters") / filter_name / "value" ) - .set_publisher(boost::bind(&ad9361_ctrl::get_filter, _codec_ctrl, key, filter_name)) - .add_coerced_subscriber(boost::bind(&ad9361_ctrl::set_filter, _codec_ctrl, key, filter_name, _1)); + for (const auto &filter_name : _codec_ctrl->get_filter_names(key)) { + subtree->create(uhd::fs_path("filters") / filter_name / "value") + .set_publisher([this, key, filter_name](){ + return this->_codec_ctrl->get_filter(key, filter_name); + }) + .add_coerced_subscriber([this, key, filter_name](filter_info_base::sptr filter_info){ + this->_codec_ctrl->set_filter(key, filter_name, filter_info); + }) + ; } } - private: +private: //! Store a pointer to an actual AD936x control object ad9361_ctrl::sptr _codec_ctrl; @@ -291,8 +327,6 @@ ad936x_manager::sptr ad936x_manager::make( const ad9361_ctrl::sptr &codec_ctrl, const size_t n_frontends ) { - return sptr( - new ad936x_manager_impl(codec_ctrl, n_frontends) - ); + return boost::make_shared(codec_ctrl, n_frontends); } diff --git a/host/lib/usrp/e300/e300_impl.cpp b/host/lib/usrp/e300/e300_impl.cpp index 78b1f05b1..324b25407 100644 --- a/host/lib/usrp/e300/e300_impl.cpp +++ b/host/lib/usrp/e300/e300_impl.cpp @@ -508,13 +508,14 @@ e300_impl::e300_impl(const uhd::device_addr_t &device_addr) this->_setup_radio(instance); //now test each radio module's connection to the codec interface - for(radio_perifs_t &perif: _radio_perifs) - { + for (radio_perifs_t &perif : _radio_perifs) { _codec_mgr->loopback_self_test( - boost::bind( - &radio_ctrl_core_3000::poke32, perif.ctrl, radio::sr_addr(radio::CODEC_IDLE), _1 - ), - boost::bind(&radio_ctrl_core_3000::peek64, perif.ctrl, radio::RB64_CODEC_READBACK) + [&perif](const uint32_t value){ + perif.ctrl->poke32(radio::sr_addr(radio::CODEC_IDLE), value); + }, + [&perif](){ + return perif.ctrl->peek64(radio::RB64_CODEC_READBACK); + } ); } //////////////////////////////////////////////////////////////////// -- cgit v1.2.3