diff options
| author | Nick Foster <nick@nerdnetworks.org> | 2010-11-10 12:15:35 -0800 | 
|---|---|---|
| committer | Nick Foster <nick@nerdnetworks.org> | 2010-11-10 12:15:35 -0800 | 
| commit | fb0cdbc553d288402ee7939dc72f4368eb9e8e1b (patch) | |
| tree | e20003155af08428448a7834a82d259f3b68717d /host | |
| parent | 8fe1e7b29aacce7f75ae36e81706bbde02749b97 (diff) | |
| parent | 8c434f7d63aca25b55d6d13dffcc1d7037261d4f (diff) | |
| download | uhd-fb0cdbc553d288402ee7939dc72f4368eb9e8e1b.tar.gz uhd-fb0cdbc553d288402ee7939dc72f4368eb9e8e1b.tar.bz2 uhd-fb0cdbc553d288402ee7939dc72f4368eb9e8e1b.zip | |
Merge branch 'master' of ettus.sourcerepo.com:ettus/uhdpriv into usrp2p-next
Conflicts:
	firmware/microblaze/lib/u2_init.c
	host/lib/usrp/usrp2/clock_ctrl.cpp
	host/lib/usrp/usrp2/fw_common.h
	host/lib/usrp/usrp2/mboard_impl.cpp
	host/lib/usrp/usrp2/usrp2_iface.cpp
	host/lib/usrp/usrp2/usrp2_iface.hpp
