diff options
Diffstat (limited to 'host/lib/rfnoc/source_node_ctrl.cpp')
| -rw-r--r-- | host/lib/rfnoc/source_node_ctrl.cpp | 42 |
1 files changed, 18 insertions, 24 deletions
diff --git a/host/lib/rfnoc/source_node_ctrl.cpp b/host/lib/rfnoc/source_node_ctrl.cpp index 54e65b16c..23a17a463 100644 --- a/host/lib/rfnoc/source_node_ctrl.cpp +++ b/host/lib/rfnoc/source_node_ctrl.cpp @@ -5,18 +5,16 @@ // SPDX-License-Identifier: GPL-3.0-or-later // -#include <uhd/utils/log.hpp> -#include <uhd/rfnoc/source_node_ctrl.hpp> #include <uhd/rfnoc/sink_node_ctrl.hpp> +#include <uhd/rfnoc/source_node_ctrl.hpp> +#include <uhd/utils/log.hpp> #include <uhdlib/rfnoc/utils.hpp> 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 -) { + 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); @@ -25,7 +23,8 @@ size_t source_node_ctrl::connect_downstream( 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 ; + 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()) { @@ -43,12 +42,10 @@ void source_node_ctrl::set_rx_streamer(bool active, const size_t port) // 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<source_node_ctrl>(list_upstream_nodes().at(port).lock()); + boost::dynamic_pointer_cast<source_node_ctrl>( + list_upstream_nodes().at(port).lock()); if (this_upstream_block_ctrl) { - this_upstream_block_ctrl->set_rx_streamer( - active, - get_upstream_port(port) - ); + this_upstream_block_ctrl->set_rx_streamer(active, get_upstream_port(port)); } } @@ -56,25 +53,23 @@ void source_node_ctrl::set_rx_streamer(bool active, const size_t port) } size_t source_node_ctrl::_request_output_port( - const size_t suggested_port, - const uhd::device_addr_t & -) const { + 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 -) { + 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() - )); + 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)); + 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<sink_node_ctrl>(downstream_node)) { throw uhd::type_error("Attempting to register a non-sink block as downstream."); @@ -83,4 +78,3 @@ void source_node_ctrl::_register_downstream_node( _downstream_nodes[port] = boost::weak_ptr<node_ctrl_base>(downstream_node); } - |