1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
//
// Copyright 2019 Ettus Research, a National Instruments Brand
//
// SPDX-License-Identifier: GPL-3.0-or-later
//
#include <uhd/exception.hpp>
#include <uhd/rfnoc/defaults.hpp>
#include <uhd/rfnoc/noc_block_base.hpp>
#include <uhd/rfnoc/register_iface.hpp>
#include <uhdlib/rfnoc/clock_iface.hpp>
using namespace uhd::rfnoc;
noc_block_base::make_args_t::~make_args_t() = default;
/******************************************************************************
* Structors
*****************************************************************************/
noc_block_base::noc_block_base(make_args_ptr make_args)
: register_iface_holder(std::move(make_args->reg_iface))
, _noc_id(make_args->noc_id)
, _block_id(make_args->block_id)
, _num_input_ports(make_args->num_input_ports)
, _num_output_ports(make_args->num_output_ports)
, _clock_iface(make_args->clk_iface)
, _mb_controller(std::move(make_args->mb_control))
, _block_args(make_args->args)
{
// First, create one tick_rate property for every port
_tick_rate_props.reserve(get_num_input_ports() + get_num_output_ports());
for (size_t input_port = 0; input_port < get_num_input_ports(); input_port++) {
_tick_rate_props.push_back(property_t<double>(PROP_KEY_TICK_RATE,
DEFAULT_TICK_RATE,
{res_source_info::INPUT_EDGE, input_port}));
}
for (size_t output_port = 0; output_port < get_num_output_ports(); output_port++) {
_tick_rate_props.push_back(property_t<double>(PROP_KEY_TICK_RATE,
DEFAULT_TICK_RATE,
{res_source_info::OUTPUT_EDGE, output_port}));
}
// Register all the tick_rate properties and create a default resolver
prop_ptrs_t prop_refs;
prop_refs.reserve(_tick_rate_props.size());
for (auto& prop : _tick_rate_props) {
prop_refs.insert(&prop);
register_property(&prop);
}
for (auto& prop : _tick_rate_props) {
auto prop_refs_copy = prop_refs;
add_property_resolver(
{&prop}, std::move(prop_refs_copy), [this, source_prop = &prop]() {
for (property_t<double>& tick_rate_prop : _tick_rate_props) {
tick_rate_prop = source_prop->get();
}
this->_set_tick_rate(source_prop->get());
});
}
// Now enable this clock iface
_clock_iface->set_running(true);
}
noc_block_base::~noc_block_base()
{
// nop
}
void noc_block_base::set_num_input_ports(const size_t num_ports)
{
if (num_ports > get_num_input_ports()) {
throw uhd::value_error(
"New number of input ports must not exceed current number!");
}
_num_input_ports = num_ports;
}
void noc_block_base::set_num_output_ports(const size_t num_ports)
{
if (num_ports > get_num_output_ports()) {
throw uhd::value_error(
"New number of output ports must not exceed current number!");
}
_num_output_ports = num_ports;
}
void noc_block_base::set_tick_rate(const double tick_rate)
{
if (_tick_rate == tick_rate) {
return;
}
// Update this node
_set_tick_rate(tick_rate);
// Now trigger property propagation
if (!_tick_rate_props.empty()) {
auto src_info = _tick_rate_props.at(0).get_src_info();
set_property<double>(PROP_KEY_TICK_RATE, tick_rate, src_info);
}
}
void noc_block_base::_set_tick_rate(const double tick_rate)
{
if (tick_rate == _tick_rate) {
return;
}
RFNOC_LOG_TRACE("Updating tick rate to " << (tick_rate / 1e6) << " MHz");
_clock_iface->set_freq(tick_rate);
_tick_rate = tick_rate;
}
std::shared_ptr<mb_controller> noc_block_base::get_mb_controller()
{
return _mb_controller;
}
|
