aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--host/lib/CMakeLists.txt4
-rw-r--r--host/lib/deps/CMakeLists.txt2
-rw-r--r--host/lib/usrp/CMakeLists.txt2
-rw-r--r--host/lib/usrp/dboard/eiscat/CMakeLists.txt4
-rw-r--r--host/lib/usrp/dboard/magnesium/CMakeLists.txt4
-rw-r--r--host/lib/usrp/mpmd/CMakeLists.txt (renamed from host/lib/usrp/netd/CMakeLists.txt)9
-rw-r--r--host/lib/usrp/mpmd/mpmd_impl.cpp (renamed from host/lib/usrp/netd/netd_impl.cpp)60
-rw-r--r--host/lib/usrp/mpmd/mpmd_impl.hpp (renamed from host/lib/usrp/netd/netd_impl.hpp)32
8 files changed, 57 insertions, 60 deletions
diff --git a/host/lib/CMakeLists.txt b/host/lib/CMakeLists.txt
index a1c5648ad..bfc8ddc11 100644
--- a/host/lib/CMakeLists.txt
+++ b/host/lib/CMakeLists.txt
@@ -72,7 +72,7 @@ LIBUHD_REGISTER_COMPONENT("USRP1" ENABLE_USRP1 ON "ENABLE_LIBUHD;ENABLE_USB" OFF
LIBUHD_REGISTER_COMPONENT("USRP2" ENABLE_USRP2 ON "ENABLE_LIBUHD" OFF OFF)
LIBUHD_REGISTER_COMPONENT("X300" ENABLE_X300 ON "ENABLE_LIBUHD" OFF OFF)
LIBUHD_REGISTER_COMPONENT("N230" ENABLE_N230 ON "ENABLE_LIBUHD" OFF OFF)
-LIBUHD_REGISTER_COMPONENT("NETD" ENABLE_NETD ON "ENABLE_LIBUHD" OFF OFF)
+LIBUHD_REGISTER_COMPONENT("MPMD" ENABLE_MPMD ON "ENABLE_LIBUHD" OFF OFF)
LIBUHD_REGISTER_COMPONENT("OctoClock" ENABLE_OCTOCLOCK ON "ENABLE_LIBUHD" OFF OFF)
########################################################################
@@ -165,7 +165,7 @@ ENDIF(MSVC)
########################################################################
# Setup libuhd library
########################################################################
-IF(ENABLE_NETD)
+IF(ENABLE_MPMD)
INCLUDE_DIRECTORIES(deps/rpclib/include)
ADD_SUBDIRECTORY(deps)
LIST(APPEND libuhd_sources $<TARGET_OBJECTS:uhd_rpclib>)
diff --git a/host/lib/deps/CMakeLists.txt b/host/lib/deps/CMakeLists.txt
index bcb89d29a..8f292d4f2 100644
--- a/host/lib/deps/CMakeLists.txt
+++ b/host/lib/deps/CMakeLists.txt
@@ -14,6 +14,6 @@
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
-IF(ENABLE_NETD)
+IF(ENABLE_MPMD)
ADD_SUBDIRECTORY(rpclib)
ENDIF()
diff --git a/host/lib/usrp/CMakeLists.txt b/host/lib/usrp/CMakeLists.txt
index 0f8172d41..7515a9bb0 100644
--- a/host/lib/usrp/CMakeLists.txt
+++ b/host/lib/usrp/CMakeLists.txt
@@ -41,7 +41,7 @@ INCLUDE_SUBDIRECTORY(cores)
INCLUDE_SUBDIRECTORY(dboard)
INCLUDE_SUBDIRECTORY(common)
INCLUDE_SUBDIRECTORY(device3)
-INCLUDE_SUBDIRECTORY(netd)
+INCLUDE_SUBDIRECTORY(mpmd)
INCLUDE_SUBDIRECTORY(usrp1)
INCLUDE_SUBDIRECTORY(usrp2)
INCLUDE_SUBDIRECTORY(b100)
diff --git a/host/lib/usrp/dboard/eiscat/CMakeLists.txt b/host/lib/usrp/dboard/eiscat/CMakeLists.txt
index bd55dcc14..c1ff10b3d 100644
--- a/host/lib/usrp/dboard/eiscat/CMakeLists.txt
+++ b/host/lib/usrp/dboard/eiscat/CMakeLists.txt
@@ -15,10 +15,10 @@
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
-IF(ENABLE_NETD AND ENABLE_EISCAT)
+IF(ENABLE_MPMD AND ENABLE_EISCAT)
LIST(APPEND EISCAT_SOURCES
${CMAKE_CURRENT_SOURCE_DIR}/eiscat_radio_ctrl_impl.cpp
)
LIBUHD_APPEND_SOURCES(${EISCAT_SOURCES})
-ENDIF(ENABLE_NETD AND ENABLE_EISCAT)
+ENDIF(ENABLE_MPMD AND ENABLE_EISCAT)
diff --git a/host/lib/usrp/dboard/magnesium/CMakeLists.txt b/host/lib/usrp/dboard/magnesium/CMakeLists.txt
index 6d3f53fba..07677b8c9 100644
--- a/host/lib/usrp/dboard/magnesium/CMakeLists.txt
+++ b/host/lib/usrp/dboard/magnesium/CMakeLists.txt
@@ -15,10 +15,10 @@
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
-IF(ENABLE_NETD)
+IF(ENABLE_MPMD)
LIST(APPEND MAGNESIUM_SOURCES
${CMAKE_CURRENT_SOURCE_DIR}/magnesium_radio_ctrl_impl.cpp
)
LIBUHD_APPEND_SOURCES(${MAGNESIUM_SOURCES})
-ENDIF(ENABLE_NETD)
+ENDIF(ENABLE_MPMD)
diff --git a/host/lib/usrp/netd/CMakeLists.txt b/host/lib/usrp/mpmd/CMakeLists.txt
index a33c978c8..5ff1f36eb 100644
--- a/host/lib/usrp/netd/CMakeLists.txt
+++ b/host/lib/usrp/mpmd/CMakeLists.txt
@@ -19,11 +19,8 @@
# This file included, use CMake directory variables
########################################################################
-########################################################################
-# Conditionally configure the X300 support
-########################################################################
-IF(ENABLE_NETD)
+IF(ENABLE_MPMD)
LIBUHD_APPEND_SOURCES(
- ${CMAKE_CURRENT_SOURCE_DIR}/netd_impl.cpp
+ ${CMAKE_CURRENT_SOURCE_DIR}/mpmd_impl.cpp
)
-ENDIF(ENABLE_NETD)
+ENDIF(ENABLE_MPMD)
diff --git a/host/lib/usrp/netd/netd_impl.cpp b/host/lib/usrp/mpmd/mpmd_impl.cpp
index d57fbd901..1caec550e 100644
--- a/host/lib/usrp/netd/netd_impl.cpp
+++ b/host/lib/usrp/mpmd/mpmd_impl.cpp
@@ -15,7 +15,7 @@
// along with this program. If not, see <http://www.gnu.org/licenses/>.
//
-#include "netd_impl.hpp"
+#include "mpmd_impl.hpp"
#include <../device3/device3_impl.hpp>
#include <uhd/exception.hpp>
#include <uhd/property_tree.hpp>
@@ -35,7 +35,7 @@
using namespace uhd;
-netd_mboard_impl::netd_mboard_impl(const std::string& addr)
+mpmd_mboard_impl::mpmd_mboard_impl(const std::string& addr)
: rpc(addr, MPM_RPC_PORT)
{
UHD_LOG_TRACE("MPMD", "Initializing mboard, IP address: " << addr);
@@ -46,11 +46,11 @@ netd_mboard_impl::netd_mboard_impl(const std::string& addr)
// Get initial claim on mboard
_rpc_token = rpc.call<std::string>("claim", "UHD - Session 01"); // make this configurable with device_addr?
if (_rpc_token.empty()){
- throw uhd::value_error("netd device claiming failed!");
+ throw uhd::value_error("mpmd device claiming failed!");
}
_claimer_task = task::make([this] {
if (not this->claim()) {
- throw uhd::value_error("netd device reclaiming loop failed!");
+ throw uhd::value_error("mpmd device reclaiming loop failed!");
};
boost::this_thread::sleep_for(boost::chrono::milliseconds(1000));
});
@@ -73,7 +73,7 @@ netd_mboard_impl::netd_mboard_impl(const std::string& addr)
//}
}
-uhd::sid_t netd_mboard_impl::allocate_sid(const uint16_t port,
+uhd::sid_t mpmd_mboard_impl::allocate_sid(const uint16_t port,
const uhd::sid_t address,
const uint32_t xbar_src_addr,
const uint32_t xbar_src_port){
@@ -81,25 +81,25 @@ uhd::sid_t netd_mboard_impl::allocate_sid(const uint16_t port,
address.get(), xbar_src_addr, xbar_src_port);
return sid;
}
-netd_mboard_impl::~netd_mboard_impl() {}
+mpmd_mboard_impl::~mpmd_mboard_impl() {}
-netd_mboard_impl::uptr netd_mboard_impl::make(const std::string& addr)
+mpmd_mboard_impl::uptr mpmd_mboard_impl::make(const std::string& addr)
{
- netd_mboard_impl::uptr mb =
- netd_mboard_impl::uptr(new netd_mboard_impl(addr));
+ mpmd_mboard_impl::uptr mb =
+ mpmd_mboard_impl::uptr(new mpmd_mboard_impl(addr));
// implicit move
return mb;
}
-bool netd_mboard_impl::claim() { return rpc.call<bool>("reclaim", _rpc_token); }
+bool mpmd_mboard_impl::claim() { return rpc.call<bool>("reclaim", _rpc_token); }
-netd_impl::netd_impl(const device_addr_t& device_addr)
+mpmd_impl::mpmd_impl(const device_addr_t& device_addr)
: usrp::device3_impl()
, _device_addr(device_addr)
, _sid_framer(0)
{
- UHD_LOGGER_INFO("NETD") << "NETD initialization sequence. Device args: " << device_addr.to_string();
- _tree->create<std::string>("/name").set("NETD - Series device");
+ UHD_LOGGER_INFO("MPMD") << "MPMD initialization sequence. Device args: " << device_addr.to_string();
+ _tree->create<std::string>("/name").set("MPMD - Series device");
const device_addrs_t device_args = separate_device_addr(device_addr);
_mb.reserve(device_args.size());
for (size_t mb_i = 0; mb_i < device_args.size(); ++mb_i) {
@@ -120,13 +120,13 @@ netd_impl::netd_impl(const device_addr_t& device_addr)
}
}
-netd_impl::~netd_impl() {}
+mpmd_impl::~mpmd_impl() {}
-netd_mboard_impl::uptr netd_impl::setup_mb(const size_t mb_i,
+mpmd_mboard_impl::uptr mpmd_impl::setup_mb(const size_t mb_i,
const uhd::device_addr_t& dev_addr)
{
const fs_path mb_path = "/mboards/" + std::to_string(mb_i);
- netd_mboard_impl::uptr mb = netd_mboard_impl::make(dev_addr["addr"]);
+ mpmd_mboard_impl::uptr mb = mpmd_mboard_impl::make(dev_addr["addr"]);
mb->initialization_done = false;
std::vector<std::string> addrs;
const std::string eth0_addr = dev_addr["addr"];
@@ -170,7 +170,7 @@ netd_mboard_impl::uptr netd_impl::setup_mb(const size_t mb_i,
// TODO this does not consider the liberio use case!
-uhd::device_addr_t netd_impl::get_rx_hints(size_t /* mb_index */)
+uhd::device_addr_t mpmd_impl::get_rx_hints(size_t /* mb_index */)
{
//device_addr_t rx_hints = _mb[mb_index].recv_args;
device_addr_t rx_hints; // TODO don't ignore what the user tells us
@@ -182,10 +182,10 @@ uhd::device_addr_t netd_impl::get_rx_hints(size_t /* mb_index */)
//For nirio, the buffer size is not configurable by the user
#if defined(UHD_PLATFORM_MACOS) || defined(UHD_PLATFORM_BSD)
//limit buffer resize on macos or it will error
- rx_hints["recv_buff_size"] = boost::lexical_cast<std::string>(NETD_RX_SW_BUFF_SIZE_ETH_MACOS);
+ rx_hints["recv_buff_size"] = boost::lexical_cast<std::string>(MPMD_RX_SW_BUFF_SIZE_ETH_MACOS);
#elif defined(UHD_PLATFORM_LINUX) || defined(UHD_PLATFORM_WIN32)
//set to half-a-second of buffering at max rate
- rx_hints["recv_buff_size"] = boost::lexical_cast<std::string>(NETD_RX_SW_BUFF_SIZE_ETH);
+ rx_hints["recv_buff_size"] = boost::lexical_cast<std::string>(MPMD_RX_SW_BUFF_SIZE_ETH);
#endif
}
return rx_hints;
@@ -201,7 +201,7 @@ uhd::device_addr_t netd_impl::get_rx_hints(size_t /* mb_index */)
// }
// Everything fake below here
-both_xports_t netd_impl::make_transport(const sid_t& address,
+both_xports_t mpmd_impl::make_transport(const sid_t& address,
usrp::device3_impl::xport_type_t xport_type,
const uhd::device_addr_t& args)
{
@@ -251,7 +251,7 @@ both_xports_t netd_impl::make_transport(const sid_t& address,
return xports;
}
-device_addrs_t netd_find_with_addr(const device_addr_t& hint_)
+device_addrs_t mpmd_find_with_addr(const device_addr_t& hint_)
{
transport::udp_simple::sptr comm = transport::udp_simple::make_broadcast(
hint_["addr"], std::to_string(MPM_DISCOVERY_PORT));
@@ -293,7 +293,7 @@ device_addrs_t netd_find_with_addr(const device_addr_t& hint_)
}
device_addr_t new_addr;
new_addr["addr"] = recv_addr;
- new_addr["type"] = "netd"; // hwd will overwrite this
+ new_addr["type"] = "mpmd"; // hwd will overwrite this
// remove ident string and put other informations into device_addr dict
result.erase(result.begin());
// parse key-value pairs in the discovery string and add them to the
@@ -310,7 +310,7 @@ device_addrs_t netd_find_with_addr(const device_addr_t& hint_)
return addrs;
};
-device_addrs_t netd_find(const device_addr_t& hint_)
+device_addrs_t mpmd_find(const device_addr_t& hint_)
{
// handle cases:
//
@@ -334,7 +334,7 @@ device_addrs_t netd_find(const device_addr_t& hint_)
if (not hint.has_key("addr")) { // maybe allow other attributes as well
return device_addrs_t();
}
- device_addrs_t reply_addrs = netd_find_with_addr(hint);
+ device_addrs_t reply_addrs = mpmd_find_with_addr(hint);
if (reply_addrs.size() > 1) {
throw uhd::value_error(
str(boost::format("Could not resolve device hint \"%s\" to "
@@ -353,26 +353,26 @@ device_addrs_t netd_find(const device_addr_t& hint_)
if (hint.has_key("addr")) {
// is this safe?
- return netd_find_with_addr(hint);
+ return mpmd_find_with_addr(hint);
}
for (const transport::if_addrs_t& if_addr : transport::get_if_addrs()) {
device_addr_t new_hint = hint;
new_hint["addr"] = if_addr.bcast;
- device_addrs_t reply_addrs = netd_find_with_addr(new_hint);
+ device_addrs_t reply_addrs = mpmd_find_with_addr(new_hint);
addrs.insert(addrs.begin(), reply_addrs.begin(), reply_addrs.end());
}
return addrs;
}
-static device::sptr netd_make(const device_addr_t& device_addr)
+static device::sptr mpmd_make(const device_addr_t& device_addr)
{
- return device::sptr(boost::make_shared<netd_impl>(device_addr));
+ return device::sptr(boost::make_shared<mpmd_impl>(device_addr));
}
-UHD_STATIC_BLOCK(register_netd_device)
+UHD_STATIC_BLOCK(register_mpmd_device)
{
- device::register_device(&netd_find, &netd_make, device::USRP);
+ device::register_device(&mpmd_find, &mpmd_make, device::USRP);
}
// vim: sw=4 expandtab:
diff --git a/host/lib/usrp/netd/netd_impl.hpp b/host/lib/usrp/mpmd/mpmd_impl.hpp
index b8a3988f2..3b6a4b213 100644
--- a/host/lib/usrp/netd/netd_impl.hpp
+++ b/host/lib/usrp/mpmd/mpmd_impl.hpp
@@ -15,8 +15,8 @@
// along with this program. If not, see <http://www.gnu.org/licenses/>.
//
-#ifndef INCLUDED_NETD_IMPL_HPP
-#define INCLUDED_NETD_IMPL_HPP
+#ifndef INCLUDED_MPMD_IMPL_HPP
+#define INCLUDED_MPMD_IMPL_HPP
#include "../../utils/rpc.hpp"
#include "../device3/device3_impl.hpp"
#include <uhd/stream.hpp>
@@ -25,14 +25,14 @@
#include <uhd/utils/tasks.hpp>
#include <map>
-static const size_t NETD_RX_SW_BUFF_SIZE_ETH = 0x2000000;//32MiB For an ~8k frame size any size >32MiB is just wasted buffer space
-static const size_t NETD_RX_SW_BUFF_SIZE_ETH_MACOS = 0x100000; //1Mib
+static const size_t MPMD_RX_SW_BUFF_SIZE_ETH = 0x2000000;//32MiB For an ~8k frame size any size >32MiB is just wasted buffer space
+static const size_t MPMD_RX_SW_BUFF_SIZE_ETH_MACOS = 0x100000; //1Mib
static const size_t MPM_DISCOVERY_PORT = 49600;
static const size_t MPM_RPC_PORT = 49601;
static const char MPM_DISCOVERY_CMD[] = "MPM-DISC";
static const char MPM_ECHO_CMD[] = "MPM-ECHO";
-static const size_t NETD_10GE_DATA_FRAME_MAX_SIZE = 8000; // CHDR packet size in bytes
+static const size_t MPMD_10GE_DATA_FRAME_MAX_SIZE = 8000; // CHDR packet size in bytes
struct frame_size_t
{
@@ -40,13 +40,13 @@ struct frame_size_t
size_t send_frame_size;
};
-class netd_mboard_impl
+class mpmd_mboard_impl
{
public:
- using uptr = std::unique_ptr<netd_mboard_impl>;
+ using uptr = std::unique_ptr<mpmd_mboard_impl>;
using dev_info = std::map<std::string, std::string>;
- netd_mboard_impl(const std::string& addr);
- ~netd_mboard_impl();
+ mpmd_mboard_impl(const std::string& addr);
+ ~mpmd_mboard_impl();
static uptr make(const std::string& addr);
bool initialization_done = false;
@@ -69,13 +69,13 @@ class netd_mboard_impl
uhd::task::sptr _claimer_task;
};
-class netd_impl : public uhd::usrp::device3_impl
+class mpmd_impl : public uhd::usrp::device3_impl
{
public:
- netd_impl(const uhd::device_addr_t& device_addr);
- ~netd_impl();
+ mpmd_impl(const uhd::device_addr_t& device_addr);
+ ~mpmd_impl();
- netd_mboard_impl::uptr setup_mb(const size_t mb_i,
+ mpmd_mboard_impl::uptr setup_mb(const size_t mb_i,
const uhd::device_addr_t& dev_addr);
uhd::both_xports_t make_transport(const uhd::sid_t&,
uhd::usrp::device3_impl::xport_type_t,
@@ -85,9 +85,9 @@ class netd_impl : public uhd::usrp::device3_impl
uhd::device_addr_t get_rx_hints(size_t mb_index);
uhd::device_addr_t _device_addr;
- std::vector<netd_mboard_impl::uptr> _mb;
+ std::vector<mpmd_mboard_impl::uptr> _mb;
size_t _sid_framer;
};
-uhd::device_addrs_t netd_find(const uhd::device_addr_t& hint_);
-#endif /* INCLUDED_NETD_IMPL_HPP */
+uhd::device_addrs_t mpmd_find(const uhd::device_addr_t& hint_);
+#endif /* INCLUDED_MPMD_IMPL_HPP */
// vim: sw=4 expandtab:
generated by cgit v1.2.3 (git 2.46.0) at 2025-10-31 06:20:41 +0000