From 7d69dcdcc318ccdf87038b732acbf2bf7c087b60 Mon Sep 17 00:00:00 2001 From: Martin Braun Date: Tue, 20 Aug 2019 10:00:47 -0700 Subject: Remove proto-RFNoC files This commit removes all files and parts of files that are used by proto-RFNoC only. uhd: Fix include CMakeLists.txt, add missing files --- host/lib/rfnoc/source_node_ctrl.cpp | 80 ------------------------------------- 1 file changed, 80 deletions(-) delete mode 100644 host/lib/rfnoc/source_node_ctrl.cpp (limited to 'host/lib/rfnoc/source_node_ctrl.cpp') diff --git a/host/lib/rfnoc/source_node_ctrl.cpp b/host/lib/rfnoc/source_node_ctrl.cpp deleted file mode 100644 index 23a17a463..000000000 --- a/host/lib/rfnoc/source_node_ctrl.cpp +++ /dev/null @@ -1,80 +0,0 @@ -// -// Copyright 2014 Ettus Research LLC -// Copyright 2018 Ettus Research, a National Instruments Company -// -// SPDX-License-Identifier: GPL-3.0-or-later -// - -#include -#include -#include -#include - -using namespace uhd::rfnoc; - -size_t source_node_ctrl::connect_downstream( - node_ctrl_base::sptr downstream_node, size_t port, const uhd::device_addr_t& args) -{ - boost::mutex::scoped_lock lock(_output_mutex); - port = _request_output_port(port, args); - _register_downstream_node(downstream_node, port); - return port; -} - -void source_node_ctrl::set_rx_streamer(bool active, const size_t port) -{ - UHD_RFNOC_BLOCK_TRACE() << "source_node_ctrl::set_rx_streamer() " << port << " -> " - << active; - - /* This will enable all upstream blocks: - for(const node_ctrl_base::node_map_pair_t upstream_node: list_upstream_nodes()) { - sptr curr_upstream_block_ctrl = - boost::dynamic_pointer_cast(upstream_node.second.lock()); - if (curr_upstream_block_ctrl) { - curr_upstream_block_ctrl->set_rx_streamer( - active, - get_upstream_port(upstream_node.first) - ); - } - } - */ - - // This only enables 1:1 (if output 1 is enabled, enable what's connected to input 1) - if (list_upstream_nodes().count(port)) { - source_node_ctrl::sptr this_upstream_block_ctrl = - boost::dynamic_pointer_cast( - list_upstream_nodes().at(port).lock()); - if (this_upstream_block_ctrl) { - this_upstream_block_ctrl->set_rx_streamer(active, get_upstream_port(port)); - } - } - - _rx_streamer_active[port] = active; -} - -size_t source_node_ctrl::_request_output_port( - const size_t suggested_port, const uhd::device_addr_t&) const -{ - return utils::node_map_find_first_free(_downstream_nodes, suggested_port); -} - -void source_node_ctrl::_register_downstream_node( - node_ctrl_base::sptr downstream_node, size_t port) -{ - // Do all the checks: - if (port == ANY_PORT) { - throw uhd::type_error( - str(boost::format("[%s] Invalid output port number (ANY).") % unique_id())); - } - if (_downstream_nodes.count(port) and not _downstream_nodes[port].expired()) { - throw uhd::runtime_error( - str(boost::format("On node %s, output port %d is already connected.") - % unique_id() % port)); - } - if (not boost::dynamic_pointer_cast(downstream_node)) { - throw uhd::type_error("Attempting to register a non-sink block as downstream."); - } - // Alles klar, Herr Kommissar :) - - _downstream_nodes[port] = boost::weak_ptr(downstream_node); -} -- cgit v1.2.3