diff options
Diffstat (limited to 'host/lib/usrp/mboard')
| -rw-r--r-- | host/lib/usrp/mboard/usrp2.cpp | 10 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/dboard_impl.cpp | 106 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/dboard_impl.hpp | 50 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/dboard_interface.cpp | 4 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/dboard_interface.hpp | 7 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/dsp_impl.cpp | 111 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/impl_base.hpp | 78 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/mboard_impl.cpp (renamed from host/lib/usrp/mboard/usrp2/impl_base.cpp) | 115 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/usrp2_impl.cpp | 90 | ||||
| -rw-r--r-- | host/lib/usrp/mboard/usrp2/usrp2_impl.hpp | 149 |
10 files changed, 456 insertions, 264 deletions
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 <boost/format.hpp> #include <boost/thread.hpp> #include <netinet/in.h> -#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_base::sptr>(_impl)->get(key, val); + return wax::cast<usrp2_impl::sptr>(_impl)->get(key, val); } /*********************************************************************** * Set Properties **********************************************************************/ void usrp2::set(const wax::obj &key, const wax::obj &val){ - return wax::cast<impl_base::sptr>(_impl)->set(key, val); + return wax::cast<usrp2_impl::sptr>(_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 <http://www.gnu.org/licenses/>. // -#include <boost/format.hpp> #include <uhd/utils.hpp> #include <uhd/props.hpp> -#include <iostream> -#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<dboard::dboard_id_t>( + ntohs(in_data.data.dboard_ids.rx_id) + ); + dboard::dboard_id_t tx_dboard_id = static_cast<dboard::dboard_id_t>( + 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<dboard_prop_t>(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<dboard_prop_t>(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 <http://www.gnu.org/licenses/>. -// - -#include <uhd/usrp/dboard/manager.hpp> -#include <boost/utility.hpp> -#include <boost/shared_ptr.hpp> -#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<dboard_impl> 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 <uhd/utils.hpp> #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 <uhd/usrp/dboard/interface.hpp> -#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 <http://www.gnu.org/licenses/>. +// + +#include <uhd/utils.hpp> +#include <uhd/props.hpp> +#include <boost/assign/list_of.hpp> +#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<dsp_prop_t>(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<std::string>(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<std::string>(key); + if (key_name == "decim"){ + size_t new_decim = wax::cast<size_t>(val); + _ddc_decim[which] = new_decim; //shadow + update_ddc_config(which); + return; + } + if (key_name == "freq"){ + freq_t new_freq = wax::cast<freq_t>(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.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 <http://www.gnu.org/licenses/>. -// - -#include <boost/utility.hpp> -#include <boost/thread.hpp> -#include <boost/shared_ptr.hpp> -#include <uhd/transport/udp.hpp> -#include <uhd/dict.hpp> -#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<impl_base> 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<std::string, dboard_impl::sptr> _rx_dboards; - uhd::dict<std::string, dboard_impl::sptr> _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<std::string, usrp2_pps_source_t> _pps_source_dict; - uhd::dict<std::string, usrp2_pps_polarity_t> _pps_polarity_dict; - uhd::dict<std::string, usrp2_ref_source_t> _ref_source_dict; -}; - -#endif /* INCLUDED_IMPL_BASE_HPP */ diff --git a/host/lib/usrp/mboard/usrp2/impl_base.cpp b/host/lib/usrp/mboard/usrp2/mboard_impl.cpp index e81b7cdb0..0dec3a473 100644 --- a/host/lib/usrp/mboard/usrp2/impl_base.cpp +++ b/host/lib/usrp/mboard/usrp2/mboard_impl.cpp @@ -15,57 +15,16 @@ // along with this program. If not, see <http://www.gnu.org/licenses/>. // -#include <boost/format.hpp> #include <uhd/utils.hpp> #include <uhd/props.hpp> -#include <iostream> -#include "impl_base.hpp" -#include "dboard_interface.hpp" +#include "usrp2_impl.hpp" using namespace uhd; -using namespace uhd::usrp; /*********************************************************************** - * Structors + * Helper Methods **********************************************************************/ -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<dboard::dboard_id_t>( - ntohs(in_data.data.dboard_ids.rx_id) - ); - dboard::dboard_id_t tx_dboard_id = static_cast<dboard::dboard_id_t>( - 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 - +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; @@ -86,18 +45,7 @@ impl_base::impl_base( 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){ +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); @@ -111,40 +59,9 @@ void impl_base::update_clock_config(void){ } /*********************************************************************** - * Control Send/Recv + * MBoard Get Properties **********************************************************************/ -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<const usrp2_ctrl_data_t *>(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){ +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_); @@ -159,7 +76,7 @@ void impl_base::get(const wax::obj &key_, wax::obj &val){ return; case MBOARD_PROP_RX_DBOARD: - val = _rx_dboards[name]->get_link(); + val = _rx_dboards[name].get_link(); return; case MBOARD_PROP_RX_DBOARD_NAMES: @@ -167,7 +84,7 @@ void impl_base::get(const wax::obj &key_, wax::obj &val){ return; case MBOARD_PROP_TX_DBOARD: - val = _tx_dboards[name]->get_link(); + val = _tx_dboards[name].get_link(); return; case MBOARD_PROP_TX_DBOARD_NAMES: @@ -185,16 +102,20 @@ void impl_base::get(const wax::obj &key_, wax::obj &val){ return; case MBOARD_PROP_RX_DSP: - throw std::runtime_error("unhandled prop in usrp2 mboard"); + val = _rx_dsps[name].get_link(); + return; case MBOARD_PROP_RX_DSP_NAMES: - throw std::runtime_error("unhandled prop in usrp2 mboard"); + val = prop_names_t(_rx_dsps.get_keys()); + return; case MBOARD_PROP_TX_DSP: - throw std::runtime_error("unhandled prop in usrp2 mboard"); + val = _tx_dsps[name].get_link(); + return; case MBOARD_PROP_TX_DSP_NAMES: - throw std::runtime_error("unhandled prop in usrp2 mboard"); + val = prop_names_t(_tx_dsps.get_keys()); + return; case MBOARD_PROP_PPS_SOURCE: val = _pps_source; @@ -224,9 +145,9 @@ void impl_base::get(const wax::obj &key_, wax::obj &val){ } /*********************************************************************** - * Set Properties + * MBoard Set Properties **********************************************************************/ -void impl_base::set(const wax::obj &key, const wax::obj &val){ +void usrp2_impl::set(const wax::obj &key, const wax::obj &val){ //handle the get request conditioned on the key switch(wax::cast<mboard_prop_t>(key)){ 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 <http://www.gnu.org/licenses/>. +// + +#include <uhd/usrp/dboard/manager.hpp> +#include <boost/format.hpp> +#include <boost/bind.hpp> +#include <uhd/utils.hpp> +#include <uhd/props.hpp> +#include <iostream> +#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<const usrp2_ctrl_data_t *>(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 <http://www.gnu.org/licenses/>. +// + +#include <uhd/dict.hpp> +#include <boost/thread.hpp> +#include <boost/shared_ptr.hpp> +#include <boost/function.hpp> +#include <uhd/transport/udp.hpp> +#include <uhd/usrp/dboard/manager.hpp> +#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<void(const wax::obj &, wax::obj &)> get_t; + typedef boost::function<void(const wax::obj &, const wax::obj &)> 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<usrp2_impl> 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<std::string, usrp2_pps_source_t> _pps_source_dict; + uhd::dict<std::string, usrp2_pps_polarity_t> _pps_polarity_dict; + uhd::dict<std::string, usrp2_ref_source_t> _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<std::string, wax_obj_proxy> _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<std::string, wax_obj_proxy> _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<std::string, wax_obj_proxy> _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<std::string, wax_obj_proxy> _tx_dsps; + +}; + +#endif /* INCLUDED_USRP2_IMPL_HPP */ |