From b4e5df4080b276ff1bf7cf896bd60630cdaab652 Mon Sep 17 00:00:00 2001 From: Josh Blum Date: Thu, 18 Feb 2010 15:30:34 -0800 Subject: Flattened the usrp2 impl properties guts. Created init methods for various sub-parts. Added the ddc control (still needs update transaction). --- host/lib/usrp/mboard/usrp2.cpp | 10 +- host/lib/usrp/mboard/usrp2/dboard_impl.cpp | 106 ++++++--- host/lib/usrp/mboard/usrp2/dboard_impl.hpp | 50 ----- host/lib/usrp/mboard/usrp2/dboard_interface.cpp | 4 +- host/lib/usrp/mboard/usrp2/dboard_interface.hpp | 7 +- host/lib/usrp/mboard/usrp2/dsp_impl.cpp | 111 ++++++++++ host/lib/usrp/mboard/usrp2/impl_base.cpp | 276 ------------------------ host/lib/usrp/mboard/usrp2/impl_base.hpp | 78 ------- host/lib/usrp/mboard/usrp2/mboard_impl.cpp | 197 +++++++++++++++++ host/lib/usrp/mboard/usrp2/usrp2_impl.cpp | 90 ++++++++ host/lib/usrp/mboard/usrp2/usrp2_impl.hpp | 149 +++++++++++++ 11 files changed, 635 insertions(+), 443 deletions(-) delete mode 100644 host/lib/usrp/mboard/usrp2/dboard_impl.hpp create mode 100644 host/lib/usrp/mboard/usrp2/dsp_impl.cpp delete mode 100644 host/lib/usrp/mboard/usrp2/impl_base.cpp delete mode 100644 host/lib/usrp/mboard/usrp2/impl_base.hpp create mode 100644 host/lib/usrp/mboard/usrp2/mboard_impl.cpp create mode 100644 host/lib/usrp/mboard/usrp2/usrp2_impl.cpp create mode 100644 host/lib/usrp/mboard/usrp2/usrp2_impl.hpp (limited to 'host/lib/usrp/mboard') diff --git a/host/lib/usrp/mboard/usrp2.cpp b/host/lib/usrp/mboard/usrp2.cpp index 92f4daa49..f79ae851b 100644 --- a/host/lib/usrp/mboard/usrp2.cpp +++ b/host/lib/usrp/mboard/usrp2.cpp @@ -22,7 +22,7 @@ #include #include #include -#include "usrp2/impl_base.hpp" +#include "usrp2/usrp2_impl.hpp" using namespace uhd::usrp::mboard; @@ -92,8 +92,8 @@ usrp2::usrp2(const device_addr_t &device_addr){ ); //create the usrp2 implementation guts - _impl = impl_base::sptr( - new impl_base(ctrl_transport, data_transport) + _impl = usrp2_impl::sptr( + new usrp2_impl(ctrl_transport, data_transport) ); } @@ -105,12 +105,12 @@ usrp2::~usrp2(void){ * Get Properties **********************************************************************/ void usrp2::get(const wax::obj &key, wax::obj &val){ - return wax::cast(_impl)->get(key, val); + return wax::cast(_impl)->get(key, val); } /*********************************************************************** * Set Properties **********************************************************************/ void usrp2::set(const wax::obj &key, const wax::obj &val){ - return wax::cast(_impl)->set(key, val); + return wax::cast(_impl)->set(key, val); } diff --git a/host/lib/usrp/mboard/usrp2/dboard_impl.cpp b/host/lib/usrp/mboard/usrp2/dboard_impl.cpp index 309335cc7..7abce8e6a 100644 --- a/host/lib/usrp/mboard/usrp2/dboard_impl.cpp +++ b/host/lib/usrp/mboard/usrp2/dboard_impl.cpp @@ -15,62 +15,110 @@ // along with this program. If not, see . // -#include #include #include -#include -#include "dboard_impl.hpp" +#include "usrp2_impl.hpp" #include "dboard_interface.hpp" using namespace uhd; using namespace uhd::usrp; -dboard_impl::dboard_impl(uhd::usrp::dboard::manager::sptr mgr, type_t type){ - _mgr = mgr; - _type = type; -} +/*********************************************************************** + * Helper Methods + **********************************************************************/ +void usrp2_impl::dboard_init(void){ + //grab the dboard ids over the control line + usrp2_ctrl_data_t out_data; + out_data.id = htonl(USRP2_CTRL_ID_GIVE_ME_YOUR_DBOARD_IDS_BRO); + usrp2_ctrl_data_t in_data = ctrl_send_and_recv(out_data); + ASSERT_THROW(htonl(in_data.id) == USRP2_CTRL_ID_THESE_ARE_MY_DBOARD_IDS_DUDE); + std::cout << boost::format("rx id 0x%.2x, tx id 0x%.2x") + % ntohs(in_data.data.dboard_ids.rx_id) + % ntohs(in_data.data.dboard_ids.tx_id) << std::endl; + + //extract the dboard ids an convert them to enums + dboard::dboard_id_t rx_dboard_id = static_cast( + ntohs(in_data.data.dboard_ids.rx_id) + ); + dboard::dboard_id_t tx_dboard_id = static_cast( + ntohs(in_data.data.dboard_ids.tx_id) + ); -dboard_impl::~dboard_impl(void){ - /* NOP */ + //create a new dboard interface and manager + dboard::interface::sptr _dboard_interface( + new dboard_interface(this) + ); + dboard::manager::sptr _dboard_manager( + new dboard::manager(rx_dboard_id, tx_dboard_id, _dboard_interface) + ); + + //load dboards + _rx_dboards[""] = wax_obj_proxy( + boost::bind(&usrp2_impl::rx_dboard_get, this, _1, _2), + boost::bind(&usrp2_impl::rx_dboard_set, this, _1, _2) + ); + _tx_dboards[""] = wax_obj_proxy( + boost::bind(&usrp2_impl::tx_dboard_get, this, _1, _2), + boost::bind(&usrp2_impl::tx_dboard_set, this, _1, _2) + ); } -void dboard_impl::get(const wax::obj &key_, wax::obj &val){ +/*********************************************************************** + * RX DBoard Properties + **********************************************************************/ +void usrp2_impl::rx_dboard_get(const wax::obj &key_, wax::obj &val){ wax::obj key; std::string name; boost::tie(key, name) = extract_named_prop(key_); //handle the get request conditioned on the key switch(wax::cast(key)){ case DBOARD_PROP_NAME: - val = std::string("usrp2 dboard"); + val = std::string("usrp2 dboard (rx unit)"); return; case DBOARD_PROP_SUBDEV: - switch(_type){ - case TYPE_RX: - val = _mgr->get_rx_subdev(name); - return; - - case TYPE_TX: - val = _mgr->get_tx_subdev(name); - return; - } + val = _dboard_manager->get_rx_subdev(name); + return; case DBOARD_PROP_SUBDEV_NAMES: - switch(_type){ - case TYPE_RX: - val = _mgr->get_rx_subdev_names(); - return; + val = _dboard_manager->get_rx_subdev_names(); + return; + + case DBOARD_PROP_CODEC: + throw std::runtime_error("unhandled prop in usrp2 dboard"); + } +} + +void usrp2_impl::rx_dboard_set(const wax::obj &, const wax::obj &){ + throw std::runtime_error("Cannot set on usrp2 dboard"); +} - case TYPE_TX: - val = _mgr->get_tx_subdev_names(); - return; - } +/*********************************************************************** + * TX DBoard Properties + **********************************************************************/ +void usrp2_impl::tx_dboard_get(const wax::obj &key_, wax::obj &val){ + wax::obj key; std::string name; + boost::tie(key, name) = extract_named_prop(key_); + + //handle the get request conditioned on the key + switch(wax::cast(key)){ + case DBOARD_PROP_NAME: + val = std::string("usrp2 dboard (tx unit)"); + return; + + case DBOARD_PROP_SUBDEV: + val = _dboard_manager->get_tx_subdev(name); + return; + + case DBOARD_PROP_SUBDEV_NAMES: + val = _dboard_manager->get_tx_subdev_names(); + return; case DBOARD_PROP_CODEC: throw std::runtime_error("unhandled prop in usrp2 dboard"); } } -void dboard_impl::set(const wax::obj &, const wax::obj &){ +void usrp2_impl::tx_dboard_set(const wax::obj &, const wax::obj &){ throw std::runtime_error("Cannot set on usrp2 dboard"); } diff --git a/host/lib/usrp/mboard/usrp2/dboard_impl.hpp b/host/lib/usrp/mboard/usrp2/dboard_impl.hpp deleted file mode 100644 index a05bcd07b..000000000 --- a/host/lib/usrp/mboard/usrp2/dboard_impl.hpp +++ /dev/null @@ -1,50 +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 . -// - -#include -#include -#include -#include "fw_common.h" - -#ifndef INCLUDED_DBOARD_IMPL_HPP -#define INCLUDED_DBOARD_IMPL_HPP - -/*! - * The usrp2 dboard implementation: - * Provide the properties access for a dboard. - * Internally, hold a dboard manager and the direction. - * The usrp2 mboard base implementation will create - * two of these classes (one for rx and one for tx). - */ -class dboard_impl : boost::noncopyable, public wax::obj{ -public: - typedef boost::shared_ptr sptr; - enum type_t {TYPE_RX, TYPE_TX}; - - dboard_impl(uhd::usrp::dboard::manager::sptr manager, type_t type); - - ~dboard_impl(void); - - void get(const wax::obj &, wax::obj &); - void set(const wax::obj &, const wax::obj &); - -private: - uhd::usrp::dboard::manager::sptr _mgr; - type_t _type; -}; - -#endif /* INCLUDED_DBOARD_IMPL_HPP */ diff --git a/host/lib/usrp/mboard/usrp2/dboard_interface.cpp b/host/lib/usrp/mboard/usrp2/dboard_interface.cpp index 597654b3c..eb1caaa69 100644 --- a/host/lib/usrp/mboard/usrp2/dboard_interface.cpp +++ b/host/lib/usrp/mboard/usrp2/dboard_interface.cpp @@ -17,14 +17,14 @@ #include #include "dboard_interface.hpp" -#include "fw_common.h" +#include "usrp2_impl.hpp" using namespace uhd::usrp::dboard; /*********************************************************************** * Structors **********************************************************************/ -dboard_interface::dboard_interface(impl_base *impl){ +dboard_interface::dboard_interface(usrp2_impl *impl){ _impl = impl; } diff --git a/host/lib/usrp/mboard/usrp2/dboard_interface.hpp b/host/lib/usrp/mboard/usrp2/dboard_interface.hpp index 0f78dec17..1040e53ba 100644 --- a/host/lib/usrp/mboard/usrp2/dboard_interface.hpp +++ b/host/lib/usrp/mboard/usrp2/dboard_interface.hpp @@ -16,14 +16,15 @@ // #include -#include "impl_base.hpp" #ifndef INCLUDED_DBOARD_INTERFACE_HPP #define INCLUDED_DBOARD_INTERFACE_HPP +class usrp2_impl; //dummy class declaration + class dboard_interface : public uhd::usrp::dboard::interface{ public: - dboard_interface(impl_base *impl); + dboard_interface(usrp2_impl *impl); ~dboard_interface(void); @@ -56,7 +57,7 @@ private: bool readback ); - impl_base *_impl; + usrp2_impl *_impl; }; #endif /* INCLUDED_DBOARD_INTERFACE_HPP */ diff --git a/host/lib/usrp/mboard/usrp2/dsp_impl.cpp b/host/lib/usrp/mboard/usrp2/dsp_impl.cpp new file mode 100644 index 000000000..3c2471eb6 --- /dev/null +++ b/host/lib/usrp/mboard/usrp2/dsp_impl.cpp @@ -0,0 +1,111 @@ +// +// 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 . +// + +#include +#include +#include +#include "usrp2_impl.hpp" + +using namespace uhd; + +/*********************************************************************** + * Helper Methods + **********************************************************************/ +void usrp2_impl::ddc_init(size_t which){ + //create the ddc in the rx dsp dict + _rx_dsps[str(boost::format("ddc%d") % which)] = wax_obj_proxy( + boost::bind(&usrp2_impl::ddc_get, this, _1, _2, which), + boost::bind(&usrp2_impl::ddc_set, this, _1, _2, which) + ); + + //initial config and update + _ddc_decim[which] = 16; + _ddc_freq[which] = 0; + update_ddc_config(which); +} + +void usrp2_impl::update_ddc_config(size_t){ + //TODO +} + +/*********************************************************************** + * DDC Properties + **********************************************************************/ +void usrp2_impl::ddc_get(const wax::obj &key, wax::obj &val, size_t which){ + //handle the case where the key is an expected dsp property + if (key.type() == typeid(dsp_prop_t)){ + switch(wax::cast(key)){ + case DSP_PROP_NAME: + val = str(boost::format("usrp2 ddc%d") % which); + return; + + case DSP_PROP_OTHERS:{ + prop_names_t others = boost::assign::list_of + ("rate") + ("decim") + ("freq") + ; + val = others; + } + return; + } + } + + //handle string-based properties specific to this dsp + std::string key_name = wax::cast(key); + if (key_name == "rate"){ + val = get_master_clock_freq(); + return; + } + if (key_name == "decim"){ + val = _ddc_decim[which]; + return; + } + if (key_name == "freq"){ + val = _ddc_freq[which]; + return; + } + + throw std::invalid_argument(str( + boost::format("error getting: unknown key with name %s") % key_name + )); +} + +void usrp2_impl::ddc_set(const wax::obj &key, const wax::obj &val, size_t which){ + //handle string-based properties specific to this dsp + std::string key_name = wax::cast(key); + if (key_name == "decim"){ + size_t new_decim = wax::cast(val); + _ddc_decim[which] = new_decim; //shadow + update_ddc_config(which); + return; + } + if (key_name == "freq"){ + freq_t new_freq = wax::cast(val); + _ddc_freq[which] = new_freq; //shadow + update_ddc_config(which); + return; + } + + throw std::invalid_argument(str( + boost::format("error setting: unknown key with name %s") % key_name + )); +} + +/*********************************************************************** + * DUC Properties + **********************************************************************/ diff --git a/host/lib/usrp/mboard/usrp2/impl_base.cpp b/host/lib/usrp/mboard/usrp2/impl_base.cpp deleted file mode 100644 index e81b7cdb0..000000000 --- a/host/lib/usrp/mboard/usrp2/impl_base.cpp +++ /dev/null @@ -1,276 +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 . -// - -#include -#include -#include -#include -#include "impl_base.hpp" -#include "dboard_interface.hpp" - -using namespace uhd; -using namespace uhd::usrp; - -/*********************************************************************** - * Structors - **********************************************************************/ -impl_base::impl_base( - uhd::transport::udp::sptr ctrl_transport, - uhd::transport::udp::sptr data_transport -){ - _ctrl_transport = ctrl_transport; - _data_transport = data_transport; - - //grab the dboard ids over the control line - usrp2_ctrl_data_t out_data; - out_data.id = htonl(USRP2_CTRL_ID_GIVE_ME_YOUR_DBOARD_IDS_BRO); - usrp2_ctrl_data_t in_data = ctrl_send_and_recv(out_data); - ASSERT_THROW(htonl(in_data.id) == USRP2_CTRL_ID_THESE_ARE_MY_DBOARD_IDS_DUDE); - std::cout << boost::format("rx id 0x%.2x, tx id 0x%.2x") - % ntohs(in_data.data.dboard_ids.rx_id) - % ntohs(in_data.data.dboard_ids.tx_id) << std::endl; - - //extract the dboard ids an convert them to enums - dboard::dboard_id_t rx_dboard_id = static_cast( - ntohs(in_data.data.dboard_ids.rx_id) - ); - dboard::dboard_id_t tx_dboard_id = static_cast( - ntohs(in_data.data.dboard_ids.tx_id) - ); - - //create a new dboard interface and manager - dboard::interface::sptr _dboard_interface( - new dboard_interface(this) - ); - dboard::manager::sptr dboard_manager( - new dboard::manager(rx_dboard_id, tx_dboard_id, _dboard_interface) - ); - - //load dboards - _rx_dboards[""] = dboard_impl::sptr(new dboard_impl(dboard_manager, dboard_impl::TYPE_RX)); - _tx_dboards[""] = dboard_impl::sptr(new dboard_impl(dboard_manager, dboard_impl::TYPE_TX)); - - //TOD load dsps - - //init the pps source clock config - _pps_source_dict["sma"] = USRP2_PPS_SOURCE_SMA; - _pps_source_dict["mimo"] = USRP2_PPS_SOURCE_MIMO; - _pps_source = "sma"; - - //init the pps polarity clock config - _pps_polarity_dict["pos"] = USRP2_PPS_POLARITY_POS; - _pps_polarity_dict["neg"] = USRP2_PPS_POLARITY_NEG; - _pps_polarity = "neg"; - - //init the ref source clock config - _ref_source_dict["int"] = USRP2_REF_SOURCE_INT; - _ref_source_dict["sma"] = USRP2_REF_SOURCE_SMA; - _ref_source_dict["mimo"] = USRP2_REF_SOURCE_MIMO; - _ref_source = "int"; - - //update the clock config (sends a control packet) - update_clock_config(); -} - -impl_base::~impl_base(void){ - /* NOP */ -} - -/*********************************************************************** - * Misc Access Methods - **********************************************************************/ -double impl_base::get_master_clock_freq(void){ - return 100e6; -} - -void impl_base::update_clock_config(void){ - //setup the out data - usrp2_ctrl_data_t out_data; - out_data.id = htonl(USRP2_CTRL_ID_HERES_A_NEW_CLOCK_CONFIG_BRO); - out_data.data.clock_config.pps_source = _pps_source_dict [_pps_source]; - out_data.data.clock_config.pps_polarity = _pps_polarity_dict[_pps_polarity]; - out_data.data.clock_config.ref_source = _ref_source_dict [_ref_source]; - - //send and recv - usrp2_ctrl_data_t in_data = ctrl_send_and_recv(out_data); - ASSERT_THROW(htonl(in_data.id) == USRP2_CTRL_ID_GOT_THE_NEW_CLOCK_CONFIG_DUDE); -} - -/*********************************************************************** - * Control Send/Recv - **********************************************************************/ -usrp2_ctrl_data_t impl_base::ctrl_send_and_recv(const usrp2_ctrl_data_t &out_data){ - boost::mutex::scoped_lock lock(_ctrl_mutex); - - //fill in the seq number and send - usrp2_ctrl_data_t out_copy = out_data; - out_copy.seq = htonl(++_ctrl_seq_num); - _ctrl_transport->send(boost::asio::buffer(&out_copy, sizeof(usrp2_ctrl_data_t))); - - //loop and recieve until the time is up - size_t num_timeouts = 0; - while(true){ - uhd::shared_iovec iov = _ctrl_transport->recv(); - if (iov.len < sizeof(usrp2_ctrl_data_t)){ - //sleep a little so we dont burn cpu - if (num_timeouts++ > 50) break; - boost::this_thread::sleep(boost::posix_time::milliseconds(1)); - }else{ - //handle the received data - usrp2_ctrl_data_t in_data = *reinterpret_cast(iov.base); - if (ntohl(in_data.seq) == _ctrl_seq_num){ - return in_data; - } - //didnt get seq, continue on... - } - } - throw std::runtime_error("usrp2 no control response"); -} - -/*********************************************************************** - * Get Properties - **********************************************************************/ -void impl_base::get(const wax::obj &key_, wax::obj &val){ - wax::obj key; std::string name; - boost::tie(key, name) = extract_named_prop(key_); - - //handle the get request conditioned on the key - switch(wax::cast(key)){ - case MBOARD_PROP_NAME: - val = std::string("usrp2 mboard"); - return; - - case MBOARD_PROP_OTHERS: - val = prop_names_t(); //empty other props - return; - - case MBOARD_PROP_RX_DBOARD: - val = _rx_dboards[name]->get_link(); - return; - - case MBOARD_PROP_RX_DBOARD_NAMES: - val = prop_names_t(_rx_dboards.get_keys()); - return; - - case MBOARD_PROP_TX_DBOARD: - val = _tx_dboards[name]->get_link(); - return; - - case MBOARD_PROP_TX_DBOARD_NAMES: - val = prop_names_t(_tx_dboards.get_keys()); - return; - - case MBOARD_PROP_MTU: - // FIXME we dont know the real MTU... - // give them something to fragment about - val = size_t(1500); - return; - - case MBOARD_PROP_CLOCK_RATE: - val = freq_t(get_master_clock_freq()); - return; - - case MBOARD_PROP_RX_DSP: - throw std::runtime_error("unhandled prop in usrp2 mboard"); - - case MBOARD_PROP_RX_DSP_NAMES: - throw std::runtime_error("unhandled prop in usrp2 mboard"); - - case MBOARD_PROP_TX_DSP: - throw std::runtime_error("unhandled prop in usrp2 mboard"); - - case MBOARD_PROP_TX_DSP_NAMES: - throw std::runtime_error("unhandled prop in usrp2 mboard"); - - case MBOARD_PROP_PPS_SOURCE: - val = _pps_source; - return; - - case MBOARD_PROP_PPS_SOURCE_NAMES: - val = prop_names_t(_pps_source_dict.get_keys()); - return; - - case MBOARD_PROP_PPS_POLARITY: - val = _pps_polarity; - return; - - case MBOARD_PROP_REF_SOURCE: - val = _ref_source; - return; - - case MBOARD_PROP_REF_SOURCE_NAMES: - val = prop_names_t(_ref_source_dict.get_keys()); - return; - - case MBOARD_PROP_TIME_NOW: - case MBOARD_PROP_TIME_NEXT_PPS: - throw std::runtime_error("Error: trying to get write-only property on usrp2 mboard"); - - } -} - -/*********************************************************************** - * Set Properties - **********************************************************************/ -void impl_base::set(const wax::obj &key, const wax::obj &val){ - //handle the get request conditioned on the key - switch(wax::cast(key)){ - - case MBOARD_PROP_PPS_SOURCE:{ - std::string name = wax::cast(val); - ASSERT_THROW(_pps_source_dict.has_key(name)); - _pps_source = name; //shadow - update_clock_config(); - } - return; - - case MBOARD_PROP_PPS_POLARITY:{ - std::string name = wax::cast(val); - ASSERT_THROW(_pps_polarity_dict.has_key(name)); - _pps_polarity = name; //shadow - update_clock_config(); - } - return; - - case MBOARD_PROP_REF_SOURCE:{ - std::string name = wax::cast(val); - ASSERT_THROW(_ref_source_dict.has_key(name)); - _ref_source = name; //shadow - update_clock_config(); - } - return; - - case MBOARD_PROP_NAME: - case MBOARD_PROP_OTHERS: - case MBOARD_PROP_MTU: - case MBOARD_PROP_CLOCK_RATE: - case MBOARD_PROP_RX_DSP: - case MBOARD_PROP_RX_DSP_NAMES: - case MBOARD_PROP_TX_DSP: - case MBOARD_PROP_TX_DSP_NAMES: - case MBOARD_PROP_RX_DBOARD: - case MBOARD_PROP_RX_DBOARD_NAMES: - case MBOARD_PROP_TX_DBOARD: - case MBOARD_PROP_TX_DBOARD_NAMES: - case MBOARD_PROP_PPS_SOURCE_NAMES: - case MBOARD_PROP_REF_SOURCE_NAMES: - case MBOARD_PROP_TIME_NOW: - case MBOARD_PROP_TIME_NEXT_PPS: - throw std::runtime_error("Error: trying to set read-only property on usrp2 mboard"); - - } -} diff --git a/host/lib/usrp/mboard/usrp2/impl_base.hpp b/host/lib/usrp/mboard/usrp2/impl_base.hpp deleted file mode 100644 index b808cf2b1..000000000 --- a/host/lib/usrp/mboard/usrp2/impl_base.hpp +++ /dev/null @@ -1,78 +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 . -// - -#include -#include -#include -#include -#include -#include "dboard_impl.hpp" -#include "fw_common.h" - -#ifndef INCLUDED_IMPL_BASE_HPP -#define INCLUDED_IMPL_BASE_HPP - -class impl_base : boost::noncopyable, public wax::obj{ -public: - typedef boost::shared_ptr sptr; - - /*! - * Create a new usrp2 impl base. - * \param ctrl_transport the udp transport for control - * \param data_transport the udp transport for data - */ - impl_base( - uhd::transport::udp::sptr ctrl_transport, - uhd::transport::udp::sptr data_transport - ); - - ~impl_base(void); - - //performs a control transaction - usrp2_ctrl_data_t ctrl_send_and_recv(const usrp2_ctrl_data_t &); - - //properties access methods - void get(const wax::obj &, wax::obj &); - void set(const wax::obj &, const wax::obj &); - - //misc access methods - double get_master_clock_freq(void); - void update_clock_config(void); - -private: - //udp transports for control and data - uhd::transport::udp::sptr _ctrl_transport; - uhd::transport::udp::sptr _data_transport; - - //private vars for dealing with send/recv control - uint32_t _ctrl_seq_num; - boost::mutex _ctrl_mutex; - - //containers for the dboard objects - uhd::dict _rx_dboards; - uhd::dict _tx_dboards; - - //shadows for various settings - std::string _pps_source, _pps_polarity, _ref_source; - - //mappings from clock config strings to over the wire enums - uhd::dict _pps_source_dict; - uhd::dict _pps_polarity_dict; - uhd::dict _ref_source_dict; -}; - -#endif /* INCLUDED_IMPL_BASE_HPP */ diff --git a/host/lib/usrp/mboard/usrp2/mboard_impl.cpp b/host/lib/usrp/mboard/usrp2/mboard_impl.cpp new file mode 100644 index 000000000..0dec3a473 --- /dev/null +++ b/host/lib/usrp/mboard/usrp2/mboard_impl.cpp @@ -0,0 +1,197 @@ +// +// 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 . +// + +#include +#include +#include "usrp2_impl.hpp" + +using namespace uhd; + +/*********************************************************************** + * Helper Methods + **********************************************************************/ +void usrp2_impl::init_clock_config(void){ + //init the pps source clock config + _pps_source_dict["sma"] = USRP2_PPS_SOURCE_SMA; + _pps_source_dict["mimo"] = USRP2_PPS_SOURCE_MIMO; + _pps_source = "sma"; + + //init the pps polarity clock config + _pps_polarity_dict["pos"] = USRP2_PPS_POLARITY_POS; + _pps_polarity_dict["neg"] = USRP2_PPS_POLARITY_NEG; + _pps_polarity = "neg"; + + //init the ref source clock config + _ref_source_dict["int"] = USRP2_REF_SOURCE_INT; + _ref_source_dict["sma"] = USRP2_REF_SOURCE_SMA; + _ref_source_dict["mimo"] = USRP2_REF_SOURCE_MIMO; + _ref_source = "int"; + + //update the clock config (sends a control packet) + update_clock_config(); +} + +void usrp2_impl::update_clock_config(void){ + //setup the out data + usrp2_ctrl_data_t out_data; + out_data.id = htonl(USRP2_CTRL_ID_HERES_A_NEW_CLOCK_CONFIG_BRO); + out_data.data.clock_config.pps_source = _pps_source_dict [_pps_source]; + out_data.data.clock_config.pps_polarity = _pps_polarity_dict[_pps_polarity]; + out_data.data.clock_config.ref_source = _ref_source_dict [_ref_source]; + + //send and recv + usrp2_ctrl_data_t in_data = ctrl_send_and_recv(out_data); + ASSERT_THROW(htonl(in_data.id) == USRP2_CTRL_ID_GOT_THE_NEW_CLOCK_CONFIG_DUDE); +} + +/*********************************************************************** + * MBoard Get Properties + **********************************************************************/ +void usrp2_impl::get(const wax::obj &key_, wax::obj &val){ + wax::obj key; std::string name; + boost::tie(key, name) = extract_named_prop(key_); + + //handle the get request conditioned on the key + switch(wax::cast(key)){ + case MBOARD_PROP_NAME: + val = std::string("usrp2 mboard"); + return; + + case MBOARD_PROP_OTHERS: + val = prop_names_t(); //empty other props + return; + + case MBOARD_PROP_RX_DBOARD: + val = _rx_dboards[name].get_link(); + return; + + case MBOARD_PROP_RX_DBOARD_NAMES: + val = prop_names_t(_rx_dboards.get_keys()); + return; + + case MBOARD_PROP_TX_DBOARD: + val = _tx_dboards[name].get_link(); + return; + + case MBOARD_PROP_TX_DBOARD_NAMES: + val = prop_names_t(_tx_dboards.get_keys()); + return; + + case MBOARD_PROP_MTU: + // FIXME we dont know the real MTU... + // give them something to fragment about + val = size_t(1500); + return; + + case MBOARD_PROP_CLOCK_RATE: + val = freq_t(get_master_clock_freq()); + return; + + case MBOARD_PROP_RX_DSP: + val = _rx_dsps[name].get_link(); + return; + + case MBOARD_PROP_RX_DSP_NAMES: + val = prop_names_t(_rx_dsps.get_keys()); + return; + + case MBOARD_PROP_TX_DSP: + val = _tx_dsps[name].get_link(); + return; + + case MBOARD_PROP_TX_DSP_NAMES: + val = prop_names_t(_tx_dsps.get_keys()); + return; + + case MBOARD_PROP_PPS_SOURCE: + val = _pps_source; + return; + + case MBOARD_PROP_PPS_SOURCE_NAMES: + val = prop_names_t(_pps_source_dict.get_keys()); + return; + + case MBOARD_PROP_PPS_POLARITY: + val = _pps_polarity; + return; + + case MBOARD_PROP_REF_SOURCE: + val = _ref_source; + return; + + case MBOARD_PROP_REF_SOURCE_NAMES: + val = prop_names_t(_ref_source_dict.get_keys()); + return; + + case MBOARD_PROP_TIME_NOW: + case MBOARD_PROP_TIME_NEXT_PPS: + throw std::runtime_error("Error: trying to get write-only property on usrp2 mboard"); + + } +} + +/*********************************************************************** + * MBoard Set Properties + **********************************************************************/ +void usrp2_impl::set(const wax::obj &key, const wax::obj &val){ + //handle the get request conditioned on the key + switch(wax::cast(key)){ + + case MBOARD_PROP_PPS_SOURCE:{ + std::string name = wax::cast(val); + ASSERT_THROW(_pps_source_dict.has_key(name)); + _pps_source = name; //shadow + update_clock_config(); + } + return; + + case MBOARD_PROP_PPS_POLARITY:{ + std::string name = wax::cast(val); + ASSERT_THROW(_pps_polarity_dict.has_key(name)); + _pps_polarity = name; //shadow + update_clock_config(); + } + return; + + case MBOARD_PROP_REF_SOURCE:{ + std::string name = wax::cast(val); + ASSERT_THROW(_ref_source_dict.has_key(name)); + _ref_source = name; //shadow + update_clock_config(); + } + return; + + case MBOARD_PROP_NAME: + case MBOARD_PROP_OTHERS: + case MBOARD_PROP_MTU: + case MBOARD_PROP_CLOCK_RATE: + case MBOARD_PROP_RX_DSP: + case MBOARD_PROP_RX_DSP_NAMES: + case MBOARD_PROP_TX_DSP: + case MBOARD_PROP_TX_DSP_NAMES: + case MBOARD_PROP_RX_DBOARD: + case MBOARD_PROP_RX_DBOARD_NAMES: + case MBOARD_PROP_TX_DBOARD: + case MBOARD_PROP_TX_DBOARD_NAMES: + case MBOARD_PROP_PPS_SOURCE_NAMES: + case MBOARD_PROP_REF_SOURCE_NAMES: + case MBOARD_PROP_TIME_NOW: + case MBOARD_PROP_TIME_NEXT_PPS: + throw std::runtime_error("Error: trying to set read-only property on usrp2 mboard"); + + } +} diff --git a/host/lib/usrp/mboard/usrp2/usrp2_impl.cpp b/host/lib/usrp/mboard/usrp2/usrp2_impl.cpp new file mode 100644 index 000000000..1b985daaa --- /dev/null +++ b/host/lib/usrp/mboard/usrp2/usrp2_impl.cpp @@ -0,0 +1,90 @@ +// +// 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 . +// + +#include +#include +#include +#include +#include +#include +#include "usrp2_impl.hpp" + +using namespace uhd; + +/*********************************************************************** + * Structors + **********************************************************************/ +usrp2_impl::usrp2_impl( + uhd::transport::udp::sptr ctrl_transport, + uhd::transport::udp::sptr data_transport +){ + _ctrl_transport = ctrl_transport; + _data_transport = data_transport; + + //init the tx and rx dboards + dboard_init(); + + //init the ddcs (however many we have) + for (size_t i = 0; i < _num_ddc; i++){ + ddc_init(i); + } + + //initialize the clock configuration + init_clock_config(); +} + +usrp2_impl::~usrp2_impl(void){ + /* NOP */ +} + +/*********************************************************************** + * Misc Access Methods + **********************************************************************/ +double usrp2_impl::get_master_clock_freq(void){ + return 100e6; +} + +/*********************************************************************** + * Control Send/Recv + **********************************************************************/ +usrp2_ctrl_data_t usrp2_impl::ctrl_send_and_recv(const usrp2_ctrl_data_t &out_data){ + boost::mutex::scoped_lock lock(_ctrl_mutex); + + //fill in the seq number and send + usrp2_ctrl_data_t out_copy = out_data; + out_copy.seq = htonl(++_ctrl_seq_num); + _ctrl_transport->send(boost::asio::buffer(&out_copy, sizeof(usrp2_ctrl_data_t))); + + //loop and recieve until the time is up + size_t num_timeouts = 0; + while(true){ + uhd::shared_iovec iov = _ctrl_transport->recv(); + if (iov.len < sizeof(usrp2_ctrl_data_t)){ + //sleep a little so we dont burn cpu + if (num_timeouts++ > 50) break; + boost::this_thread::sleep(boost::posix_time::milliseconds(1)); + }else{ + //handle the received data + usrp2_ctrl_data_t in_data = *reinterpret_cast(iov.base); + if (ntohl(in_data.seq) == _ctrl_seq_num){ + return in_data; + } + //didnt get seq, continue on... + } + } + throw std::runtime_error("usrp2 no control response"); +} diff --git a/host/lib/usrp/mboard/usrp2/usrp2_impl.hpp b/host/lib/usrp/mboard/usrp2/usrp2_impl.hpp new file mode 100644 index 000000000..2475b3a3c --- /dev/null +++ b/host/lib/usrp/mboard/usrp2/usrp2_impl.hpp @@ -0,0 +1,149 @@ +// +// 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 . +// + +#include +#include +#include +#include +#include +#include +#include "fw_common.h" + +#ifndef INCLUDED_USRP2_IMPL_HPP +#define INCLUDED_USRP2_IMPL_HPP + +/*! + * Simple wax obj proxy class: + * Provides a wax obj interface for a set and a get function. + * This allows us to create nested properties structures + * while maintaining flattened code within the implementation. + */ +class wax_obj_proxy : public wax::obj{ +public: + typedef boost::function get_t; + typedef boost::function set_t; + + wax_obj_proxy(void){ + /* NOP */ + } + + wax_obj_proxy(const get_t &get, const set_t &set){ + _get = get; + _set = set; + }; + + ~wax_obj_proxy(void){ + /* NOP */ + } + + void get(const wax::obj &key, wax::obj &val){ + return _get(key, val); + } + + void set(const wax::obj &key, const wax::obj &val){ + return _set(key, val); + } + +private: + get_t _get; + set_t _set; +}; + +/*! + * USRP2 implementation guts: + * The implementation details are encapsulated here. + * Handles properties on the mboard, dboard, dsps... + */ +class usrp2_impl : boost::noncopyable, public wax::obj{ +public: + typedef boost::shared_ptr sptr; + + /*! + * Create a new usrp2 impl base. + * \param ctrl_transport the udp transport for control + * \param data_transport the udp transport for data + */ + usrp2_impl( + uhd::transport::udp::sptr ctrl_transport, + uhd::transport::udp::sptr data_transport + ); + + ~usrp2_impl(void); + + //properties interface + void get(const wax::obj &, wax::obj &); + void set(const wax::obj &, const wax::obj &); + + //performs a control transaction + usrp2_ctrl_data_t ctrl_send_and_recv(const usrp2_ctrl_data_t &); + + //misc access methods + double get_master_clock_freq(void); + +private: + //udp transports for control and data + uhd::transport::udp::sptr _ctrl_transport; + uhd::transport::udp::sptr _data_transport; + + //private vars for dealing with send/recv control + uint32_t _ctrl_seq_num; + boost::mutex _ctrl_mutex; + + //methods and shadows for clock configuration + std::string _pps_source, _pps_polarity, _ref_source; + void init_clock_config(void); + void update_clock_config(void); + + //mappings from clock config strings to over the wire enums + uhd::dict _pps_source_dict; + uhd::dict _pps_polarity_dict; + uhd::dict _ref_source_dict; + + //rx and tx dboard methods and objects + uhd::usrp::dboard::manager::sptr _dboard_manager; + void dboard_init(void); + + //properties interface for rx dboard + void rx_dboard_get(const wax::obj &, wax::obj &); + void rx_dboard_set(const wax::obj &, const wax::obj &); + uhd::dict _rx_dboards; + + //properties interface for tx dboard + void tx_dboard_get(const wax::obj &, wax::obj &); + void tx_dboard_set(const wax::obj &, const wax::obj &); + uhd::dict _tx_dboards; + + //methods and shadows for the ddc dsp + static const size_t _num_ddc = 1; + size_t _ddc_decim[_num_ddc]; + double _ddc_freq[_num_ddc]; + void ddc_init(size_t which); + void update_ddc_config(size_t which_ddc); + + //properties interface for ddc + void ddc_get(const wax::obj &, wax::obj &, size_t which); + void ddc_set(const wax::obj &, const wax::obj &, size_t which); + uhd::dict _rx_dsps; + + //properties interface for duc + void duc_get(const wax::obj &, wax::obj &); + void duc_set(const wax::obj &, const wax::obj &); + uhd::dict _tx_dsps; + +}; + +#endif /* INCLUDED_USRP2_IMPL_HPP */ -- cgit v1.2.3