Diffstat (limited to 'host')
74 files changed, 2926 insertions, 770 deletions
| diff --git a/host/config/Python.cmake b/host/config/Python.cmake index 55ef6acca..95cdb4479 100644 --- a/host/config/Python.cmake +++ b/host/config/Python.cmake @@ -18,32 +18,31 @@  ########################################################################  # Setup Python  ######################################################################## -INCLUDE(FindPythonInterp) +IF(NOT DEFINED PYTHON_EXECUTABLE) +    INCLUDE(FindPythonInterp) -IF(NOT PYTHONINTERP_FOUND) -    MESSAGE(FATAL_ERROR "Error: Python interpretor required by the build system.") -ENDIF(NOT PYTHONINTERP_FOUND) +    IF(NOT PYTHONINTERP_FOUND) +        MESSAGE(FATAL_ERROR "Error: Python interpretor required by the build system.") +    ENDIF(NOT PYTHONINTERP_FOUND) +ENDIF(NOT DEFINED PYTHON_EXECUTABLE) -MACRO(PYTHON_CHECK_MODULE module have) -    MESSAGE(STATUS "Checking for python module ${module}") +MACRO(PYTHON_CHECK_MODULE desc mod cmd have) +    MESSAGE(STATUS "Python checking for ${desc}")      EXECUTE_PROCESS( -        COMMAND ${PYTHON_EXECUTABLE} -c "import ${module}" +        COMMAND ${PYTHON_EXECUTABLE} -c " +######################################### +try: import ${mod} +except: exit(-1) +try: assert ${cmd} +except: exit(-1) +#########################################"          RESULT_VARIABLE ${have}      )      IF(${have} EQUAL 0) -        MESSAGE(STATUS "Checking for python module ${module} - found") +        MESSAGE(STATUS "Python checking for ${desc} - found")          SET(${have} TRUE)      ELSE(${have} EQUAL 0) -        MESSAGE(STATUS "Checking for python module ${module} - not found") +        MESSAGE(STATUS "Python checking for ${desc} - not found")          SET(${have} FALSE)      ENDIF(${have} EQUAL 0)  ENDMACRO(PYTHON_CHECK_MODULE) - -######################################################################## -# Check Modules -######################################################################## -PYTHON_CHECK_MODULE("Cheetah" HAVE_PYTHON_MODULE_CHEETAH) - -IF(NOT HAVE_PYTHON_MODULE_CHEETAH) -    MESSAGE(FATAL_ERROR "Error: Cheetah Templates required by the build system.") -ENDIF(NOT HAVE_PYTHON_MODULE_CHEETAH) diff --git a/host/docs/CMakeLists.txt b/host/docs/CMakeLists.txt index 65db3befc..4d3269543 100644 --- a/host/docs/CMakeLists.txt +++ b/host/docs/CMakeLists.txt @@ -20,6 +20,7 @@  ########################################################################  SET(manual_sources      index.rst +    identification.rst      build.rst      coding.rst      dboards.rst diff --git a/host/docs/dboards.rst b/host/docs/dboards.rst index 080117651..7f205c404 100644 --- a/host/docs/dboards.rst +++ b/host/docs/dboards.rst @@ -26,6 +26,14 @@ The boards have no tunable elements or programmable gains.  Though the magic of aliasing, you can down-convert signals  greater than the Nyquist rate of the ADC. +BasicRX Bandwidth (Hz):  +    For Real-Mode (A or B subdevice): 250M +    For Complex (AB or BA subdevice): 500M + +LFRX Bandwidth (Hz): +    For Real-Mode (A or B subdevice): 33M +    For Complex (AB or BA subdevice): 66M +  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  Basic TX and and LFTX  ^^^^^^^^^^^^^^^^^^^^^^^^^^^ @@ -40,6 +48,14 @@ The boards have no tunable elements or programmable gains.  Though the magic of aliasing, you can up-convert signals  greater than the Nyquist rate of the DAC. +BasicTX Bandwidth (Hz): 250M +    For Real-Mode (A or B subdevice): 250M +    For Complex (AB or BA subdevice): 500M + +LFTX Bandwidth (Hz): 33M +    For Real-Mode (A or B subdevice): 33M +    For Complex (AB or BA subdevice): 66M +  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  DBSRX  ^^^^^^^^^^^^^^^^^^^^^^^^^^^ @@ -53,7 +69,7 @@ Receive Gains:      **GC1**, Range: 0-56dB      **GC2**, Range: 0-24dB -Low-Pass Filter Bandwidth (Hz): 4M-33M +Bandwidth (Hz): 8M-66M  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  RFX Series @@ -68,6 +84,10 @@ the receive antenna will always be set to RX2, regardless of the settings.  Receive Gains: **PGA0**, Range: 0-70dB (except RFX400 range is 0-45dB) +Bandwidths (Hz): + * **RX**: 40M + * **TX**: 40M +  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  XCVR 2450  ^^^^^^^^^^^^^^^^^^^^^^^^^^^ @@ -93,9 +113,9 @@ Receive Gains:   * **LNA**, Range: 0-30.5dB   * **VGA**, Range: 0-62dB -Low-Pass Filter Bandwidths (Hz): - * **RX**: 7.5M, 9.5M, 14M, 18M; (each +-0, 5, or 10%) - * **TX**: 12M, 18M, 24M +Bandwidths (Hz): + * **RX**: 15M, 19M, 28M, 36M; (each +-0, 5, or 10%) + * **TX**: 24M, 36M, 48M  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  WBX Series @@ -112,9 +132,9 @@ Transmit Gains: **PGA0**, Range: 0-25dB  Receive Gains: **PGA0**, Range: 0-31.5dB -Low-Pass Filter Bandwidths (Hz): - * **RX**: 20M (Fixed) - * **TX**: 20M (Fixed) +Bandwidths (Hz): + * **RX**: 40M + * **TX**: 40M  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  TVRX @@ -125,7 +145,7 @@ Receive Gains:   * **RF**, Range: -13.3-50.3dB (frequency-dependent)   * **IF**, Range: -1.5-32.5dB -Bandpass Filter Bandwidth: 6MHz +Bandwidth: 6MHz  ------------------------------------------------------------------------  Daughterboard Modifications @@ -137,7 +157,7 @@ Modification usually involves moving/removing a SMT component  and burning a new daughterboard id into the eeprom.  ^^^^^^^^^^^^^^^^^^^^^^^^^^^ -DBSRX +DBSRX - Mod  ^^^^^^^^^^^^^^^^^^^^^^^^^^^  Due to different clocking capabilities, @@ -167,3 +187,45 @@ With the daughterboard plugged-in, run the following commands:  * <args> are device address arguments (optional if only one USRP is on your machine)  * <slot> is the name of the daughterboard slot (optional if the USRP has only one slot) + +^^^^^^^^^^^^^^^^^^^^^^^^^^^ +RFX - Mod +^^^^^^^^^^^^^^^^^^^^^^^^^^^ +Older RFX boards require modifications to use the motherboard oscillator. +If this is the case, UHD will print a warning about the modification. +Please follow the modification procedures below: + +**Step 1: Disable the daughterboard clocks** + +Move R64 to R84, Move R142 to R153 + +**Step 2: Connect the motherboard blocks** + +Move R35 to R36, Move R117 to R115 +These are all 0-ohm, so if you lose one, just short across the appropriate pads + +**Step 3: Burn the appropriate daughterboard id into the EEPROM** + +With the daughterboard plugged-in, run the following commands: +:: + +    cd <prefix>/share/uhd/utils +    ./usrp_burn_db_eeprom --id=<rx_id> --unit=RX --args=<args> --slot=<slot> +    ./usrp_burn_db_eeprom --id=<tx_id> --unit=TX --args=<args> --slot=<slot> + +* <rx_id> choose the appropriate RX ID for your daughterboard + +  * **RFX400:** 0x0024 +  * **RFX900:** 0x0025 +  * **RFX1800:** 0x0034 +  * **RFX1200:** 0x0026 +  * **RFX2400:** 0x0027 +* <tx_id> choose the appropriate TX ID for your daughterboard + +  * **RFX400:** 0x0028 +  * **RFX900:** 0x0029 +  * **RFX1800:** 0x0035 +  * **RFX1200:** 0x002a +  * **RFX2400:** 0x002b +* <args> are device address arguments (optional if only one USRP is on your machine) +* <slot> is the name of the daughterboard slot (optional if the USRP has only one slot) diff --git a/host/docs/identification.rst b/host/docs/identification.rst new file mode 100644 index 000000000..49d36ec1a --- /dev/null +++ b/host/docs/identification.rst @@ -0,0 +1,97 @@ +======================================================================== +UHD - Device Identification Notes +======================================================================== + +.. contents:: Table of Contents + +------------------------------------------------------------------------ +Identifying USRPs +------------------------------------------------------------------------ +Every device has several ways of identifying it on the host system: + +* **Serial:** A globally unique identifier. +* **Address:** A unique identifier on a network. +* **Name:** An optional user-set identifier. + +The address is only applicable for network-based devices. +See the USRP2 application notes. + +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +Device discovery via command line +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +A "find devices" utility application comes bundled with the UHD. +The find devices application will search for all devices on the host system and print the results. + +:: + +    uhd_find_devices + +Device address arguments can be supplied to narrow the scope of the search. + +:: + +    uhd_find_devices --args="type=usrp1" + +    -- OR -- + +    uhd_find_devices --args="serial=12345678" + +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +Device discovery through the API +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +The device::find() API call searches for devices and returns a list of discovered devices. + +:: + +    uhd::device_addr_t hint; //an empty hint discovers all devices +    uhd::device_addrs_t dev_addrs = uhd::device::find(hint); + +The hint argument can be populated to narrow the scope of the search. + +:: + +    uhd::device_addr_t hint; +    hint["type"] = "usrp1"; +    uhd::device_addrs_t dev_addrs = uhd::device::find(hint); + +    -- OR -- + +    uhd::device_addr_t hint; +    hint["serial"] = "12345678"; +    uhd::device_addrs_t dev_addrs = uhd::device::find(hint); + +------------------------------------------------------------------------ +Naming a USRP +------------------------------------------------------------------------ +For convenience purposes, users may assign a custom name to their USRPs. +The USRP can then be identified via name, rather than a difficult to remember serial or address. + +A name has the following properties: + +* is composed of ASCII characters +* is between 0 and 20 characters +* is not required to be unique + +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +Set a custom name +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ + +Run the following commands: +:: + +    cd <prefix>/share/uhd/utils +    ./usrp_burn_mb_eeprom --args=<optional device args> --key=name --val=lab1_xcvr + +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +Discovery via name +^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ + +The keyword "name" can be used to narrow the scope of the search. +Example with the find devices utility: +:: + +    uhd_find_devices --args="name=lab1_xcvr" + +    -- OR -- + +    uhd_find_devices --args="type=usrp1, name=lab1_xcvr" diff --git a/host/docs/index.rst b/host/docs/index.rst index 7f8129e2d..9d6d14d0f 100644 --- a/host/docs/index.rst +++ b/host/docs/index.rst @@ -21,6 +21,7 @@ Building the UHD  Application Notes  ^^^^^^^^^^^^^^^^^^^^^  * `General Application Notes <./general.html>`_ +* `Device Identification Notes <./identification.html>`_  * `Firmware and FPGA Image Notes <./images.html>`_  * `USRP1 Application Notes <./usrp1.html>`_  * `USRP2 Application Notes <./usrp2.html>`_ diff --git a/host/docs/usrp1.rst b/host/docs/usrp1.rst index 3443fd871..be684e20e 100644 --- a/host/docs/usrp1.rst +++ b/host/docs/usrp1.rst @@ -4,36 +4,6 @@ UHD - USRP1 Application Notes  .. contents:: Table of Contents ------------------------------------------------------------------------- -Addressing the device ------------------------------------------------------------------------- -A USRP1 can be identified though its 8 digit serial number, -designated by the "serial" key in the device address. - -The device address string representation for a USRP1 with serial 12345678: - -:: - -    serial=12345678 - -^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ -Change the serial number -^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ -The USRP1 serial number can be changed to any 8 byte string. Examples: - -:: - -    cd <prefix>/share/uhd/utils -    ./usrp1_serial_burner --new=87654321 - -    -- OR -- - -    ./usrp1_serial_burner --new=Beatrice - -    -- OR -- - -    ./usrp1_serial_burner --old=12345678 --new=87654321 -  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^  Specify a non-standard image  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ diff --git a/host/docs/usrp2.rst b/host/docs/usrp2.rst index 0ddcaa4e5..d07175ce4 100644 --- a/host/docs/usrp2.rst +++ b/host/docs/usrp2.rst @@ -11,9 +11,14 @@ Load the images onto the SD card  Use the usrp2_card_burner.py with caution. If you specify the wrong device node,  you could overwrite your hard drive. Make sure that --dev= specifies the SD card. -Use the *--list* option to get a list of possible raw devices. -The list result will filter out disk partitions and devices too large to be the sd card. -The list option has been implemented on Linux, Mac OS X, and Windows. +**Warning!** +It is possible to use 3rd party SD cards with the USRP2. +However, certain types of SD cards will not interface with the CPLD: + +* Cards can be SDHC, which is not a supported interface. +* Cards can have unexpected timing characteristics. + +For these reasons, we recommend that you use the SD card that was supplied with the USRP2.  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^  Use the card burner tool (unix) @@ -28,6 +33,10 @@ Use the card burner tool (unix)      sudo ./usrp2_card_burner.py --dev=/dev/sd<XXX> --fpga=<path_to_fpga_image>      sudo ./usrp2_card_burner.py --dev=/dev/sd<XXX> --fw=<path_to_firmware_image> +Use the *--list* option to get a list of possible raw devices. +The list result will filter out disk partitions and devices too large to be the sd card. +The list option has been implemented on Linux, Mac OS X, and Windows. +  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^  Use the card burner tool (windows)  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ @@ -97,7 +106,7 @@ Run the following commands:  ::      cd <prefix>/share/uhd/utils -    ./usrp_addr_burner --addr=192.168.10.2 --new-ip=192.168.10.3 +    ./usrp_burn_mb_eeprom --args=<optional device args> --key=ip-addr --val=192.168.10.3  **Method 2 (Linux Only):**  This method assumes that you do not know the IP address of your USRP2. @@ -179,8 +188,8 @@ The LEDs reveal the following about the state of the device:  * **LED B:** undocumented  * **LED C:** receiving  * **LED D:** firmware loaded -* **LED E:** undocumented -* **LED F:** FPGA loaded +* **LED E:** reference lock +* **LED F:** CPLD loaded  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ diff --git a/host/examples/CMakeLists.txt b/host/examples/CMakeLists.txt index d19838335..ce2ca9640 100644 --- a/host/examples/CMakeLists.txt +++ b/host/examples/CMakeLists.txt @@ -16,30 +16,35 @@  #  ######################################################################## -ADD_EXECUTABLE(benchmark_rx_rate benchmark_rx_rate.cpp) -TARGET_LINK_LIBRARIES(benchmark_rx_rate uhd) - -ADD_EXECUTABLE(rx_timed_samples rx_timed_samples.cpp) -TARGET_LINK_LIBRARIES(rx_timed_samples uhd) - -ADD_EXECUTABLE(test_async_messages test_async_messages.cpp) -TARGET_LINK_LIBRARIES(test_async_messages uhd) - -ADD_EXECUTABLE(test_pps_input test_pps_input.cpp) -TARGET_LINK_LIBRARIES(test_pps_input uhd) +# example applications +######################################################################## +SET(example_sources +    benchmark_rx_rate.cpp +    rx_samples_to_file.cpp +    rx_samples_to_udp.cpp +    rx_timed_samples.cpp +    test_async_messages.cpp +    test_pps_input.cpp +    tx_timed_samples.cpp +    tx_waveforms.cpp +) -ADD_EXECUTABLE(tx_timed_samples tx_timed_samples.cpp) -TARGET_LINK_LIBRARIES(tx_timed_samples uhd) +#for each source: build an executable and install +FOREACH(example_source ${example_sources}) +    GET_FILENAME_COMPONENT(example_name ${example_source} NAME_WE) +    ADD_EXECUTABLE(${example_name} ${example_source}) +    TARGET_LINK_LIBRARIES(${example_name} uhd) +    INSTALL(TARGETS ${example_name} RUNTIME DESTINATION ${PKG_DATA_DIR}/examples) +ENDFOREACH(example_source) -ADD_EXECUTABLE(tx_waveforms tx_waveforms.cpp) -TARGET_LINK_LIBRARIES(tx_waveforms uhd) +######################################################################## +# ASCII Art DFT - requires curses, so this part is optional +######################################################################## +INCLUDE(FindCurses) -INSTALL(TARGETS -    benchmark_rx_rate -    rx_timed_samples -    test_async_messages -    test_pps_input -    tx_timed_samples -    tx_waveforms -    RUNTIME DESTINATION ${PKG_DATA_DIR}/examples -) +IF(CURSES_FOUND) +    INCLUDE_DIRECTORIES(${CURSES_INCLUDE_DIR}) +    ADD_EXECUTABLE(rx_ascii_art_dft rx_ascii_art_dft.cpp) +    TARGET_LINK_LIBRARIES(rx_ascii_art_dft uhd ${CURSES_LIBRARIES}) +    INSTALL(TARGETS rx_ascii_art_dft RUNTIME DESTINATION ${PKG_DATA_DIR}/examples) +ENDIF(CURSES_FOUND) diff --git a/host/examples/ascii_art_dft.hpp b/host/examples/ascii_art_dft.hpp new file mode 100644 index 000000000..92fb77596 --- /dev/null +++ b/host/examples/ascii_art_dft.hpp @@ -0,0 +1,320 @@ +// +// ASCII Art DFT Plotter - Josh Blum +// + +#ifndef ASCII_ART_DFT_HPP +#define ASCII_ART_DFT_HPP + +#include <string> +#include <cstddef> +#include <vector> +#include <complex> +#include <stdexcept> + +namespace acsii_art_dft{ + +    //! Type produced by the log power DFT function +    typedef std::vector<float> log_pwr_dft_type; + +    /*! +     * Get a logarithmic power DFT of the input samples. +     * Samples are expected to be in the range [-1.0, 1.0]. +     * \param samps a pointer to an array of complex samples +     * \param nsamps the number of samples in the array +     * \return a real range of DFT bins in units of dB +     */ +    template <typename T> log_pwr_dft_type log_pwr_dft( +        const std::complex<T> *samps, size_t nsamps +    ); + +    /*! +     * Convert a DFT to a printable ascii plot. +     * \param dft the log power dft bins +     * \param width the frame width in characters +     * \param height the frame height in characters +     * \param samp_rate the sample rate in Sps +     * \param dc_freq the DC frequency in Hz +     * \param dyn_rng the dynamic range in dB +     * \param ref_lvl the reference level in dB +     * \return the plot as an ascii string +     */ +    std::string dft_to_plot( +        const log_pwr_dft_type &dft, +        size_t width, +        size_t height, +        double samp_rate, +        double dc_freq, +        float dyn_rng, +        float ref_lvl +    ); + +} //namespace ascii_dft + +/*********************************************************************** + * Implementation includes + **********************************************************************/ +#include <cmath> +#include <sstream> +#include <algorithm> + +/*********************************************************************** + * Helper functions + **********************************************************************/ +namespace {/*anon*/ + +    static const double pi = double(std::acos(-1.0)); + +    //! Round a floating-point value to the nearest integer +    template <typename T> int iround(T val){ +        return (val > 0)? int(val + 0.5) : int(val - 0.5); +    } + +    //! Pick the closest number that is nice to display +    template <typename T> T to_clean_num(const T num){ +        if (num == 0) return 0; +        const T pow10 = std::pow(T(10), int(std::floor(std::log10(std::abs(num))))); +        const T norm = std::abs(num)/pow10; +        static const int cleans[] = {1, 2, 5, 10}; +        int clean = cleans[0]; +        for (size_t i = 1; i < sizeof(cleans)/sizeof(cleans[0]); i++){ +            if (std::abs(norm - cleans[i]) < std::abs(norm - clean)) +                clean = cleans[i]; +        } +        return ((num < 0)? -1 : 1)*clean*pow10; +    } + +    //! Compute an FFT with pre-computed factors using Cooley-Tukey +    template <typename T> std::complex<T> ct_fft_f( +        const std::complex<T> *samps, size_t nsamps, +        const std::complex<T> *factors, +        size_t start = 0, size_t step = 1 +    ){ +        if (nsamps == 1) return samps[start]; +        std::complex<T> E_k = ct_fft_f(samps, nsamps/2, factors+1, start,      step*2); +        std::complex<T> O_k = ct_fft_f(samps, nsamps/2, factors+1, start+step, step*2); +        return E_k + factors[0]*O_k; +    } + +    //! Compute an FFT for a particular bin k using Cooley-Tukey +    template <typename T> std::complex<T> ct_fft_k( +        const std::complex<T> *samps, size_t nsamps, size_t k +    ){ +        //pre-compute the factors to use in Cooley-Tukey +        std::vector<std::complex<T> > factors; +        for (size_t N = nsamps; N != 0; N /= 2){ +            factors.push_back(std::exp(std::complex<T>(0, T(-2*pi*k/N)))); +        } +        return ct_fft_f(samps, nsamps, &factors.front()); +    } + +    //! Helper class to build a DFT plot frame +    class frame_type{ +    public: +        frame_type(size_t width, size_t height): +            _frame(width-1, std::vector<char>(height, ' ')) +        { +            /* NOP */ +        } + +        //accessors to parts of the frame +        char &get_plot(size_t b, size_t z){return _frame.at(b+albl_w).at(z+flbl_h);} +        char &get_albl(size_t b, size_t z){return _frame.at(b)       .at(z+flbl_h);} +        char &get_ulbl(size_t b)          {return _frame.at(b)       .at(flbl_h-1);} +        char &get_flbl(size_t b)          {return _frame.at(b+albl_w).at(flbl_h-1);} + +        //dimension accessors +        size_t get_plot_h(void) const{return _frame.front().size() - flbl_h;} +        size_t get_plot_w(void) const{return _frame.size() - albl_w;} +        size_t get_albl_w(void) const{return albl_w;} + +        std::string to_string(void){ +            std::stringstream frame_ss; +            for (size_t z = 0; z < _frame.front().size(); z++){ +                for (size_t b = 0; b < _frame.size(); b++){ +                    frame_ss << _frame[b][_frame[b].size()-z-1]; +                } +                frame_ss << std::endl; +            } +            return frame_ss.str(); +        } + +    private: +        static const size_t albl_w = 6, flbl_h = 1; +        std::vector<std::vector<char> > _frame; +    }; + +} //namespace /*anon*/ + +/*********************************************************************** + * Implementation code + **********************************************************************/ +namespace acsii_art_dft{ + +    //! skip constants for amplitude and frequency labels +    static const size_t albl_skip = 5, flbl_skip = 20; + +    template <typename T> log_pwr_dft_type log_pwr_dft( +        const std::complex<T> *samps, size_t nsamps +    ){ +        if (nsamps & (nsamps - 1)) +            throw std::runtime_error("num samps is not a power of 2"); + +        //compute the window +        double win_pwr = 0; +        std::vector<std::complex<T> > win_samps; +        for(size_t n = 0; n < nsamps; n++){ +            //double w_n = 1; +            //double w_n = 0.54 //hamming window +            //    -0.46*std::cos(2*pi*n/(nsamps-1)) +            //; +            double w_n = 0.35875 //blackman-harris window +                -0.48829*std::cos(2*pi*n/(nsamps-1)) +                +0.14128*std::cos(4*pi*n/(nsamps-1)) +                -0.01168*std::cos(6*pi*n/(nsamps-1)) +            ; +            //double w_n = 1 // flat top window +            //    -1.930*std::cos(2*pi*n/(nsamps-1)) +            //    +1.290*std::cos(4*pi*n/(nsamps-1)) +            //    -0.388*std::cos(6*pi*n/(nsamps-1)) +            //    +0.032*std::cos(8*pi*n/(nsamps-1)) +            //; +            win_samps.push_back(T(w_n)*samps[n]); +            win_pwr += w_n*w_n; +        } + +        //compute the log-power dft +        log_pwr_dft_type log_pwr_dft; +        for(size_t k = 0; k < nsamps; k++){ +            std::complex<T> dft_k = ct_fft_k(&win_samps.front(), nsamps, k); +            log_pwr_dft.push_back(float( +                + 20*std::log10(std::abs(dft_k)) +                - 20*std::log10(T(nsamps)) +                - 10*std::log10(win_pwr/nsamps) +                + 3 +            )); +        } + +        return log_pwr_dft; +    } + +    std::string dft_to_plot( +        const log_pwr_dft_type &dft_, +        size_t width, +        size_t height, +        double samp_rate, +        double dc_freq, +        float dyn_rng, +        float ref_lvl +    ){ +        frame_type frame(width, height); //fill this frame + +        //re-order the dft so dc in in the center +        const size_t num_bins = dft_.size() - 1 + dft_.size()%2; //make it odd +        log_pwr_dft_type dft(num_bins); +        for (size_t n = 0; n < num_bins; n++){ +            dft[n] = dft_[(n + num_bins/2)%num_bins]; +        } + +        //fill the plot with dft bins +        for (size_t b = 0; b < frame.get_plot_w(); b++){ +            //indexes from the dft to grab for the plot +            const size_t n_start = std::max(iround(double(b-0.5)*(num_bins-1)/(frame.get_plot_w()-1)), 0); +            const size_t n_stop  = std::min(iround(double(b+0.5)*(num_bins-1)/(frame.get_plot_w()-1)), int(num_bins)); + +            //calculate val as the max across points +            float val = dft.at(n_start); +            for (size_t n = n_start; n < n_stop; n++) val = std::max(val, dft.at(n)); + +            const float scaled = (val - (ref_lvl - dyn_rng))*(frame.get_plot_h()-1)/dyn_rng; +            for (size_t z = 0; z < frame.get_plot_h(); z++){ +                static const std::string syms(".:!|"); +                if      (scaled-z > 1) frame.get_plot(b, z) = syms.at(syms.size()-1); +                else if (scaled-z > 0) frame.get_plot(b, z) = syms.at(size_t((scaled-z)*syms.size())); +            } +        } + +        //create vertical amplitude labels +        const float db_step = to_clean_num(dyn_rng/(frame.get_plot_h()-1)*albl_skip); +        for ( +            float db = db_step*(int((ref_lvl - dyn_rng)/db_step)); +            db      <=  db_step*(int(ref_lvl/db_step)); +            db      +=  db_step +        ){ +            const int z = iround((db - (ref_lvl - dyn_rng))*(frame.get_plot_h()-1)/dyn_rng); +            if (z < 0 or size_t(z) >= frame.get_plot_h()) continue; +            std::stringstream ss; ss << db; std::string lbl = ss.str(); +            for (size_t i = 0; i < lbl.size() and i < frame.get_albl_w(); i++){ +                frame.get_albl(i, z) = lbl[i]; +            } +        } + +        //create vertical units label +        std::string ulbl = "dBfs"; +        for (size_t i = 0; i < ulbl.size(); i++){ +            frame.get_ulbl(i+1) = ulbl[i]; +        } + +        //create horizontal frequency labels +        const double f_step = to_clean_num(samp_rate/frame.get_plot_w()*flbl_skip); +        for ( +            double freq = f_step*int((-samp_rate/2/f_step)); +            freq       <= f_step*int((+samp_rate/2/f_step)); +            freq       += f_step +        ){ +            const int b = iround((freq + samp_rate/2)*(frame.get_plot_w()-1)/samp_rate); +            std::stringstream ss; ss << (freq+dc_freq)/1e6 << "MHz"; std::string lbl = ss.str(); +            if (b < int(lbl.size()/2) or b + lbl.size() - lbl.size()/2 >= frame.get_plot_w()) continue; +            for (size_t i = 0; i < lbl.size(); i++){ +                frame.get_flbl(b + i - lbl.size()/2) = lbl[i]; +            } +        } + +        return frame.to_string(); +    } +} //namespace ascii_dft + +#endif /*ASCII_ART_DFT_HPP*/ + +/* + +//example main function to test the dft + +#include <iostream> +#include <cstdlib> +#include <curses.h> + +int main(void){ +    initscr(); + +    while (true){ +        clear(); + +        std::vector<std::complex<float> > samples; +        for(size_t i = 0; i < 512; i++){ +            samples.push_back(std::complex<float>( +                float(std::rand() - RAND_MAX/2)/(RAND_MAX)/4, +                float(std::rand() - RAND_MAX/2)/(RAND_MAX)/4 +            )); +            samples[i] += 0.5*std::sin(i*3.14/2) + 0.7; +        } + +        acsii_art_dft::log_pwr_dft_type dft; +        dft = acsii_art_dft::log_pwr_dft(&samples.front(), samples.size()); + +        printw("%s", acsii_art_dft::dft_to_plot( +            dft, COLS, LINES, +            12.5e4, 2.45e9, +            60, 0 +        ).c_str()); + +        sleep(1); +    } + + +    endwin(); +    std::cout << "here\n"; +    return 0; +} + +*/ + diff --git a/host/examples/benchmark_rx_rate.cpp b/host/examples/benchmark_rx_rate.cpp index 36611f97f..b189368f9 100644 --- a/host/examples/benchmark_rx_rate.cpp +++ b/host/examples/benchmark_rx_rate.cpp @@ -137,7 +137,6 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      std::cout << boost::format("Creating the usrp device with: %s...") % args << std::endl;      uhd::usrp::single_usrp::sptr sdev = uhd::usrp::single_usrp::make(args);      std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; -    sdev->issue_stream_cmd(uhd::stream_cmd_t::STREAM_MODE_STOP_CONTINUOUS); //stop if left running      if (not vm.count("rate")){          sdev->set_rx_rate(500e3); //initial rate diff --git a/host/examples/rx_ascii_art_dft.cpp b/host/examples/rx_ascii_art_dft.cpp new file mode 100644 index 000000000..5a24867b4 --- /dev/null +++ b/host/examples/rx_ascii_art_dft.cpp @@ -0,0 +1,143 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#include <uhd/utils/thread_priority.hpp> +#include <uhd/utils/safe_main.hpp> +#include <uhd/usrp/single_usrp.hpp> +#include "ascii_art_dft.hpp" //implementation +#include <boost/program_options.hpp> +#include <boost/thread.hpp> //gets time +#include <boost/format.hpp> +#include <curses.h> +#include <iostream> +#include <complex> + +namespace po = boost::program_options; + +int UHD_SAFE_MAIN(int argc, char *argv[]){ +    uhd::set_thread_priority_safe(); + +    //variables to be set by po +    std::string args; +    size_t num_bins; +    double rate, freq, frame_rate; +    float gain, ref_lvl, dyn_rng; + +    //setup the program options +    po::options_description desc("Allowed options"); +    desc.add_options() +        ("help", "help message") +        ("args", po::value<std::string>(&args)->default_value(""), "single uhd device address args") +        // hardware parameters +        ("rate", po::value<double>(&rate), "rate of incoming samples (sps)") +        ("freq", po::value<double>(&freq)->default_value(0), "RF center frequency in Hz") +        ("gain", po::value<float>(&gain)->default_value(0), "gain for the RF chain") +        // display parameters +        ("num-bins", po::value<size_t>(&num_bins)->default_value(512), "the number of bins in the DFT") +        ("frame-rate", po::value<double>(&frame_rate)->default_value(5), "frame rate of the display (fps)") +        ("ref-lvl", po::value<float>(&ref_lvl)->default_value(0), "reference level for the display (dB)") +        ("dyn-rng", po::value<float>(&dyn_rng)->default_value(60), "dynamic range for the display (dB)") +    ; +    po::variables_map vm; +    po::store(po::parse_command_line(argc, argv, desc), vm); +    po::notify(vm); + +    //print the help message +    if (vm.count("help") or not vm.count("rate")){ +        std::cout << boost::format("UHD RX ASCII Art DFT %s") % desc << std::endl; +        return ~0; +    } + +    //create a usrp device +    std::cout << std::endl; +    std::cout << boost::format("Creating the usrp device with: %s...") % args << std::endl; +    uhd::usrp::single_usrp::sptr sdev = uhd::usrp::single_usrp::make(args); +    std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; + +    //set the rx sample rate +    std::cout << boost::format("Setting RX Rate: %f Msps...") % (rate/1e6) << std::endl; +    sdev->set_rx_rate(rate); +    std::cout << boost::format("Actual RX Rate: %f Msps...") % (sdev->get_rx_rate()/1e6) << std::endl << std::endl; + +    //set the rx center frequency +    std::cout << boost::format("Setting RX Freq: %f Mhz...") % (freq/1e6) << std::endl; +    sdev->set_rx_freq(freq); +    std::cout << boost::format("Actual RX Freq: %f Mhz...") % (sdev->get_rx_freq()/1e6) << std::endl << std::endl; + +    //set the rx rf gain +    std::cout << boost::format("Setting RX Gain: %f dB...") % gain << std::endl; +    sdev->set_rx_gain(gain); +    std::cout << boost::format("Actual RX Gain: %f dB...") % sdev->get_rx_gain() << std::endl << std::endl; + +    //allocate recv buffer and metatdata +    uhd::rx_metadata_t md; +    std::vector<std::complex<float> > buff(num_bins); +    //------------------------------------------------------------------ +    //-- Initialize +    //------------------------------------------------------------------ +    initscr(); //curses init +    sdev->issue_stream_cmd(uhd::stream_cmd_t::STREAM_MODE_START_CONTINUOUS); +    boost::system_time next_refresh = boost::get_system_time(); + +    //------------------------------------------------------------------ +    //-- Main loop +    //------------------------------------------------------------------ +    while (true){ +        //read a buffer's worth of samples every iteration +        size_t num_rx_samps = sdev->get_device()->recv( +            &buff.front(), buff.size(), md, +            uhd::io_type_t::COMPLEX_FLOAT32, +            uhd::device::RECV_MODE_FULL_BUFF +        ); +        if (num_rx_samps != buff.size()) continue; + +        //check and update the display refresh condition +        if (boost::get_system_time() < next_refresh) continue; +        next_refresh = boost::get_system_time() + boost::posix_time::microseconds(long(1e6/frame_rate)); + +        //calculate the dft and create the ascii art frame +        acsii_art_dft::log_pwr_dft_type lpdft( +            acsii_art_dft::log_pwr_dft(&buff.front(), num_rx_samps) +        ); +        std::string frame = acsii_art_dft::dft_to_plot( +            lpdft, COLS, LINES, +            sdev->get_rx_rate(), +            sdev->get_rx_freq(), +            dyn_rng, ref_lvl +        ); + +        //curses screen handling: clear and print frame +        clear(); +        printw("%s", frame.c_str()); + +        //curses key handling: no timeout, any key to exit +        timeout(0); +        int ch = getch(); +        if (ch != KEY_RESIZE and ch != ERR) break; +    } + +    //------------------------------------------------------------------ +    //-- Cleanup +    //------------------------------------------------------------------ +    sdev->issue_stream_cmd(uhd::stream_cmd_t::STREAM_MODE_STOP_CONTINUOUS); +    endwin(); //curses done + +    //finished +    std::cout << std::endl << "Done!" << std::endl << std::endl; + +    return 0; +} diff --git a/host/examples/rx_samples_to_file.cpp b/host/examples/rx_samples_to_file.cpp new file mode 100644 index 000000000..c80d2a6de --- /dev/null +++ b/host/examples/rx_samples_to_file.cpp @@ -0,0 +1,135 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#include <uhd/utils/thread_priority.hpp> +#include <uhd/utils/safe_main.hpp> +#include <uhd/usrp/single_usrp.hpp> +#include <boost/program_options.hpp> +#include <boost/format.hpp> +#include <boost/thread.hpp> +#include <iostream> +#include <fstream> +#include <complex> + +namespace po = boost::program_options; + +int UHD_SAFE_MAIN(int argc, char *argv[]){ +    uhd::set_thread_priority_safe(); + +    //variables to be set by po +    std::string args, file; +    size_t total_num_samps; +    double rate, freq; +    float gain; + +    //setup the program options +    po::options_description desc("Allowed options"); +    desc.add_options() +        ("help", "help message") +        ("args", po::value<std::string>(&args)->default_value(""), "single uhd device address args") +        ("file", po::value<std::string>(&file)->default_value("out.16sc.dat"), "name of the file to write binary samples to") +        ("nsamps", po::value<size_t>(&total_num_samps)->default_value(1000), "total number of samples to receive") +        ("rate", po::value<double>(&rate)->default_value(100e6/16), "rate of incoming samples") +        ("freq", po::value<double>(&freq)->default_value(0), "rf center frequency in Hz") +        ("gain", po::value<float>(&gain)->default_value(0), "gain for the RF chain") +    ; +    po::variables_map vm; +    po::store(po::parse_command_line(argc, argv, desc), vm); +    po::notify(vm); + +    //print the help message +    if (vm.count("help")){ +        std::cout << boost::format("UHD RX to File %s") % desc << std::endl; +        return ~0; +    } + +    //create a usrp device +    std::cout << std::endl; +    std::cout << boost::format("Creating the usrp device with: %s...") % args << std::endl; +    uhd::usrp::single_usrp::sptr sdev = uhd::usrp::single_usrp::make(args); +    uhd::device::sptr dev = sdev->get_device(); +    std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; + +    //set the rx sample rate +    std::cout << boost::format("Setting RX Rate: %f Msps...") % (rate/1e6) << std::endl; +    sdev->set_rx_rate(rate); +    std::cout << boost::format("Actual RX Rate: %f Msps...") % (sdev->get_rx_rate()/1e6) << std::endl << std::endl; + +    //set the rx center frequency +    std::cout << boost::format("Setting RX Freq: %f Mhz...") % (freq/1e6) << std::endl; +    sdev->set_rx_freq(freq); +    std::cout << boost::format("Actual RX Freq: %f Mhz...") % (sdev->get_rx_freq()/1e6) << std::endl << std::endl; + +    //set the rx rf gain +    std::cout << boost::format("Setting RX Gain: %f dB...") % gain << std::endl; +    sdev->set_rx_gain(gain); +    std::cout << boost::format("Actual RX Gain: %f dB...") % sdev->get_rx_gain() << std::endl << std::endl; + +    boost::this_thread::sleep(boost::posix_time::seconds(1)); //allow for some setup time +    std::cout << "LO Locked = " << sdev->get_rx_lo_locked() << std::endl; + +    //setup streaming +    uhd::stream_cmd_t stream_cmd(uhd::stream_cmd_t::STREAM_MODE_NUM_SAMPS_AND_DONE); +    stream_cmd.num_samps = total_num_samps; +    stream_cmd.stream_now = true; +    sdev->issue_stream_cmd(stream_cmd); + +    //loop until total number of samples reached +    size_t num_acc_samps = 0; //number of accumulated samples +    uhd::rx_metadata_t md; +    std::vector<std::complex<short> > buff(dev->get_max_recv_samps_per_packet()); +    std::ofstream outfile(file.c_str(), std::ofstream::binary); + +    while(num_acc_samps < total_num_samps){ +        size_t num_rx_samps = dev->recv( +            &buff.front(), buff.size(), md, +            uhd::io_type_t::COMPLEX_INT16, +            uhd::device::RECV_MODE_ONE_PACKET +        ); + +        //handle the error codes +        switch(md.error_code){ +        case uhd::rx_metadata_t::ERROR_CODE_NONE: +            break; + +        case uhd::rx_metadata_t::ERROR_CODE_TIMEOUT: +            if (num_acc_samps == 0) continue; +            std::cout << boost::format( +                "Got timeout before all samples received, possible packet loss, exiting loop..." +            ) << std::endl; +            goto done_loop; + +        default: +            std::cout << boost::format( +                "Got error code 0x%x, exiting loop..." +            ) % md.error_code << std::endl; +            goto done_loop; +        } + +        //write complex short integer samples to the binary file +        outfile.write((const char*)&buff[0], num_rx_samps * sizeof(std::complex<short>)); + +        num_acc_samps += num_rx_samps; +    } done_loop: + +    outfile.close(); + +    //finished +    std::cout << std::endl << "Done!" << std::endl << std::endl; + +    return 0; +} diff --git a/host/examples/rx_samples_to_udp.cpp b/host/examples/rx_samples_to_udp.cpp new file mode 100644 index 000000000..488c95494 --- /dev/null +++ b/host/examples/rx_samples_to_udp.cpp @@ -0,0 +1,135 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#include <uhd/utils/thread_priority.hpp> +#include <uhd/utils/safe_main.hpp> +#include <uhd/usrp/single_usrp.hpp> +#include <uhd/transport/udp_simple.hpp> +#include <boost/program_options.hpp> +#include <boost/format.hpp> +#include <boost/thread.hpp> +#include <iostream> +#include <complex> + +namespace po = boost::program_options; + +int UHD_SAFE_MAIN(int argc, char *argv[]){ +    uhd::set_thread_priority_safe(); + +    //variables to be set by po +    std::string args; +    size_t total_num_samps; +    double rate, freq; +    float gain; +    std::string addr, port; + +    //setup the program options +    po::options_description desc("Allowed options"); +    desc.add_options() +        ("help", "help message") +        ("args", po::value<std::string>(&args)->default_value(""), "single uhd device address args") +        ("nsamps", po::value<size_t>(&total_num_samps)->default_value(1000), "total number of samples to receive") +        ("rate", po::value<double>(&rate)->default_value(100e6/16), "rate of incoming samples") +        ("freq", po::value<double>(&freq)->default_value(0), "rf center frequency in Hz") +        ("gain", po::value<float>(&gain)->default_value(0), "gain for the RF chain") +        ("port", po::value<std::string>(&port)->default_value("7124"), "server udp port") +        ("addr", po::value<std::string>(&addr)->default_value("192.168.1.10"), "resolvable server address") +    ; +    po::variables_map vm; +    po::store(po::parse_command_line(argc, argv, desc), vm); +    po::notify(vm); + +    //print the help message +    if (vm.count("help")){ +        std::cout << boost::format("UHD RX to UDP %s") % desc << std::endl; +        return ~0; +    } + +    //create a usrp device +    std::cout << std::endl; +    std::cout << boost::format("Creating the usrp device with: %s...") % args << std::endl; +    uhd::usrp::single_usrp::sptr sdev = uhd::usrp::single_usrp::make(args); +    uhd::device::sptr dev = sdev->get_device(); +    std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; + +    //set the rx sample rate +    std::cout << boost::format("Setting RX Rate: %f Msps...") % (rate/1e6) << std::endl; +    sdev->set_rx_rate(rate); +    std::cout << boost::format("Actual RX Rate: %f Msps...") % (sdev->get_rx_rate()/1e6) << std::endl << std::endl; + +    //set the rx center frequency +    std::cout << boost::format("Setting RX Freq: %f Mhz...") % (freq/1e6) << std::endl; +    sdev->set_rx_freq(freq); +    std::cout << boost::format("Actual RX Freq: %f Mhz...") % (sdev->get_rx_freq()/1e6) << std::endl << std::endl; + +    //set the rx rf gain +    std::cout << boost::format("Setting RX Gain: %f dB...") % gain << std::endl; +    sdev->set_rx_gain(gain); +    std::cout << boost::format("Actual RX Gain: %f dB...") % sdev->get_rx_gain() << std::endl << std::endl; + +    boost::this_thread::sleep(boost::posix_time::seconds(1)); //allow for some setup time +    std::cout << "LO Locked = " << sdev->get_rx_lo_locked() << std::endl; + +    //setup streaming +    uhd::stream_cmd_t stream_cmd(uhd::stream_cmd_t::STREAM_MODE_NUM_SAMPS_AND_DONE); +    stream_cmd.num_samps = total_num_samps; +    stream_cmd.stream_now = true; +    sdev->issue_stream_cmd(stream_cmd); + +    //loop until total number of samples reached +    size_t num_acc_samps = 0; //number of accumulated samples +    uhd::rx_metadata_t md; +    std::vector<std::complex<float> > buff(dev->get_max_recv_samps_per_packet()); +    uhd::transport::udp_simple::sptr udp_xport = uhd::transport::udp_simple::make_connected(addr, port); + +    while(num_acc_samps < total_num_samps){ +        size_t num_rx_samps = dev->recv( +            &buff.front(), buff.size(), md, +            uhd::io_type_t::COMPLEX_FLOAT32, +            uhd::device::RECV_MODE_ONE_PACKET +        ); + +        //handle the error codes +        switch(md.error_code){ +        case uhd::rx_metadata_t::ERROR_CODE_NONE: +            break; + +        case uhd::rx_metadata_t::ERROR_CODE_TIMEOUT: +            if (num_acc_samps == 0) continue; +            std::cout << boost::format( +                "Got timeout before all samples received, possible packet loss, exiting loop..." +            ) << std::endl; +            goto done_loop; + +        default: +            std::cout << boost::format( +                "Got error code 0x%x, exiting loop..." +            ) % md.error_code << std::endl; +            goto done_loop; +        } + +        //send complex single precision floating point samples over udp +        udp_xport->send(boost::asio::buffer(buff, num_rx_samps)); + +        num_acc_samps += num_rx_samps; +    } done_loop: + +    //finished +    std::cout << std::endl << "Done!" << std::endl << std::endl; + +    return 0; +} diff --git a/host/examples/rx_timed_samples.cpp b/host/examples/rx_timed_samples.cpp index 441665900..8a810811f 100644 --- a/host/examples/rx_timed_samples.cpp +++ b/host/examples/rx_timed_samples.cpp @@ -32,7 +32,7 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      std::string args;      time_t seconds_in_future;      size_t total_num_samps; -    double rx_rate, freq; +    double rate, freq;      //setup the program options      po::options_description desc("Allowed options"); @@ -41,7 +41,7 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){          ("args", po::value<std::string>(&args)->default_value(""), "single uhd device address args")          ("secs", po::value<time_t>(&seconds_in_future)->default_value(3), "number of seconds in the future to receive")          ("nsamps", po::value<size_t>(&total_num_samps)->default_value(1000), "total number of samples to receive") -        ("rxrate", po::value<double>(&rx_rate)->default_value(100e6/16), "rate of incoming samples") +        ("rate", po::value<double>(&rate)->default_value(100e6/16), "rate of incoming samples")          ("freq", po::value<double>(&freq)->default_value(0), "rf center frequency in Hz")          ("dilv", "specify to disable inner-loop verbose")      ; @@ -64,12 +64,17 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      uhd::device::sptr dev = sdev->get_device();      std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; -    //set properties on the device -    std::cout << boost::format("Setting RX Rate: %f Msps...") % (rx_rate/1e6) << std::endl; -    sdev->set_rx_rate(rx_rate); -    std::cout << boost::format("Actual RX Rate: %f Msps...") % (sdev->get_rx_rate()/1e6) << std::endl; -    std::cout << boost::format("Setting device timestamp to 0...") << std::endl; +    //set the rx sample rate +    std::cout << boost::format("Setting RX Rate: %f Msps...") % (rate/1e6) << std::endl; +    sdev->set_rx_rate(rate); +    std::cout << boost::format("Actual RX Rate: %f Msps...") % (sdev->get_rx_rate()/1e6) << std::endl << std::endl; + +    //set the rx center frequency +    std::cout << boost::format("Setting RX Freq: %f Mhz...") % (freq/1e6) << std::endl;      sdev->set_rx_freq(freq); +    std::cout << boost::format("Actual RX Freq: %f Mhz...") % (sdev->get_rx_freq()/1e6) << std::endl << std::endl; + +    std::cout << boost::format("Setting device timestamp to 0...") << std::endl;      sdev->set_time_now(uhd::time_spec_t(0.0));      //setup streaming diff --git a/host/examples/tx_timed_samples.cpp b/host/examples/tx_timed_samples.cpp index 863446682..799da37e0 100644 --- a/host/examples/tx_timed_samples.cpp +++ b/host/examples/tx_timed_samples.cpp @@ -33,7 +33,7 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      time_t seconds_in_future;      size_t total_num_samps;      size_t samps_per_packet; -    double tx_rate, freq; +    double rate, freq;      float ampl;      //setup the program options @@ -44,7 +44,7 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){          ("secs", po::value<time_t>(&seconds_in_future)->default_value(3), "number of seconds in the future to transmit")          ("nsamps", po::value<size_t>(&total_num_samps)->default_value(1000), "total number of samples to transmit")          ("spp", po::value<size_t>(&samps_per_packet)->default_value(1000), "number of samples per packet") -        ("txrate", po::value<double>(&tx_rate)->default_value(100e6/16), "rate of outgoing samples") +        ("rate", po::value<double>(&rate)->default_value(100e6/16), "rate of outgoing samples")          ("freq", po::value<double>(&freq)->default_value(0), "rf center frequency in Hz")          ("ampl", po::value<float>(&l)->default_value(float(0.3)), "amplitude of each sample")          ("dilv", "specify to disable inner-loop verbose") @@ -68,12 +68,17 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      uhd::device::sptr dev = sdev->get_device();      std::cout << boost::format("Using Device: %s") % sdev->get_pp_string() << std::endl; -    //set properties on the device -    std::cout << boost::format("Setting TX Rate: %f Msps...") % (tx_rate/1e6) << std::endl; -    sdev->set_tx_rate(tx_rate); -    std::cout << boost::format("Actual TX Rate: %f Msps...") % (sdev->get_tx_rate()/1e6) << std::endl; -    std::cout << boost::format("Setting device timestamp to 0...") << std::endl; +    //set the tx sample rate +    std::cout << boost::format("Setting TX Rate: %f Msps...") % (rate/1e6) << std::endl; +    sdev->set_tx_rate(rate); +    std::cout << boost::format("Actual TX Rate: %f Msps...") % (sdev->get_tx_rate()/1e6) << std::endl << std::endl; + +    //set the tx center frequency +    std::cout << boost::format("Setting TX Freq: %f Mhz...") % (freq/1e6) << std::endl;      sdev->set_tx_freq(freq); +    std::cout << boost::format("Actual TX Freq: %f Mhz...") % (sdev->get_tx_freq()/1e6) << std::endl << std::endl; + +    std::cout << boost::format("Setting device timestamp to 0...") << std::endl;      sdev->set_time_now(uhd::time_spec_t(0.0));      //allocate data to send diff --git a/host/include/uhd/types/CMakeLists.txt b/host/include/uhd/types/CMakeLists.txt index dbce21c98..a96976b5e 100644 --- a/host/include/uhd/types/CMakeLists.txt +++ b/host/include/uhd/types/CMakeLists.txt @@ -19,6 +19,7 @@  INSTALL(FILES      clock_config.hpp      device_addr.hpp +    dict.ipp      dict.hpp      io_type.hpp      mac_addr.hpp @@ -28,6 +29,7 @@ INSTALL(FILES      serial.hpp      stream_cmd.hpp      time_spec.hpp +    tune_request.hpp      tune_result.hpp      DESTINATION ${INCLUDE_DIR}/uhd/types  ) diff --git a/host/include/uhd/types/dict.hpp b/host/include/uhd/types/dict.hpp index de96ea768..6166140a0 100644 --- a/host/include/uhd/types/dict.hpp +++ b/host/include/uhd/types/dict.hpp @@ -19,11 +19,6 @@  #define INCLUDED_UHD_TYPES_DICT_HPP  #include <uhd/config.hpp> -#include <boost/foreach.hpp> -#include <boost/format.hpp> -#include <boost/lexical_cast.hpp> -#include <stdexcept> -#include <typeinfo>  #include <vector>  #include <list> @@ -34,14 +29,10 @@ namespace uhd{       */      template <typename Key, typename Val> class dict{      public: -        typedef std::pair<Key, Val> pair_t; -          /*!           * Create a new empty dictionary.           */ -        dict(void){ -            /* NOP */ -        } +        dict(void);          /*!           * Input iterator constructor: @@ -50,64 +41,42 @@ namespace uhd{           * \param last the end iterator           */          template <typename InputIterator> -        dict(InputIterator first, InputIterator last){ -            for(InputIterator it = first; it != last; it++){ -                _map.push_back(*it); -            } -        } - -        /*! -         * Destroy this dict. -         */ -        ~dict(void){ -            /* NOP */ -        } +        dict(InputIterator first, InputIterator last);          /*!           * Get the number of elements in this dict.           * \return the number of elements           */ -        std::size_t size(void) const{ -            return _map.size(); -        } +        std::size_t size(void) const;          /*!           * Get a list of the keys in this dict.           * Key order depends on insertion precedence.           * \return vector of keys           */ -        const std::vector<Key> keys(void) const{ -            std::vector<Key> keys; -            BOOST_FOREACH(const pair_t &p, _map){ -                keys.push_back(p.first); -            } -            return keys; -        } +        const std::vector<Key> keys(void) const;          /*!           * Get a list of the values in this dict.           * Value order depends on insertion precedence.           * \return vector of values           */ -        const std::vector<Val> vals(void) const{ -            std::vector<Val> vals; -            BOOST_FOREACH(const pair_t &p, _map){ -                vals.push_back(p.second); -            } -            return vals; -        } +        const std::vector<Val> vals(void) const;          /*!           * Does the dictionary contain this key?           * \param key the key to look for           * \return true if found           */ -        bool has_key(const Key &key) const{ -            BOOST_FOREACH(const pair_t &p, _map){ -                if (p.first == key) return true; -            } -            return false; -        } +        bool has_key(const Key &key) const; + +        /*! +         * Get a value in the dict or default. +         * \param key the key to look for +         * \param def use if key not found +         * \return the value or default +         */ +        const Val &get(const Key &key, const Val &def) const;          /*!           * Get a value for the given key if it exists. @@ -116,15 +85,7 @@ namespace uhd{           * \return the value at the key           * \throw an exception when not found           */ -        const Val &operator[](const Key &key) const{ -            BOOST_FOREACH(const pair_t &p, _map){ -                if (p.first == key) return p.second; -            } -            throw std::invalid_argument(str(boost::format( -                "key \"%s\" not found in dict(%s, %s)" -            ) % boost::lexical_cast<std::string>(key) -            % typeid(Key).name() % typeid(Val).name())); -        } +        const Val &operator[](const Key &key) const;          /*!           * Set a value for the given key, however, in reality @@ -132,13 +93,7 @@ namespace uhd{           * \param key the key to set to           * \return a reference to the value           */ -        Val &operator[](const Key &key){ -            BOOST_FOREACH(pair_t &p, _map){ -                if (p.first == key) return p.second; -            } -            _map.push_back(std::make_pair(key, Val())); -            return _map.back().second; -        } +        Val &operator[](const Key &key);          /*!           * Pop an item out of the dictionary. @@ -146,16 +101,15 @@ namespace uhd{           * \return the value of the item           * \throw an exception when not found           */ -        Val pop(const Key &key){ -            Val val = (*this)[key]; -            _map.remove(pair_t(key, val)); -            return val; -        } +        Val pop(const Key &key);      private: +        typedef std::pair<Key, Val> pair_t;          std::list<pair_t> _map; //private container      };  } //namespace uhd +#include <uhd/types/dict.ipp> +  #endif /* INCLUDED_UHD_TYPES_DICT_HPP */ diff --git a/host/include/uhd/types/dict.ipp b/host/include/uhd/types/dict.ipp new file mode 100644 index 000000000..ba05d5272 --- /dev/null +++ b/host/include/uhd/types/dict.ipp @@ -0,0 +1,128 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#ifndef INCLUDED_UHD_TYPES_DICT_IPP +#define INCLUDED_UHD_TYPES_DICT_IPP + +#include <boost/foreach.hpp> +#include <boost/format.hpp> +#include <boost/lexical_cast.hpp> +#include <stdexcept> +#include <typeinfo> + +namespace uhd{ + +    namespace /*anon*/{ +        template<typename Key, typename Val> +        struct key_not_found: std::out_of_range{ +            key_not_found(const Key &key): std::out_of_range( +                str(boost::format( +                    "key \"%s\" not found in dict(%s, %s)" +                    ) % boost::lexical_cast<std::string>(key) +                    % typeid(Key).name() % typeid(Val).name() +                ) +            ){ +                /* NOP */ +            } +        }; +    } // namespace /*anon*/ + +    template <typename Key, typename Val> +    dict<Key, Val>::dict(void){ +        /* NOP */ +    } + +    template <typename Key, typename Val> +    template <typename InputIterator> +    dict<Key, Val>::dict(InputIterator first, InputIterator last){ +        for(InputIterator it = first; it != last; it++){ +            _map.push_back(*it); +        } +    } + +    template <typename Key, typename Val> +    std::size_t dict<Key, Val>::size(void) const{ +        return _map.size(); +    } + +    template <typename Key, typename Val> +    const std::vector<Key> dict<Key, Val>::keys(void) const{ +        std::vector<Key> keys; +        BOOST_FOREACH(const pair_t &p, _map){ +            keys.push_back(p.first); +        } +        return keys; +    } + +    template <typename Key, typename Val> +    const std::vector<Val> dict<Key, Val>::vals(void) const{ +        std::vector<Val> vals; +        BOOST_FOREACH(const pair_t &p, _map){ +            vals.push_back(p.second); +        } +        return vals; +    } + +    template <typename Key, typename Val> +    bool dict<Key, Val>::has_key(const Key &key) const{ +        BOOST_FOREACH(const pair_t &p, _map){ +            if (p.first == key) return true; +        } +        return false; +    } + +    template <typename Key, typename Val> +    const Val &dict<Key, Val>::get(const Key &key, const Val &def) const{ +        BOOST_FOREACH(const pair_t &p, _map){ +            if (p.first == key) return p.second; +        } +        return def; +    } + +    template <typename Key, typename Val> +    const Val &dict<Key, Val>::operator[](const Key &key) const{ +        BOOST_FOREACH(const pair_t &p, _map){ +            if (p.first == key) return p.second; +        } +        throw key_not_found<Key, Val>(key); +    } + +    template <typename Key, typename Val> +    Val &dict<Key, Val>::operator[](const Key &key){ +        BOOST_FOREACH(pair_t &p, _map){ +            if (p.first == key) return p.second; +        } +        _map.push_back(std::make_pair(key, Val())); +        return _map.back().second; +    } + +    template <typename Key, typename Val> +    Val dict<Key, Val>::pop(const Key &key){ +        typename std::list<pair_t>::iterator it; +        for (it = _map.begin(); it != _map.end(); it++){ +            if (it->first == key){ +                Val val = it->second; +                _map.erase(it); +                return val; +            } +        } +        throw key_not_found<Key, Val>(key); +    } + +} //namespace uhd + +#endif /* INCLUDED_UHD_TYPES_DICT_IPP */ diff --git a/host/include/uhd/types/metadata.hpp b/host/include/uhd/types/metadata.hpp index 65952941c..3f250d13e 100644 --- a/host/include/uhd/types/metadata.hpp +++ b/host/include/uhd/types/metadata.hpp @@ -19,7 +19,6 @@  #define INCLUDED_UHD_TYPES_METADATA_HPP  #include <uhd/config.hpp> -#include <boost/cstdint.hpp>  #include <uhd/types/time_spec.hpp>  namespace uhd{ @@ -30,58 +29,59 @@ namespace uhd{       * The receive routines will convert IF data headers into metadata.       */      struct UHD_API rx_metadata_t{ -        /*! -         * Time specification: -         * Set from timestamps on incoming data when provided. -         */ +        //! Has time specification?          bool has_time_spec; + +        //! Time of the first sample.          time_spec_t time_spec;          /*! -         * Fragmentation flag and offset: +         * Fragmentation flag:           * Similar to IPv4 fragmentation: http://en.wikipedia.org/wiki/IPv4#Fragmentation_and_reassembly           * More fragments is true when the input buffer has insufficient size to fit           * an entire received packet. More fragments will be false for the last fragment. -         * The fragment offset is the sample number at the start of the receive buffer. -         * For non-fragmented receives, the fragment offset should always be zero.           */          bool more_fragments; -        size_t fragment_offset;          /*! -         * Burst flags: -         * Start of burst will be true for the first packet in the chain. -         * End of burst will be true for the last packet in the chain. +         * Fragmentation offset: +         * The fragment offset is the sample number at the start of the receive buffer. +         * For non-fragmented receives, the fragment offset should always be zero.           */ +        size_t fragment_offset; + +        //! Start of burst will be true for the first packet in the chain.          bool start_of_burst; + +        //! End of burst will be true for the last packet in the chain.          bool end_of_burst;          /*! -         * Error conditions: -         * - none: no error associated with this metadata -         * - timeout: no packet received, underlying code timed-out -         * - late command: a stream command was issued in the past -         * - broken chain: expected another stream command -         * - overflow: an internal receive buffer has filled -         * - bad packet: the buffer was unrecognizable as a vrt packet +         * The error condition on a receive call.           *           * Note: When an overrun occurs in continuous streaming mode,           * the device will continue to send samples to the host.           * For other streaming modes, streaming will discontinue           * until the user issues a new stream command.           * -         * Note: The metadata fields have meaning for the following error codes: +         * The metadata fields have meaning for the following error codes:           * - none           * - late command           * - broken chain           * - overflow           */          enum error_code_t { +            //! No error associated with this metadata.              ERROR_CODE_NONE         = 0x0, +            //! No packet received, implementation timed-out.              ERROR_CODE_TIMEOUT      = 0x1, +            //! A stream command was issued in the past.              ERROR_CODE_LATE_COMMAND = 0x2, +            //! Expected another stream command.              ERROR_CODE_BROKEN_CHAIN = 0x4, +            //! An internal receive buffer has filled.              ERROR_CODE_OVERFLOW     = 0x8, +            //! The packet could not be parsed.              ERROR_CODE_BAD_PACKET   = 0xf          } error_code;      }; @@ -93,19 +93,19 @@ namespace uhd{       */      struct UHD_API tx_metadata_t{          /*! -         * Time specification: -         * Set has time spec to false to perform a send "now". -         * Or, set to true, and fill in time spec for a send "at". +         * Has time specification? +         * - Set false to send immediately. +         * - Set true to send at the time specified by time spec.           */          bool has_time_spec; + +        //! When to send the first sample.          time_spec_t time_spec; -        /*! -         * Burst flags: -         * Set start of burst to true for the first packet in the chain. -         * Set end of burst to true for the last packet in the chain. -         */ +        //! Set start of burst to true for the first packet in the chain.          bool start_of_burst; + +        //! Set end of burst to true for the last packet in the chain.          bool end_of_burst;          /*! @@ -122,27 +122,27 @@ namespace uhd{          //! The channel number in a mimo configuration          size_t channel; -        /*! -         * Time specification: when the async event occurred. -         */ +        //! Has time specification?          bool has_time_spec; + +        //! When the async event occurred.          time_spec_t time_spec;          /*! -         * Event codes: -         * - success: a packet was successfully transmitted -         * - underflow: an internal send buffer has emptied -         * - sequence error: packet loss between host and device -         * - time error: packet had time that was late (or too early) -         * - underflow in packet: underflow occurred inside a packet -         * - sequence error in burst: packet loss within a burst +         * The type of event for a receive async message call.           */          enum event_code_t { +            //! A packet was successfully transmitted.              EVENT_CODE_SUCCESS    = 0x1, +            //! An internal send buffer has emptied.              EVENT_CODE_UNDERFLOW  = 0x2, +            //! Packet loss between host and device.              EVENT_CODE_SEQ_ERROR  = 0x4, +            //! Packet had time that was late (or too early).              EVENT_CODE_TIME_ERROR = 0x8, +            //! Underflow occurred inside a packet.              EVENT_CODE_UNDERFLOW_IN_PACKET = 0x10, +            //! Packet loss within a burst.              EVENT_CODE_SEQ_ERROR_IN_BURST  = 0x20          } event_code;      }; diff --git a/host/include/uhd/types/tune_request.hpp b/host/include/uhd/types/tune_request.hpp new file mode 100644 index 000000000..942b93251 --- /dev/null +++ b/host/include/uhd/types/tune_request.hpp @@ -0,0 +1,95 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#ifndef INCLUDED_UHD_TYPES_TUNE_REQUEST_HPP +#define INCLUDED_UHD_TYPES_TUNE_REQUEST_HPP + +#include <uhd/config.hpp> + +namespace uhd{ + +    /*! +     * A tune request instructs the implementation how to tune the RF chain. +     * The policies can be used to select automatic tuning or +     * fined control over the daughterboard IF and DSP tuning. +     * Not all combinations of policies are applicable. +     * Convenience constructors are supplied for most use cases. +     */ +    struct UHD_API tune_request_t{ +        /*! +         * Make a new tune request for a particular center frequency. +         * Use an automatic policy for the intermediate and DSP frequency +         * to tune the chain as close as possible to the target frequency. +         * \param target_freq the target frequency in Hz +         */ +        tune_request_t(double target_freq = 0); + +        /*! +         * Make a new tune request for a particular center frequency. +         * Use a manual policy for the intermediate frequency, +         * and an automatic policy for the DSP frequency, +         * to tune the chain as close as possible to the target frequency. +         * \param target_freq the target frequency in Hz +         * \param lo_off the LO offset frequency in Hz +         */ +        tune_request_t(double target_freq, double lo_off); + +        //! Policy options for tunable elements in the RF chain. +        enum policy_t { +            //! Do not set this argument, use current setting. +            POLICY_NONE   = 'N', +            //! Automatically determine the argument's value. +            POLICY_AUTO   = 'A', +            //! Use the argument's value for the setting. +            POLICY_MANUAL = 'M' +        }; + +        /*! +         * The target frequency of the overall chain in Hz. +         * Set this even if all policies are set to manual. +         */ +        double target_freq; + +        /*! +         * The policy for the intermediate frequency. +         * Automatic behavior: the target frequency + default LO offset. +         */ +        policy_t inter_freq_policy; + +        /*! +         * The intermediate frequency in Hz. +         * Set when the policy is set to manual. +         */ +        double inter_freq; + +        /*! +         * The policy for the DSP frequency. +         * Automatic behavior: the difference between the target and IF. +         */ +        policy_t dsp_freq_policy; + +        /*! +         * The DSP frequency in Hz. +         * Set when the policy is set to manual. +         */ +        double dsp_freq; + +    }; + +} //namespace uhd + +#endif /* INCLUDED_UHD_TYPES_TUNE_REQUEST_HPP */ diff --git a/host/include/uhd/usrp/CMakeLists.txt b/host/include/uhd/usrp/CMakeLists.txt index abddf3951..cdf31df87 100644 --- a/host/include/uhd/usrp/CMakeLists.txt +++ b/host/include/uhd/usrp/CMakeLists.txt @@ -34,6 +34,7 @@ INSTALL(FILES      ### utilities ###      dsp_utils.hpp +    mboard_eeprom.hpp      misc_utils.hpp      subdev_spec.hpp      tune_helper.hpp diff --git a/host/include/uhd/usrp/mboard_eeprom.hpp b/host/include/uhd/usrp/mboard_eeprom.hpp new file mode 100644 index 000000000..530b177be --- /dev/null +++ b/host/include/uhd/usrp/mboard_eeprom.hpp @@ -0,0 +1,64 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#ifndef INCLUDED_UHD_USRP_MBOARD_EEPROM_HPP +#define INCLUDED_UHD_USRP_MBOARD_EEPROM_HPP + +#include <uhd/config.hpp> +#include <uhd/types/dict.hpp> +#include <uhd/types/serial.hpp> +#include <string> + +namespace uhd{ namespace usrp{ + +    /*! +     * The motherboard EEPROM object: +     * Knows how to read and write the EEPROM for various USRPs. +     * The class inherits from a string, string dictionary. +     * Use the dictionary interface to get and set values. +     * Commit to the EEPROM to save changed settings. +     */ +    struct UHD_API mboard_eeprom_t : uhd::dict<std::string, std::string>{ + +        //! Possible EEPROM maps types +        enum map_type{ +            MAP_N100, +            MAP_B000 +        }; + +        //! Make a new empty mboard eeprom +        mboard_eeprom_t(void); + +        /*! +         * Make a new mboard EEPROM handler. +         * \param iface the interface to i2c +         * \param map the map type enum +         */ +        mboard_eeprom_t(i2c_iface &iface, map_type map); + +        /*! +         * Write the contents of this object to the EEPROM. +         * \param iface the interface to i2c +         * \param map the map type enum +         */ +        void commit(i2c_iface &iface, map_type map); + +    }; + +}} //namespace + +#endif /* INCLUDED_UHD_USRP_MBOARD_EEPROM_HPP */ diff --git a/host/include/uhd/usrp/mboard_props.hpp b/host/include/uhd/usrp/mboard_props.hpp index 0f250f439..df94d1678 100644 --- a/host/include/uhd/usrp/mboard_props.hpp +++ b/host/include/uhd/usrp/mboard_props.hpp @@ -44,7 +44,8 @@ namespace uhd{ namespace usrp{          MBOARD_PROP_CLOCK_CONFIG    = 'C', //rw, clock_config_t          MBOARD_PROP_TIME_NOW        = 't', //rw, time_spec_t          MBOARD_PROP_TIME_NEXT_PPS   = 'T', //wo, time_spec_t -        MBOARD_PROP_STREAM_CMD      = 's'  //wo, stream_cmd_t +        MBOARD_PROP_STREAM_CMD      = 's', //wo, stream_cmd_t +        MBOARD_PROP_EEPROM_MAP      = 'M'  //wr, mboard_eeprom_t::sptr      };  }} //namespace diff --git a/host/include/uhd/usrp/mimo_usrp.hpp b/host/include/uhd/usrp/mimo_usrp.hpp index 78833e24e..a2092f04f 100644 --- a/host/include/uhd/usrp/mimo_usrp.hpp +++ b/host/include/uhd/usrp/mimo_usrp.hpp @@ -127,7 +127,7 @@ public:      virtual double get_rx_rate_all(void) = 0;      virtual tune_result_t set_rx_freq(size_t chan, double freq) = 0; -    virtual tune_result_t set_rx_freq(size_t chan, double freq, double lo_off) = 0; +    //virtual tune_result_t set_rx_freq(size_t chan, double freq, double lo_off) = 0;      virtual double get_rx_freq(size_t chan) = 0;      virtual freq_range_t get_rx_freq_range(size_t chan) = 0; @@ -161,7 +161,7 @@ public:      virtual double get_tx_rate_all(void) = 0;      virtual tune_result_t set_tx_freq(size_t chan, double freq) = 0; -    virtual tune_result_t set_tx_freq(size_t chan, double freq, double lo_off) = 0; +    //virtual tune_result_t set_tx_freq(size_t chan, double freq, double lo_off) = 0;      virtual double get_tx_freq(size_t chan) = 0;      virtual freq_range_t get_tx_freq_range(size_t chan) = 0; @@ -298,7 +298,7 @@ public:              time_spec_t time_0 = _mboard(0)[MBOARD_PROP_TIME_NOW].as<time_spec_t>();              time_spec_t time_i = _mboard(chan)[MBOARD_PROP_TIME_NOW].as<time_spec_t>();              if (time_i < time_0 or (time_i - time_0) > time_spec_t(0.01)){ //10 ms: greater than RTT but not too big -                uhd::print_warning(str(boost::format( +                uhd::warning::post(str(boost::format(                      "Detected time deviation between board %d and board 0.\n"                      "Board 0 time is %f seconds.\n"                      "Board %d time is %f seconds.\n" @@ -345,9 +345,9 @@ public:          return tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan), 0, target_freq);      } -    tune_result_t set_rx_freq(size_t chan, double target_freq, double lo_off){ -        return tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan), 0, target_freq, lo_off); -    } +    //tune_result_t set_rx_freq(size_t chan, double target_freq, double lo_off){ +    //    return tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan), 0, target_freq, lo_off); +    //}      double get_rx_freq(size_t chan){          return derive_freq_from_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan), 0); @@ -425,9 +425,9 @@ public:          return tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan), 0, target_freq);      } -    tune_result_t set_tx_freq(size_t chan, double target_freq, double lo_off){ -        return tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan), 0, target_freq, lo_off); -    } +    //tune_result_t set_tx_freq(size_t chan, double target_freq, double lo_off){ +    //    return tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan), 0, target_freq, lo_off); +    //}      double get_tx_freq(size_t chan){          return derive_freq_from_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan), 0); @@ -512,7 +512,7 @@ namespace uhd{ namespace usrp{   * The Make Function   **********************************************************************/  inline mimo_usrp::sptr mimo_usrp::make(const device_addr_t &dev_addr){ -    uhd::print_warning( +    uhd::warning::post(          "The mimo USRP interface has been deprecated.\n"          "Please switch to the multi USRP interface.\n"          "#include <uhd/usrp/multi_usrp.hpp>\n" diff --git a/host/include/uhd/usrp/multi_usrp.hpp b/host/include/uhd/usrp/multi_usrp.hpp index 2f71f80b1..98ba07fc0 100644 --- a/host/include/uhd/usrp/multi_usrp.hpp +++ b/host/include/uhd/usrp/multi_usrp.hpp @@ -23,6 +23,7 @@  #include <uhd/types/ranges.hpp>  #include <uhd/types/stream_cmd.hpp>  #include <uhd/types/clock_config.hpp> +#include <uhd/types/tune_request.hpp>  #include <uhd/types/tune_result.hpp>  #include <uhd/usrp/subdev_spec.hpp>  #include <uhd/usrp/dboard_iface.hpp> @@ -144,6 +145,14 @@ public:      virtual void set_time_unknown_pps(const time_spec_t &time_spec) = 0;      /*! +     * Are the times across all motherboards in this configuration synchronized? +     * Checks that all time registers are approximately close but not exact, +     * given that the RTT may varying for a control packet transaction. +     * \return true when all motherboards time registers are in sync +     */ +    virtual bool get_time_synchronized(void) = 0; + +    /*!       * Issue a stream command to the usrp device.       * This tells the usrp to send samples into the host.       * See the documentation for stream_cmd_t for more info. @@ -213,20 +222,13 @@ public:      /*!       * Set the RX center frequency. -     * \param freq the frequency in Hz +     * \param tune_request tune request instructions       * \param chan the channel index 0 to N-1       * \return a tune result object       */ -    virtual tune_result_t set_rx_freq(double freq, size_t chan) = 0; - -    /*! -     * Set the RX center frequency. -     * \param freq the frequency in Hz -     * \param lo_off an LO offset in Hz -     * \param chan the channel index 0 to N-1 -     * \return a tune result object -     */ -    virtual tune_result_t set_rx_freq(double freq, double lo_off, size_t chan) = 0; +    virtual tune_result_t set_rx_freq( +        const tune_request_t &tune_request, size_t chan = 0 +    ) = 0;      /*!       * Get the RX center frequency. @@ -399,20 +401,13 @@ public:      /*!       * Set the TX center frequency. -     * \param freq the frequency in Hz -     * \param chan the channel index 0 to N-1 -     * \return a tune result object -     */ -    virtual tune_result_t set_tx_freq(double freq, size_t chan) = 0; - -    /*! -     * Set the TX center frequency. -     * \param freq the frequency in Hz -     * \param lo_off an LO offset in Hz +     * \param tune_request tune request instructions       * \param chan the channel index 0 to N-1       * \return a tune result object       */ -    virtual tune_result_t set_tx_freq(double freq, double lo_off, size_t chan) = 0; +    virtual tune_result_t set_tx_freq( +        const tune_request_t &tune_request, size_t chan = 0 +    ) = 0;      /*!       * Get the TX center frequency. diff --git a/host/include/uhd/usrp/simple_usrp.hpp b/host/include/uhd/usrp/simple_usrp.hpp index 22f4d64ba..77416dbbd 100644 --- a/host/include/uhd/usrp/simple_usrp.hpp +++ b/host/include/uhd/usrp/simple_usrp.hpp @@ -117,7 +117,7 @@ public:      virtual double get_rx_rate(void) = 0;      virtual tune_result_t set_rx_freq(double freq) = 0; -    virtual tune_result_t set_rx_freq(double freq, double lo_off) = 0; +    //virtual tune_result_t set_rx_freq(double freq, double lo_off) = 0;      virtual double get_rx_freq(void) = 0;      virtual freq_range_t get_rx_freq_range(void) = 0; @@ -152,7 +152,7 @@ public:      virtual double get_tx_rate(void) = 0;      virtual tune_result_t set_tx_freq(double freq) = 0; -    virtual tune_result_t set_tx_freq(double freq, double lo_off) = 0; +    //virtual tune_result_t set_tx_freq(double freq, double lo_off) = 0;      virtual double get_tx_freq(void) = 0;      virtual freq_range_t get_tx_freq_range(void) = 0; @@ -243,9 +243,9 @@ public:          return _sdev->set_rx_freq(target_freq);      } -    tune_result_t set_rx_freq(double target_freq, double lo_off){ -        return _sdev->set_rx_freq(target_freq, lo_off); -    } +    //tune_result_t set_rx_freq(double target_freq, double lo_off){ +    //    return _sdev->set_rx_freq(target_freq, lo_off); +    //}      double get_rx_freq(void){          return _sdev->get_rx_freq(); @@ -318,9 +318,9 @@ public:          return _sdev->set_tx_freq(target_freq);      } -    tune_result_t set_tx_freq(double target_freq, double lo_off){ -        return _sdev->set_tx_freq(target_freq, lo_off); -    } +    //tune_result_t set_tx_freq(double target_freq, double lo_off){ +    //    return _sdev->set_tx_freq(target_freq, lo_off); +    //}      double get_tx_freq(void){          return _sdev->get_tx_freq(); @@ -374,7 +374,7 @@ namespace uhd{ namespace usrp{   * The Make Function   **********************************************************************/  inline simple_usrp::sptr simple_usrp::make(const device_addr_t &dev_addr){ -    uhd::print_warning( +    uhd::warning::post(          "The simple USRP interface has been deprecated.\n"          "Please switch to the single USRP interface.\n"          "#include <uhd/usrp/single_usrp.hpp>\n" diff --git a/host/include/uhd/usrp/single_usrp.hpp b/host/include/uhd/usrp/single_usrp.hpp index a068fbed8..26303fe10 100644 --- a/host/include/uhd/usrp/single_usrp.hpp +++ b/host/include/uhd/usrp/single_usrp.hpp @@ -23,6 +23,7 @@  #include <uhd/types/ranges.hpp>  #include <uhd/types/stream_cmd.hpp>  #include <uhd/types/clock_config.hpp> +#include <uhd/types/tune_request.hpp>  #include <uhd/types/tune_result.hpp>  #include <uhd/usrp/subdev_spec.hpp>  #include <uhd/usrp/dboard_iface.hpp> @@ -154,20 +155,13 @@ public:      /*!       * Set the RX center frequency. -     * \param freq the frequency in Hz +     * \param tune_request tune request instructions       * \param chan the channel index 0 to N-1       * \return a tune result object       */ -    virtual tune_result_t set_rx_freq(double freq, size_t chan = 0) = 0; - -    /*! -     * Set the RX center frequency. -     * \param freq the frequency in Hz -     * \param lo_off an LO offset in Hz -     * \param chan the channel index 0 to N-1 -     * \return a tune result object -     */ -    virtual tune_result_t set_rx_freq(double freq, double lo_off, size_t chan = 0) = 0; +    virtual tune_result_t set_rx_freq( +        const tune_request_t &tune_request, size_t chan = 0 +    ) = 0;      /*!       * Get the RX center frequency. @@ -330,20 +324,13 @@ public:      /*!       * Set the TX center frequency. -     * \param freq the frequency in Hz -     * \param chan the channel index 0 to N-1 -     * \return a tune result object -     */ -    virtual tune_result_t set_tx_freq(double freq, size_t chan = 0) = 0; - -    /*! -     * Set the TX center frequency. -     * \param freq the frequency in Hz -     * \param lo_off an LO offset in Hz +     * \param tune_request tune request instructions       * \param chan the channel index 0 to N-1       * \return a tune result object       */ -    virtual tune_result_t set_tx_freq(double freq, double lo_off, size_t chan = 0) = 0; +    virtual tune_result_t set_tx_freq( +        const tune_request_t &tune_request, size_t chan = 0 +    ) = 0;      /*!       * Get the TX center frequency. diff --git a/host/include/uhd/usrp/subdev_spec.hpp b/host/include/uhd/usrp/subdev_spec.hpp index 5de3bb3b8..b189724c9 100644 --- a/host/include/uhd/usrp/subdev_spec.hpp +++ b/host/include/uhd/usrp/subdev_spec.hpp @@ -26,10 +26,10 @@  namespace uhd{ namespace usrp{      /*! -     * A subdevice specification (daughterboard, subdevice) name pairing. +     * A subdevice specification (daughterboard slot, subdevice) name pairing.       */      struct UHD_API subdev_spec_pair_t : boost::equality_comparable<subdev_spec_pair_t>{ -        //! The daughterboard name +        //! The daughterboard slot name          std::string db_name;          //! The subdevice name @@ -50,7 +50,7 @@ namespace uhd{ namespace usrp{      UHD_API bool operator==(const subdev_spec_pair_t &, const subdev_spec_pair_t &);      /*! -     * A list of (daughterboard name, subdevice name) pairs: +     * A list of (daughterboard slot name, subdevice name) pairs:       *       * A subdevice specification represents a list of subdevices on a motherboard.       * The subdevices specified may span across multiple daughterboards; @@ -62,6 +62,11 @@ namespace uhd{ namespace usrp{       * The markup-string is a whitespace separated list of dboard:subdev pairs.       * The first pair represents the subdevice for channel zero,       * the second pair represents the subdevice for channel one, and so on. +     * +     * Special handling for empty conditions: +     * - An empty subdevice specification means: select the first subdevice found in the configuration +     * - An empty daughterboard name means: select the only daughterboard slot or error if multiple exist +     * - An empty subdevice name means: select the only subdevice on that board or error if multiple exist       */      class UHD_API subdev_spec_t : public std::vector<subdev_spec_pair_t>{      public: diff --git a/host/include/uhd/usrp/tune_helper.hpp b/host/include/uhd/usrp/tune_helper.hpp index ec133fa08..db12241c1 100644 --- a/host/include/uhd/usrp/tune_helper.hpp +++ b/host/include/uhd/usrp/tune_helper.hpp @@ -20,6 +20,7 @@  #include <uhd/config.hpp>  #include <uhd/wax.hpp> +#include <uhd/types/tune_request.hpp>  #include <uhd/types/tune_result.hpp>  namespace uhd{ namespace usrp{ @@ -32,23 +33,12 @@ namespace uhd{ namespace usrp{       * \param subdev the dboard subdevice object with properties       * \param ddc the mboard dsp object with properties       * \param chan the channel of the dsp to tune -     * \param target_freq the desired center frequency -     * \param lo_offset an offset for the subdevice IF from center +     * \param tune_request tune request instructions       * \return a tune result struct       */      UHD_API tune_result_t tune_rx_subdev_and_dsp(          wax::obj subdev, wax::obj ddc, size_t chan, -        double target_freq, double lo_offset -    ); - -    /*! -     * Tune a rx chain to the desired frequency: -     * Same as the above, except the LO offset -     * is calculated based on the subdevice and BW. -     */ -    UHD_API tune_result_t tune_rx_subdev_and_dsp( -        wax::obj subdev, wax::obj ddc, -        size_t chan, double target_freq +        const tune_request_t &tune_request      );      /*! @@ -70,23 +60,12 @@ namespace uhd{ namespace usrp{       * \param subdev the dboard subdevice object with properties       * \param duc the mboard dsp object with properties       * \param chan the channel of the dsp to tune -     * \param target_freq the desired center frequency -     * \param lo_offset an offset for the subdevice IF from center +     * \param tune_request tune request instructions       * \return a tune result struct       */      UHD_API tune_result_t tune_tx_subdev_and_dsp(          wax::obj subdev, wax::obj duc, size_t chan, -        double target_freq, double lo_offset -    ); - -    /*! -     * Tune a tx chain to the desired frequency: -     * Same as the above, except the LO offset -     * is calculated based on the subdevice and BW. -     */ -    UHD_API tune_result_t tune_tx_subdev_and_dsp( -        wax::obj subdev, wax::obj duc, -        size_t chan, double target_freq +        const tune_request_t &tune_request      );      /*! diff --git a/host/include/uhd/utils/warning.hpp b/host/include/uhd/utils/warning.hpp index 91d8400ab..a1e3f0d1e 100644 --- a/host/include/uhd/utils/warning.hpp +++ b/host/include/uhd/utils/warning.hpp @@ -19,16 +19,44 @@  #define INCLUDED_UHD_UTILS_WARNING_HPP  #include <uhd/config.hpp> +#include <boost/function.hpp> +#include <vector>  #include <string> -namespace uhd{ +namespace uhd{ namespace warning{ + +    //! Callback function type for a message handler +    typedef boost::function<void(std::string)> handler_t;      /*! -     * Print a formatted warning string to stderr. +     * Post a warning message to all registered handlers.       * \param msg the multiline warning message       */ -    UHD_API void print_warning(const std::string &msg); +    UHD_API void post(const std::string &msg); + +    /*! +     * Register a new handler with this name. +     * If the name was already registered for this name, +     * the old registered handler will be replaced. +     * \param name a unique name for this handler +     * \param handler the callback handler function +     */ +    UHD_API void register_handler(const std::string &name, const handler_t &handler); + +    /*! +     * Unregister a handler for this name. +     * \param name a unique name for a registered handler +     * \return the handler that was registered +     * \throw error when the name was not found in the registry +     */ +    UHD_API handler_t unregister_handler(const std::string &name); + +    /*! +     * Get a list of registered handler names. +     * \return a vector of unique string names +     */ +    UHD_API const std::vector<std::string> registry_names(void); -} //namespace uhd +}} //namespace uhd::warning  #endif /* INCLUDED_UHD_UTILS_WARNING_HPP */ diff --git a/host/lib/CMakeLists.txt b/host/lib/CMakeLists.txt index 81845de21..e4de7bcc7 100644 --- a/host/lib/CMakeLists.txt +++ b/host/lib/CMakeLists.txt @@ -16,6 +16,25 @@  #  ######################################################################## +# Check Python Modules +######################################################################## +PYTHON_CHECK_MODULE( +    "Python version 2.6 or greater" +    "platform" "platform.python_version() >= '2.6'" +    HAVE_PYTHON_PLAT_MIN_VERSION +) + +PYTHON_CHECK_MODULE( +    "Cheetah templates 2.0.0 or greater" +    "Cheetah" "Cheetah.Version >= '2.0.0'" +    HAVE_PYTHON_MODULE_CHEETAH +) + +IF(NOT HAVE_PYTHON_PLAT_MIN_VERSION OR NOT HAVE_PYTHON_MODULE_CHEETAH) +    MESSAGE(FATAL_ERROR "Error: python requirements not met for the build system.") +ENDIF(NOT HAVE_PYTHON_PLAT_MIN_VERSION OR NOT HAVE_PYTHON_MODULE_CHEETAH) + +########################################################################  # Helpful Macros  ########################################################################  MACRO(LIBUHD_APPEND_SOURCES) diff --git a/host/lib/ic_reg_maps/CMakeLists.txt b/host/lib/ic_reg_maps/CMakeLists.txt index 772166334..ac051b843 100644 --- a/host/lib/ic_reg_maps/CMakeLists.txt +++ b/host/lib/ic_reg_maps/CMakeLists.txt @@ -60,6 +60,16 @@ LIBUHD_PYTHON_GEN_SOURCE(  )  LIBUHD_PYTHON_GEN_SOURCE( +    ${CMAKE_SOURCE_DIR}/lib/ic_reg_maps/gen_max2112_regs.py +    ${CMAKE_BINARY_DIR}/lib/ic_reg_maps/max2112_regs.hpp +) + +LIBUHD_PYTHON_GEN_SOURCE( +    ${CMAKE_SOURCE_DIR}/lib/ic_reg_maps/gen_max2112_regs.py +    ${CMAKE_BINARY_DIR}/lib/ic_reg_maps/max2112_regs.hpp +) + +LIBUHD_PYTHON_GEN_SOURCE(      ${CMAKE_SOURCE_DIR}/lib/ic_reg_maps/gen_ad9862_regs.py      ${CMAKE_BINARY_DIR}/lib/ic_reg_maps/ad9862_regs.hpp  ) diff --git a/host/lib/ic_reg_maps/gen_max2112_regs.py b/host/lib/ic_reg_maps/gen_max2112_regs.py new file mode 100755 index 000000000..c2fc4e3e2 --- /dev/null +++ b/host/lib/ic_reg_maps/gen_max2112_regs.py @@ -0,0 +1,181 @@ +#!/usr/bin/env python +# +# Copyright 2010 Ettus Research LLC +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program.  If not, see <http://www.gnu.org/licenses/>. +# + +######################################################################## +# Template for raw text data describing write registers +# name addr[bit range inclusive] default optional enums +######################################################################## +WRITE_REGS_TMPL="""\ +######################################################################## +## Note: offsets given from perspective of data bits (excludes address) +######################################################################## +## +######################################################################## +## N-Divider MSB (0) Write +######################################################################## +frac                  0[7]          1       invalid, frac +n_divider_msb         0[0:6]        0 +######################################################################## +## N-Divider LSB (1) Write +######################################################################## +n_divider_lsb         1[0:7]        0x23 +~n_divider            n_divider_lsb, n_divider_msb +######################################################################## +## Charge Pump (2) Write +######################################################################## +cpmp                  2[6:7]        0 +cplin                 2[4:5]        1 +f_divider_mmsb        2[0:3]        0x2 +######################################################################## +## F-Divider MSB (3) Write +######################################################################## +f_divider_msb         3[0:7]        0xF6 +######################################################################## +## F-Divider LSB (4) Write +######################################################################## +f_divider_lsb         4[0:7]        0x84  +~f_divider            f_divider_lsb, f_divider_msb, f_divider_mmsb +######################################################################## +## XTAL-Divider R-Divider (5) Write +######################################################################## +#set $xtal_divider_names = ', '.join(map(lambda x: 'div' + str(x), range(1,9))) +xtal_divider          5[5:7]        0       $xtal_divider_names +r_divider             5[0:4]        1        +######################################################################## +## PLL (6) Write +######################################################################## +d24                   6[7]          1       div2, div4  ## div2 for LO <= 1125M, div4 > 1125M +cps                   6[6]          1       i_cp_from_icp, i_cp_from_vas +icp                   6[5]          0       i_cp_600ua, i_cp_1200ua +##reserved            6[0:4]        0 +######################################################################## +## VCO (7) Write +######################################################################## +vco                   7[3:7]        0x19 +vas                   7[2]          1       disabled, enabled +adl                   7[1]          1       disabled, enabled +ade                   7[0]          1       disabled, enabled +######################################################################## +## LPF (8) Write +######################################################################## +lp                    8[0:7]        0x4B    ## map(lambda x: "%0.2f"%((4e6 + (x - 12) * 290e3)/1e6), range(255)) in MHz +######################################################################## +## Control (9) Write +######################################################################## +stby                  9[7]          0       normal, disable_sig_and_synth +##reserved            9[6]          0 +pwdn                  9[5]          0       normal, invalid +##reserved            9[4]          0 +bbg                   9[0:3]        0       ## Baseband Gain in dB +######################################################################## +## Shutdown (0xA) Write +######################################################################## +##reserved            0xA[7]        0 +pll_shutdown          0xA[6]        0       normal, shutdown +div_shutdown          0xA[5]        0       normal, shutdown +vco_shutdown          0xA[4]        0       normal, shutdown +bb_shutdown           0xA[3]        0       normal, shutdown +rfmix_shutdown        0xA[2]        0       normal, shutdown +rfvga_shutdown        0xA[1]        0       normal, shutdown +fe_shutdown           0xA[0]        0       normal, shutdown +######################################################################## +## Test (0xB) Write +######################################################################## +cptst                 0xB[5:7]      0 +##reserved            0xB[4]        0 +turbo                 0xB[3]        1 +ld_mux                0xB[0:2]      0       refout=0, invalid +""" + +######################################################################## +# Template for raw text data describing read registers +# name addr[bit range inclusive] default optional enums +######################################################################## +READ_REGS_TMPL="""\ +######################################################################## +## Status Byte-1 (0xC) Read +######################################################################## +por                   0xC[7]        0       read, reset +vasa                  0xC[6]        0       vas_fail, vas_win +vase                  0xC[5]        0       active, inactive +ld                    0xC[4]        0       unlocked, locked +##reserved            0xC[0:3]      0 +######################################################################## +## Status Byte-2 (0xD) Read +######################################################################## +vcosbr                0xD[3:7]      0       ## vco band readback +adc                   0xD[0:2]      0       ool0, lock0, vaslock0, vaslock1, vaslock2, vaslock3, lock1, ool1 +""" + +######################################################################## +# Template for methods in the body of the struct +######################################################################## +BODY_TMPL="""\ +boost::uint8_t get_reg(boost::uint8_t addr){ +    boost::uint8_t reg = 0; +    switch(addr){ +    #for $addr in sorted(set(map(lambda r: r.get_addr(), $regs))) +    case $addr: +        #for $reg in filter(lambda r: r.get_addr() == addr, $regs) +        reg |= (boost::uint8_t($reg.get_name()) & $reg.get_mask()) << $reg.get_shift(); +        #end for +        break; +    #end for +    } +    return boost::uint8_t(reg); +} + +void set_reg(boost::uint8_t addr, boost::uint8_t reg){ +    switch(addr){ +    #for $addr in sorted(set(map(lambda r: r.get_addr(), $regs))) +    case $addr: +        #for $reg in filter(lambda r: r.get_addr() == addr, $regs) +        $reg.get_name() = $(reg.get_type())((reg >> $reg.get_shift()) & $reg.get_mask()); +        #end for +        break; +    #end for +    } +} +""" + +SPLIT_REGS_HELPER_TMPL="""\ +#for $divname in ['n','f'] +void set_$(divname)_divider(boost::uint32_t $divname){ +    #for $regname in sorted(map(lambda r: r.get_name(), filter(lambda r: r.get_name().find(divname + '_divider') == 0, $regs))) +    #end for +} +#end for +""" +    #$regname = boost::uint8_t($divname & $regs[regname].get_mask()); +    #$divname = boost::uint32_t($divname >> $regs[regname].get_shift()); + +if __name__ == '__main__': +    import common; common.generate( +        name='max2112_write_regs', +        regs_tmpl=WRITE_REGS_TMPL, +        body_tmpl=BODY_TMPL, +        file=__file__, +    ) + +    import common; common.generate( +        name='max2112_read_regs', +        regs_tmpl=READ_REGS_TMPL, +        body_tmpl=BODY_TMPL, +        file=__file__, +        append=True, +    ) diff --git a/host/lib/transport/udp_zero_copy_asio.cpp b/host/lib/transport/udp_zero_copy_asio.cpp index d84aeefdd..ed29864e9 100644 --- a/host/lib/transport/udp_zero_copy_asio.cpp +++ b/host/lib/transport/udp_zero_copy_asio.cpp @@ -336,7 +336,7 @@ template<typename Opt> static void resize_buff_helper(          else std::cout << boost::format(              "Current %s sock buff size: %d bytes"          ) % name % actual_size << std::endl; -        if (actual_size < target_size) uhd::print_warning(str(boost::format( +        if (actual_size < target_size) uhd::warning::post(str(boost::format(              "The %s buffer is smaller than the requested size.\n"              "The minimum recommended buffer size is %d bytes.\n"              "See the transport application notes on buffer resizing.\n%s" diff --git a/host/lib/types.cpp b/host/lib/types.cpp index 6aa82b012..e5e6a2512 100644 --- a/host/lib/types.cpp +++ b/host/lib/types.cpp @@ -17,6 +17,7 @@  #include <uhd/utils/assert.hpp>  #include <uhd/types/ranges.hpp> +#include <uhd/types/tune_request.hpp>  #include <uhd/types/tune_result.hpp>  #include <uhd/types/clock_config.hpp>  #include <uhd/types/stream_cmd.hpp> @@ -58,6 +59,26 @@ freq_range_t::freq_range_t(double min, double max):  }  /*********************************************************************** + * tune request + **********************************************************************/ +tune_request_t::tune_request_t(double target_freq): +    target_freq(target_freq), +    inter_freq_policy(POLICY_AUTO), +    dsp_freq_policy(POLICY_AUTO) +{ +    /* NOP */ +} + +tune_request_t::tune_request_t(double target_freq, double lo_off): +    target_freq(target_freq), +    inter_freq_policy(POLICY_MANUAL), +    inter_freq(target_freq + lo_off), +    dsp_freq_policy(POLICY_AUTO) +{ +    /* NOP */ +} + +/***********************************************************************   * tune result   **********************************************************************/  std::string tune_result_t::to_pp_string(void) const{ @@ -229,22 +250,19 @@ mac_addr_t mac_addr_t::from_bytes(const byte_vector_t &bytes){  mac_addr_t mac_addr_t::from_string(const std::string &mac_addr_str){ -    byte_vector_t bytes = boost::assign::list_of -        (0x00)(0x50)(0xC2)(0x85)(0x30)(0x00); // Matt's IAB +    byte_vector_t bytes;      try{ -        //only allow patterns of xx:xx or xx:xx:xx:xx:xx:xx -        //the IAB above will fill in for the shorter pattern -        if (mac_addr_str.size() != 5 and mac_addr_str.size() != 17) -            throw std::runtime_error("expected exactly 5 or 17 characters"); +        if (mac_addr_str.size() != 17){ +            throw std::runtime_error("expected exactly 17 characters"); +        }          //split the mac addr hex string at the colons -        size_t i = 0;          BOOST_FOREACH(const std::string &hex_str, std::split_string(mac_addr_str, ":")){              int hex_num;              std::istringstream iss(hex_str);              iss >> std::hex >> hex_num; -            bytes[i++] = boost::uint8_t(hex_num); +            bytes.push_back(boost::uint8_t(hex_num));          }      } diff --git a/host/lib/usrp/CMakeLists.txt b/host/lib/usrp/CMakeLists.txt index eeb181e0b..3d832c356 100644 --- a/host/lib/usrp/CMakeLists.txt +++ b/host/lib/usrp/CMakeLists.txt @@ -23,6 +23,7 @@ LIBUHD_APPEND_SOURCES(      ${CMAKE_SOURCE_DIR}/lib/usrp/dboard_id.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/dboard_manager.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/dsp_utils.cpp +    ${CMAKE_SOURCE_DIR}/lib/usrp/mboard_eeprom.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/misc_utils.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/multi_usrp.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/single_usrp.cpp diff --git a/host/lib/usrp/dboard/CMakeLists.txt b/host/lib/usrp/dboard/CMakeLists.txt index 8d3d11530..79cd42d18 100644 --- a/host/lib/usrp/dboard/CMakeLists.txt +++ b/host/lib/usrp/dboard/CMakeLists.txt @@ -25,5 +25,6 @@ LIBUHD_APPEND_SOURCES(      ${CMAKE_SOURCE_DIR}/lib/usrp/dboard/db_dbsrx.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/dboard/db_unknown.cpp      ${CMAKE_SOURCE_DIR}/lib/usrp/dboard/db_tvrx.cpp +    ${CMAKE_SOURCE_DIR}/lib/usrp/dboard/db_dbsrx2.cpp  ) diff --git a/host/lib/usrp/dboard/db_basic_and_lf.cpp b/host/lib/usrp/dboard/db_basic_and_lf.cpp index 41f6f8002..f03dd43d1 100644 --- a/host/lib/usrp/dboard/db_basic_and_lf.cpp +++ b/host/lib/usrp/dboard/db_basic_and_lf.cpp @@ -20,6 +20,7 @@  #include <uhd/types/ranges.hpp>  #include <uhd/utils/assert.hpp>  #include <uhd/utils/static.hpp> +#include <uhd/utils/warning.hpp>  #include <uhd/usrp/dboard_base.hpp>  #include <uhd/usrp/dboard_manager.hpp>  #include <boost/assign/list_of.hpp> @@ -30,6 +31,16 @@ using namespace uhd::usrp;  using namespace boost::assign;  /*********************************************************************** + * Constants + **********************************************************************/ +static const uhd::dict<std::string, double> subdev_bandwidth_scalar = map_list_of +    ("A", 1.0) +    ("B", 1.0) +    ("AB", 2.0) +    ("BA", 2.0) +; + +/***********************************************************************   * The basic and lf boards:   *   They share a common class because only the frequency bounds differ.   **********************************************************************/ @@ -68,11 +79,11 @@ static const uhd::dict<std::string, subdev_conn_t> sd_name_to_conn = map_list_of   * Register the basic and LF dboards   **********************************************************************/  static dboard_base::sptr make_basic_rx(dboard_base::ctor_args_t args){ -    return dboard_base::sptr(new basic_rx(args, 90e9)); +    return dboard_base::sptr(new basic_rx(args, 250e6));  }  static dboard_base::sptr make_basic_tx(dboard_base::ctor_args_t args){ -    return dboard_base::sptr(new basic_tx(args, 90e9)); +    return dboard_base::sptr(new basic_tx(args, 250e6));  }  static dboard_base::sptr make_lf_rx(dboard_base::ctor_args_t args){ @@ -161,6 +172,10 @@ void basic_rx::rx_get(const wax::obj &key_, wax::obj &val){          val = true; //there is no LO, so it must be true!          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = subdev_bandwidth_scalar[get_subdev_name()]*_max_freq; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -185,6 +200,14 @@ void basic_rx::rx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("%s: No tunable bandwidth, fixed filtered to %0.2fMHz") +                % get_rx_id().to_pp_string() % _max_freq +            ) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } @@ -260,6 +283,10 @@ void basic_tx::tx_get(const wax::obj &key_, wax::obj &val){          val = true; //there is no LO, so it must be true!          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = subdev_bandwidth_scalar[get_subdev_name()]*_max_freq; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -284,6 +311,14 @@ void basic_tx::tx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("%s: No tunable bandwidth, fixed filtered to %0.2fMHz") +                % get_tx_id().to_pp_string() % _max_freq +            ) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/dboard/db_dbsrx.cpp b/host/lib/usrp/dboard/db_dbsrx.cpp index 0b8b4db83..85251bdf9 100644 --- a/host/lib/usrp/dboard/db_dbsrx.cpp +++ b/host/lib/usrp/dboard/db_dbsrx.cpp @@ -175,7 +175,7 @@ UHD_STATIC_BLOCK(reg_dbsrx_dboard){  dbsrx::dbsrx(ctor_args_t args) : rx_dboard_base(args){      //warn user about incorrect DBID on USRP1, requires R193 populated      if (this->get_iface()->get_special_props().soft_clock_divider and this->get_rx_id() == 0x000D) -        uhd::print_warning( +        uhd::warning::post(              str(boost::format(                  "DBSRX: incorrect dbid\n"                  "Expected dbid 0x0002 and R193\n" @@ -186,7 +186,7 @@ dbsrx::dbsrx(ctor_args_t args) : rx_dboard_base(args){      //warn user about incorrect DBID on non-USRP1, requires R194 populated      if (not this->get_iface()->get_special_props().soft_clock_divider and this->get_rx_id() == 0x0002) -        uhd::print_warning( +        uhd::warning::post(              str(boost::format(                  "DBSRX: incorrect dbid\n"                  "Expected dbid 0x000D and R194\n" @@ -236,8 +236,10 @@ void dbsrx::set_lo_freq(double target_freq){      bool update_filter_settings = false;      //choose refclock      std::vector<double> clock_rates = this->get_iface()->get_clock_rates(dboard_iface::UNIT_RX); +    const double max_clock_rate = std::sorted(clock_rates).back();      BOOST_FOREACH(ref_clock, std::reversed(std::sorted(clock_rates))){          if (ref_clock > 27.0e6) continue; +        if (size_t(max_clock_rate/ref_clock)%2 == 1) continue; //reject asymmetric clocks (odd divisors)          //choose m_divider such that filter tuning constraint is met          m = 31; @@ -340,7 +342,7 @@ void dbsrx::set_lo_freq(double target_freq){          //vtune is too low, try lower frequency vco          if (_max2118_read_regs.adc == 0){              if (_max2118_write_regs.osc_band == 0){ -                uhd::print_warning( +                uhd::warning::post(                      str(boost::format(                          "DBSRX: Tuning exceeded vco range, _max2118_write_regs.osc_band == %d\n"                           ) % int(_max2118_write_regs.osc_band)) @@ -354,7 +356,7 @@ void dbsrx::set_lo_freq(double target_freq){          //vtune is too high, try higher frequency vco          if (_max2118_read_regs.adc == 7){              if (_max2118_write_regs.osc_band == 7){ -                uhd::print_warning( +                uhd::warning::post(                      str(boost::format(                          "DBSRX: Tuning exceeded vco range, _max2118_write_regs.osc_band == %d\n"                           ) % int(_max2118_write_regs.osc_band)) @@ -561,7 +563,7 @@ void dbsrx::rx_get(const wax::obj &key_, wax::obj &val){          return;      case SUBDEV_PROP_BANDWIDTH: -        val = _bandwidth; +        val = 2*_bandwidth; //_bandwidth is low-pass, we want complex double-sided          return;      default: UHD_THROW_PROP_GET_ERROR(); @@ -586,7 +588,7 @@ void dbsrx::rx_set(const wax::obj &key_, const wax::obj &val){          return; //always enabled      case SUBDEV_PROP_BANDWIDTH: -        this->set_bandwidth(val.as<double>()); +        this->set_bandwidth(val.as<double>()/2.0); //complex double-sided, we want low-pass          return;      default: UHD_THROW_PROP_SET_ERROR(); diff --git a/host/lib/usrp/dboard/db_dbsrx2.cpp b/host/lib/usrp/dboard/db_dbsrx2.cpp new file mode 100644 index 000000000..5a65e6123 --- /dev/null +++ b/host/lib/usrp/dboard/db_dbsrx2.cpp @@ -0,0 +1,439 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +// No RX IO Pins Used + +#include "max2112_regs.hpp" +#include <uhd/utils/static.hpp> +#include <uhd/utils/assert.hpp> +#include <uhd/utils/algorithm.hpp> +#include <uhd/types/ranges.hpp> +#include <uhd/types/dict.hpp> +#include <uhd/usrp/subdev_props.hpp> +#include <uhd/usrp/dboard_base.hpp> +#include <uhd/usrp/dboard_manager.hpp> +#include <boost/assign/list_of.hpp> +#include <boost/format.hpp> +#include <boost/thread.hpp> +#include <boost/math/special_functions/round.hpp> +#include <utility> + +using namespace uhd; +using namespace uhd::usrp; +using namespace boost::assign; + +/*********************************************************************** + * The DBSRX2 constants + **********************************************************************/ +static const bool dbsrx2_debug = false; + +static const freq_range_t dbsrx2_freq_range(0.8e9, 2.4e9); + +static const int dbsrx2_ref_divider = 4; // Hitachi HMC426 divider (U7) + +static const prop_names_t dbsrx2_antennas = list_of("J3"); + +static const uhd::dict<std::string, gain_range_t> dbsrx2_gain_ranges = map_list_of +    ("GC1", gain_range_t(0, 73, float(0.05))) +    ("BBG", gain_range_t(0, 15, 1)) +; + +/*********************************************************************** + * The DBSRX2 dboard class + **********************************************************************/ +class dbsrx2 : public rx_dboard_base{ +public: +    dbsrx2(ctor_args_t args); +    ~dbsrx2(void); + +    void rx_get(const wax::obj &key, wax::obj &val); +    void rx_set(const wax::obj &key, const wax::obj &val); + +private: +    double _lo_freq; +    double _bandwidth; +    uhd::dict<std::string, float> _gains; +    max2112_write_regs_t _max2112_write_regs; +    max2112_read_regs_t _max2112_read_regs; +    boost::uint8_t _max2112_addr(){ //0x60 or 0x61 depending on which side +        return (this->get_iface()->get_special_props().mangle_i2c_addrs)? 0x60 : 0x61; +    } + +    void set_lo_freq(double target_freq); +    void set_gain(float gain, const std::string &name); +    void set_bandwidth(double bandwidth); + +    void send_reg(boost::uint8_t start_reg, boost::uint8_t stop_reg){ +        start_reg = boost::uint8_t(std::clip(int(start_reg), 0x0, 0xB)); +        stop_reg = boost::uint8_t(std::clip(int(stop_reg), 0x0, 0xB)); + +        for(boost::uint8_t start_addr=start_reg; start_addr <= stop_reg; start_addr += sizeof(boost::uint32_t) - 1){ +            int num_bytes = int(stop_reg - start_addr + 1) > int(sizeof(boost::uint32_t)) - 1 ? sizeof(boost::uint32_t) - 1 : stop_reg - start_addr + 1; + +            //create buffer for register data (+1 for start address) +            byte_vector_t regs_vector(num_bytes + 1); + +            //first byte is the address of first register +            regs_vector[0] = start_addr; + +            //get the register data +            for(int i=0; i<num_bytes; i++){ +                regs_vector[1+i] = _max2112_write_regs.get_reg(start_addr+i); +                if(dbsrx2_debug) std::cerr << boost::format( +                    "DBSRX2: send reg 0x%02x, value 0x%04x, start_addr = 0x%04x, num_bytes %d" +                ) % int(start_addr+i) % int(regs_vector[1+i]) % int(start_addr) % num_bytes << std::endl; +            } + +            //send the data +            this->get_iface()->write_i2c( +                _max2112_addr(), regs_vector +            ); +        } +    } + +    void read_reg(boost::uint8_t start_reg, boost::uint8_t stop_reg){ +        static const boost::uint8_t status_addr = 0xC; +        start_reg = boost::uint8_t(std::clip(int(start_reg), 0x0, 0xD)); +        stop_reg = boost::uint8_t(std::clip(int(stop_reg), 0x0, 0xD)); + +        for(boost::uint8_t start_addr=start_reg; start_addr <= stop_reg; start_addr += sizeof(boost::uint32_t)){ +            int num_bytes = int(stop_reg - start_addr + 1) > int(sizeof(boost::uint32_t)) ? sizeof(boost::uint32_t) : stop_reg - start_addr + 1; + +            //create address to start reading register data +            byte_vector_t address_vector(1); +            address_vector[0] = start_addr; + +            //send the address +            this->get_iface()->write_i2c( +                _max2112_addr(), address_vector +            ); + +            //create buffer for register data +            byte_vector_t regs_vector(num_bytes); + +            //read from i2c +            regs_vector = this->get_iface()->read_i2c( +                _max2112_addr(), num_bytes +            ); + +            for(boost::uint8_t i=0; i < num_bytes; i++){ +                if (i + start_addr >= status_addr){ +                    _max2112_read_regs.set_reg(i + start_addr, regs_vector[i]); +                    /* +                    if(dbsrx2_debug) std::cerr << boost::format( +                        "DBSRX2: set reg 0x%02x, value 0x%04x" +                    ) % int(i + start_addr) % int(_max2112_read_regs.get_reg(i + start_addr)) << std::endl; +                    */ +                } +                if(dbsrx2_debug) std::cerr << boost::format( +                    "DBSRX2: read reg 0x%02x, value 0x%04x, start_addr = 0x%04x, num_bytes %d" +                ) % int(start_addr+i) % int(regs_vector[i]) % int(start_addr) % num_bytes << std::endl; +            } +        } +    } + +    /*! +     * Is the LO locked? +     * \return true for locked +     */ +    bool get_locked(void){ +        read_reg(0xC, 0xD); + +        //mask and return lock detect +        bool locked = (_max2112_read_regs.ld & _max2112_read_regs.vasa & _max2112_read_regs.vase) != 0; + +        if(dbsrx2_debug) std::cerr << boost::format( +            "DBSRX2 locked: %d" +        ) % locked << std::endl; + +        return locked; +    } + +}; + +/*********************************************************************** + * Register the DBSRX2 dboard + **********************************************************************/ +// FIXME 0x67 is the default i2c address on USRP2 +//       need to handle which side for USRP1 with different address +static dboard_base::sptr make_dbsrx2(dboard_base::ctor_args_t args){ +    return dboard_base::sptr(new dbsrx2(args)); +} + +UHD_STATIC_BLOCK(reg_dbsrx2_dboard){ +    //register the factory function for the rx dbid +    dboard_manager::register_dboard(0x0012, &make_dbsrx2, "DBSRX2"); +} + +/*********************************************************************** + * Structors + **********************************************************************/ +dbsrx2::dbsrx2(ctor_args_t args) : rx_dboard_base(args){ +    //enable only the clocks we need +    this->get_iface()->set_clock_enabled(dboard_iface::UNIT_RX, true); + +    //set the gpio directions and atr controls (identically) +    this->get_iface()->set_pin_ctrl(dboard_iface::UNIT_RX, 0x0); // All unused in atr +    this->get_iface()->set_gpio_ddr(dboard_iface::UNIT_RX, 0x0); // All Inputs + +    //send initial register settings +    send_reg(0x0, 0xB); +    //for (boost::uint8_t addr=0; addr<=12; addr++) this->send_reg(addr, addr); + +    //set defaults for LO, gains +    set_lo_freq(dbsrx2_freq_range.min); +    BOOST_FOREACH(const std::string &name, dbsrx2_gain_ranges.keys()){ +        set_gain(dbsrx2_gain_ranges[name].min, name); +    } + +    set_bandwidth(40e6); // default bandwidth from datasheet +    get_locked(); + +    _max2112_write_regs.bbg = boost::math::iround(std::clip<float>(0, dbsrx2_gain_ranges["BBG"].min, dbsrx2_gain_ranges["BBG"].max)); +    send_reg(0x9, 0x9); +} + +dbsrx2::~dbsrx2(void){ +} + + +/*********************************************************************** + * Tuning + **********************************************************************/ +void dbsrx2::set_lo_freq(double target_freq){ +    //target_freq = std::clip(target_freq, dbsrx2_freq_range.min, dbsrx2_freq_range.max); + +    //variables used in the calculation below +    int scaler = target_freq > 1125e6 ? 2 : 4; +    double ref_freq = this->get_iface()->get_clock_rate(dboard_iface::UNIT_RX); +    int R, intdiv, fracdiv, ext_div; +    double N; + +    //compute tuning variables +    ext_div = dbsrx2_ref_divider; // 12MHz < ref_freq/ext_divider < 30MHz + +    R = 1; //Divide by 1 is the only tested value + +    N = (target_freq*R*ext_div)/(ref_freq); //actual spec range is (19, 251) +    intdiv = int(std::floor(N)); //  if (intdiv < 19  or intdiv > 251) continue; +    fracdiv = boost::math::iround((N - intdiv)*double(1 << 20)); + +    //calculate the actual freq from the values above +    N = double(intdiv) + double(fracdiv)/double(1 << 20); +    _lo_freq = (N*ref_freq)/(R*ext_div); + +    //load new counters into registers +    _max2112_write_regs.set_n_divider(intdiv); +    _max2112_write_regs.set_f_divider(fracdiv); +    _max2112_write_regs.r_divider = R; +    _max2112_write_regs.d24 = scaler == 4 ? max2112_write_regs_t::D24_DIV4 : max2112_write_regs_t::D24_DIV2; + +    //debug output of calculated variables +    if (dbsrx2_debug) std::cerr +        << boost::format("DBSRX2 tune:\n") +        << boost::format("    R=%d, N=%f, scaler=%d, ext_div=%d\n") % R % N % scaler % ext_div +        << boost::format("    int=%d, frac=%d, d24=%d\n") % intdiv % fracdiv % int(_max2112_write_regs.d24) +        << boost::format("    Ref    Freq=%fMHz\n") % (ref_freq/1e6) +        << boost::format("    Target Freq=%fMHz\n") % (target_freq/1e6) +        << boost::format("    Actual Freq=%fMHz\n") % (_lo_freq/1e6) +        << std::endl; + +    //send the registers +    send_reg(0x0, 0x7); + +    //FIXME: probably unnecessary to call get_locked here +    //get_locked(); + +} + +/*********************************************************************** + * Gain Handling + **********************************************************************/ +/*! + * Convert a requested gain for the BBG vga into the integer register value. + * The gain passed into the function will be set to the actual value. + * \param gain the requested gain in dB + * \return 4 bit the register value + */ +static int gain_to_bbg_vga_reg(float &gain){ +    int reg = boost::math::iround(std::clip<float>(gain, dbsrx2_gain_ranges["BBG"].min, dbsrx2_gain_ranges["BBG"].max)); + +    gain = float(reg); + +    if (dbsrx2_debug) std::cerr  +        << boost::format("DBSRX2 BBG Gain:\n") +        << boost::format("    %f dB, bbg: %d") % gain % reg  +        << std::endl; + +    return reg; +} + +/*! + * Convert a requested gain for the GC1 rf vga into the dac_volts value. + * The gain passed into the function will be set to the actual value. + * \param gain the requested gain in dB + * \return dac voltage value + */ +static float gain_to_gc1_rfvga_dac(float &gain){ +    //clip the input +    gain = std::clip<float>(gain, dbsrx2_gain_ranges["GC1"].min, dbsrx2_gain_ranges["GC1"].max); + +    //voltage level constants +    static const float max_volts = float(0.5), min_volts = float(2.7); +    static const float slope = (max_volts-min_volts)/dbsrx2_gain_ranges["GC1"].max; + +    //calculate the voltage for the aux dac +    float dac_volts = gain*slope + min_volts; + +    if (dbsrx2_debug) std::cerr  +        << boost::format("DBSRX2 GC1 Gain:\n") +        << boost::format("    %f dB, dac_volts: %f V") % gain % dac_volts  +        << std::endl; + +    //the actual gain setting +    gain = (dac_volts - min_volts)/slope; + +    return dac_volts; +} + +void dbsrx2::set_gain(float gain, const std::string &name){ +    assert_has(dbsrx2_gain_ranges.keys(), name, "dbsrx2 gain name"); +    if (name == "BBG"){ +        _max2112_write_regs.bbg = gain_to_bbg_vga_reg(gain); +        send_reg(0x9, 0x9); +    } +    else if(name == "GC1"){ +        //write the new voltage to the aux dac +        this->get_iface()->write_aux_dac(dboard_iface::UNIT_RX, dboard_iface::AUX_DAC_A, gain_to_gc1_rfvga_dac(gain)); +    } +    else UHD_THROW_INVALID_CODE_PATH(); +    _gains[name] = gain; +} + +/*********************************************************************** + * Bandwidth Handling + **********************************************************************/ +void dbsrx2::set_bandwidth(double bandwidth){ +    //clip the input +    bandwidth = std::clip<double>(bandwidth, 4e6, 40e6); + +    _max2112_write_regs.lp = int((bandwidth/1e6 - 4)/0.29 + 12); +    _bandwidth = double(4 + (_max2112_write_regs.lp - 12) * 0.29)*1e6; + +    if (dbsrx2_debug) std::cerr  +        << boost::format("DBSRX2 Bandwidth:\n") +        << boost::format("    %f MHz, lp: %f V") % (_bandwidth/1e6) % int(_max2112_write_regs.lp) +        << std::endl; + +    this->send_reg(0x8, 0x8); +} + +/*********************************************************************** + * RX Get and Set + **********************************************************************/ +void dbsrx2::rx_get(const wax::obj &key_, wax::obj &val){ +    named_prop_t key = named_prop_t::extract(key_); + +    //handle the get request conditioned on the key +    switch(key.as<subdev_prop_t>()){ +    case SUBDEV_PROP_NAME: +        val = get_rx_id().to_pp_string(); +        return; + +    case SUBDEV_PROP_OTHERS: +        val = prop_names_t(); //empty +        return; + +    case SUBDEV_PROP_GAIN: +        assert_has(_gains.keys(), key.name, "dbsrx2 gain name"); +        val = _gains[key.name]; +        return; + +    case SUBDEV_PROP_GAIN_RANGE: +        assert_has(dbsrx2_gain_ranges.keys(), key.name, "dbsrx2 gain name"); +        val = dbsrx2_gain_ranges[key.name]; +        return; + +    case SUBDEV_PROP_GAIN_NAMES: +        val = prop_names_t(dbsrx2_gain_ranges.keys()); +        return; + +    case SUBDEV_PROP_FREQ: +        val = _lo_freq; +        return; + +    case SUBDEV_PROP_FREQ_RANGE: +        val = dbsrx2_freq_range; +        return; + +    case SUBDEV_PROP_ANTENNA: +        val = std::string("J3"); +        return; + +    case SUBDEV_PROP_ANTENNA_NAMES: +        val = dbsrx2_antennas; +        return; + +    case SUBDEV_PROP_CONNECTION: +        val = SUBDEV_CONN_COMPLEX_QI; +        return; + +    case SUBDEV_PROP_ENABLED: +        val = true; //always enabled +        return; + +    case SUBDEV_PROP_USE_LO_OFFSET: +        val = false; +        return; + +    case SUBDEV_PROP_LO_LOCKED: +        val = this->get_locked(); +        return; + +    case SUBDEV_PROP_BANDWIDTH: +        val = _bandwidth; +        return; + +    default: UHD_THROW_PROP_GET_ERROR(); +    } +} + +void dbsrx2::rx_set(const wax::obj &key_, const wax::obj &val){ +    named_prop_t key = named_prop_t::extract(key_); + +    //handle the get request conditioned on the key +    switch(key.as<subdev_prop_t>()){ + +    case SUBDEV_PROP_FREQ: +        this->set_lo_freq(val.as<double>()); +        return; + +    case SUBDEV_PROP_GAIN: +        this->set_gain(val.as<float>(), key.name); +        return; + +    case SUBDEV_PROP_ENABLED: +        return; //always enabled + +    case SUBDEV_PROP_BANDWIDTH: +        this->set_bandwidth(val.as<double>()); +        return; + +    default: UHD_THROW_PROP_SET_ERROR(); +    } +} + diff --git a/host/lib/usrp/dboard/db_rfx.cpp b/host/lib/usrp/dboard/db_rfx.cpp index 3c24d90db..152198c3a 100644 --- a/host/lib/usrp/dboard/db_rfx.cpp +++ b/host/lib/usrp/dboard/db_rfx.cpp @@ -43,6 +43,7 @@  #include <uhd/utils/assert.hpp>  #include <uhd/utils/static.hpp>  #include <uhd/utils/algorithm.hpp> +#include <uhd/utils/warning.hpp>  #include <uhd/usrp/dboard_id.hpp>  #include <uhd/usrp/dboard_base.hpp>  #include <uhd/usrp/dboard_manager.hpp> @@ -456,6 +457,10 @@ void rfx_xcvr::rx_get(const wax::obj &key_, wax::obj &val){          val = this->get_locked(dboard_iface::UNIT_RX);          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 2*20.0e6; //20MHz low-pass, we want complex double-sided +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -481,6 +486,12 @@ void rfx_xcvr::rx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("RFX: No tunable bandwidth, fixed filtered to 40MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } @@ -543,6 +554,10 @@ void rfx_xcvr::tx_get(const wax::obj &key_, wax::obj &val){          val = this->get_locked(dboard_iface::UNIT_TX);          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 2*20.0e6; //20MHz low-pass, we want complex double-sided +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -568,6 +583,12 @@ void rfx_xcvr::tx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("RFX: No tunable bandwidth, fixed filtered to 40MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/dboard/db_tvrx.cpp b/host/lib/usrp/dboard/db_tvrx.cpp index d39dc3bf8..2873e3d54 100644 --- a/host/lib/usrp/dboard/db_tvrx.cpp +++ b/host/lib/usrp/dboard/db_tvrx.cpp @@ -459,6 +459,10 @@ void tvrx::rx_get(const wax::obj &key_, wax::obj &val){          val = true;          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 6.0e6; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -479,6 +483,12 @@ void tvrx::rx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("TVRX: No tunable bandwidth, fixed filtered to 6MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/dboard/db_unknown.cpp b/host/lib/usrp/dboard/db_unknown.cpp index ec7ab440b..d0359d124 100644 --- a/host/lib/usrp/dboard/db_unknown.cpp +++ b/host/lib/usrp/dboard/db_unknown.cpp @@ -19,23 +19,52 @@  #include <uhd/types/ranges.hpp>  #include <uhd/utils/assert.hpp>  #include <uhd/utils/static.hpp> +#include <uhd/utils/warning.hpp>  #include <uhd/usrp/dboard_base.hpp>  #include <uhd/usrp/dboard_manager.hpp>  #include <boost/assign/list_of.hpp>  #include <boost/format.hpp> +#include <boost/foreach.hpp> +#include <boost/tuple/tuple.hpp> +#include <vector>  using namespace uhd;  using namespace uhd::usrp;  using namespace boost::assign;  /*********************************************************************** + * Utility functions + **********************************************************************/ +static void warn_if_old_rfx(const dboard_id_t &dboard_id, const std::string &xx){ +    typedef boost::tuple<std::string, dboard_id_t, dboard_id_t> old_ids_t; //name, rx_id, tx_id +    static const std::vector<old_ids_t> old_rfx_ids = list_of +        (old_ids_t("Flex 400 Classic",  0x0004, 0x0008)) +        (old_ids_t("Flex 900 Classic",  0x0005, 0x0009)) +        (old_ids_t("Flex 1200 Classic", 0x0006, 0x000a)) +        (old_ids_t("Flex 1800 Classic", 0x0030, 0x0031)) +        (old_ids_t("Flex 2400 Classic", 0x0007, 0x000b)) +    ; +    BOOST_FOREACH(const old_ids_t &old_id, old_rfx_ids){ +        std::string name; dboard_id_t rx_id, tx_id; +        boost::tie(name, rx_id, tx_id) = old_id; +        if ( +            (xx == "RX" and rx_id == dboard_id) or +            (xx == "TX" and tx_id == dboard_id) +        ) uhd::warning::post(str(boost::format( +            "Detected %s daughterboard %s\n" +            "This board requires modification to use.\n" +            "See the daughterboard application notes.\n" +        ) % xx % name)); +    } +} + +/***********************************************************************   * The unknown boards:   *   Like a basic board, but with only one subdev.   **********************************************************************/  class unknown_rx : public rx_dboard_base{  public:      unknown_rx(ctor_args_t args); -    ~unknown_rx(void);      void rx_get(const wax::obj &key, wax::obj &val);      void rx_set(const wax::obj &key, const wax::obj &val); @@ -44,7 +73,6 @@ public:  class unknown_tx : public tx_dboard_base{  public:      unknown_tx(ctor_args_t args); -    ~unknown_tx(void);      void tx_get(const wax::obj &key, wax::obj &val);      void tx_set(const wax::obj &key, const wax::obj &val); @@ -70,11 +98,7 @@ UHD_STATIC_BLOCK(reg_unknown_dboards){   * Unknown RX dboard   **********************************************************************/  unknown_rx::unknown_rx(ctor_args_t args) : rx_dboard_base(args){ -    /* NOP */ -} - -unknown_rx::~unknown_rx(void){ -    /* NOP */ +    warn_if_old_rfx(this->get_rx_id(), "RX");  }  void unknown_rx::rx_get(const wax::obj &key_, wax::obj &val){ @@ -134,6 +158,10 @@ void unknown_rx::rx_get(const wax::obj &key_, wax::obj &val){          val = true; //there is no LO, so it must be true!          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 0.0; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -158,19 +186,21 @@ void unknown_rx::rx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("Unknown Daughterboard: No tunable bandwidth, fixed filtered to 0.0MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  }  /*********************************************************************** - * Basic and LF TX dboard + * Unknown TX dboard   **********************************************************************/  unknown_tx::unknown_tx(ctor_args_t args) : tx_dboard_base(args){ -    /* NOP */ -} - -unknown_tx::~unknown_tx(void){ -    /* NOP */ +    warn_if_old_rfx(this->get_tx_id(), "TX");  }  void unknown_tx::tx_get(const wax::obj &key_, wax::obj &val){ @@ -230,6 +260,10 @@ void unknown_tx::tx_get(const wax::obj &key_, wax::obj &val){          val = true; //there is no LO, so it must be true!          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 0.0; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -254,6 +288,12 @@ void unknown_tx::tx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("Unknown Daughterboard: No tunable bandwidth, fixed filtered to 0.0MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/dboard/db_wbx.cpp b/host/lib/usrp/dboard/db_wbx.cpp index 907268aac..572f5de97 100644 --- a/host/lib/usrp/dboard/db_wbx.cpp +++ b/host/lib/usrp/dboard/db_wbx.cpp @@ -71,6 +71,7 @@  #include <uhd/utils/assert.hpp>  #include <uhd/utils/static.hpp>  #include <uhd/utils/algorithm.hpp> +#include <uhd/utils/warning.hpp>  #include <uhd/usrp/dboard_base.hpp>  #include <uhd/usrp/dboard_manager.hpp>  #include <boost/assign/list_of.hpp> @@ -525,6 +526,10 @@ void wbx_xcvr::rx_get(const wax::obj &key_, wax::obj &val){          val = this->get_locked(dboard_iface::UNIT_RX);          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 2*20.0e6; //20MHz low-pass, we want complex double-sided +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -550,6 +555,12 @@ void wbx_xcvr::rx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("WBX: No tunable bandwidth, fixed filtered to 40MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } @@ -616,6 +627,10 @@ void wbx_xcvr::tx_get(const wax::obj &key_, wax::obj &val){          val = this->get_locked(dboard_iface::UNIT_TX);          return; +    case SUBDEV_PROP_BANDWIDTH: +        val = 2*20.0e6; //20MHz low-pass, we want complex double-sided +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -641,6 +656,12 @@ void wbx_xcvr::tx_set(const wax::obj &key_, const wax::obj &val){      case SUBDEV_PROP_ENABLED:          return; //always enabled +    case SUBDEV_PROP_BANDWIDTH: +        uhd::warning::post( +            str(boost::format("WBX: No tunable bandwidth, fixed filtered to 40MHz")) +        ); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/dboard/db_xcvr2450.cpp b/host/lib/usrp/dboard/db_xcvr2450.cpp index fb1367113..be0e42b92 100644 --- a/host/lib/usrp/dboard/db_xcvr2450.cpp +++ b/host/lib/usrp/dboard/db_xcvr2450.cpp @@ -626,7 +626,7 @@ void xcvr2450::rx_get(const wax::obj &key_, wax::obj &val){          return;      case SUBDEV_PROP_BANDWIDTH: -        val = _rx_bandwidth; +        val = 2*_rx_bandwidth; //_tx_bandwidth is low-pass, we want complex double-sided          return;      default: UHD_THROW_PROP_GET_ERROR(); @@ -652,7 +652,7 @@ void xcvr2450::rx_set(const wax::obj &key_, const wax::obj &val){          return;      case SUBDEV_PROP_BANDWIDTH: -        this->set_rx_bandwidth(val.as<double>()); +        this->set_rx_bandwidth(val.as<double>()/2.0); //complex double-sided, we want low-pass          return;      case SUBDEV_PROP_ENABLED: @@ -725,7 +725,7 @@ void xcvr2450::tx_get(const wax::obj &key_, wax::obj &val){          return;      case SUBDEV_PROP_BANDWIDTH: -        val = _tx_bandwidth; +        val = 2*_tx_bandwidth; //_tx_bandwidth is low-pass, we want complex double-sided          return;      default: UHD_THROW_PROP_GET_ERROR(); @@ -747,7 +747,7 @@ void xcvr2450::tx_set(const wax::obj &key_, const wax::obj &val){          return;      case SUBDEV_PROP_BANDWIDTH: -        this->set_tx_bandwidth(val.as<double>()); +        this->set_tx_bandwidth(val.as<double>()/2.0); //complex double-sided, we want low-pass          return;      case SUBDEV_PROP_ANTENNA: diff --git a/host/lib/usrp/dboard_manager.cpp b/host/lib/usrp/dboard_manager.cpp index d73a698ae..5a98bb8eb 100644 --- a/host/lib/usrp/dboard_manager.cpp +++ b/host/lib/usrp/dboard_manager.cpp @@ -189,7 +189,7 @@ static args_t get_dboard_args(      //verify that there is a registered constructor for this id      if (not get_id_to_args_map().has_key(dboard_id)){ -        uhd::print_warning(str(boost::format( +        uhd::warning::post(str(boost::format(              "Unknown dboard ID: %s.\n"          ) % dboard_id.to_pp_string()));          return get_dboard_args(unit, dboard_id, true); @@ -217,7 +217,7 @@ dboard_manager_impl::dboard_manager_impl(      //warn for invalid dboard id xcvr combinations      if (rx_dboard_is_xcvr != this_dboard_is_xcvr or tx_dboard_is_xcvr != this_dboard_is_xcvr){ -        uhd::print_warning(str(boost::format( +        uhd::warning::post(str(boost::format(              "Unknown transceiver board ID combination...\n"              "RX dboard ID: %s\n"              "TX dboard ID: %s\n" diff --git a/host/lib/usrp/mboard_eeprom.cpp b/host/lib/usrp/mboard_eeprom.cpp new file mode 100644 index 000000000..661030aa7 --- /dev/null +++ b/host/lib/usrp/mboard_eeprom.cpp @@ -0,0 +1,194 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#include <uhd/usrp/mboard_eeprom.hpp> +#include <uhd/types/mac_addr.hpp> +#include <uhd/utils/algorithm.hpp> +#include <boost/asio/ip/address_v4.hpp> +#include <boost/assign/list_of.hpp> +#include <boost/lexical_cast.hpp> +#include <boost/foreach.hpp> + +using namespace uhd; +using namespace uhd::usrp; + +/*********************************************************************** + * Constants + **********************************************************************/ +static const size_t SERIAL_LEN = 9; +static const size_t NAME_MAX_LEN = 32 - SERIAL_LEN; + +/*********************************************************************** + * Utility functions + **********************************************************************/ + +//! create a string from a byte vector, return empty if invalid ascii +static const std::string bytes_to_string(const byte_vector_t &bytes){ +    std::string out; +    BOOST_FOREACH(boost::uint8_t byte, bytes){ +        if (byte < 32 or byte > 127) return out; +        out += byte; +    } +    return out; +} + +//! create a byte vector from a string, null terminate unless max length +static const byte_vector_t string_to_bytes(const std::string &string, size_t max_length){ +    byte_vector_t bytes; +    for (size_t i = 0; i < std::min(string.size(), max_length); i++){ +        bytes.push_back(string[i]); +    } +    if (bytes.size() < max_length - 1) bytes.push_back('\0'); +    return bytes; +} + +/*********************************************************************** + * Implementation of N100 load/store + **********************************************************************/ +static const boost::uint8_t N100_EEPROM_ADDR = 0x50; + +static const uhd::dict<std::string, boost::uint8_t> USRP_N100_OFFSETS = boost::assign::map_list_of +    ("rev-lsb-msb", 0x00) +    ("mac-addr", 0x02) +    ("ip-addr", 0x08) +    //leave space here for other addresses (perhaps) +    ("serial", 0x18) +    ("name", 0x18 + SERIAL_LEN) +; + +static void load_n100(mboard_eeprom_t &mb_eeprom, i2c_iface &iface){ +    //extract the revision number +    byte_vector_t rev_lsb_msb = iface.read_eeprom(N100_EEPROM_ADDR, USRP_N100_OFFSETS["rev-lsb-msb"], 2); +    boost::uint16_t rev = (boost::uint16_t(rev_lsb_msb.at(0)) << 0) | (boost::uint16_t(rev_lsb_msb.at(1)) << 8); +    mb_eeprom["rev"] = boost::lexical_cast<std::string>(rev); + +    //extract the addresses +    mb_eeprom["mac-addr"] = mac_addr_t::from_bytes(iface.read_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["mac-addr"], 6 +    )).to_string(); + +    boost::asio::ip::address_v4::bytes_type ip_addr_bytes; +    std::copy(iface.read_eeprom(N100_EEPROM_ADDR, USRP_N100_OFFSETS["ip-addr"], 4), ip_addr_bytes); +    mb_eeprom["ip-addr"] = boost::asio::ip::address_v4(ip_addr_bytes).to_string(); + +    //extract the serial +    mb_eeprom["serial"] = bytes_to_string(iface.read_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["serial"], SERIAL_LEN +    )); + +    //extract the name +    mb_eeprom["name"] = bytes_to_string(iface.read_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["name"], NAME_MAX_LEN +    )); + +    //empty serial correction: use the mac address +    if (mb_eeprom["serial"].empty()) mb_eeprom["serial"] = mb_eeprom["mac-addr"]; +} + +static void store_n100(const mboard_eeprom_t &mb_eeprom, i2c_iface &iface){ +    //parse the revision number +    if (mb_eeprom.has_key("rev")){ +        boost::uint16_t rev = boost::lexical_cast<boost::uint16_t>(mb_eeprom["rev"]); +        byte_vector_t rev_lsb_msb = boost::assign::list_of +            (boost::uint8_t(rev >> 0)) +            (boost::uint8_t(rev >> 8)) +        ; +        iface.write_eeprom(N100_EEPROM_ADDR, USRP_N100_OFFSETS["rev-lsb-msb"], rev_lsb_msb); +    } + +    //store the addresses +    if (mb_eeprom.has_key("mac-addr")) iface.write_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["mac-addr"], +        mac_addr_t::from_string(mb_eeprom["mac-addr"]).to_bytes() +    ); + +    if (mb_eeprom.has_key("ip-addr")){ +        byte_vector_t ip_addr_bytes(4); +        std::copy(boost::asio::ip::address_v4::from_string(mb_eeprom["ip-addr"]).to_bytes(), ip_addr_bytes); +        iface.write_eeprom(N100_EEPROM_ADDR, USRP_N100_OFFSETS["ip-addr"], ip_addr_bytes); +    } + +    //store the serial +    if (mb_eeprom.has_key("serial")) iface.write_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["serial"], +        string_to_bytes(mb_eeprom["serial"], SERIAL_LEN) +    ); + +    //store the name +    if (mb_eeprom.has_key("name")) iface.write_eeprom( +        N100_EEPROM_ADDR, USRP_N100_OFFSETS["name"], +        string_to_bytes(mb_eeprom["name"], NAME_MAX_LEN) +    ); +} + +/*********************************************************************** + * Implementation of B000 load/store + **********************************************************************/ +static const boost::uint8_t B000_EEPROM_ADDR = 0x50; +static const size_t B000X_SERIAL_LEN = 8; + +static const uhd::dict<std::string, boost::uint8_t> USRP_B000_OFFSETS = boost::assign::map_list_of +    ("serial", 0xf8) +    ("name", 0xf8 - NAME_MAX_LEN) +; + +static void load_b000(mboard_eeprom_t &mb_eeprom, i2c_iface &iface){ +    //extract the serial +    mb_eeprom["serial"] = bytes_to_string(iface.read_eeprom( +        B000_EEPROM_ADDR, USRP_B000_OFFSETS["serial"], B000X_SERIAL_LEN +    )); + +    //extract the name +    mb_eeprom["name"] = bytes_to_string(iface.read_eeprom( +        B000_EEPROM_ADDR, USRP_B000_OFFSETS["name"], NAME_MAX_LEN +    )); +} + +static void store_b000(const mboard_eeprom_t &mb_eeprom, i2c_iface &iface){ +    //store the serial +    if (mb_eeprom.has_key("serial")) iface.write_eeprom( +        B000_EEPROM_ADDR, USRP_B000_OFFSETS["serial"], +        string_to_bytes(mb_eeprom["serial"], B000X_SERIAL_LEN) +    ); + +    //store the name +    if (mb_eeprom.has_key("name")) iface.write_eeprom( +        B000_EEPROM_ADDR, USRP_B000_OFFSETS["name"], +        string_to_bytes(mb_eeprom["name"], NAME_MAX_LEN) +    ); +} + +/*********************************************************************** + * Implementation of mboard eeprom + **********************************************************************/ +mboard_eeprom_t::mboard_eeprom_t(void){ +    /* NOP */ +} + +mboard_eeprom_t::mboard_eeprom_t(i2c_iface &iface, map_type map){ +    switch(map){ +    case MAP_N100: load_n100(*this, iface); break; +    case MAP_B000: load_b000(*this, iface); break; +    } +} + +void mboard_eeprom_t::commit(i2c_iface &iface, map_type map){ +    switch(map){ +    case MAP_N100: store_n100(*this, iface); break; +    case MAP_B000: store_b000(*this, iface); break; +    } +} diff --git a/host/lib/usrp/misc_utils.cpp b/host/lib/usrp/misc_utils.cpp index 7e49baa52..5856d706f 100644 --- a/host/lib/usrp/misc_utils.cpp +++ b/host/lib/usrp/misc_utils.cpp @@ -164,13 +164,13 @@ static void verify_xx_subdev_spec(          }          //sanity check that the dboard/subdevice names exist for this mboard -        BOOST_FOREACH(const subdev_spec_pair_t &pair, subdev_spec){ +        BOOST_FOREACH(subdev_spec_pair_t &pair, subdev_spec){              //empty db name means select dboard automatically              if (pair.db_name.empty()){                  if (dboard_names.size() != 1) throw std::runtime_error(                      "A daughterboard name must be provided for multi-slot motherboards: " + subdev_spec.to_string()                  ); -                pair.db_name == dboard_names.front(); +                pair.db_name = dboard_names.front();              }              uhd::assert_has(dboard_names, pair.db_name, xx_type + " dboard name");              wax::obj dboard = mboard[named_prop_t(dboard_prop, pair.db_name)]; @@ -181,7 +181,7 @@ static void verify_xx_subdev_spec(                  if (subdev_names.size() != 1) throw std::runtime_error(                      "A subdevice name must be provided for multi-subdev daughterboards: " + subdev_spec.to_string()                  ); -                pair.sd_name == subdev_names.front(); +                pair.sd_name = subdev_names.front();              }              uhd::assert_has(subdev_names, pair.sd_name, xx_type + " subdev name");          } diff --git a/host/lib/usrp/multi_usrp.cpp b/host/lib/usrp/multi_usrp.cpp index 443b91594..876f1a3fc 100644 --- a/host/lib/usrp/multi_usrp.cpp +++ b/host/lib/usrp/multi_usrp.cpp @@ -145,7 +145,7 @@ public:              time_spec_t time_0 = _mboard(0)[MBOARD_PROP_TIME_NOW].as<time_spec_t>();              time_spec_t time_i = _mboard(m)[MBOARD_PROP_TIME_NOW].as<time_spec_t>();              if (time_i < time_0 or (time_i - time_0) > time_spec_t(0.01)){ //10 ms: greater than RTT but not too big -                uhd::print_warning(str(boost::format( +                uhd::warning::post(str(boost::format(                      "Detected time deviation between board %d and board 0.\n"                      "Board 0 time is %f seconds.\n"                      "Board %d time is %f seconds.\n" @@ -154,6 +154,15 @@ public:          }      } +    bool get_time_synchronized(void){ +        for (size_t m = 1; m < get_num_mboards(); m++){ +            time_spec_t time_0 = _mboard(0)[MBOARD_PROP_TIME_NOW].as<time_spec_t>(); +            time_spec_t time_i = _mboard(m)[MBOARD_PROP_TIME_NOW].as<time_spec_t>(); +            if (time_i < time_0 or (time_i - time_0) > time_spec_t(0.01)) return false; +        } +        return true; +    } +      void issue_stream_cmd(const stream_cmd_t &stream_cmd){          for (size_t m = 0; m < get_num_mboards(); m++){              _mboard(m)[MBOARD_PROP_STREAM_CMD] = stream_cmd; @@ -210,15 +219,9 @@ public:          return _rx_dsp(0)[DSP_PROP_HOST_RATE].as<double>();      } -    tune_result_t set_rx_freq(double target_freq, size_t chan){ -        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan/rx_cpm()), chan%rx_cpm(), target_freq); -        do_tune_freq_warning_message(target_freq, get_rx_freq(chan), "RX"); -        return r; -    } - -    tune_result_t set_rx_freq(double target_freq, double lo_off, size_t chan){ -        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan/rx_cpm()), chan%rx_cpm(), target_freq, lo_off); -        do_tune_freq_warning_message(target_freq, get_rx_freq(chan), "RX"); +    tune_result_t set_rx_freq(const tune_request_t &tune_request, size_t chan){ +        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(chan/rx_cpm()), chan%rx_cpm(), tune_request); +        do_tune_freq_warning_message(tune_request.target_freq, get_rx_freq(chan), "RX");          return r;      } @@ -314,15 +317,9 @@ public:          return _tx_dsp(0)[DSP_PROP_HOST_RATE].as<double>();      } -    tune_result_t set_tx_freq(double target_freq, size_t chan){ -        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan/tx_cpm()), chan%tx_cpm(), target_freq); -        do_tune_freq_warning_message(target_freq, get_tx_freq(chan), "TX"); -        return r; -    } - -    tune_result_t set_tx_freq(double target_freq, double lo_off, size_t chan){ -        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan/tx_cpm()), chan%tx_cpm(), target_freq, lo_off); -        do_tune_freq_warning_message(target_freq, get_tx_freq(chan), "TX"); +    tune_result_t set_tx_freq(const tune_request_t &tune_request, size_t chan){ +        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(chan/tx_cpm()), chan%tx_cpm(), tune_request); +        do_tune_freq_warning_message(tune_request.target_freq, get_tx_freq(chan), "TX");          return r;      } diff --git a/host/lib/usrp/single_usrp.cpp b/host/lib/usrp/single_usrp.cpp index 5e57849b8..a0456d1f0 100644 --- a/host/lib/usrp/single_usrp.cpp +++ b/host/lib/usrp/single_usrp.cpp @@ -146,15 +146,9 @@ public:          return _rx_dsp()[DSP_PROP_HOST_RATE].as<double>();      } -    tune_result_t set_rx_freq(double target_freq, size_t chan){ -        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(), chan, target_freq); -        do_tune_freq_warning_message(target_freq, get_rx_freq(chan), "RX"); -        return r; -    } - -    tune_result_t set_rx_freq(double target_freq, double lo_off, size_t chan){ -        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(), chan, target_freq, lo_off); -        do_tune_freq_warning_message(target_freq, get_rx_freq(chan), "RX"); +    tune_result_t set_rx_freq(const tune_request_t &tune_request, size_t chan){ +        tune_result_t r = tune_rx_subdev_and_dsp(_rx_subdev(chan), _rx_dsp(), chan, tune_request); +        do_tune_freq_warning_message(tune_request.target_freq, get_rx_freq(chan), "RX");          return r;      } @@ -238,15 +232,9 @@ public:          return _tx_dsp()[DSP_PROP_HOST_RATE].as<double>();      } -    tune_result_t set_tx_freq(double target_freq, size_t chan){ -        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(), chan, target_freq); -        do_tune_freq_warning_message(target_freq, get_tx_freq(chan), "TX"); -        return r; -    } - -    tune_result_t set_tx_freq(double target_freq, double lo_off, size_t chan){ -        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(), chan, target_freq, lo_off); -        do_tune_freq_warning_message(target_freq, get_tx_freq(chan), "TX"); +    tune_result_t set_tx_freq(const tune_request_t &tune_request, size_t chan){ +        tune_result_t r = tune_tx_subdev_and_dsp(_tx_subdev(chan), _tx_dsp(), chan, tune_request); +        do_tune_freq_warning_message(tune_request.target_freq, get_tx_freq(chan), "TX");          return r;      } diff --git a/host/lib/usrp/tune_helper.cpp b/host/lib/usrp/tune_helper.cpp index 7633c67f2..fa40a8a26 100644 --- a/host/lib/usrp/tune_helper.cpp +++ b/host/lib/usrp/tune_helper.cpp @@ -19,6 +19,7 @@  #include <uhd/usrp/subdev_props.hpp>  #include <uhd/usrp/dsp_props.hpp>  #include <uhd/usrp/dboard_iface.hpp> //unit_t +#include <uhd/utils/algorithm.hpp>  #include <boost/math/special_functions/sign.hpp>  #include <cmath> @@ -28,55 +29,99 @@ using namespace uhd::usrp;  /***********************************************************************   * Tune Helper Functions   **********************************************************************/ -static tune_result_t tune_xx_subdev_and_dxc( +static tune_result_t tune_xx_subdev_and_dsp(      dboard_iface::unit_t unit, -    wax::obj subdev, wax::obj dxc, size_t chan, -    double target_freq, double lo_offset +    wax::obj subdev, wax::obj dsp, size_t chan, +    const tune_request_t &tune_request  ){      wax::obj subdev_freq_proxy = subdev[SUBDEV_PROP_FREQ]; -    std::string freq_name = dxc[DSP_PROP_FREQ_SHIFT_NAMES].as<prop_names_t>().at(chan); -    wax::obj dxc_freq_proxy = dxc[named_prop_t(DSP_PROP_FREQ_SHIFT, freq_name)]; -    double dxc_sample_rate = dxc[DSP_PROP_CODEC_RATE].as<double>(); +    std::string freq_name = dsp[DSP_PROP_FREQ_SHIFT_NAMES].as<prop_names_t>().at(chan); +    wax::obj dsp_freq_proxy = dsp[named_prop_t(DSP_PROP_FREQ_SHIFT, freq_name)]; +    double dsp_sample_rate = dsp[DSP_PROP_CODEC_RATE].as<double>(); -    // Ask the d'board to tune as closely as it can to target_freq+lo_offset -    double target_inter_freq = target_freq + lo_offset; -    subdev_freq_proxy = target_inter_freq; -    double actual_inter_freq = subdev_freq_proxy.as<double>(); - -    //perform the correction correction for dxc rates outside of nyquist -    double delta_freq = std::fmod(target_freq - actual_inter_freq, dxc_sample_rate); -    bool outside_of_nyquist = std::abs(delta_freq) > dxc_sample_rate/2.0; -    double target_dxc_freq = (outside_of_nyquist)? -        boost::math::sign(delta_freq)*dxc_sample_rate - delta_freq : -delta_freq; +    //------------------------------------------------------------------ +    //-- calculate the LO offset, only used with automatic policy +    //------------------------------------------------------------------ +    double lo_offset = 0.0; +    if (subdev[SUBDEV_PROP_USE_LO_OFFSET].as<bool>()){ +        //If the local oscillator will be in the passband, use an offset. +        //But constrain the LO offset by the width of the filter bandwidth. +        double rate = dsp[DSP_PROP_HOST_RATE].as<double>(); +        double bw = subdev[SUBDEV_PROP_BANDWIDTH].as<double>(); +        if (bw > rate) lo_offset = std::min((bw - rate)/2, rate/2); +    } -    //invert the sign on the dxc freq given the following conditions -    if (unit == dboard_iface::UNIT_TX) target_dxc_freq *= -1.0; +    //------------------------------------------------------------------ +    //-- set the intermediate frequency depending upon the IF policy +    //------------------------------------------------------------------ +    double target_inter_freq = 0.0; +    switch (tune_request.inter_freq_policy){ +    case tune_request_t::POLICY_AUTO: +        target_inter_freq = tune_request.target_freq + lo_offset; +        subdev_freq_proxy = target_inter_freq; +        break; + +    case tune_request_t::POLICY_MANUAL: +        target_inter_freq = tune_request.inter_freq; +        subdev_freq_proxy = target_inter_freq; +        break; + +    case tune_request_t::POLICY_NONE: break; //does not set +    } +    double actual_inter_freq = subdev_freq_proxy.as<double>(); -    dxc_freq_proxy = target_dxc_freq; -    double actual_dxc_freq = dxc_freq_proxy.as<double>(); +    //------------------------------------------------------------------ +    //-- calculate the dsp freq, only used with automatic policy +    //------------------------------------------------------------------ +    double delta_freq = std::fmod(tune_request.target_freq - actual_inter_freq, dsp_sample_rate); +    bool outside_of_nyquist = std::abs(delta_freq) > dsp_sample_rate/2.0; +    double target_dsp_freq = (outside_of_nyquist)? +        boost::math::sign(delta_freq)*dsp_sample_rate - delta_freq : -delta_freq; + +    //invert the sign on the dsp freq given the following conditions +    if (unit == dboard_iface::UNIT_TX) target_dsp_freq *= -1.0; + +    //------------------------------------------------------------------ +    //-- set the dsp frequency depending upon the dsp frequency policy +    //------------------------------------------------------------------ +    switch (tune_request.dsp_freq_policy){ +    case tune_request_t::POLICY_AUTO: +        dsp_freq_proxy = target_dsp_freq; +        break; + +    case tune_request_t::POLICY_MANUAL: +        target_dsp_freq = tune_request.dsp_freq; +        dsp_freq_proxy = target_dsp_freq; +        break; + +    case tune_request_t::POLICY_NONE: break; //does not set +    } +    double actual_dsp_freq = dsp_freq_proxy.as<double>(); -    //load and return the tune result +    //------------------------------------------------------------------ +    //-- load and return the tune result +    //------------------------------------------------------------------      tune_result_t tune_result;      tune_result.target_inter_freq = target_inter_freq;      tune_result.actual_inter_freq = actual_inter_freq; -    tune_result.target_dsp_freq = target_dxc_freq; -    tune_result.actual_dsp_freq = actual_dxc_freq; +    tune_result.target_dsp_freq = target_dsp_freq; +    tune_result.actual_dsp_freq = actual_dsp_freq;      return tune_result;  } -static double derive_freq_from_xx_subdev_and_dxc( +static double derive_freq_from_xx_subdev_and_dsp(      dboard_iface::unit_t unit, -    wax::obj subdev, wax::obj dxc, size_t chan +    wax::obj subdev, wax::obj dsp, size_t chan  ){      //extract actual dsp and IF frequencies      double actual_inter_freq = subdev[SUBDEV_PROP_FREQ].as<double>(); -    std::string freq_name = dxc[DSP_PROP_FREQ_SHIFT_NAMES].as<prop_names_t>().at(chan); -    double actual_dxc_freq = dxc[named_prop_t(DSP_PROP_FREQ_SHIFT, freq_name)].as<double>(); +    std::string freq_name = dsp[DSP_PROP_FREQ_SHIFT_NAMES].as<prop_names_t>().at(chan); +    double actual_dsp_freq = dsp[named_prop_t(DSP_PROP_FREQ_SHIFT, freq_name)].as<double>(); -    //invert the sign on the dxc freq given the following conditions -    if (unit == dboard_iface::UNIT_TX) actual_dxc_freq *= -1.0; +    //invert the sign on the dsp freq given the following conditions +    if (unit == dboard_iface::UNIT_TX) actual_dsp_freq *= -1.0; -    return actual_inter_freq - actual_dxc_freq; +    return actual_inter_freq - actual_dsp_freq;  }  /*********************************************************************** @@ -84,27 +129,15 @@ static double derive_freq_from_xx_subdev_and_dxc(   **********************************************************************/  tune_result_t usrp::tune_rx_subdev_and_dsp(      wax::obj subdev, wax::obj ddc, size_t chan, -    double target_freq, double lo_offset -){ -    return tune_xx_subdev_and_dxc(dboard_iface::UNIT_RX, subdev, ddc, chan, target_freq, lo_offset); -} - -tune_result_t usrp::tune_rx_subdev_and_dsp( -    wax::obj subdev, wax::obj ddc, -    size_t chan, double target_freq +    const tune_request_t &tune_request  ){ -    double lo_offset = 0.0; -    //if the local oscillator will be in the passband, use an offset -    if (subdev[SUBDEV_PROP_USE_LO_OFFSET].as<bool>()){ -        lo_offset = 2.0*ddc[DSP_PROP_HOST_RATE].as<double>(); -    } -    return tune_rx_subdev_and_dsp(subdev, ddc, chan, target_freq, lo_offset); +    return tune_xx_subdev_and_dsp(dboard_iface::UNIT_RX, subdev, ddc, chan, tune_request);  }  double usrp::derive_freq_from_rx_subdev_and_dsp(      wax::obj subdev, wax::obj ddc, size_t chan  ){ -    return derive_freq_from_xx_subdev_and_dxc(dboard_iface::UNIT_RX, subdev, ddc, chan); +    return derive_freq_from_xx_subdev_and_dsp(dboard_iface::UNIT_RX, subdev, ddc, chan);  }  /*********************************************************************** @@ -112,25 +145,13 @@ double usrp::derive_freq_from_rx_subdev_and_dsp(   **********************************************************************/  tune_result_t usrp::tune_tx_subdev_and_dsp(      wax::obj subdev, wax::obj duc, size_t chan, -    double target_freq, double lo_offset +    const tune_request_t &tune_request  ){ -    return tune_xx_subdev_and_dxc(dboard_iface::UNIT_TX, subdev, duc, chan, target_freq, lo_offset); -} - -tune_result_t usrp::tune_tx_subdev_and_dsp( -    wax::obj subdev, wax::obj duc, -    size_t chan, double target_freq -){ -    double lo_offset = 0.0; -    //if the local oscillator will be in the passband, use an offset -    if (subdev[SUBDEV_PROP_USE_LO_OFFSET].as<bool>()){ -        lo_offset = 2.0*duc[DSP_PROP_HOST_RATE].as<double>(); -    } -    return tune_tx_subdev_and_dsp(subdev, duc, chan, target_freq, lo_offset); +    return tune_xx_subdev_and_dsp(dboard_iface::UNIT_TX, subdev, duc, chan, tune_request);  }  double usrp::derive_freq_from_tx_subdev_and_dsp(      wax::obj subdev, wax::obj duc, size_t chan  ){ -    return derive_freq_from_xx_subdev_and_dxc(dboard_iface::UNIT_TX, subdev, duc, chan); +    return derive_freq_from_xx_subdev_and_dsp(dboard_iface::UNIT_TX, subdev, duc, chan);  } diff --git a/host/lib/usrp/usrp1/CMakeLists.txt b/host/lib/usrp/usrp1/CMakeLists.txt index 67487f99e..022015231 100644 --- a/host/lib/usrp/usrp1/CMakeLists.txt +++ b/host/lib/usrp/usrp1/CMakeLists.txt @@ -40,7 +40,7 @@ ENDIF(ENABLE_USRP1 AND NOT HAVE_USB_SUPPORT)  IF(ENABLE_USRP1)      MESSAGE(STATUS "  Building USRP1 support.") -    INCLUDE_DIRECTORIES(${CMAKE_SOURCE_DIR}/../firmware/fx2/include) +    INCLUDE_DIRECTORIES(${CMAKE_SOURCE_DIR}/../firmware/fx2/common)      LIBUHD_APPEND_SOURCES(          ${CMAKE_SOURCE_DIR}/lib/usrp/usrp1/clock_ctrl.cpp diff --git a/host/lib/usrp/usrp1/mboard_impl.cpp b/host/lib/usrp/usrp1/mboard_impl.cpp index fe3774eb4..4df5ada0a 100644 --- a/host/lib/usrp/usrp1/mboard_impl.cpp +++ b/host/lib/usrp/usrp1/mboard_impl.cpp @@ -98,7 +98,7 @@ static boost::uint32_t calc_rx_mux(      //    for all quadrature sources: Z = 0      //    for mixed sources: warning + Z = 0      int Z = (num_quads > 0)? 0 : 1; -    if (num_quads != 0 and num_reals != 0) uhd::print_warning( +    if (num_quads != 0 and num_reals != 0) uhd::warning::post(          "Mixing real and quadrature rx subdevices is not supported.\n"          "The Q input to the real source(s) will be non-zero.\n"      ); @@ -262,24 +262,10 @@ void usrp1_impl::mboard_get(const wax::obj &key_, wax::obj &val)  {      named_prop_t key = named_prop_t::extract(key_); -    if(key_.type() == typeid(std::string)) { -      if(key.as<std::string>() == "serial") { -        uhd::byte_vector_t buf; -        buf.insert(buf.begin(), 248); -        boost::this_thread::sleep(boost::posix_time::milliseconds(100)); -        _iface->write_i2c(I2C_DEV_EEPROM, buf); -        boost::this_thread::sleep(boost::posix_time::milliseconds(100)); -        buf = _iface->read_i2c(I2C_DEV_EEPROM, 8); -        val = std::string(buf.begin(), buf.end()); -      } - -      return; -   	} -      //handle the get request conditioned on the key      switch(key.as<mboard_prop_t>()){      case MBOARD_PROP_NAME: -        val = std::string("usrp1 mboard - " + (*_mboard_proxy)[std::string("serial")].as<std::string>()); +        val = std::string("usrp1 mboard - " + _iface->mb_eeprom["serial"]);          return;      case MBOARD_PROP_OTHERS: @@ -336,6 +322,10 @@ void usrp1_impl::mboard_get(const wax::obj &key_, wax::obj &val)          val = _tx_subdev_spec;          return; +    case MBOARD_PROP_EEPROM_MAP: +        val = _iface->mb_eeprom; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -351,14 +341,6 @@ void usrp1_impl::mboard_set(const wax::obj &key, const wax::obj &val)          std::cout << "USRP1 EEPROM image: " << usrp1_eeprom_image << std::endl;          _ctrl_transport->usrp_load_eeprom(val.as<std::string>());        } - -      if(key.as<std::string>() == "serial") { -        std::string sernum = val.as<std::string>(); -        uhd::byte_vector_t buf(sernum.begin(), sernum.end()); -        buf.insert(buf.begin(), 248); -        _iface->write_i2c(I2C_DEV_EEPROM, buf); -      } -        return;     	} @@ -395,6 +377,13 @@ void usrp1_impl::mboard_set(const wax::obj &key, const wax::obj &val)          _iface->poke32(FR_TX_MUX, calc_tx_mux(_tx_subdev_spec, _mboard_proxy->get_link()));          return; +    case MBOARD_PROP_EEPROM_MAP: +        // Step1: commit the map, writing only those values set. +        // Step2: readback the entire eeprom map into the iface. +        val.as<mboard_eeprom_t>().commit(*_iface, mboard_eeprom_t::MAP_B000); +        _iface->mb_eeprom = mboard_eeprom_t(*_iface, mboard_eeprom_t::MAP_B000); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/usrp1/usrp1_iface.cpp b/host/lib/usrp/usrp1/usrp1_iface.cpp index 64ced2905..63fcd5777 100644 --- a/host/lib/usrp/usrp1/usrp1_iface.cpp +++ b/host/lib/usrp/usrp1/usrp1_iface.cpp @@ -25,6 +25,7 @@  #include <iomanip>  using namespace uhd; +using namespace uhd::usrp;  using namespace uhd::transport;  static const bool iface_debug = false; @@ -36,7 +37,8 @@ public:       ******************************************************************/      usrp1_iface_impl(usrp_ctrl::sptr ctrl_transport)      { -        _ctrl_transport = ctrl_transport;  +        _ctrl_transport = ctrl_transport; +        mb_eeprom = mboard_eeprom_t(*this, mboard_eeprom_t::MAP_B000);      }      ~usrp1_iface_impl(void) diff --git a/host/lib/usrp/usrp1/usrp1_iface.hpp b/host/lib/usrp/usrp1/usrp1_iface.hpp index 3f608584a..34a2330b5 100644 --- a/host/lib/usrp/usrp1/usrp1_iface.hpp +++ b/host/lib/usrp/usrp1/usrp1_iface.hpp @@ -18,6 +18,7 @@  #ifndef INCLUDED_USRP1_IFACE_HPP  #define INCLUDED_USRP1_IFACE_HPP +#include <uhd/usrp/mboard_eeprom.hpp>  #include <uhd/types/serial.hpp>  #include <boost/shared_ptr.hpp>  #include <boost/utility.hpp> @@ -81,6 +82,8 @@ public:                                     boost::uint16_t index,                                     unsigned char* buff,                                     boost::uint16_t length) = 0; + +    uhd::usrp::mboard_eeprom_t mb_eeprom;  };  #endif /* INCLUDED_USRP1_IFACE_HPP */ diff --git a/host/lib/usrp/usrp1/usrp1_impl.cpp b/host/lib/usrp/usrp1/usrp1_impl.cpp index 276ca86f6..6016b0979 100644 --- a/host/lib/usrp/usrp1/usrp1_impl.cpp +++ b/host/lib/usrp/usrp1/usrp1_impl.cpp @@ -56,15 +56,17 @@ static device_addrs_t usrp1_find(const device_addr_t &hint)      //return an empty list of addresses when type is set to non-usrp1      if (hint.has_key("type") and hint["type"] != "usrp1") return usrp1_addrs; +    //Return an empty list of addresses when an address is specified, +    //since an address is intended for a different, non-USB, device. +    if (hint.has_key("addr")) return usrp1_addrs; +      //extract the firmware path for the USRP1      std::string usrp1_fw_image;      try{ -        usrp1_fw_image = find_image_path( -            hint.has_key("fw")? hint["fw"] : "usrp1_fw.ihx" -        ); +        usrp1_fw_image = find_image_path(hint.get("fw", "usrp1_fw.ihx"));      }      catch(...){ -        uhd::print_warning( +        uhd::warning::post(              "Could not locate USRP1 firmware.\n"              "Please install the images package.\n"          ); @@ -91,11 +93,16 @@ static device_addrs_t usrp1_find(const device_addr_t &hint)      pid = USRP1_PRODUCT_ID;      BOOST_FOREACH(usb_device_handle::sptr handle, usb_device_handle::get_device_list(vid, pid)) { +        usrp1_iface::sptr iface = usrp1_iface::make(usrp_ctrl::make(usb_control::make(handle)));          device_addr_t new_addr;          new_addr["type"] = "usrp1"; +        new_addr["name"] = iface->mb_eeprom["name"];          new_addr["serial"] = handle->get_serial(); -        //this is a found usrp1 when a hint serial is not specified or it matches -        if (not hint.has_key("serial") or hint["serial"] == new_addr["serial"]){ +        //this is a found usrp1 when the hint serial and name match or blank +        if ( +            (not hint.has_key("name")   or hint["name"]   == new_addr["name"]) and +            (not hint.has_key("serial") or hint["serial"] == new_addr["serial"]) +        ){              usrp1_addrs.push_back(new_addr);          }      } @@ -110,7 +117,7 @@ static device::sptr usrp1_make(const device_addr_t &device_addr){      //extract the FPGA path for the USRP1      std::string usrp1_fpga_image = find_image_path( -        device_addr.has_key("fpga")? device_addr["fpga"] : "usrp1_fpga.rbf" +        device_addr.get("fpga", "usrp1_fpga.rbf")      );      //std::cout << "USRP1 FPGA image: " << usrp1_fpga_image << std::endl; diff --git a/host/lib/usrp/usrp2/clock_ctrl.cpp b/host/lib/usrp/usrp2/clock_ctrl.cpp index 04bbd6ba3..8eaafe680 100644 --- a/host/lib/usrp/usrp2/clock_ctrl.cpp +++ b/host/lib/usrp/usrp2/clock_ctrl.cpp @@ -22,6 +22,7 @@  #include "usrp2_clk_regs.hpp"  #include <uhd/utils/assert.hpp>  #include <boost/cstdint.hpp> +#include <boost/lexical_cast.hpp>  #include <iostream>  using namespace uhd; diff --git a/host/lib/usrp/usrp2/io_impl.cpp b/host/lib/usrp/usrp2/io_impl.cpp index bbe9c273f..83b70bddc 100644 --- a/host/lib/usrp/usrp2/io_impl.cpp +++ b/host/lib/usrp/usrp2/io_impl.cpp @@ -236,6 +236,11 @@ size_t usrp2_impl::get_max_recv_samps_per_packet(void) const{      return bpp/_rx_otw_type.get_sample_size();  } +static void handle_overflow(std::vector<usrp2_mboard_impl::sptr> &mboards, size_t chan){ +    std::cerr << "O" << std::flush; +    mboards.at(chan/mboards.size())->handle_overflow(); +} +  size_t usrp2_impl::recv(      const std::vector<void *> &buffs, size_t num_samps,      rx_metadata_t &metadata, const io_type_t &io_type, @@ -248,6 +253,7 @@ size_t usrp2_impl::recv(          io_type, _rx_otw_type,                     //input and output types to convert          _mboards.front()->get_master_clock_freq(), //master clock tick rate          uhd::transport::vrt::if_hdr_unpack_be, -        boost::bind(&usrp2_impl::io_impl::get_recv_buffs, _io_impl.get(), _1, timeout) +        boost::bind(&usrp2_impl::io_impl::get_recv_buffs, _io_impl.get(), _1, timeout), +        boost::bind(&handle_overflow, _mboards, _1)      );  } diff --git a/host/lib/usrp/usrp2/mboard_impl.cpp b/host/lib/usrp/usrp2/mboard_impl.cpp index 9ccf90bbb..eb5b79b20 100644 --- a/host/lib/usrp/usrp2/mboard_impl.cpp +++ b/host/lib/usrp/usrp2/mboard_impl.cpp @@ -23,11 +23,7 @@  #include "mboard_rev.hpp"  #include <uhd/utils/assert.hpp>  #include <uhd/utils/algorithm.hpp> -#include <uhd/types/mac_addr.hpp> -#include <uhd/types/dict.hpp>  #include <boost/bind.hpp> -#include <boost/assign/list_of.hpp> -#include <boost/asio/ip/address_v4.hpp>  #include <iostream>  #include <boost/date_time/posix_time/posix_time.hpp> @@ -44,11 +40,9 @@ usrp2_mboard_impl::usrp2_mboard_impl(      size_t recv_frame_size  ):      _index(index), -    _recv_frame_size(recv_frame_size) +    _recv_frame_size(recv_frame_size), +    _iface(usrp2_iface::make(ctrl_transport))  { -    //make a new interface for usrp2 stuff -    _iface = usrp2_iface::make(ctrl_transport); -          //contruct the interfaces to mboard perifs      _clock_ctrl = usrp2_clock_ctrl::make(_iface);      _codec_ctrl = usrp2_codec_ctrl::make(_iface); @@ -188,7 +182,15 @@ void usrp2_mboard_impl::set_time_spec(const time_spec_t &time_spec, bool now){      _iface->poke32(_iface->regs.time64_secs, boost::uint32_t(time_spec.get_full_secs()));  } +void usrp2_mboard_impl::handle_overflow(void){ +    _iface->poke32(_iface->regs.rx_ctrl_clear_overrun, 1); +    if (_continuous_streaming){ //re-issue the stream command if already continuous +        this->issue_ddc_stream_cmd(stream_cmd_t::STREAM_MODE_START_CONTINUOUS); +    } +} +  void usrp2_mboard_impl::issue_ddc_stream_cmd(const stream_cmd_t &stream_cmd){ +    _continuous_streaming = stream_cmd.stream_mode == stream_cmd_t::STREAM_MODE_START_CONTINUOUS;      _iface->poke32(_iface->regs.rx_ctrl_stream_cmd, dsp_type1::calc_stream_cmd_word(          stream_cmd, _recv_frame_size      )); @@ -203,42 +205,14 @@ static const std::string dboard_name = "0";  void usrp2_mboard_impl::get(const wax::obj &key_, wax::obj &val){      named_prop_t key = named_prop_t::extract(key_); - -    //handle the other props -    if (key_.type() == typeid(std::string)){ -        if (key.as<std::string>() == "mac-addr"){ -            byte_vector_t bytes = _iface->read_eeprom(USRP2_I2C_ADDR_MBOARD, USRP2_EE_MBOARD_MAC_ADDR, 6); -            val = mac_addr_t::from_bytes(bytes).to_string(); -            return; -        } - -        if (key.as<std::string>() == "ip-addr"){ -            boost::asio::ip::address_v4::bytes_type bytes; -            std::copy(_iface->read_eeprom(USRP2_I2C_ADDR_MBOARD, USRP2_EE_MBOARD_IP_ADDR, 4), bytes); -            val = boost::asio::ip::address_v4(bytes).to_string(); -            return; -        } -         -        if (key.as<std::string>() == "hw-rev"){ -            //extract the mboard rev number -            val = _iface->get_hw_rev().to_string(); -            return; -        } -    } -      //handle the get request conditioned on the key      switch(key.as<mboard_prop_t>()){      case MBOARD_PROP_NAME: -        val = str(boost::format("usrp2 mboard%d - rev %s") % _index % _iface->get_hw_rev().to_string()); +        val = str(boost::format("usrp2 mboard%d - rev %s") % _index % _iface->mb_eeprom["rev"]);          return; -    case MBOARD_PROP_OTHERS:{ -            prop_names_t others = boost::assign::list_of -                ("mac-addr") -                ("ip-addr") -            ; -            val = others; -        } +    case MBOARD_PROP_OTHERS: +        val = prop_names_t();          return;      case MBOARD_PROP_RX_DBOARD: @@ -299,6 +273,10 @@ void usrp2_mboard_impl::get(const wax::obj &key_, wax::obj &val){          val = _tx_subdev_spec;          return; +    case MBOARD_PROP_EEPROM_MAP: +        val = _iface->mb_eeprom; +        return; +      default: UHD_THROW_PROP_GET_ERROR();      }  } @@ -307,32 +285,6 @@ void usrp2_mboard_impl::get(const wax::obj &key_, wax::obj &val){   * MBoard Set Properties   **********************************************************************/  void usrp2_mboard_impl::set(const wax::obj &key, const wax::obj &val){ -    //handle the other props -    if (key.type() == typeid(std::string)){ -        if (key.as<std::string>() == "mac-addr"){ -            byte_vector_t bytes = mac_addr_t::from_string(val.as<std::string>()).to_bytes(); -            _iface->write_eeprom(USRP2_I2C_ADDR_MBOARD, USRP2_EE_MBOARD_MAC_ADDR, bytes); -            return; -        } - -        if (key.as<std::string>() == "ip-addr"){ -            byte_vector_t bytes(4); -            std::copy(boost::asio::ip::address_v4::from_string(val.as<std::string>()).to_bytes(), bytes); -            _iface->write_eeprom(USRP2_I2C_ADDR_MBOARD, USRP2_EE_MBOARD_IP_ADDR, bytes); -            return; -        } -         -        if (key.as<std::string>() == "hw-rev"){ -            mboard_rev_t rev = mboard_rev_t::from_string(val.as<std::string>()); -            byte_vector_t rev_bytes(2); -            rev_bytes[1] = rev.to_uint16() >> 8; -            rev_bytes[0] = rev.to_uint16() & 0xff; -            _iface->write_eeprom(USRP2_I2C_ADDR_MBOARD, USRP2_EE_MBOARD_REV, rev_bytes); -            _iface->set_hw_rev(rev); //so the iface knows what rev it is -            return; -        } -    } -      //handle the set request conditioned on the key      switch(key.as<mboard_prop_t>()){ @@ -375,6 +327,13 @@ void usrp2_mboard_impl::set(const wax::obj &key, const wax::obj &val){          ));          return; +    case MBOARD_PROP_EEPROM_MAP: +        // Step1: commit the map, writing only those values set. +        // Step2: readback the entire eeprom map into the iface. +        val.as<mboard_eeprom_t>().commit(*_iface, mboard_eeprom_t::MAP_N100); +        _iface->mb_eeprom = mboard_eeprom_t(*_iface, mboard_eeprom_t::MAP_N100); +        return; +      default: UHD_THROW_PROP_SET_ERROR();      }  } diff --git a/host/lib/usrp/usrp2/usrp2_iface.cpp b/host/lib/usrp/usrp2/usrp2_iface.cpp index d5ac14155..52adb5373 100644 --- a/host/lib/usrp/usrp2/usrp2_iface.cpp +++ b/host/lib/usrp/usrp2/usrp2_iface.cpp @@ -30,6 +30,7 @@  #include <algorithm>  using namespace uhd; +using namespace uhd::usrp;  using namespace uhd::transport;  /*! @@ -65,6 +66,7 @@ public:              ) % int(USRP2_FPGA_COMPAT_NUM) % fpga_compat_num));          } +        mb_eeprom = mboard_eeprom_t(*this, mboard_eeprom_t::MAP_N100);      }      ~usrp2_iface_impl(void){ diff --git a/host/lib/usrp/usrp2/usrp2_iface.hpp b/host/lib/usrp/usrp2/usrp2_iface.hpp index fee3b23af..88bff5913 100644 --- a/host/lib/usrp/usrp2/usrp2_iface.hpp +++ b/host/lib/usrp/usrp2/usrp2_iface.hpp @@ -20,6 +20,7 @@  #include <uhd/transport/udp_simple.hpp>  #include <uhd/types/serial.hpp> +#include <uhd/usrp/mboard_eeprom.hpp>  #include <boost/shared_ptr.hpp>  #include <boost/utility.hpp>  #include <boost/cstdint.hpp> @@ -128,6 +129,8 @@ public:       * Hardware revision as returned by the device.       */      mboard_rev_t hw_rev; +    //motherboard eeprom map structure +    uhd::usrp::mboard_eeprom_t mb_eeprom;  };  #endif /* INCLUDED_USRP2_IFACE_HPP */ diff --git a/host/lib/usrp/usrp2/usrp2_impl.cpp b/host/lib/usrp/usrp2/usrp2_impl.cpp index a680708ad..5f549c4fd 100644 --- a/host/lib/usrp/usrp2/usrp2_impl.cpp +++ b/host/lib/usrp/usrp2/usrp2_impl.cpp @@ -21,6 +21,7 @@  #include <uhd/usrp/device_props.hpp>  #include <uhd/utils/assert.hpp>  #include <uhd/utils/static.hpp> +#include <uhd/utils/warning.hpp>  #include <uhd/utils/algorithm.hpp>  #include <boost/assign/list_of.hpp>  #include <boost/format.hpp> @@ -61,7 +62,7 @@ static uhd::device_addrs_t usrp2_find(const device_addr_t &hint){              if (if_addrs.inet == asio::ip::address_v4::loopback().to_string()) continue;              //create a new hint with this broadcast address -            device_addr_t new_hint; +            device_addr_t new_hint = hint;              new_hint["addr"] = if_addrs.bcast;              //call discover with the new hint and append results @@ -101,19 +102,37 @@ static uhd::device_addrs_t usrp2_find(const device_addr_t &hint){      while(true){          size_t len = udp_transport->recv(asio::buffer(usrp2_ctrl_data_in_mem), DISCOVERY_TIMEOUT_MS);          //std::cout << len << "\n"; -        if (len > offsetof(usrp2_ctrl_data_t, data)){ -            //handle the received data -            switch(ntohl(ctrl_data_in->id)){ -            case USRP2_CTRL_ID_WAZZUP_DUDE: -                //make a boost asio ipv4 with the raw addr in host byte order -                boost::asio::ip::address_v4 ip_addr(ntohl(ctrl_data_in->data.ip_addr)); -                device_addr_t new_addr; -                new_addr["type"] = "usrp2"; -                new_addr["addr"] = ip_addr.to_string(); -                usrp2_addrs.push_back(new_addr); -                //dont break here, it will exit the while loop -                //just continue on to the next loop iteration +        if (len > offsetof(usrp2_ctrl_data_t, data) and ntohl(ctrl_data_in->id) == USRP2_CTRL_ID_WAZZUP_DUDE){ +            //make a boost asio ipv4 with the raw addr in host byte order +            boost::asio::ip::address_v4 ip_addr(ntohl(ctrl_data_in->data.ip_addr)); +            device_addr_t new_addr; +            new_addr["type"] = "usrp2"; +            new_addr["addr"] = ip_addr.to_string(); +            //Attempt to read the name from the EEPROM and perform filtering. +            //This operation can throw due to COMPAT mismatch. That is OK. +            //We will allow the device to be found and the COMPAT mismatch +            //will be thrown as an exception in the factory function. +            try{ +                mboard_eeprom_t mb_eeprom = usrp2_iface::make( +                    udp_simple::make_connected(new_addr["addr"], num2str(USRP2_UDP_CTRL_PORT)) +                )->mb_eeprom; +                new_addr["name"] = mb_eeprom["name"]; +                new_addr["serial"] = mb_eeprom["serial"]; +                if ( +                    (not hint.has_key("name")   or hint["name"]   == new_addr["name"]) and +                    (not hint.has_key("serial") or hint["serial"] == new_addr["serial"]) +                ){ +                    usrp2_addrs.push_back(new_addr); +                }              } +            catch(const std::exception &e){ +                uhd::warning::post( +                    std::string("Ignoring discovered device\n") +                    + e.what() +                ); +            } +            //dont break here, it will exit the while loop +            //just continue on to the next loop iteration          }          if (len == 0) break; //timeout      } diff --git a/host/lib/usrp/usrp2/usrp2_impl.hpp b/host/lib/usrp/usrp2/usrp2_impl.hpp index 1ebd90ca4..738c398d9 100644 --- a/host/lib/usrp/usrp2/usrp2_impl.hpp +++ b/host/lib/usrp/usrp2/usrp2_impl.hpp @@ -33,7 +33,7 @@  #include <boost/shared_ptr.hpp>  #include <boost/function.hpp>  #include <uhd/transport/vrt_if_packet.hpp> -#include <uhd/transport/udp_simple.hpp> //mtu +#include <uhd/transport/udp_simple.hpp>  #include <uhd/transport/udp_zero_copy.hpp>  #include <uhd/usrp/dboard_manager.hpp>  #include <uhd/usrp/subdev_spec.hpp> @@ -93,14 +93,12 @@ public:          return _clock_ctrl->get_master_clock_rate();      } +    void handle_overflow(void); +  private:      size_t _index;      const size_t _recv_frame_size; - -    //properties for this mboard -    void get(const wax::obj &, wax::obj &); -    void set(const wax::obj &, const wax::obj &); -    uhd::usrp::subdev_spec_t _rx_subdev_spec, _tx_subdev_spec; +    bool _continuous_streaming;      //interfaces      usrp2_iface::sptr _iface; @@ -109,6 +107,11 @@ private:      usrp2_serdes_ctrl::sptr _serdes_ctrl;      usrp2_gps_ctrl::sptr _gps_ctrl; +    //properties for this mboard +    void get(const wax::obj &, wax::obj &); +    void set(const wax::obj &, const wax::obj &); +    uhd::usrp::subdev_spec_t _rx_subdev_spec, _tx_subdev_spec; +      //rx and tx dboard methods and objects      uhd::usrp::dboard_manager::sptr _dboard_manager;      uhd::usrp::dboard_iface::sptr _dboard_iface; diff --git a/host/lib/usrp/wrapper_utils.hpp b/host/lib/usrp/wrapper_utils.hpp index aee230fc0..6f9fdbfca 100644 --- a/host/lib/usrp/wrapper_utils.hpp +++ b/host/lib/usrp/wrapper_utils.hpp @@ -40,7 +40,7 @@ static inline void do_samp_rate_warning_message(  ){      static const double max_allowed_error = 1.0; //Sps      if (std::abs(target_rate - actual_rate) > max_allowed_error){ -        uhd::print_warning(str(boost::format( +        uhd::warning::post(str(boost::format(              "The hardware does not support the requested %s sample rate:\n"              "Target sample rate: %f MSps\n"              "Actual sample rate: %f MSps\n" @@ -55,7 +55,7 @@ static inline void do_tune_freq_warning_message(  ){      static const double max_allowed_error = 1.0; //Hz      if (std::abs(target_freq - actual_freq) > max_allowed_error){ -        uhd::print_warning(str(boost::format( +        uhd::warning::post(str(boost::format(              "The hardware does not support the requested %s frequency:\n"              "Target frequency: %f MHz\n"              "Actual frequency: %f MHz\n" diff --git a/host/lib/utils/thread_priority.cpp b/host/lib/utils/thread_priority.cpp index f09d1b1d6..40b74f655 100644 --- a/host/lib/utils/thread_priority.cpp +++ b/host/lib/utils/thread_priority.cpp @@ -26,7 +26,7 @@ bool uhd::set_thread_priority_safe(float priority, bool realtime){          set_thread_priority(priority, realtime);          return true;      }catch(const std::exception &e){ -        uhd::print_warning(str(boost::format( +        uhd::warning::post(str(boost::format(              "%s\n"              "Failed to set thread priority %d (%s):\n"              "Performance may be negatively affected.\n" diff --git a/host/lib/utils/warning.cpp b/host/lib/utils/warning.cpp index 8a7d35a23..05be7ae4d 100644 --- a/host/lib/utils/warning.cpp +++ b/host/lib/utils/warning.cpp @@ -17,16 +17,67 @@  #include <uhd/utils/warning.hpp>  #include <uhd/utils/algorithm.hpp> +#include <uhd/utils/static.hpp> +#include <uhd/types/dict.hpp>  #include <boost/foreach.hpp> +#include <sstream> +#include <stdexcept>  #include <iostream>  #include <vector>  using namespace uhd; -void uhd::print_warning(const std::string &msg){ -    //print the warning message -    std::cerr << std::endl << "Warning:" << std::endl; +/*********************************************************************** + * Registry implementation + **********************************************************************/ +//create the registry for the handlers +typedef uhd::dict<std::string, warning::handler_t> registry_t; +UHD_SINGLETON_FCN(registry_t, get_registry) + +//the default warning handler +static void stderr_warning(const std::string &msg){ +    std::cerr << msg; +} + +//register a default handler +UHD_STATIC_BLOCK(warning_register_default){ +    warning::register_handler("default", &stderr_warning); +} + +/*********************************************************************** + * Post + format + **********************************************************************/ +void warning::post(const std::string &msg){ +    std::stringstream ss; + +    //format the warning message +    ss << std::endl << "Warning:" << std::endl;      BOOST_FOREACH(const std::string &line, std::split_string(msg, "\n")){ -        std::cerr << "    " << line << std::endl; +        ss << "    " << line << std::endl; +    } + +    //post the formatted message +    BOOST_FOREACH(const std::string &name, get_registry().keys()){ +        get_registry()[name](ss.str());      }  } + +/*********************************************************************** + * Registry accessor functions + **********************************************************************/ +void warning::register_handler( +    const std::string &name, const handler_t &handler +){ +    get_registry()[name] = handler; +} + +warning::handler_t warning::unregister_handler(const std::string &name){ +    if (not get_registry().has_key(name)) throw std::runtime_error( +        "The warning registry does not have a handler registered to " + name +    ); +    return get_registry().pop(name); +} + +const std::vector<std::string> warning::registry_names(void){ +    return get_registry().keys(); +} diff --git a/host/test/tune_helper_test.cpp b/host/test/tune_helper_test.cpp index 1ef4af330..e0500ae3f 100644 --- a/host/test/tune_helper_test.cpp +++ b/host/test/tune_helper_test.cpp @@ -91,6 +91,44 @@ private:      }  }; +class dummy_subdev_bw : public wax::obj{ +private: +    void get(const wax::obj &key, wax::obj &val){ +        switch(key.as<subdev_prop_t>()){ + +        case SUBDEV_PROP_FREQ: +            val = _freq; +            return; + +        case SUBDEV_PROP_USE_LO_OFFSET: +            val = true; +            return; + +        case SUBDEV_PROP_BANDWIDTH: +            val = _bandwidth; +            return; + +        default: UHD_THROW_PROP_GET_ERROR(); +        } +    } + +    void set(const wax::obj &key, const wax::obj &val){ +        switch(key.as<subdev_prop_t>()){ +        case SUBDEV_PROP_FREQ: +            _freq = val.as<double>(); +            return; + +        case SUBDEV_PROP_BANDWIDTH: +            _bandwidth = val.as<double>(); +            return; + +        default: UHD_THROW_PROP_SET_ERROR(); +        } +    } + +    double _freq, _bandwidth; +}; +  class dummy_dsp : public wax::obj{  public:      dummy_dsp(double codec_rate): @@ -106,6 +144,10 @@ private:              val = _codec_rate;              return; +        case DSP_PROP_HOST_RATE: +            val = _host_rate; +            return; +          case DSP_PROP_FREQ_SHIFT:              val = _freq_shift;              return; @@ -125,11 +167,15 @@ private:              _freq_shift = val.as<double>();              return; +        case DSP_PROP_HOST_RATE: +            _host_rate = val.as<double>(); +            return; +          default: UHD_THROW_PROP_SET_ERROR();          }      } -    double _codec_rate, _freq_shift; +    double _codec_rate, _freq_shift, _host_rate;  };  /*********************************************************************** @@ -141,7 +187,7 @@ BOOST_AUTO_TEST_CASE(test_tune_helper_rx){      dummy_subdev subdev(1e6);      dummy_dsp dsp(100e6); -    std::cout << "Testing tune helper RX automatic LO offset" << std::endl; +    std::cout << "Testing tune helper RX automatic IF offset" << std::endl;      tune_result_t tr = tune_rx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0, 2.3451e9);      std::cout << tr.to_pp_string() << std::endl;      BOOST_CHECK_CLOSE(tr.actual_inter_freq, 2.345e9, tolerance); @@ -155,7 +201,7 @@ BOOST_AUTO_TEST_CASE(test_tune_helper_tx){      dummy_subdev subdev(1e6);      dummy_dsp dsp(100e6); -    std::cout << "Testing tune helper TX automatic LO offset" << std::endl; +    std::cout << "Testing tune helper TX automatic IF offset" << std::endl;      tune_result_t tr = tune_tx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0, 2.3451e9);      std::cout << tr.to_pp_string() << std::endl;      BOOST_CHECK_CLOSE(tr.actual_inter_freq, 2.345e9, tolerance); @@ -178,3 +224,30 @@ BOOST_AUTO_TEST_CASE(test_tune_helper_rx_nyquist){      double freq_derived = derive_freq_from_rx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0);      BOOST_CHECK_CLOSE(freq_derived, -45e6, tolerance);  } + +BOOST_AUTO_TEST_CASE(test_tune_helper_rx_lo_off){ +    dummy_subdev_bw subdev; +    dummy_dsp dsp(100e6); +    tune_result_t tr; + +    std::cout << "Testing tune helper RX automatic LO offset B >> fs" << std::endl; +    subdev[SUBDEV_PROP_BANDWIDTH] = double(40e6); +    dsp[DSP_PROP_HOST_RATE] = double(4e6); +    tr = tune_rx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0, 2.45e9); +    std::cout << tr.to_pp_string() << std::endl; +    BOOST_CHECK_CLOSE(tr.actual_inter_freq, 2.45e9+4e6/2, tolerance); + +    std::cout << "Testing tune helper RX automatic LO offset B > fs" << std::endl; +    subdev[SUBDEV_PROP_BANDWIDTH] = double(40e6); +    dsp[DSP_PROP_HOST_RATE] = double(25e6); +    tr = tune_rx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0, 2.45e9); +    std::cout << tr.to_pp_string() << std::endl; +    BOOST_CHECK_CLOSE(tr.actual_inter_freq, 2.45e9+(40e6-25e6)/2, tolerance); + +    std::cout << "Testing tune helper RX automatic LO offset B < fs" << std::endl; +    subdev[SUBDEV_PROP_BANDWIDTH] = double(20e6); +    dsp[DSP_PROP_HOST_RATE] = double(25e6); +    tr = tune_rx_subdev_and_dsp(subdev.get_link(), dsp.get_link(), 0, 2.45e9); +    std::cout << tr.to_pp_string() << std::endl; +    BOOST_CHECK_CLOSE(tr.actual_inter_freq, 2.45e9, tolerance); +} diff --git a/host/test/warning_test.cpp b/host/test/warning_test.cpp index 6202c4270..db19955de 100644 --- a/host/test/warning_test.cpp +++ b/host/test/warning_test.cpp @@ -19,9 +19,9 @@  #include <uhd/utils/warning.hpp>  #include <iostream> -BOOST_AUTO_TEST_CASE(test_print_warning){ +BOOST_AUTO_TEST_CASE(test_warning_post){      std::cerr << "---begin print test ---" << std::endl; -    uhd::print_warning( +    uhd::warning::post(          "This is a test print for a warning message.\n"          "And this is the second line of the test print.\n"      ); diff --git a/host/utils/CMakeLists.txt b/host/utils/CMakeLists.txt index a95864ca7..38e21c753 100644 --- a/host/utils/CMakeLists.txt +++ b/host/utils/CMakeLists.txt @@ -18,41 +18,41 @@  ########################################################################  # Utilities that get installed into the runtime path  ######################################################################## -ADD_EXECUTABLE(uhd_find_devices uhd_find_devices.cpp) -TARGET_LINK_LIBRARIES(uhd_find_devices uhd) - -ADD_EXECUTABLE(uhd_usrp_probe uhd_usrp_probe.cpp) -TARGET_LINK_LIBRARIES(uhd_usrp_probe uhd) - -INSTALL(TARGETS -    uhd_find_devices -    uhd_usrp_probe -    RUNTIME DESTINATION ${RUNTIME_DIR} +SET(util_runtime_sources +    uhd_find_devices.cpp +    uhd_usrp_probe.cpp  ) +#for each source: build an executable and install +FOREACH(util_source ${util_runtime_sources}) +    GET_FILENAME_COMPONENT(util_name ${util_source} NAME_WE) +    ADD_EXECUTABLE(${util_name} ${util_source}) +    TARGET_LINK_LIBRARIES(${util_name} uhd) +    INSTALL(TARGETS ${util_name} RUNTIME DESTINATION ${RUNTIME_DIR}) +ENDFOREACH(util_source) +  ########################################################################  # Utilities that get installed into the share path  ######################################################################## -ADD_EXECUTABLE(usrp2_addr_burner usrp2_addr_burner.cpp) -TARGET_LINK_LIBRARIES(usrp2_addr_burner uhd) - -ADD_EXECUTABLE(usrp_burn_db_eeprom usrp_burn_db_eeprom.cpp) -TARGET_LINK_LIBRARIES(usrp_burn_db_eeprom uhd) - -ADD_EXECUTABLE(usrp1_init_eeprom usrp1_init_eeprom.cpp) -TARGET_LINK_LIBRARIES(usrp1_init_eeprom uhd) - -ADD_EXECUTABLE(usrp1_serial_burner usrp1_serial_burner.cpp) -TARGET_LINK_LIBRARIES(usrp1_serial_burner uhd) - -INSTALL(TARGETS -    usrp2_addr_burner -    usrp_burn_db_eeprom -    usrp1_init_eeprom -    usrp1_serial_burner -    RUNTIME DESTINATION ${PKG_DATA_DIR}/utils +SET(util_share_sources +    usrp_burn_db_eeprom.cpp +    usrp_burn_mb_eeprom.cpp  ) +IF(ENABLE_USRP1) +    LIST(APPEND util_share_sources +        usrp1_init_eeprom.cpp +    ) +ENDIF(ENABLE_USRP1) + +#for each source: build an executable and install +FOREACH(util_source ${util_share_sources}) +    GET_FILENAME_COMPONENT(util_name ${util_source} NAME_WE) +    ADD_EXECUTABLE(${util_name} ${util_source}) +    TARGET_LINK_LIBRARIES(${util_name} uhd) +    INSTALL(TARGETS ${util_name} RUNTIME DESTINATION ${PKG_DATA_DIR}/utils) +ENDFOREACH(util_source) +  INSTALL(PROGRAMS      usrp2_recovery.py      usrp2_card_burner.py diff --git a/host/utils/uhd_usrp_probe.cpp b/host/utils/uhd_usrp_probe.cpp index 8947034d7..8cea52fa6 100644 --- a/host/utils/uhd_usrp_probe.cpp +++ b/host/utils/uhd_usrp_probe.cpp @@ -26,6 +26,7 @@  #include <uhd/usrp/dsp_props.hpp>  #include <uhd/usrp/subdev_props.hpp>  #include <uhd/usrp/dboard_id.hpp> +#include <uhd/usrp/mboard_eeprom.hpp>  #include <boost/program_options.hpp>  #include <boost/format.hpp>  #include <boost/foreach.hpp> @@ -123,10 +124,9 @@ static std::string get_mboard_pp_string(wax::obj mboard){      std::stringstream ss;      ss << boost::format("Mboard: %s") % mboard[usrp::MBOARD_PROP_NAME].as<std::string>() << std::endl;      //ss << std::endl; -    BOOST_FOREACH(const std::string &other_name, mboard[usrp::MBOARD_PROP_OTHERS].as<prop_names_t>()){ -        try{ -            ss << boost::format("%s: %s") % other_name % mboard[other_name].as<std::string>() << std::endl; -        } catch(...){} +    usrp::mboard_eeprom_t mb_eeprom = mboard[usrp::MBOARD_PROP_EEPROM_MAP].as<usrp::mboard_eeprom_t>(); +    BOOST_FOREACH(const std::string &key, mb_eeprom.keys()){ +        if (not mb_eeprom[key].empty()) ss << boost::format("%s: %s") % key % mb_eeprom[key] << std::endl;      }      BOOST_FOREACH(const std::string &dsp_name, mboard[usrp::MBOARD_PROP_RX_DSP_NAMES].as<prop_names_t>()){          ss << make_border(get_dsp_pp_string("RX", mboard[named_prop_t(usrp::MBOARD_PROP_RX_DSP, dsp_name)])); diff --git a/host/utils/usrp1_serial_burner.cpp b/host/utils/usrp1_serial_burner.cpp deleted file mode 100644 index bf7d3d3bb..000000000 --- a/host/utils/usrp1_serial_burner.cpp +++ /dev/null @@ -1,75 +0,0 @@ -// -// Copyright 2010 Ettus Research LLC -// -// This program is free software: you can redistribute it and/or modify -// it under the terms of the GNU General Public License as published by -// the Free Software Foundation, either version 3 of the License, or -// (at your option) any later version. -// -// This program is distributed in the hope that it will be useful, -// but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -// GNU General Public License for more details. -// -// You should have received a copy of the GNU General Public License -// along with this program.  If not, see <http://www.gnu.org/licenses/>. -// - -#include <uhd/utils/safe_main.hpp> -#include <uhd/device.hpp> -#include <uhd/usrp/device_props.hpp> -#include <boost/program_options.hpp> -#include <boost/format.hpp> -#include <iostream> - -namespace po = boost::program_options; - -int UHD_SAFE_MAIN(int argc, char *argv[]){ -    po::options_description desc("Allowed options"); -    desc.add_options() -        ("help", "help message") -        ("old", po::value<std::string>(), "old USRP serial number (optional)") -        ("new", po::value<std::string>(), "new USRP serial number") -    ; - -    po::variables_map vm; -    po::store(po::parse_command_line(argc, argv, desc), vm); -    po::notify(vm);  - -    //print the help message -    if (vm.count("help")){ -        std::cout << boost::format("USRP serial burner %s") % desc << std::endl; -        return ~0; -    } - -    if(vm.count("new") == 0) { -        std::cout << "error: must input --new arg" << std::endl; -        return ~0; -    } - -    //load the options into the address -    uhd::device_addr_t device_addr; -    device_addr["type"] = "usrp1"; -    if(vm.count("old")) device_addr["serial"] = vm["old"].as<std::string>(); - -    //find and create a control transport to do the writing. - -    uhd::device_addrs_t found_addrs = uhd::device::find(device_addr); - -    if (found_addrs.size() == 0){ -        std::cerr << "No USRP devices found" << std::endl; -        return ~0; -    } - -    for (size_t i = 0; i < found_addrs.size(); i++){ -        uhd::device::sptr dev = uhd::device::make(found_addrs[i]); -        wax::obj mb = (*dev)[uhd::usrp::DEVICE_PROP_MBOARD]; -        std::cout << "Writing serial number..." << std::endl; -        mb[std::string("serial")] = vm["new"].as<std::string>(); -        std::cout << "Reading back serial number: " << mb[std::string("serial")].as<std::string>() << std::endl; -    } - - -    std::cout << "Power-cycle the usrp for the changes to take effect." << std::endl; -    return 0; -} diff --git a/host/utils/usrp2_addr_burner.cpp b/host/utils/usrp2_addr_burner.cpp deleted file mode 100644 index f0e3434b7..000000000 --- a/host/utils/usrp2_addr_burner.cpp +++ /dev/null @@ -1,91 +0,0 @@ -// -// Copyright 2010 Ettus Research LLC -// -// This program is free software: you can redistribute it and/or modify -// it under the terms of the GNU General Public License as published by -// the Free Software Foundation, either version 3 of the License, or -// (at your option) any later version. -// -// This program is distributed in the hope that it will be useful, -// but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -// GNU General Public License for more details. -// -// You should have received a copy of the GNU General Public License -// along with this program.  If not, see <http://www.gnu.org/licenses/>. -// - -#include <uhd/utils/safe_main.hpp> -#include <uhd/device.hpp> -#include <uhd/usrp/device_props.hpp> -#include <boost/program_options.hpp> -#include <boost/format.hpp> -#include <iostream> - -namespace po = boost::program_options; - -int UHD_SAFE_MAIN(int argc, char *argv[]){ -    po::options_description desc("Allowed options"); -    desc.add_options() -        ("help", "help message") -        ("addr", po::value<std::string>(), "resolvable network address") -        ("new-ip", po::value<std::string>(), "new ip address (optional)") -        ("new-mac", po::value<std::string>(), "new mac address (optional)") -    ; - -    po::variables_map vm; -    po::store(po::parse_command_line(argc, argv, desc), vm); -    po::notify(vm);  - -    //print the help message -    if (vm.count("help")){ -        std::cout << boost::format("USRP2 Address Burner %s") % desc << std::endl; -        return ~0; -    } - -    //load the options into the address -    uhd::device_addr_t device_addr; -    device_addr["type"] = "usrp2"; -    if (vm.count("addr")){ -        device_addr["addr"] = vm["addr"].as<std::string>(); -    } -    else{ -        std::cerr << "Error: missing addr option" << std::endl; -        return ~0; -    } - -    //create a usrp2 device -    uhd::device::sptr u2_dev = uhd::device::make(device_addr); -    //FIXME usees the default mboard for now (until the mimo link is supported) -    wax::obj u2_mb = (*u2_dev)[uhd::usrp::DEVICE_PROP_MBOARD]; -    std::cout << std::endl; - -    //fetch and print current settings -    std::cout << "Fetching current settings from usrp2 eeprom:" << std::endl; -    std::string curr_ip = u2_mb[std::string("ip-addr")].as<std::string>(); -    std::cout << boost::format("  Current IP Address: %s") % curr_ip << std::endl; -    std::string curr_mac = u2_mb[std::string("mac-addr")].as<std::string>(); -    std::cout << boost::format("  Current MAC Address: %s") % curr_mac << std::endl; -    std::cout << "  Done" << std::endl << std::endl; - -    //try to set the new ip (if provided) -    if (vm.count("new-ip")){ -        std::cout << "Burning a new ip address into the usrp2 eeprom:" << std::endl; -        std::string new_ip = vm["new-ip"].as<std::string>(); -        std::cout << boost::format("  New IP Address: %s") % new_ip << std::endl; -        u2_mb[std::string("ip-addr")] = new_ip; -        std::cout << "  Done" << std::endl << std::endl; -    } - -    //try to set the new mac (if provided) -    if (vm.count("new-mac")){ -        std::cout << "Burning a new mac address into the usrp2 eeprom:" << std::endl; -        std::string new_mac = vm["new-mac"].as<std::string>(); -        std::cout << boost::format("  New MAC Address: %s") % new_mac << std::endl; -        u2_mb[std::string("mac-addr")] = new_mac; -        std::cout << "  Done" << std::endl << std::endl; -    } - -    std::cout << "Power-cycle the usrp2 for the changes to take effect." << std::endl; -    return 0; -} diff --git a/host/utils/usrp_burn_db_eeprom.cpp b/host/utils/usrp_burn_db_eeprom.cpp index 64ecf75d6..9afd71a22 100644 --- a/host/utils/usrp_burn_db_eeprom.cpp +++ b/host/utils/usrp_burn_db_eeprom.cpp @@ -58,10 +58,10 @@ int UHD_SAFE_MAIN(int argc, char *argv[]){      //print the help message      if (vm.count("help")){ -        std::cout << boost::format("USRP Burn DB EEPROM %s") % desc << std::endl; +        std::cout << boost::format("USRP Burn Daughterboard EEPROM %s") % desc << std::endl;          std::cout << boost::format( -            "Omit the id argument to perform readback,\n" -            "Or specify a new id to burn into the eeprom.\n" +            "Omit the ID argument to perform readback,\n" +            "Or specify a new ID to burn into the EEPROM.\n"          ) << std::endl;          return ~0;      } diff --git a/host/utils/usrp_burn_mb_eeprom.cpp b/host/utils/usrp_burn_mb_eeprom.cpp new file mode 100644 index 000000000..20e1b58b1 --- /dev/null +++ b/host/utils/usrp_burn_mb_eeprom.cpp @@ -0,0 +1,81 @@ +// +// Copyright 2010 Ettus Research LLC +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program.  If not, see <http://www.gnu.org/licenses/>. +// + +#include <uhd/utils/safe_main.hpp> +#include <uhd/device.hpp> +#include <uhd/usrp/device_props.hpp> +#include <uhd/usrp/mboard_props.hpp> +#include <uhd/usrp/mboard_eeprom.hpp> +#include <boost/program_options.hpp> +#include <boost/format.hpp> +#include <iostream> + +namespace po = boost::program_options; + +int UHD_SAFE_MAIN(int argc, char *argv[]){ +    std::string args, key, val; + +    po::options_description desc("Allowed options"); +    desc.add_options() +        ("help", "help message") +        ("args", po::value<std::string>(&args)->default_value(""), "device address args [default = \"\"]") +        ("key", po::value<std::string>(&key), "the indentifier for a value in EEPROM") +        ("val", po::value<std::string>(&val), "the new value to set, omit for readback") +    ; + +    po::variables_map vm; +    po::store(po::parse_command_line(argc, argv, desc), vm); +    po::notify(vm); + +    //print the help message +    if (vm.count("help") or not vm.count("key")){ +        std::cout << boost::format("USRP Burn Motherboard EEPROM %s") % desc << std::endl; +        std::cout << boost::format( +            "Omit the value argument to perform a readback,\n" +            "Or specify a new value to burn into the EEPROM.\n" +        ) << std::endl; +        return ~0; +    } + +    std::cout << "Creating USRP device from address: " + args << std::endl; +    uhd::device::sptr dev = uhd::device::make(args); +    //FIXME the default mboard for now (may be others) +    wax::obj mboard = (*dev)[uhd::usrp::DEVICE_PROP_MBOARD]; +    std::cout << std::endl; + +    if (true /*always readback*/){ +        std::cout << "Fetching current settings from EEPROM..." << std::endl; +        uhd::usrp::mboard_eeprom_t mb_eeprom = \ +            mboard[uhd::usrp::MBOARD_PROP_EEPROM_MAP].as<uhd::usrp::mboard_eeprom_t>(); +        if (not mb_eeprom.has_key(key)){ +            std::cerr << boost::format("Cannot find value for EEPROM[%s]") % key << std::endl; +            return ~0; +        } +        std::cout << boost::format("    EEPROM [\"%s\"] is \"%s\"") % key % mb_eeprom[key] << std::endl; +        std::cout << std::endl; +    } +    if (vm.count("val")){ +        uhd::usrp::mboard_eeprom_t mb_eeprom; mb_eeprom[key] = val; +        std::cout << boost::format("Setting EEPROM [\"%s\"] to \"%s\"...") % key % val << std::endl; +        mboard[uhd::usrp::MBOARD_PROP_EEPROM_MAP] = mb_eeprom; +        std::cout << "Power-cycle the USRP device for the changes to take effect." << std::endl; +        std::cout << std::endl; +    } + +    std::cout << "Done" << std::endl; +    return 0; +} | 
