1 files changed, 113 insertions, 0 deletions
diff --git a/host/lib/usrp/dboard/magnesium/magnesium_ad9371_iface.cpp b/host/lib/usrp/dboard/magnesium/magnesium_ad9371_iface.cpp
new file mode 100644
index 000000000..2fe31f066
--- /dev/null
+++ b/host/lib/usrp/dboard/magnesium/magnesium_ad9371_iface.cpp
@@ -0,0 +1,113 @@
+//
+// Copyright 2017 Ettus Research, a National Instruments Company
+//
+// SPDX-License-Identifier: GPL-3.0
+//
+
+#include "magnesium_ad9371_iface.hpp"
+#include <uhd/utils/log.hpp>
+#include <uhd/utils/log.hpp>
+
+using namespace uhd;
+
+namespace {
+    /*! Return a valid 'which' string for use with AD9371 API calls
+     *
+     * These strings take the form of "RX1", "TX2", ...
+     */
+    std::string _get_which(
+        const direction_t dir,
+        const size_t chan
+    ) {
+        UHD_ASSERT_THROW(dir == RX_DIRECTION or dir == TX_DIRECTION);
+        UHD_ASSERT_THROW(chan == 0 or chan == 1);
+        return str(boost::format("%s%d")
+                   % (dir == RX_DIRECTION ? "RX" : "TX")
+                   % (chan+1)
+        );
+    }
+}
+
+/******************************************************************************
+ * Structors
+ *****************************************************************************/
+magnesium_ad9371_iface::magnesium_ad9371_iface(
+    uhd::rpc_client::sptr rpcc,
+    const size_t slot_idx
+) : _rpcc(rpcc)
+  , _slot_idx(slot_idx)
+  , _rpc_prefix((slot_idx == 0) ? "db_0_" : "db_1_")
+  , _L((slot_idx == 0) ? "AD9371-0" : "AD9371-1")
+{
+    UHD_LOG_TRACE(_L,
+        "Initialized controls with RPC prefix " << _rpc_prefix <<
+        " for slot " << _slot_idx);
+}
+
+double magnesium_ad9371_iface::set_frequency(
+        const double freq,
+        const size_t chan,
+        const direction_t dir
+) {
+    // Note: This sets the frequency for both channels (1 and 2).
+    auto which = _get_which(dir, chan);
+    UHD_LOG_TRACE(_L,
+            "Calling " << _rpc_prefix << "set_freq on "
+            << which << " with " << freq);
+    auto actual_freq =
+        _rpcc->request_with_token<double>(_rpc_prefix + "set_freq",
+                which, freq, false);
+    UHD_LOG_TRACE(_L,
+            _rpc_prefix << "set_freq returned " << actual_freq);
+    return actual_freq;
+}
+
+double magnesium_ad9371_iface::set_gain(
+        const double gain,
+        const size_t chan,
+        const direction_t dir
+) {
+    auto which = _get_which(dir, chan);
+    UHD_LOG_TRACE(_L, "Calling " << _rpc_prefix << "set_gain on " << which << " with " << gain);
+    auto retval = _rpcc->request_with_token<double>(_rpc_prefix + "set_gain", which, gain);
+    UHD_LOG_TRACE(_L, _rpc_prefix << "set_gain returned " << retval);
+
+    return retval;
+    //return 0.0;
+}
+
+
+double magnesium_ad9371_iface::set_bandwidth(const double bandwidth, const size_t chan, const direction_t dir)
+{
+    // TODO: implement
+    UHD_LOG_WARNING(_L, "Ignoring attempt to set bandwidth");
+    return 0.0;
+}
+
+double magnesium_ad9371_iface::get_frequency(
+    const size_t chan,
+    const direction_t dir
+) {
+    auto which = _get_which(dir, chan);
+    UHD_LOG_TRACE(_L, "calling " << _rpc_prefix << "get_freq on " << which);
+    auto retval = _rpcc->request_with_token<double>(_rpc_prefix + "get_freq", which);
+    UHD_LOG_TRACE(_L, _rpc_prefix << "get_freq returned " << retval);
+    return retval;
+}
+
+double magnesium_ad9371_iface::get_gain(const size_t chan, const direction_t dir)
+{
+    auto which = _get_which(dir, chan);
+    UHD_LOG_TRACE(_L, "calling " << _rpc_prefix << "get_gain on " << which);
+    auto retval = _rpcc->request_with_token<double>(_rpc_prefix + "get_gain", which);
+    UHD_LOG_TRACE(_L, _rpc_prefix << "get_gain returned " << retval);
+    return retval;
+}
+
+double magnesium_ad9371_iface::get_bandwidth(const size_t chan, const direction_t dir)
+{
+    // TODO: implement
+    UHD_LOG_WARNING(_L, "Ignoring attempt to get bandwidth");
+    return 0.0;
+}
+